--- /dev/null
+/**
+ * ============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;
+ }
+}
--- /dev/null
+/**
+ * ============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;
+ }
+
+}
--- /dev/null
+/**
+ * ============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 +
+ '}';
+ }
+
+}
--- /dev/null
+/**
+ * ============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));
+ }
+}
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;
register(VersionResource.class);
register(EchoResource.class);
register(NodeSchemaResource.class);
+ register(EdgeResource.class);
//Request Filters
registerFiltersForRequests();
Code Review / aai / schema-service.git / commitdiff