diff options
5 files changed, 428 insertions, 0 deletions
diff --git a/aai-schema-service/src/main/java/org/onap/aai/schemaservice/edges/EdgeResource.java b/aai-schema-service/src/main/java/org/onap/aai/schemaservice/edges/EdgeResource.java new file mode 100644 index 0000000..cb045ea --- /dev/null +++ b/aai-schema-service/src/main/java/org/onap/aai/schemaservice/edges/EdgeResource.java @@ -0,0 +1,95 @@ +/** + * ============LICENSE_START======================================================= + * org.onap.aai + * ================================================================================ + * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * ============LICENSE_END========================================================= + */ +package org.onap.aai.schemaservice.edges; + +import com.google.gson.Gson; +import com.google.gson.GsonBuilder; +import org.onap.aai.exceptions.AAIException; +import org.onap.aai.restcore.HttpMethod; +import org.onap.aai.restcore.RESTAPI; +import org.onap.aai.schemaservice.nodeschema.SchemaVersion; +import org.onap.aai.schemaservice.nodeschema.SchemaVersions; +import org.onap.aai.schemaservice.nodeschema.validation.AAISchemaValidationException; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.util.StringUtils; + +import javax.ws.rs.GET; +import javax.ws.rs.Path; +import javax.ws.rs.Produces; +import javax.ws.rs.QueryParam; +import javax.ws.rs.core.Context; +import javax.ws.rs.core.HttpHeaders; +import javax.ws.rs.core.Response; +import javax.ws.rs.core.UriInfo; +import java.util.Optional; + +@Path("/v1") +public class EdgeResource extends RESTAPI { + + private final EdgeService edgeService; + private final SchemaVersions schemaVersions; + private final Gson gson; + + @Autowired + public EdgeResource(EdgeService edgeService, SchemaVersions schemaVersions){ + this.edgeService = edgeService; + this.schemaVersions = schemaVersions; + gson = new GsonBuilder().create(); + } + + @GET + @Path("/edgerules") + @Produces({ "application/json"}) + public Response retrieveSchema(@QueryParam("version") String version, + @Context HttpHeaders headers, + @Context UriInfo info) + { + Response response = null; + + try { + + if(StringUtils.isEmpty(version)){ + throw new AAIException("AAI_3050"); + } + + SchemaVersion schemaVersion = new SchemaVersion(version); + + if(!schemaVersions.getVersions().contains(schemaVersion)){ + throw new AAIException("AAI_3018", version); + } + + Optional<EdgeRules> edgeRulesOptional = edgeService.findRules(version); + + if(!edgeRulesOptional.isPresent()){ + throw new AAIException("AAI_3001"); + } + + response = Response.ok(gson.toJson(edgeRulesOptional.get())).build(); + } catch(AAIException ex){ + response = consumerExceptionResponseGenerator(headers, info, HttpMethod.GET, ex); + } catch(AAISchemaValidationException ex){ + response = consumerExceptionResponseGenerator(headers, info, HttpMethod.GET, new AAIException("AAI_3051", version)); + } catch(Exception ex){ + response = consumerExceptionResponseGenerator(headers, info, HttpMethod.GET, new AAIException("AAI_4000")); + } + + return response; + } +} diff --git a/aai-schema-service/src/main/java/org/onap/aai/schemaservice/edges/EdgeRule.java b/aai-schema-service/src/main/java/org/onap/aai/schemaservice/edges/EdgeRule.java new file mode 100644 index 0000000..ab0f311 --- /dev/null +++ b/aai-schema-service/src/main/java/org/onap/aai/schemaservice/edges/EdgeRule.java @@ -0,0 +1,153 @@ +/** + * ============LICENSE_START======================================================= + * org.onap.aai + * ================================================================================ + * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * ============LICENSE_END========================================================= + */ +package org.onap.aai.schemaservice.edges; + +import com.google.gson.annotations.SerializedName; + +public class EdgeRule { + + private String from; + private String to; + private String label; + + private String direction; + private String multiplicity; + private String description; + + @SerializedName("contains-other-v") + private String containsOtherV; + + @Override + public String toString() { + return "EdgeRule{" + + "from='" + from + '\'' + + ", to='" + to + '\'' + + ", label='" + label + '\'' + + ", direction='" + direction + '\'' + + ", multiplicity='" + multiplicity + '\'' + + ", description='" + description + '\'' + + ", containsOtherV='" + containsOtherV + '\'' + + ", deleteOtherV='" + deleteOtherV + '\'' + + ", preventDelete='" + preventDelete + '\'' + + ", privateEdge=" + privateEdge + + ", isDefaultEdge=" + defaultEdge + + '}'; + } + + @SerializedName("delete-other-v") + private String deleteOtherV; + @SerializedName("prevent-delete") + private String preventDelete; + + @SerializedName("private") + private String privateEdge; + + @SerializedName("default") + private String defaultEdge; + + public String getFrom() { + return from; + } + + public void setFrom(String from) { + this.from = from; + } + + public String getTo() { + return to; + } + + public void setTo(String to) { + this.to = to; + } + + public String getLabel() { + return label; + } + + public void setLabel(String label) { + this.label = label; + } + + public String getDirection() { + return direction; + } + + public void setDirection(String direction) { + this.direction = direction; + } + + public String getMultiplicity() { + return multiplicity; + } + + public void setMultiplicity(String multiplicity) { + this.multiplicity = multiplicity; + } + + public String getDescription() { + return description; + } + + public void setDescription(String description) { + this.description = description; + } + + public String getContainsOtherV() { + return containsOtherV; + } + + public void setContainsOtherV(String containsOtherV) { + this.containsOtherV = containsOtherV; + } + + public String getDeleteOtherV() { + return deleteOtherV; + } + + public void setDeleteOtherV(String deleteOtherV) { + this.deleteOtherV = deleteOtherV; + } + + public String getPreventDelete() { + return preventDelete; + } + + public void setPreventDelete(String preventDelete) { + this.preventDelete = preventDelete; + } + + public String getPrivateEdge() { + return privateEdge; + } + + public void setPrivateEdge(String privateEdge) { + this.privateEdge = privateEdge; + } + + public String getDefaultEdge() { + return defaultEdge; + } + + public void setDefaultEdge(String defaultEdge) { + this.defaultEdge = defaultEdge; + } + +} diff --git a/aai-schema-service/src/main/java/org/onap/aai/schemaservice/edges/EdgeRules.java b/aai-schema-service/src/main/java/org/onap/aai/schemaservice/edges/EdgeRules.java new file mode 100644 index 0000000..ec68d30 --- /dev/null +++ b/aai-schema-service/src/main/java/org/onap/aai/schemaservice/edges/EdgeRules.java @@ -0,0 +1,72 @@ +/** + * ============LICENSE_START======================================================= + * org.onap.aai + * ================================================================================ + * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * ============LICENSE_END========================================================= + */ +package org.onap.aai.schemaservice.edges; + +import com.google.gson.annotations.SerializedName; + +import java.util.List; +import java.util.Objects; + +public class EdgeRules { + + @SerializedName("rules") + private List<EdgeRule> rules; + + public EdgeRules(List<EdgeRule> rules){ + this.rules = rules; + } + + public List<EdgeRule> getRules() { + return rules; + } + + public void setRules(List<EdgeRule> rules) { + this.rules = rules; + } + + @Override + public boolean equals(Object o) { + + if (this == o) { + return true; + } + + if (o == null || getClass() != o.getClass()) { + return false; + } + + EdgeRules rules1 = (EdgeRules) o; + + return Objects.equals(rules, rules1.rules); + } + + @Override + public int hashCode() { + return Objects.hash(rules); + } + + @Override + public String toString() { + return "EdgeRules{" + + "rules=" + rules + + '}'; + } + +} diff --git a/aai-schema-service/src/main/java/org/onap/aai/schemaservice/edges/EdgeService.java b/aai-schema-service/src/main/java/org/onap/aai/schemaservice/edges/EdgeService.java new file mode 100644 index 0000000..ca953fd --- /dev/null +++ b/aai-schema-service/src/main/java/org/onap/aai/schemaservice/edges/EdgeService.java @@ -0,0 +1,106 @@ +/** + * ============LICENSE_START======================================================= + * org.onap.aai + * ================================================================================ + * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * ============LICENSE_END========================================================= + */ +package org.onap.aai.schemaservice.edges; + +import com.att.eelf.configuration.EELFLogger; +import com.att.eelf.configuration.EELFManager; +import com.google.gson.FieldNamingPolicy; +import com.google.gson.Gson; +import com.google.gson.GsonBuilder; +import com.google.gson.stream.JsonReader; +import org.onap.aai.schemaservice.nodeschema.SchemaVersion; +import org.onap.aai.schemaservice.nodeschema.SchemaVersions; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.stereotype.Service; + +import javax.annotation.PostConstruct; +import java.io.File; +import java.io.FileReader; +import java.io.IOException; +import java.nio.file.Files; +import java.nio.file.Path; +import java.nio.file.Paths; +import java.util.*; +import java.util.stream.Collectors; +import java.util.stream.Stream; + +@Service +public class EdgeService { + + private static final EELFLogger LOGGER = EELFManager.getInstance().getLogger(EdgeService.class); + + private static final String FILESEP = System.getProperty("file.separator"); + + private SchemaVersions schemaVersions; + private String edgesLocation; + + private Map<String, EdgeRules> rulesMap; + + @Autowired + public EdgeService(SchemaVersions schemaVersions, + @Value("${schema.edges.location}") String edgesLocation){ + this.schemaVersions = schemaVersions; + this.edgesLocation = edgesLocation; + this.rulesMap = new HashMap<>(); + } + + @PostConstruct + public void initialize() throws IOException { + + Gson gson = new GsonBuilder().setFieldNamingPolicy(FieldNamingPolicy.LOWER_CASE_WITH_DASHES).create(); + + for (SchemaVersion schemaVersion : schemaVersions.getVersions()) { + + String edgeRuleVersionPath = edgesLocation + FILESEP + schemaVersion.toString(); + + LOGGER.debug("For the version {} looking for edge rules in folder {}", schemaVersion, edgeRuleVersionPath); + + try (Stream<Path> pathStream = Files.walk(Paths.get(edgeRuleVersionPath))){ + + List<Path> jsonFiles = pathStream + .filter((path) -> path.toString().endsWith(".json")) + .collect(Collectors.toList()); + + if(jsonFiles.isEmpty()){ + LOGGER.error("Unable to find any edge rules json files in folder {}", edgeRuleVersionPath); + } else { + LOGGER.trace("Found the following edge rules {}", jsonFiles); + } + + List<EdgeRule> rules = new ArrayList<>(); + for(Path path : jsonFiles){ + File edgeRuleFile = path.toFile(); + try (JsonReader jsonReader = new JsonReader(new FileReader(edgeRuleFile))){ + EdgeRules edgeRules = gson.fromJson(jsonReader, EdgeRules.class); + rules.addAll(edgeRules.getRules()); + } + } + + rulesMap.put(schemaVersion.toString(), new EdgeRules(rules)); + } + } + + } + + public Optional<EdgeRules> findRules(String version){ + return Optional.ofNullable(rulesMap.get(version)); + } +} diff --git a/aai-schema-service/src/main/java/org/onap/aai/schemaservice/web/JerseyConfiguration.java b/aai-schema-service/src/main/java/org/onap/aai/schemaservice/web/JerseyConfiguration.java index 606d24b..bdd7946 100644 --- a/aai-schema-service/src/main/java/org/onap/aai/schemaservice/web/JerseyConfiguration.java +++ b/aai-schema-service/src/main/java/org/onap/aai/schemaservice/web/JerseyConfiguration.java @@ -20,6 +20,7 @@ package org.onap.aai.schemaservice.web; import org.glassfish.jersey.server.ResourceConfig; +import org.onap.aai.schemaservice.edges.EdgeResource; import org.onap.aai.schemaservice.healthcheck.EchoResource; import org.onap.aai.schemaservice.nodeschema.NodeSchemaResource; import org.onap.aai.schemaservice.versions.VersionResource; @@ -52,6 +53,7 @@ public class JerseyConfiguration extends ResourceConfig { register(VersionResource.class); register(EchoResource.class); register(NodeSchemaResource.class); + register(EdgeResource.class); //Request Filters registerFiltersForRequests(); |