Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

Recent changes were made to apex-pdp to handle the delta policy lists sent from PAP.  

Jira
serverONAP JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId425b2b0a-557c-3c0c-b515-579789cceedb
keyPOLICY-3170

This page is where we will document all test cases design and results.


These tests have been carried out on a full ONAP deployment to ensure that apex is working as expected after the recent changes made to handle the list(s) of delta policies. Scanning through the full list of policies in apex pdp has been eradicated as Pap now performs this task and sends just delta policies to Apex. Below are the test cases and results from the tests and also a postman collection containing the test flow.

Here are the versions of policy components used in the ONAP deployment. 

Postman Collection: Apex Delta Policies Test Cases.postman_collection.json

Postman collection includes various steps, event to send to apex and policies to test. 




Info
titleTest Cases

 

Test #DescriptionResult
1

Deploy Policy #1. Trigger event and make sure expected output is fired.

Verify PDP_UPDATE message has Policy 1 in policiesToBeDeployed list and nothing in policiesToBeUndeployed list.

Verify PDP_STATUS message is replying back with Policy 1 ONLY. 

Verify that in the Heartbeat message only Policy 1 is returned.

Code Block
languageyml
titleOutput From Triggered Event
"policyExecutedCount":1,"policyExecutedSuccessCount":1,"policyExecutedFailCount":0


