diff options
Diffstat (limited to 'optical-service/provider/src/main/java/org/onap/sdnc/northbound/asyncrequests/AsyncNotificationHandling.java')
-rw-r--r-- | optical-service/provider/src/main/java/org/onap/sdnc/northbound/asyncrequests/AsyncNotificationHandling.java | 162 |
1 files changed, 162 insertions, 0 deletions
diff --git a/optical-service/provider/src/main/java/org/onap/sdnc/northbound/asyncrequests/AsyncNotificationHandling.java b/optical-service/provider/src/main/java/org/onap/sdnc/northbound/asyncrequests/AsyncNotificationHandling.java new file mode 100644 index 00000000..955cbb48 --- /dev/null +++ b/optical-service/provider/src/main/java/org/onap/sdnc/northbound/asyncrequests/AsyncNotificationHandling.java @@ -0,0 +1,162 @@ +/*- + * ============LICENSE_START======================================================= + * ONAP : SDN-C + * ================================================================================ + * Copyright (C) 2019-2020 Fujitsu Limited 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.sdnc.northbound.asyncrequests; + +import javax.servlet.Servlet; +import javax.servlet.ServletException; +import javax.servlet.http.HttpServlet; +import javax.servlet.http.HttpServletRequest; +import javax.servlet.http.HttpServletResponse; +import java.util.Properties; + +import java.io.Writer; +import java.io.StringWriter; +import java.io.BufferedReader; +import java.io.IOException; +import java.util.stream.Collectors; + +import org.apache.velocity.VelocityContext; +import org.apache.velocity.app.VelocityEngine; +import org.apache.velocity.Template; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.json.JSONArray; +import org.json.JSONObject; +import org.osgi.service.component.annotations.Component; + +@Component(immediate = true, property = {"alias=/asyncNotification", "servlet-name=AsyncNotification"}) +public class AsyncNotificationHandling extends HttpServlet implements Servlet { + + private static final long serialVersionUID = 1L; + + private final Logger LOG = LoggerFactory.getLogger(AsyncNotificationHandling.class); + + private static final String PARAMETER_NAME = "parameter-name"; + private static final String STRING_VALUE = "string-value"; + private static final String REQUEST_ID = "request-id"; + private static final String SVC_REQUEST_ID = "svc-request-id"; + private static final String RESPONSE_CODE = "response-code"; + private static final String ACK_FINAL_INDICATOR = "ack-final-indicator"; + private static final String CONFIGURATION_RESPONSE = "configuration-response-common"; + private static final String PROPERTIES_PATH = "/opt/onap/ccsdk/data/properties/"; + private static final String TEMPLATE_NAME = "rpc-message-sliapi-execute-async.vt"; + private static final String UTF_8 = "UTF-8"; + + /** + * Handles async request for different domain controllers + */ + + @Override + public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { + + LOG.info("Reached async servlet"); + BufferedReader requestInput = null; + try { + requestInput = request.getReader(); + } catch (Exception e) { + LOG.error("Unable to read input from request", e); + } + + if (requestInput == null) { + return; + } + String json = requestInput.lines().collect(Collectors.joining()); + LOG.info("Async Request payload {}", json); + if (json == null) { + return; + } + + JSONObject jsonObj = new JSONObject(json); + JSONObject input = jsonObj.getJSONObject("input"); + + if (input.has(CONFIGURATION_RESPONSE)) { + JSONObject payloadString = null; + + try { + payloadString = input.getJSONObject(CONFIGURATION_RESPONSE); + String rpcMessageBody = buildAsyncNotifRPCMsgRoadm(payloadString); + LOG.debug("rpc message body {}", rpcMessageBody); + invokeRPC(rpcMessageBody); + } catch (Exception e) { + LOG.error("Unable to build rpc message body::", e); + } + } else { + LOG.info("Async request received for wrong domain"); + } + + } + + private void invokeRPC(String rpcMsgbody) { + try { + String odlUrlBase = "http://sdnc.onap:8282/restconf/operations"; // using cluster SDNC URL + String odlUser = "admin"; + String odlPassword = "Kp8bJ4SXszM0WXlhak3eHlcse2gAw84vaoGGmJvUy2U"; + String sdncEndpoint = "SLI-API:execute-graph"; + + if ((odlUrlBase != null) && (odlUrlBase.length() > 0)) { + SdncOdlConnection conn = + SdncOdlConnection.newInstance(odlUrlBase + "/" + sdncEndpoint, odlUser, odlPassword); + + conn.send("POST", "application/json", rpcMsgbody); + } else { + LOG.info("POST message body would be:\n {}", rpcMsgbody); + } + } catch (Exception e) { + LOG.error("Unable to process message", e); + } + } + + private String buildAsyncNotifRPCMsgRoadm(JSONObject payloadString) throws IOException { + VelocityEngine velocityEngine = new VelocityEngine(); + + Properties props = new Properties(); + props.put("file.resource.loader.path", PROPERTIES_PATH); + velocityEngine.init(props); + + String sliParameters = "sli_parameters"; + + JSONArray sliParametersArray = new JSONArray(); + + VelocityContext context = new VelocityContext(); + + context.put("rpc_name", "handle-async-notif"); + String requestId = payloadString.getString(SVC_REQUEST_ID); + String responseCode = payloadString.getString(RESPONSE_CODE); + String ackIndicator = payloadString.getString(ACK_FINAL_INDICATOR); + + sliParametersArray.put(new JSONObject().put(PARAMETER_NAME, REQUEST_ID).put(STRING_VALUE, requestId)); + sliParametersArray.put(new JSONObject().put(PARAMETER_NAME, RESPONSE_CODE).put(STRING_VALUE, responseCode)); + sliParametersArray + .put(new JSONObject().put(PARAMETER_NAME, ACK_FINAL_INDICATOR).put(STRING_VALUE, ackIndicator)); + + context.put(sliParameters, sliParametersArray); + + Writer writer = new StringWriter(); + velocityEngine.mergeTemplate(TEMPLATE_NAME, UTF_8, context, writer); + writer.flush(); + + return writer.toString(); + + } + +} |