summaryrefslogtreecommitdiffstats
path: root/examples/examples-onap-bbs/src/main/resources/logic/ServiceUpdateStateCpeAuthTask.js
diff options
context:
space:
mode:
authors00370346 <swarup.nayak1@huawei.com>2019-04-11 00:14:39 +0530
committers00370346 <swarup.nayak1@huawei.com>2019-04-15 23:44:03 +0530
commit5262c350a449c02d91b558976c37850d6340ad81 (patch)
tree6dbd0594a6aa3dbd268f4ceaf18b1e9f4ea4519f /examples/examples-onap-bbs/src/main/resources/logic/ServiceUpdateStateCpeAuthTask.js
parent5f3e975966a0eaa247ee0eac0148da2f8755e777 (diff)
ONAP BBS: Apex Nomadic ONT Policy Implementation
Issue-ID: DCAEGEN2-1237 Change-Id: I81831f6498b6c47c0a43215e0445c791b12dac6e Signed-off-by: s00370346 <swarup.nayak1@huawei.com>
Diffstat (limited to 'examples/examples-onap-bbs/src/main/resources/logic/ServiceUpdateStateCpeAuthTask.js')
-rw-r--r--examples/examples-onap-bbs/src/main/resources/logic/ServiceUpdateStateCpeAuthTask.js155
1 files changed, 155 insertions, 0 deletions
diff --git a/examples/examples-onap-bbs/src/main/resources/logic/ServiceUpdateStateCpeAuthTask.js b/examples/examples-onap-bbs/src/main/resources/logic/ServiceUpdateStateCpeAuthTask.js
new file mode 100644
index 000000000..9c48f0d52
--- /dev/null
+++ b/examples/examples-onap-bbs/src/main/resources/logic/ServiceUpdateStateCpeAuthTask.js
@@ -0,0 +1,155 @@
+/*
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2019 Huawei. 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.
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ * ============LICENSE_END=========================================================
+ */
+
+load("nashorn:mozilla_compat.js");
+importClass(java.io.BufferedReader);
+importClass(java.io.IOException);
+importClass(java.nio.file.Files);
+importClass(java.nio.file.Paths);
+executor.logger.info("Begin Execution ServiceUpdateStateCpeAuthTask.js");
+executor.logger.info(executor.subject.id);
+executor.logger.info(executor.inFields);
+var returnValue = executor.isTrue;
+
+//**************************************************************************//
+
+var clEventType = Java.type("org.onap.policy.controlloop.VirtualControlLoopEvent");
+var clEvent = executor.inFields.get("VirtualControlLoopEvent");
+executor.logger.info(clEvent.toString());
+executor.logger.info(clEvent.getClosedLoopControlName());
+
+var requestID = clEvent.getRequestId();
+executor.logger.info("requestID = " + requestID);
+var attachmentPoint = null;
+var serviceInstanceId = null;
+var AAI_URL = "localhost:8080";
+try {
+ var br = Files.newBufferedReader(Paths.get("/home/apexuser/examples/config/ONAPBBS/config.txt"));
+ // read line by line
+ var line;
+ while ((line = br.readLine()) != null) {
+ if (line.startsWith("AAI_URL")) {
+ var str = line.split("=");
+ AAI_URL = str[str.length - 1];
+ break;
+ }
+
+ }
+} catch (err) {
+ executor.logger.info("Failed to retrieve data " + err);
+}
+executor.logger.info("AAI_URL=>" + AAI_URL);
+
+if (clEvent.getAai().get("attachmentPoint") != null) {
+ attachmentPoint = clEvent.getAai().get("attachmentPoint");
+ executor.logger.info("attachmentPoint = " + attachmentPoint);
+ serviceInstanceId = clEvent.getAai().get("service-information.hsia-cfs-service-instance-id");
+ executor.logger.info("serviceInstanceId = " + serviceInstanceId);
+
+ var result;
+ var jsonObj;
+ var prevResult = true;
+
+
+ /*BBS Policy updates {{bbs-cfs-service-instance-UUID}} orchestration-status [ assigned --> created ]*/
+ var json = {id: 1, someValue: "1234"};
+ try {
+ var urlPut = "http://" + AAI_URL + "/RestConfServer/rest/operations/policy/cpe/cpeAuthUpdate";
+ result = httpPut(urlPut, JSON.stringify(json)).data;
+ executor.logger.info("Data received From " + urlPut + " " +result.toString());
+ repos = JSON.parse(result);
+ executor.logger.info("After Parse " + result.toString());
+
+ if (result == "") {
+ prevResult = false;
+ }
+ }catch (err) {
+ executor.logger.info("Failed to retrieve data " + err);
+ prevResult = false;
+ }
+
+ /* If Success then Fill output schema */
+ if (prevResult == true) {
+ executor.outFields.put("result", "SUCCCESS");
+ } else {
+ executor.outFields.put("result", "FAILURE");
+ }
+
+ executor.outFields.put("requestID", requestID);
+ executor.outFields.put("attachmentPoint", attachmentPoint);
+ executor.outFields.put("serviceInstanceId", attachmentPoint);
+ executor.logger.info(executor.outFields);
+}
+
+
+
+var returnValue = executor.isTrue;
+executor.logger.info("End Execution ServiceUpdateStateCpeAuthTask.js");
+
+
+function httpGet(theUrl){
+ var con = new java.net.URL(theUrl).openConnection();
+ con.requestMethod = "GET";
+ return asResponse(con);
+}
+
+function httpPost(theUrl, data, contentType){
+ contentType = contentType || "application/json";
+ var con = new java.net.URL(theUrl).openConnection();
+ con.requestMethod = "POST";
+ con.setRequestProperty("Content-Type", contentType);
+ con.doOutput=true;
+ write(con.outputStream, data);
+ return asResponse(con);
+}
+
+function httpPut(theUrl, data, contentType){
+ contentType = contentType || "application/json";
+ var con = new java.net.URL(theUrl).openConnection();
+ con.requestMethod = "PUT";
+ con.setRequestProperty("Content-Type", contentType);
+ con.doOutput=true;
+ write(con.outputStream, data);
+ return asResponse(con);
+}
+
+function asResponse(con){
+ var d = read(con.inputStream);
+ return {data : d, statusCode : con.resultCode};
+}
+
+function write(outputStream, data){
+ var wr = new java.io.DataOutputStream(outputStream);
+ wr.writeBytes(data);
+ wr.flush();
+ wr.close();
+}
+
+function read(inputStream){
+ var inReader = new java.io.BufferedReader(new java.io.InputStreamReader(inputStream));
+ var inputLine;
+ var result = new java.lang.StringBuffer();
+
+ while ((inputLine = inReader.readLine()) != null) {
+ result.append(inputLine);
+ }
+ inReader.close();
+ return result.toString();
+}