--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2019 Nordix Foundation.
+ * ================================================================================
+ * 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.
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.nearric.simulator.service;
+
+import java.io.IOException;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Set;
+
+import javax.servlet.http.HttpServletRequest;
+
+import org.onap.nearric.simulator.model.PolicyInstance;
+import org.onap.nearric.simulator.model.PolicyType;
+import org.oransc.ric.a1med.api.model.InlineResponse200;
+import org.oransc.ric.a1med.api.model.PolicyTypeSchema;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+
+import com.fasterxml.jackson.core.JsonParseException;
+import com.fasterxml.jackson.core.JsonParser;
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.github.fge.jackson.JsonLoader;
+import com.github.fge.jsonschema.core.exceptions.ProcessingException;
+import com.github.fge.jsonschema.core.report.ProcessingMessage;
+import com.github.fge.jsonschema.core.report.ProcessingReport;
+import com.github.fge.jsonschema.main.JsonSchema;
+import com.github.fge.jsonschema.main.JsonSchemaFactory;
+
+/**
+ * This class provides the service implementation of all the A1 operation
+ *
+ * @author lathishbabu.ganesan@est.tech
+ *
+ */
+
+@Service
+public class A1PApiServiceImpl {
+
+ private static final Logger log = LoggerFactory.getLogger(A1PApiServiceImpl.class);
+
+ private HashMap<String, PolicyType> policyTypes = new HashMap<String, PolicyType>();
+
+ private ObjectMapper objectMapper = null;
+
+ private HttpServletRequest request = null;
+
+ public boolean validateSchema(String jsonData, String jsonSchema) {
+ ProcessingReport report = null;
+ boolean result = false;
+ try {
+ log.info("Applying schema: @<@<" + jsonSchema + ">@>@ to data: #<#<" + jsonData + ">#>#");
+ JsonNode schemaNode = JsonLoader.fromString(jsonSchema);
+ JsonNode data = JsonLoader.fromString(jsonData);
+ JsonSchemaFactory factory = JsonSchemaFactory.byDefault();
+ JsonSchema schema = factory.getJsonSchema(schemaNode);
+ report = schema.validate(data);
+ } catch (JsonParseException jpex) {
+ log.info("Error. Something went wrong trying to parse json data: #<#<" + jsonData
+ + ">#># or json schema: @<@<" + jsonSchema + ">@>@. Are the double quotes included? "
+ + jpex.getMessage());
+ } catch (ProcessingException pex) {
+ log.info("Error. Something went wrong trying to process json data: #<#<" + jsonData
+ + ">#># with json schema: @<@<" + jsonSchema + ">@>@ " + pex.getMessage());
+ } catch (IOException e) {
+ log.info("Error. Something went wrong trying to read json data: #<#<" + jsonData
+ + ">#># or json schema: @<@<" + jsonSchema + ">@>@");
+ }
+ if (report != null) {
+ Iterator<ProcessingMessage> iter = report.iterator();
+ while (iter.hasNext()) {
+ ProcessingMessage pm = iter.next();
+ log.info("Processing Message: " + pm.getMessage());
+ }
+ result = report.isSuccess();
+ }
+ log.info("Result=" + result);
+ return result;
+ }
+
+ public A1PApiServiceImpl() {
+ }
+
+ public void set(ObjectMapper objectMapper, HttpServletRequest request) {
+ this.objectMapper = objectMapper;
+ this.request = request;
+ }
+
+ public void reset() {
+ log.info("Resetting db");
+ policyTypes.clear();
+ }
+
+ public ResponseEntity<Void> createReplaceType(Integer policyTypeId, PolicyTypeSchema policyTypeSchema) {
+ log.info("createReplaceType - policyTypeId: " + policyTypeId);
+ log.info("createReplaceType - policyTypeSchema: " + policyTypeSchema);
+
+ if (policyTypeId == null || policyTypeSchema == null || policyTypeSchema.getName() == null) {
+ log.info("createReplaceType - bad parameters");
+ return new ResponseEntity<Void>(HttpStatus.BAD_REQUEST);
+ }
+
+ if (policyTypeSchema.getPolicyTypeId().intValue() != policyTypeId.intValue()) {
+ log.info("createReplaceType - policytype id mismatch between request and policyTypeSchema");
+ return new ResponseEntity<Void>(HttpStatus.BAD_REQUEST);
+ }
+
+ if (policyTypes.containsKey(policyTypeId.toString())) {
+ log.info("createReplaceType - policytype already exists");
+ return new ResponseEntity<Void>(HttpStatus.BAD_REQUEST);
+ }
+
+ PolicyType policyType = new PolicyType(policyTypeId, policyTypeSchema);
+ policyTypes.put(policyTypeId.toString(), policyType);
+ log.info("createReplaceType - created ok");
+
+ return new ResponseEntity<Void>(HttpStatus.CREATED);
+ }
+
+ public ResponseEntity<Void> deleteType(Integer policyTypeId) {
+ log.info("deleteType - policyTypeId: " + policyTypeId);
+
+ if (policyTypeId == null) {
+ log.info("deleteType - bad parameter");
+ return new ResponseEntity<Void>(HttpStatus.BAD_REQUEST);
+ }
+
+ PolicyType policyType = policyTypes.get(policyTypeId.toString());
+
+ if (policyType == null) {
+ log.info("deleteType - policytype does not exists");
+ return new ResponseEntity<Void>(HttpStatus.NOT_FOUND);
+ }
+
+ if (policyType.getNumberInstances() > 0) {
+ log.info("deleteType - cannot delete, instances exists");
+ return new ResponseEntity<Void>(HttpStatus.BAD_REQUEST);
+ }
+ policyTypes.remove(policyTypeId.toString());
+
+ log.info("deleteType - deleted ok");
+ return new ResponseEntity<Void>(HttpStatus.NO_CONTENT);
+ }
+
+ public ResponseEntity<Void> deleteInstance(Integer policyTypeId, String policyInstanceId) {
+
+ log.info("deleteInstance - policyTypeId: " + policyTypeId);
+ log.info("deleteInstance - policyInstanceId: " + policyInstanceId);
+
+ if (policyTypeId == null || policyInstanceId == null) {
+ log.info("deleteInstance - bad parameters");
+ return new ResponseEntity<Void>(HttpStatus.NOT_FOUND);
+ }
+
+ PolicyType policyType = policyTypes.get(policyTypeId.toString());
+
+ if (policyType == null) {
+ log.info("deleteType - policytype does not exists");
+ return new ResponseEntity<Void>(HttpStatus.NOT_FOUND);
+ }
+ PolicyInstance policyInstance = policyType.getInstance(policyInstanceId);
+ if (policyInstance == null) {
+ log.info("deleteType - instance does not exists");
+ return new ResponseEntity<Void>(HttpStatus.NOT_FOUND);
+ }
+ policyType.delete(policyInstanceId);
+
+ log.info("deleteInstance - deleted ok");
+ return new ResponseEntity<Void>(HttpStatus.NO_CONTENT);
+
+ }
+
+ public ResponseEntity<PolicyTypeSchema> getPolicyTypeSchema(Integer policyTypeId) {
+ log.info("getPolicyTypeSchema - policyTypeId: " + policyTypeId);
+
+ if (policyTypeId == null) {
+ log.info("getPolicyTypeSchema - bad parameter");
+ return new ResponseEntity<PolicyTypeSchema>(HttpStatus.NOT_FOUND);
+ }
+
+ String accept = request.getHeader("Accept");
+ if (accept != null && accept.contains("application/json")) {
+ String res = null;
+ try {
+ PolicyType policyType = policyTypes.get(policyTypeId.toString());
+
+ if (policyType == null) {
+ log.info("getPolicyTypeSchema - policytype does not exists");
+ return new ResponseEntity<PolicyTypeSchema>(HttpStatus.NOT_FOUND);
+ }
+
+ String json = null;
+ PolicyTypeSchema schema = policyType.getSchema();
+ String createSchema = "{}";
+ try {
+ // Convert Map to JSON
+ json = objectMapper.writeValueAsString(schema);
+ // Print JSON output
+ log.info("getPolicyTypeSchema - schema: " + json);
+
+ createSchema = objectMapper.writeValueAsString(schema.getCreateSchema());
+ log.info("getPolicyTypeSchema - createSchema: " + createSchema);
+ } catch (Exception e) {
+ e.printStackTrace();
+ log.info("getPolicyTypeSchema - schema corrupt");
+ return new ResponseEntity<PolicyTypeSchema>(HttpStatus.INTERNAL_SERVER_ERROR);
+ }
+ res = "{\n \"name\" : \"" + schema.getName() + "\",\n \"description\" : \"" + schema.getDescription()
+ + "\",\n \"create_schema\" : " + createSchema + ",\n \"policy_type_id\" : "
+ + schema.getPolicyTypeId().intValue() + "\n}";
+ log.info("getPolicyTypeSchema - json schema: " + res);
+ return new ResponseEntity<PolicyTypeSchema>(objectMapper.readValue(res, PolicyTypeSchema.class),
+ HttpStatus.OK);
+ } catch (Exception e) {
+ e.printStackTrace();
+ log.info("getPolicyTypeSchema - Couldn't serialize response for content type application/json");
+ return new ResponseEntity<PolicyTypeSchema>(HttpStatus.INTERNAL_SERVER_ERROR);
+ }
+ }
+ log.info("getPolicyTypeSchema - not implemented");
+ return new ResponseEntity<PolicyTypeSchema>(HttpStatus.NOT_IMPLEMENTED);
+ }
+
+ public ResponseEntity<List<Integer>> getAllTypes() {
+ log.info("getAllTypes");
+
+ String accept = request.getHeader("Accept");
+ if (accept != null && accept.contains("application/json")) {
+ try {
+ Set<String> types = policyTypes.keySet();
+ String res = "";
+ for (Iterator<String> iterator = types.iterator(); iterator.hasNext();) {
+ String tid = (String) iterator.next();
+ if (res.length() > 0) {
+ res = res + ",";
+ }
+ res = res + tid;
+ }
+ return new ResponseEntity<List<Integer>>(objectMapper.readValue("[" + res + "]", List.class),
+ HttpStatus.OK);
+ } catch (IOException e) {
+ e.printStackTrace();
+ log.info("getAllTypes - Couldn't serialize response for content type application/json");
+ return new ResponseEntity<List<Integer>>(HttpStatus.INTERNAL_SERVER_ERROR);
+ }
+ }
+ log.info("getAllTypes - not implemented");
+ return new ResponseEntity<List<Integer>>(HttpStatus.NOT_IMPLEMENTED);
+ }
+
+ public ResponseEntity<Void> createReplaceInstance(Integer policyTypeId, String policyInstanceId, Object body) {
+ log.info("createReplaceInstance - policyTypeId:" + policyTypeId);
+ log.info("createReplaceInstance - policyInstanceId:" + policyInstanceId);
+ log.info("createReplaceInstance - body:" + body);
+
+ if (policyTypeId == null || policyInstanceId == null || body == null) {
+ log.info("createReplaceInstance - bad parameter");
+ return new ResponseEntity<Void>(HttpStatus.BAD_REQUEST);
+ }
+
+ log.info("createReplaceInstance - bodyclass:" + body.getClass().toString());
+
+ PolicyType policyType = policyTypes.get(policyTypeId.toString());
+
+ if (policyType == null) {
+ log.info("createReplaceInstance - policytype does not exists");
+ return new ResponseEntity<Void>(HttpStatus.NOT_FOUND);
+ }
+
+ // Create json string from schema
+ String createSchema = null;
+ try {
+ PolicyTypeSchema schema = policyType.getSchema();
+ // Convert Map to JSON
+ String json = objectMapper.writeValueAsString(schema);
+ // Print JSON output
+ log.info("createReplaceInstance - schema - json: " + json);
+ createSchema = objectMapper.writeValueAsString(schema.getCreateSchema());
+ log.info("createReplaceInstance - createSchema - string: " + createSchema);
+ } catch (Exception e) {
+ e.printStackTrace();
+ log.info("createReplaceInstance - schema corrupt");
+ return new ResponseEntity<Void>(HttpStatus.INTERNAL_SERVER_ERROR);
+ }
+
+ // Create json string from instance
+ String jsonInstance = null;
+ try {
+ log.info("createReplaceInstance - raw: " + body);
+ // Convert Map to JSON
+ jsonInstance = objectMapper.writeValueAsString(body);
+ // Print JSON output
+ log.info("createReplaceInstance - instance: " + jsonInstance);
+
+ } catch (Exception e) {
+ e.printStackTrace();
+ log.info("createReplaceInstance - instancce corrupt");
+ return new ResponseEntity<Void>(HttpStatus.INTERNAL_SERVER_ERROR);
+ }
+
+ if (!validateSchema(jsonInstance, createSchema)) {
+ log.info("createReplaceInstance - schema validation failed");
+ return new ResponseEntity<Void>(HttpStatus.BAD_REQUEST);
+ }
+ PolicyInstance policyInstance = new PolicyInstance(policyInstanceId, body);
+ policyType.createReplaceInstance(policyInstanceId, policyInstance);
+
+ log.info("createReplaceInstance - created/replaced ok");
+ return new ResponseEntity<Void>(HttpStatus.CREATED);
+
+ }
+
+ public ResponseEntity<List<String>> getAllInstanceForType(Integer policyTypeId) {
+ log.info("getAllInstanceForType - policyTypeId:" + policyTypeId);
+
+ if (policyTypeId == null) {
+ log.info("getAllInstanceForType - bad parameter");
+ return new ResponseEntity<List<String>>(HttpStatus.NOT_FOUND);
+ }
+
+ String accept = request.getHeader("Accept");
+ if (accept != null && accept.contains("application/json")) {
+ try {
+ PolicyType policyType = policyTypes.get(policyTypeId.toString());
+ if (policyType == null) {
+ log.info("getAllInstanceForType - policytype does not exists");
+ return new ResponseEntity<List<String>>(HttpStatus.NOT_FOUND);
+ }
+ Set<String> instances = policyType.getInstances();
+ String res = "";
+ for (Iterator iterator = instances.iterator(); iterator.hasNext();) {
+ String iid = (String) iterator.next();
+ iid = "\"" + iid + "\"";
+ if (res.length() > 0) {
+ res = res + ",";
+ }
+ res = res + iid;
+ }
+ log.info("getAllInstanceForType - " + res);
+ return new ResponseEntity<List<String>>(objectMapper.readValue("[" + res + "]", List.class),
+ HttpStatus.OK);
+ } catch (IOException e) {
+ e.printStackTrace();
+ log.info("getAllInstanceForType - Couldn't serialize response for content type application/json");
+ return new ResponseEntity<List<String>>(HttpStatus.INTERNAL_SERVER_ERROR);
+ }
+ }
+ log.info("getAllInstanceForType - not implemented");
+ return new ResponseEntity<List<String>>(HttpStatus.NOT_IMPLEMENTED);
+
+ }
+
+ public ResponseEntity<Object> getPolicyInstance(Integer policyTypeId, String policyInstanceId) {
+ log.info("getPolicyInstance - policyTypeId:" + policyTypeId);
+ log.info("getPolicyInstance - policyInstanceId:" + policyInstanceId);
+
+ if (policyTypeId == null || policyInstanceId == null) {
+ log.info("getPolicyInstance - bad parameter");
+ return new ResponseEntity<Object>(HttpStatus.NOT_FOUND);
+ }
+
+ String accept = request.getHeader("Accept");
+ if (accept != null && accept.contains("application/json")) {
+ try {
+ PolicyType policyType = policyTypes.get(policyTypeId.toString());
+ if (policyType == null) {
+ log.info("getPolicyInstance - policytype does not exists");
+ return new ResponseEntity<Object>(HttpStatus.NOT_FOUND);
+ }
+ PolicyInstance policyInstance = policyType.getInstance(policyInstanceId);
+ if (policyInstance == null) {
+ log.info("getPolicyInstance - policyinstance does not exists");
+ return new ResponseEntity<Object>(HttpStatus.NOT_FOUND);
+ }
+
+ String json = null;
+ try {
+ log.info("getPolicyInstance - rawschema: " + policyInstance.getJson());
+ // Convert Map to JSON
+ json = objectMapper.writeValueAsString(policyInstance.getJson());
+ // Print JSON output
+ log.info("getPolicyInstance - schema: " + json);
+
+ } catch (Exception e) {
+ e.printStackTrace();
+ log.info("getPolicyInstance - schema corrupt");
+ return new ResponseEntity<Object>(HttpStatus.INTERNAL_SERVER_ERROR);
+ }
+
+ return new ResponseEntity<Object>(objectMapper.readValue(json, Object.class), HttpStatus.OK);
+ } catch (IOException e) {
+ e.printStackTrace();
+ log.info("getPolicyInstance - policyinstance corrupt");
+ return new ResponseEntity<Object>(HttpStatus.INTERNAL_SERVER_ERROR);
+ }
+ }
+
+ return new ResponseEntity<Object>(HttpStatus.NOT_IMPLEMENTED);
+ }
+
+ public ResponseEntity<List<InlineResponse200>> getStatus(Integer policyTypeId, String policyInstanceId) {
+ log.info("getStatus - policyTypeId:" + policyTypeId);
+ log.info("getStatus - policyInstanceId:" + policyInstanceId);
+
+ if (policyTypeId == null || policyInstanceId == null) {
+ log.info("getStatus - bad parameters");
+ return new ResponseEntity<List<InlineResponse200>>(HttpStatus.NOT_FOUND);
+ }
+
+ String accept = request.getHeader("Accept");
+ if (accept != null && accept.contains("application/json")) {
+ try {
+ PolicyType policyType = policyTypes.get(policyTypeId.toString());
+ if (policyType == null) {
+ log.info("getStatus - policytype does not exists");
+ return new ResponseEntity<List<InlineResponse200>>(HttpStatus.NOT_FOUND);
+ }
+ PolicyInstance policyInstance = policyType.getInstance(policyInstanceId);
+ if (policyInstance == null) {
+ log.info("getStatus - policyinstance does not exists");
+ return new ResponseEntity<List<InlineResponse200>>(HttpStatus.NOT_FOUND);
+ }
+
+ return new ResponseEntity<List<InlineResponse200>>(
+ objectMapper.readValue("[ {\n \"handler_id\" : \"NearRTRIC-1\",\n \"status\" : \"enforced\"\n} ]",
+ List.class),
+ HttpStatus.OK);
+ } catch (IOException e) {
+ e.printStackTrace();
+ log.info("getStatus - Couldn't serialize response for content type application/json");
+ return new ResponseEntity<List<InlineResponse200>>(HttpStatus.INTERNAL_SERVER_ERROR);
+ }
+ }
+
+ return new ResponseEntity<List<InlineResponse200>>(HttpStatus.NOT_IMPLEMENTED);
+ }
+
+}
Code Review / nonrtric.git / blobdiff