aboutsummaryrefslogtreecommitdiffstats
path: root/examples/examples-grpc/src/main/resources/logic/ReceivePMSubscriptionTask.js
diff options
context:
space:
mode:
Diffstat (limited to 'examples/examples-grpc/src/main/resources/logic/ReceivePMSubscriptionTask.js')
-rw-r--r--examples/examples-grpc/src/main/resources/logic/ReceivePMSubscriptionTask.js44
1 files changed, 42 insertions, 2 deletions
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;