Code Block
languagebash
titlePDP_UPDATE
linenumberstrue
collapsetrue
2021-05-07T09:13:39.012+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [IN|DMAAP|POLICY-PDP-PAP]
{"description":"The default group that registers all supported policy types and pdps." . . . .
.
.
"policiesToBeDeployed":[{"type":"onap.policies.native.Apex","type_version":"1.0.0","properties":{"engineServiceParameters":{"name":"MyApexEngine","version":"0.0.1","id":45,"instanceCount":2,"deploymentPort":12561,"engineParameters":{"executorParameters":{"JAVASCRIPT":{"parameterClassName":"org.onap.policy.apex.plugins.executor.javascript.JavascriptExecutorParameters"}},"contextParameters":{"parameterClassName":"org.onap.policy.apex.context.parameters.ContextParameters","schemaParameters":{"Avro":{"parameterClassName":"org.onap.policy.apex.plugins.context.schema.avro.AvroSchemaHelperParameters"}}}},"policy_type_impl":{"apexPolicyModel":{"key":{"name":"APEXgRPCPolicy","version":"0.0.1"},"keyInformation":{"key":{"name":"APEXgRPCPolicy_KeyInfo","version":"0.0.1"},"keyInfoMap":{"entry":[{"key":{"name":"APEXgRPCPolicy","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy","version":"0.0.1"},"UUID":"b8424cdb-29fb-3566-b77a-f4f847d81cc9","description":"Generated description for concept referred to by key \"APEXgRPCPolicy:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Albums","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Albums","version":"0.0.1"},"UUID":"9922906c-ccaa-34f7-95e2-bcc36e77821b","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Albums:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Events","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Events","version":"0.0.1"},"UUID":"5bf28afd-787c-3138-a3e1-b33ad94a038a","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Events:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_KeyInfo","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_KeyInfo","version":"0.0.1"},"UUID":"68abaa6f-8d03-3a53-9590-007115817d5c","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_KeyInfo:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Policies","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Policies","version":"0.0.1"},"UUID":"819d06c3-33c2-3031-aa78-96281aa4270a","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Policies:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Schemas","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Schemas","version":"0.0.1"},"UUID":"8e67d466-f990-3a39-9fd7-4490cac342dc","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Schemas:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Tasks","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Tasks","version":"0.0.1"},"UUID":"4668db3d-6fe2-3885-8e47-f30cd0102f0a","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Tasks:0.0.1\""}},{"key":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"value":{"key":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"UUID":"6e5fa19b-14df-37e3-a4ae-8c537e861a82","description":"Generated description for concept referred to by key \"CDSActionIdentifiersType:0.0.1\""}},{"key":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"UUID":"8350ac5e-c157-38b9-9614-a0f93a830e60","description":"Generated description for concept referred to by key \"CDSCreateSubscriptionPayloadType:0.0.1\""}},{"key":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"UUID":"12658406-9147-3c9d-a38c-5ad5e30b092b","description":"Generated description for concept referred to by key \"CDSDeleteSubscriptionPayloadType:0.0.1\""}},{"key":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"value":{"key":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"UUID":"35590ac0-062c-39f1-8786-b4ff716e30b1","description":"Generated description for concept referred to by key \"CDSRequestCommonHeaderType:0.0.1\""}},{"key":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"value":{"key":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"UUID":"dd7e1805-885a-350b-aaf9-ed541321ae3c","description":"Generated description for concept referred to by key \"CDSResponseCommonHeaderType:0.0.1\""}},{"key":{"name":"CDSResponseEvent","version":"0.0.1"},"value":{"key":{"name":"CDSResponseEvent","version":"0.0.1"},"UUID":"15161037-9ac8-3223-820f-4e743562a345","description":"Generated description for concept referred to by key \"CDSResponseEvent:0.0.1\""}},{"key":{"name":"CDSResponsePayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSResponsePayloadType","version":"0.0.1"},"UUID":"97dc5f58-25bb-3c20-8d53-fdb70d7ca256","description":"Generated description for concept referred to by key \"CDSResponsePayloadType:0.0.1\""}},{"key":{"name":"CDSResponseStatusEvent","version":"0.0.1"},"value":{"key":{"name":"CDSResponseStatusEvent","version":"0.0.1"},"UUID":"7986e21b-32f7-302e-9554-31f21b673493","description":"Generated description for concept referred to by key \"CDSResponseStatusEvent:0.0.1\""}},{"key":{"name":"CDSResponseStatusType","version":"0.0.1"},"value":{"key":{"name":"CDSResponseStatusType","version":"0.0.1"},"UUID":"92b8a2cf-344e-3ce1-8cc0-2b7d3cb695fa","description":"Generated description for concept referred to by key \"CDSResponseStatusType:0.0.1\""}},{"key":{"name":"CDSResponseTask","version":"0.0.1"},"value":{"key":{"name":"CDSResponseTask","version":"0.0.1"},"UUID":"d22c78a5-272c-391d-8083-28588280caf9","description":"Generated description for concept referred to by key \"CDSResponseTask:0.0.1\""}},{"key":{"name":"CreateSubscriptionPayloadEvent","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionPayloadEvent","version":"0.0.1"},"UUID":"92162397-1a8e-3a3f-a469-d2af7700af4a","description":"Generated description for concept referred to by key \"CreateSubscriptionPayloadEvent:0.0.1\""}},{"key":{"name":"CreateSubscriptionPayloadTask","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionPayloadTask","version":"0.0.1"},"UUID":"bc0c69f0-52ed-38ea-b468-ae4a6fd1730d","description":"Generated description for concept referred to by key \"CreateSubscriptionPayloadTask:0.0.1\""}},{"key":{"name":"CreateSubscriptionRequestEvent","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionRequestEvent","version":"0.0.1"},"UUID":"7cfcf843-337e-3f41-b755-5043cb0a08fc","description":"Generated description for concept referred to by key \"CreateSubscriptionRequestEvent:0.0.1\""}},{"key":{"name":"CreateSubscriptionRequestTask","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionRequestTask","version":"0.0.1"},"UUID":"89cb75e9-f06c-30d3-b4ff-698d45f63869","description":"Generated description for concept referred to by key \"CreateSubscriptionRequestTask:0.0.1\""}},{"key":{"name":"DeleteSubscriptionPayloadEvent","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionPayloadEvent","version":"0.0.1"},"UUID":"994fa441-04ab-33bb-832d-1cd12ab5d074","description":"Generated description for concept referred to by key \"DeleteSubscriptionPayloadEvent:0.0.1\""}},{"key":{"name":"DeleteSubscriptionPayloadTask","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionPayloadTask","version":"0.0.1"},"UUID":"0f519117-5fea-3e4b-941f-8f778100465f","description":"Generated description for concept referred to by key \"DeleteSubscriptionPayloadTask:0.0.1\""}},{"key":{"name":"DeleteSubscriptionRequestEvent","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionRequestEvent","version":"0.0.1"},"UUID":"15d618d8-1689-3a05-89a5-05efa9388f65","description":"Generated description for concept referred to by key \"DeleteSubscriptionRequestEvent:0.0.1\""}},{"key":{"name":"DeleteSubscriptionRequestTask","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionRequestTask","version":"0.0.1"},"UUID":"acb772fe-d442-39e3-98f9-b1080caf4150","description":"Generated description for concept referred to by key \"DeleteSubscriptionRequestTask:0.0.1\""}},{"key":{"name":"PMSubscriptionAlbum","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionAlbum","version":"0.0.1"},"UUID":"c2bd6f0d-6854-317a-9be2-97c08338428c","description":"Generated description for concept referred to by key \"PMSubscriptionAlbum:0.0.1\""}},{"key":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"UUID":"992b7819-9f69-3aa0-bb0f-6e45ea15ce05","description":"Generated description for concept referred to by key \"PMSubscriptionOutputEvent:0.0.1\""}},{"key":{"name":"PMSubscriptionType","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionType","version":"0.0.1"},"UUID":"73c1c397-4fc3-357f-93b6-a8ad707fbaae","description":"Generated description for concept referred to by key \"PMSubscriptionType:0.0.1\""}},{"key":{"name":"ReceiveEventPolicy","version":"0.0.1"},"value":{"key":{"name":"ReceiveEventPolicy","version":"0.0.1"},"UUID":"568b7345-9de1-36d3-b6a3-9b857e6809a1","description":"Generated description for concept referred to by key \"ReceiveEventPolicy:0.0.1\""}},{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"value":{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"UUID":"6c1c6c45-26e0-3591-94bf-679d20e283f4","description":"Generated description for concept referred to by key \"ReceivePMSubscriptionTask:0.0.1\""}},{"key":{"name":"SimpleIntType","version":"0.0.1"},"value":{"key":{"name":"SimpleIntType","version":"0.0.1"},"UUID":"153791fd-ae0a-36a7-88a5-309a7936415d","description":"Generated description for concept referred to by key \"SimpleIntType:0.0.1\""}},{"key":{"name":"SimpleStringType","version":"0.0.1"},"value":{"key":{"name":"SimpleStringType","version":"0.0.1"},"UUID":"8a4957cf-9493-3a76-8c22-a208e23259af","description":"Generated description for concept referred to by key \"SimpleStringType:0.0.1\""}},{"key":{"name":"SubscriptionStatusType","version":"0.0.1"},"value":{"key":{"name":"SubscriptionStatusType","version":"0.0.1"},"UUID":"597643b1-9db1-31ce-85d0-e1c63c43b30b","description":"Generated description for concept referred to by key \"SubscriptionStatusType:0.0.1\""}},{"key":{"name":"SubscriptionType","version":"0.0.1"},"value":{"key":{"name":"SubscriptionType","version":"0.0.1"},"UUID":"184547bb-7d64-3cb2-a273-d7185102c5ce","description":"Generated description for concept referred to by key \"SubscriptionType:0.0.1\""}},{"key":{"name":"UUIDType","version":"0.0.1"},"value":{"key":{"name":"UUIDType","version":"0.0.1"},"UUID":"6a8cc68e-dfc8-3403-9c6d-071c886b319c","description":"Generated description for concept referred to by key \"UUIDType:0.0.1\""}},{"key":{"name":"testPolicyB","version":"0.0.1"},"value":{"key":{"name":"testPolicyB","version":"0.0.1"},"UUID":"ead590a3-ba2e-3a01-b6e9-9329f5c8fee1","description":"Generated description for concept referred to by key \"testPolicyB:0.0.1\""}}]}},"policies":{"key":{"name":"APEXgRPCPolicy_Policies","version":"0.0.1"},"policyMap":{"entry":[{"key":{"name":"ReceiveEventPolicy","version":"0.0.1"},"value":{"policyKey":{"name":"ReceiveEventPolicy","version":"0.0.1"},"template":"Freestyle","state":{"entry":[{"key":"ReceiveSubscriptionState","value":{"stateKey":{"parentKeyName":"ReceiveEventPolicy","parentKeyVersion":"0.0.1","parentLocalName":"NULL","localName":"ReceiveSubscriptionState"},"trigger":{"name":"testPolicyB","version":"0.0.1"},"stateOutputs":{"entry":[{"key":"ReceivePMSubscriptionOutput","value":{"key":{"parentKeyName":"ReceiveEventPolicy","parentKeyVersion":"0.0.1","parentLocalName":"ReceiveSubscriptionState","localName":"ReceivePMSubscriptionOutput"},"outgoingEvent":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"nextState":{"parentKeyName":"NULL","parentKeyVersion":"0.0.0","parentLocalName":"NULL","localName":"NULL"}}}]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskSelectionLogic":{"key":"NULL","logicFlavour":"UNDEFINED","logic":""},"stateFinalizerLogicMap":{"entry":[]},"defaultTask":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"taskReferences":{"entry":[{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"value":{"key":{"parentKeyName":"ReceiveEventPolicy","parentKeyVersion":"0.0.1","parentLocalName":"ReceiveSubscriptionState","localName":"ReceiveEventPolicy"},"outputType":"DIRECT","output":{"parentKeyName":"ReceiveEventPolicy","parentKeyVersion":"0.0.1","parentLocalName":"ReceiveSubscriptionState","localName":"ReceivePMSubscriptionOutput"}}}]}}}]},"firstState":"ReceiveSubscriptionState"}}]}},"tasks":{"key":{"name":"APEXgRPCPolicy_Tasks","version":"0.0.1"},"taskMap":{"entry":[{"key":{"name":"CDSResponseTask","version":"0.0.1"},"value":{"key":{"name":"CDSResponseTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSResponsePayloadType","version":"0.0.1"},"optional":false}},{"key":"status","value":{"key":"status","fieldSchemaKey":{"name":"CDSResponseStatusType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"status","value":{"key":"status","fieldSchemaKey":{"name":"SubscriptionStatusType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n *  Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n *      http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\n\nvar uuidType = java.util.UUID;\n\nvar albumID = uuidType.fromString(\"d0050623-18e5-46c9-9298-9a567990cd7c\");\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(albumID.toString());\n\nvar responseStatus = executor.subject.getOutFieldSchemaHelper(\"status\").createNewInstance();\n\nresponseStatus.put(\"subscriptionName\", pmSubscriptionInfo.get(\"subscription\").get(\"subscriptionName\"))\nresponseStatus.put(\"nfName\", pmSubscriptionInfo.get(\"nfName\"))\nresponseStatus.put(\"changeType\", pmSubscriptionInfo.get(\"changeType\"))\n\nvar response = executor.inFields.get(\"payload\")\n\nif (\"failure\".equals(response.get(\"create_DasH_subscription_DasH_response\").get(\"odl_DasH_response\").get(\"status\"))) {\n    responseStatus.put(\"message\", \"failed\")\n} else {\n    responseStatus.put(\"message\", \"success\")\n}\n\nexecutor.outFields.put(\"status\", responseStatus)\n\ntrue;"}}},{"key":{"name":"CreateSubscriptionPayloadTask","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionPayloadTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n *  Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n *      http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\nexecutor.logger.info(executor.subject.id);\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(executor.inFields.get(\"albumID\").toString())\n\nvar payloadProperties = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"create_DasH_subscription_DasH_properties_record\");\n\npayloadProperties.put(\"nfName\",  pmSubscriptionInfo.get(\"nfName\"))\npayloadProperties.put(\"subscriptionName\",  pmSubscriptionInfo.get(\"subscription\").get(\"subscriptionName\"))\npayloadProperties.put(\"administrativeState\", pmSubscriptionInfo.get(\"subscription\").get(\"administrativeState\"))\npayloadProperties.put(\"fileBasedGP\",  pmSubscriptionInfo.get(\"subscription\").get(\"fileBasedGP\").toString())\npayloadProperties.put(\"fileLocation\", pmSubscriptionInfo.get(\"subscription\").get(\"fileLocation\"))\npayloadProperties.put(\"measurementGroups\", pmSubscriptionInfo.get(\"subscription\").get(\"measurementGroups\"))\n\nvar payloadEntry = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"CDSRequestPayloadEntry\");\npayloadEntry.put(\"create_DasH_subscription_DasH_properties\", payloadProperties)\n\nvar payload = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewInstance();\nvar payloadSchemaHelper = executor.subject.getOutFieldSchemaHelper(\"payload\");\npayload.put(\"create_DasH_subscription_DasH_request\", payloadEntry);\n\nexecutor.logger.info(\"CDS payload - \" + executor.stringify2Json( payload, payloadSchemaHelper));\n\nexecutor.outFields.put(\"albumID\", executor.inFields.get(\"albumID\"));\nexecutor.outFields.put(\"payload\", payload);\n\nexecutor.logger.info(\"Sending Create Subscription Event to CDS\");\n\ntrue;"}}},{"key":{"name":"CreateSubscriptionRequestTask","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionRequestTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n *  Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n *      http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\nexecutor.logger.info(executor.subject.id);\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(executor.inFields.get(\"albumID\").toString())\nvar payload = executor.inFields.get(\"payload\")\nvar actionName = \"create-subscription\"\n\nvar commonHeader = executor.subject.getOutFieldSchemaHelper(\"commonHeader\").createNewInstance();\ncommonHeader.put(\"originatorId\", \"sdnc\");\ncommonHeader.put(\"requestId\", \"123456-1000\");\ncommonHeader.put(\"subRequestId\", \"sub-123456-1000\");\n\nvar actionIdentifiers = executor.subject.getOutFieldSchemaHelper(\"actionIdentifiers\").createNewInstance();\nactionIdentifiers.put(\"actionName\", actionName);\nactionIdentifiers.put(\"blueprintName\", \"pm_control\");\nactionIdentifiers.put(\"blueprintVersion\", \"1.0.0\");\nactionIdentifiers.put(\"mode\", \"sync\");\n\nexecutor.outFields.put(\"commonHeader\", commonHeader);\nexecutor.outFields.put(\"actionIdentifiers\", actionIdentifiers);\nexecutor.outFields.put(\"payload\", payload);\n\nexecutor.logger.info(\"Sending Activate Subscription Event to CDS\")\n\ntrue;"}}},{"key":{"name":"DeleteSubscriptionPayloadTask","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionPayloadTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n *  Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n *      http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\nexecutor.logger.info(executor.subject.id);\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(executor.inFields.get(\"albumID\").toString())\n\nvar payloadProperties = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"delete_DasH_subscription_DasH_properties_record\");\n\npayloadProperties.put(\"nfName\",  pmSubscriptionInfo.get(\"nfName\"))\npayloadProperties.put(\"subscriptionName\",  pmSubscriptionInfo.get(\"subscription\").get(\"subscriptionName\"))\npayloadProperties.put(\"administrativeState\", pmSubscriptionInfo.get(\"subscription\").get(\"administrativeState\"))\npayloadProperties.put(\"fileBasedGP\",  pmSubscriptionInfo.get(\"subscription\").get(\"fileBasedGP\").toString())\npayloadProperties.put(\"fileLocation\", pmSubscriptionInfo.get(\"subscription\").get(\"fileLocation\"))\npayloadProperties.put(\"measurementGroups\", pmSubscriptionInfo.get(\"subscription\").get(\"measurementGroups\"))\n\nvar payloadEntry = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"CDSRequestPayloadEntry\");\npayloadEntry.put(\"delete_DasH_subscription_DasH_properties\", payloadProperties)\n\nvar payload = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewInstance();\npayload.put(\"delete_DasH_subscription_DasH_request\", payloadEntry);\n\nexecutor.outFields.put(\"albumID\", executor.inFields.get(\"albumID\"))\nexecutor.outFields.put(\"payload\", payload);\n\nexecutor.logger.info(\"Sending delete Subscription Event to CDS\")\n\ntrue;"}}},{"key":{"name":"DeleteSubscriptionRequestTask","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionRequestTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n *  Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n *      http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\nexecutor.logger.info(executor.subject.id);\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(executor.inFields.get(\"albumID\").toString())\nvar payload = executor.inFields.get(\"payload\")\nvar actionName = \"delete-subscription\"\n\nvar commonHeader = executor.subject.getOutFieldSchemaHelper(\"commonHeader\").createNewInstance();\ncommonHeader.put(\"originatorId\", \"sdnc\");\ncommonHeader.put(\"requestId\", \"123456-1000\");\ncommonHeader.put(\"subRequestId\", \"sub-123456-1000\");\n\nvar actionIdentifiers = executor.subject.getOutFieldSchemaHelper(\"actionIdentifiers\").createNewInstance();\nactionIdentifiers.put(\"actionName\", actionName);\nactionIdentifiers.put(\"blueprintName\", \"pm_control\");\nactionIdentifiers.put(\"blueprintVersion\", \"1.0.0\");\nactionIdentifiers.put(\"mode\", \"sync\");\n\nexecutor.outFields.put(\"commonHeader\", commonHeader);\nexecutor.outFields.put(\"actionIdentifiers\", actionIdentifiers);\nexecutor.outFields.put(\"payload\", payload);\n\nexecutor.logger.info(\"Sending Deactivate Subscription Event to CDS\")\n\ntrue;"}}},{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"value":{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"changeType","value":{"key":"changeType","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"closedLoopControlName","value":{"key":"closedLoopControlName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"nfName","value":{"key":"nfName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"policyName","value":{"key":"policyName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"subscription","value":{"key":"subscription","fieldSchemaKey":{"name":"SubscriptionType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n *  Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n *      http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\nvar uuidType = java.util.UUID;\nvar HashMapType = java.util.HashMap;\n\nvar headers = new HashMapType();\n    //headers.put(\"Authorization\" , \"Basic Y2NzZGthcHBzOmNjc2RrYXBwcw==\");\nexecutor.logger.info(\"LogEvent11111111111\");\nvar response = new org.onap.policy.rest.RestManager().post(\n        \"http://10.2.0.149:32005/events/POLICY-CL-MGT\",\n        \"\",\n        \"\",\n        headers,\n        \"application/json\",\n        '{\"test\":\"test\"}'\n);\nexecutor.logger.info(\"DMaaP Response after sending LogEvent: \" + response);\n\n//albumID will be used to fetch info from our album later\nvar albumID = uuidType.fromString(\"d0050623-18e5-46c9-9298-9a567990cd7c\");\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").getSchemaHelper().createNewInstance();\nvar returnValue = true;;\n\nif (executor.inFields.get(\"policyName\") != null) {\n    var changeType = executor.inFields.get(\"changeType\")\n    var nfName = executor.inFields.get(\"nfName\")\n    var policyName = executor.inFields.get(\"policyName\")\n    var closedLoopControlName = executor.inFields.get(\"closedLoopControlName\")\n    var subscription = executor.inFields.get(\"subscription\")\n\n    var obj = {};\n    obj[\"nfName\"] = executor.inFields.get(\"nfName\")\n    executor.logger.info(\"nfName\" + executor.stringify2Json(obj))\n\n    var ticketInfo = new HashMapType();\n    populate_creator_info(ticketInfo);\n    executor.logger.info(\"ticketInfo\" + executor.stringify2Json(ticketInfo))\n\n    pmSubscriptionInfo.put(\"nfName\", executor.inFields.get(\"nfName\"));\n    pmSubscriptionInfo.put(\"changeType\", executor.inFields.get(\"changeType\"))\n    pmSubscriptionInfo.put(\"policyName\", executor.inFields.get(\"policyName\"))\n    pmSubscriptionInfo.put(\"closedLoopControlName\", executor.inFields.get(\"closedLoopControlName\"))\n    pmSubscriptionInfo.put(\"subscription\", subscription)\n\n    executor.getContextAlbum(\"PMSubscriptionAlbum\").put(albumID.toString(), pmSubscriptionInfo);\n\n    executor.outFields.put(\"albumID\", albumID)\n} else {\n    executor.message = \"Received invalid event\"\n    returnValue = false;\n}\n\nfunction populate_creator_info(ticketInfo){\n    populate_field(ticketInfo, \"appId\", \"NSO\");\n    populate_field(ticketInfo, \"creatorId\", \"fidLab\");\n    populate_field(ticketInfo, \"creatorFirstName\", \"PSO\");\n    populate_field(ticketInfo, \"creatorLastName\", \"team7\");\n    populate_field(ticketInfo, \"creatorGroup\", \"PSO-team7\");\n    populate_field(ticketInfo, \"creatorPEIN\", \"0000000\");\n    populate_field(ticketInfo, \"creatorPhoneNumber\", \"800-450-7771\");\n    populate_field(ticketInfo, \"fid\", \"fidLab\");\n    populate_field(ticketInfo, \"organizationCode\", \"PSO\");\n    populate_field(ticketInfo, \"source\", create_caEn_value(\"SURV/ALARM FROM/PSO\"));\n    populate_field(ticketInfo, \"customerName\", \"XYZ\");\n    populate_field(ticketInfo, \"authorization\", \"Basic dGVzdHVzZXI=\");\n}\n\nfunction populate_field(mapname, name, value){\n    if (value == null){\n        mapname.put(name, \"none\");\n    } else{\n        mapname.put(name, value);\n    }\n\n}\n\nfunction create_caEn_value(value){\n    var attr = {};\n    attr[\"caEn\"] = String(value);\n    return attr;\n}\n\nreturnValue;"}}}]}},"events":{"key":{"name":"APEXgRPCPolicy_Events","version":"0.0.1"},"eventMap":{"entry":[{"key":{"name":"CDSResponseEvent","version":"0.0.1"},"value":{"key":{"name":"CDSResponseEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"CDS","target":"APEX","parameter":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSResponsePayloadType","version":"0.0.1"},"optional":false}},{"key":"status","value":{"key":"status","fieldSchemaKey":{"name":"CDSResponseStatusType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"CDSResponseStatusEvent","version":"0.0.1"},"value":{"key":{"name":"CDSResponseStatusEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"DCAE","parameter":{"entry":[{"key":"status","value":{"key":"status","fieldSchemaKey":{"name":"SubscriptionStatusType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"CreateSubscriptionPayloadEvent","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionPayloadEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"CreateSubscriptionRequestEvent","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionRequestEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"DeleteSubscriptionPayloadEvent","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionPayloadEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"DeleteSubscriptionRequestEvent","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionRequestEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"testPolicyB","version":"0.0.1"},"value":{"key":{"name":"testPolicyB","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"DCAE","target":"APEX","parameter":{"entry":[{"key":"changeType","value":{"key":"changeType","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"closedLoopControlName","value":{"key":"closedLoopControlName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"nfName","value":{"key":"nfName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"policyName","value":{"key":"policyName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"subscription","value":{"key":"subscription","fieldSchemaKey":{"name":"SubscriptionType","version":"0.0.1"},"optional":false}}]}}}]}},"albums":{"key":{"name":"APEXgRPCPolicy_Albums","version":"0.0.1"},"albums":{"entry":[{"key":{"name":"PMSubscriptionAlbum","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionAlbum","version":"0.0.1"},"scope":"policy","isWritable":true,"itemSchema":{"name":"PMSubscriptionType","version":"0.0.1"}}}]}},"schemas":{"key":{"name":"APEXgRPCPolicy_Schemas","version":"0.0.1"},"schemas":{"entry":[{"key":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"value":{"key":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n    \"type\": \"record\",\n    \"name\": \"CDSActionIdentifiers_Type\",\n    \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n    \"fields\": [\n        {\n            \"name\": \"actionName\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"blueprintName\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"blueprintVersion\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"mode\",\n            \"type\": \"string\"\n        }\n    ]\n}"}},{"key":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n  \"type\": \"map\",\n  \"values\": {\n    \"type\": \"record\",\n    \"name\": \"CDSRequestPayloadEntry\",\n    \"fields\": [\n      {\n        \"name\": \"create_DasH_subscription_DasH_properties\",\n        \"type\": {\n          \"name\": \"create_DasH_subscription_DasH_properties_record\",\n          \"type\": \"record\",\n          \"fields\": [\n            {\n              \"name\": \"nfName\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"subscriptionName\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"administrativeState\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"fileBasedGP\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"fileLocation\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"measurementGroups\",\n              \"type\": {\n                \"type\": \"array\",\n                \"items\": {\n                  \"name\": \"measurementGroups_record\",\n                  \"type\": \"record\",\n                  \"fields\": [\n                    {\n                      \"name\": \"measurementGroup\",\n                      \"type\": {\n                        \"name\": \"measurementGroup\",\n                        \"type\": \"record\",\n                        \"fields\": [\n                          {\n                            \"name\": \"measurementTypes\",\n                            \"type\": {\n                              \"type\": \"array\",\n                              \"items\": {\n                                \"name\": \"measurementTypes_record\",\n                                \"type\": \"record\",\n                                \"fields\": [\n                                  {\n                                    \"name\": \"measurementType\",\n                                    \"type\": \"string\"\n                                  }\n                                ]\n                              }\n                            }\n                          },\n                          {\n                            \"name\": \"managedObjectDNsBasic\",\n                            \"type\": {\n                              \"type\": \"array\",\n                              \"items\": {\n                                \"name\": \"managedObjectDNsBasic_record\",\n                                \"type\": \"record\",\n                                \"fields\": [\n                                  {\n                                    \"name\": \"DN\",\n                                    \"type\": \"string\"\n                                  }\n                                ]\n                              }\n                            }\n                          }\n                        ]\n                      }\n                    }\n                  ]\n                }\n              }\n            }\n          ]\n        }\n      }\n    ]\n  }\n}"}},{"key":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n  \"type\": \"map\",\n  \"values\": {\n    \"type\": \"record\",\n    \"name\": \"CDSRequestPayloadEntry\",\n    \"fields\": [\n      {\n        \"name\": \"delete_DasH_subscription_DasH_properties\",\n        \"type\": {\n          \"name\": \"delete_DasH_subscription_DasH_properties_record\",\n          \"type\": \"record\",\n          \"fields\": [\n            {\n              \"name\": \"nfName\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"subscriptionName\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"administrativeState\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"fileBasedGP\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"fileLocation\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"measurementGroups\",\n              \"type\": {\n                \"type\": \"array\",\n                \"items\": {\n                  \"name\": \"measurementGroups_record\",\n                  \"type\": \"record\",\n                  \"fields\": [\n                    {\n                      \"name\": \"measurementGroup\",\n                      \"type\": {\n                        \"name\": \"measurementGroup\",\n                        \"type\": \"record\",\n                        \"fields\": [\n                          {\n                            \"name\": \"measurementTypes\",\n                            \"type\": {\n                              \"type\": \"array\",\n                              \"items\": {\n                                \"name\": \"measurementTypes_record\",\n                                \"type\": \"record\",\n                                \"fields\": [\n                                  {\n                                    \"name\": \"measurementType\",\n                                    \"type\": \"string\"\n                                  }\n                                ]\n                              }\n                            }\n                          },\n                          {\n                            \"name\": \"managedObjectDNsBasic\",\n                            \"type\": {\n                              \"type\": \"array\",\n                              \"items\": {\n                                \"name\": \"managedObjectDNsBasic_record\",\n                                \"type\": \"record\",\n                                \"fields\": [\n                                  {\n                                    \"name\": \"DN\",\n                                    \"type\": \"string\"\n                                  }\n                                ]\n                              }\n                            }\n                          }\n                        ]\n                      }\n                    }\n                  ]\n                }\n              }\n            }\n          ]\n        }\n      }\n    ]\n  }\n}"}},{"key":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"value":{"key":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n    \"type\": \"record\",\n    \"name\": \"CDSRequestCommonHeader_Type\",\n    \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n    \"fields\": [\n        {\n            \"name\": \"originatorId\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"requestId\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"subRequestId\",\n            \"type\": \"string\"\n        }\n    ]\n}"}},{"key":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"value":{"key":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n    \"type\": \"record\",\n    \"name\": \"CDSResponseCommonHeader_Type\",\n    \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n    \"fields\": [\n        {\n            \"name\": \"originatorId\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"requestId\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"subRequestId\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"timestamp\",\n            \"type\": \"string\"\n        }\n    ]\n}"}},{"key":{"name":"CDSResponsePayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSResponsePayloadType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n  \"name\": \"CDSResponsePayloadEntry\",\n  \"type\": \"record\",\n  \"namespace\": \"com.acme.avro\",\n  \"fields\": [\n    {\n      \"name\": \"create_DasH_subscription_DasH_response\",\n      \"type\": {\n        \"name\": \"create_DasH_subscription_DasH_response\",\n        \"type\": \"record\",\n        \"fields\": [\n          {\n            \"name\": \"odl_DasH_response\",\n            \"type\": {\n              \"name\": \"odl_DasH_response\",\n              \"type\": \"record\",\n              \"fields\": [\n                  {\n                    \"name\": \"status\",\n                    \"type\": \"string\"\n                  }\n              ]\n            }\n          }\n        ]\n      }\n    }\n  ]\n}"}},{"key":{"name":"CDSResponseStatusType","version":"0.0.1"},"value":{"key":{"name":"CDSResponseStatusType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n    \"type\": \"record\",\n    \"name\": \"CDSResponseStatus_Type\",\n    \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n    \"fields\": [\n        {\n            \"name\": \"code\",\n            \"type\": \"int\"\n        },\n        {\n            \"name\": \"eventType\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"timestamp\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"message\",\n            \"type\": \"string\"\n        }\n    ]\n}"}},{"key":{"name":"PMSubscriptionType","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n  \"name\": \"PMSubscription\",\n  \"type\": \"record\",\n  \"namespace\": \"org.onap.policy.apex.onap.pmcontrol\",\n  \"fields\": [\n    {\n      \"name\": \"nfName\",\n      \"type\": \"string\"\n    },\n    {\n      \"name\": \"changeType\",\n      \"type\": \"string\"\n    },\n    {\n      \"name\": \"closedLoopControlName\",\n      \"type\": \"string\"\n    },\n    {\n      \"name\": \"policyName\",\n      \"type\": \"string\"\n    },\n    {\n      \"name\": \"subscription\",\n      \"type\": {\n        \"name\": \"subscription\",\n        \"type\": \"record\",\n        \"fields\": [\n          {\n            \"name\": \"subscriptionName\",\n            \"type\": \"string\"\n          },\n          {\n            \"name\": \"administrativeState\",\n            \"type\": \"string\"\n          },\n          {\n            \"name\": \"fileBasedGP\",\n            \"type\": \"int\"\n          },\n          {\n            \"name\": \"fileLocation\",\n            \"type\": \"string\"\n          },\n          {\n            \"name\": \"measurementGroups\",\n            \"type\": {\n              \"type\": \"array\",\n              \"items\": {\n                \"name\": \"Measurement_Groups_Type\",\n                \"type\": \"record\",\n                \"fields\": [\n                  {\n                    \"name\": \"measurementGroup\",\n                    \"type\": {\n                      \"name\": \"Measurement_Group_Type\",\n                      \"type\": \"record\",\n                      \"fields\": [\n                        {\n                          \"name\": \"measurementTypes\",\n                          \"type\": {\n                            \"type\": \"array\",\n                            \"items\": {\n                              \"name\": \"Measurement_Types_Type\",\n                              \"type\": \"record\",\n                              \"fields\": [\n                                {\n                                  \"name\": \"measurementType\",\n                                  \"type\": \"string\"\n                                }\n                              ]\n                            }\n                          }\n                        },\n                        {\n                          \"name\": \"managedObjectDNsBasic\",\n                          \"type\": {\n                            \"type\": \"array\",\n                            \"items\": {\n                              \"name\": \"Managed_Object_Dns_Basic_Type\",\n                              \"type\": \"record\",\n                              \"fields\": [\n                                {\n                                  \"name\": \"DN\",\n                                  \"type\": \"string\"\n                                }\n                              ]\n                            }\n                          }\n                        }\n                      ]\n                    }\n                  }\n                ]\n              }\n            }\n          }\n        ]\n      }\n    }\n  ]\n}"}},{"key":{"name":"SimpleIntType","version":"0.0.1"},"value":{"key":{"name":"SimpleIntType","version":"0.0.1"},"schemaFlavour":"Java","schemaDefinition":"java.lang.Integer"}},{"key":{"name":"SimpleStringType","version":"0.0.1"},"value":{"key":{"name":"SimpleStringType","version":"0.0.1"},"schemaFlavour":"Java","schemaDefinition":"java.lang.String"}},{"key":{"name":"SubscriptionStatusType","version":"0.0.1"},"value":{"key":{"name":"SubscriptionStatusType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n    \"type\": \"record\",\n    \"name\": \"ActivateSubscriptionStatus_Type\",\n    \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n    \"fields\": [\n        {\n            \"name\": \"subscriptionName\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"nfName\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"changeType\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"message\",\n            \"type\": \"string\"\n        }\n    ]\n}"}},{"key":{"name":"SubscriptionType","version":"0.0.1"},"value":{"key":{"name":"SubscriptionType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n  \"name\": \"subscription\",\n  \"type\": \"record\",\n  \"fields\": [\n    {\n      \"name\": \"subscriptionName\",\n      \"type\": \"string\"\n    },\n    {\n      \"name\": \"administrativeState\",\n      \"type\": \"string\"\n    },\n    {\n      \"name\": \"fileBasedGP\",\n      \"type\": \"int\"\n    },\n    {\n      \"name\": \"fileLocation\",\n      \"type\": \"string\"\n    },\n    {\n      \"name\": \"measurementGroups\",\n      \"type\": {\n        \"type\": \"array\",\n        \"items\": {\n          \"name\": \"Measurement_Groups_Type\",\n          \"type\": \"record\",\n          \"fields\": [\n            {\n              \"name\": \"measurementGroup\",\n              \"type\": {\n                \"name\": \"Measurement_Group_Type\",\n                \"type\": \"record\",\n                \"fields\": [\n                  {\n                    \"name\": \"measurementTypes\",\n                    \"type\": {\n                      \"type\": \"array\",\n                      \"items\": {\n                        \"name\": \"Measurement_Types_Type\",\n                        \"type\": \"record\",\n                        \"fields\": [\n                          {\n                            \"name\": \"measurementType\",\n                            \"type\": \"string\"\n                          }\n                        ]\n                      }\n                    }\n                  },\n                  {\n                    \"name\": \"managedObjectDNsBasic\",\n                    \"type\": {\n                      \"type\": \"array\",\n                      \"items\": {\n                        \"name\": \"Managed_Object_Dns_Basic_Type\",\n                        \"type\": \"record\",\n                        \"fields\": [\n                          {\n                            \"name\": \"DN\",\n                            \"type\": \"string\"\n                          }\n                        ]\n                      }\n                    }\n                  }\n                ]\n              }\n            }\n          ]\n        }\n      }\n    }\n  ]\n}"}},{"key":{"name":"UUIDType","version":"0.0.1"},"value":{"key":{"name":"UUIDType","version":"0.0.1"},"schemaFlavour":"Java","schemaDefinition":"java.util.UUID"}}]}}}}},"eventOutputParameters":{"logOutputter01":{"carrierTechnologyParameters":{"carrierTechnology":"FILE","parameters":{"fileName":"outputevents.log"}},"eventProtocolParameters":{"eventProtocol":"JSON"}}},"eventInputParameters":{"DCAEConsumer01":{"carrierTechnologyParameters":{"carrierTechnology":"RESTCLIENT","parameterClassName":"org.onap.policy.apex.plugins.event.carrier.restclient.RestClientCarrierTechnologyParameters","parameters":{"url":"http://message-router:3904/events/unauthenticated.DCAE_CL_OUTPUT/APEX/1?timeout=30000"}},"eventProtocolParameters":{"eventProtocol":"JSON","parameters":{"nameAlias":"testPolicyB"}},"eventName":"testPolicyB","eventNameFilter":"testPolicyB"}}},"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0","metadata":{"policy-id":"onap.policies.native.apex.Grpc.test01","policy-version":"1.0.0"}}],"policiesToBeUndeployed":[]


Code Block
languagebash
titlePDP_STATUS
linenumberstrue
[2021-05-07T09:13:39.172+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp status response message for PdpUpdate","policies":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T09:13:39.171471Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":50,"policyDeploySuccessCount":37,"policyDeployFailCount":13,"policyExecutedCount":3,"policyExecutedSuccessCount":3,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620378819145,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620378819145},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620378819150,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620378819150}]},"response":{"responseTo":"e51d066c-745c-4a53-b336-257a24d093fa","responseStatus":"SUCCESS","responseMessage":"Apex engine started and policies are running."},"messageName":"PDP_STATUS","requestId":"53e9c6b1-7b6a-4c56-b644-21c7f08877eb","timestampMs":1620378819171,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}


Code Block
languagebash
titleHeartbeat Message
[2021-05-07T09:36:53.449+00:00|INFO|network|Timer-0] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp Heartbeat","policies":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T09:36:53.448912Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":52,"policyDeploySuccessCount":39,"policyDeployFailCount":13,"policyExecutedCount":4,"policyExecutedSuccessCount":4,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620378914283,"eventCount":1,"lastExecutionTime":12294,"averageExecutionTime":12294.0,"upTime":95138,"lastEnterTime":0,"lastStart":1620378819145},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620378819150,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620378819150}]},"messageName":"PDP_STATUS","requestId":"bf864ee9-9b0d-40eb-a129-c7690dd1e0f1","timestampMs":1620380213448,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}



