Recent changes were made to apex-pdp to handle the delta policy lists sent from PAP.   POLICY-3170 - Getting issue details... STATUS

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. 




Test 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.

Output From Triggered Event
"policyExecutedCount":1,"policyExecutedSuccessCount":1,"policyExecutedFailCount":0
PDP_UPDATE
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":[]
PDP_STATUS
[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"}

Heartbeat 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.

PDP_UPDATE
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":[]
PDP_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"}

Heartbeat
[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.

PDP_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"}
PDP_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"}

Heartbeat
[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.

PDP_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

PDP_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"}

Heartbeat
[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.

PDP_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":[]


PDP_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"}


Heartbeat
[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.

PDP_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"}
PDP_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"}
Heartbeat
[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.
PDP_UPDATE
[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":[]
PDP_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"}
PDP_UPDATE
[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"}
PDP_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"}

Heartbeat
[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.

Heartbeat
[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"}

PDP_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"}
PDP_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"}
Heartbeat
[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.
Heartbeat 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"}


  • No labels

2 Comments

  1. Thanks for the tests Wayne Dunican

    Suggest you to add few more test cases to verify the PAP-PDP layer dmaap messaging. Some examples below:

    • When policyA is deployed only policyA is sent in the PDP_UPDATE message. After deployment PDP is replying back with policyA in the PDP_STATUS message. In the normal heartbeat only policyA is reported.
    • After that, when policyB is deployed only policyB is sent in the PDP_UPDATE message. After deployment PDP is replying back with policyB in the PDP_STATUS message. In the normal heartbeat both policyA & policyB are reported.
    • Repeat the same one more time for policyC.
    • Now undeploy the policies and verify the reverse behaviour.
    • Test with policies which are supposed to fail during deployment.
    • Restart apex-pdp pod when it has few policies deployed already.
    • Test the execution of policies when multiple policies are deployed.
  2. No problem Ram Krishna Verma

    Sounds good. I will update the test cases today.