aboutsummaryrefslogtreecommitdiffstats
path: root/src/main/java/org/onap/aai/spike/schema/OxmConfigTranslator.java
diff options
context:
space:
mode:
authorMichael Arrastia <MArrasti@amdocs.com>2018-11-28 17:27:31 +0000
committerMichael Arrastia <MArrasti@amdocs.com>2018-11-28 17:27:31 +0000
commitd894ec51a86cfb4d711d3c053d8aa46759584456 (patch)
treec60a1680d735c5c76bc1e9ec625be6140d4b7667 /src/main/java/org/onap/aai/spike/schema/OxmConfigTranslator.java
parent9eb82afe62f6891d1e140fd9003e1ceb7df119ee (diff)
Upgrade version of aai-common
* Configure Spike with schema ingestion beans. * Update OXMModelLoader and EdgeRulesLoader to make use of schema ingestion beans. Here there is an acknowledged awkward marrying of bean creation and static method use. * Update tests to mock schema ingestion beans and organise test resources. Change-Id: I1f043aa5852dbd2737a804ebc282a12afb9fb39f Issue-ID: AAI-1951 Signed-off-by: Michael Arrastia <MArrasti@amdocs.com>
Diffstat (limited to 'src/main/java/org/onap/aai/spike/schema/OxmConfigTranslator.java')
-rw-r--r--src/main/java/org/onap/aai/spike/schema/OxmConfigTranslator.java19
1 files changed, 11 insertions, 8 deletions
diff --git a/src/main/java/org/onap/aai/spike/schema/OxmConfigTranslator.java b/src/main/java/org/onap/aai/spike/schema/OxmConfigTranslator.java
index 51ed93e..389781f 100644
--- a/src/main/java/org/onap/aai/spike/schema/OxmConfigTranslator.java
+++ b/src/main/java/org/onap/aai/spike/schema/OxmConfigTranslator.java
@@ -32,15 +32,16 @@ import java.util.stream.Collectors;
import java.util.stream.Stream;
import org.onap.aai.setup.ConfigTranslator;
import org.onap.aai.setup.SchemaLocationsBean;
-import org.onap.aai.setup.Version;
+import org.onap.aai.setup.SchemaVersion;
+import org.onap.aai.setup.SchemaVersions;
public class OxmConfigTranslator extends ConfigTranslator {
- public OxmConfigTranslator(SchemaLocationsBean bean) {
- super(bean);
+ public OxmConfigTranslator(SchemaLocationsBean bean, SchemaVersions schemaVersions) {
+ super(bean, schemaVersions);
}
@Override
- public Map<Version, List<String>> getNodeFiles() {
+ public Map<SchemaVersion, List<String>> getNodeFiles() {
String nodeDirectory = bean.getNodeDirectory();
if (nodeDirectory == null) {
throw new ServiceConfigurationError(
@@ -54,7 +55,7 @@ public class OxmConfigTranslator extends ConfigTranslator {
}
@Override
- public Map<Version, List<String>> getEdgeFiles() {
+ public Map<SchemaVersion, List<String>> getEdgeFiles() {
String edgeDirectory = bean.getEdgeDirectory();
if (edgeDirectory == null) {
throw new ServiceConfigurationError(
@@ -79,7 +80,7 @@ public class OxmConfigTranslator extends ConfigTranslator {
* @return a new Map object (may be empty)
* @throws IOException if there is a problem reading the specified directory path
*/
- private Map<Version, List<String>> getVersionMap(Path folderPath, String globPattern) throws IOException {
+ private Map<SchemaVersion, List<String>> getVersionMap(Path folderPath, String globPattern) throws IOException {
final PathMatcher filter = folderPath.getFileSystem().getPathMatcher("glob:**/" + globPattern);
try (final Stream<Path> stream = Files.list(folderPath)) {
return stream.filter(filter::matches).map(Path::toString).filter(p -> getVersionFromPath(p) != null)
@@ -87,10 +88,12 @@ public class OxmConfigTranslator extends ConfigTranslator {
}
}
- private Version getVersionFromPath(String pathName) {
+ private SchemaVersion getVersionFromPath(String pathName) {
String version = "V" + pathName.replaceAll("^.*\\/", "").replaceAll("\\D+", "");
try {
- return Version.valueOf(version);
+ SchemaVersion schemaVersion = schemaVersions.getVersions().stream()
+ .filter(s -> s.toString().equalsIgnoreCase(version)).findAny().orElse(null);
+ return schemaVersion;
} catch (IllegalArgumentException e) {
return null;
}