2

Deploy Policy #2. Test it is running.

Verify PDP_UPDATE message has Policy 2 in policiesToBeDeployed list and nothing in policiesToBeUndeployed list.

Verify PDP_STATUS message is replying back with Policy 2 included. 

Verify that in the Heartbeat message Policy 1 AND Policy 2 is returned.

Code Block
languagebash
titlePDP_UPDATE
collapsetrue
2021-05-07T09:51:56.731+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [IN|DMAAP|POLICY-PDP-PAP]
{"description":"The default group that registers all supported policy types and pdps.", . . . . 
. 
.
"policiesToBeDeployed":[{"type":"onap.policies.native.Apex","type_version":"1.0.0","properties":{"engineServiceParameters":{"name":"MyApexEngine","version":"0.0.1","id":45,"instanceCount":2,"deploymentPort":12561,"engineParameters":{"executorParameters":{"JAVASCRIPT":{"parameterClassName":"org.onap.policy.apex.plugins.executor.javascript.JavascriptExecutorParameters"}},"contextParameters":{"parameterClassName":"org.onap.policy.apex.context.parameters.ContextParameters","schemaParameters":{"Avro":{"parameterClassName":"org.onap.policy.apex.plugins.context.schema.avro.AvroSchemaHelperParameters"}}}},"policy_type_impl":{"apexPolicyModel":{"key":{"name":"APEXgRPCPolicy","version":"0.0.1"},"keyInformation":{"key":{"name":"APEXgRPCPolicy_KeyInfo","version":"0.0.1"},"keyInfoMap":{"entry":[{"key":{"name":"APEXgRPCPolicy","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy","version":"0.0.1"},"UUID":"b8424cdb-29fb-3566-b77a-f4f847d81cc9","description":"Generated description for concept referred to by key \"APEXgRPCPolicy:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Albums","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Albums","version":"0.0.1"},"UUID":"9922906c-ccaa-34f7-95e2-bcc36e77821b","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Albums:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Events","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Events","version":"0.0.1"},"UUID":"5bf28afd-787c-3138-a3e1-b33ad94a038a","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Events:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_KeyInfo","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_KeyInfo","version":"0.0.1"},"UUID":"68abaa6f-8d03-3a53-9590-007115817d5c","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_KeyInfo:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Policies","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Policies","version":"0.0.1"},"UUID":"819d06c3-33c2-3031-aa78-96281aa4270a","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Policies:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Schemas","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Schemas","version":"0.0.1"},"UUID":"8e67d466-f990-3a39-9fd7-4490cac342dc","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Schemas:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Tasks","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Tasks","version":"0.0.1"},"UUID":"4668db3d-6fe2-3885-8e47-f30cd0102f0a","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Tasks:0.0.1\""}},{"key":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"value":{"key":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"UUID":"6e5fa19b-14df-37e3-a4ae-8c537e861a82","description":"Generated description for concept referred to by key \"CDSActionIdentifiersType:0.0.1\""}},{"key":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"UUID":"8350ac5e-c157-38b9-9614-a0f93a830e60","description":"Generated description for concept referred to by key \"CDSCreateSubscriptionPayloadType:0.0.1\""}},{"key":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"UUID":"12658406-9147-3c9d-a38c-5ad5e30b092b","description":"Generated description for concept referred to by key \"CDSDeleteSubscriptionPayloadType:0.0.1\""}},{"key":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"value":{"key":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"UUID":"35590ac0-062c-39f1-8786-b4ff716e30b1","description":"Generated description for concept referred to by key \"CDSRequestCommonHeaderType:0.0.1\""}},{"key":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"value":{"key":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"UUID":"dd7e1805-885a-350b-aaf9-ed541321ae3c","description":"Generated description for concept referred to by key \"CDSResponseCommonHeaderType:0.0.1\""}},{"key":{"name":"CDSResponseEvent","version":"0.0.1"},"value":{"key":{"name":"CDSResponseEvent","version":"0.0.1"},"UUID":"15161037-9ac8-3223-820f-4e743562a345","description":"Generated description for concept referred to by key \"CDSResponseEvent:0.0.1\""}},{"key":{"name":"CDSResponsePayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSResponsePayloadType","version":"0.0.1"},"UUID":"97dc5f58-25bb-3c20-8d53-fdb70d7ca256","description":"Generated description for concept referred to by key \"CDSResponsePayloadType:0.0.1\""}},{"key":{"name":"CDSResponseStatusEvent","version":"0.0.1"},"value":{"key":{"name":"CDSResponseStatusEvent","version":"0.0.1"},"UUID":"7986e21b-32f7-302e-9554-31f21b673493","description":"Generated description for concept referred to by key \"CDSResponseStatusEvent:0.0.1\""}},{"key":{"name":"CDSResponseStatusType","version":"0.0.1"},"value":{"key":{"name":"CDSResponseStatusType","version":"0.0.1"},"UUID":"92b8a2cf-344e-3ce1-8cc0-2b7d3cb695fa","description":"Generated description for concept referred to by key \"CDSResponseStatusType:0.0.1\""}},{"key":{"name":"CDSResponseTask","version":"0.0.1"},"value":{"key":{"name":"CDSResponseTask","version":"0.0.1"},"UUID":"d22c78a5-272c-391d-8083-28588280caf9","description":"Generated description for concept referred to by key \"CDSResponseTask:0.0.1\""}},{"key":{"name":"CreateSubscriptionPayloadEvent","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionPayloadEvent","version":"0.0.1"},"UUID":"92162397-1a8e-3a3f-a469-d2af7700af4a","description":"Generated description for concept referred to by key \"CreateSubscriptionPayloadEvent:0.0.1\""}},{"key":{"name":"CreateSubscriptionPayloadTask","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionPayloadTask","version":"0.0.1"},"UUID":"bc0c69f0-52ed-38ea-b468-ae4a6fd1730d","description":"Generated description for concept referred to by key \"CreateSubscriptionPayloadTask:0.0.1\""}},{"key":{"name":"CreateSubscriptionRequestEvent","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionRequestEvent","version":"0.0.1"},"UUID":"7cfcf843-337e-3f41-b755-5043cb0a08fc","description":"Generated description for concept referred to by key \"CreateSubscriptionRequestEvent:0.0.1\""}},{"key":{"name":"CreateSubscriptionRequestTask","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionRequestTask","version":"0.0.1"},"UUID":"89cb75e9-f06c-30d3-b4ff-698d45f63869","description":"Generated description for concept referred to by key \"CreateSubscriptionRequestTask:0.0.1\""}},{"key":{"name":"DeleteSubscriptionPayloadEvent","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionPayloadEvent","version":"0.0.1"},"UUID":"994fa441-04ab-33bb-832d-1cd12ab5d074","description":"Generated description for concept referred to by key \"DeleteSubscriptionPayloadEvent:0.0.1\""}},{"key":{"name":"DeleteSubscriptionPayloadTask","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionPayloadTask","version":"0.0.1"},"UUID":"0f519117-5fea-3e4b-941f-8f778100465f","description":"Generated description for concept referred to by key \"DeleteSubscriptionPayloadTask:0.0.1\""}},{"key":{"name":"DeleteSubscriptionRequestEvent","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionRequestEvent","version":"0.0.1"},"UUID":"15d618d8-1689-3a05-89a5-05efa9388f65","description":"Generated description for concept referred to by key \"DeleteSubscriptionRequestEvent:0.0.1\""}},{"key":{"name":"DeleteSubscriptionRequestTask","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionRequestTask","version":"0.0.1"},"UUID":"acb772fe-d442-39e3-98f9-b1080caf4150","description":"Generated description for concept referred to by key \"DeleteSubscriptionRequestTask:0.0.1\""}},{"key":{"name":"PMSubscriptionAlbum","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionAlbum","version":"0.0.1"},"UUID":"c2bd6f0d-6854-317a-9be2-97c08338428c","description":"Generated description for concept referred to by key \"PMSubscriptionAlbum:0.0.1\""}},{"key":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"UUID":"992b7819-9f69-3aa0-bb0f-6e45ea15ce05","description":"Generated description for concept referred to by key \"PMSubscriptionOutputEvent:0.0.1\""}},{"key":{"name":"PMSubscriptionType","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionType","version":"0.0.1"},"UUID":"73c1c397-4fc3-357f-93b6-a8ad707fbaae","description":"Generated description for concept referred to by key \"PMSubscriptionType:0.0.1\""}},{"key":{"name":"ReceiveEventPolicy","version":"0.0.1"},"value":{"key":{"name":"ReceiveEventPolicy","version":"0.0.1"},"UUID":"568b7345-9de1-36d3-b6a3-9b857e6809a1","description":"Generated description for concept referred to by key \"ReceiveEventPolicy:0.0.1\""}},{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"value":{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"UUID":"6c1c6c45-26e0-3591-94bf-679d20e283f4","description":"Generated description for concept referred to by key \"ReceivePMSubscriptionTask:0.0.1\""}},{"key":{"name":"SimpleIntType","version":"0.0.1"},"value":{"key":{"name":"SimpleIntType","version":"0.0.1"},"UUID":"153791fd-ae0a-36a7-88a5-309a7936415d","description":"Generated description for concept referred to by key \"SimpleIntType:0.0.1\""}},{"key":{"name":"SimpleStringType","version":"0.0.1"},"value":{"key":{"name":"SimpleStringType","version":"0.0.1"},"UUID":"8a4957cf-9493-3a76-8c22-a208e23259af","description":"Generated description for concept referred to by key \"SimpleStringType:0.0.1\""}},{"key":{"name":"SubscriptionStatusType","version":"0.0.1"},"value":{"key":{"name":"SubscriptionStatusType","version":"0.0.1"},"UUID":"597643b1-9db1-31ce-85d0-e1c63c43b30b","description":"Generated description for concept referred to by key \"SubscriptionStatusType:0.0.1\""}},{"key":{"name":"SubscriptionType","version":"0.0.1"},"value":{"key":{"name":"SubscriptionType","version":"0.0.1"},"UUID":"184547bb-7d64-3cb2-a273-d7185102c5ce","description":"Generated description for concept referred to by key \"SubscriptionType:0.0.1\""}},{"key":{"name":"UUIDType","version":"0.0.1"},"value":{"key":{"name":"UUIDType","version":"0.0.1"},"UUID":"6a8cc68e-dfc8-3403-9c6d-071c886b319c","description":"Generated description for concept referred to by key \"UUIDType:0.0.1\""}},{"key":{"name":"testPolicyB","version":"0.0.1"},"value":{"key":{"name":"testPolicyB","version":"0.0.1"},"UUID":"ead590a3-ba2e-3a01-b6e9-9329f5c8fee1","description":"Generated description for concept referred to by key \"testPolicyB:0.0.1\""}}]}},"policies":{"key":{"name":"APEXgRPCPolicy_Policies","version":"0.0.1"},"policyMap":{"entry":[{"key":{"name":"ReceiveEventPolicy","version":"0.0.1"},"value":{"policyKey":{"name":"ReceiveEventPolicy","version":"0.0.1"},"template":"Freestyle","state":{"entry":[{"key":"ReceiveSubscriptionState","value":{"stateKey":{"parentKeyName":"ReceiveEventPolicy","parentKeyVersion":"0.0.1","parentLocalName":"NULL","localName":"ReceiveSubscriptionState"},"trigger":{"name":"testPolicyB","version":"0.0.1"},"stateOutputs":{"entry":[{"key":"ReceivePMSubscriptionOutput","value":{"key":{"parentKeyName":"ReceiveEventPolicy","parentKeyVersion":"0.0.1","parentLocalName":"ReceiveSubscriptionState","localName":"ReceivePMSubscriptionOutput"},"outgoingEvent":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"nextState":{"parentKeyName":"NULL","parentKeyVersion":"0.0.0","parentLocalName":"NULL","localName":"NULL"}}}]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskSelectionLogic":{"key":"NULL","logicFlavour":"UNDEFINED","logic":""},"stateFinalizerLogicMap":{"entry":[]},"defaultTask":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"taskReferences":{"entry":[{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"value":{"key":{"parentKeyName":"ReceiveEventPolicy","parentKeyVersion":"0.0.1","parentLocalName":"ReceiveSubscriptionState","localName":"ReceiveEventPolicy"},"outputType":"DIRECT","output":{"parentKeyName":"ReceiveEventPolicy","parentKeyVersion":"0.0.1","parentLocalName":"ReceiveSubscriptionState","localName":"ReceivePMSubscriptionOutput"}}}]}}}]},"firstState":"ReceiveSubscriptionState"}}]}},"tasks":{"key":{"name":"APEXgRPCPolicy_Tasks","version":"0.0.1"},"taskMap":{"entry":[{"key":{"name":"CDSResponseTask","version":"0.0.1"},"value":{"key":{"name":"CDSResponseTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSResponsePayloadType","version":"0.0.1"},"optional":false}},{"key":"status","value":{"key":"status","fieldSchemaKey":{"name":"CDSResponseStatusType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"status","value":{"key":"status","fieldSchemaKey":{"name":"SubscriptionStatusType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n *  Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n *      http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\n\nvar uuidType = java.util.UUID;\n\nvar albumID = uuidType.fromString(\"d0050623-18e5-46c9-9298-9a567990cd7c\");\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(albumID.toString());\n\nvar responseStatus = executor.subject.getOutFieldSchemaHelper(\"status\").createNewInstance();\n\nresponseStatus.put(\"subscriptionName\", pmSubscriptionInfo.get(\"subscription\").get(\"subscriptionName\"))\nresponseStatus.put(\"nfName\", pmSubscriptionInfo.get(\"nfName\"))\nresponseStatus.put(\"changeType\", pmSubscriptionInfo.get(\"changeType\"))\n\nvar response = executor.inFields.get(\"payload\")\n\nif (\"failure\".equals(response.get(\"create_DasH_subscription_DasH_response\").get(\"odl_DasH_response\").get(\"status\"))) {\n    responseStatus.put(\"message\", \"failed\")\n} else {\n    responseStatus.put(\"message\", \"success\")\n}\n\nexecutor.outFields.put(\"status\", responseStatus)\n\ntrue;"}}},{"key":{"name":"CreateSubscriptionPayloadTask","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionPayloadTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n *  Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n *      http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\nexecutor.logger.info(executor.subject.id);\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(executor.inFields.get(\"albumID\").toString())\n\nvar payloadProperties = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"create_DasH_subscription_DasH_properties_record\");\n\npayloadProperties.put(\"nfName\",  pmSubscriptionInfo.get(\"nfName\"))\npayloadProperties.put(\"subscriptionName\",  pmSubscriptionInfo.get(\"subscription\").get(\"subscriptionName\"))\npayloadProperties.put(\"administrativeState\", pmSubscriptionInfo.get(\"subscription\").get(\"administrativeState\"))\npayloadProperties.put(\"fileBasedGP\",  pmSubscriptionInfo.get(\"subscription\").get(\"fileBasedGP\").toString())\npayloadProperties.put(\"fileLocation\", pmSubscriptionInfo.get(\"subscription\").get(\"fileLocation\"))\npayloadProperties.put(\"measurementGroups\", pmSubscriptionInfo.get(\"subscription\").get(\"measurementGroups\"))\n\nvar payloadEntry = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"CDSRequestPayloadEntry\");\npayloadEntry.put(\"create_DasH_subscription_DasH_properties\", payloadProperties)\n\nvar payload = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewInstance();\nvar payloadSchemaHelper = executor.subject.getOutFieldSchemaHelper(\"payload\");\npayload.put(\"create_DasH_subscription_DasH_request\", payloadEntry);\n\nexecutor.logger.info(\"CDS payload - \" + executor.stringify2Json( payload, payloadSchemaHelper));\n\nexecutor.outFields.put(\"albumID\", executor.inFields.get(\"albumID\"));\nexecutor.outFields.put(\"payload\", payload);\n\nexecutor.logger.info(\"Sending Create Subscription Event to CDS\");\n\ntrue;"}}},{"key":{"name":"CreateSubscriptionRequestTask","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionRequestTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n *  Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n *      http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\nexecutor.logger.info(executor.subject.id);\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(executor.inFields.get(\"albumID\").toString())\nvar payload = executor.inFields.get(\"payload\")\nvar actionName = \"create-subscription\"\n\nvar commonHeader = executor.subject.getOutFieldSchemaHelper(\"commonHeader\").createNewInstance();\ncommonHeader.put(\"originatorId\", \"sdnc\");\ncommonHeader.put(\"requestId\", \"123456-1000\");\ncommonHeader.put(\"subRequestId\", \"sub-123456-1000\");\n\nvar actionIdentifiers = executor.subject.getOutFieldSchemaHelper(\"actionIdentifiers\").createNewInstance();\nactionIdentifiers.put(\"actionName\", actionName);\nactionIdentifiers.put(\"blueprintName\", \"pm_control\");\nactionIdentifiers.put(\"blueprintVersion\", \"1.0.0\");\nactionIdentifiers.put(\"mode\", \"sync\");\n\nexecutor.outFields.put(\"commonHeader\", commonHeader);\nexecutor.outFields.put(\"actionIdentifiers\", actionIdentifiers);\nexecutor.outFields.put(\"payload\", payload);\n\nexecutor.logger.info(\"Sending Activate Subscription Event to CDS\")\n\ntrue;"}}},{"key":{"name":"DeleteSubscriptionPayloadTask","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionPayloadTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n *  Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n *      http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\nexecutor.logger.info(executor.subject.id);\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(executor.inFields.get(\"albumID\").toString())\n\nvar payloadProperties = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"delete_DasH_subscription_DasH_properties_record\");\n\npayloadProperties.put(\"nfName\",  pmSubscriptionInfo.get(\"nfName\"))\npayloadProperties.put(\"subscriptionName\",  pmSubscriptionInfo.get(\"subscription\").get(\"subscriptionName\"))\npayloadProperties.put(\"administrativeState\", pmSubscriptionInfo.get(\"subscription\").get(\"administrativeState\"))\npayloadProperties.put(\"fileBasedGP\",  pmSubscriptionInfo.get(\"subscription\").get(\"fileBasedGP\").toString())\npayloadProperties.put(\"fileLocation\", pmSubscriptionInfo.get(\"subscription\").get(\"fileLocation\"))\npayloadProperties.put(\"measurementGroups\", pmSubscriptionInfo.get(\"subscription\").get(\"measurementGroups\"))\n\nvar payloadEntry = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"CDSRequestPayloadEntry\");\npayloadEntry.put(\"delete_DasH_subscription_DasH_properties\", payloadProperties)\n\nvar payload = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewInstance();\npayload.put(\"delete_DasH_subscription_DasH_request\", payloadEntry);\n\nexecutor.outFields.put(\"albumID\", executor.inFields.get(\"albumID\"))\nexecutor.outFields.put(\"payload\", payload);\n\nexecutor.logger.info(\"Sending delete Subscription Event to CDS\")\n\ntrue;"}}},{"key":{"name":"DeleteSubscriptionRequestTask","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionRequestTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n *  Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n *      http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\nexecutor.logger.info(executor.subject.id);\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(executor.inFields.get(\"albumID\").toString())\nvar payload = executor.inFields.get(\"payload\")\nvar actionName = \"delete-subscription\"\n\nvar commonHeader = executor.subject.getOutFieldSchemaHelper(\"commonHeader\").createNewInstance();\ncommonHeader.put(\"originatorId\", \"sdnc\");\ncommonHeader.put(\"requestId\", \"123456-1000\");\ncommonHeader.put(\"subRequestId\", \"sub-123456-1000\");\n\nvar actionIdentifiers = executor.subject.getOutFieldSchemaHelper(\"actionIdentifiers\").createNewInstance();\nactionIdentifiers.put(\"actionName\", actionName);\nactionIdentifiers.put(\"blueprintName\", \"pm_control\");\nactionIdentifiers.put(\"blueprintVersion\", \"1.0.0\");\nactionIdentifiers.put(\"mode\", \"sync\");\n\nexecutor.outFields.put(\"commonHeader\", commonHeader);\nexecutor.outFields.put(\"actionIdentifiers\", actionIdentifiers);\nexecutor.outFields.put(\"payload\", payload);\n\nexecutor.logger.info(\"Sending Deactivate Subscription Event to CDS\")\n\ntrue;"}}},{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"value":{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"changeType","value":{"key":"changeType","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"closedLoopControlName","value":{"key":"closedLoopControlName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"nfName","value":{"key":"nfName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"policyName","value":{"key":"policyName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"subscription","value":{"key":"subscription","fieldSchemaKey":{"name":"SubscriptionType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n *  Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n *      http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\nvar uuidType = java.util.UUID;\nvar HashMapType = java.util.HashMap;\n\nvar headers = new HashMapType();\n    //headers.put(\"Authorization\" , \"Basic Y2NzZGthcHBzOmNjc2RrYXBwcw==\");\nexecutor.logger.info(\"LogEvent11111111111\");\nvar response = new org.onap.policy.rest.RestManager().post(\n        \"http://10.2.0.149:32005/events/POLICY-CL-MGT\",\n        \"\",\n        \"\",\n        headers,\n        \"application/json\",\n        '{\"test\":\"test\"}'\n);\nexecutor.logger.info(\"DMaaP Response after sending LogEvent: \" + response);\n\n//albumID will be used to fetch info from our album later\nvar albumID = uuidType.fromString(\"d0050623-18e5-46c9-9298-9a567990cd7c\");\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").getSchemaHelper().createNewInstance();\nvar returnValue = true;;\n\nif (executor.inFields.get(\"policyName\") != null) {\n    var changeType = executor.inFields.get(\"changeType\")\n    var nfName = executor.inFields.get(\"nfName\")\n    var policyName = executor.inFields.get(\"policyName\")\n    var closedLoopControlName = executor.inFields.get(\"closedLoopControlName\")\n    var subscription = executor.inFields.get(\"subscription\")\n\n    var obj = {};\n    obj[\"nfName\"] = executor.inFields.get(\"nfName\")\n    executor.logger.info(\"nfName\" + executor.stringify2Json(obj))\n\n    var ticketInfo = new HashMapType();\n    populate_creator_info(ticketInfo);\n    executor.logger.info(\"ticketInfo\" + executor.stringify2Json(ticketInfo))\n\n    pmSubscriptionInfo.put(\"nfName\", executor.inFields.get(\"nfName\"));\n    pmSubscriptionInfo.put(\"changeType\", executor.inFields.get(\"changeType\"))\n    pmSubscriptionInfo.put(\"policyName\", executor.inFields.get(\"policyName\"))\n    pmSubscriptionInfo.put(\"closedLoopControlName\", executor.inFields.get(\"closedLoopControlName\"))\n    pmSubscriptionInfo.put(\"subscription\", subscription)\n\n    executor.getContextAlbum(\"PMSubscriptionAlbum\").put(albumID.toString(), pmSubscriptionInfo);\n\n    executor.outFields.put(\"albumID\", albumID)\n} else {\n    executor.message = \"Received invalid event\"\n    returnValue = false;\n}\n\nfunction populate_creator_info(ticketInfo){\n    populate_field(ticketInfo, \"appId\", \"NSO\");\n    populate_field(ticketInfo, \"creatorId\", \"fidLab\");\n    populate_field(ticketInfo, \"creatorFirstName\", \"PSO\");\n    populate_field(ticketInfo, \"creatorLastName\", \"team7\");\n    populate_field(ticketInfo, \"creatorGroup\", \"PSO-team7\");\n    populate_field(ticketInfo, \"creatorPEIN\", \"0000000\");\n    populate_field(ticketInfo, \"creatorPhoneNumber\", \"800-450-7771\");\n    populate_field(ticketInfo, \"fid\", \"fidLab\");\n    populate_field(ticketInfo, \"organizationCode\", \"PSO\");\n    populate_field(ticketInfo, \"source\", create_caEn_value(\"SURV/ALARM FROM/PSO\"));\n    populate_field(ticketInfo, \"customerName\", \"XYZ\");\n    populate_field(ticketInfo, \"authorization\", \"Basic dGVzdHVzZXI=\");\n}\n\nfunction populate_field(mapname, name, value){\n    if (value == null){\n        mapname.put(name, \"none\");\n    } else{\n        mapname.put(name, value);\n    }\n\n}\n\nfunction create_caEn_value(value){\n    var attr = {};\n    attr[\"caEn\"] = String(value);\n    return attr;\n}\n\nreturnValue;"}}}]}},"events":{"key":{"name":"APEXgRPCPolicy_Events","version":"0.0.1"},"eventMap":{"entry":[{"key":{"name":"CDSResponseEvent","version":"0.0.1"},"value":{"key":{"name":"CDSResponseEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"CDS","target":"APEX","parameter":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSResponsePayloadType","version":"0.0.1"},"optional":false}},{"key":"status","value":{"key":"status","fieldSchemaKey":{"name":"CDSResponseStatusType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"CDSResponseStatusEvent","version":"0.0.1"},"value":{"key":{"name":"CDSResponseStatusEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"DCAE","parameter":{"entry":[{"key":"status","value":{"key":"status","fieldSchemaKey":{"name":"SubscriptionStatusType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"CreateSubscriptionPayloadEvent","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionPayloadEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"CreateSubscriptionRequestEvent","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionRequestEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"DeleteSubscriptionPayloadEvent","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionPayloadEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"DeleteSubscriptionRequestEvent","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionRequestEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"testPolicyB","version":"0.0.1"},"value":{"key":{"name":"testPolicyB","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"DCAE","target":"APEX","parameter":{"entry":[{"key":"changeType","value":{"key":"changeType","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"closedLoopControlName","value":{"key":"closedLoopControlName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"nfName","value":{"key":"nfName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"policyName","value":{"key":"policyName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"subscription","value":{"key":"subscription","fieldSchemaKey":{"name":"SubscriptionType","version":"0.0.1"},"optional":false}}]}}}]}},"albums":{"key":{"name":"APEXgRPCPolicy_Albums","version":"0.0.1"},"albums":{"entry":[{"key":{"name":"PMSubscriptionAlbum","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionAlbum","version":"0.0.1"},"scope":"policy","isWritable":true,"itemSchema":{"name":"PMSubscriptionType","version":"0.0.1"}}}]}},"schemas":{"key":{"name":"APEXgRPCPolicy_Schemas","version":"0.0.1"},"schemas":{"entry":[{"key":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"value":{"key":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n    \"type\": \"record\",\n    \"name\": \"CDSActionIdentifiers_Type\",\n    \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n    \"fields\": [\n        {\n            \"name\": \"actionName\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"blueprintName\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"blueprintVersion\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"mode\",\n            \"type\": \"string\"\n        }\n    ]\n}"}},{"key":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n  \"type\": \"map\",\n  \"values\": {\n    \"type\": \"record\",\n    \"name\": \"CDSRequestPayloadEntry\",\n    \"fields\": [\n      {\n        \"name\": \"create_DasH_subscription_DasH_properties\",\n        \"type\": {\n          \"name\": \"create_DasH_subscription_DasH_properties_record\",\n          \"type\": \"record\",\n          \"fields\": [\n            {\n              \"name\": \"nfName\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"subscriptionName\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"administrativeState\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"fileBasedGP\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"fileLocation\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"measurementGroups\",\n              \"type\": {\n                \"type\": \"array\",\n                \"items\": {\n                  \"name\": \"measurementGroups_record\",\n                  \"type\": \"record\",\n                  \"fields\": [\n                    {\n                      \"name\": \"measurementGroup\",\n                      \"type\": {\n                        \"name\": \"measurementGroup\",\n                        \"type\": \"record\",\n                        \"fields\": [\n                          {\n                            \"name\": \"measurementTypes\",\n                            \"type\": {\n                              \"type\": \"array\",\n                              \"items\": {\n                                \"name\": \"measurementTypes_record\",\n                                \"type\": \"record\",\n                                \"fields\": [\n                                  {\n                                    \"name\": \"measurementType\",\n                                    \"type\": \"string\"\n                                  }\n                                ]\n                              }\n                            }\n                          },\n                          {\n                            \"name\": \"managedObjectDNsBasic\",\n                            \"type\": {\n                              \"type\": \"array\",\n                              \"items\": {\n                                \"name\": \"managedObjectDNsBasic_record\",\n                                \"type\": \"record\",\n                                \"fields\": [\n                                  {\n                                    \"name\": \"DN\",\n                                    \"type\": \"string\"\n                                  }\n                                ]\n                              }\n                            }\n                          }\n                        ]\n                      }\n                    }\n                  ]\n                }\n              }\n            }\n          ]\n        }\n      }\n    ]\n  }\n}"}},{"key":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n  \"type\": \"map\",\n  \"values\": {\n    \"type\": \"record\",\n    \"name\": \"CDSRequestPayloadEntry\",\n    \"fields\": [\n      {\n        \"name\": \"delete_DasH_subscription_DasH_properties\",\n        \"type\": {\n          \"name\": \"delete_DasH_subscription_DasH_properties_record\",\n          \"type\": \"record\",\n          \"fields\": [\n            {\n              \"name\": \"nfName\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"subscriptionName\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"administrativeState\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"fileBasedGP\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"fileLocation\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"measurementGroups\",\n              \"type\": {\n                \"type\": \"array\",\n                \"items\": {\n                  \"name\": \"measurementGroups_record\",\n                  \"type\": \"record\",\n                  \"fields\": [\n                    {\n                      \"name\": \"measurementGroup\",\n                      \"type\": {\n                        \"name\": \"measurementGroup\",\n                        \"type\": \"record\",\n                        \"fields\": [\n                          {\n                            \"name\": \"measurementTypes\",\n                            \"type\": {\n                              \"type\": \"array\",\n                              \"items\": {\n                                \"name\": \"measurementTypes_record\",\n                                \"type\": \"record\",\n                                \"fields\": [\n                                  {\n                                    \"name\": \"measurementType\",\n                                    \"type\": \"string\"\n                                  }\n                                ]\n                              }\n                            }\n                          },\n                          {\n                            \"name\": \"managedObjectDNsBasic\",\n                            \"type\": {\n                              \"type\": \"array\",\n                              \"items\": {\n                                \"name\": \"managedObjectDNsBasic_record\",\n                                \"type\": \"record\",\n                                \"fields\": [\n                                  {\n                                    \"name\": \"DN\",\n                                    \"type\": \"string\"\n                                  }\n                                ]\n                              }\n                            }\n                          }\n                        ]\n                      }\n                    }\n                  ]\n                }\n              }\n            }\n          ]\n        }\n      }\n    ]\n  }\n}"}},{"key":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"value":{"key":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n    \"type\": \"record\",\n    \"name\": \"CDSRequestCommonHeader_Type\",\n    \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n    \"fields\": [\n        {\n            \"name\": \"originatorId\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"requestId\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"subRequestId\",\n            \"type\": \"string\"\n        }\n    ]\n}"}},{"key":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"value":{"key":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n    \"type\": \"record\",\n    \"name\": \"CDSResponseCommonHeader_Type\",\n    \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n    \"fields\": [\n        {\n            \"name\": \"originatorId\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"requestId\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"subRequestId\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"timestamp\",\n            \"type\": \"string\"\n        }\n    ]\n}"}},{"key":{"name":"CDSResponsePayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSResponsePayloadType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n  \"name\": \"CDSResponsePayloadEntry\",\n  \"type\": \"record\",\n  \"namespace\": \"com.acme.avro\",\n  \"fields\": [\n    {\n      \"name\": \"create_DasH_subscription_DasH_response\",\n      \"type\": {\n        \"name\": \"create_DasH_subscription_DasH_response\",\n        \"type\": \"record\",\n        \"fields\": [\n          {\n            \"name\": \"odl_DasH_response\",\n            \"type\": {\n              \"name\": \"odl_DasH_response\",\n              \"type\": \"record\",\n              \"fields\": [\n                  {\n                    \"name\": \"status\",\n                    \"type\": \"string\"\n                  }\n              ]\n            }\n          }\n        ]\n      }\n    }\n  ]\n}"}},{"key":{"name":"CDSResponseStatusType","version":"0.0.1"},"value":{"key":{"name":"CDSResponseStatusType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n    \"type\": \"record\",\n    \"name\": \"CDSResponseStatus_Type\",\n    \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n    \"fields\": [\n        {\n            \"name\": \"code\",\n            \"type\": \"int\"\n        },\n        {\n            \"name\": \"eventType\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"timestamp\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"message\",\n            \"type\": \"string\"\n        }\n    ]\n}"}},{"key":{"name":"PMSubscriptionType","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n  \"name\": \"PMSubscription\",\n  \"type\": \"record\",\n  \"namespace\": \"org.onap.policy.apex.onap.pmcontrol\",\n  \"fields\": [\n    {\n      \"name\": \"nfName\",\n      \"type\": \"string\"\n    },\n    {\n      \"name\": \"changeType\",\n      \"type\": \"string\"\n    },\n    {\n      \"name\": \"closedLoopControlName\",\n      \"type\": \"string\"\n    },\n    {\n      \"name\": \"policyName\",\n      \"type\": \"string\"\n    },\n    {\n      \"name\": \"subscription\",\n      \"type\": {\n        \"name\": \"subscription\",\n        \"type\": \"record\",\n        \"fields\": [\n          {\n            \"name\": \"subscriptionName\",\n            \"type\": \"string\"\n          },\n          {\n            \"name\": \"administrativeState\",\n            \"type\": \"string\"\n          },\n          {\n            \"name\": \"fileBasedGP\",\n            \"type\": \"int\"\n          },\n          {\n            \"name\": \"fileLocation\",\n            \"type\": \"string\"\n          },\n          {\n            \"name\": \"measurementGroups\",\n            \"type\": {\n              \"type\": \"array\",\n              \"items\": {\n                \"name\": \"Measurement_Groups_Type\",\n                \"type\": \"record\",\n                \"fields\": [\n                  {\n                    \"name\": \"measurementGroup\",\n                    \"type\": {\n                      \"name\": \"Measurement_Group_Type\",\n                      \"type\": \"record\",\n                      \"fields\": [\n                        {\n                          \"name\": \"measurementTypes\",\n                          \"type\": {\n                            \"type\": \"array\",\n                            \"items\": {\n                              \"name\": \"Measurement_Types_Type\",\n                              \"type\": \"record\",\n                              \"fields\": [\n                                {\n                                  \"name\": \"measurementType\",\n                                  \"type\": \"string\"\n                                }\n                              ]\n                            }\n                          }\n                        },\n                        {\n                          \"name\": \"managedObjectDNsBasic\",\n                          \"type\": {\n                            \"type\": \"array\",\n                            \"items\": {\n                              \"name\": \"Managed_Object_Dns_Basic_Type\",\n                              \"type\": \"record\",\n                              \"fields\": [\n                                {\n                                  \"name\": \"DN\",\n                                  \"type\": \"string\"\n                                }\n                              ]\n                            }\n                          }\n                        }\n                      ]\n                    }\n                  }\n                ]\n              }\n            }\n          }\n        ]\n      }\n    }\n  ]\n}"}},{"key":{"name":"SimpleIntType","version":"0.0.1"},"value":{"key":{"name":"SimpleIntType","version":"0.0.1"},"schemaFlavour":"Java","schemaDefinition":"java.lang.Integer"}},{"key":{"name":"SimpleStringType","version":"0.0.1"},"value":{"key":{"name":"SimpleStringType","version":"0.0.1"},"schemaFlavour":"Java","schemaDefinition":"java.lang.String"}},{"key":{"name":"SubscriptionStatusType","version":"0.0.1"},"value":{"key":{"name":"SubscriptionStatusType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n    \"type\": \"record\",\n    \"name\": \"ActivateSubscriptionStatus_Type\",\n    \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n    \"fields\": [\n        {\n            \"name\": \"subscriptionName\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"nfName\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"changeType\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"message\",\n            \"type\": \"string\"\n        }\n    ]\n}"}},{"key":{"name":"SubscriptionType","version":"0.0.1"},"value":{"key":{"name":"SubscriptionType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n  \"name\": \"subscription\",\n  \"type\": \"record\",\n  \"fields\": [\n    {\n      \"name\": \"subscriptionName\",\n      \"type\": \"string\"\n    },\n    {\n      \"name\": \"administrativeState\",\n      \"type\": \"string\"\n    },\n    {\n      \"name\": \"fileBasedGP\",\n      \"type\": \"int\"\n    },\n    {\n      \"name\": \"fileLocation\",\n      \"type\": \"string\"\n    },\n    {\n      \"name\": \"measurementGroups\",\n      \"type\": {\n        \"type\": \"array\",\n        \"items\": {\n          \"name\": \"Measurement_Groups_Type\",\n          \"type\": \"record\",\n          \"fields\": [\n            {\n              \"name\": \"measurementGroup\",\n              \"type\": {\n                \"name\": \"Measurement_Group_Type\",\n                \"type\": \"record\",\n                \"fields\": [\n                  {\n                    \"name\": \"measurementTypes\",\n                    \"type\": {\n                      \"type\": \"array\",\n                      \"items\": {\n                        \"name\": \"Measurement_Types_Type\",\n                        \"type\": \"record\",\n                        \"fields\": [\n                          {\n                            \"name\": \"measurementType\",\n                            \"type\": \"string\"\n                          }\n                        ]\n                      }\n                    }\n                  },\n                  {\n                    \"name\": \"managedObjectDNsBasic\",\n                    \"type\": {\n                      \"type\": \"array\",\n                      \"items\": {\n                        \"name\": \"Managed_Object_Dns_Basic_Type\",\n                        \"type\": \"record\",\n                        \"fields\": [\n                          {\n                            \"name\": \"DN\",\n                            \"type\": \"string\"\n                          }\n                        ]\n                      }\n                    }\n                  }\n                ]\n              }\n            }\n          ]\n        }\n      }\n    }\n  ]\n}"}},{"key":{"name":"UUIDType","version":"0.0.1"},"value":{"key":{"name":"UUIDType","version":"0.0.1"},"schemaFlavour":"Java","schemaDefinition":"java.util.UUID"}}]}}}}},"eventOutputParameters":{"logOutputter02":{"carrierTechnologyParameters":{"carrierTechnology":"FILE","parameters":{"fileName":"outputevents.log"}},"eventProtocolParameters":{"eventProtocol":"JSON"}}},"eventInputParameters":{"DCAEConsumer02":{"carrierTechnologyParameters":{"carrierTechnology":"RESTCLIENT","parameterClassName":"org.onap.policy.apex.plugins.event.carrier.restclient.RestClientCarrierTechnologyParameters","parameters":{"url":"http://message-router:3904/events/unauthenticated.DCAE_CL_OUTPUT/APEX/1?timeout=30000"}},"eventProtocolParameters":{"eventProtocol":"JSON","parameters":{"nameAlias":"testPolicyC"}},"eventName":"testPolicyC","eventNameFilter":"testPolicyC"}}},"name":"onap.policies.native.apex.Grpc.test02","version":"1.0.0","metadata":{"policy-id":"onap.policies.native.apex.Grpc.test02","policy-version":"1.0.0"}}],"policiesToBeUndeployed":[]


Code Block
languagebash
titlePDP_STATUS
[2021-05-07T09:51:56.817+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp status response message for PdpUpdate","policies":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test02","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T09:51:56.816871Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":53,"policyDeploySuccessCount":40,"policyDeployFailCount":13,"policyExecutedCount":4,"policyExecutedSuccessCount":4,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620378914283,"eventCount":1,"lastExecutionTime":12294,"averageExecutionTime":12294.0,"upTime":95138,"lastEnterTime":0,"lastStart":1620378819145},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620378819150,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620378819150},{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620381116802,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620381116802},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620381116805,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620381116805}]},"response":{"responseTo":"26b5a061-0d2b-4d51-b6d9-82fa070bfa2b","responseStatus":"SUCCESS","responseMessage":"Apex engine started and policies are running."},"messageName":"PDP_STATUS","requestId":"31a82b3e-8b00-4ed4-b416-a60030252f38","timestampMs":1620381116816,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}


Code Block
languagebash
titleHeartbeat
[2021-05-07T10:02:54.148+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [IN|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp Heartbeat","policies":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test02","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T10:02:53.449056Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":53,"policyDeploySuccessCount":40,"policyDeployFailCount":13,"policyExecutedCount":4,"policyExecutedSuccessCount":4,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620378914283,"eventCount":1,"lastExecutionTime":12294,"averageExecutionTime":12294.0,"upTime":95138,"lastEnterTime":0,"lastStart":1620378819145},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620378819150,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620378819150},{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620381116802,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620381116802},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620381116805,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620381116805}]},"messageName":"PDP_STATUS","requestId":"2717f480-9c10-4574-a85f-ed6043b6c795","timestampMs":1620381773449,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}


