summaryrefslogtreecommitdiffstats
path: root/examples/examples-grpc
diff options
context:
space:
mode:
authorJim Hahn <jrh3@att.com>2020-11-16 16:20:00 +0000
committerGerrit Code Review <gerrit@onap.org>2020-11-16 16:20:00 +0000
commit6a84e64998c749182c1a49301a245918724123d9 (patch)
tree672fc84d3da532975f0517fcfbd776799d6e5a93 /examples/examples-grpc
parent17527ee82c63b8671224b3340e379e0bfcce6ba1 (diff)
parentfd5ee076b2ecf9fc5151090cf8a9b49fac6cf055 (diff)
Merge "Update gRPC example for JSON Stringify"
Diffstat (limited to 'examples/examples-grpc')
-rw-r--r--examples/examples-grpc/src/main/resources/logic/CreateSubscriptionPayloadTask.js9
-rw-r--r--examples/examples-grpc/src/main/resources/logic/ReceivePMSubscriptionTask.js44
2 files changed, 48 insertions, 5 deletions
diff --git a/examples/examples-grpc/src/main/resources/logic/CreateSubscriptionPayloadTask.js b/examples/examples-grpc/src/main/resources/logic/CreateSubscriptionPayloadTask.js
index 48f31847b..85e7ae2e9 100644
--- a/examples/examples-grpc/src/main/resources/logic/CreateSubscriptionPayloadTask.js
+++ b/examples/examples-grpc/src/main/resources/logic/CreateSubscriptionPayloadTask.js
@@ -35,11 +35,14 @@ var payloadEntry = executor.subject.getOutFieldSchemaHelper("payload").createNew
payloadEntry.put("create_DasH_subscription_DasH_properties", payloadProperties)
var payload = executor.subject.getOutFieldSchemaHelper("payload").createNewInstance();
+var payloadSchemaHelper = executor.subject.getOutFieldSchemaHelper("payload");
payload.put("create_DasH_subscription_DasH_request", payloadEntry);
-executor.outFields.put("albumID", executor.inFields.get("albumID"))
+executor.logger.info("CDS payload - " + executor.stringify2Json( payload, payloadSchemaHelper));
+
+executor.outFields.put("albumID", executor.inFields.get("albumID"));
executor.outFields.put("payload", payload);
-executor.logger.info("Sending Create Subscription Event to CDS")
+executor.logger.info("Sending Create Subscription Event to CDS");
-true;
+true; \ No newline at end of file
diff --git a/examples/examples-grpc/src/main/resources/logic/ReceivePMSubscriptionTask.js b/examples/examples-grpc/src/main/resources/logic/ReceivePMSubscriptionTask.js
index bc4028a32..0134b6bca 100644
--- a/examples/examples-grpc/src/main/resources/logic/ReceivePMSubscriptionTask.js
+++ b/examples/examples-grpc/src/main/resources/logic/ReceivePMSubscriptionTask.js
@@ -18,6 +18,7 @@
* ============LICENSE_END=========================================================
*/
var uuidType = java.util.UUID;
+var HashMapType = java.util.HashMap;
//albumID will be used to fetch info from our album later
@@ -25,13 +26,21 @@ var albumID = uuidType.fromString("d0050623-18e5-46c9-9298-9a567990cd7c");
var pmSubscriptionInfo = executor.getContextAlbum("PMSubscriptionAlbum").getSchemaHelper().createNewInstance();
var returnValue = true;;
-if(executor.inFields.get("policyName") != null) {
+if (executor.inFields.get("policyName") != null) {
var changeType = executor.inFields.get("changeType")
var nfName = executor.inFields.get("nfName")
var policyName = executor.inFields.get("policyName")
var closedLoopControlName = executor.inFields.get("closedLoopControlName")
var subscription = executor.inFields.get("subscription")
+ var obj = {};
+ obj["nfName"] = executor.inFields.get("nfName")
+ executor.logger.info("nfName" + executor.stringify2Json(obj))
+
+ var ticketInfo = new HashMapType();
+ populate_creator_info(ticketInfo);
+ executor.logger.info("ticketInfo" + executor.stringify2Json(ticketInfo))
+
pmSubscriptionInfo.put("nfName", executor.inFields.get("nfName"));
pmSubscriptionInfo.put("changeType", executor.inFields.get("changeType"))
pmSubscriptionInfo.put("policyName", executor.inFields.get("policyName"))
@@ -45,4 +54,35 @@ if(executor.inFields.get("policyName") != null) {
executor.message = "Received invalid event"
returnValue = false;
}
-returnValue; \ No newline at end of file
+
+function populate_creator_info(ticketInfo){
+ populate_field(ticketInfo, "appId", "NSO");
+ populate_field(ticketInfo, "creatorId", "fidLab");
+ populate_field(ticketInfo, "creatorFirstName", "PSO");
+ populate_field(ticketInfo, "creatorLastName", "team7");
+ populate_field(ticketInfo, "creatorGroup", "PSO-team7");
+ populate_field(ticketInfo, "creatorPEIN", "0000000");
+ populate_field(ticketInfo, "creatorPhoneNumber", "800-450-7771");
+ populate_field(ticketInfo, "fid", "fidLab");
+ populate_field(ticketInfo, "organizationCode", "PSO");
+ populate_field(ticketInfo, "source", create_caEn_value("SURV/ALARM FROM/PSO"));
+ populate_field(ticketInfo, "customerName", "XYZ");
+ populate_field(ticketInfo, "authorization", "Basic dGVzdHVzZXI=");
+}
+
+function populate_field(mapname, name, value){
+ if (value == null){
+ mapname.put(name, "none");
+ } else{
+ mapname.put(name, value);
+ }
+
+}
+
+function create_caEn_value(value){
+ var attr = {};
+ attr["caEn"] = String(value);
+ return attr;
+}
+
+returnValue;