3

Undeploy Policy #1. Verify Policy #2 is still running.

Verify policiesToBeUndeployed list contains Policy 1.

Verify PDP_STATUS message does not contain Policy 1.

Verify Heartbeat only has Policy 2.

Code Block
languagebash
titlePDP_UPDATE
[2021-05-07T10:24:07.540+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [IN|DMAAP|POLICY-PDP-PAP]
{"description":"The default group that registers all supported policy types and pdps." . . 
.
.
"policiesToBeDeployed":[],"policiesToBeUndeployed":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"}],"messageName":"PDP_UPDATE","requestId":"09d262c5-34cb-4a22-8853-d83f3264ccec","timestampMs":1620383045958,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}


Code Block
languagebash
titlePDP_STATUS
[2021-05-07T10:24:07.825+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp status response message for PdpUpdate","policies":[{"name":"onap.policies.native.apex.Grpc.test02","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T10:24:07.825165Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":54,"policyDeploySuccessCount":41,"policyDeployFailCount":13,"policyExecutedCount":4,"policyExecutedSuccessCount":4,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620381116802,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620381116802},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620381116805,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620381116805}]},"response":{"responseTo":"09d262c5-34cb-4a22-8853-d83f3264ccec","responseStatus":"SUCCESS","responseMessage":"Apex engine started and policies are running."},"messageName":"PDP_STATUS","requestId":"46c9b20a-71c1-4c50-81ad-a493b895d071","timestampMs":1620383047825,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}


Code Block
languagebash
titleHeartbeat
[2021-05-07T10:26:54.113+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [IN|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp Heartbeat","policies":[{"name":"onap.policies.native.apex.Grpc.test02","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T10:26:53.449146Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":54,"policyDeploySuccessCount":41,"policyDeployFailCount":13,"policyExecutedCount":4,"policyExecutedSuccessCount":4,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620381116802,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620381116802},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620381116805,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620381116805}]},"messageName":"PDP_STATUS","requestId":"86480e16-083b-46d9-b39e-3f0392e6c255","timestampMs":1620383213449,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}


4

Undeploy Policy #2. Verify no policies are running.

Verify Policy 2 is in policiesToBeUndeployed list.

Very Policy 2 is not in PDP_STATUS list of policies. Verify no policies are running.

Very Policy 2 is not in Heartbeat message.

Code Block
languagebash
titlePDP_UPDATE
[2021-05-07T10:29:38.862+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [IN|DMAAP|POLICY-PDP-PAP]
{"description":"The default group that registers all supported policy types and pdps.","policies":[],"policiesToBeDeployed":[],"policiesToBeUndeployed":[{"name":"onap.policies.native.apex.Grpc.test02","version":"1.0.0"}],"messageName":"PDP_UPDATE","requestId":"fbce7644-69d2-4b00-82cc-159d2e6171a1","timestampMs":1620383378137,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}
[2021-05-07T10:29:38.862+00:00|WARN|Registry|DMAAP-source-POLICY-PDP-PAP] replacing previously registered: object:apex/tosca/policy/list


Code Block
languagebash
titlePDP_STATUS
[2021-05-07T10:29:39.164+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp status response message for PdpUpdate","policies":[],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T10:29:39.164124Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":54,"policyDeploySuccessCount":41,"policyDeployFailCount":13,"policyExecutedCount":4,"policyExecutedSuccessCount":4,"policyExecutedFailCount":0,"engineStats":[]},"response":{"responseTo":"fbce7644-69d2-4b00-82cc-159d2e6171a1","responseStatus":"SUCCESS","responseMessage":"Pdp update successful. No policies are running."},"messageName":"PDP_STATUS","requestId":"01b98607-524e-4f77-98b6-ac4342e53cf0","timestampMs":1620383379164,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}


Code Block
languagebash
titleHeartbeat
[2021-05-07T10:30:53.448+00:00|INFO|network|Timer-0] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp Heartbeat","policies":[],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T10:30:53.448595Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":54,"policyDeploySuccessCount":41,"policyDeployFailCount":13,"policyExecutedCount":4,"policyExecutedSuccessCount":4,"policyExecutedFailCount":0,"engineStats":[]},"messageName":"PDP_STATUS","requestId":"a020a375-5671-44e9-9876-00c22a876553","timestampMs":1620383453448,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}


5Deploy Policy #1, #2, #3. Make sure all are running.

Code Block
languagebash
titlePDP_UPDATE
[2021-05-07T11:52:57.432+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [IN|DMAAP|POLICY-PDP-PAP]
{"description":"The default group that registers all supported policy types and pdps. . . 
.
.
.
"policiesToBeDeployed":[{"type":"onap.policies.native.Apex","type_version":"1.0.0","properties":{"engineServiceParameters":{"name":"MyApexEngine","version":"0.0.1","id":45,"instanceCount":2,"deploymentPort":12561,"engineParameters":{"executorParameters":{"JAVASCRIPT":{"parameterClassName":"org.onap.policy.apex.plugins.executor.javascript.JavascriptExecutorParameters"}},
.
.
.
"metadata":{"policy-id":"onap.policies.native.apex.Grpc.test03","policy-version":"1.0.0"}}],"policiesToBeUndeployed":[]


Code Block
languagebash
titlePDP_STATUS
2021-05-07T11:52:57.684+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp status response message for PdpUpdate","policies":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test02","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test03","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T11:52:57.684007Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":55,"policyDeploySuccessCount":42,"policyDeployFailCount":13,"policyExecutedCount":4,"policyExecutedSuccessCount":4,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377514,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377514},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377522,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377522},{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377600,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377600},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377604,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377604},{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377668,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377668},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377672,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377672}]},"response":{"responseTo":"d534d254-cb6d-4cfb-99cb-94e167fb5504","responseStatus":"SUCCESS","responseMessage":"Apex engine started and policies are running."},"messageName":"PDP_STATUS","requestId":"76b5edee-db9e-400e-b01f-7d00413fee9b","timestampMs":1620388377683,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}


Code Block
languagebash
titleHeartbeat
[2021-05-07T11:54:53.453+00:00|INFO|network|Timer-0] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp Heartbeat","policies":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test02","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test03","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T11:54:53.448764Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":55,"policyDeploySuccessCount":42,"policyDeployFailCount":13,"policyExecutedCount":4,"policyExecutedSuccessCount":4,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377514,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377514},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377522,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377522},{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377600,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377600},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377604,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377604},{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377668,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377668},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377672,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377672}]},"messageName":"PDP_STATUS","requestId":"642f3af4-7752-410e-a6c4-39e39cbbcaae","timestampMs":1620388493448,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}


6

Undeploy Policy #2. Make sure Policy #1 and Policy #2 are running. Remove Policies #1 & #3. Make sure none are running.

Verify ALL policies in policiesToBeDeployed.

Verify ALL policies in PDP_STATUS message.

Verify ALL policies in heartbeat.

Code Block
languagebash
titlePDP_UPDATE
[2021-05-07T12:14:13.097+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [IN|DMAAP|POLICY-PDP-PAP]
{"description":"The default group that registers all supported policy types and pdps." . . .
.
.
"policiesToBeDeployed":[],"policiesToBeUndeployed":[{"name":"onap.policies.native.apex.Grpc.test02","version":"1.0.0"}],"messageName":"PDP_UPDATE","requestId":"ebe313d7-a48a-4e2b-96d9-0e6fc38feef8","timestampMs":1620389652214,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}


Code Block
languagebash
titlePDP_STATUS
[2021-05-07T12:14:13.383+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp status response message for PdpUpdate","policies":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test03","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T12:14:13.382804Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":56,"policyDeploySuccessCount":43,"policyDeployFailCount":13,"policyExecutedCount":4,"policyExecutedSuccessCount":4,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377514,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377514},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377522,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377522},{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377668,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377668},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377672,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377672}]},"response":{"responseTo":"ebe313d7-a48a-4e2b-96d9-0e6fc38feef8","responseStatus":"SUCCESS","responseMessage":"Apex engine started and policies are running."},"messageName":"PDP_STATUS","requestId":"e2bb4044-c33a-4810-baf9-7d720400aff1","timestampMs":1620389653382,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}


Code Block
languagebash
titleHeartbeat
[2021-05-07T12:16:54.117+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [IN|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp Heartbeat","policies":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test03","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T12:16:53.448840Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":56,"policyDeploySuccessCount":43,"policyDeployFailCount":13,"policyExecutedCount":4,"policyExecutedSuccessCount":4,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377514,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377514},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377522,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377522},{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377668,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377668},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377672,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377672}]},"messageName":"PDP_STATUS","requestId":"7ea03028-a6db-4bfb-96d3-847af75a4652","timestampMs":1620389813448,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}


#7Deploy Policy to fail.


Code Block
languagebash
titlePDP_UPDATE
collapsetrue
[2021-05-07T12:21:13.105+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [IN|DMAAP|POLICY-PDP-PAP]
{"description":"The default group that registers all supported policy types and pdps." . . .
.
.
.
"policiesToBeDeployed":[{"type":"onap.policies.native.Apex","type_version":"1.0.0","properties":{"engineServiceParameters":{"name":"MyApexEngine","version":"0.0.1","id":45,"instanceCount":2,"deploymentPort":12561,"engineParameters":{"executorParameters":{"JAVASCRIPT":{"parameterClassName":"org.onap.policy.apex.plugins.executor.javascript.JavascriptExecutorParameters"}},"contextParameters":{"parameterClassName":"org.onap.policy.apex.context.parameters.ContextParameters","schemaParameters":{"Avro":{"parameterClassName":"org.onap.policy.apex.plugins.context.schema.avro.AvroSchemaHelperParameters"}}}},"policy_type_impl":{"apexPolicyModel":{"key":{"name":"APEXgRPCPolicy","version":"0.0.1"},"keyInformation":{"key":{"name":"APEXgRPCPolicy_KeyInfo","version":"0.0.1"},"keyInfoMap":{"entry":[{"key":{"name":"APEXgRPCPolicy","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy","version":"0.0.1"},"UUID":"b8424cdb-29fb-3566-b77a-f4f847d81cc9","description":"Generated description for concept referred to by key \"APEXgRPCPolicy:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Albums","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Albums","version":"0.0.1"},"UUID":"9922906c-ccaa-34f7-95e2-bcc36e77821b","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Albums:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Events","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Events","version":"0.0.1"},"UUID":"5bf28afd-787c-3138-a3e1-b33ad94a038a","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Events:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_KeyInfo","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_KeyInfo","version":"0.0.1"},"UUID":"68abaa6f-8d03-3a53-9590-007115817d5c","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_KeyInfo:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Policies","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Policies","version":"0.0.1"},"UUID":"819d06c3-33c2-3031-aa78-96281aa4270a","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Policies:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Schemas","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Schemas","version":"0.0.1"},"UUID":"8e67d466-f990-3a39-9fd7-4490cac342dc","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Schemas:0.0.1\""}},{"key":{"name":"APEXgRPCPolicy_Tasks","version":"0.0.1"},"value":{"key":{"name":"APEXgRPCPolicy_Tasks","version":"0.0.1"},"UUID":"4668db3d-6fe2-3885-8e47-f30cd0102f0a","description":"Generated description for concept referred to by key \"APEXgRPCPolicy_Tasks:0.0.1\""}},{"key":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"value":{"key":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"UUID":"6e5fa19b-14df-37e3-a4ae-8c537e861a82","description":"Generated description for concept referred to by key \"CDSActionIdentifiersType:0.0.1\""}},{"key":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"UUID":"8350ac5e-c157-38b9-9614-a0f93a830e60","description":"Generated description for concept referred to by key \"CDSCreateSubscriptionPayloadType:0.0.1\""}},{"key":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"UUID":"12658406-9147-3c9d-a38c-5ad5e30b092b","description":"Generated description for concept referred to by key \"CDSDeleteSubscriptionPayloadType:0.0.1\""}},{"key":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"value":{"key":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"UUID":"35590ac0-062c-39f1-8786-b4ff716e30b1","description":"Generated description for concept referred to by key \"CDSRequestCommonHeaderType:0.0.1\""}},{"key":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"value":{"key":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"UUID":"dd7e1805-885a-350b-aaf9-ed541321ae3c","description":"Generated description for concept referred to by key \"CDSResponseCommonHeaderType:0.0.1\""}},{"key":{"name":"CDSResponseEvent","version":"0.0.1"},"value":{"key":{"name":"CDSResponseEvent","version":"0.0.1"},"UUID":"15161037-9ac8-3223-820f-4e743562a345","description":"Generated description for concept referred to by key \"CDSResponseEvent:0.0.1\""}},{"key":{"name":"CDSResponsePayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSResponsePayloadType","version":"0.0.1"},"UUID":"97dc5f58-25bb-3c20-8d53-fdb70d7ca256","description":"Generated description for concept referred to by key \"CDSResponsePayloadType:0.0.1\""}},{"key":{"name":"CDSResponseStatusEvent","version":"0.0.1"},"value":{"key":{"name":"CDSResponseStatusEvent","version":"0.0.1"},"UUID":"7986e21b-32f7-302e-9554-31f21b673493","description":"Generated description for concept referred to by key \"CDSResponseStatusEvent:0.0.1\""}},{"key":{"name":"CDSResponseStatusType","version":"0.0.1"},"value":{"key":{"name":"CDSResponseStatusType","version":"0.0.1"},"UUID":"92b8a2cf-344e-3ce1-8cc0-2b7d3cb695fa","description":"Generated description for concept referred to by key \"CDSResponseStatusType:0.0.1\""}},{"key":{"name":"CDSResponseTask","version":"0.0.1"},"value":{"key":{"name":"CDSResponseTask","version":"0.0.1"},"UUID":"d22c78a5-272c-391d-8083-28588280caf9","description":"Generated description for concept referred to by key \"CDSResponseTask:0.0.1\""}},{"key":{"name":"CreateSubscriptionPayloadEvent","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionPayloadEvent","version":"0.0.1"},"UUID":"92162397-1a8e-3a3f-a469-d2af7700af4a","description":"Generated description for concept referred to by key \"CreateSubscriptionPayloadEvent:0.0.1\""}},{"key":{"name":"CreateSubscriptionPayloadTask","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionPayloadTask","version":"0.0.1"},"UUID":"bc0c69f0-52ed-38ea-b468-ae4a6fd1730d","description":"Generated description for concept referred to by key \"CreateSubscriptionPayloadTask:0.0.1\""}},{"key":{"name":"CreateSubscriptionRequestEvent","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionRequestEvent","version":"0.0.1"},"UUID":"7cfcf843-337e-3f41-b755-5043cb0a08fc","description":"Generated description for concept referred to by key \"CreateSubscriptionRequestEvent:0.0.1\""}},{"key":{"name":"CreateSubscriptionRequestTask","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionRequestTask","version":"0.0.1"},"UUID":"89cb75e9-f06c-30d3-b4ff-698d45f63869","description":"Generated description for concept referred to by key \"CreateSubscriptionRequestTask:0.0.1\""}},{"key":{"name":"DeleteSubscriptionPayloadEvent","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionPayloadEvent","version":"0.0.1"},"UUID":"994fa441-04ab-33bb-832d-1cd12ab5d074","description":"Generated description for concept referred to by key \"DeleteSubscriptionPayloadEvent:0.0.1\""}},{"key":{"name":"DeleteSubscriptionPayloadTask","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionPayloadTask","version":"0.0.1"},"UUID":"0f519117-5fea-3e4b-941f-8f778100465f","description":"Generated description for concept referred to by key \"DeleteSubscriptionPayloadTask:0.0.1\""}},{"key":{"name":"DeleteSubscriptionRequestEvent","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionRequestEvent","version":"0.0.1"},"UUID":"15d618d8-1689-3a05-89a5-05efa9388f65","description":"Generated description for concept referred to by key \"DeleteSubscriptionRequestEvent:0.0.1\""}},{"key":{"name":"DeleteSubscriptionRequestTask","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionRequestTask","version":"0.0.1"},"UUID":"acb772fe-d442-39e3-98f9-b1080caf4150","description":"Generated description for concept referred to by key \"DeleteSubscriptionRequestTask:0.0.1\""}},{"key":{"name":"PMSubscriptionAlbum","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionAlbum","version":"0.0.1"},"UUID":"c2bd6f0d-6854-317a-9be2-97c08338428c","description":"Generated description for concept referred to by key \"PMSubscriptionAlbum:0.0.1\""}},{"key":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"UUID":"992b7819-9f69-3aa0-bb0f-6e45ea15ce05","description":"Generated description for concept referred to by key \"PMSubscriptionOutputEvent:0.0.1\""}},{"key":{"name":"PMSubscriptionType","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionType","version":"0.0.1"},"UUID":"73c1c397-4fc3-357f-93b6-a8ad707fbaae","description":"Generated description for concept referred to by key \"PMSubscriptionType:0.0.1\""}},{"key":{"name":"ReceiveEventPolicy","version":"0.0.1"},"value":{"key":{"name":"ReceiveEventPolicy","version":"0.0.1"},"UUID":"568b7345-9de1-36d3-b6a3-9b857e6809a1","description":"Generated description for concept referred to by key \"ReceiveEventPolicy:0.0.1\""}},{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"value":{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"UUID":"6c1c6c45-26e0-3591-94bf-679d20e283f4","description":"Generated description for concept referred to by key \"ReceivePMSubscriptionTask:0.0.1\""}},{"key":{"name":"SimpleIntType","version":"0.0.1"},"value":{"key":{"name":"SimpleIntType","version":"0.0.1"},"UUID":"153791fd-ae0a-36a7-88a5-309a7936415d","description":"Generated description for concept referred to by key \"SimpleIntType:0.0.1\""}},{"key":{"name":"SimpleStringType","version":"0.0.1"},"value":{"key":{"name":"SimpleStringType","version":"0.0.1"},"UUID":"8a4957cf-9493-3a76-8c22-a208e23259af","description":"Generated description for concept referred to by key \"SimpleStringType:0.0.1\""}},{"key":{"name":"SubscriptionStatusType","version":"0.0.1"},"value":{"key":{"name":"SubscriptionStatusType","version":"0.0.1"},"UUID":"597643b1-9db1-31ce-85d0-e1c63c43b30b","description":"Generated description for concept referred to by key \"SubscriptionStatusType:0.0.1\""}},{"key":{"name":"SubscriptionType","version":"0.0.1"},"value":{"key":{"name":"SubscriptionType","version":"0.0.1"},"UUID":"184547bb-7d64-3cb2-a273-d7185102c5ce","description":"Generated description for concept referred to by key \"SubscriptionType:0.0.1\""}},{"key":{"name":"UUIDType","version":"0.0.1"},"value":{"key":{"name":"UUIDType","version":"0.0.1"},"UUID":"6a8cc68e-dfc8-3403-9c6d-071c886b319c","description":"Generated description for concept referred to by key \"UUIDType:0.0.1\""}},{"key":{"name":"testPolicyB","version":"0.0.1"},"value":{"key":{"name":"testPolicyB","version":"0.0.1"},"UUID":"ead590a3-ba2e-3a01-b6e9-9329f5c8fee1","description":"Generated description for concept referred to by key \"testPolicyB:0.0.1\""}}]}},"policies":{"key":{"name":"APEXgRPCPolicy_Policies","version":"0.0.1"},"policyMap":{"entry":[{"key":{"name":"ReceiveEventPolicy","version":"0.0.1"},"value":{"policyKey":{"name":"ReceiveEventPolicy","version":"0.0.1"},"template":"Freestyle","state":{"entry":[{"key":"ReceiveSubscriptionState","value":{"stateKey":{"parentKeyName":"ReceiveEventPolicy","parentKeyVersion":"0.0.1","parentLocalName":"NULL","localName":"ReceiveSubscriptionState"},"trigger":{"name":"testPolicyB","version":"0.0.1"},"stateOutputs":{"entry":[{"key":"ReceivePMSubscriptionOutput","value":{"key":{"parentKeyName":"ReceiveEventPolicy","parentKeyVersion":"0.0.1","parentLocalName":"ReceiveSubscriptionState","localName":"ReceivePMSubscriptionOutput"},"outgoingEvent":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"nextState":{"parentKeyName":"NULL","parentKeyVersion":"0.0.0","parentLocalName":"NULL","localName":"NULL"}}}]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskSelectionLogic":{"key":"NULL","logicFlavour":"UNDEFINED","logic":""},"stateFinalizerLogicMap":{"entry":[]},"defaultTask":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"taskReferences":{"entry":[{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"value":{"key":{"parentKeyName":"ReceiveEventPolicy","parentKeyVersion":"0.0.1","parentLocalName":"ReceiveSubscriptionState","localName":"ReceiveEventPolicy"},"outputType":"DIRECT","output":{"parentKeyName":"ReceiveEventPolicy","parentKeyVersion":"0.0.1","parentLocalName":"ReceiveSubscriptionState","localName":"ReceivePMSubscriptionOutput"}}}]}}}]},"firstState":"ReceiveSubscriptionState"}}]}},"tasks":{"key":{"name":"APEXgRPCPolicy_Tasks","version":"0.0.1"},"taskMap":{"entry":[{"key":{"name":"CDSResponseTask","version":"0.0.1"},"value":{"key":{"name":"CDSResponseTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSResponsePayloadType","version":"0.0.1"},"optional":false}},{"key":"status","value":{"key":"status","fieldSchemaKey":{"name":"CDSResponseStatusType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"status","value":{"key":"status","fieldSchemaKey":{"name":"SubscriptionStatusType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n *  Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n *      http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\n\nvar uuidType = java.util.UUID;\n\nvar albumID = uuidType.fromString(\"d0050623-18e5-46c9-9298-9a567990cd7c\");\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(albumID.toString());\n\nvar responseStatus = executor.subject.getOutFieldSchemaHelper(\"status\").createNewInstance();\n\nresponseStatus.put(\"subscriptionName\", pmSubscriptionInfo.get(\"subscription\").get(\"subscriptionName\"))\nresponseStatus.put(\"nfName\", pmSubscriptionInfo.get(\"nfName\"))\nresponseStatus.put(\"changeType\", pmSubscriptionInfo.get(\"changeType\"))\n\nvar response = executor.inFields.get(\"payload\")\n\nif (\"failure\".equals(response.get(\"create_DasH_subscription_DasH_response\").get(\"odl_DasH_response\").get(\"status\"))) {\n    responseStatus.put(\"message\", \"failed\")\n} else {\n    responseStatus.put(\"message\", \"success\")\n}\n\nexecutor.outFields.put(\"status\", responseStatus)\n\ntrue;"}}},{"key":{"name":"CreateSubscriptionPayloadTask","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionPayloadTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n *  Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n *      http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\nexecutor.logger.info(executor.subject.id);\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(executor.inFields.get(\"albumID\").toString())\n\nvar payloadProperties = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"create_DasH_subscription_DasH_properties_record\");\n\npayloadProperties.put(\"nfName\",  pmSubscriptionInfo.get(\"nfName\"))\npayloadProperties.put(\"subscriptionName\",  pmSubscriptionInfo.get(\"subscription\").get(\"subscriptionName\"))\npayloadProperties.put(\"administrativeState\", pmSubscriptionInfo.get(\"subscription\").get(\"administrativeState\"))\npayloadProperties.put(\"fileBasedGP\",  pmSubscriptionInfo.get(\"subscription\").get(\"fileBasedGP\").toString())\npayloadProperties.put(\"fileLocation\", pmSubscriptionInfo.get(\"subscription\").get(\"fileLocation\"))\npayloadProperties.put(\"measurementGroups\", pmSubscriptionInfo.get(\"subscription\").get(\"measurementGroups\"))\n\nvar payloadEntry = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"CDSRequestPayloadEntry\");\npayloadEntry.put(\"create_DasH_subscription_DasH_properties\", payloadProperties)\n\nvar payload = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewInstance();\nvar payloadSchemaHelper = executor.subject.getOutFieldSchemaHelper(\"payload\");\npayload.put(\"create_DasH_subscription_DasH_request\", payloadEntry);\n\nexecutor.logger.info(\"CDS payload - \" + executor.stringify2Json( payload, payloadSchemaHelper));\n\nexecutor.outFields.put(\"albumID\", executor.inFields.get(\"albumID\"));\nexecutor.outFields.put(\"payload\", payload);\n\nexecutor.logger.info(\"Sending Create Subscription Event to CDS\");\n\ntrue;"}}},{"key":{"name":"CreateSubscriptionRequestTask","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionRequestTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n *  Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n *      http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\nexecutor.logger.info(executor.subject.id);\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(executor.inFields.get(\"albumID\").toString())\nvar payload = executor.inFields.get(\"payload\")\nvar actionName = \"create-subscription\"\n\nvar commonHeader = executor.subject.getOutFieldSchemaHelper(\"commonHeader\").createNewInstance();\ncommonHeader.put(\"originatorId\", \"sdnc\");\ncommonHeader.put(\"requestId\", \"123456-1000\");\ncommonHeader.put(\"subRequestId\", \"sub-123456-1000\");\n\nvar actionIdentifiers = executor.subject.getOutFieldSchemaHelper(\"actionIdentifiers\").createNewInstance();\nactionIdentifiers.put(\"actionName\", actionName);\nactionIdentifiers.put(\"blueprintName\", \"pm_control\");\nactionIdentifiers.put(\"blueprintVersion\", \"1.0.0\");\nactionIdentifiers.put(\"mode\", \"sync\");\n\nexecutor.outFields.put(\"commonHeader\", commonHeader);\nexecutor.outFields.put(\"actionIdentifiers\", actionIdentifiers);\nexecutor.outFields.put(\"payload\", payload);\n\nexecutor.logger.info(\"Sending Activate Subscription Event to CDS\")\n\ntrue;"}}},{"key":{"name":"DeleteSubscriptionPayloadTask","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionPayloadTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n *  Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n *      http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\nexecutor.logger.info(executor.subject.id);\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(executor.inFields.get(\"albumID\").toString())\n\nvar payloadProperties = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"delete_DasH_subscription_DasH_properties_record\");\n\npayloadProperties.put(\"nfName\",  pmSubscriptionInfo.get(\"nfName\"))\npayloadProperties.put(\"subscriptionName\",  pmSubscriptionInfo.get(\"subscription\").get(\"subscriptionName\"))\npayloadProperties.put(\"administrativeState\", pmSubscriptionInfo.get(\"subscription\").get(\"administrativeState\"))\npayloadProperties.put(\"fileBasedGP\",  pmSubscriptionInfo.get(\"subscription\").get(\"fileBasedGP\").toString())\npayloadProperties.put(\"fileLocation\", pmSubscriptionInfo.get(\"subscription\").get(\"fileLocation\"))\npayloadProperties.put(\"measurementGroups\", pmSubscriptionInfo.get(\"subscription\").get(\"measurementGroups\"))\n\nvar payloadEntry = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"CDSRequestPayloadEntry\");\npayloadEntry.put(\"delete_DasH_subscription_DasH_properties\", payloadProperties)\n\nvar payload = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewInstance();\npayload.put(\"delete_DasH_subscription_DasH_request\", payloadEntry);\n\nexecutor.outFields.put(\"albumID\", executor.inFields.get(\"albumID\"))\nexecutor.outFields.put(\"payload\", payload);\n\nexecutor.logger.info(\"Sending delete Subscription Event to CDS\")\n\ntrue;"}}},{"key":{"name":"DeleteSubscriptionRequestTask","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionRequestTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n *  Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n *      http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\n\nexecutor.logger.info(executor.subject.id);\n\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").get(executor.inFields.get(\"albumID\").toString())\nvar payload = executor.inFields.get(\"payload\")\nvar actionName = \"delete-subscription\"\n\nvar commonHeader = executor.subject.getOutFieldSchemaHelper(\"commonHeader\").createNewInstance();\ncommonHeader.put(\"originatorId\", \"sdnc\");\ncommonHeader.put(\"requestId\", \"123456-1000\");\ncommonHeader.put(\"subRequestId\", \"sub-123456-1000\");\n\nvar actionIdentifiers = executor.subject.getOutFieldSchemaHelper(\"actionIdentifiers\").createNewInstance();\nactionIdentifiers.put(\"actionName\", actionName);\nactionIdentifiers.put(\"blueprintName\", \"pm_control\");\nactionIdentifiers.put(\"blueprintVersion\", \"1.0.0\");\nactionIdentifiers.put(\"mode\", \"sync\");\n\nexecutor.outFields.put(\"commonHeader\", commonHeader);\nexecutor.outFields.put(\"actionIdentifiers\", actionIdentifiers);\nexecutor.outFields.put(\"payload\", payload);\n\nexecutor.logger.info(\"Sending Deactivate Subscription Event to CDS\")\n\ntrue;"}}},{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"value":{"key":{"name":"ReceivePMSubscriptionTask","version":"0.0.1"},"inputFields":{"entry":[{"key":"changeType","value":{"key":"changeType","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"closedLoopControlName","value":{"key":"closedLoopControlName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"nfName","value":{"key":"nfName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"policyName","value":{"key":"policyName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"subscription","value":{"key":"subscription","fieldSchemaKey":{"name":"SubscriptionType","version":"0.0.1"},"optional":false}}]},"outputFields":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}}]},"taskParameters":{"entry":[]},"contextAlbumReference":[{"name":"PMSubscriptionAlbum","version":"0.0.1"}],"taskLogic":{"key":"TaskLogic","logicFlavour":"JAVASCRIPT","logic":"/*\n * ============LICENSE_START=======================================================\n *  Copyright (C) 2020 Nordix. All rights reserved.\n * ================================================================================\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n *      http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n *\n * SPDX-License-Identifier: Apache-2.0\n * ============LICENSE_END=========================================================\n */\nvar uuidType = java.util.UUID;\nvar HashMapType = java.util.HashMap;\n\nvar headers = new HashMapType();\n    //headers.put(\"Authorization\" , \"Basic Y2NzZGthcHBzOmNjc2RrYXBwcw==\");\nexecutor.logger.info(\"LogEvent11111111111\");\nvar response = new org.onap.policy.rest.RestManager().post(\n        \"http://10.2.0.149:32005/events/POLICY-CL-MGT\",\n        \"\",\n        \"\",\n        headers,\n        \"application/json\",\n        '{\"test\":\"test\"}'\n);\nexecutor.logger.info(\"DMaaP Response after sending LogEvent: \" + response);\n\n//albumID will be used to fetch info from our album later\nvar albumID = uuidType.fromString(\"d0050623-18e5-46c9-9298-9a567990cd7c\");\nvar pmSubscriptionInfo = executor.getContextAlbum(\"PMSubscriptionAlbum\").getSchemaHelper().createNewInstance();\nvar returnValue = true;;\n\nif (executor.inFields.get(\"policyName\") != null) {\n    var changeType = executor.inFields.get(\"changeType\")\n    var nfName = executor.inFields.get(\"nfName\")\n    var policyName = executor.inFields.get(\"policyName\")\n    var closedLoopControlName = executor.inFields.get(\"closedLoopControlName\")\n    var subscription = executor.inFields.get(\"subscription\")\n\n    var obj = {};\n    obj[\"nfName\"] = executor.inFields.get(\"nfName\")\n    executor.logger.info(\"nfName\" + executor.stringify2Json(obj))\n\n    var ticketInfo = new HashMapType();\n    populate_creator_info(ticketInfo);\n    executor.logger.info(\"ticketInfo\" + executor.stringify2Json(ticketInfo))\n\n    pmSubscriptionInfo.put(\"nfName\", executor.inFields.get(\"nfName\"));\n    pmSubscriptionInfo.put(\"changeType\", executor.inFields.get(\"changeType\"))\n    pmSubscriptionInfo.put(\"policyName\", executor.inFields.get(\"policyName\"))\n    pmSubscriptionInfo.put(\"closedLoopControlName\", executor.inFields.get(\"closedLoopControlName\"))\n    pmSubscriptionInfo.put(\"subscription\", subscription)\n\n    executor.getContextAlbum(\"PMSubscriptionAlbum\").put(albumID.toString(), pmSubscriptionInfo);\n\n    executor.outFields.put(\"albumID\", albumID)\n} else {\n    executor.message = \"Received invalid event\"\n    returnValue = false;\n}\n\nfunction populate_creator_info(ticketInfo){\n    populate_field(ticketInfo, \"appId\", \"NSO\");\n    populate_field(ticketInfo, \"creatorId\", \"fidLab\");\n    populate_field(ticketInfo, \"creatorFirstName\", \"PSO\");\n    populate_field(ticketInfo, \"creatorLastName\", \"team7\");\n    populate_field(ticketInfo, \"creatorGroup\", \"PSO-team7\");\n    populate_field(ticketInfo, \"creatorPEIN\", \"0000000\");\n    populate_field(ticketInfo, \"creatorPhoneNumber\", \"800-450-7771\");\n    populate_field(ticketInfo, \"fid\", \"fidLab\");\n    populate_field(ticketInfo, \"organizationCode\", \"PSO\");\n    populate_field(ticketInfo, \"source\", create_caEn_value(\"SURV/ALARM FROM/PSO\"));\n    populate_field(ticketInfo, \"customerName\", \"XYZ\");\n    populate_field(ticketInfo, \"authorization\", \"Basic dGVzdHVzZXI=\");\n}\n\nfunction populate_field(mapname, name, value){\n    if (value == null){\n        mapname.put(name, \"none\");\n    } else{\n        mapname.put(name, value);\n    }\n\n}\n\nfunction create_caEn_value(value){\n    var attr = {};\n    attr[\"caEn\"] = String(value);\n    return attr;\n}\n\nreturnValue;"}}}]}},"events":{"key":{"name":"APEXgRPCPolicy_Events","version":"0.0.1"},"eventMap":{"entry":[{"key":{"name":"CDSResponseEvent","version":"0.0.1"},"value":{"key":{"name":"CDSResponseEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"CDS","target":"APEX","parameter":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSResponsePayloadType","version":"0.0.1"},"optional":false}},{"key":"status","value":{"key":"status","fieldSchemaKey":{"name":"CDSResponseStatusType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"CDSResponseStatusEvent","version":"0.0.1"},"value":{"key":{"name":"CDSResponseStatusEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"DCAE","parameter":{"entry":[{"key":"status","value":{"key":"status","fieldSchemaKey":{"name":"SubscriptionStatusType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"CreateSubscriptionPayloadEvent","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionPayloadEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"CreateSubscriptionRequestEvent","version":"0.0.1"},"value":{"key":{"name":"CreateSubscriptionRequestEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"DeleteSubscriptionPayloadEvent","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionPayloadEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"DeleteSubscriptionRequestEvent","version":"0.0.1"},"value":{"key":{"name":"DeleteSubscriptionRequestEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"actionIdentifiers","value":{"key":"actionIdentifiers","fieldSchemaKey":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"optional":false}},{"key":"commonHeader","value":{"key":"commonHeader","fieldSchemaKey":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"optional":false}},{"key":"payload","value":{"key":"payload","fieldSchemaKey":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionOutputEvent","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"APEX","target":"APEX","parameter":{"entry":[{"key":"albumID","value":{"key":"albumID","fieldSchemaKey":{"name":"UUIDType","version":"0.0.1"},"optional":false}}]}}},{"key":{"name":"testPolicyB","version":"0.0.1"},"value":{"key":{"name":"testPolicyB","version":"0.0.1"},"nameSpace":"org.onap.policy.apex.onap.pmcontrol","source":"DCAE","target":"APEX","parameter":{"entry":[{"key":"changeType","value":{"key":"changeType","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"closedLoopControlName","value":{"key":"closedLoopControlName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"nfName","value":{"key":"nfName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"policyName","value":{"key":"policyName","fieldSchemaKey":{"name":"SimpleStringType","version":"0.0.1"},"optional":false}},{"key":"subscription","value":{"key":"subscription","fieldSchemaKey":{"name":"SubscriptionType","version":"0.0.1"},"optional":false}}]}}}]}},"albums":{"key":{"name":"APEXgRPCPolicy_Albums","version":"0.0.1"},"albums":{"entry":[{"key":{"name":"PMSubscriptionAlbum","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionAlbum","version":"0.0.1"},"scope":"policy","isWritable":true,"itemSchema":{"name":"PMSubscriptionType","version":"0.0.1"}}}]}},"schemas":{"key":{"name":"APEXgRPCPolicy_Schemas","version":"0.0.1"},"schemas":{"entry":[{"key":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"value":{"key":{"name":"CDSActionIdentifiersType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n    \"type\": \"record\",\n    \"name\": \"CDSActionIdentifiers_Type\",\n    \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n    \"fields\": [\n        {\n            \"name\": \"actionName\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"blueprintName\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"blueprintVersion\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"mode\",\n            \"type\": \"string\"\n        }\n    ]\n}"}},{"key":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSCreateSubscriptionPayloadType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n  \"type\": \"map\",\n  \"values\": {\n    \"type\": \"record\",\n    \"name\": \"CDSRequestPayloadEntry\",\n    \"fields\": [\n      {\n        \"name\": \"create_DasH_subscription_DasH_properties\",\n        \"type\": {\n          \"name\": \"create_DasH_subscription_DasH_properties_record\",\n          \"type\": \"record\",\n          \"fields\": [\n            {\n              \"name\": \"nfName\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"subscriptionName\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"administrativeState\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"fileBasedGP\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"fileLocation\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"measurementGroups\",\n              \"type\": {\n                \"type\": \"array\",\n                \"items\": {\n                  \"name\": \"measurementGroups_record\",\n                  \"type\": \"record\",\n                  \"fields\": [\n                    {\n                      \"name\": \"measurementGroup\",\n                      \"type\": {\n                        \"name\": \"measurementGroup\",\n                        \"type\": \"record\",\n                        \"fields\": [\n                          {\n                            \"name\": \"measurementTypes\",\n                            \"type\": {\n                              \"type\": \"array\",\n                              \"items\": {\n                                \"name\": \"measurementTypes_record\",\n                                \"type\": \"record\",\n                                \"fields\": [\n                                  {\n                                    \"name\": \"measurementType\",\n                                    \"type\": \"string\"\n                                  }\n                                ]\n                              }\n                            }\n                          },\n                          {\n                            \"name\": \"managedObjectDNsBasic\",\n                            \"type\": {\n                              \"type\": \"array\",\n                              \"items\": {\n                                \"name\": \"managedObjectDNsBasic_record\",\n                                \"type\": \"record\",\n                                \"fields\": [\n                                  {\n                                    \"name\": \"DN\",\n                                    \"type\": \"string\"\n                                  }\n                                ]\n                              }\n                            }\n                          }\n                        ]\n                      }\n                    }\n                  ]\n                }\n              }\n            }\n          ]\n        }\n      }\n    ]\n  }\n}"}},{"key":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSDeleteSubscriptionPayloadType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n  \"type\": \"map\",\n  \"values\": {\n    \"type\": \"record\",\n    \"name\": \"CDSRequestPayloadEntry\",\n    \"fields\": [\n      {\n        \"name\": \"delete_DasH_subscription_DasH_properties\",\n        \"type\": {\n          \"name\": \"delete_DasH_subscription_DasH_properties_record\",\n          \"type\": \"record\",\n          \"fields\": [\n            {\n              \"name\": \"nfName\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"subscriptionName\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"administrativeState\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"fileBasedGP\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"fileLocation\",\n              \"type\": \"string\"\n            },\n            {\n              \"name\": \"measurementGroups\",\n              \"type\": {\n                \"type\": \"array\",\n                \"items\": {\n                  \"name\": \"measurementGroups_record\",\n                  \"type\": \"record\",\n                  \"fields\": [\n                    {\n                      \"name\": \"measurementGroup\",\n                      \"type\": {\n                        \"name\": \"measurementGroup\",\n                        \"type\": \"record\",\n                        \"fields\": [\n                          {\n                            \"name\": \"measurementTypes\",\n                            \"type\": {\n                              \"type\": \"array\",\n                              \"items\": {\n                                \"name\": \"measurementTypes_record\",\n                                \"type\": \"record\",\n                                \"fields\": [\n                                  {\n                                    \"name\": \"measurementType\",\n                                    \"type\": \"string\"\n                                  }\n                                ]\n                              }\n                            }\n                          },\n                          {\n                            \"name\": \"managedObjectDNsBasic\",\n                            \"type\": {\n                              \"type\": \"array\",\n                              \"items\": {\n                                \"name\": \"managedObjectDNsBasic_record\",\n                                \"type\": \"record\",\n                                \"fields\": [\n                                  {\n                                    \"name\": \"DN\",\n                                    \"type\": \"string\"\n                                  }\n                                ]\n                              }\n                            }\n                          }\n                        ]\n                      }\n                    }\n                  ]\n                }\n              }\n            }\n          ]\n        }\n      }\n    ]\n  }\n}"}},{"key":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"value":{"key":{"name":"CDSRequestCommonHeaderType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n    \"type\": \"record\",\n    \"name\": \"CDSRequestCommonHeader_Type\",\n    \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n    \"fields\": [\n        {\n            \"name\": \"originatorId\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"requestId\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"subRequestId\",\n            \"type\": \"string\"\n        }\n    ]\n}"}},{"key":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"value":{"key":{"name":"CDSResponseCommonHeaderType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n    \"type\": \"record\",\n    \"name\": \"CDSResponseCommonHeader_Type\",\n    \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n    \"fields\": [\n        {\n            \"name\": \"originatorId\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"requestId\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"subRequestId\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"timestamp\",\n            \"type\": \"string\"\n        }\n    ]\n}"}},{"key":{"name":"CDSResponsePayloadType","version":"0.0.1"},"value":{"key":{"name":"CDSResponsePayloadType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n  \"name\": \"CDSResponsePayloadEntry\",\n  \"type\": \"record\",\n  \"namespace\": \"com.acme.avro\",\n  \"fields\": [\n    {\n      \"name\": \"create_DasH_subscription_DasH_response\",\n      \"type\": {\n        \"name\": \"create_DasH_subscription_DasH_response\",\n        \"type\": \"record\",\n        \"fields\": [\n          {\n            \"name\": \"odl_DasH_response\",\n            \"type\": {\n              \"name\": \"odl_DasH_response\",\n              \"type\": \"record\",\n              \"fields\": [\n                  {\n                    \"name\": \"status\",\n                    \"type\": \"string\"\n                  }\n              ]\n            }\n          }\n        ]\n      }\n    }\n  ]\n}"}},{"key":{"name":"CDSResponseStatusType","version":"0.0.1"},"value":{"key":{"name":"CDSResponseStatusType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n    \"type\": \"record\",\n    \"name\": \"CDSResponseStatus_Type\",\n    \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n    \"fields\": [\n        {\n            \"name\": \"code\",\n            \"type\": \"int\"\n        },\n        {\n            \"name\": \"eventType\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"timestamp\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"message\",\n            \"type\": \"string\"\n        }\n    ]\n}"}},{"key":{"name":"PMSubscriptionType","version":"0.0.1"},"value":{"key":{"name":"PMSubscriptionType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n  \"name\": \"PMSubscription\",\n  \"type\": \"record\",\n  \"namespace\": \"org.onap.policy.apex.onap.pmcontrol\",\n  \"fields\": [\n    {\n      \"name\": \"nfName\",\n      \"type\": \"string\"\n    },\n    {\n      \"name\": \"changeType\",\n      \"type\": \"string\"\n    },\n    {\n      \"name\": \"closedLoopControlName\",\n      \"type\": \"string\"\n    },\n    {\n      \"name\": \"policyName\",\n      \"type\": \"string\"\n    },\n    {\n      \"name\": \"subscription\",\n      \"type\": {\n        \"name\": \"subscription\",\n        \"type\": \"record\",\n        \"fields\": [\n          {\n            \"name\": \"subscriptionName\",\n            \"type\": \"string\"\n          },\n          {\n            \"name\": \"administrativeState\",\n            \"type\": \"string\"\n          },\n          {\n            \"name\": \"fileBasedGP\",\n            \"type\": \"int\"\n          },\n          {\n            \"name\": \"fileLocation\",\n            \"type\": \"string\"\n          },\n          {\n            \"name\": \"measurementGroups\",\n            \"type\": {\n              \"type\": \"array\",\n              \"items\": {\n                \"name\": \"Measurement_Groups_Type\",\n                \"type\": \"record\",\n                \"fields\": [\n                  {\n                    \"name\": \"measurementGroup\",\n                    \"type\": {\n                      \"name\": \"Measurement_Group_Type\",\n                      \"type\": \"record\",\n                      \"fields\": [\n                        {\n                          \"name\": \"measurementTypes\",\n                          \"type\": {\n                            \"type\": \"array\",\n                            \"items\": {\n                              \"name\": \"Measurement_Types_Type\",\n                              \"type\": \"record\",\n                              \"fields\": [\n                                {\n                                  \"name\": \"measurementType\",\n                                  \"type\": \"string\"\n                                }\n                              ]\n                            }\n                          }\n                        },\n                        {\n                          \"name\": \"managedObjectDNsBasic\",\n                          \"type\": {\n                            \"type\": \"array\",\n                            \"items\": {\n                              \"name\": \"Managed_Object_Dns_Basic_Type\",\n                              \"type\": \"record\",\n                              \"fields\": [\n                                {\n                                  \"name\": \"DN\",\n                                  \"type\": \"string\"\n                                }\n                              ]\n                            }\n                          }\n                        }\n                      ]\n                    }\n                  }\n                ]\n              }\n            }\n          }\n        ]\n      }\n    }\n  ]\n}"}},{"key":{"name":"SimpleIntType","version":"0.0.1"},"value":{"key":{"name":"SimpleIntType","version":"0.0.1"},"schemaFlavour":"Java","schemaDefinition":"java.lang.Integer"}},{"key":{"name":"SimpleStringType","version":"0.0.1"},"value":{"key":{"name":"SimpleStringType","version":"0.0.1"},"schemaFlavour":"Java","schemaDefinition":"java.lang.String"}},{"key":{"name":"SubscriptionStatusType","version":"0.0.1"},"value":{"key":{"name":"SubscriptionStatusType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n    \"type\": \"record\",\n    \"name\": \"ActivateSubscriptionStatus_Type\",\n    \"namespace\": \"org.onap.policy.apex.onap.helloworld\",\n    \"fields\": [\n        {\n            \"name\": \"subscriptionName\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"nfName\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"changeType\",\n            \"type\": \"string\"\n        },\n        {\n            \"name\": \"message\",\n            \"type\": \"string\"\n        }\n    ]\n}"}},{"key":{"name":"SubscriptionType","version":"0.0.1"},"value":{"key":{"name":"SubscriptionType","version":"0.0.1"},"schemaFlavour":"Avro","schemaDefinition":"{\n  \"name\": \"subscription\",\n  \"type\": \"record\",\n  \"fields\": [\n    {\n      \"name\": \"subscriptionName\",\n      \"type\": \"string\"\n    },\n    {\n      \"name\": \"administrativeState\",\n      \"type\": \"string\"\n    },\n    {\n      \"name\": \"fileBasedGP\",\n      \"type\": \"int\"\n    },\n    {\n      \"name\": \"fileLocation\",\n      \"type\": \"string\"\n    },\n    {\n      \"name\": \"measurementGroups\",\n      \"type\": {\n        \"type\": \"array\",\n        \"items\": {\n          \"name\": \"Measurement_Groups_Type\",\n          \"type\": \"record\",\n          \"fields\": [\n            {\n              \"name\": \"measurementGroup\",\n              \"type\": {\n                \"name\": \"Measurement_Group_Type\",\n                \"type\": \"record\",\n                \"fields\": [\n                  {\n                    \"name\": \"measurementTypes\",\n                    \"type\": {\n                      \"type\": \"array\",\n                      \"items\": {\n                        \"name\": \"Measurement_Types_Type\",\n                        \"type\": \"record\",\n                        \"fields\": [\n                          {\n                            \"name\": \"measurementType\",\n                            \"type\": \"string\"\n                          }\n                        ]\n                      }\n                    }\n                  },\n                  {\n                    \"name\": \"managedObjectDNsBasic\",\n                    \"type\": {\n                      \"type\": \"array\",\n                      \"items\": {\n                        \"name\": \"Managed_Object_Dns_Basic_Type\",\n                        \"type\": \"record\",\n                        \"fields\": [\n                          {\n                            \"name\": \"DN\",\n                            \"type\": \"string\"\n                          }\n                        ]\n                      }\n                    }\n                  }\n                ]\n              }\n            }\n          ]\n        }\n      }\n    }\n  ]\n}"}},{"key":{"name":"UUIDType","version":"0.0.1"},"value":{"key":{"name":"UUIDType","version":"0.0.1"},"schemaFlavour":"Java","schemaDefinition":"java.util.UUID"}}]}}}}},"eventOutputParameters":{"logOutputter03":{"carrierTechnologyParameters":{"carrierTechnology":"FILE","parameters":{"fileName":"outputevents.log"}},"eventProtocolParameters":{"eventProtocol":"JSON"}}},"eventInputParameters":{"DCAEConsumer03":{"carrierTechnologyParameters":{"carrierTechnology":"RESTCLIENT","parameterClassName":"org.onap.policy.apex.plugins.event.carrier.restclient.RestClientCarrierTechnologyParameters","parameters":{"url":"http://message-router:3904/events/unauthenticated.DCAE_CL_OUTPUT/APEX/1?timeout=30000"}},"eventProtocolParameters":{"eventProtocol":"JSON","parameters":{"nameAlias":"testPolicyD"}},"eventName":"testPolicyD","eventNameFilter":"testPolicyD"}}},"name":"onap.policies.native.apex.Grpc.test0fail","version":"1.0.0","metadata":{"policy-id":"onap.policies.native.apex.Grpc.test0fail","policy-version":"1.0.0"}}],"policiesToBeUndeployed":[]


Code Block
languagebash
titlePDP_STATUS
[2021-05-07T12:21:13.120+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp status response message for PdpUpdate","policies":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test03","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T12:21:13.120606Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":57,"policyDeploySuccessCount":43,"policyDeployFailCount":14,"policyExecutedCount":4,"policyExecutedSuccessCount":4,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377514,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377514},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377522,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377522},{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377668,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377668},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377672,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377672}]},"response":{"responseTo":"9f3cf978-cffa-481b-80a6-fbef7da0306d","responseStatus":"FAIL","responseMessage":"Apex engine service running failed. Updating the APEX engine with new policies failed."},"messageName":"PDP_STATUS","requestId":"74a90046-04c1-405e-9e81-c0497d25ebf8","timestampMs":1620390073120,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}


Code Block
languagebash
titlePDP_UPDATE
collapsetrue
[2021-05-07T12:21:15.342+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [IN|DMAAP|POLICY-PDP-PAP]
{"description":"The default group that registers all supported policy types and pdps." . .
.
.
.
"policiesToBeDeployed":[],"policiesToBeUndeployed":[{"name":"onap.policies.native.apex.Grpc.test0fail","version":"1.0.0"}],"messageName":"PDP_UPDATE","requestId":"3f38dd7a-19f3-4347-9e69-26147467d17f","timestampMs":1620390074460,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}


Code Block
languagebash
titlePDP_STATUS
[2021-05-07T12:21:15.345+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp status response message for PdpUpdate","policies":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test03","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T12:21:15.345674Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":57,"policyDeploySuccessCount":43,"policyDeployFailCount":14,"policyExecutedCount":4,"policyExecutedSuccessCount":4,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377514,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377514},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377522,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377522},{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377668,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377668},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377672,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377672}]},"response":{"responseTo":"3f38dd7a-19f3-4347-9e69-26147467d17f","responseStatus":"SUCCESS","responseMessage":"Pdp already updated"},"messageName":"PDP_STATUS","requestId":"62730772-226f-4b4c-b692-5014f43194fb","timestampMs":1620390075345,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}


Code Block
languagebash
titleHeartbeat
[2021-05-07T12:30:54.114+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [IN|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp Heartbeat","policies":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test03","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T12:30:53.448716Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":57,"policyDeploySuccessCount":43,"policyDeployFailCount":14,"policyExecutedCount":4,"policyExecutedSuccessCount":4,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377514,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377514},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377522,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377522},{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377668,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377668},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620388377672,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620388377672}]},"messageName":"PDP_STATUS","requestId":"7318dc86-d3ae-41cb-b432-ec76106933d2","timestampMs":1620390653448,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}


#8

Bring down apex-pdp pod with Policy 1 and Policy 3 deployed. Bring back up the pod and verify policies are deployed upon registration.

Verify heartbeat sent with no policies.

Verify pdp registered.

Verify PDP_UPDATE message sent with policiesToBeDeployed with Policy 1 and Policy 3 in list.

Verify PDP_STATUS has Policy 1 and 3 included.

Verify Heartbeat has both policies included.


Code Block
languagebash
titleHeartbeat
[2021-05-07T12:35:48.564+00:00|INFO|network|Timer-0] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"PASSIVE","healthy":"HEALTHY","description":"Pdp Heartbeat","statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T12:35:48.527864Z","pdpGroupName":"defaultGroup","policyDeployCount":0,"policyDeploySuccessCount":0,"policyDeployFailCount":0,"policyExecutedCount":0,"policyExecutedSuccessCount":0,"policyExecutedFailCount":0},"messageName":"PDP_STATUS","requestId":"8c053560-00e0-43f7-94e6-5d048308ac30","timestampMs":1620390948525,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup"}


Code Block
languagebash
titlePDP_UPDATE
[2021-05-07T12:36:21.125+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [IN|DMAAP|POLICY-PDP-PAP]
{"pdpHeartbeatIntervalMs":120000,"policies":[{"type":"onap.policies.native.Apex","type_version":"1.0.0" . .
.
.
"policiesToBeDeployed":[{"type":"onap.policies.native.Apex","type_version":"1.0.0","properties":{"engineServiceParameters":{"name":"MyApexEngine","version":"0.0.1","id":45,"instanceCount":2,"deploymentPort":12561
.
.
.
"eventInputParameters":{"DCAEConsumer03":{"carrierTechnologyParameters":{"carrierTechnology":"RESTCLIENT","parameterClassName":"org.onap.policy.apex.plugins.event.carrier.restclient.RestClientCarrierTechnologyParameters","parameters":{"url":"http://message-router:3904/events/unauthenticated.DCAE_CL_OUTPUT/APEX/1?timeout=30000"}},"eventProtocolParameters":{"eventProtocol":"JSON","parameters":{"nameAlias":"testPolicyD"}},"eventName":"testPolicyD","eventNameFilter":"testPolicyD"}}},"name":"onap.policies.native.apex.Grpc.test03","version":"1.0.0","metadata":{"policy-id":"onap.policies.native.apex.Grpc.test03","policy-version":"1.0.0"}}],"messageName":"PDP_UPDATE","requestId":"f219221d-25ac-4474-8585-2e85db37fe15","timestampMs":1620390950442,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}


Code Block
languagebash
titlePDP_STATUS
[2021-05-07T12:36:21.160+00:00|INFO|network|DMAAP-source-POLICY-PDP-PAP] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"PASSIVE","healthy":"HEALTHY","description":"Pdp status response message for PdpUpdate","policies":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test03","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T12:36:21.159886Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":0,"policyDeploySuccessCount":0,"policyDeployFailCount":0,"policyExecutedCount":0,"policyExecutedSuccessCount":0,"policyExecutedFailCount":0},"response":{"responseTo":"f219221d-25ac-4474-8585-2e85db37fe15","responseStatus":"SUCCESS","responseMessage":"Pdp update successful."},"messageName":"PDP_STATUS","requestId":"e103cd65-9d3c-4a73-bd6c-40699d4b0ca3","timestampMs":1620390981159,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}


Code Block
languagebash
titleHeartbeat
[2021-05-07T12:47:48.522+00:00|INFO|network|Timer-0] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp Heartbeat","policies":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test03","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T12:47:48.521403Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":1,"policyDeploySuccessCount":1,"policyDeployFailCount":0,"policyExecutedCount":0,"policyExecutedSuccessCount":0,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620390983946,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620390983946},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620390983961,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620390983961},{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620390984090,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620390984090},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620390984101,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620390984101}]},"messageName":"PDP_STATUS","requestId":"6516c4cd-fcd9-4fd5-b3fe-02917715d094","timestampMs":1620391668521,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}


#9Send event to Policy 1 when three policies are deployed. Verify event triggers policy.


Code Block
languagebash
titleHeartbeat after event sent
[2021-05-07T12:59:48.524+00:00|INFO|network|Timer-0] [OUT|DMAAP|POLICY-PDP-PAP]
{"pdpType":"apex","state":"ACTIVE","healthy":"HEALTHY","description":"Pdp Heartbeat","policies":[{"name":"onap.policies.native.apex.Grpc.test01","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test03","version":"1.0.0"},{"name":"onap.policies.native.apex.Grpc.test02","version":"1.0.0"}],"statistics":{"pdpInstanceId":"dev-policy-apex-pdp-0","timeStamp":"2021-05-07T12:59:48.521765Z","pdpGroupName":"defaultGroup","pdpSubGroupName":"apex","policyDeployCount":2,"policyDeploySuccessCount":2,"policyDeployFailCount":0,"policyExecutedCount":1,"policyExecutedSuccessCount":1,"policyExecutedFailCount":0,"engineStats":[{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620392295329,"eventCount":1,"lastExecutionTime":12375,"averageExecutionTime":12375.0,"upTime":1311383,"lastEnterTime":0,"lastStart":1620390983946},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620390983961,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620390983961},{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620390984090,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620390984090},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620390984101,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620390984101},{"engineId":"MyApexEngine-0:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620392018414,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620392018414},{"engineId":"MyApexEngine-1:0.0.1","engineWorkerState":"READY","engineTimeStamp":1620392018422,"eventCount":0,"lastExecutionTime":0,"averageExecutionTime":0.0,"upTime":0,"lastEnterTime":0,"lastStart":1620392018422}]},"messageName":"PDP_STATUS","requestId":"7b8f3a8f-0f13-40c6-bc18-ae1481c5c582","timestampMs":1620392388521,"name":"dev-policy-apex-pdp-0","pdpGroup":"defaultGroup","pdpSubgroup":"apex"}