X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=testsuites%2Fapex-pdp-stability%2Fsrc%2Fmain%2Fresources%2FapexPdpStabilityTestPlan.jmx;h=1ba0976de6ff795081c60cc9891938a52ecb4dd8;hb=refs%2Fheads%2Fmaster;hp=afeb77fab7c733c65e1dc00cba325b5aff2f1514;hpb=2f5f1dbd3c38dd3915760158a003b04ca69b478b;p=policy%2Fapex-pdp.git diff --git a/testsuites/apex-pdp-stability/src/main/resources/apexPdpStabilityTestPlan.jmx b/testsuites/apex-pdp-stability/src/main/resources/apexPdpStabilityTestPlan.jmx index afeb77fab..4700d18b7 100644 --- a/testsuites/apex-pdp-stability/src/main/resources/apexPdpStabilityTestPlan.jmx +++ b/testsuites/apex-pdp-stability/src/main/resources/apexPdpStabilityTestPlan.jmx @@ -3,7 +3,9 @@ ============LICENSE_START======================================================= ONAP Apex-PDP ================================================================================ - Copyright (C) 2020-2021 Nordix Foundation.All rights reserved. + Copyright (C) 2020-2022 Nordix Foundation.All rights reserved. + Modifications Copyright (C) 2021 Bell Canada. All rights reserved. + Modifications Copyright (C) 2024 Nordix Foundation. ================================================================================ Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. @@ -18,20 +20,17 @@ limitations under the License. ============LICENSE_END========================================================= --> - + - - - false - true + true - + true + - - + Content-Type @@ -44,18 +43,13 @@ - - - - - + 23324 http - - - 6 - - + + + + @@ -67,43 +61,53 @@ threadsTimeOutInMs - ${__P(threadsTimeOutInMs,5000)} + ${__P(threadsTimeOutInMs,2000)} = wait - ${__P(wait,10000)} + ${__P(wait,5000)} Wait time between requests to apex-pdp = PAP_PORT - ${__P(PAP_PORT,30211)} + ${__P(PAP_PORT,30003)} = API_PORT - ${__P(API_PORT,30785)} + ${__P(API_PORT,30002)} = APEX_PORT - ${__P(APEX_PORT,30687)} + ${__P(APEX_PORT,30001)} + = + + + KAFKA_PORT + ${__P(KAFKA_PORT,9092)} = - - DMAAP_PORT - ${__P(DMAAP_PORT,31345)} + + CDS_PORT + ${__P(CDS_PORT,6680)} = HOSTNAME - ${__P(HOSTNAME,10.2.0.120)} + ${__P(HOSTNAME,localhost)} = LOG_PATH - ${__P(LOG_PATH,/home/arkadiusza/apex_stability)} + ${__P(LOG_PATH,/jmeter_results/apex_stability)} + = + + + KAFKA_HOST + ${__P(KAFKA_HOST,localhost)} = @@ -112,22 +116,36 @@ - https://${HOSTNAME}:${API_PORT} - healthcheck + http://${HOSTNAME}:${API_PORT} + policyadmin + zb!XztG34 + + + + + http://${HOSTNAME}:${PAP_PORT} + policyadmin + zb!XztG34 + + + + + http://${HOSTNAME}:${APEX_PORT}/policy/apex-pdp/v1/healthcheck + policyadmin zb!XztG34 - https://${HOSTNAME}:${PAP_PORT} - healthcheck + http://${HOSTNAME}:${APEX_PORT}/metrics + policyadmin zb!XztG34 - https://${HOSTNAME}:${APEX_PORT} - healthcheck + http://${HOSTNAME}:${APEX_PORT} + policyadmin zb!XztG34 @@ -137,20 +155,25 @@ + 1 + 1 + true continue - - false + 1 + false - 1 - 1 - false - - - true - + + 6 + ${HOSTNAME} + ${API_PORT} + http + /policy/api/v1/policies + true + POST + true true @@ -161,15 +184,17 @@ "topology_template": { "policies": [ { - "operational.apex.stabilityTestDefaultDomain": { + "onap.policies.apex.Example": { "type": "onap.policies.native.Apex", "type_version": "1.0.0", + "name": "onap.policies.apex.Example", + "version": "1.0.0", "properties": { "engineServiceParameters": { - "name": "MyApexEngine", + "name": "NSOApexEngine", "version": "0.0.1", "id": 45, - "instanceCount": 4, + "instanceCount": 5, "deploymentPort": 12561, "engineParameters": { "executorParameters": { @@ -184,467 +209,599 @@ "parameterClassName": "org.onap.policy.apex.plugins.context.schema.avro.AvroSchemaHelperParameters" } } - } + }, + "taskParameters": [ + { + "key": "logUrl", + "value": "http://${KAFKA_HOST}:${KAFKA_PORT}/events/apex-cl-mgt" + } + ] }, "policy_type_impl": { "apexPolicyModel": { "key": { - "name": "APEXgRPCPolicy", + "name": "onap.policies.apex.Example", "version": "0.0.1" }, "keyInformation": { "key": { - "name": "APEXgRPCPolicy_KeyInfo", + "name": "onap.policies.apex.Example_KeyInfo", "version": "0.0.1" }, "keyInfoMap": { "entry": [ { "key": { - "name": "APEXgRPCPolicy", + "name": "ApexExample_AAIFailureResponseEvent", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_AAIFailureResponseEvent", + "version": "0.0.1" + }, + "UUID": "fc0c1892-a2ae-3678-818f-b9b23939b241", + "description": "Generated description for concept referred to by key \"ApexExample_AAIFailureResponseEvent:0.0.1\"" + } + }, + { + "key": { + "name": "ApexExample_AAIFailureResponseHandlerPolicy", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_AAIFailureResponseHandlerPolicy", + "version": "0.0.1" + }, + "UUID": "ba931e7e-aee9-3af8-98d8-16b92a909e8a", + "description": "Generated description for concept referred to by key \"ApexExample_AAIFailureResponseHandlerPolicy:0.0.1\"" + } + }, + { + "key": { + "name": "ApexExample_AAIRequestErrorType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_AAIRequestErrorType", + "version": "0.0.1" + }, + "UUID": "b4dd59c5-0169-3810-800c-1396c2206de4", + "description": "Generated description for concept referred to by key \"ApexExample_AAIRequestErrorType:0.0.1\"" + } + }, + { + "key": { + "name": "ApexExample_AAIRequestEvent", "version": "0.0.1" }, "value": { "key": { - "name": "APEXgRPCPolicy", + "name": "ApexExample_AAIRequestEvent", "version": "0.0.1" }, - "UUID": "b8424cdb-29fb-3566-b77a-f4f847d81cc9", - "description": "Generated description for concept referred to by key \"APEXgRPCPolicy:0.0.1\"" + "UUID": "599c297e-96c8-3b21-ad1c-e643bddeacbf", + "description": "Generated description for concept referred to by key \"ApexExample_AAIRequestEvent:0.0.1\"" } }, { "key": { - "name": "APEXgRPCPolicy_Albums", + "name": "ApexExample_AAISuccessResponseEvent", "version": "0.0.1" }, "value": { "key": { - "name": "APEXgRPCPolicy_Albums", + "name": "ApexExample_AAISuccessResponseEvent", "version": "0.0.1" }, - "UUID": "9922906c-ccaa-34f7-95e2-bcc36e77821b", - "description": "Generated description for concept referred to by key \"APEXgRPCPolicy_Albums:0.0.1\"" + "UUID": "b5e3f122-2dcd-3cdf-a0ec-8210b3f80478", + "description": "Generated description for concept referred to by key \"ApexExample_AAISuccessResponseEvent:0.0.1\"" } }, { "key": { - "name": "APEXgRPCPolicy_Events", + "name": "ApexExample_AAISuccessResponseHandlerPolicy", "version": "0.0.1" }, "value": { "key": { - "name": "APEXgRPCPolicy_Events", + "name": "ApexExample_AAISuccessResponseHandlerPolicy", "version": "0.0.1" }, - "UUID": "5bf28afd-787c-3138-a3e1-b33ad94a038a", - "description": "Generated description for concept referred to by key \"APEXgRPCPolicy_Events:0.0.1\"" + "UUID": "15504e23-78c5-305e-9fce-cf1f50e75013", + "description": "Generated description for concept referred to by key \"ApexExample_AAISuccessResponseHandlerPolicy:0.0.1\"" } }, { "key": { - "name": "APEXgRPCPolicy_KeyInfo", + "name": "ApexExample_CDSActionIdentifiersType", "version": "0.0.1" }, "value": { "key": { - "name": "APEXgRPCPolicy_KeyInfo", + "name": "ApexExample_CDSActionIdentifiersType", "version": "0.0.1" }, - "UUID": "68abaa6f-8d03-3a53-9590-007115817d5c", - "description": "Generated description for concept referred to by key \"APEXgRPCPolicy_KeyInfo:0.0.1\"" + "UUID": "e2715e7d-835e-32c7-b433-a2e92bcad6ee", + "description": "Generated description for concept referred to by key \"ApexExample_CDSActionIdentifiersType:0.0.1\"" } }, { "key": { - "name": "APEXgRPCPolicy_Policies", + "name": "ApexExample_CDSConfigModifyFailureResponseEvent", "version": "0.0.1" }, "value": { "key": { - "name": "APEXgRPCPolicy_Policies", + "name": "ApexExample_CDSConfigModifyFailureResponseEvent", "version": "0.0.1" }, - "UUID": "819d06c3-33c2-3031-aa78-96281aa4270a", - "description": "Generated description for concept referred to by key \"APEXgRPCPolicy_Policies:0.0.1\"" + "UUID": "b492e841-2c03-36a9-9ec2-dda5852152c3", + "description": "Generated description for concept referred to by key \"ApexExample_CDSConfigModifyFailureResponseEvent:0.0.1\"" } }, { "key": { - "name": "APEXgRPCPolicy_Schemas", + "name": "ApexExample_CDSConfigModifyFailureResponseHandlerPolicy", "version": "0.0.1" }, "value": { "key": { - "name": "APEXgRPCPolicy_Schemas", + "name": "ApexExample_CDSConfigModifyFailureResponseHandlerPolicy", "version": "0.0.1" }, - "UUID": "8e67d466-f990-3a39-9fd7-4490cac342dc", - "description": "Generated description for concept referred to by key \"APEXgRPCPolicy_Schemas:0.0.1\"" + "UUID": "ef4e45f4-1181-3121-a3b6-507126df25e7", + "description": "Generated description for concept referred to by key \"ApexExample_CDSConfigModifyFailureResponseHandlerPolicy:0.0.1\"" } }, { "key": { - "name": "APEXgRPCPolicy_Tasks", + "name": "ApexExample_CDSConfigModifyFailureResponseTask", "version": "0.0.1" }, "value": { "key": { - "name": "APEXgRPCPolicy_Tasks", + "name": "ApexExample_CDSConfigModifyFailureResponseTask", "version": "0.0.1" }, - "UUID": "4668db3d-6fe2-3885-8e47-f30cd0102f0a", - "description": "Generated description for concept referred to by key \"APEXgRPCPolicy_Tasks:0.0.1\"" + "UUID": "91cb711a-0c73-3f51-83e6-fca9c547c71d", + "description": "Generated description for concept referred to by key \"ApexExample_CDSConfigModifyFailureResponseTask:0.0.1\"" } }, { "key": { - "name": "CDSActionIdentifiersType", + "name": "ApexExample_CDSConfigModifyRequestEvent", "version": "0.0.1" }, "value": { "key": { - "name": "CDSActionIdentifiersType", + "name": "ApexExample_CDSConfigModifyRequestEvent", "version": "0.0.1" }, - "UUID": "6e5fa19b-14df-37e3-a4ae-8c537e861a82", - "description": "Generated description for concept referred to by key \"CDSActionIdentifiersType:0.0.1\"" + "UUID": "dda3c648-dc8b-38e0-855d-9cb72397f957", + "description": "Generated description for concept referred to by key \"ApexExample_CDSConfigModifyRequestEvent:0.0.1\"" } }, { "key": { - "name": "CDSCreateSubscriptionPayloadType", + "name": "ApexExample_CDSConfigModifyResponsePayloadType", "version": "0.0.1" }, "value": { "key": { - "name": "CDSCreateSubscriptionPayloadType", + "name": "ApexExample_CDSConfigModifyResponsePayloadType", "version": "0.0.1" }, - "UUID": "8350ac5e-c157-38b9-9614-a0f93a830e60", - "description": "Generated description for concept referred to by key \"CDSCreateSubscriptionPayloadType:0.0.1\"" + "UUID": "96b306bd-6dee-3d47-981c-eaac316d5ae1", + "description": "Generated description for concept referred to by key \"ApexExample_CDSConfigModifyResponsePayloadType:0.0.1\"" } }, { "key": { - "name": "CDSDeleteSubscriptionPayloadType", + "name": "ApexExample_CDSConfigModifySuccessResponseEvent", "version": "0.0.1" }, "value": { "key": { - "name": "CDSDeleteSubscriptionPayloadType", + "name": "ApexExample_CDSConfigModifySuccessResponseEvent", "version": "0.0.1" }, - "UUID": "12658406-9147-3c9d-a38c-5ad5e30b092b", - "description": "Generated description for concept referred to by key \"CDSDeleteSubscriptionPayloadType:0.0.1\"" + "UUID": "1b65abfb-ce35-3765-9b9c-d2ee02bef28b", + "description": "Generated description for concept referred to by key \"ApexExample_CDSConfigModifySuccessResponseEvent:0.0.1\"" } }, { "key": { - "name": "CDSRequestCommonHeaderType", + "name": "ApexExample_CDSConfigModifySuccessResponseHandlerPolicy", "version": "0.0.1" }, "value": { "key": { - "name": "CDSRequestCommonHeaderType", + "name": "ApexExample_CDSConfigModifySuccessResponseHandlerPolicy", "version": "0.0.1" }, - "UUID": "35590ac0-062c-39f1-8786-b4ff716e30b1", - "description": "Generated description for concept referred to by key \"CDSRequestCommonHeaderType:0.0.1\"" + "UUID": "4dac3de7-3817-396f-91d6-ce701d162877", + "description": "Generated description for concept referred to by key \"ApexExample_CDSConfigModifySuccessResponseHandlerPolicy:0.0.1\"" } }, { "key": { - "name": "CDSResponseCommonHeaderType", + "name": "ApexExample_CDSConfigModifySuccessResponseTask", "version": "0.0.1" }, "value": { "key": { - "name": "CDSResponseCommonHeaderType", + "name": "ApexExample_CDSConfigModifySuccessResponseTask", "version": "0.0.1" }, - "UUID": "dd7e1805-885a-350b-aaf9-ed541321ae3c", - "description": "Generated description for concept referred to by key \"CDSResponseCommonHeaderType:0.0.1\"" + "UUID": "92dc9e6b-2082-3d90-ba5e-f2dba18b72b6", + "description": "Generated description for concept referred to by key \"ApexExample_CDSConfigModifySuccessResponseTask:0.0.1\"" } }, { "key": { - "name": "CDSResponseEvent", + "name": "ApexExample_CDSFailureResponseCommonHeaderType", "version": "0.0.1" }, "value": { "key": { - "name": "CDSResponseEvent", + "name": "ApexExample_CDSFailureResponseCommonHeaderType", "version": "0.0.1" }, - "UUID": "15161037-9ac8-3223-820f-4e743562a345", - "description": "Generated description for concept referred to by key \"CDSResponseEvent:0.0.1\"" + "UUID": "a6801c93-f15b-3158-ba33-7760197d3609", + "description": "Generated description for concept referred to by key \"ApexExample_CDSFailureResponseCommonHeaderType:0.0.1\"" } }, { "key": { - "name": "CDSResponsePayloadType", + "name": "ApexExample_CDSFailureResponseStatusType", "version": "0.0.1" }, "value": { "key": { - "name": "CDSResponsePayloadType", + "name": "ApexExample_CDSFailureResponseStatusType", "version": "0.0.1" }, - "UUID": "97dc5f58-25bb-3c20-8d53-fdb70d7ca256", - "description": "Generated description for concept referred to by key \"CDSResponsePayloadType:0.0.1\"" + "UUID": "e2da0a15-c542-3e77-874d-4512e9b4162e", + "description": "Generated description for concept referred to by key \"ApexExample_CDSFailureResponseStatusType:0.0.1\"" } }, { "key": { - "name": "CDSResponsePolicy", + "name": "ApexExample_CDSRequestCommonHeaderType", "version": "0.0.1" }, "value": { "key": { - "name": "CDSResponsePolicy", + "name": "ApexExample_CDSRequestCommonHeaderType", "version": "0.0.1" }, - "UUID": "c28b05a8-7436-3ac0-82ca-6d5fc18c9584", - "description": "Generated description for concept referred to by key \"CDSResponsePolicy:0.0.1\"" + "UUID": "f54edff0-532f-3142-8e65-a5c9d67888ef", + "description": "Generated description for concept referred to by key \"ApexExample_CDSRequestCommonHeaderType:0.0.1\"" } }, { "key": { - "name": "CDSResponseStatusEvent", + "name": "ApexExample_CDSRequestPayloadType", "version": "0.0.1" }, "value": { "key": { - "name": "CDSResponseStatusEvent", + "name": "ApexExample_CDSRequestPayloadType", "version": "0.0.1" }, - "UUID": "7986e21b-32f7-302e-9554-31f21b673493", - "description": "Generated description for concept referred to by key \"CDSResponseStatusEvent:0.0.1\"" + "UUID": "b967dc44-a156-32d3-a796-f03dbf74316c", + "description": "Generated description for concept referred to by key \"ApexExample_CDSRequestPayloadType:0.0.1\"" } }, { "key": { - "name": "CDSResponseStatusType", + "name": "ApexExample_CDSRestartFailureResponseEvent", "version": "0.0.1" }, "value": { "key": { - "name": "CDSResponseStatusType", + "name": "ApexExample_CDSRestartFailureResponseEvent", "version": "0.0.1" }, - "UUID": "92b8a2cf-344e-3ce1-8cc0-2b7d3cb695fa", - "description": "Generated description for concept referred to by key \"CDSResponseStatusType:0.0.1\"" + "UUID": "f2aa4552-069d-3db8-8638-2d1f59124e7a", + "description": "Generated description for concept referred to by key \"ApexExample_CDSRestartFailureResponseEvent:0.0.1\"" } }, { "key": { - "name": "CDSResponseTask", + "name": "ApexExample_CDSRestartFailureResponseHandlerPolicy", "version": "0.0.1" }, "value": { "key": { - "name": "CDSResponseTask", + "name": "ApexExample_CDSRestartFailureResponseHandlerPolicy", "version": "0.0.1" }, - "UUID": "d22c78a5-272c-391d-8083-28588280caf9", - "description": "Generated description for concept referred to by key \"CDSResponseTask:0.0.1\"" + "UUID": "c2e3b07f-2c09-3195-9527-6b3ab0666d61", + "description": "Generated description for concept referred to by key \"ApexExample_CDSRestartFailureResponseHandlerPolicy:0.0.1\"" } }, { "key": { - "name": "CreateSubscriptionPayloadEvent", + "name": "ApexExample_CDSRestartFailureResponseTask", "version": "0.0.1" }, "value": { "key": { - "name": "CreateSubscriptionPayloadEvent", + "name": "ApexExample_CDSRestartFailureResponseTask", "version": "0.0.1" }, - "UUID": "92162397-1a8e-3a3f-a469-d2af7700af4a", - "description": "Generated description for concept referred to by key \"CreateSubscriptionPayloadEvent:0.0.1\"" + "UUID": "a7c28cc1-9fe5-30b7-9dd8-5a4f7f7d811e", + "description": "Generated description for concept referred to by key \"ApexExample_CDSRestartFailureResponseTask:0.0.1\"" } }, { "key": { - "name": "CreateSubscriptionPayloadTask", + "name": "ApexExample_CDSRestartRequestEvent", "version": "0.0.1" }, "value": { "key": { - "name": "CreateSubscriptionPayloadTask", + "name": "ApexExample_CDSRestartRequestEvent", "version": "0.0.1" }, - "UUID": "bc0c69f0-52ed-38ea-b468-ae4a6fd1730d", - "description": "Generated description for concept referred to by key \"CreateSubscriptionPayloadTask:0.0.1\"" + "UUID": "d01d1022-48ac-391d-904d-282ccb063f8a", + "description": "Generated description for concept referred to by key \"ApexExample_CDSRestartRequestEvent:0.0.1\"" } }, { "key": { - "name": "CreateSubscriptionRequestEvent", + "name": "ApexExample_CDSRestartResponsePayloadType", "version": "0.0.1" }, "value": { "key": { - "name": "CreateSubscriptionRequestEvent", + "name": "ApexExample_CDSRestartResponsePayloadType", "version": "0.0.1" }, - "UUID": "7cfcf843-337e-3f41-b755-5043cb0a08fc", - "description": "Generated description for concept referred to by key \"CreateSubscriptionRequestEvent:0.0.1\"" + "UUID": "ad8cbd94-6eb5-3743-8a7d-42cbe49a5320", + "description": "Generated description for concept referred to by key \"ApexExample_CDSRestartResponsePayloadType:0.0.1\"" } }, { "key": { - "name": "CreateSubscriptionRequestTask", + "name": "ApexExample_CDSRestartSuccessResponseEvent", "version": "0.0.1" }, "value": { "key": { - "name": "CreateSubscriptionRequestTask", + "name": "ApexExample_CDSRestartSuccessResponseEvent", "version": "0.0.1" }, - "UUID": "89cb75e9-f06c-30d3-b4ff-698d45f63869", - "description": "Generated description for concept referred to by key \"CreateSubscriptionRequestTask:0.0.1\"" + "UUID": "bbb06330-9161-392e-a0ca-a6bb5e3376af", + "description": "Generated description for concept referred to by key \"ApexExample_CDSRestartSuccessResponseEvent:0.0.1\"" } }, { "key": { - "name": "DeleteSubscriptionPayloadEvent", + "name": "ApexExample_CDSRestartSuccessResponseHandlerPolicy", "version": "0.0.1" }, "value": { "key": { - "name": "DeleteSubscriptionPayloadEvent", + "name": "ApexExample_CDSRestartSuccessResponseHandlerPolicy", "version": "0.0.1" }, - "UUID": "994fa441-04ab-33bb-832d-1cd12ab5d074", - "description": "Generated description for concept referred to by key \"DeleteSubscriptionPayloadEvent:0.0.1\"" + "UUID": "70c6c6e5-00da-30cb-8ec0-14437d657f39", + "description": "Generated description for concept referred to by key \"ApexExample_CDSRestartSuccessResponseHandlerPolicy:0.0.1\"" } }, { "key": { - "name": "DeleteSubscriptionPayloadTask", + "name": "ApexExample_CDSRestartSuccessResponseTask", "version": "0.0.1" }, "value": { "key": { - "name": "DeleteSubscriptionPayloadTask", + "name": "ApexExample_CDSRestartSuccessResponseTask", "version": "0.0.1" }, - "UUID": "0f519117-5fea-3e4b-941f-8f778100465f", - "description": "Generated description for concept referred to by key \"DeleteSubscriptionPayloadTask:0.0.1\"" + "UUID": "77f16151-80b5-304c-a448-19d8528feed1", + "description": "Generated description for concept referred to by key \"ApexExample_CDSRestartSuccessResponseTask:0.0.1\"" } }, { "key": { - "name": "DeleteSubscriptionRequestEvent", + "name": "ApexExample_CDSSuccessResponseCommonHeaderType", "version": "0.0.1" }, "value": { "key": { - "name": "DeleteSubscriptionRequestEvent", + "name": "ApexExample_CDSSuccessResponseCommonHeaderType", "version": "0.0.1" }, - "UUID": "15d618d8-1689-3a05-89a5-05efa9388f65", - "description": "Generated description for concept referred to by key \"DeleteSubscriptionRequestEvent:0.0.1\"" + "UUID": "2f17aee2-fbdf-3c41-a779-f9c17b5bda5b", + "description": "Generated description for concept referred to by key \"ApexExample_CDSSuccessResponseCommonHeaderType:0.0.1\"" } }, { "key": { - "name": "DeleteSubscriptionRequestTask", + "name": "ApexExample_CDSSuccessResponseStatusType", "version": "0.0.1" }, "value": { "key": { - "name": "DeleteSubscriptionRequestTask", + "name": "ApexExample_CDSSuccessResponseStatusType", "version": "0.0.1" }, - "UUID": "acb772fe-d442-39e3-98f9-b1080caf4150", - "description": "Generated description for concept referred to by key \"DeleteSubscriptionRequestTask:0.0.1\"" + "UUID": "8c554852-3ed6-3027-a0d3-fccd2db19875", + "description": "Generated description for concept referred to by key \"ApexExample_CDSSuccessResponseStatusType:0.0.1\"" } }, { "key": { - "name": "PMSubscriptionAlbum", + "name": "ApexExample_EventDetailsAlbum", "version": "0.0.1" }, "value": { "key": { - "name": "PMSubscriptionAlbum", + "name": "ApexExample_EventDetailsAlbum", "version": "0.0.1" }, - "UUID": "c2bd6f0d-6854-317a-9be2-97c08338428c", - "description": "Generated description for concept referred to by key \"PMSubscriptionAlbum:0.0.1\"" + "UUID": "b402baca-915b-3952-97fc-d9899f9ca81c", + "description": "Generated description for concept referred to by key \"ApexExample_EventDetailsAlbum:0.0.1\"" } }, { "key": { - "name": "PMSubscriptionOutputEvent", + "name": "ApexExample_EventDetailsAlbumType", "version": "0.0.1" }, "value": { "key": { - "name": "PMSubscriptionOutputEvent", + "name": "ApexExample_EventDetailsAlbumType", "version": "0.0.1" }, - "UUID": "992b7819-9f69-3aa0-bb0f-6e45ea15ce05", - "description": "Generated description for concept referred to by key \"PMSubscriptionOutputEvent:0.0.1\"" + "UUID": "3626f32a-eee6-3254-b3d4-e4829518c381", + "description": "Generated description for concept referred to by key \"ApexExample_EventDetailsAlbumType:0.0.1\"" } }, { "key": { - "name": "PMSubscriptionType", + "name": "ApexExample_HandleAAIFailureResponseTask", "version": "0.0.1" }, "value": { "key": { - "name": "PMSubscriptionType", + "name": "ApexExample_HandleAAIFailureResponseTask", "version": "0.0.1" }, - "UUID": "73c1c397-4fc3-357f-93b6-a8ad707fbaae", - "description": "Generated description for concept referred to by key \"PMSubscriptionType:0.0.1\"" + "UUID": "87abb453-a919-3131-8ffb-3e5c910c6049", + "description": "Generated description for concept referred to by key \"ApexExample_HandleAAIFailureResponseTask:0.0.1\"" } }, { "key": { - "name": "ReceiveEventPolicy", + "name": "ApexExample_HandleAAISuccessResponseTask", "version": "0.0.1" }, "value": { "key": { - "name": "ReceiveEventPolicy", + "name": "ApexExample_HandleAAISuccessResponseTask", "version": "0.0.1" }, - "UUID": "568b7345-9de1-36d3-b6a3-9b857e6809a1", - "description": "Generated description for concept referred to by key \"ReceiveEventPolicy:0.0.1\"" + "UUID": "8881e644-3cca-3aec-8201-312ca6f719e0", + "description": "Generated description for concept referred to by key \"ApexExample_HandleAAISuccessResponseTask:0.0.1\"" } }, { "key": { - "name": "ReceivePMSubscriptionTask", + "name": "ApexExample_HandleVesEventTask", "version": "0.0.1" }, "value": { "key": { - "name": "ReceivePMSubscriptionTask", + "name": "ApexExample_HandleVesEventTask", "version": "0.0.1" }, - "UUID": "6c1c6c45-26e0-3591-94bf-679d20e283f4", - "description": "Generated description for concept referred to by key \"ReceivePMSubscriptionTask:0.0.1\"" + "UUID": "057f6ddd-d6aa-3ce2-a060-d344de16d7f3", + "description": "Generated description for concept referred to by key \"ApexExample_HandleVesEventTask:0.0.1\"" } }, { "key": { - "name": "SimpleIntType", + "name": "ApexExample_LogStatusEvent", "version": "0.0.1" }, "value": { "key": { - "name": "SimpleIntType", + "name": "ApexExample_LogStatusEvent", "version": "0.0.1" }, - "UUID": "153791fd-ae0a-36a7-88a5-309a7936415d", - "description": "Generated description for concept referred to by key \"SimpleIntType:0.0.1\"" + "UUID": "4867b1e7-a819-3b9f-be2b-a97fe6019827", + "description": "Generated description for concept referred to by key \"ApexExample_LogStatusEvent:0.0.1\"" + } + }, + { + "key": { + "name": "ApexExample_VesEvent", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_VesEvent", + "version": "0.0.1" + }, + "UUID": "975b3071-b775-3617-a888-f831fe5a31db", + "description": "Generated description for concept referred to by key \"ApexExample_VesEvent:0.0.1\"" + } + }, + { + "key": { + "name": "ApexExample_VesEventHandlerPolicy", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_VesEventHandlerPolicy", + "version": "0.0.1" + }, + "UUID": "ad9efe17-a03e-3b64-8e8a-51e144f57d2c", + "description": "Generated description for concept referred to by key \"ApexExample_VesEventHandlerPolicy:0.0.1\"" + } + }, + { + "key": { + "name": "ApexExample_VesEventType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_VesEventType", + "version": "0.0.1" + }, + "UUID": "0054393c-10df-3214-af86-cb04a23325bf", + "description": "Generated description for concept referred to by key \"ApexExample_VesEventType:0.0.1\"" + } + }, + { + "key": { + "name": "ApexExample_VnfRelationShipListType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_VnfRelationShipListType", + "version": "0.0.1" + }, + "UUID": "865a5903-201b-34ff-918b-2bfdde743576", + "description": "Generated description for concept referred to by key \"ApexExample_VnfRelationShipListType:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleBooleanType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleBooleanType", + "version": "0.0.1" + }, + "UUID": "7218fb2f-59e3-321d-9ae1-bc97b19eb4ae", + "description": "Generated description for concept referred to by key \"SimpleBooleanType:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleLongType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleLongType", + "version": "0.0.1" + }, + "UUID": "2dfcd9ec-a6f9-3f9f-958f-9b36cf4ac574", + "description": "Generated description for concept referred to by key \"SimpleLongType:0.0.1\"" } }, { @@ -663,58 +820,100 @@ }, { "key": { - "name": "SubscriptionStatusType", + "name": "onap.policies.apex.Example", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "onap.policies.apex.Example", + "version": "0.0.1" + }, + "UUID": "b2501730-8870-3475-b22a-4a4d22792ebb", + "description": "Generated description for concept referred to by key \"onap.policies.apex.Example:0.0.1\"" + } + }, + { + "key": { + "name": "onap.policies.apex.Example_Albums", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "onap.policies.apex.Example_Albums", + "version": "0.0.1" + }, + "UUID": "7dc5f49d-c291-38de-bcae-1db30d00581f", + "description": "Generated description for concept referred to by key \"onap.policies.apex.Example_Albums:0.0.1\"" + } + }, + { + "key": { + "name": "onap.policies.apex.Example_Events", "version": "0.0.1" }, "value": { "key": { - "name": "SubscriptionStatusType", + "name": "onap.policies.apex.Example_Events", "version": "0.0.1" }, - "UUID": "597643b1-9db1-31ce-85d0-e1c63c43b30b", - "description": "Generated description for concept referred to by key \"SubscriptionStatusType:0.0.1\"" + "UUID": "06b3112b-ae8b-3f37-8aa6-f539c0250550", + "description": "Generated description for concept referred to by key \"onap.policies.apex.Example_Events:0.0.1\"" } }, { "key": { - "name": "SubscriptionType", + "name": "onap.policies.apex.Example_KeyInfo", "version": "0.0.1" }, "value": { "key": { - "name": "SubscriptionType", + "name": "onap.policies.apex.Example_KeyInfo", "version": "0.0.1" }, - "UUID": "184547bb-7d64-3cb2-a273-d7185102c5ce", - "description": "Generated description for concept referred to by key \"SubscriptionType:0.0.1\"" + "UUID": "454848e1-43ac-3ce4-bfdc-b9b6271dc563", + "description": "Generated description for concept referred to by key \"onap.policies.apex.Example_KeyInfo:0.0.1\"" } }, { "key": { - "name": "UUIDType", + "name": "onap.policies.apex.Example_Policies", "version": "0.0.1" }, "value": { "key": { - "name": "UUIDType", + "name": "onap.policies.apex.Example_Policies", "version": "0.0.1" }, - "UUID": "6a8cc68e-dfc8-3403-9c6d-071c886b319c", - "description": "Generated description for concept referred to by key \"UUIDType:0.0.1\"" + "UUID": "24c3fca5-b0dd-398c-83ee-66a187296b32", + "description": "Generated description for concept referred to by key \"onap.policies.apex.Example_Policies:0.0.1\"" } }, { "key": { - "name": "testPolicyB", + "name": "onap.policies.apex.Example_Schemas", "version": "0.0.1" }, "value": { "key": { - "name": "testPolicyB", + "name": "onap.policies.apex.Example_Schemas", "version": "0.0.1" }, - "UUID": "ead590a3-ba2e-3a01-b6e9-9329f5c8fee1", - "description": "Generated description for concept referred to by key \"testPolicyB:0.0.1\"" + "UUID": "c6aff774-f50a-329d-a731-9c23a6e7e02e", + "description": "Generated description for concept referred to by key \"onap.policies.apex.Example_Schemas:0.0.1\"" + } + }, + { + "key": { + "name": "onap.policies.apex.Example_Tasks", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "onap.policies.apex.Example_Tasks", + "version": "0.0.1" + }, + "UUID": "f856a6df-6237-3acc-aa68-f55e64cc0ec9", + "description": "Generated description for concept referred to by key \"onap.policies.apex.Example_Tasks:0.0.1\"" } } ] @@ -722,50 +921,50 @@ }, "policies": { "key": { - "name": "APEXgRPCPolicy_Policies", + "name": "onap.policies.apex.Example_Policies", "version": "0.0.1" }, "policyMap": { "entry": [ { "key": { - "name": "CDSResponsePolicy", + "name": "ApexExample_AAIFailureResponseHandlerPolicy", "version": "0.0.1" }, "value": { "policyKey": { - "name": "CDSResponsePolicy", + "name": "ApexExample_AAIFailureResponseHandlerPolicy", "version": "0.0.1" }, "template": "Freestyle", "state": { "entry": [ { - "key": "CDSResponseState", + "key": "ApexExample_ReceiveAAIFailureResponseState", "value": { "stateKey": { - "parentKeyName": "CDSResponsePolicy", + "parentKeyName": "ApexExample_AAIFailureResponseHandlerPolicy", "parentKeyVersion": "0.0.1", "parentLocalName": "NULL", - "localName": "CDSResponseState" + "localName": "ApexExample_ReceiveAAIFailureResponseState" }, "trigger": { - "name": "CDSResponseEvent", + "name": "ApexExample_AAIFailureResponseEvent", "version": "0.0.1" }, "stateOutputs": { "entry": [ { - "key": "ResponseOutput", + "key": "ApexExample_AAIFailureStateOutput", "value": { "key": { - "parentKeyName": "CDSResponsePolicy", + "parentKeyName": "ApexExample_AAIFailureResponseHandlerPolicy", "parentKeyVersion": "0.0.1", - "parentLocalName": "CDSResponseState", - "localName": "ResponseOutput" + "parentLocalName": "ApexExample_ReceiveAAIFailureResponseState", + "localName": "ApexExample_AAIFailureStateOutput" }, "outgoingEvent": { - "name": "CDSResponseStatusEvent", + "name": "ApexExample_LogStatusEvent", "version": "0.0.1" }, "nextState": { @@ -788,29 +987,29 @@ "entry": [] }, "defaultTask": { - "name": "CDSResponseTask", + "name": "ApexExample_HandleAAIFailureResponseTask", "version": "0.0.1" }, "taskReferences": { "entry": [ { "key": { - "name": "CDSResponseTask", + "name": "ApexExample_HandleAAIFailureResponseTask", "version": "0.0.1" }, "value": { "key": { - "parentKeyName": "CDSResponsePolicy", + "parentKeyName": "ApexExample_AAIFailureResponseHandlerPolicy", "parentKeyVersion": "0.0.1", - "parentLocalName": "CDSResponseState", - "localName": "CDSResponsePolicy" + "parentLocalName": "ApexExample_ReceiveAAIFailureResponseState", + "localName": "ApexExample_AAIFailureResponseHandlerPolicy" }, "outputType": "DIRECT", "output": { - "parentKeyName": "CDSResponsePolicy", + "parentKeyName": "ApexExample_AAIFailureResponseHandlerPolicy", "parentKeyVersion": "0.0.1", - "parentLocalName": "CDSResponseState", - "localName": "ResponseOutput" + "parentLocalName": "ApexExample_ReceiveAAIFailureResponseState", + "localName": "ApexExample_AAIFailureStateOutput" } } } @@ -820,173 +1019,144 @@ } ] }, - "firstState": "CDSResponseState" + "firstState": "ApexExample_ReceiveAAIFailureResponseState" } }, { "key": { - "name": "ReceiveEventPolicy", + "name": "ApexExample_AAISuccessResponseHandlerPolicy", "version": "0.0.1" }, "value": { "policyKey": { - "name": "ReceiveEventPolicy", + "name": "ApexExample_AAISuccessResponseHandlerPolicy", "version": "0.0.1" }, "template": "Freestyle", "state": { "entry": [ { - "key": "CreateOrDeleteState", + "key": "ApexExample_ReceiveAAISuccessResponseState", "value": { "stateKey": { - "parentKeyName": "ReceiveEventPolicy", + "parentKeyName": "ApexExample_AAISuccessResponseHandlerPolicy", "parentKeyVersion": "0.0.1", "parentLocalName": "NULL", - "localName": "CreateOrDeleteState" + "localName": "ApexExample_ReceiveAAISuccessResponseState" }, "trigger": { - "name": "PMSubscriptionOutputEvent", + "name": "ApexExample_AAISuccessResponseEvent", "version": "0.0.1" }, "stateOutputs": { "entry": [ { - "key": "CreateSubscriptionPayload", - "value": { - "key": { - "parentKeyName": "ReceiveEventPolicy", - "parentKeyVersion": "0.0.1", - "parentLocalName": "CreateOrDeleteState", - "localName": "CreateSubscriptionPayload" - }, - "outgoingEvent": { - "name": "CreateSubscriptionPayloadEvent", - "version": "0.0.1" - }, - "nextState": { - "parentKeyName": "ReceiveEventPolicy", - "parentKeyVersion": "0.0.1", - "parentLocalName": "NULL", - "localName": "CreateSubscription" - } - } - }, - { - "key": "DeleteSubscriptionPayload", + "key": "ApexExample_AAISuccessStateOutput", "value": { "key": { - "parentKeyName": "ReceiveEventPolicy", + "parentKeyName": "ApexExample_AAISuccessResponseHandlerPolicy", "parentKeyVersion": "0.0.1", - "parentLocalName": "CreateOrDeleteState", - "localName": "DeleteSubscriptionPayload" + "parentLocalName": "ApexExample_ReceiveAAISuccessResponseState", + "localName": "ApexExample_AAISuccessStateOutput" }, "outgoingEvent": { - "name": "DeleteSubscriptionPayloadEvent", + "name": "ApexExample_CDSConfigModifyRequestEvent", "version": "0.0.1" }, "nextState": { - "parentKeyName": "ReceiveEventPolicy", - "parentKeyVersion": "0.0.1", + "parentKeyName": "NULL", + "parentKeyVersion": "0.0.0", "parentLocalName": "NULL", - "localName": "DeleteSubscription" + "localName": "NULL" } } } ] }, - "contextAlbumReference": [ - { - "name": "PMSubscriptionAlbum", - "version": "0.0.1" - } - ], + "contextAlbumReference": [], "taskSelectionLogic": { - "key": "TaskSelectionLogic", - "logicFlavour": "JAVASCRIPT", - "logic": "/*\n * ============LICENSE_START=======================================================\n * Copyright (C) 2020 Nordix Foundation.\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 changeType = pmSubscriptionInfo.get(\"changeType\").toString()\n\nif (\"CREATE\".equals(changeType)) {\n executor.subject.getTaskKey(\"CreateSubscriptionPayloadTask\").copyTo(executor.selectedTask);\n}\nelse if (\"DELETE\".equals(changeType)) {\n executor.subject.getTaskKey(\"DeleteSubscriptionPayloadTask\").copyTo(executor.selectedTask);\n}\n\ntrue;" + "key": "NULL", + "logicFlavour": "UNDEFINED", + "logic": "" }, "stateFinalizerLogicMap": { "entry": [] }, "defaultTask": { - "name": "CreateSubscriptionPayloadTask", + "name": "ApexExample_HandleAAISuccessResponseTask", "version": "0.0.1" }, "taskReferences": { "entry": [ { "key": { - "name": "CreateSubscriptionPayloadTask", - "version": "0.0.1" - }, - "value": { - "key": { - "parentKeyName": "ReceiveEventPolicy", - "parentKeyVersion": "0.0.1", - "parentLocalName": "CreateOrDeleteState", - "localName": "ReceiveEventPolicy" - }, - "outputType": "DIRECT", - "output": { - "parentKeyName": "ReceiveEventPolicy", - "parentKeyVersion": "0.0.1", - "parentLocalName": "CreateOrDeleteState", - "localName": "CreateSubscriptionPayload" - } - } - }, - { - "key": { - "name": "DeleteSubscriptionPayloadTask", + "name": "ApexExample_HandleAAISuccessResponseTask", "version": "0.0.1" }, "value": { "key": { - "parentKeyName": "ReceiveEventPolicy", + "parentKeyName": "ApexExample_AAISuccessResponseHandlerPolicy", "parentKeyVersion": "0.0.1", - "parentLocalName": "CreateOrDeleteState", - "localName": "ReceiveEventPolicy" + "parentLocalName": "ApexExample_ReceiveAAISuccessResponseState", + "localName": "ApexExample_AAISuccessResponseHandlerPolicy" }, "outputType": "DIRECT", "output": { - "parentKeyName": "ReceiveEventPolicy", + "parentKeyName": "ApexExample_AAISuccessResponseHandlerPolicy", "parentKeyVersion": "0.0.1", - "parentLocalName": "CreateOrDeleteState", - "localName": "DeleteSubscriptionPayload" + "parentLocalName": "ApexExample_ReceiveAAISuccessResponseState", + "localName": "ApexExample_AAISuccessStateOutput" } } } ] } } - }, + } + ] + }, + "firstState": "ApexExample_ReceiveAAISuccessResponseState" + } + }, + { + "key": { + "name": "ApexExample_CDSConfigModifyFailureResponseHandlerPolicy", + "version": "0.0.1" + }, + "value": { + "policyKey": { + "name": "ApexExample_CDSConfigModifyFailureResponseHandlerPolicy", + "version": "0.0.1" + }, + "template": "Freestyle", + "state": { + "entry": [ { - "key": "CreateSubscription", + "key": "ApexExample_CDSConfigModifyFailureResponseState", "value": { "stateKey": { - "parentKeyName": "ReceiveEventPolicy", + "parentKeyName": "ApexExample_CDSConfigModifyFailureResponseHandlerPolicy", "parentKeyVersion": "0.0.1", "parentLocalName": "NULL", - "localName": "CreateSubscription" + "localName": "ApexExample_CDSConfigModifyFailureResponseState" }, "trigger": { - "name": "CreateSubscriptionPayloadEvent", + "name": "ApexExample_CDSConfigModifyFailureResponseEvent", "version": "0.0.1" }, "stateOutputs": { "entry": [ { - "key": "IssueCreateSubscriptionRequestOutput", + "key": "ApexExample_ConfigModifyFailureResponseOutput", "value": { "key": { - "parentKeyName": "ReceiveEventPolicy", + "parentKeyName": "ApexExample_CDSConfigModifyFailureResponseHandlerPolicy", "parentKeyVersion": "0.0.1", - "parentLocalName": "CreateSubscription", - "localName": "IssueCreateSubscriptionRequestOutput" + "parentLocalName": "ApexExample_CDSConfigModifyFailureResponseState", + "localName": "ApexExample_ConfigModifyFailureResponseOutput" }, "outgoingEvent": { - "name": "CreateSubscriptionRequestEvent", + "name": "ApexExample_LogStatusEvent", "version": "0.0.1" }, "nextState": { @@ -999,12 +1169,7 @@ } ] }, - "contextAlbumReference": [ - { - "name": "PMSubscriptionAlbum", - "version": "0.0.1" - } - ], + "contextAlbumReference": [], "taskSelectionLogic": { "key": "NULL", "logicFlavour": "UNDEFINED", @@ -1014,62 +1179,80 @@ "entry": [] }, "defaultTask": { - "name": "CreateSubscriptionRequestTask", + "name": "ApexExample_CDSConfigModifyFailureResponseTask", "version": "0.0.1" }, "taskReferences": { "entry": [ { "key": { - "name": "CreateSubscriptionRequestTask", + "name": "ApexExample_CDSConfigModifyFailureResponseTask", "version": "0.0.1" }, "value": { "key": { - "parentKeyName": "ReceiveEventPolicy", + "parentKeyName": "ApexExample_CDSConfigModifyFailureResponseHandlerPolicy", "parentKeyVersion": "0.0.1", - "parentLocalName": "CreateSubscription", - "localName": "ReceiveEventPolicy" + "parentLocalName": "ApexExample_CDSConfigModifyFailureResponseState", + "localName": "ApexExample_CDSConfigModifyFailureResponseHandlerPolicy" }, "outputType": "DIRECT", "output": { - "parentKeyName": "ReceiveEventPolicy", + "parentKeyName": "ApexExample_CDSConfigModifyFailureResponseHandlerPolicy", "parentKeyVersion": "0.0.1", - "parentLocalName": "CreateSubscription", - "localName": "IssueCreateSubscriptionRequestOutput" + "parentLocalName": "ApexExample_CDSConfigModifyFailureResponseState", + "localName": "ApexExample_ConfigModifyFailureResponseOutput" } } } ] } } - }, + } + ] + }, + "firstState": "ApexExample_CDSConfigModifyFailureResponseState" + } + }, + { + "key": { + "name": "ApexExample_CDSConfigModifySuccessResponseHandlerPolicy", + "version": "0.0.1" + }, + "value": { + "policyKey": { + "name": "ApexExample_CDSConfigModifySuccessResponseHandlerPolicy", + "version": "0.0.1" + }, + "template": "Freestyle", + "state": { + "entry": [ { - "key": "DeleteSubscription", + "key": "ApexExample_CDSConfigModifySuccessResponseState", "value": { "stateKey": { - "parentKeyName": "ReceiveEventPolicy", + "parentKeyName": "ApexExample_CDSConfigModifySuccessResponseHandlerPolicy", "parentKeyVersion": "0.0.1", "parentLocalName": "NULL", - "localName": "DeleteSubscription" + "localName": "ApexExample_CDSConfigModifySuccessResponseState" }, "trigger": { - "name": "DeleteSubscriptionPayloadEvent", + "name": "ApexExample_CDSConfigModifySuccessResponseEvent", "version": "0.0.1" }, "stateOutputs": { "entry": [ { - "key": "IssueDeleteSubscriptionRequestOutput", + "key": "ApexExample_ConfigModifySuccessResponseOutput", "value": { "key": { - "parentKeyName": "ReceiveEventPolicy", + "parentKeyName": "ApexExample_CDSConfigModifySuccessResponseHandlerPolicy", "parentKeyVersion": "0.0.1", - "parentLocalName": "DeleteSubscription", - "localName": "IssueDeleteSubscriptionRequestOutput" + "parentLocalName": "ApexExample_CDSConfigModifySuccessResponseState", + "localName": "ApexExample_ConfigModifySuccessResponseOutput" }, "outgoingEvent": { - "name": "DeleteSubscriptionRequestEvent", + "name": "ApexExample_CDSRestartRequestEvent", "version": "0.0.1" }, "nextState": { @@ -1082,12 +1265,7 @@ } ] }, - "contextAlbumReference": [ - { - "name": "PMSubscriptionAlbum", - "version": "0.0.1" - } - ], + "contextAlbumReference": [], "taskSelectionLogic": { "key": "NULL", "logicFlavour": "UNDEFINED", @@ -1097,80 +1275,93 @@ "entry": [] }, "defaultTask": { - "name": "DeleteSubscriptionRequestTask", + "name": "ApexExample_CDSConfigModifySuccessResponseTask", "version": "0.0.1" }, "taskReferences": { "entry": [ { "key": { - "name": "DeleteSubscriptionRequestTask", + "name": "ApexExample_CDSConfigModifySuccessResponseTask", "version": "0.0.1" }, "value": { "key": { - "parentKeyName": "ReceiveEventPolicy", + "parentKeyName": "ApexExample_CDSConfigModifySuccessResponseHandlerPolicy", "parentKeyVersion": "0.0.1", - "parentLocalName": "DeleteSubscription", - "localName": "ReceiveEventPolicy" + "parentLocalName": "ApexExample_CDSConfigModifySuccessResponseState", + "localName": "ApexExample_CDSConfigModifySuccessResponseHandlerPolicy" }, "outputType": "DIRECT", "output": { - "parentKeyName": "ReceiveEventPolicy", + "parentKeyName": "ApexExample_CDSConfigModifySuccessResponseHandlerPolicy", "parentKeyVersion": "0.0.1", - "parentLocalName": "DeleteSubscription", - "localName": "IssueDeleteSubscriptionRequestOutput" + "parentLocalName": "ApexExample_CDSConfigModifySuccessResponseState", + "localName": "ApexExample_ConfigModifySuccessResponseOutput" } } } ] } } - }, + } + ] + }, + "firstState": "ApexExample_CDSConfigModifySuccessResponseState" + } + }, + { + "key": { + "name": "ApexExample_CDSRestartFailureResponseHandlerPolicy", + "version": "0.0.1" + }, + "value": { + "policyKey": { + "name": "ApexExample_CDSRestartFailureResponseHandlerPolicy", + "version": "0.0.1" + }, + "template": "Freestyle", + "state": { + "entry": [ { - "key": "ReceiveSubscriptionState", + "key": "ApexExample_CDSRestartFailureResponseState", "value": { "stateKey": { - "parentKeyName": "ReceiveEventPolicy", + "parentKeyName": "ApexExample_CDSRestartFailureResponseHandlerPolicy", "parentKeyVersion": "0.0.1", "parentLocalName": "NULL", - "localName": "ReceiveSubscriptionState" + "localName": "ApexExample_CDSRestartFailureResponseState" }, "trigger": { - "name": "testPolicyB", + "name": "ApexExample_CDSRestartFailureResponseEvent", "version": "0.0.1" }, "stateOutputs": { "entry": [ { - "key": "ReceivePMSubscriptionOutput", + "key": "ApexExample_RestartFailureResponseOutput", "value": { "key": { - "parentKeyName": "ReceiveEventPolicy", + "parentKeyName": "ApexExample_CDSRestartFailureResponseHandlerPolicy", "parentKeyVersion": "0.0.1", - "parentLocalName": "ReceiveSubscriptionState", - "localName": "ReceivePMSubscriptionOutput" + "parentLocalName": "ApexExample_CDSRestartFailureResponseState", + "localName": "ApexExample_RestartFailureResponseOutput" }, "outgoingEvent": { - "name": "PMSubscriptionOutputEvent", + "name": "ApexExample_LogStatusEvent", "version": "0.0.1" }, "nextState": { - "parentKeyName": "ReceiveEventPolicy", - "parentKeyVersion": "0.0.1", + "parentKeyName": "NULL", + "parentKeyVersion": "0.0.0", "parentLocalName": "NULL", - "localName": "CreateOrDeleteState" + "localName": "NULL" } } } ] }, - "contextAlbumReference": [ - { - "name": "PMSubscriptionAlbum", - "version": "0.0.1" - } - ], + "contextAlbumReference": [], "taskSelectionLogic": { "key": "NULL", "logicFlavour": "UNDEFINED", @@ -1180,29 +1371,29 @@ "entry": [] }, "defaultTask": { - "name": "ReceivePMSubscriptionTask", + "name": "ApexExample_CDSRestartFailureResponseTask", "version": "0.0.1" }, "taskReferences": { "entry": [ { "key": { - "name": "ReceivePMSubscriptionTask", + "name": "ApexExample_CDSRestartFailureResponseTask", "version": "0.0.1" }, "value": { "key": { - "parentKeyName": "ReceiveEventPolicy", + "parentKeyName": "ApexExample_CDSRestartFailureResponseHandlerPolicy", "parentKeyVersion": "0.0.1", - "parentLocalName": "ReceiveSubscriptionState", - "localName": "ReceiveEventPolicy" + "parentLocalName": "ApexExample_CDSRestartFailureResponseState", + "localName": "ApexExample_CDSRestartFailureResponseHandlerPolicy" }, "outputType": "DIRECT", "output": { - "parentKeyName": "ReceiveEventPolicy", + "parentKeyName": "ApexExample_CDSRestartFailureResponseHandlerPolicy", "parentKeyVersion": "0.0.1", - "parentLocalName": "ReceiveSubscriptionState", - "localName": "ReceivePMSubscriptionOutput" + "parentLocalName": "ApexExample_CDSRestartFailureResponseState", + "localName": "ApexExample_RestartFailureResponseOutput" } } } @@ -1212,27 +1403,219 @@ } ] }, - "firstState": "ReceiveSubscriptionState" + "firstState": "ApexExample_CDSRestartFailureResponseState" } - } - ] - } - }, + }, + { + "key": { + "name": "ApexExample_CDSRestartSuccessResponseHandlerPolicy", + "version": "0.0.1" + }, + "value": { + "policyKey": { + "name": "ApexExample_CDSRestartSuccessResponseHandlerPolicy", + "version": "0.0.1" + }, + "template": "Freestyle", + "state": { + "entry": [ + { + "key": "ApexExample_CDSRestartSuccessResponseState", + "value": { + "stateKey": { + "parentKeyName": "ApexExample_CDSRestartSuccessResponseHandlerPolicy", + "parentKeyVersion": "0.0.1", + "parentLocalName": "NULL", + "localName": "ApexExample_CDSRestartSuccessResponseState" + }, + "trigger": { + "name": "ApexExample_CDSRestartSuccessResponseEvent", + "version": "0.0.1" + }, + "stateOutputs": { + "entry": [ + { + "key": "ApexExample_RestartSuccessResponseOutput", + "value": { + "key": { + "parentKeyName": "ApexExample_CDSRestartSuccessResponseHandlerPolicy", + "parentKeyVersion": "0.0.1", + "parentLocalName": "ApexExample_CDSRestartSuccessResponseState", + "localName": "ApexExample_RestartSuccessResponseOutput" + }, + "outgoingEvent": { + "name": "ApexExample_LogStatusEvent", + "version": "0.0.1" + }, + "nextState": { + "parentKeyName": "NULL", + "parentKeyVersion": "0.0.0", + "parentLocalName": "NULL", + "localName": "NULL" + } + } + } + ] + }, + "contextAlbumReference": [], + "taskSelectionLogic": { + "key": "NULL", + "logicFlavour": "UNDEFINED", + "logic": "" + }, + "stateFinalizerLogicMap": { + "entry": [] + }, + "defaultTask": { + "name": "ApexExample_CDSRestartSuccessResponseTask", + "version": "0.0.1" + }, + "taskReferences": { + "entry": [ + { + "key": { + "name": "ApexExample_CDSRestartSuccessResponseTask", + "version": "0.0.1" + }, + "value": { + "key": { + "parentKeyName": "ApexExample_CDSRestartSuccessResponseHandlerPolicy", + "parentKeyVersion": "0.0.1", + "parentLocalName": "ApexExample_CDSRestartSuccessResponseState", + "localName": "ApexExample_CDSRestartSuccessResponseHandlerPolicy" + }, + "outputType": "DIRECT", + "output": { + "parentKeyName": "ApexExample_CDSRestartSuccessResponseHandlerPolicy", + "parentKeyVersion": "0.0.1", + "parentLocalName": "ApexExample_CDSRestartSuccessResponseState", + "localName": "ApexExample_RestartSuccessResponseOutput" + } + } + } + ] + } + } + } + ] + }, + "firstState": "ApexExample_CDSRestartSuccessResponseState" + } + }, + { + "key": { + "name": "ApexExample_VesEventHandlerPolicy", + "version": "0.0.1" + }, + "value": { + "policyKey": { + "name": "ApexExample_VesEventHandlerPolicy", + "version": "0.0.1" + }, + "template": "Freestyle", + "state": { + "entry": [ + { + "key": "ApexExample_ReceiveVesState", + "value": { + "stateKey": { + "parentKeyName": "ApexExample_VesEventHandlerPolicy", + "parentKeyVersion": "0.0.1", + "parentLocalName": "NULL", + "localName": "ApexExample_ReceiveVesState" + }, + "trigger": { + "name": "ApexExample_VesEvent", + "version": "0.0.1" + }, + "stateOutputs": { + "entry": [ + { + "key": "ApexExample_VesOutput", + "value": { + "key": { + "parentKeyName": "ApexExample_VesEventHandlerPolicy", + "parentKeyVersion": "0.0.1", + "parentLocalName": "ApexExample_ReceiveVesState", + "localName": "ApexExample_VesOutput" + }, + "outgoingEvent": { + "name": "ApexExample_AAIRequestEvent", + "version": "0.0.1" + }, + "nextState": { + "parentKeyName": "NULL", + "parentKeyVersion": "0.0.0", + "parentLocalName": "NULL", + "localName": "NULL" + } + } + } + ] + }, + "contextAlbumReference": [], + "taskSelectionLogic": { + "key": "NULL", + "logicFlavour": "UNDEFINED", + "logic": "" + }, + "stateFinalizerLogicMap": { + "entry": [] + }, + "defaultTask": { + "name": "ApexExample_HandleVesEventTask", + "version": "0.0.1" + }, + "taskReferences": { + "entry": [ + { + "key": { + "name": "ApexExample_HandleVesEventTask", + "version": "0.0.1" + }, + "value": { + "key": { + "parentKeyName": "ApexExample_VesEventHandlerPolicy", + "parentKeyVersion": "0.0.1", + "parentLocalName": "ApexExample_ReceiveVesState", + "localName": "ApexExample_VesEventHandlerPolicy" + }, + "outputType": "DIRECT", + "output": { + "parentKeyName": "ApexExample_VesEventHandlerPolicy", + "parentKeyVersion": "0.0.1", + "parentLocalName": "ApexExample_ReceiveVesState", + "localName": "ApexExample_VesOutput" + } + } + } + ] + } + } + } + ] + }, + "firstState": "ApexExample_ReceiveVesState" + } + } + ] + } + }, "tasks": { "key": { - "name": "APEXgRPCPolicy_Tasks", + "name": "onap.policies.apex.Example_Tasks", "version": "0.0.1" }, "taskMap": { "entry": [ { "key": { - "name": "CDSResponseTask", + "name": "ApexExample_CDSConfigModifyFailureResponseTask", "version": "0.0.1" }, "value": { "key": { - "name": "CDSResponseTask", + "name": "ApexExample_CDSConfigModifyFailureResponseTask", "version": "0.0.1" }, "inputFields": { @@ -1242,7 +1625,7 @@ "value": { "key": "actionIdentifiers", "fieldSchemaKey": { - "name": "CDSActionIdentifiersType", + "name": "ApexExample_CDSActionIdentifiersType", "version": "0.0.1" }, "optional": false @@ -1253,7 +1636,7 @@ "value": { "key": "commonHeader", "fieldSchemaKey": { - "name": "CDSResponseCommonHeaderType", + "name": "ApexExample_CDSFailureResponseCommonHeaderType", "version": "0.0.1" }, "optional": false @@ -1264,7 +1647,7 @@ "value": { "key": "payload", "fieldSchemaKey": { - "name": "CDSResponsePayloadType", + "name": "ApexExample_CDSConfigModifyResponsePayloadType", "version": "0.0.1" }, "optional": false @@ -1275,7 +1658,7 @@ "value": { "key": "status", "fieldSchemaKey": { - "name": "CDSResponseStatusType", + "name": "ApexExample_CDSFailureResponseStatusType", "version": "0.0.1" }, "optional": false @@ -1286,11 +1669,11 @@ "outputFields": { "entry": [ { - "key": "status", + "key": "message", "value": { - "key": "status", + "key": "message", "fieldSchemaKey": { - "name": "SubscriptionStatusType", + "name": "SimpleStringType", "version": "0.0.1" }, "optional": false @@ -1303,35 +1686,68 @@ }, "contextAlbumReference": [ { - "name": "PMSubscriptionAlbum", + "name": "ApexExample_EventDetailsAlbum", "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;" + "logic": "var uuidType = java.util.UUID;\nvar longType = java.lang.Long;\nvar HashMapType = java.util.HashMap;\n\nvar albumID = executor.getExecutionProperties().getProperty(\"albumId\");\n\nvar eventDetailsAlbum = executor.getContextAlbum(\"ApexExample_EventDetailsAlbum\").get(albumID.toString());\nvar commonEventHeader = eventDetailsAlbum.get(\"commonEventHeader\");\nvar timestamp = longType(new Date().getTime())\nvar errorMessage = \"CDS operation failed. Error message from CDS - \" + executor.inFields.get(\"status\").get(\"errorMessage\");\nerrorMessage = errorMessage.replace(/\"/g, '\\\\\\\\\\\\\"')\nsend(commonEventHeader.get(\"eventId\"), \"VNF\", commonEventHeader.get(\"sourceId\"), timestamp, \"FINAL_FAILURE\", \"Failed to process VES event. Reason: \" + errorMessage);\ntrue;\n\nfunction send(id, targetType, targetId, timestamp, status, message) {\n var logData = '{'\n +'\"id\" : \"' + id + '\",'\n +'\"target\" : {'\n +'\"targetType\" : \"' + targetType + '\",'\n +'\"entityInfo\" : {'\n +'\"id\" : \"' + targetId + '\"'\n +'}'\n +'},'\n +'\"component\" : {'\n +'\"name\" : \"Policy\",'\n +'\"flavour\" : \"Apex-PDP\",'\n +'\"timestamp\" : ' + timestamp + ','\n +'\"status\" : \"' + status + '\",'\n +'\"message\" : \"' + message + '\",'\n +'\"artifacts\" : {'\n +'\"policyName\" : \"onap.policies.apex.Example\",'\n +'\"policyVersion\" : \"1.0.0\"'\n +'}'\n +'},'\n +'\"otherFields\" : {'\n +'\"useCaseName\" : \"apex-pdp-policy-example\"'\n +'}'\n +'}';\n\n executor.logger.info(\"sending the status to log.\");\n fireLogEvent(logData);\n}\n\nfunction fireLogEvent(logEvent){\n var headers = new HashMapType();\n executor.logger.info(\"LogEvent:\"+logEvent);\n var response = new org.onap.policy.rest.RestManager().post(\n executor.getParameters().get(\"logUrl\"),\n \"\",\n \"\",\n headers,\n \"application/json\",\n logEvent\n );\n executor.logger.info(\"DMaaP Response after sending LogEvent: \" + response);\n return response;\n}" } } }, { "key": { - "name": "CreateSubscriptionPayloadTask", + "name": "ApexExample_CDSConfigModifySuccessResponseTask", "version": "0.0.1" }, "value": { "key": { - "name": "CreateSubscriptionPayloadTask", + "name": "ApexExample_CDSConfigModifySuccessResponseTask", "version": "0.0.1" }, "inputFields": { "entry": [ { - "key": "albumID", + "key": "actionIdentifiers", + "value": { + "key": "actionIdentifiers", + "fieldSchemaKey": { + "name": "ApexExample_CDSActionIdentifiersType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "commonHeader", + "value": { + "key": "commonHeader", + "fieldSchemaKey": { + "name": "ApexExample_CDSSuccessResponseCommonHeaderType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "payload", + "value": { + "key": "payload", + "fieldSchemaKey": { + "name": "ApexExample_CDSConfigModifyResponsePayloadType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "status", "value": { - "key": "albumID", + "key": "status", "fieldSchemaKey": { - "name": "UUIDType", + "name": "ApexExample_CDSSuccessResponseStatusType", "version": "0.0.1" }, "optional": false @@ -1342,11 +1758,22 @@ "outputFields": { "entry": [ { - "key": "albumID", + "key": "actionIdentifiers", + "value": { + "key": "actionIdentifiers", + "fieldSchemaKey": { + "name": "ApexExample_CDSActionIdentifiersType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "commonHeader", "value": { - "key": "albumID", + "key": "commonHeader", "fieldSchemaKey": { - "name": "UUIDType", + "name": "ApexExample_CDSRequestCommonHeaderType", "version": "0.0.1" }, "optional": false @@ -1357,7 +1784,7 @@ "value": { "key": "payload", "fieldSchemaKey": { - "name": "CDSCreateSubscriptionPayloadType", + "name": "ApexExample_CDSRequestPayloadType", "version": "0.0.1" }, "optional": false @@ -1370,83 +1797,83 @@ }, "contextAlbumReference": [ { - "name": "PMSubscriptionAlbum", + "name": "ApexExample_EventDetailsAlbum", "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();\npayload.put(\"create_DasH_subscription_DasH_request\", payloadEntry);\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;" + "logic": "var uuidType = java.util.UUID;\nvar longType = java.lang.Long;\nvar HashMapType = java.util.HashMap;\n\nvar albumID = executor.getExecutionProperties().getProperty(\"albumId\");\nvar eventDetailsAlbum = executor.getContextAlbum(\"ApexExample_EventDetailsAlbum\").get(albumID.toString());\nvar commonEventHeader = eventDetailsAlbum.get(\"commonEventHeader\");\nvar timestamp = longType(new Date().getTime());\nvar faultFields = eventDetailsAlbum.get(\"faultFields\");\nvar vnfDetails = eventDetailsAlbum.get(\"vnfDetails\");\nvar commonHeader = executor.subject.getOutFieldSchemaHelper(\"commonHeader\").createNewInstance();\ncommonHeader.put(\"subRequestId\", commonEventHeader.get(\"eventId\"));\ncommonHeader.put(\"requestId\", uuidType.randomUUID().toString());\ncommonHeader.put(\"originatorId\", \"POLICY\");\n\nvar actionIdentifiers = executor.subject.getOutFieldSchemaHelper(\"actionIdentifiers\").createNewInstance();\nactionIdentifiers.put(\"mode\", \"sync\");\nactionIdentifiers.put(\"blueprintName\", \"apex-example-cba\");\nactionIdentifiers.put(\"blueprintVersion\", \"1.0.0\");\nactionIdentifiers.put(\"actionName\", \"restart\");\n\nvar payloadProperties = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"update_DasH_properties_record\");\npayloadProperties.put(\"service_DasH_instance_DoT_service_DasH_instance_DasH_id\", vnfDetails.get(\"service-id\").toString())\npayloadProperties.put(\"generic_DasH_vnf_DoT_vnf_DasH_id\", vnfDetails.get(\"vnf-name\").toString())\nvar dataRecord = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"update_DasH_data_record\");\ndataRecord.put(\"active_DasH_streams\",\"7\")\npayloadProperties.put(\"data\", dataRecord)\nvar payloadEntry = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"CDSRequestPayloadEntry\");\npayloadEntry.put(\"update_DasH_properties\", payloadProperties)\npayloadEntry.put(\"vfStatus\", faultFields.get(\"vfStatus\"))\nvar payload = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewInstance();\npayload.put(\"restart_DasH_request\", payloadEntry);\n\nexecutor.outFields.put(\"commonHeader\", commonHeader);\nexecutor.outFields.put(\"actionIdentifiers\", actionIdentifiers);\nexecutor.outFields.put(\"payload\", payload);\n\nexecutor.logger.info(+executor.outFields);\n\nsend(commonEventHeader.get(\"eventId\"), \"VNF\", commonEventHeader.get(\"sourceId\"), timestamp, \"SUCCESS\", \"ConfigModify request is successful. Sending restart request to CDS.\")\ntrue;\n\nfunction send(id, targetType, targetId, timestamp, status, message) {\n var logData = '{'\n +'\"id\" : \"' + id + '\",'\n +'\"target\" : {'\n +'\"targetType\" : \"' + targetType + '\",'\n +'\"entityInfo\" : {'\n +'\"id\" : \"' + targetId + '\"'\n +'}'\n +'},'\n +'\"component\" : {'\n +'\"name\" : \"Policy\",'\n +'\"flavour\" : \"Apex-PDP\",'\n +'\"timestamp\" : ' + timestamp + ','\n +'\"status\" : \"' + status + '\",'\n +'\"message\" : \"' + message + '\",'\n +'\"artifacts\" : {'\n +'\"policyName\" : \"onap.policies.apex.Example\",'\n +'\"policyVersion\" : \"1.0.0\"'\n +'}'\n +'},'\n +'\"otherFields\" : {'\n +'\"useCaseName\" : \"apex-pdp-policy-example\"'\n +'}'\n +'}';\n\n executor.logger.info(\"sending the status to log.\");\n fireLogEvent(logData);\n}\n\nfunction fireLogEvent(logEvent){\n var headers = new HashMapType();\n executor.logger.info(\"LogEvent:\"+logEvent);\n var response = new org.onap.policy.rest.RestManager().post(\n executor.getParameters().get(\"logUrl\"),\n \"\",\n \"\",\n headers,\n \"application/json\",\n logEvent\n );\n executor.logger.info(\"DMaaP Response after sending LogEvent: \" + response);\n return response;\n}" } } }, { "key": { - "name": "CreateSubscriptionRequestTask", + "name": "ApexExample_CDSRestartFailureResponseTask", "version": "0.0.1" }, "value": { "key": { - "name": "CreateSubscriptionRequestTask", + "name": "ApexExample_CDSRestartFailureResponseTask", "version": "0.0.1" }, "inputFields": { "entry": [ { - "key": "albumID", + "key": "actionIdentifiers", "value": { - "key": "albumID", + "key": "actionIdentifiers", "fieldSchemaKey": { - "name": "UUIDType", + "name": "ApexExample_CDSActionIdentifiersType", "version": "0.0.1" }, "optional": false } }, { - "key": "payload", + "key": "commonHeader", "value": { - "key": "payload", + "key": "commonHeader", "fieldSchemaKey": { - "name": "CDSCreateSubscriptionPayloadType", + "name": "ApexExample_CDSFailureResponseCommonHeaderType", "version": "0.0.1" }, "optional": false } - } - ] - }, - "outputFields": { - "entry": [ + }, { - "key": "actionIdentifiers", + "key": "payload", "value": { - "key": "actionIdentifiers", + "key": "payload", "fieldSchemaKey": { - "name": "CDSActionIdentifiersType", + "name": "ApexExample_CDSRestartResponsePayloadType", "version": "0.0.1" }, "optional": false } }, { - "key": "commonHeader", + "key": "status", "value": { - "key": "commonHeader", + "key": "status", "fieldSchemaKey": { - "name": "CDSRequestCommonHeaderType", + "name": "ApexExample_CDSFailureResponseStatusType", "version": "0.0.1" }, "optional": false } - }, + } + ] + }, + "outputFields": { + "entry": [ { - "key": "payload", + "key": "message", "value": { - "key": "payload", + "key": "message", "fieldSchemaKey": { - "name": "CDSCreateSubscriptionPayloadType", + "name": "SimpleStringType", "version": "0.0.1" }, "optional": false @@ -1459,189 +1886,3577 @@ }, "contextAlbumReference": [ { - "name": "PMSubscriptionAlbum", + "name": "ApexExample_EventDetailsAlbum", "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;" + "logic": "var uuidType = java.util.UUID;\nvar longType = java.lang.Long;\n\nvar albumID = executor.getExecutionProperties().getProperty(\"albumId\");\nvar eventDetailsAlbum = executor.getContextAlbum(\"ApexExample_EventDetailsAlbum\").get(albumID.toString());\nvar commonEventHeader = eventDetailsAlbum.get(\"commonEventHeader\");\nvar timestamp = longType(new Date().getTime())\nvar errorMessage = \"CDS operation failed. Error message from CDS - \" + executor.inFields.get(\"status\").get(\"errorMessage\");\nsend(commonEventHeader.get(\"eventId\"), \"VNF\", commonEventHeader.get(\"sourceId\"), timestamp, \"FINAL_FAILURE\", \"Failed to process VES event. Reason: \" + errorMessage);\ntrue;\n\nfunction send(id, targetType, targetId, timestamp, status, message) {\n var logData = '{'\n +'\"id\" : \"' + id + '\",'\n +'\"target\" : {'\n +'\"targetType\" : \"' + targetType + '\",'\n +'\"entityInfo\" : {'\n +'\"id\" : \"' + targetId + '\"'\n +'}'\n +'},'\n +'\"component\" : {'\n +'\"name\" : \"Policy\",'\n +'\"flavour\" : \"Apex-PDP\",'\n +'\"timestamp\" : ' + timestamp + ','\n +'\"status\" : \"' + status + '\",'\n +'\"message\" : \"' + message + '\",'\n +'\"artifacts\" : {'\n +'\"policyName\" : \"onap.policies.apex.Example\",'\n +'\"policyVersion\" : \"1.0.0\"'\n +'}'\n +'},'\n +'\"otherFields\" : {'\n +'\"useCaseName\" : \"apex-pdp-policy-example\"'\n +'}'\n +'}';\n\n executor.logger.info(\"sending the status to log.\");\n fireLogEvent(logData);\n}\n\nfunction fireLogEvent(logEvent){\n var headers = new HashMapType();\n executor.logger.info(\"LogEvent:\"+logEvent);\n var response = new org.onap.policy.rest.RestManager().post(\n executor.getParameters().get(\"logUrl\"),\n \"\",\n \"\",\n headers,\n \"application/json\",\n logEvent\n );\n executor.logger.info(\"DMaaP Response after sending LogEvent: \" + response);\n return response;\n}" } } }, { "key": { - "name": "DeleteSubscriptionPayloadTask", + "name": "ApexExample_CDSRestartSuccessResponseTask", "version": "0.0.1" }, "value": { "key": { - "name": "DeleteSubscriptionPayloadTask", + "name": "ApexExample_CDSRestartSuccessResponseTask", "version": "0.0.1" }, "inputFields": { "entry": [ { - "key": "albumID", + "key": "actionIdentifiers", "value": { - "key": "albumID", + "key": "actionIdentifiers", "fieldSchemaKey": { - "name": "UUIDType", + "name": "ApexExample_CDSActionIdentifiersType", "version": "0.0.1" }, "optional": false } - } - ] - }, - "outputFields": { - "entry": [ + }, { - "key": "albumID", + "key": "commonHeader", + "value": { + "key": "commonHeader", + "fieldSchemaKey": { + "name": "ApexExample_CDSSuccessResponseCommonHeaderType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "payload", "value": { - "key": "albumID", + "key": "payload", "fieldSchemaKey": { - "name": "UUIDType", + "name": "ApexExample_CDSRestartResponsePayloadType", "version": "0.0.1" }, "optional": false } }, { - "key": "payload", + "key": "status", + "value": { + "key": "status", + "fieldSchemaKey": { + "name": "ApexExample_CDSSuccessResponseStatusType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + }, + "outputFields": { + "entry": [ + { + "key": "message", + "value": { + "key": "message", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + }, + "taskParameters": { + "entry": [] + }, + "contextAlbumReference": [ + { + "name": "ApexExample_EventDetailsAlbum", + "version": "0.0.1" + } + ], + "taskLogic": { + "key": "TaskLogic", + "logicFlavour": "JAVASCRIPT", + "logic": "var uuidType = java.util.UUID;\nvar longType = java.lang.Long;\nvar HashMapType = java.util.HashMap;\n\nvar albumID = executor.getExecutionProperties().getProperty(\"albumId\");\nvar timestamp = longType(new Date().getTime());\n\nvar eventDetailsAlbum = executor.getContextAlbum(\"ApexExample_EventDetailsAlbum\").get(albumID.toString());\nvar commonEventHeader = eventDetailsAlbum.get(\"commonEventHeader\");\nsend(commonEventHeader.get(\"eventId\"), \"VNF\", commonEventHeader.get(\"sourceId\"), timestamp, \"FINAL_SUCCESS\", \"Successfully processed the VES Event. Restart is complete.\")\ntrue;\n\nfunction send(id, targetType, targetId, timestamp, status, message) {\n var logData = '{'\n +'\"id\" : \"' + id + '\",'\n +'\"target\" : {'\n +'\"targetType\" : \"' + targetType + '\",'\n +'\"entityInfo\" : {'\n +'\"id\" : \"' + targetId + '\"'\n +'}'\n +'},'\n +'\"component\" : {'\n +'\"name\" : \"Policy\",'\n +'\"flavour\" : \"Apex-PDP\",'\n +'\"timestamp\" : ' + timestamp + ','\n +'\"status\" : \"' + status + '\",'\n +'\"message\" : \"' + message + '\",'\n +'\"artifacts\" : {'\n +'\"policyName\" : \"onap.policies.apex.Example\",'\n +'\"policyVersion\" : \"1.0.0\"'\n +'}'\n +'},'\n +'\"otherFields\" : {'\n +'\"useCaseName\" : \"apex-pdp-policy-example\"'\n +'}'\n +'}';\n\n executor.logger.info(\"sending the status to log.\");\n fireLogEvent(logData);\n}\n\nfunction fireLogEvent(logEvent){\n var headers = new HashMapType();\n executor.logger.info(\"LogEvent:\"+logEvent);\n var response = new org.onap.policy.rest.RestManager().post(\n executor.getParameters().get(\"logUrl\"),\n \"\",\n \"\",\n headers,\n \"application/json\",\n logEvent\n );\n executor.logger.info(\"DMaaP Response after sending LogEvent: \" + response);\n return response;\n}" + } + } + }, + { + "key": { + "name": "ApexExample_HandleAAIFailureResponseTask", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_HandleAAIFailureResponseTask", + "version": "0.0.1" + }, + "inputFields": { + "entry": [ + { + "key": "requestError", + "value": { + "key": "requestError", + "fieldSchemaKey": { + "name": "ApexExample_AAIRequestErrorType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + }, + "outputFields": { + "entry": [ + { + "key": "message", + "value": { + "key": "message", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + }, + "taskParameters": { + "entry": [] + }, + "contextAlbumReference": [ + { + "name": "ApexExample_EventDetailsAlbum", + "version": "0.0.1" + } + ], + "taskLogic": { + "key": "TaskLogic", + "logicFlavour": "JAVASCRIPT", + "logic": "var uuidType = java.util.UUID;\nvar longType = java.lang.Long;\nvar HashMapType = java.util.HashMap;\n\nvar albumID = executor.getExecutionProperties().getProperty(\"albumId\");\n\nvar eventDetailsAlbum = executor.getContextAlbum(\"ApexExample_EventDetailsAlbum\").get(albumID.toString());\nvar commonEventHeader = eventDetailsAlbum.get(\"commonEventHeader\");\n\nvar aaiErrorMessage = \"AAI operation failed. Error message from AAI - \" + executor.inFields.get(\"requestError\").get(\"serviceException\").get(\"text\");\nvar timestamp = longType(new Date().getTime());\n\nsend(commonEventHeader.get(\"eventId\"), \"VNF\", commonEventHeader.get(\"sourceId\"), timestamp, \"FINAL_FAILURE\", \"Failed to process VES event. Reason: \" + aaiErrorMessage)\ntrue;\n\nfunction send(id, targetType, targetId, timestamp, status, message) {\n var logData = '{'\n +'\"id\" : \"' + id + '\",'\n +'\"target\" : {'\n +'\"targetType\" : \"' + targetType + '\",'\n +'\"entityInfo\" : {'\n +'\"id\" : \"' + targetId + '\"'\n +'}'\n +'},'\n +'\"component\" : {'\n +'\"name\" : \"Policy\",'\n +'\"flavour\" : \"Apex-PDP\",'\n +'\"timestamp\" : ' + timestamp + ','\n +'\"status\" : \"' + status + '\",'\n +'\"message\" : \"' + message + '\",'\n +'\"artifacts\" : {'\n +'\"policyName\" : \"onap.policies.apex.Example\",'\n +'\"policyVersion\" : \"1.0.0\"'\n +'}'\n +'},'\n +'\"otherFields\" : {'\n +'\"useCaseName\" : \"apex-pdp-policy-example\"'\n +'}'\n +'}';\n\n executor.logger.info(\"sending the status to log.\");\n fireLogEvent(logData);\n}\n\nfunction fireLogEvent(logEvent){\n var headers = new HashMapType();\n executor.logger.info(\"LogEvent:\"+logEvent);\n var response = new org.onap.policy.rest.RestManager().post(\n executor.getParameters().get(\"logUrl\"),\n \"\",\n \"\",\n headers,\n \"application/json\",\n logEvent\n );\n executor.logger.info(\"DMaaP Response after sending LogEvent: \" + response);\n return response;\n}" + } + } + }, + { + "key": { + "name": "ApexExample_HandleAAISuccessResponseTask", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_HandleAAISuccessResponseTask", + "version": "0.0.1" + }, + "inputFields": { + "entry": [ + { + "key": "in-maint", + "value": { + "key": "in-maint", + "fieldSchemaKey": { + "name": "SimpleBooleanType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "is-closed-loop-disabled", + "value": { + "key": "is-closed-loop-disabled", + "fieldSchemaKey": { + "name": "SimpleBooleanType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "model-customization-id", + "value": { + "key": "model-customization-id", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "model-invariant-id", + "value": { + "key": "model-invariant-id", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "model-version-id", + "value": { + "key": "model-version-id", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "orchestration-status", + "value": { + "key": "orchestration-status", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "prov-status", + "value": { + "key": "prov-status", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "relationship-list", + "value": { + "key": "relationship-list", + "fieldSchemaKey": { + "name": "ApexExample_VnfRelationShipListType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "resource-version", + "value": { + "key": "resource-version", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "service-id", + "value": { + "key": "service-id", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "vnf-id", + "value": { + "key": "vnf-id", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "vnf-name", + "value": { + "key": "vnf-name", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "vnf-type", + "value": { + "key": "vnf-type", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + }, + "outputFields": { + "entry": [ + { + "key": "actionIdentifiers", + "value": { + "key": "actionIdentifiers", + "fieldSchemaKey": { + "name": "ApexExample_CDSActionIdentifiersType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "commonHeader", + "value": { + "key": "commonHeader", + "fieldSchemaKey": { + "name": "ApexExample_CDSRequestCommonHeaderType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "payload", + "value": { + "key": "payload", + "fieldSchemaKey": { + "name": "ApexExample_CDSRequestPayloadType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + }, + "taskParameters": { + "entry": [] + }, + "contextAlbumReference": [ + { + "name": "ApexExample_EventDetailsAlbum", + "version": "0.0.1" + } + ], + "taskLogic": { + "key": "TaskLogic", + "logicFlavour": "JAVASCRIPT", + "logic": "var uuidType = java.util.UUID;\nvar HashMapType = java.util.HashMap;\nvar longType = java.lang.Long;\n\nvar albumID = executor.getExecutionProperties().getProperty(\"albumId\");\nvar eventDetailsAlbum = executor.getContextAlbum(\"ApexExample_EventDetailsAlbum\").get(albumID.toString());\n\nvar vnfDetails = executor.inFields;\nexecutor.logger.info(\"ApexExample_HandleAAISuccessResponseTask processing event - \" + vnfDetails);\neventDetailsAlbum.put(\"vnfDetails\", vnfDetails);\nvar commonEventHeader = eventDetailsAlbum.get(\"commonEventHeader\");\nvar faultFields = eventDetailsAlbum.get(\"faultFields\");\n\nvar commonHeader = executor.subject.getOutFieldSchemaHelper(\"commonHeader\").createNewInstance();\ncommonHeader.put(\"subRequestId\", commonEventHeader.get(\"eventId\"));\ncommonHeader.put(\"requestId\", uuidType.randomUUID().toString());\ncommonHeader.put(\"originatorId\", \"POLICY\");\n\nvar actionIdentifiers = executor.subject.getOutFieldSchemaHelper(\"actionIdentifiers\").createNewInstance();\nactionIdentifiers.put(\"mode\", \"sync\");\nactionIdentifiers.put(\"blueprintName\", \"apex-example-cba\");\nactionIdentifiers.put(\"blueprintVersion\", \"1.0.0\");\nactionIdentifiers.put(\"actionName\", \"modify-config\");\n\nvar payloadProperties = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"update_DasH_properties_record\");\npayloadProperties.put(\"service_DasH_instance_DoT_service_DasH_instance_DasH_id\", vnfDetails.get(\"service-id\").toString())\npayloadProperties.put(\"generic_DasH_vnf_DoT_vnf_DasH_id\", vnfDetails.get(\"vnf-id\").toString())\nvar dataRecord = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"update_DasH_data_record\");\ndataRecord.put(\"active_DasH_streams\",\"7\")\npayloadProperties.put(\"data\", dataRecord)\nvar payloadEntry = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"CDSRequestPayloadEntry\");\npayloadEntry.put(\"update_DasH_properties\", payloadProperties)\npayloadEntry.put(\"vfStatus\", faultFields.get(\"vfStatus\"))\nvar payload = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewInstance();\nvar payloadSchemaHelper = executor.subject.getOutFieldSchemaHelper(\"payload\");\npayload.put(\"modify_DasH_config_DasH_request\", payloadEntry);\n\n//always use the executor.stringify2json method instead of JSON.strngify\nexecutor.logger.info(\"CDS modify config request payload - \" + executor.stringify2Json(payload, payloadSchemaHelper));\n\nexecutor.outFields.put(\"commonHeader\", commonHeader);\nexecutor.outFields.put(\"actionIdentifiers\", actionIdentifiers);\nexecutor.outFields.put(\"payload\", payload);\nvar timestamp = longType(new Date().getTime());\nsend(commonEventHeader.get(\"eventId\"), \"VNF\", commonEventHeader.get(\"sourceId\"), timestamp, \"SUCCESS\", \"VNF details are received from AAI successfully. Sending ConfigModify request to CDS.\")\ntrue;\n\nfunction send(id, targetType, targetId, timestamp, status, message) {\n var logData = '{'\n +'\"id\" : \"' + id + '\",'\n +'\"target\" : {'\n +'\"targetType\" : \"' + targetType + '\",'\n +'\"entityInfo\" : {'\n +'\"id\" : \"' + targetId + '\"'\n +'}'\n +'},'\n +'\"component\" : {'\n +'\"name\" : \"Policy\",'\n +'\"flavour\" : \"Apex-PDP\",'\n +'\"timestamp\" : ' + timestamp + ','\n +'\"status\" : \"' + status + '\",'\n +'\"message\" : \"' + message + '\",'\n +'\"artifacts\" : {'\n +'\"policyName\" : \"onap.policies.apex.Example\",'\n +'\"policyVersion\" : \"1.0.0\"'\n +'}'\n +'},'\n +'\"otherFields\" : {'\n +'\"useCaseName\" : \"apex-pdp-policy-example\"'\n +'}'\n +'}';\n\n executor.logger.info(\"sending the status to log.\");\n fireLogEvent(logData);\n}\n\nfunction fireLogEvent(logEvent){\n var headers = new HashMapType();\n executor.logger.info(\"LogEvent:\"+logEvent);\n var response = new org.onap.policy.rest.RestManager().post(\n executor.getParameters().get(\"logUrl\"),\n \"\",\n \"\",\n headers,\n \"application/json\",\n logEvent\n );\n executor.logger.info(\"DMaaP Response after sending LogEvent: \" + response);\n return response;\n}" + } + } + }, + { + "key": { + "name": "ApexExample_HandleVesEventTask", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_HandleVesEventTask", + "version": "0.0.1" + }, + "inputFields": { + "entry": [ + { + "key": "event", + "value": { + "key": "event", + "fieldSchemaKey": { + "name": "ApexExample_VesEventType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + }, + "outputFields": { + "entry": [ + { + "key": "aaifield", + "value": { + "key": "aaifield", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + }, + "taskParameters": { + "entry": [] + }, + "contextAlbumReference": [ + { + "name": "ApexExample_EventDetailsAlbum", + "version": "0.0.1" + } + ], + "taskLogic": { + "key": "TaskLogic", + "logicFlavour": "JAVASCRIPT", + "logic": "var uuidType = java.util.UUID;\nvar HashMapType = java.util.HashMap;\nvar longType = java.lang.Long;\n\nvar eventDetailsAlbum = executor.getContextAlbum(\"ApexExample_EventDetailsAlbum\").getSchemaHelper().createNewInstance();\nvar returnValue = true;\n\nvar event = executor.inFields.get(\"event\");\nexecutor.logger.info(\"ApexExample_HandleVesEventTask processing VES event - \" + event);\n\nvar commonEventHeader = event.get(\"commonEventHeader\");\nvar faultFields = event.get(\"faultFields\");\n\n//albumID will be used to fetch info from our album later\nvar albumID = commonEventHeader.get(\"sourceId\");\n\n// save the event processing start time in apex\ncommonEventHeader.put(\"startEpochMicrosec\", longType(new Date().getTime()));\n//save the incoming fault event details to album\neventDetailsAlbum.put(\"commonEventHeader\", commonEventHeader)\neventDetailsAlbum.put(\"faultFields\", faultFields)\nexecutor.getContextAlbum(\"ApexExample_EventDetailsAlbum\").put(albumID.toString(), eventDetailsAlbum);\n\nexecutor.getExecutionProperties().setProperty(\"albumId\", albumID);\nexecutor.getExecutionProperties().setProperty(\"vnf-name\", eventDetailsAlbum.get(\"commonEventHeader\").get(\"sourceName\"));\n\nvar timestamp = longType(new Date().getTime());\nsend(eventDetailsAlbum.get(\"commonEventHeader\").get(\"eventId\"), \"VNF\", eventDetailsAlbum.get(\"commonEventHeader\").get(\"sourceId\"), timestamp, \"ACTIVE\", \"VES event has been received. Going to fetch VNF details from AAI.\")\n\nexecutor.logger.info(executor.outFields);\nreturnValue;\n\nfunction send(id, targetType, targetId, timestamp, status, message) {\n var logData = '{'\n +'\"id\" : \"' + id + '\",'\n +'\"target\" : {'\n +'\"targetType\" : \"' + targetType + '\",'\n +'\"entityInfo\" : {'\n +'\"id\" : \"' + targetId + '\"'\n +'}'\n +'},'\n +'\"component\" : {'\n +'\"name\" : \"Policy\",'\n +'\"flavour\" : \"Apex-PDP\",'\n +'\"timestamp\" : ' + timestamp + ','\n +'\"status\" : \"' + status + '\",'\n +'\"message\" : \"' + message + '\",'\n +'\"artifacts\" : {'\n +'\"policyName\" : \"onap.policies.apex.Example\",'\n +'\"policyVersion\" : \"1.0.0\"'\n +'}'\n +'},'\n +'\"otherFields\" : {'\n +'\"useCaseName\" : \"apex-pdp-policy-example\"'\n +'}'\n +'}';\n\n executor.logger.info(\"sending the status to log.\");\n fireLogEvent(logData);\n}\n\n\nfunction fireLogEvent(logEvent){\n var headers = new HashMapType();\n executor.logger.info(\"LogEvent:\"+logEvent);\n var response = new org.onap.policy.rest.RestManager().post(\n executor.getParameters().get(\"logUrl\"),\n \"\",\n \"\",\n headers,\n \"application/json\",\n logEvent\n );\n executor.logger.info(\"DMaaP Response after sending LogEvent: \" + response);\n return response;\n}" + } + } + } + ] + } + }, + "events": { + "key": { + "name": "onap.policies.apex.Example_Events", + "version": "0.0.1" + }, + "eventMap": { + "entry": [ + { + "key": { + "name": "ApexExample_AAIFailureResponseEvent", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_AAIFailureResponseEvent", + "version": "0.0.1" + }, + "nameSpace": "org.onap.policy.apex.example", + "source": "AAI", + "target": "APEX", + "parameter": { + "entry": [ + { + "key": "requestError", + "value": { + "key": "requestError", + "fieldSchemaKey": { + "name": "ApexExample_AAIRequestErrorType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + } + } + }, + { + "key": { + "name": "ApexExample_AAIRequestEvent", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_AAIRequestEvent", + "version": "0.0.1" + }, + "nameSpace": "org.onap.policy.apex.example", + "source": "APEX", + "target": "AAI", + "parameter": { + "entry": [ + { + "key": "aaifield", + "value": { + "key": "aaifield", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + } + } + }, + { + "key": { + "name": "ApexExample_AAISuccessResponseEvent", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_AAISuccessResponseEvent", + "version": "0.0.1" + }, + "nameSpace": "org.onap.policy.apex.example", + "source": "AAI", + "target": "APEX", + "parameter": { + "entry": [ + { + "key": "in-maint", + "value": { + "key": "in-maint", + "fieldSchemaKey": { + "name": "SimpleBooleanType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "is-closed-loop-disabled", + "value": { + "key": "is-closed-loop-disabled", + "fieldSchemaKey": { + "name": "SimpleBooleanType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "model-customization-id", + "value": { + "key": "model-customization-id", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "model-invariant-id", + "value": { + "key": "model-invariant-id", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "model-version-id", + "value": { + "key": "model-version-id", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "orchestration-status", + "value": { + "key": "orchestration-status", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "prov-status", + "value": { + "key": "prov-status", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "relationship-list", + "value": { + "key": "relationship-list", + "fieldSchemaKey": { + "name": "ApexExample_VnfRelationShipListType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "resource-version", + "value": { + "key": "resource-version", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "service-id", + "value": { + "key": "service-id", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "vnf-id", + "value": { + "key": "vnf-id", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "vnf-name", + "value": { + "key": "vnf-name", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "vnf-type", + "value": { + "key": "vnf-type", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + } + } + }, + { + "key": { + "name": "ApexExample_CDSConfigModifyFailureResponseEvent", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_CDSConfigModifyFailureResponseEvent", + "version": "0.0.1" + }, + "nameSpace": "org.onap.policy.apex.example", + "source": "CDS", + "target": "APEX", + "parameter": { + "entry": [ + { + "key": "actionIdentifiers", + "value": { + "key": "actionIdentifiers", + "fieldSchemaKey": { + "name": "ApexExample_CDSActionIdentifiersType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "commonHeader", + "value": { + "key": "commonHeader", + "fieldSchemaKey": { + "name": "ApexExample_CDSFailureResponseCommonHeaderType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "payload", + "value": { + "key": "payload", + "fieldSchemaKey": { + "name": "ApexExample_CDSConfigModifyResponsePayloadType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "status", + "value": { + "key": "status", + "fieldSchemaKey": { + "name": "ApexExample_CDSFailureResponseStatusType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + } + } + }, + { + "key": { + "name": "ApexExample_CDSConfigModifyRequestEvent", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_CDSConfigModifyRequestEvent", + "version": "0.0.1" + }, + "nameSpace": "org.onap.policy.apex.example", + "source": "APEX", + "target": "APEX", + "parameter": { + "entry": [ + { + "key": "actionIdentifiers", + "value": { + "key": "actionIdentifiers", + "fieldSchemaKey": { + "name": "ApexExample_CDSActionIdentifiersType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "commonHeader", + "value": { + "key": "commonHeader", + "fieldSchemaKey": { + "name": "ApexExample_CDSRequestCommonHeaderType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "payload", + "value": { + "key": "payload", + "fieldSchemaKey": { + "name": "ApexExample_CDSRequestPayloadType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + } + } + }, + { + "key": { + "name": "ApexExample_CDSConfigModifySuccessResponseEvent", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_CDSConfigModifySuccessResponseEvent", + "version": "0.0.1" + }, + "nameSpace": "org.onap.policy.apex.example", + "source": "CDS", + "target": "APEX", + "parameter": { + "entry": [ + { + "key": "actionIdentifiers", + "value": { + "key": "actionIdentifiers", + "fieldSchemaKey": { + "name": "ApexExample_CDSActionIdentifiersType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "commonHeader", + "value": { + "key": "commonHeader", + "fieldSchemaKey": { + "name": "ApexExample_CDSSuccessResponseCommonHeaderType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "payload", + "value": { + "key": "payload", + "fieldSchemaKey": { + "name": "ApexExample_CDSConfigModifyResponsePayloadType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "status", + "value": { + "key": "status", + "fieldSchemaKey": { + "name": "ApexExample_CDSSuccessResponseStatusType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + } + } + }, + { + "key": { + "name": "ApexExample_CDSRestartFailureResponseEvent", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_CDSRestartFailureResponseEvent", + "version": "0.0.1" + }, + "nameSpace": "org.onap.policy.apex.example", + "source": "CDS", + "target": "APEX", + "parameter": { + "entry": [ + { + "key": "actionIdentifiers", + "value": { + "key": "actionIdentifiers", + "fieldSchemaKey": { + "name": "ApexExample_CDSActionIdentifiersType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "commonHeader", + "value": { + "key": "commonHeader", + "fieldSchemaKey": { + "name": "ApexExample_CDSFailureResponseCommonHeaderType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "payload", + "value": { + "key": "payload", + "fieldSchemaKey": { + "name": "ApexExample_CDSRestartResponsePayloadType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "status", + "value": { + "key": "status", + "fieldSchemaKey": { + "name": "ApexExample_CDSFailureResponseStatusType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + } + } + }, + { + "key": { + "name": "ApexExample_CDSRestartRequestEvent", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_CDSRestartRequestEvent", + "version": "0.0.1" + }, + "nameSpace": "org.onap.policy.apex.example", + "source": "APEX", + "target": "APEX", + "parameter": { + "entry": [ + { + "key": "actionIdentifiers", + "value": { + "key": "actionIdentifiers", + "fieldSchemaKey": { + "name": "ApexExample_CDSActionIdentifiersType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "commonHeader", + "value": { + "key": "commonHeader", + "fieldSchemaKey": { + "name": "ApexExample_CDSRequestCommonHeaderType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "payload", + "value": { + "key": "payload", + "fieldSchemaKey": { + "name": "ApexExample_CDSRequestPayloadType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + } + } + }, + { + "key": { + "name": "ApexExample_CDSRestartSuccessResponseEvent", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_CDSRestartSuccessResponseEvent", + "version": "0.0.1" + }, + "nameSpace": "org.onap.policy.apex.example", + "source": "CDS", + "target": "APEX", + "parameter": { + "entry": [ + { + "key": "actionIdentifiers", + "value": { + "key": "actionIdentifiers", + "fieldSchemaKey": { + "name": "ApexExample_CDSActionIdentifiersType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "commonHeader", + "value": { + "key": "commonHeader", + "fieldSchemaKey": { + "name": "ApexExample_CDSSuccessResponseCommonHeaderType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "payload", + "value": { + "key": "payload", + "fieldSchemaKey": { + "name": "ApexExample_CDSRestartResponsePayloadType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "status", + "value": { + "key": "status", + "fieldSchemaKey": { + "name": "ApexExample_CDSSuccessResponseStatusType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + } + } + }, + { + "key": { + "name": "ApexExample_LogStatusEvent", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_LogStatusEvent", + "version": "0.0.1" + }, + "nameSpace": "org.onap.policy.apex.example", + "source": "APEX", + "target": "DCAE", + "parameter": { + "entry": [ + { + "key": "message", + "value": { + "key": "message", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + } + } + }, + { + "key": { + "name": "ApexExample_VesEvent", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_VesEvent", + "version": "0.0.1" + }, + "nameSpace": "org.onap.policy.apex.example", + "source": "DCAE", + "target": "APEX", + "parameter": { + "entry": [ + { + "key": "event", + "value": { + "key": "event", + "fieldSchemaKey": { + "name": "ApexExample_VesEventType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + } + } + } + ] + } + }, + "albums": { + "key": { + "name": "onap.policies.apex.Example_Albums", + "version": "0.0.1" + }, + "albums": { + "entry": [ + { + "key": { + "name": "ApexExample_EventDetailsAlbum", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_EventDetailsAlbum", + "version": "0.0.1" + }, + "scope": "policy", + "isWritable": true, + "itemSchema": { + "name": "ApexExample_EventDetailsAlbumType", + "version": "0.0.1" + } + } + } + ] + } + }, + "schemas": { + "key": { + "name": "onap.policies.apex.Example_Schemas", + "version": "0.0.1" + }, + "schemas": { + "entry": [ + { + "key": { + "name": "ApexExample_AAIRequestErrorType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_AAIRequestErrorType", + "version": "0.0.1" + }, + "schemaFlavour": "Avro", + "schemaDefinition": "{\n \"name\": \"AAIRequestErrorType\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"serviceException\",\n \"type\": {\n \"name\": \"serviceException\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"messageId\",\n \"type\": \"string\"\n },\n {\n \"name\": \"text\",\n \"type\": \"string\"\n },\n {\n \"name\": \"variables\",\n \"type\": {\n \"type\": \"array\",\n \"items\": \"string\"\n }\n }\n ]\n }\n }\n ]\n}" + } + }, + { + "key": { + "name": "ApexExample_CDSActionIdentifiersType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_CDSActionIdentifiersType", + "version": "0.0.1" + }, + "schemaFlavour": "Avro", + "schemaDefinition": "{\n \"type\": \"record\",\n \"name\": \"CDSActionIdentifiers_Type\",\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": "ApexExample_CDSConfigModifyResponsePayloadType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_CDSConfigModifyResponsePayloadType", + "version": "0.0.1" + }, + "schemaFlavour": "Avro", + "schemaDefinition": "{\n \"name\": \"CDSConfigResponsePayloadEntry\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"modify_DasH_config_DasH_response\",\n \"type\": {\n \"name\": \"modify_DasH_config_DasH_response\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"execute_DasH_command_DasH_logs\",\n \"type\": {\n \"type\": \"array\",\n \"items\": \"string\"\n }\n },\n {\n \"name\": \"prepare_DasH_environment_DasH_logs\",\n \"type\": {\n \"type\": \"array\",\n \"items\": \"string\"\n }\n }\n ]\n }\n }\n ]\n}" + } + }, + { + "key": { + "name": "ApexExample_CDSFailureResponseCommonHeaderType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_CDSFailureResponseCommonHeaderType", + "version": "0.0.1" + }, + "schemaFlavour": "Avro", + "schemaDefinition": "{\n \"type\": \"record\",\n \"name\": \"CDSResponseCommonHeader_Type\",\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": "ApexExample_CDSFailureResponseStatusType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_CDSFailureResponseStatusType", + "version": "0.0.1" + }, + "schemaFlavour": "Avro", + "schemaDefinition": "{\n \"type\": \"record\",\n \"name\": \"CDSResponseStatus_Type\",\n \"fields\": [\n {\n \"name\": \"code\",\n \"type\": \"int\"\n },\n {\n \"name\": \"timestamp\",\n \"type\": \"string\"\n },\n {\n \"name\": \"message\",\n \"type\": \"string\"\n },\n {\n \"name\": \"errorMessage\",\n \"type\": \"string\"\n }\n ]\n}" + } + }, + { + "key": { + "name": "ApexExample_CDSRequestCommonHeaderType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_CDSRequestCommonHeaderType", + "version": "0.0.1" + }, + "schemaFlavour": "Avro", + "schemaDefinition": "{\n \"type\": \"record\",\n \"name\": \"CDSRequestCommonHeader_Type\",\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": "ApexExample_CDSRequestPayloadType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_CDSRequestPayloadType", + "version": "0.0.1" + }, + "schemaFlavour": "Avro", + "schemaDefinition": "{\n \"type\": \"map\",\n \"values\": {\n \"type\": \"record\",\n \"name\": \"CDSRequestPayloadEntry\",\n \"fields\": [\n {\n \"name\": \"vfStatus\",\n \"type\": \"string\"\n },\n {\n \"name\": \"update_DasH_properties\",\n \"type\": {\n \"name\": \"update_DasH_properties_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"service_DasH_instance_DoT_service_DasH_instance_DasH_id\",\n \"type\": \"string\"\n },\n {\n \"name\": \"generic_DasH_vnf_DoT_vnf_DasH_id\",\n \"type\": \"string\"\n },\n {\n \"name\": \"data\",\n \"type\": {\n \"name\": \"update_DasH_data_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"active_DasH_streams\",\n \"type\": \"string\"\n }\n ]\n }\n }\n ]\n }\n }\n ]\n }\n}" + } + }, + { + "key": { + "name": "ApexExample_CDSRestartResponsePayloadType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_CDSRestartResponsePayloadType", + "version": "0.0.1" + }, + "schemaFlavour": "Avro", + "schemaDefinition": "{\n \"name\": \"CDSRestartResponsePayloadEntry\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"restart_DasH_response\",\n \"type\": {\n \"name\": \"restart_DasH_response\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"execute_DasH_command_DasH_logs\",\n \"type\": {\n \"type\": \"array\",\n \"items\": \"string\"\n }\n },\n {\n \"name\": \"prepare_DasH_environment_DasH_logs\",\n \"type\": {\n \"type\": \"array\",\n \"items\": \"string\"\n }\n }\n ]\n }\n }\n ]\n}" + } + }, + { + "key": { + "name": "ApexExample_CDSSuccessResponseCommonHeaderType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_CDSSuccessResponseCommonHeaderType", + "version": "0.0.1" + }, + "schemaFlavour": "Avro", + "schemaDefinition": "{\n \"type\": \"record\",\n \"name\": \"CDSResponseCommonHeader_Type\",\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": "ApexExample_CDSSuccessResponseStatusType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_CDSSuccessResponseStatusType", + "version": "0.0.1" + }, + "schemaFlavour": "Avro", + "schemaDefinition": "{\n \"type\": \"record\",\n \"name\": \"CDSResponseStatus_Type\",\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": "ApexExample_EventDetailsAlbumType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_EventDetailsAlbumType", + "version": "0.0.1" + }, + "schemaFlavour": "Avro", + "schemaDefinition": "{\n \"name\": \"eventDetails\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"commonEventHeader\",\n \"type\": {\n \"name\": \"commonEventHeader\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"domain\",\n \"type\": \"string\"\n },\n {\n \"name\": \"eventId\",\n \"type\": \"string\"\n },\n {\n \"name\": \"eventName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"lastEpochMicrosec\",\n \"type\": \"long\"\n },\n {\n \"name\": \"priority\",\n \"type\": \"string\"\n },\n {\n \"name\": \"reportingEntityName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"sequence\",\n \"type\": \"int\"\n },\n {\n \"name\": \"sourceId\",\n \"type\": \"string\"\n },\n {\n \"name\": \"sourceName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"startEpochMicrosec\",\n \"type\": \"long\"\n },\n {\n \"name\": \"timeZoneOffset\",\n \"type\": \"string\"\n },\n {\n \"name\": \"version\",\n \"type\": \"string\"\n },\n {\n \"name\": \"vesEventListenerVersion\",\n \"type\": \"string\"\n }\n ]\n }\n },\n {\n \"name\": \"faultFields\",\n \"type\": {\n \"name\": \"faultFields\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"alarmAdditionalInformation\",\n \"type\": {\n \"name\": \"alarmAdditionalInformation\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"PilotNumberPoolSize\",\n \"type\": \"string\"\n }\n ]\n }\n },\n {\n \"name\": \"alarmCondition\",\n \"type\": \"string\"\n },\n {\n \"name\": \"eventSeverity\",\n \"type\": \"string\"\n },\n {\n \"name\": \"eventSourceType\",\n \"type\": \"string\"\n },\n {\n \"name\": \"faultFieldsVersion\",\n \"type\": \"int\"\n },\n {\n \"name\": \"specificProblem\",\n \"type\": \"string\"\n },\n {\n \"name\": \"vfStatus\",\n \"type\": \"string\"\n }\n ]\n }\n },\n {\n \"name\": \"vnfDetails\",\n \"type\": {\n \"name\": \"vnfDetails\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"vnf_DasH_id\",\n \"type\": \"string\"\n },\n {\n \"name\": \"vnf_DasH_name\",\n \"type\": \"string\"\n },\n {\n \"name\": \"vnf_DasH_type\",\n \"type\": \"string\"\n },\n {\n \"name\": \"service_DasH_id\",\n \"type\": \"string\"\n },\n {\n \"name\": \"prov_DasH_status\",\n \"type\": \"string\"\n },\n {\n \"name\": \"orchestration_DasH_status\",\n \"type\": \"string\"\n },\n {\n \"name\": \"in_DasH_maint\",\n \"type\": \"boolean\"\n },\n {\n \"name\": \"is_DasH_closed_DasH_loop_DasH_disabled\",\n \"type\": \"boolean\"\n },\n {\n \"name\": \"resource_DasH_version\",\n \"type\": \"string\"\n },\n {\n \"name\": \"model_DasH_invariant_DasH_id\",\n \"type\": \"string\"\n },\n {\n \"name\": \"model_DasH_version_DasH_id\",\n \"type\": \"string\"\n },\n {\n \"name\": \"model_DasH_customization_DasH_id\",\n \"type\": \"string\"\n }\n ]\n }\n },\n {\n \"name\": \"target\",\n \"type\": {\n \"name\": \"target\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"targetType\",\n \"type\": \"string\"\n },\n {\n \"name\": \"entityInfo\",\n \"type\": {\n \"name\": \"entityInfo\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"name\",\n \"type\": \"string\"\n }\n ]\n }\n }\n ]\n }\n }\n ]\n}" + } + }, + { + "key": { + "name": "ApexExample_VesEventType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_VesEventType", + "version": "0.0.1" + }, + "schemaFlavour": "Avro", + "schemaDefinition": "{\n \"name\": \"event\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"commonEventHeader\",\n \"type\": {\n \"name\": \"commonEventHeader\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"domain\",\n \"type\": \"string\"\n },\n {\n \"name\": \"eventId\",\n \"type\": \"string\"\n },\n {\n \"name\": \"eventName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"lastEpochMicrosec\",\n \"type\": \"long\"\n },\n {\n \"name\": \"priority\",\n \"type\": \"string\"\n },\n {\n \"name\": \"reportingEntityName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"sequence\",\n \"type\": \"int\"\n },\n {\n \"name\": \"sourceId\",\n \"type\": \"string\"\n },\n {\n \"name\": \"sourceName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"startEpochMicrosec\",\n \"type\": \"long\"\n },\n {\n \"name\": \"timeZoneOffset\",\n \"type\": \"string\"\n },\n {\n \"name\": \"version\",\n \"type\": \"string\"\n },\n {\n \"name\": \"vesEventListenerVersion\",\n \"type\": \"string\"\n }\n ]\n }\n },\n {\n \"name\": \"faultFields\",\n \"type\": {\n \"name\": \"faultFields\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"alarmAdditionalInformation\",\n \"type\": {\n \"name\": \"alarmAdditionalInformation\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"PilotNumberPoolSize\",\n \"type\": \"string\"\n }\n ]\n }\n },\n {\n \"name\": \"alarmCondition\",\n \"type\": \"string\"\n },\n {\n \"name\": \"eventSeverity\",\n \"type\": \"string\"\n },\n {\n \"name\": \"eventSourceType\",\n \"type\": \"string\"\n },\n {\n \"name\": \"faultFieldsVersion\",\n \"type\": \"int\"\n },\n {\n \"name\": \"specificProblem\",\n \"type\": \"string\"\n },\n {\n \"name\": \"vfStatus\",\n \"type\": \"string\"\n }\n ]\n }\n }\n ]\n}" + } + }, + { + "key": { + "name": "ApexExample_VnfRelationShipListType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "ApexExample_VnfRelationShipListType", + "version": "0.0.1" + }, + "schemaFlavour": "Avro", + "schemaDefinition": "{\n \"name\": \"VnfRelationShipListType\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"relationship\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"relationship_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"related_DasH_to\",\n \"type\": \"string\"\n },\n {\n \"name\": \"relationship_DasH_label\",\n \"type\": \"string\"\n },\n {\n \"name\": \"related_DasH_link\",\n \"type\": \"string\"\n },\n {\n \"name\": \"relationship_DasH_data\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"relationship_DasH_data_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"relationship_DasH_key\",\n \"type\": \"string\"\n },\n {\n \"name\": \"relationship_DasH_value\",\n \"type\": \"string\"\n }\n ]\n }\n }\n },\n {\n \"name\": \"related_DasH_to_DasH_property\",\n \"type\": {\n \"type\": \"array\",\n \"items\": {\n \"name\": \"related_DasH_to_DasH_property_record\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"property_DasH_key\",\n \"type\": \"string\"\n },\n {\n \"name\": \"property_DasH_value\",\n \"type\": \"string\"\n }\n ]\n }\n }\n }\n ]\n }\n }\n }\n ]\n}" + } + }, + { + "key": { + "name": "SimpleBooleanType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleBooleanType", + "version": "0.0.1" + }, + "schemaFlavour": "Java", + "schemaDefinition": "java.lang.Boolean" + } + }, + { + "key": { + "name": "SimpleLongType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleLongType", + "version": "0.0.1" + }, + "schemaFlavour": "Java", + "schemaDefinition": "java.lang.Long" + } + }, + { + "key": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "schemaFlavour": "Java", + "schemaDefinition": "java.lang.String" + } + } + ] + } + } + } + } + }, + "eventInputParameters": { + "ApexExample_DCAEConsumer": { + "carrierTechnologyParameters": { + "carrierTechnology": "KAFKA", + "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.kafka.KafkaCarrierTechnologyParameters", + "parameters": { + "bootstrapServers": "kafka:9092", + "groupId": "apex-group", + "enableAutoCommit": true, + "autoCommitTime": 1000, + "sessionTimeout": 30000, + "consumerPollTime": 100, + "consumerTopicList": ["unauthenticated.dcae_policy_example_output"], + "keyDeserializer": "org.apache.kafka.common.serialization.StringDeserializer", + "valueDeserializer": "org.apache.kafka.common.serialization.StringDeserializer" + } + }, + "eventProtocolParameters": { + "eventProtocol": "JSON" + }, + "eventName": "ApexExample_VesEvent" + } + }, + "eventOutputParameters": { + "ApexExample_AAIProducer": { + "carrierTechnologyParameters": { + "carrierTechnology": "KAFKA", + "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.kafka.KafkaCarrierTechnologyParameters", + "parameters": { + "bootstrapServers": "kafka:9092", + "acks": "all", + "retries": 0, + "batchSize": 16384, + "lingerTime": 1, + "bufferMemory": 33554432, + "producerTopic": "apex-cl-mgt", + "keySerializer": "org.apache.kafka.common.serialization.StringSerializer", + "valueSerializer": "org.apache.kafka.common.serialization.StringSerializer" + } + }, + "eventProtocolParameters": { + "eventProtocol": "JSON" + } + } + } + } + } + } + ] + } +} + = + + + + + + + + 200 + + + Assertion.response_code + false + 1 + + + + + 6 + ${HOSTNAME} + ${API_PORT} + http + /policy/api/v1/policies + true + POST + true + true + + + + false + { + "tosca_definitions_version": "tosca_simple_yaml_1_1_0", + "topology_template": { + "policies": [ + { + "onap.policies.apex.Simplecontrolloop": { + "type": "onap.policies.native.Apex", + "type_version": "1.0.0", + "name": "onap.policies.apex.Simplecontrolloop", + "version": "1.0.0", + "properties": { + "engineServiceParameters": { + "name": "NSOApexEngine", + "version": "0.0.1", + "id": 45, + "instanceCount": 5, + "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": "onap.policies.apex.Simplecontrolloop", + "version": "0.0.1" + }, + "keyInformation": { + "key": { + "name": "onap.policies.apex.Simplecontrolloop_KeyInfo", + "version": "0.0.1" + }, + "keyInfoMap": { + "entry": [ + { + "key": { + "name": "SimpleBooleanType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleBooleanType", + "version": "0.0.1" + }, + "UUID": "7218fb2f-59e3-321d-9ae1-bc97b19eb4ae", + "description": "Generated description for concept referred to by key \"SimpleBooleanType:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_AAIFailureResponseEvent", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_AAIFailureResponseEvent", + "version": "0.0.1" + }, + "UUID": "c8a29e27-0a15-354a-84f9-4c7f207e5c81", + "description": "Generated description for concept referred to by key \"SimpleCL_AAIFailureResponseEvent:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_AAIFailureResponseHandlerPolicy", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_AAIFailureResponseHandlerPolicy", + "version": "0.0.1" + }, + "UUID": "5e843cee-0180-39b9-8989-180b2ffe11c0", + "description": "Generated description for concept referred to by key \"SimpleCL_AAIFailureResponseHandlerPolicy:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_AAIRequestErrorType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_AAIRequestErrorType", + "version": "0.0.1" + }, + "UUID": "90291c92-9b27-3cd9-8720-db572419c048", + "description": "Generated description for concept referred to by key \"SimpleCL_AAIRequestErrorType:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_AAIRequestEvent", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_AAIRequestEvent", + "version": "0.0.1" + }, + "UUID": "7b7e6751-4e0b-389d-98c0-5567bbc0294c", + "description": "Generated description for concept referred to by key \"SimpleCL_AAIRequestEvent:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_AAISuccessResponseEvent", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_AAISuccessResponseEvent", + "version": "0.0.1" + }, + "UUID": "63d5680c-14ef-3505-8d34-ebb646bba07b", + "description": "Generated description for concept referred to by key \"SimpleCL_AAISuccessResponseEvent:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_AAISuccessResponseHandlerPolicy", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_AAISuccessResponseHandlerPolicy", + "version": "0.0.1" + }, + "UUID": "a84ca97d-6e94-39a2-91f9-59a6c9aa435e", + "description": "Generated description for concept referred to by key \"SimpleCL_AAISuccessResponseHandlerPolicy:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_CDSActionIdentifiersType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_CDSActionIdentifiersType", + "version": "0.0.1" + }, + "UUID": "0e2ee622-7fd3-3e49-82e2-539c4f5e9624", + "description": "Generated description for concept referred to by key \"SimpleCL_CDSActionIdentifiersType:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_CDSConfigModifyFailureResponseEvent", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_CDSConfigModifyFailureResponseEvent", + "version": "0.0.1" + }, + "UUID": "e84f8682-ea33-3ad0-8626-8bc4634581fc", + "description": "Generated description for concept referred to by key \"SimpleCL_CDSConfigModifyFailureResponseEvent:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_CDSConfigModifyFailureResponseHandlerPolicy", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_CDSConfigModifyFailureResponseHandlerPolicy", + "version": "0.0.1" + }, + "UUID": "a252f835-2479-38ef-9ef4-20af62725752", + "description": "Generated description for concept referred to by key \"SimpleCL_CDSConfigModifyFailureResponseHandlerPolicy:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_CDSConfigModifyFailureResponseTask", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_CDSConfigModifyFailureResponseTask", + "version": "0.0.1" + }, + "UUID": "cfc46ea9-b8c1-38dd-ac9c-304c916daf34", + "description": "Generated description for concept referred to by key \"SimpleCL_CDSConfigModifyFailureResponseTask:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_CDSConfigModifyRequestEvent", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_CDSConfigModifyRequestEvent", + "version": "0.0.1" + }, + "UUID": "1e7095d6-a455-3f89-acae-486e35d7e311", + "description": "Generated description for concept referred to by key \"SimpleCL_CDSConfigModifyRequestEvent:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_CDSConfigModifyRequestPayloadType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_CDSConfigModifyRequestPayloadType", + "version": "0.0.1" + }, + "UUID": "d22ea83b-695d-3da9-b9f5-41f16ca433bf", + "description": "Generated description for concept referred to by key \"SimpleCL_CDSConfigModifyRequestPayloadType:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_CDSConfigModifyResponsePayloadType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_CDSConfigModifyResponsePayloadType", + "version": "0.0.1" + }, + "UUID": "e9fe2e40-1f0d-30dd-8b9e-885695878693", + "description": "Generated description for concept referred to by key \"SimpleCL_CDSConfigModifyResponsePayloadType:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_CDSConfigModifySuccessResponseEvent", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_CDSConfigModifySuccessResponseEvent", + "version": "0.0.1" + }, + "UUID": "5e04fa76-0a17-38a9-8524-23b2d1a23fa5", + "description": "Generated description for concept referred to by key \"SimpleCL_CDSConfigModifySuccessResponseEvent:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_CDSConfigModifySuccessResponseHandlerPolicy", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_CDSConfigModifySuccessResponseHandlerPolicy", + "version": "0.0.1" + }, + "UUID": "15866380-40f5-3f8e-87d9-13747a36d352", + "description": "Generated description for concept referred to by key \"SimpleCL_CDSConfigModifySuccessResponseHandlerPolicy:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_CDSConfigModifySuccessResponseTask", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_CDSConfigModifySuccessResponseTask", + "version": "0.0.1" + }, + "UUID": "2c3d76ce-dd42-32ac-a397-ab418534e1cf", + "description": "Generated description for concept referred to by key \"SimpleCL_CDSConfigModifySuccessResponseTask:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_CDSFailureResponseCommonHeaderType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_CDSFailureResponseCommonHeaderType", + "version": "0.0.1" + }, + "UUID": "b99c44da-dae7-3c96-b528-58852537d063", + "description": "Generated description for concept referred to by key \"SimpleCL_CDSFailureResponseCommonHeaderType:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_CDSFailureResponseStatusType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_CDSFailureResponseStatusType", + "version": "0.0.1" + }, + "UUID": "1db688e2-3afe-3b03-9795-fdbfa80fa240", + "description": "Generated description for concept referred to by key \"SimpleCL_CDSFailureResponseStatusType:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_CDSRequestCommonHeaderType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_CDSRequestCommonHeaderType", + "version": "0.0.1" + }, + "UUID": "31022456-e85b-3a9b-9ecb-a09691792d3e", + "description": "Generated description for concept referred to by key \"SimpleCL_CDSRequestCommonHeaderType:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_CDSSuccessResponseCommonHeaderType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_CDSSuccessResponseCommonHeaderType", + "version": "0.0.1" + }, + "UUID": "d6075720-622e-3a0d-827a-aa4580a2f5d7", + "description": "Generated description for concept referred to by key \"SimpleCL_CDSSuccessResponseCommonHeaderType:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_CDSSuccessResponseStatusType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_CDSSuccessResponseStatusType", + "version": "0.0.1" + }, + "UUID": "948359ff-3308-3ac5-a5ec-6e3c1b9cd4d5", + "description": "Generated description for concept referred to by key \"SimpleCL_CDSSuccessResponseStatusType:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_EventDetailsAlbum", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_EventDetailsAlbum", + "version": "0.0.1" + }, + "UUID": "63a6fd26-2fd6-3a0e-8a27-49a5d2ea4644", + "description": "Generated description for concept referred to by key \"SimpleCL_EventDetailsAlbum:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_EventDetailsAlbumType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_EventDetailsAlbumType", + "version": "0.0.1" + }, + "UUID": "a0407d0b-5719-38bf-9529-25ad62ace8c4", + "description": "Generated description for concept referred to by key \"SimpleCL_EventDetailsAlbumType:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_HandleAAIFailureResponseTask", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_HandleAAIFailureResponseTask", + "version": "0.0.1" + }, + "UUID": "28e894dc-4ab8-3469-aab7-d81bd05bb4c9", + "description": "Generated description for concept referred to by key \"SimpleCL_HandleAAIFailureResponseTask:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_HandleAAISuccessResponseTask", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_HandleAAISuccessResponseTask", + "version": "0.0.1" + }, + "UUID": "073f1433-999e-3506-98ad-ef820d2fa7f0", + "description": "Generated description for concept referred to by key \"SimpleCL_HandleAAISuccessResponseTask:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_HandleVesEventTask", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_HandleVesEventTask", + "version": "0.0.1" + }, + "UUID": "afc6ed46-6801-3c85-bb4c-0ab5b0dd4a74", + "description": "Generated description for concept referred to by key \"SimpleCL_HandleVesEventTask:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_LogEvent", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_LogEvent", + "version": "0.0.1" + }, + "UUID": "317be184-a01a-3e2d-9ae4-cafaa405de70", + "description": "Generated description for concept referred to by key \"SimpleCL_LogEvent:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_LogEventComponentType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_LogEventComponentType", + "version": "0.0.1" + }, + "UUID": "be7fc79b-9b73-381a-8e23-9dd6e6b1233d", + "description": "Generated description for concept referred to by key \"SimpleCL_LogEventComponentType:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_LogEventOtherFieldsType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_LogEventOtherFieldsType", + "version": "0.0.1" + }, + "UUID": "1a082851-49e3-3f4c-b023-c05236cc8389", + "description": "Generated description for concept referred to by key \"SimpleCL_LogEventOtherFieldsType:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_LogEventTargetType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_LogEventTargetType", + "version": "0.0.1" + }, + "UUID": "cab6cd51-ea7b-3241-a173-ea8a24e29737", + "description": "Generated description for concept referred to by key \"SimpleCL_LogEventTargetType:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_VesEvent", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_VesEvent", + "version": "0.0.1" + }, + "UUID": "0f57665a-f0a9-314e-ad0a-04c1f5758174", + "description": "Generated description for concept referred to by key \"SimpleCL_VesEvent:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_VesEventHandlerPolicy", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_VesEventHandlerPolicy", + "version": "0.0.1" + }, + "UUID": "ba5d9a46-8cb4-3fbe-84fd-eabba5b7dd4b", + "description": "Generated description for concept referred to by key \"SimpleCL_VesEventHandlerPolicy:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleCL_VesEventType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_VesEventType", + "version": "0.0.1" + }, + "UUID": "9fd7a967-57d4-36ef-81e9-c3396f3aa8d1", + "description": "Generated description for concept referred to by key \"SimpleCL_VesEventType:0.0.1\"" + } + }, + { + "key": { + "name": "SimpleLongType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleLongType", + "version": "0.0.1" + }, + "UUID": "2dfcd9ec-a6f9-3f9f-958f-9b36cf4ac574", + "description": "Generated description for concept referred to by key \"SimpleLongType: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": "onap.policies.apex.Simplecontrolloop", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "onap.policies.apex.Simplecontrolloop", + "version": "0.0.1" + }, + "UUID": "ecc97b87-f30b-344c-a476-d36501bf5cbd", + "description": "Generated description for concept referred to by key \"onap.policies.apex.Simplecontrolloop:0.0.1\"" + } + }, + { + "key": { + "name": "onap.policies.apex.Simplecontrolloop_Albums", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "onap.policies.apex.Simplecontrolloop_Albums", + "version": "0.0.1" + }, + "UUID": "1469671a-56dd-3a68-bf6c-77a5cf7a9487", + "description": "Generated description for concept referred to by key \"onap.policies.apex.Simplecontrolloop_Albums:0.0.1\"" + } + }, + { + "key": { + "name": "onap.policies.apex.Simplecontrolloop_Events", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "onap.policies.apex.Simplecontrolloop_Events", + "version": "0.0.1" + }, + "UUID": "23c4eee4-aba5-36f6-96d6-46f40061bfed", + "description": "Generated description for concept referred to by key \"onap.policies.apex.Simplecontrolloop_Events:0.0.1\"" + } + }, + { + "key": { + "name": "onap.policies.apex.Simplecontrolloop_KeyInfo", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "onap.policies.apex.Simplecontrolloop_KeyInfo", + "version": "0.0.1" + }, + "UUID": "ea9e73ff-483c-3827-896c-6eaa9d69bc6e", + "description": "Generated description for concept referred to by key \"onap.policies.apex.Simplecontrolloop_KeyInfo:0.0.1\"" + } + }, + { + "key": { + "name": "onap.policies.apex.Simplecontrolloop_Policies", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "onap.policies.apex.Simplecontrolloop_Policies", + "version": "0.0.1" + }, + "UUID": "38c068e5-bb9a-3997-9e50-ec77c66825c8", + "description": "Generated description for concept referred to by key \"onap.policies.apex.Simplecontrolloop_Policies:0.0.1\"" + } + }, + { + "key": { + "name": "onap.policies.apex.Simplecontrolloop_Schemas", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "onap.policies.apex.Simplecontrolloop_Schemas", + "version": "0.0.1" + }, + "UUID": "38514b27-8b9b-3d06-844a-3aced27deb0a", + "description": "Generated description for concept referred to by key \"onap.policies.apex.Simplecontrolloop_Schemas:0.0.1\"" + } + }, + { + "key": { + "name": "onap.policies.apex.Simplecontrolloop_Tasks", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "onap.policies.apex.Simplecontrolloop_Tasks", + "version": "0.0.1" + }, + "UUID": "0e0387b5-07fa-30e4-8554-eb51d2e18939", + "description": "Generated description for concept referred to by key \"onap.policies.apex.Simplecontrolloop_Tasks:0.0.1\"" + } + } + ] + } + }, + "policies": { + "key": { + "name": "onap.policies.apex.Simplecontrolloop_Policies", + "version": "0.0.1" + }, + "policyMap": { + "entry": [ + { + "key": { + "name": "SimpleCL_AAIFailureResponseHandlerPolicy", + "version": "0.0.1" + }, + "value": { + "policyKey": { + "name": "SimpleCL_AAIFailureResponseHandlerPolicy", + "version": "0.0.1" + }, + "template": "Freestyle", + "state": { + "entry": [ + { + "key": "SimpleCL_ReceiveAAIFailureResponseState", + "value": { + "stateKey": { + "parentKeyName": "SimpleCL_AAIFailureResponseHandlerPolicy", + "parentKeyVersion": "0.0.1", + "parentLocalName": "NULL", + "localName": "SimpleCL_ReceiveAAIFailureResponseState" + }, + "trigger": { + "name": "SimpleCL_AAIFailureResponseEvent", + "version": "0.0.1" + }, + "stateOutputs": { + "entry": [ + { + "key": "AAIFailureStateOutput", + "value": { + "key": { + "parentKeyName": "SimpleCL_AAIFailureResponseHandlerPolicy", + "parentKeyVersion": "0.0.1", + "parentLocalName": "SimpleCL_ReceiveAAIFailureResponseState", + "localName": "AAIFailureStateOutput" + }, + "outgoingEvent": { + "name": "SimpleCL_LogEvent", + "version": "0.0.1" + }, + "outgoingEventReference": [ + { + "name": "SimpleCL_LogEvent", + "version": "0.0.1" + } + ], + "nextState": { + "parentKeyName": "NULL", + "parentKeyVersion": "0.0.0", + "parentLocalName": "NULL", + "localName": "NULL" + } + } + } + ] + }, + "contextAlbumReference": [], + "taskSelectionLogic": { + "key": "NULL", + "logicFlavour": "UNDEFINED", + "logic": "" + }, + "stateFinalizerLogicMap": { + "entry": [] + }, + "defaultTask": { + "name": "SimpleCL_HandleAAIFailureResponseTask", + "version": "0.0.1" + }, + "taskReferences": { + "entry": [ + { + "key": { + "name": "SimpleCL_HandleAAIFailureResponseTask", + "version": "0.0.1" + }, + "value": { + "key": { + "parentKeyName": "SimpleCL_AAIFailureResponseHandlerPolicy", + "parentKeyVersion": "0.0.1", + "parentLocalName": "SimpleCL_ReceiveAAIFailureResponseState", + "localName": "SimpleCL_AAIFailureResponseHandlerPolicy" + }, + "outputType": "DIRECT", + "output": { + "parentKeyName": "SimpleCL_AAIFailureResponseHandlerPolicy", + "parentKeyVersion": "0.0.1", + "parentLocalName": "SimpleCL_ReceiveAAIFailureResponseState", + "localName": "AAIFailureStateOutput" + } + } + } + ] + } + } + } + ] + }, + "firstState": "SimpleCL_ReceiveAAIFailureResponseState" + } + }, + { + "key": { + "name": "SimpleCL_AAISuccessResponseHandlerPolicy", + "version": "0.0.1" + }, + "value": { + "policyKey": { + "name": "SimpleCL_AAISuccessResponseHandlerPolicy", + "version": "0.0.1" + }, + "template": "Freestyle", + "state": { + "entry": [ + { + "key": "SimpleCL_ReceiveAAISuccessResponseState", + "value": { + "stateKey": { + "parentKeyName": "SimpleCL_AAISuccessResponseHandlerPolicy", + "parentKeyVersion": "0.0.1", + "parentLocalName": "NULL", + "localName": "SimpleCL_ReceiveAAISuccessResponseState" + }, + "trigger": { + "name": "SimpleCL_AAISuccessResponseEvent", + "version": "0.0.1" + }, + "stateOutputs": { + "entry": [ + { + "key": "AAISuccessStateOutput", + "value": { + "key": { + "parentKeyName": "SimpleCL_AAISuccessResponseHandlerPolicy", + "parentKeyVersion": "0.0.1", + "parentLocalName": "SimpleCL_ReceiveAAISuccessResponseState", + "localName": "AAISuccessStateOutput" + }, + "outgoingEvent": { + "name": "SimpleCL_CDSConfigModifyRequestEvent", + "version": "0.0.1" + }, + "outgoingEventReference": [ + { + "name": "SimpleCL_CDSConfigModifyRequestEvent", + "version": "0.0.1" + }, + { + "name": "SimpleCL_LogEvent", + "version": "0.0.1" + } + ], + "nextState": { + "parentKeyName": "NULL", + "parentKeyVersion": "0.0.0", + "parentLocalName": "NULL", + "localName": "NULL" + } + } + } + ] + }, + "contextAlbumReference": [], + "taskSelectionLogic": { + "key": "NULL", + "logicFlavour": "UNDEFINED", + "logic": "" + }, + "stateFinalizerLogicMap": { + "entry": [] + }, + "defaultTask": { + "name": "SimpleCL_HandleAAISuccessResponseTask", + "version": "0.0.1" + }, + "taskReferences": { + "entry": [ + { + "key": { + "name": "SimpleCL_HandleAAISuccessResponseTask", + "version": "0.0.1" + }, + "value": { + "key": { + "parentKeyName": "SimpleCL_AAISuccessResponseHandlerPolicy", + "parentKeyVersion": "0.0.1", + "parentLocalName": "SimpleCL_ReceiveAAISuccessResponseState", + "localName": "SimpleCL_AAISuccessResponseHandlerPolicy" + }, + "outputType": "DIRECT", + "output": { + "parentKeyName": "SimpleCL_AAISuccessResponseHandlerPolicy", + "parentKeyVersion": "0.0.1", + "parentLocalName": "SimpleCL_ReceiveAAISuccessResponseState", + "localName": "AAISuccessStateOutput" + } + } + } + ] + } + } + } + ] + }, + "firstState": "SimpleCL_ReceiveAAISuccessResponseState" + } + }, + { + "key": { + "name": "SimpleCL_CDSConfigModifyFailureResponseHandlerPolicy", + "version": "0.0.1" + }, + "value": { + "policyKey": { + "name": "SimpleCL_CDSConfigModifyFailureResponseHandlerPolicy", + "version": "0.0.1" + }, + "template": "Freestyle", + "state": { + "entry": [ + { + "key": "SimpleCL_CDSConfigModifyFailureResponseState", + "value": { + "stateKey": { + "parentKeyName": "SimpleCL_CDSConfigModifyFailureResponseHandlerPolicy", + "parentKeyVersion": "0.0.1", + "parentLocalName": "NULL", + "localName": "SimpleCL_CDSConfigModifyFailureResponseState" + }, + "trigger": { + "name": "SimpleCL_CDSConfigModifyFailureResponseEvent", + "version": "0.0.1" + }, + "stateOutputs": { + "entry": [ + { + "key": "ConfigModifyFailureResponseOutput", + "value": { + "key": { + "parentKeyName": "SimpleCL_CDSConfigModifyFailureResponseHandlerPolicy", + "parentKeyVersion": "0.0.1", + "parentLocalName": "SimpleCL_CDSConfigModifyFailureResponseState", + "localName": "ConfigModifyFailureResponseOutput" + }, + "outgoingEvent": { + "name": "SimpleCL_LogEvent", + "version": "0.0.1" + }, + "outgoingEventReference": [ + { + "name": "SimpleCL_LogEvent", + "version": "0.0.1" + } + ], + "nextState": { + "parentKeyName": "NULL", + "parentKeyVersion": "0.0.0", + "parentLocalName": "NULL", + "localName": "NULL" + } + } + } + ] + }, + "contextAlbumReference": [], + "taskSelectionLogic": { + "key": "NULL", + "logicFlavour": "UNDEFINED", + "logic": "" + }, + "stateFinalizerLogicMap": { + "entry": [] + }, + "defaultTask": { + "name": "SimpleCL_CDSConfigModifyFailureResponseTask", + "version": "0.0.1" + }, + "taskReferences": { + "entry": [ + { + "key": { + "name": "SimpleCL_CDSConfigModifyFailureResponseTask", + "version": "0.0.1" + }, + "value": { + "key": { + "parentKeyName": "SimpleCL_CDSConfigModifyFailureResponseHandlerPolicy", + "parentKeyVersion": "0.0.1", + "parentLocalName": "SimpleCL_CDSConfigModifyFailureResponseState", + "localName": "SimpleCL_CDSConfigModifyFailureResponseHandlerPolicy" + }, + "outputType": "DIRECT", + "output": { + "parentKeyName": "SimpleCL_CDSConfigModifyFailureResponseHandlerPolicy", + "parentKeyVersion": "0.0.1", + "parentLocalName": "SimpleCL_CDSConfigModifyFailureResponseState", + "localName": "ConfigModifyFailureResponseOutput" + } + } + } + ] + } + } + } + ] + }, + "firstState": "SimpleCL_CDSConfigModifyFailureResponseState" + } + }, + { + "key": { + "name": "SimpleCL_CDSConfigModifySuccessResponseHandlerPolicy", + "version": "0.0.1" + }, + "value": { + "policyKey": { + "name": "SimpleCL_CDSConfigModifySuccessResponseHandlerPolicy", + "version": "0.0.1" + }, + "template": "Freestyle", + "state": { + "entry": [ + { + "key": "SimpleCL_CDSConfigModifySuccessResponseState", + "value": { + "stateKey": { + "parentKeyName": "SimpleCL_CDSConfigModifySuccessResponseHandlerPolicy", + "parentKeyVersion": "0.0.1", + "parentLocalName": "NULL", + "localName": "SimpleCL_CDSConfigModifySuccessResponseState" + }, + "trigger": { + "name": "SimpleCL_CDSConfigModifySuccessResponseEvent", + "version": "0.0.1" + }, + "stateOutputs": { + "entry": [ + { + "key": "ConfigModifySuccessResponseOutput", + "value": { + "key": { + "parentKeyName": "SimpleCL_CDSConfigModifySuccessResponseHandlerPolicy", + "parentKeyVersion": "0.0.1", + "parentLocalName": "SimpleCL_CDSConfigModifySuccessResponseState", + "localName": "ConfigModifySuccessResponseOutput" + }, + "outgoingEvent": { + "name": "SimpleCL_LogEvent", + "version": "0.0.1" + }, + "outgoingEventReference": [ + { + "name": "SimpleCL_LogEvent", + "version": "0.0.1" + } + ], + "nextState": { + "parentKeyName": "NULL", + "parentKeyVersion": "0.0.0", + "parentLocalName": "NULL", + "localName": "NULL" + } + } + } + ] + }, + "contextAlbumReference": [], + "taskSelectionLogic": { + "key": "NULL", + "logicFlavour": "UNDEFINED", + "logic": "" + }, + "stateFinalizerLogicMap": { + "entry": [] + }, + "defaultTask": { + "name": "SimpleCL_CDSConfigModifySuccessResponseTask", + "version": "0.0.1" + }, + "taskReferences": { + "entry": [ + { + "key": { + "name": "SimpleCL_CDSConfigModifySuccessResponseTask", + "version": "0.0.1" + }, + "value": { + "key": { + "parentKeyName": "SimpleCL_CDSConfigModifySuccessResponseHandlerPolicy", + "parentKeyVersion": "0.0.1", + "parentLocalName": "SimpleCL_CDSConfigModifySuccessResponseState", + "localName": "SimpleCL_CDSConfigModifySuccessResponseHandlerPolicy" + }, + "outputType": "DIRECT", + "output": { + "parentKeyName": "SimpleCL_CDSConfigModifySuccessResponseHandlerPolicy", + "parentKeyVersion": "0.0.1", + "parentLocalName": "SimpleCL_CDSConfigModifySuccessResponseState", + "localName": "ConfigModifySuccessResponseOutput" + } + } + } + ] + } + } + } + ] + }, + "firstState": "SimpleCL_CDSConfigModifySuccessResponseState" + } + }, + { + "key": { + "name": "SimpleCL_VesEventHandlerPolicy", + "version": "0.0.1" + }, + "value": { + "policyKey": { + "name": "SimpleCL_VesEventHandlerPolicy", + "version": "0.0.1" + }, + "template": "Freestyle", + "state": { + "entry": [ + { + "key": "SimpleCL_ReceiveVesState", + "value": { + "stateKey": { + "parentKeyName": "SimpleCL_VesEventHandlerPolicy", + "parentKeyVersion": "0.0.1", + "parentLocalName": "NULL", + "localName": "SimpleCL_ReceiveVesState" + }, + "trigger": { + "name": "SimpleCL_VesEvent", + "version": "0.0.1" + }, + "stateOutputs": { + "entry": [ + { + "key": "VesOutput", + "value": { + "key": { + "parentKeyName": "SimpleCL_VesEventHandlerPolicy", + "parentKeyVersion": "0.0.1", + "parentLocalName": "SimpleCL_ReceiveVesState", + "localName": "VesOutput" + }, + "outgoingEvent": { + "name": "SimpleCL_AAIRequestEvent", + "version": "0.0.1" + }, + "outgoingEventReference": [ + { + "name": "SimpleCL_AAIRequestEvent", + "version": "0.0.1" + }, + { + "name": "SimpleCL_LogEvent", + "version": "0.0.1" + } + ], + "nextState": { + "parentKeyName": "NULL", + "parentKeyVersion": "0.0.0", + "parentLocalName": "NULL", + "localName": "NULL" + } + } + } + ] + }, + "contextAlbumReference": [], + "taskSelectionLogic": { + "key": "NULL", + "logicFlavour": "UNDEFINED", + "logic": "" + }, + "stateFinalizerLogicMap": { + "entry": [] + }, + "defaultTask": { + "name": "SimpleCL_HandleVesEventTask", + "version": "0.0.1" + }, + "taskReferences": { + "entry": [ + { + "key": { + "name": "SimpleCL_HandleVesEventTask", + "version": "0.0.1" + }, + "value": { + "key": { + "parentKeyName": "SimpleCL_VesEventHandlerPolicy", + "parentKeyVersion": "0.0.1", + "parentLocalName": "SimpleCL_ReceiveVesState", + "localName": "SimpleCL_VesEventHandlerPolicy" + }, + "outputType": "DIRECT", + "output": { + "parentKeyName": "SimpleCL_VesEventHandlerPolicy", + "parentKeyVersion": "0.0.1", + "parentLocalName": "SimpleCL_ReceiveVesState", + "localName": "VesOutput" + } + } + } + ] + } + } + } + ] + }, + "firstState": "SimpleCL_ReceiveVesState" + } + } + ] + } + }, + "tasks": { + "key": { + "name": "onap.policies.apex.Simplecontrolloop_Tasks", + "version": "0.0.1" + }, + "taskMap": { + "entry": [ + { + "key": { + "name": "SimpleCL_CDSConfigModifyFailureResponseTask", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_CDSConfigModifyFailureResponseTask", + "version": "0.0.1" + }, + "inputEvent": { + "key": { + "name": "SimpleCL_CDSConfigModifyFailureResponseEvent", + "version": "0.0.1" + }, + "nameSpace": "org.onap.policy.apex.simplecontrolloop", + "source": "CDS", + "target": "APEX", + "parameter": { + "entry": [ + { + "key": "actionIdentifiers", + "value": { + "key": "actionIdentifiers", + "fieldSchemaKey": { + "name": "SimpleCL_CDSActionIdentifiersType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "commonHeader", + "value": { + "key": "commonHeader", + "fieldSchemaKey": { + "name": "SimpleCL_CDSFailureResponseCommonHeaderType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "payload", + "value": { + "key": "payload", + "fieldSchemaKey": { + "name": "SimpleCL_CDSConfigModifyRequestPayloadType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "status", + "value": { + "key": "status", + "fieldSchemaKey": { + "name": "SimpleCL_CDSFailureResponseStatusType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + } + }, + "outputEvents": { + "entry": [ + { + "key": "SimpleCL_LogEvent", + "value": { + "key": { + "name": "SimpleCL_LogEvent", + "version": "0.0.1" + }, + "nameSpace": "org.onap.policy.apex.simplecontrolloop", + "source": "APEX", + "target": "DCAE", + "parameter": { + "entry": [ + { + "key": "component", + "value": { + "key": "component", + "fieldSchemaKey": { + "name": "SimpleCL_LogEventComponentType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "id", + "value": { + "key": "id", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "otherFields", + "value": { + "key": "otherFields", + "fieldSchemaKey": { + "name": "SimpleCL_LogEventOtherFieldsType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "target", + "value": { + "key": "target", + "fieldSchemaKey": { + "name": "SimpleCL_LogEventTargetType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + } + } + } + ] + }, + "taskParameters": { + "entry": [] + }, + "contextAlbumReference": [ + { + "name": "SimpleCL_EventDetailsAlbum", + "version": "0.0.1" + } + ], + "taskLogic": { + "key": "TaskLogic", + "logicFlavour": "JAVASCRIPT", + "logic": "var uuidType = java.util.UUID;\nvar longType = java.lang.Long;\nvar HashMapType = java.util.HashMap;\n\nvar albumID = executor.getExecutionProperties().getProperty(\"albumId\");\nvar eventDetailsAlbum = executor.getContextAlbum(\"SimpleCL_EventDetailsAlbum\").get(albumID.toString());\n\nvar commonEventHeader = eventDetailsAlbum.get(\"commonEventHeader\");\nvar errorMessage = \"CDS operation failed. Error message from CDS - \" + executor.inFields.get(\"status\").get(\"errorMessage\");\nvar logEventFields = populateLogEventFields(commonEventHeader.get(\"eventId\"), eventDetailsAlbum.get(\"otherFields\").get(\"hashMap\").get(\"pnfName\"), \"PNF\", \"FINAL_FAILURE\", \"Failed to process VES event. Reason: \" + errorMessage);\nexecutor.addFieldsToOutput(logEventFields);\nexecutor.logger.info(executor.outFieldsList);\ntrue;\n\nfunction populateLogEventFields(eventId, pnfName, targetType, status, message) {\n var timestamp = longType(new Date().getTime());\n var logEventFields = java.util.HashMap();\n logEventFields.put(\"id\", eventId);\n\n var entityInfo = executor.subject.getOutFieldSchemaHelper(\"SimpleCL_LogEvent\", \"target\").createNewSubInstance(\"entityInfo\");\n entityInfo.put(\"pnf_DasH_name\", pnfName);\n var target = executor.subject.getOutFieldSchemaHelper(\"SimpleCL_LogEvent\", \"target\").createNewInstance();\n target.put(\"entityInfo\", entityInfo);\n target.put(\"targetType\", targetType)\n logEventFields.put(\"target\", target);\n\n var artifacts = executor.subject.getOutFieldSchemaHelper(\"SimpleCL_LogEvent\", \"component\").createNewSubInstance(\"artifacts\");\n artifacts.put(\"policyName\", \"onap.policies.apex.Simplecontrolloop\");\n artifacts.put(\"policyVersion\", \"1.0.0\");\n var component = executor.subject.getOutFieldSchemaHelper(\"SimpleCL_LogEvent\", \"component\").createNewInstance();\n component.put(\"artifacts\", artifacts);\n component.put(\"name\", \"Policy\")\n component.put(\"flavour\", \"Apex-PDP\")\n component.put(\"timestamp\", timestamp)\n component.put(\"status\", status)\n component.put(\"message\", message)\n logEventFields.put(\"component\", component);\n\n var otherFieldsEntry = executor.subject.getOutFieldSchemaHelper(\"SimpleCL_LogEvent\", \"otherFields\").createNewInstance();\n otherFieldsEntry.put(\"useCaseName\", \"simple-controlloop-usecase\");\n logEventFields.put(\"otherFields\", otherFieldsEntry);\n\n return logEventFields;\n}" + } + } + }, + { + "key": { + "name": "SimpleCL_CDSConfigModifySuccessResponseTask", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_CDSConfigModifySuccessResponseTask", + "version": "0.0.1" + }, + "inputEvent": { + "key": { + "name": "SimpleCL_CDSConfigModifySuccessResponseEvent", + "version": "0.0.1" + }, + "nameSpace": "org.onap.policy.apex.simplecontrolloop", + "source": "CDS", + "target": "APEX", + "parameter": { + "entry": [ + { + "key": "actionIdentifiers", + "value": { + "key": "actionIdentifiers", + "fieldSchemaKey": { + "name": "SimpleCL_CDSActionIdentifiersType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "commonHeader", + "value": { + "key": "commonHeader", + "fieldSchemaKey": { + "name": "SimpleCL_CDSSuccessResponseCommonHeaderType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "payload", + "value": { + "key": "payload", + "fieldSchemaKey": { + "name": "SimpleCL_CDSConfigModifyResponsePayloadType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "status", + "value": { + "key": "status", + "fieldSchemaKey": { + "name": "SimpleCL_CDSSuccessResponseStatusType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + } + }, + "outputEvents": { + "entry": [ + { + "key": "SimpleCL_LogEvent", + "value": { + "key": { + "name": "SimpleCL_LogEvent", + "version": "0.0.1" + }, + "nameSpace": "org.onap.policy.apex.simplecontrolloop", + "source": "APEX", + "target": "DCAE", + "parameter": { + "entry": [ + { + "key": "component", + "value": { + "key": "component", + "fieldSchemaKey": { + "name": "SimpleCL_LogEventComponentType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "id", + "value": { + "key": "id", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "otherFields", + "value": { + "key": "otherFields", + "fieldSchemaKey": { + "name": "SimpleCL_LogEventOtherFieldsType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "target", + "value": { + "key": "target", + "fieldSchemaKey": { + "name": "SimpleCL_LogEventTargetType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + } + } + } + ] + }, + "taskParameters": { + "entry": [] + }, + "contextAlbumReference": [ + { + "name": "SimpleCL_EventDetailsAlbum", + "version": "0.0.1" + } + ], + "taskLogic": { + "key": "TaskLogic", + "logicFlavour": "JAVASCRIPT", + "logic": "var uuidType = java.util.UUID;\nvar longType = java.lang.Long;\nvar HashMapType = java.util.HashMap;\n\nvar albumID = executor.getExecutionProperties().getProperty(\"albumId\");\nvar eventDetailsAlbum = executor.getContextAlbum(\"SimpleCL_EventDetailsAlbum\").get(albumID.toString());\nvar commonEventHeader = eventDetailsAlbum.get(\"commonEventHeader\");\n\nvar logEventFields = populateLogEventFields(commonEventHeader.get(\"eventId\"), eventDetailsAlbum.get(\"otherFields\").get(\"hashMap\").get(\"pnfName\"), \"PNF\", \"FINAL_SUCCESS\", \"Successfully processed the VES event. Hostname is updated.\")\nexecutor.addFieldsToOutput(logEventFields);\nexecutor.logger.info(executor.outFieldsList);\ntrue;\n\nfunction populateLogEventFields(eventId, pnfName, targetType, status, message) {\n var timestamp = longType(new Date().getTime());\n var logEventFields = java.util.HashMap();\n logEventFields.put(\"id\", eventId);\n\n var entityInfo = executor.subject.getOutFieldSchemaHelper(\"SimpleCL_LogEvent\", \"target\").createNewSubInstance(\"entityInfo\");\n entityInfo.put(\"pnf_DasH_name\", pnfName);\n var target = executor.subject.getOutFieldSchemaHelper(\"SimpleCL_LogEvent\", \"target\").createNewInstance();\n target.put(\"entityInfo\", entityInfo);\n target.put(\"targetType\", targetType)\n logEventFields.put(\"target\", target);\n\n var artifacts = executor.subject.getOutFieldSchemaHelper(\"SimpleCL_LogEvent\", \"component\").createNewSubInstance(\"artifacts\");\n artifacts.put(\"policyName\", \"onap.policies.apex.Simplecontrolloop\");\n artifacts.put(\"policyVersion\", \"1.0.0\");\n var component = executor.subject.getOutFieldSchemaHelper(\"SimpleCL_LogEvent\", \"component\").createNewInstance();\n component.put(\"artifacts\", artifacts);\n component.put(\"name\", \"Policy\")\n component.put(\"flavour\", \"Apex-PDP\")\n component.put(\"timestamp\", timestamp)\n component.put(\"status\", status)\n component.put(\"message\", message)\n logEventFields.put(\"component\", component);\n\n var otherFieldsEntry = executor.subject.getOutFieldSchemaHelper(\"SimpleCL_LogEvent\", \"otherFields\").createNewInstance();\n otherFieldsEntry.put(\"useCaseName\", \"simple-controlloop-usecase\");\n logEventFields.put(\"otherFields\", otherFieldsEntry);\n\n return logEventFields;\n}" + } + } + }, + { + "key": { + "name": "SimpleCL_HandleAAIFailureResponseTask", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_HandleAAIFailureResponseTask", + "version": "0.0.1" + }, + "inputEvent": { + "key": { + "name": "SimpleCL_AAIFailureResponseEvent", + "version": "0.0.1" + }, + "nameSpace": "org.onap.policy.apex.simplecontrolloop", + "source": "AAI", + "target": "APEX", + "parameter": { + "entry": [ + { + "key": "requestError", + "value": { + "key": "requestError", + "fieldSchemaKey": { + "name": "SimpleCL_AAIRequestErrorType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + } + }, + "outputEvents": { + "entry": [ + { + "key": "SimpleCL_LogEvent", + "value": { + "key": { + "name": "SimpleCL_LogEvent", + "version": "0.0.1" + }, + "nameSpace": "org.onap.policy.apex.simplecontrolloop", + "source": "APEX", + "target": "DCAE", + "parameter": { + "entry": [ + { + "key": "component", + "value": { + "key": "component", + "fieldSchemaKey": { + "name": "SimpleCL_LogEventComponentType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "id", + "value": { + "key": "id", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "otherFields", + "value": { + "key": "otherFields", + "fieldSchemaKey": { + "name": "SimpleCL_LogEventOtherFieldsType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "target", + "value": { + "key": "target", + "fieldSchemaKey": { + "name": "SimpleCL_LogEventTargetType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + } + } + } + ] + }, + "taskParameters": { + "entry": [] + }, + "contextAlbumReference": [ + { + "name": "SimpleCL_EventDetailsAlbum", + "version": "0.0.1" + } + ], + "taskLogic": { + "key": "TaskLogic", + "logicFlavour": "JAVASCRIPT", + "logic": "var uuidType = java.util.UUID;\nvar longType = java.lang.Long;\nvar HashMapType = java.util.HashMap;\n\nvar albumID = executor.getExecutionProperties().getProperty(\"albumId\");\nvar eventDetailsAlbum = executor.getContextAlbum(\"SimpleCL_EventDetailsAlbum\").get(albumID.toString());\n\nvar aaiErrorMessage = \"AAI operation failed. Error message from AAI - \" + executor.inFields.get(\"requestError\").get(\"serviceException\").get(\"text\");\n\nvar logEventFields = populateLogEventFields(eventDetailsAlbum.get(\"commonEventHeader\").get(\"eventId\"), eventDetailsAlbum.get(\"otherFields\").get(\"hashMap\").get(\"pnfName\"), \"PNF\", \"FINAL_FAILURE\", \"Failed to process VES event. Reason: \" + aaiErrorMessage)\nexecutor.addFieldsToOutput(logEventFields);\nexecutor.logger.info(executor.outFieldsList);\ntrue;\n\nfunction populateLogEventFields(eventId, pnfName, targetType, status, message) {\n var timestamp = longType(new Date().getTime());\n var logEventFields = java.util.HashMap();\n logEventFields.put(\"id\", eventId);\n\n var entityInfo = executor.subject.getOutFieldSchemaHelper(\"SimpleCL_LogEvent\", \"target\").createNewSubInstance(\"entityInfo\");\n entityInfo.put(\"pnf_DasH_name\", pnfName);\n var target = executor.subject.getOutFieldSchemaHelper(\"SimpleCL_LogEvent\", \"target\").createNewInstance();\n target.put(\"entityInfo\", entityInfo);\n target.put(\"targetType\", targetType)\n logEventFields.put(\"target\", target);\n\n var artifacts = executor.subject.getOutFieldSchemaHelper(\"SimpleCL_LogEvent\", \"component\").createNewSubInstance(\"artifacts\");\n artifacts.put(\"policyName\", \"onap.policies.apex.Simplecontrolloop\");\n artifacts.put(\"policyVersion\", \"1.0.0\");\n var component = executor.subject.getOutFieldSchemaHelper(\"SimpleCL_LogEvent\", \"component\").createNewInstance();\n component.put(\"artifacts\", artifacts);\n component.put(\"name\", \"Policy\")\n component.put(\"flavour\", \"Apex-PDP\")\n component.put(\"timestamp\", timestamp)\n component.put(\"status\", status)\n component.put(\"message\", message)\n logEventFields.put(\"component\", component);\n\n var otherFieldsEntry = executor.subject.getOutFieldSchemaHelper(\"SimpleCL_LogEvent\", \"otherFields\").createNewInstance();\n otherFieldsEntry.put(\"useCaseName\", \"simple-controlloop-usecase\");\n logEventFields.put(\"otherFields\", otherFieldsEntry);\n\n return logEventFields;\n}" + } + } + }, + { + "key": { + "name": "SimpleCL_HandleAAISuccessResponseTask", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_HandleAAISuccessResponseTask", + "version": "0.0.1" + }, + "inputEvent": { + "key": { + "name": "SimpleCL_AAISuccessResponseEvent", + "version": "0.0.1" + }, + "nameSpace": "org.onap.policy.apex.simplecontrolloop", + "source": "AAI", + "target": "APEX", + "parameter": { + "entry": [ + { + "key": "equip-model", + "value": { + "key": "equip-model", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "equip-type", + "value": { + "key": "equip-type", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "equip-vendor", + "value": { + "key": "equip-vendor", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "in-maint", + "value": { + "key": "in-maint", + "fieldSchemaKey": { + "name": "SimpleBooleanType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "ipaddress-v4-oam", + "value": { + "key": "ipaddress-v4-oam", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "ipaddress-v6-oam", + "value": { + "key": "ipaddress-v6-oam", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "management-option", + "value": { + "key": "management-option", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "pnf-id", + "value": { + "key": "pnf-id", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "pnf-name", + "value": { + "key": "pnf-name", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "pnf-name2", + "value": { + "key": "pnf-name2", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "resource-version", + "value": { + "key": "resource-version", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + } + }, + "outputEvents": { + "entry": [ + { + "key": "SimpleCL_CDSConfigModifyRequestEvent", + "value": { + "key": { + "name": "SimpleCL_CDSConfigModifyRequestEvent", + "version": "0.0.1" + }, + "nameSpace": "org.onap.policy.apex.simplecontrolloop", + "source": "APEX", + "target": "APEX", + "parameter": { + "entry": [ + { + "key": "actionIdentifiers", + "value": { + "key": "actionIdentifiers", + "fieldSchemaKey": { + "name": "SimpleCL_CDSActionIdentifiersType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "commonHeader", + "value": { + "key": "commonHeader", + "fieldSchemaKey": { + "name": "SimpleCL_CDSRequestCommonHeaderType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "payload", + "value": { + "key": "payload", + "fieldSchemaKey": { + "name": "SimpleCL_CDSConfigModifyRequestPayloadType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + } + } + }, + { + "key": "SimpleCL_LogEvent", + "value": { + "key": { + "name": "SimpleCL_LogEvent", + "version": "0.0.1" + }, + "nameSpace": "org.onap.policy.apex.simplecontrolloop", + "source": "APEX", + "target": "DCAE", + "parameter": { + "entry": [ + { + "key": "component", + "value": { + "key": "component", + "fieldSchemaKey": { + "name": "SimpleCL_LogEventComponentType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "id", + "value": { + "key": "id", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "otherFields", + "value": { + "key": "otherFields", + "fieldSchemaKey": { + "name": "SimpleCL_LogEventOtherFieldsType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "target", + "value": { + "key": "target", + "fieldSchemaKey": { + "name": "SimpleCL_LogEventTargetType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + } + } + } + ] + }, + "taskParameters": { + "entry": [] + }, + "contextAlbumReference": [ + { + "name": "SimpleCL_EventDetailsAlbum", + "version": "0.0.1" + } + ], + "taskLogic": { + "key": "TaskLogic", + "logicFlavour": "JAVASCRIPT", + "logic": "var uuidType = java.util.UUID;\nvar HashMapType = java.util.HashMap;\nvar longType = java.lang.Long;\n\nvar albumID = executor.getExecutionProperties().getProperty(\"albumId\");\nvar eventDetailsAlbum = executor.getContextAlbum(\"SimpleCL_EventDetailsAlbum\").get(albumID.toString());\nexecutor.logger.info(\"HandleAAISuccessResponseTask extracted context album - \" + albumID.toString() + \"::\" + eventDetailsAlbum);\n\nvar eventId = eventDetailsAlbum.get(\"commonEventHeader\").get(\"eventId\");\nvar otherFieldsMap = eventDetailsAlbum.get(\"otherFields\").get(\"hashMap\");\n\nvar targetEntityName = executor.inFields.get(\"pnf-name\")\nvar logMessage = \"\";\nvar existingHostname = executor.inFields.get(\"pnf-name2\");\nvar hostnameInVesEvent = otherFieldsMap.get(\"hostname\");\n\nvar albumSchemaHelper = executor.getContextAlbum(\"SimpleCL_EventDetailsAlbum\").getSchemaHelper();\nvar target = albumSchemaHelper.createNewSubInstance(\"target\");\ntarget.put(\"targetType\", \"PNF\")\nvar entityInfo = albumSchemaHelper.createNewSubInstance(\"entityInfo\");\nentityInfo.put(\"name\",targetEntityName);\ntarget.put(\"entityInfo\", entityInfo);\neventDetailsAlbum.put(\"target\", target);\n\nvar returnVal = true;\n\nif ((String(hostnameInVesEvent) != \"UNDEFINED\") && (String(existingHostname) != String(hostnameInVesEvent))) {\n logMessage = \"Hostname available in AAI does not match with the hostname received in the VES Event.\";\n returnVal = false\n var logEventFields = populateLogEventFields(eventId, otherFieldsMap.get(\"pnfName\"), \"PNF\", \"FINAL_FAILURE\", \"Failed to process VES event. Reason: \" + logMessage)\n executor.addFieldsToOutput(logEventFields);\n} else {\n logMessage = \"Received response from AAI successfully. Hostname in AAI matches with the one in Ves event. Going to make the update-config request to CDS.\";\n\n var cdsRequestEventFields = populateCdsRequestEventFields(albumID.toString(), eventId, executor.inFields.get(\"ipaddress-v4-oam\"), otherFieldsMap.get(\"pnfName\"));\n executor.addFieldsToOutput(cdsRequestEventFields);\n\n var logEventFields = populateLogEventFields(eventId, otherFieldsMap.get(\"pnfName\"), \"PNF\", \"SUCCESS\", logMessage);\n executor.addFieldsToOutput(logEventFields);\n}\nexecutor.logger.info(executor.outFieldsList);\nreturnVal;\n\nfunction populateCdsRequestEventFields(subRequestId, requestId, ipAddress, pnfName) {\n var commonHeader = executor.subject.getOutFieldSchemaHelper(\"commonHeader\").createNewInstance();\n commonHeader.put(\"subRequestId\", subRequestId);\n commonHeader.put(\"requestId\", requestId);\n commonHeader.put(\"originatorId\", \"POLICY\");\n\n var blueprintName = \"controlloop-hostname-update\";\n var blueprintVersion = \"1.0.4\";\n var newHostname = \"host\" + Math.random().toString(36).substring(7);\n eventDetailsAlbum.put(\"generatedHostname\", newHostname);\n\n var actionIdentifiers = executor.subject.getOutFieldSchemaHelper(\"actionIdentifiers\").createNewInstance();\n actionIdentifiers.put(\"mode\", \"sync\");\n actionIdentifiers.put(\"blueprintName\", blueprintName);\n actionIdentifiers.put(\"blueprintVersion\", blueprintVersion);\n actionIdentifiers.put(\"actionName\", \"update-config\");\n\n var payloadEntry = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewSubInstance(\"CDSConfigModifyRequestPayloadEntry\");\n payloadEntry.put(\"hostname\", newHostname)\n payloadEntry.put(\"IP\", ipAddress);\n payloadEntry.put(\"pnfName\", pnfName);\n\n var payload = executor.subject.getOutFieldSchemaHelper(\"payload\").createNewInstance();\n payload.put(\"update_DasH_config_DasH_request\", payloadEntry);\n\n var cdsRequestEventFields = java.util.HashMap();\n cdsRequestEventFields.put(\"commonHeader\", commonHeader);\n cdsRequestEventFields.put(\"actionIdentifiers\", actionIdentifiers);\n cdsRequestEventFields.put(\"payload\", payload);\n\n return cdsRequestEventFields;\n}\n\nfunction populateLogEventFields(eventId, pnfName, targetType, status, message) {\n var timestamp = longType(new Date().getTime());\n var logEventFields = java.util.HashMap();\n logEventFields.put(\"id\", eventId);\n\n var entityInfo = executor.subject.getOutFieldSchemaHelper(\"SimpleCL_LogEvent\", \"target\").createNewSubInstance(\"entityInfo\");\n entityInfo.put(\"pnf_DasH_name\", pnfName);\n var target = executor.subject.getOutFieldSchemaHelper(\"SimpleCL_LogEvent\", \"target\").createNewInstance();\n target.put(\"entityInfo\", entityInfo);\n target.put(\"targetType\", targetType)\n logEventFields.put(\"target\", target);\n\n var artifacts = executor.subject.getOutFieldSchemaHelper(\"SimpleCL_LogEvent\", \"component\").createNewSubInstance(\"artifacts\");\n artifacts.put(\"policyName\", \"onap.policies.apex.Simplecontrolloop\");\n artifacts.put(\"policyVersion\", \"1.0.0\");\n var component = executor.subject.getOutFieldSchemaHelper(\"SimpleCL_LogEvent\", \"component\").createNewInstance();\n component.put(\"artifacts\", artifacts);\n component.put(\"name\", \"Policy\")\n component.put(\"flavour\", \"Apex-PDP\")\n component.put(\"timestamp\", timestamp)\n component.put(\"status\", status)\n component.put(\"message\", message)\n logEventFields.put(\"component\", component);\n\n var otherFieldsEntry = executor.subject.getOutFieldSchemaHelper(\"SimpleCL_LogEvent\", \"otherFields\").createNewInstance();\n otherFieldsEntry.put(\"useCaseName\", \"simple-controlloop-usecase\");\n logEventFields.put(\"otherFields\", otherFieldsEntry);\n\n return logEventFields;\n}" + } + } + }, + { + "key": { + "name": "SimpleCL_HandleVesEventTask", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_HandleVesEventTask", + "version": "0.0.1" + }, + "inputEvent": { + "key": { + "name": "SimpleCL_VesEvent", + "version": "0.0.1" + }, + "nameSpace": "org.onap.policy.apex.simplecontrolloop", + "source": "DCAE", + "target": "APEX", + "parameter": { + "entry": [ + { + "key": "event", + "value": { + "key": "event", + "fieldSchemaKey": { + "name": "SimpleCL_VesEventType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + } + }, + "outputEvents": { + "entry": [ + { + "key": "SimpleCL_AAIRequestEvent", + "value": { + "key": { + "name": "SimpleCL_AAIRequestEvent", + "version": "0.0.1" + }, + "nameSpace": "org.onap.policy.apex.simplecontrolloop", + "source": "APEX", + "target": "AAI", + "parameter": { + "entry": [ + { + "key": "aaifield", + "value": { + "key": "aaifield", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + } + } + }, + { + "key": "SimpleCL_LogEvent", + "value": { + "key": { + "name": "SimpleCL_LogEvent", + "version": "0.0.1" + }, + "nameSpace": "org.onap.policy.apex.simplecontrolloop", + "source": "APEX", + "target": "DCAE", + "parameter": { + "entry": [ + { + "key": "component", + "value": { + "key": "component", + "fieldSchemaKey": { + "name": "SimpleCL_LogEventComponentType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "id", + "value": { + "key": "id", + "fieldSchemaKey": { + "name": "SimpleStringType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "otherFields", + "value": { + "key": "otherFields", + "fieldSchemaKey": { + "name": "SimpleCL_LogEventOtherFieldsType", + "version": "0.0.1" + }, + "optional": false + } + }, + { + "key": "target", + "value": { + "key": "target", + "fieldSchemaKey": { + "name": "SimpleCL_LogEventTargetType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + } + } + } + ] + }, + "taskParameters": { + "entry": [] + }, + "contextAlbumReference": [ + { + "name": "SimpleCL_EventDetailsAlbum", + "version": "0.0.1" + } + ], + "taskLogic": { + "key": "TaskLogic", + "logicFlavour": "JAVASCRIPT", + "logic": "var uuidType = java.util.UUID;\nvar HashMapType = java.util.HashMap;\nvar longType = java.lang.Long;\n\nvar eventDetailsAlbum = executor.getContextAlbum(\"SimpleCL_EventDetailsAlbum\").getSchemaHelper().createNewInstance();\nvar returnValue = true;\n\nvar event = executor.inFields.get(\"event\");\nexecutor.logger.info(\"HandleVesEventTask processing VES event - \" + event);\n\nvar commonEventHeader = event.get(\"commonEventHeader\");\nvar otherFields = event.get(\"otherFields\");\n// albumID will be used to fetch info from our album later. Storing event data in album by sourceId / AAI pnf-id, the same will be sent to CDS request payload as subRequestId\nvar albumID = commonEventHeader.get(\"sourceId\");\n// save the event processing start time in apex\ncommonEventHeader.put(\"startEpochMicrosec\", longType(new Date().getTime()));\n//save the incoming event details to album\neventDetailsAlbum.put(\"commonEventHeader\", commonEventHeader);\neventDetailsAlbum.put(\"otherFields\", otherFields);\nexecutor.getContextAlbum(\"SimpleCL_EventDetailsAlbum\").put(albumID.toString(), eventDetailsAlbum);\nexecutor.logger.info(\"HandleVesEventTask storing context album - \" + albumID.toString() + \"::\" + eventDetailsAlbum);\n\nexecutor.getExecutionProperties().setProperty(\"albumId\", albumID);\nexecutor.getExecutionProperties().setProperty(\"pnfName\", otherFields.get(\"hashMap\").get(\"pnfName\"));\n\nvar logEventFields = populateLogEventFields(eventDetailsAlbum.get(\"commonEventHeader\").get(\"eventId\"), otherFields.get(\"hashMap\").get(\"pnfName\"), \"PNF\", \"ACTIVE\", \"VES event has been received. Going to fetch details from AAI.\")\nexecutor.addFieldsToOutput(logEventFields);\n\nexecutor.logger.info(executor.outFieldsList);\nreturnValue;\n\nfunction populateLogEventFields(eventId, pnfName, targetType, status, message) {\n // populate logEventFields\n var timestamp = longType(new Date().getTime());\n var logEventFields = java.util.HashMap();\n logEventFields.put(\"id\", eventId);\n\n var entityInfo = executor.subject.getOutFieldSchemaHelper(\"SimpleCL_LogEvent\", \"target\").createNewSubInstance(\"entityInfo\");\n entityInfo.put(\"pnf_DasH_name\", pnfName);\n var target = executor.subject.getOutFieldSchemaHelper(\"SimpleCL_LogEvent\", \"target\").createNewInstance();\n target.put(\"entityInfo\", entityInfo);\n target.put(\"targetType\", targetType)\n logEventFields.put(\"target\", target);\n\n var artifacts = executor.subject.getOutFieldSchemaHelper(\"SimpleCL_LogEvent\", \"component\").createNewSubInstance(\"artifacts\");\n artifacts.put(\"policyName\", \"onap.policies.apex.Simplecontrolloop\");\n artifacts.put(\"policyVersion\", \"1.0.0\");\n var component = executor.subject.getOutFieldSchemaHelper(\"SimpleCL_LogEvent\", \"component\").createNewInstance();\n component.put(\"artifacts\", artifacts);\n component.put(\"name\", \"Policy\")\n component.put(\"flavour\", \"Apex-PDP\")\n component.put(\"timestamp\", timestamp)\n component.put(\"status\", status)\n component.put(\"message\", message)\n logEventFields.put(\"component\", component);\n\n var otherFieldsEntry = executor.subject.getOutFieldSchemaHelper(\"SimpleCL_LogEvent\", \"otherFields\").createNewInstance();\n otherFieldsEntry.put(\"useCaseName\", \"simple-controlloop-usecase\");\n logEventFields.put(\"otherFields\", otherFieldsEntry);\n\n return logEventFields;\n}" + } + } + } + ] + } + }, + "events": { + "key": { + "name": "onap.policies.apex.Simplecontrolloop_Events", + "version": "0.0.1" + }, + "eventMap": { + "entry": [ + { + "key": { + "name": "SimpleCL_AAIFailureResponseEvent", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_AAIFailureResponseEvent", + "version": "0.0.1" + }, + "nameSpace": "org.onap.policy.apex.simplecontrolloop", + "source": "AAI", + "target": "APEX", + "parameter": { + "entry": [ + { + "key": "requestError", + "value": { + "key": "requestError", + "fieldSchemaKey": { + "name": "SimpleCL_AAIRequestErrorType", + "version": "0.0.1" + }, + "optional": false + } + } + ] + } + } + }, + { + "key": { + "name": "SimpleCL_AAIRequestEvent", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_AAIRequestEvent", + "version": "0.0.1" + }, + "nameSpace": "org.onap.policy.apex.simplecontrolloop", + "source": "APEX", + "target": "AAI", + "parameter": { + "entry": [ + { + "key": "aaifield", "value": { - "key": "payload", + "key": "aaifield", "fieldSchemaKey": { - "name": "CDSDeleteSubscriptionPayloadType", + "name": "SimpleStringType", "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", + "name": "SimpleCL_AAISuccessResponseEvent", "version": "0.0.1" }, "value": { "key": { - "name": "DeleteSubscriptionRequestTask", + "name": "SimpleCL_AAISuccessResponseEvent", "version": "0.0.1" }, - "inputFields": { + "nameSpace": "org.onap.policy.apex.simplecontrolloop", + "source": "AAI", + "target": "APEX", + "parameter": { "entry": [ { - "key": "albumID", + "key": "equip-model", "value": { - "key": "albumID", + "key": "equip-model", "fieldSchemaKey": { - "name": "UUIDType", + "name": "SimpleStringType", "version": "0.0.1" }, "optional": false } }, { - "key": "payload", + "key": "equip-type", "value": { - "key": "payload", + "key": "equip-type", "fieldSchemaKey": { - "name": "CDSDeleteSubscriptionPayloadType", + "name": "SimpleStringType", "version": "0.0.1" }, "optional": false } - } - ] - }, - "outputFields": { - "entry": [ + }, { - "key": "actionIdentifiers", + "key": "equip-vendor", "value": { - "key": "actionIdentifiers", + "key": "equip-vendor", "fieldSchemaKey": { - "name": "CDSActionIdentifiersType", + "name": "SimpleStringType", "version": "0.0.1" }, "optional": false } }, { - "key": "commonHeader", + "key": "in-maint", "value": { - "key": "commonHeader", + "key": "in-maint", "fieldSchemaKey": { - "name": "CDSRequestCommonHeaderType", + "name": "SimpleBooleanType", "version": "0.0.1" }, "optional": false } }, { - "key": "payload", + "key": "ipaddress-v4-oam", "value": { - "key": "payload", + "key": "ipaddress-v4-oam", "fieldSchemaKey": { - "name": "CDSDeleteSubscriptionPayloadType", + "name": "SimpleStringType", "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", + "key": "ipaddress-v6-oam", "value": { - "key": "changeType", + "key": "ipaddress-v6-oam", "fieldSchemaKey": { "name": "SimpleStringType", "version": "0.0.1" @@ -1650,9 +5465,9 @@ } }, { - "key": "closedLoopControlName", + "key": "management-option", "value": { - "key": "closedLoopControlName", + "key": "management-option", "fieldSchemaKey": { "name": "SimpleStringType", "version": "0.0.1" @@ -1661,9 +5476,9 @@ } }, { - "key": "nfName", + "key": "pnf-id", "value": { - "key": "nfName", + "key": "pnf-id", "fieldSchemaKey": { "name": "SimpleStringType", "version": "0.0.1" @@ -1672,9 +5487,9 @@ } }, { - "key": "policyName", + "key": "pnf-name", "value": { - "key": "policyName", + "key": "pnf-name", "fieldSchemaKey": { "name": "SimpleStringType", "version": "0.0.1" @@ -1683,70 +5498,42 @@ } }, { - "key": "subscription", + "key": "pnf-name2", "value": { - "key": "subscription", + "key": "pnf-name2", "fieldSchemaKey": { - "name": "SubscriptionType", + "name": "SimpleStringType", "version": "0.0.1" }, "optional": false } - } - ] - }, - "outputFields": { - "entry": [ + }, { - "key": "albumID", + "key": "resource-version", "value": { - "key": "albumID", + "key": "resource-version", "fieldSchemaKey": { - "name": "UUIDType", + "name": "SimpleStringType", "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;\n\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 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}\nreturnValue;" } } - } - ] - } - }, - "events": { - "key": { - "name": "APEXgRPCPolicy_Events", - "version": "0.0.1" - }, - "eventMap": { - "entry": [ + }, { "key": { - "name": "CDSResponseEvent", + "name": "SimpleCL_CDSConfigModifyFailureResponseEvent", "version": "0.0.1" }, "value": { "key": { - "name": "CDSResponseEvent", + "name": "SimpleCL_CDSConfigModifyFailureResponseEvent", "version": "0.0.1" }, - "nameSpace": "org.onap.policy.apex.onap.pmcontrol", + "nameSpace": "org.onap.policy.apex.simplecontrolloop", "source": "CDS", "target": "APEX", "parameter": { @@ -1756,7 +5543,7 @@ "value": { "key": "actionIdentifiers", "fieldSchemaKey": { - "name": "CDSActionIdentifiersType", + "name": "SimpleCL_CDSActionIdentifiersType", "version": "0.0.1" }, "optional": false @@ -1767,7 +5554,7 @@ "value": { "key": "commonHeader", "fieldSchemaKey": { - "name": "CDSResponseCommonHeaderType", + "name": "SimpleCL_CDSFailureResponseCommonHeaderType", "version": "0.0.1" }, "optional": false @@ -1778,7 +5565,7 @@ "value": { "key": "payload", "fieldSchemaKey": { - "name": "CDSResponsePayloadType", + "name": "SimpleCL_CDSConfigModifyRequestPayloadType", "version": "0.0.1" }, "optional": false @@ -1789,7 +5576,7 @@ "value": { "key": "status", "fieldSchemaKey": { - "name": "CDSResponseStatusType", + "name": "SimpleCL_CDSFailureResponseStatusType", "version": "0.0.1" }, "optional": false @@ -1801,55 +5588,36 @@ }, { "key": { - "name": "CDSResponseStatusEvent", + "name": "SimpleCL_CDSConfigModifyRequestEvent", "version": "0.0.1" }, "value": { "key": { - "name": "CDSResponseStatusEvent", + "name": "SimpleCL_CDSConfigModifyRequestEvent", "version": "0.0.1" }, - "nameSpace": "org.onap.policy.apex.onap.pmcontrol", + "nameSpace": "org.onap.policy.apex.simplecontrolloop", "source": "APEX", - "target": "DCAE", + "target": "APEX", "parameter": { "entry": [ { - "key": "status", + "key": "actionIdentifiers", "value": { - "key": "status", + "key": "actionIdentifiers", "fieldSchemaKey": { - "name": "SubscriptionStatusType", + "name": "SimpleCL_CDSActionIdentifiersType", "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", + "key": "commonHeader", "value": { - "key": "albumID", + "key": "commonHeader", "fieldSchemaKey": { - "name": "UUIDType", + "name": "SimpleCL_CDSRequestCommonHeaderType", "version": "0.0.1" }, "optional": false @@ -1860,7 +5628,7 @@ "value": { "key": "payload", "fieldSchemaKey": { - "name": "CDSCreateSubscriptionPayloadType", + "name": "SimpleCL_CDSConfigModifyRequestPayloadType", "version": "0.0.1" }, "optional": false @@ -1872,16 +5640,16 @@ }, { "key": { - "name": "CreateSubscriptionRequestEvent", + "name": "SimpleCL_CDSConfigModifySuccessResponseEvent", "version": "0.0.1" }, "value": { "key": { - "name": "CreateSubscriptionRequestEvent", + "name": "SimpleCL_CDSConfigModifySuccessResponseEvent", "version": "0.0.1" }, - "nameSpace": "org.onap.policy.apex.onap.pmcontrol", - "source": "APEX", + "nameSpace": "org.onap.policy.apex.simplecontrolloop", + "source": "CDS", "target": "APEX", "parameter": { "entry": [ @@ -1890,7 +5658,7 @@ "value": { "key": "actionIdentifiers", "fieldSchemaKey": { - "name": "CDSActionIdentifiersType", + "name": "SimpleCL_CDSActionIdentifiersType", "version": "0.0.1" }, "optional": false @@ -1901,7 +5669,7 @@ "value": { "key": "commonHeader", "fieldSchemaKey": { - "name": "CDSRequestCommonHeaderType", + "name": "SimpleCL_CDSSuccessResponseCommonHeaderType", "version": "0.0.1" }, "optional": false @@ -1912,48 +5680,18 @@ "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", + "name": "SimpleCL_CDSConfigModifyResponsePayloadType", "version": "0.0.1" }, "optional": false } }, { - "key": "payload", + "key": "status", "value": { - "key": "payload", + "key": "status", "fieldSchemaKey": { - "name": "CDSDeleteSubscriptionPayloadType", + "name": "SimpleCL_CDSSuccessResponseStatusType", "version": "0.0.1" }, "optional": false @@ -1965,77 +5703,58 @@ }, { "key": { - "name": "DeleteSubscriptionRequestEvent", + "name": "SimpleCL_LogEvent", "version": "0.0.1" }, "value": { "key": { - "name": "DeleteSubscriptionRequestEvent", + "name": "SimpleCL_LogEvent", "version": "0.0.1" }, - "nameSpace": "org.onap.policy.apex.onap.pmcontrol", + "nameSpace": "org.onap.policy.apex.simplecontrolloop", "source": "APEX", - "target": "APEX", + "target": "DCAE", "parameter": { "entry": [ { - "key": "actionIdentifiers", + "key": "component", "value": { - "key": "actionIdentifiers", + "key": "component", "fieldSchemaKey": { - "name": "CDSActionIdentifiersType", + "name": "SimpleCL_LogEventComponentType", "version": "0.0.1" }, "optional": false } }, { - "key": "commonHeader", + "key": "id", "value": { - "key": "commonHeader", + "key": "id", "fieldSchemaKey": { - "name": "CDSRequestCommonHeaderType", + "name": "SimpleStringType", "version": "0.0.1" }, "optional": false } }, { - "key": "payload", + "key": "otherFields", "value": { - "key": "payload", + "key": "otherFields", "fieldSchemaKey": { - "name": "CDSDeleteSubscriptionPayloadType", + "name": "SimpleCL_LogEventOtherFieldsType", "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", + "key": "target", "value": { - "key": "albumID", + "key": "target", "fieldSchemaKey": { - "name": "UUIDType", + "name": "SimpleCL_LogEventTargetType", "version": "0.0.1" }, "optional": false @@ -2047,69 +5766,25 @@ }, { "key": { - "name": "testPolicyB", + "name": "SimpleCL_VesEvent", "version": "0.0.1" }, "value": { "key": { - "name": "testPolicyB", + "name": "SimpleCL_VesEvent", "version": "0.0.1" }, - "nameSpace": "org.onap.policy.apex.onap.pmcontrol", + "nameSpace": "org.onap.policy.apex.simplecontrolloop", "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", + "key": "event", "value": { - "key": "subscription", + "key": "event", "fieldSchemaKey": { - "name": "SubscriptionType", + "name": "SimpleCL_VesEventType", "version": "0.0.1" }, "optional": false @@ -2124,25 +5799,25 @@ }, "albums": { "key": { - "name": "APEXgRPCPolicy_Albums", + "name": "onap.policies.apex.Simplecontrolloop_Albums", "version": "0.0.1" }, "albums": { "entry": [ { "key": { - "name": "PMSubscriptionAlbum", + "name": "SimpleCL_EventDetailsAlbum", "version": "0.0.1" }, "value": { "key": { - "name": "PMSubscriptionAlbum", + "name": "SimpleCL_EventDetailsAlbum", "version": "0.0.1" }, "scope": "policy", "isWritable": true, "itemSchema": { - "name": "PMSubscriptionType", + "name": "SimpleCL_EventDetailsAlbumType", "version": "0.0.1" } } @@ -2152,191 +5827,247 @@ }, "schemas": { "key": { - "name": "APEXgRPCPolicy_Schemas", + "name": "onap.policies.apex.Simplecontrolloop_Schemas", "version": "0.0.1" }, "schemas": { "entry": [ { "key": { - "name": "CDSActionIdentifiersType", + "name": "SimpleBooleanType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleBooleanType", + "version": "0.0.1" + }, + "schemaFlavour": "Java", + "schemaDefinition": "java.lang.Boolean" + } + }, + { + "key": { + "name": "SimpleCL_AAIRequestErrorType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_AAIRequestErrorType", + "version": "0.0.1" + }, + "schemaFlavour": "Avro", + "schemaDefinition": "{\n \"name\": \"AAIRequestErrorType\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"serviceException\",\n \"type\": {\n \"name\": \"serviceException\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"messageId\",\n \"type\": \"string\"\n },\n {\n \"name\": \"text\",\n \"type\": \"string\"\n },\n {\n \"name\": \"variables\",\n \"type\": {\n \"type\": \"array\",\n \"items\": \"string\"\n }\n }\n ]\n }\n }\n ]\n}" + } + }, + { + "key": { + "name": "SimpleCL_CDSActionIdentifiersType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_CDSActionIdentifiersType", + "version": "0.0.1" + }, + "schemaFlavour": "Avro", + "schemaDefinition": "{\n \"type\": \"record\",\n \"name\": \"CDSActionIdentifiers_Type\",\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": "SimpleCL_CDSConfigModifyRequestPayloadType", + "version": "0.0.1" + }, + "value": { + "key": { + "name": "SimpleCL_CDSConfigModifyRequestPayloadType", + "version": "0.0.1" + }, + "schemaFlavour": "Avro", + "schemaDefinition": "{\n \"type\": \"map\",\n \"values\": {\n \"type\": \"record\",\n \"name\": \"CDSConfigModifyRequestPayloadEntry\",\n \"fields\": [\n {\n \"name\": \"hostname\",\n \"type\": \"string\"\n },\n {\n \"name\": \"IP\",\n \"type\": \"string\"\n },\n {\n \"name\": \"pnfName\",\n \"type\": \"string\"\n }\n ]\n }\n}" + } + }, + { + "key": { + "name": "SimpleCL_CDSConfigModifyResponsePayloadType", "version": "0.0.1" }, "value": { "key": { - "name": "CDSActionIdentifiersType", + "name": "SimpleCL_CDSConfigModifyResponsePayloadType", "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}" + "schemaDefinition": "{\n \"name\": \"CDSConfigResponsePayloadEntry\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"update_DasH_config_DasH_response\",\n \"type\": {\n \"name\": \"update_DasH_config_DasH_response\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"execute_DasH_command_DasH_logs\",\n \"type\": {\n \"type\": \"array\",\n \"items\": \"string\"\n }\n },\n {\n \"name\": \"prepare_DasH_environment_DasH_logs\",\n \"type\": {\n \"type\": \"array\",\n \"items\": \"string\"\n }\n }\n ]\n }\n }\n ]\n}" } }, { "key": { - "name": "CDSCreateSubscriptionPayloadType", + "name": "SimpleCL_CDSFailureResponseCommonHeaderType", "version": "0.0.1" }, "value": { "key": { - "name": "CDSCreateSubscriptionPayloadType", + "name": "SimpleCL_CDSFailureResponseCommonHeaderType", "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}" + "schemaDefinition": "{\n \"type\": \"record\",\n \"name\": \"CDSResponseCommonHeader_Type\",\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": "CDSDeleteSubscriptionPayloadType", + "name": "SimpleCL_CDSFailureResponseStatusType", "version": "0.0.1" }, "value": { "key": { - "name": "CDSDeleteSubscriptionPayloadType", + "name": "SimpleCL_CDSFailureResponseStatusType", "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}" + "schemaDefinition": "{\n \"type\": \"record\",\n \"name\": \"CDSResponseStatus_Type\",\n \"fields\": [\n {\n \"name\": \"code\",\n \"type\": \"int\"\n },\n {\n \"name\": \"timestamp\",\n \"type\": \"string\"\n },\n {\n \"name\": \"message\",\n \"type\": \"string\"\n },\n {\n \"name\": \"errorMessage\",\n \"type\": \"string\"\n }\n ]\n}" } }, { "key": { - "name": "CDSRequestCommonHeaderType", + "name": "SimpleCL_CDSRequestCommonHeaderType", "version": "0.0.1" }, "value": { "key": { - "name": "CDSRequestCommonHeaderType", + "name": "SimpleCL_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}" + "schemaDefinition": "{\n \"type\": \"record\",\n \"name\": \"CDSRequestCommonHeader_Type\",\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", + "name": "SimpleCL_CDSSuccessResponseCommonHeaderType", "version": "0.0.1" }, "value": { "key": { - "name": "CDSResponseCommonHeaderType", + "name": "SimpleCL_CDSSuccessResponseCommonHeaderType", "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}" + "schemaDefinition": "{\n \"type\": \"record\",\n \"name\": \"CDSResponseCommonHeader_Type\",\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", + "name": "SimpleCL_CDSSuccessResponseStatusType", "version": "0.0.1" }, "value": { "key": { - "name": "CDSResponsePayloadType", + "name": "SimpleCL_CDSSuccessResponseStatusType", "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}" + "schemaDefinition": "{\n \"type\": \"record\",\n \"name\": \"CDSResponseStatus_Type\",\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": "CDSResponseStatusType", + "name": "SimpleCL_EventDetailsAlbumType", "version": "0.0.1" }, "value": { "key": { - "name": "CDSResponseStatusType", + "name": "SimpleCL_EventDetailsAlbumType", "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}" + "schemaDefinition": "{\n \"name\": \"eventDetails\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"commonEventHeader\",\n \"type\": {\n \"name\": \"commonEventHeader\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"domain\",\n \"type\": \"string\"\n },\n {\n \"name\": \"eventId\",\n \"type\": \"string\"\n },\n {\n \"name\": \"eventName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"lastEpochMicrosec\",\n \"type\": \"long\"\n },\n {\n \"name\": \"priority\",\n \"type\": \"string\"\n },\n {\n \"name\": \"reportingEntityName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"sequence\",\n \"type\": \"int\"\n },\n {\n \"name\": \"sourceId\",\n \"type\": \"string\"\n },\n {\n \"name\": \"sourceName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"startEpochMicrosec\",\n \"type\": \"long\"\n },\n {\n \"name\": \"timeZoneOffset\",\n \"type\": \"string\"\n },\n {\n \"name\": \"version\",\n \"type\": \"string\"\n },\n {\n \"name\": \"internalHeaderFields\",\n \"type\": {\n \"name\": \"internalHeaderFields\",\n \"type\": \"record\",\n \"fields\": []\n }\n },\n {\n \"name\": \"vesEventListenerVersion\",\n \"type\": \"string\"\n }\n ]\n }\n },\n {\n \"name\": \"otherFields\",\n \"type\": {\n \"name\": \"otherFields\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"hashMap\",\n \"type\": {\n \"name\": \"hashMap\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"hostname\",\n \"type\": \"string\"\n },\n {\n \"name\": \"pnfName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"pnfId\",\n \"type\": \"string\"\n },\n {\n \"name\": \"ip\",\n \"type\": \"string\"\n }\n ]\n }\n },\n {\n \"name\": \"otherFieldsVersion\",\n \"type\": \"string\"\n }\n ]\n }\n },\n {\n \"name\": \"target\",\n \"type\": {\n \"name\": \"target\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"targetType\",\n \"type\": \"string\"\n },\n {\n \"name\": \"entityInfo\",\n \"type\": {\n \"name\": \"entityInfo\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"name\",\n \"type\": \"string\"\n }\n ]\n }\n }\n ]\n }\n },\n {\n \"name\": \"generatedHostname\",\n \"type\": \"string\"\n }\n ]\n}" } }, { "key": { - "name": "PMSubscriptionType", + "name": "SimpleCL_LogEventComponentType", "version": "0.0.1" }, "value": { "key": { - "name": "PMSubscriptionType", + "name": "SimpleCL_LogEventComponentType", "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}" + "schemaDefinition": "{\n \"name\": \"component\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"name\",\n \"type\": \"string\"\n },\n {\n \"name\": \"flavour\",\n \"type\": \"string\"\n },\n {\n \"name\": \"timestamp\",\n \"type\": \"long\"\n },\n {\n \"name\": \"status\",\n \"type\": \"string\"\n },\n {\n \"name\": \"message\",\n \"type\": \"string\"\n },\n {\n \"name\": \"artifacts\",\n \"type\": {\n \"name\": \"artifacts\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"policyName\",\n \"type\": \"string\"\n },\n {\n \"name\": \"policyVersion\",\n \"type\": \"string\"\n }\n ]\n }\n }\n ]\n }" } }, { "key": { - "name": "SimpleIntType", + "name": "SimpleCL_LogEventOtherFieldsType", "version": "0.0.1" }, "value": { "key": { - "name": "SimpleIntType", + "name": "SimpleCL_LogEventOtherFieldsType", "version": "0.0.1" }, - "schemaFlavour": "Java", - "schemaDefinition": "java.lang.Integer" + "schemaFlavour": "Avro", + "schemaDefinition": "{\n \"name\": \"otherFields\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"useCaseName\",\n \"type\": \"string\"\n }\n ]\n }" } }, { "key": { - "name": "SimpleStringType", + "name": "SimpleCL_LogEventTargetType", "version": "0.0.1" }, "value": { "key": { - "name": "SimpleStringType", + "name": "SimpleCL_LogEventTargetType", "version": "0.0.1" }, - "schemaFlavour": "Java", - "schemaDefinition": "java.lang.String" + "schemaFlavour": "Avro", + "schemaDefinition": "{\n \"name\": \"target\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"targetType\",\n \"type\": \"string\"\n },\n {\n \"name\": \"entityInfo\",\n \"type\": {\n \"name\": \"entityInfo\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"pnf_DasH_name\",\n \"type\": \"string\"\n }\n ]\n }\n }\n ]\n }" } }, { "key": { - "name": "SubscriptionStatusType", + "name": "SimpleCL_VesEventType", "version": "0.0.1" }, "value": { "key": { - "name": "SubscriptionStatusType", + "name": "SimpleCL_VesEventType", "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}" + "schemaDefinition": "{\n \"name\":\"event\",\n \"type\":\"record\",\n \"fields\":[\n {\n \"name\":\"commonEventHeader\",\n \"type\":{\n \"name\":\"commonEventHeader\",\n \"type\":\"record\",\n \"fields\":[\n {\n \"name\":\"domain\",\n \"type\":\"string\"\n },\n {\n \"name\":\"eventId\",\n \"type\":\"string\"\n },\n {\n \"name\":\"eventName\",\n \"type\":\"string\"\n },\n {\n \"name\":\"lastEpochMicrosec\",\n \"type\":\"long\"\n },\n {\n \"name\":\"priority\",\n \"type\":\"string\"\n },\n {\n \"name\":\"reportingEntityName\",\n \"type\":\"string\"\n },\n {\n \"name\":\"sequence\",\n \"type\":\"int\"\n },\n {\n \"name\":\"sourceId\",\n \"type\":\"string\"\n },\n {\n \"name\":\"sourceName\",\n \"type\":\"string\"\n },\n {\n \"name\":\"startEpochMicrosec\",\n \"type\":\"long\"\n },\n {\n \"name\":\"version\",\n \"type\":\"string\"\n },\n {\n \"name\":\"internalHeaderFields\",\n \"type\":{\n \"name\":\"internalHeaderFields\",\n \"type\":\"record\",\n \"fields\":[\n\n ]\n }\n },\n {\n \"name\":\"vesEventListenerVersion\",\n \"type\":\"string\"\n }\n ]\n }\n },\n {\n \"name\":\"otherFields\",\n \"type\":{\n \"name\":\"otherFields\",\n \"type\":\"record\",\n \"fields\":[\n {\n \"name\":\"hashMap\",\n \"type\":{\n \"name\":\"hashMap\",\n \"type\":\"record\",\n \"fields\":[\n {\n \"name\":\"hostname\",\n \"type\":\"string\"\n },\n {\n \"name\":\"pnfName\",\n \"type\":\"string\"\n },\n {\n \"name\":\"pnfId\",\n \"type\":\"string\"\n },\n {\n \"name\":\"ip\",\n \"type\":\"string\"\n }\n ]\n }\n },\n {\n \"name\":\"otherFieldsVersion\",\n \"type\":\"string\"\n }\n ]\n }\n }\n ]\n}" } }, { "key": { - "name": "SubscriptionType", + "name": "SimpleLongType", "version": "0.0.1" }, "value": { "key": { - "name": "SubscriptionType", + "name": "SimpleLongType", "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}" + "schemaFlavour": "Java", + "schemaDefinition": "java.lang.Long" } }, { "key": { - "name": "UUIDType", + "name": "SimpleStringType", "version": "0.0.1" }, "value": { "key": { - "name": "UUIDType", + "name": "SimpleStringType", "version": "0.0.1" }, "schemaFlavour": "Java", - "schemaDefinition": "java.util.UUID" + "schemaDefinition": "java.lang.String" } } ] @@ -2345,117 +6076,61 @@ } } }, - "eventOutputParameters": { - "logOutputter": { - "carrierTechnologyParameters": { - "carrierTechnology": "FILE", - "parameters": { - "fileName": "outputevents.log" - } - }, - "eventProtocolParameters": { - "eventProtocol": "JSON" - } - }, - "CDSRequestProducer": { - "carrierTechnologyParameters": { - "carrierTechnology": "GRPC", - "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.grpc.GrpcCarrierTechnologyParameters", - "parameters": { - "host": "10.2.0.122", - "port": 54322, - "username": "ccsdkapps", - "password": "ccsdkapps", - "timeout": 60 - } - }, - "eventProtocolParameters": { - "eventProtocol": "JSON" - }, - "eventNameFilter": "(Create|Delete)SubscriptionRequestEvent", - "requestorMode": true, - "requestorPeer": "CDSRequestConsumer", - "requestorTimeout": 500 - }, - "CDSReplyProducer": { + "eventInputParameters": { + "SimpleCL_DCAEConsumer": { "carrierTechnologyParameters": { - "carrierTechnology": "RESTCLIENT", - "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.restclient.RestClientCarrierTechnologyParameters", + "carrierTechnology": "KAFKA", + "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.kafka.KafkaCarrierTechnologyParameters", "parameters": { - "url": "http://message-router:3904/events/POLICY-CL-MGT" + "bootstrapServers": "kafka:9092", + "groupId": "apex-group", + "enableAutoCommit": true, + "autoCommitTime": 1000, + "sessionTimeout": 30000, + "consumerPollTime": 100, + "consumerTopicList": ["unauthenticated.dcae_cl_output"], + "keyDeserializer": "org.apache.kafka.common.serialization.StringDeserializer", + "valueDeserializer": "org.apache.kafka.common.serialization.StringDeserializer" } }, "eventProtocolParameters": { "eventProtocol": "JSON" }, - "eventNameFilter": "CDSResponseStatusEvent" + "eventName": "SimpleCL_VesEvent" } }, - "eventInputParameters": { - "DCAEConsumer": { + "eventOutputParameters": { + "SimpleCL_LogEventProducer": { "carrierTechnologyParameters": { - "carrierTechnology": "RESTCLIENT", - "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.restclient.RestClientCarrierTechnologyParameters", - "parameters": { - "url": "http://message-router:3904/events/unauthenticated.DCAE_CL_OUTPUT/cg1/c1?timeout=30000" - } - }, - "eventProtocolParameters": { - "eventProtocol": "JSON", + "carrierTechnology": "KAFKA", + "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.kafka.KafkaCarrierTechnologyParameters", "parameters": { - "nameAlias": "testPolicyB" + "bootstrapServers": "kafka:9092", + "acks": "all", + "retries": 0, + "batchSize": 16384, + "lingerTime": 1, + "bufferMemory": 33554432, + "producerTopic": "apex-cl-mgt", + "keySerializer": "org.apache.kafka.common.serialization.StringSerializer", + "valueSerializer": "org.apache.kafka.common.serialization.StringSerializer" } }, - "eventName": "testPolicyB", - "eventNameFilter": "testPolicyB" - }, - "CDSRequestConsumer": { - "carrierTechnologyParameters": { - "carrierTechnology": "GRPC", - "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.grpc.GrpcCarrierTechnologyParameters" - }, "eventProtocolParameters": { "eventProtocol": "JSON" - }, - "eventName": "CDSResponseEvent", - "eventNameFilter": "CDSResponseEvent", - "requestorMode": true, - "requestorPeer": "CDSRequestProducer", - "requestorTimeout": 500 + } } } - }, - "name": "operational.apex.stabilityTestDefaultDomain", - "version": "1.0.0", - "metadata": { - "policy-id": "operational.apex.stabilityTestDefaultDomain", - "policy-version": "1.0.0" } } } ] - }, - "name": "ToscaServiceTemplateSimple", - "version": "1.0.0", - "metadata": {} + } } = - ${HOSTNAME} - ${API_PORT} - https - - /policy/api/v1/policies - POST - true - false - true - false - - - @@ -2469,7 +6144,15 @@ - + + 6 + ${HOSTNAME} + ${PAP_PORT} + http + /policy/pap/v1/pdps/deployments/batch + true + POST + true true @@ -2485,7 +6168,10 @@ "action": "POST", "policies": [ { - "name": "operational.apex.stabilityTestDefaultDomain", + "name": "onap.policies.apex.Simplecontrolloop", + "version": "1.0.0" + }, { + "name": "onap.policies.apex.Example", "version": "1.0.0" } ] @@ -2498,19 +6184,6 @@ - ${HOSTNAME} - ${PAP_PORT} - https - - /policy/pap/v1/pdps/deployments/batch - POST - true - false - true - false - - - @@ -2524,231 +6197,617 @@ + + ${wait} + + - + + ${threads} + 1 + 259200 + true + true continue - - false + -1 + false - ${threads} - 1 - true - 259200 - - true - - - + 6 ${HOSTNAME} ${APEX_PORT} - https - + http /policy/apex-pdp/v1/healthcheck + true GET + true + false + + + + + + + + 200 + + + Assertion.response_code + false + 8 + + + + + 6 + ${HOSTNAME} + ${APEX_PORT} + http + /metrics true - false + GET true - false - - - + false + + + - + + + 200 + + + Assertion.response_code + false + 8 + Response code + Assert response coming back from apex-pdp + + + + + + + true + + + import org.apache.kafka.clients.producer.Callback +import org.apache.kafka.clients.producer.RecordMetadata +import org.apache.kafka.clients.producer.KafkaProducer +import org.apache.kafka.clients.producer.ProducerRecord +import org.apache.kafka.clients.producer.ProducerConfig +import org.apache.kafka.common.serialization.StringSerializer + +def props = new Properties() +props.put("bootstrap.servers", "kafka:9092") +props.put("group.id", "new-group") +props.put("acks", "all") +props.put("retries", 0) +props.put("batch.size", 16384) +props.put("linger.ms", 1) +props.put("buffer.memory", 33554432) +props.put("key.serializer", StringSerializer.class.getName()) +props.put("value.serializer", StringSerializer.class.getName()) + +def producer = new KafkaProducer<>(props) + +def jsonString = '''{ + "event": { + "commonEventHeader": { + "startEpochMicrosec": 1597953057126, + "sourceId": "927b2580-36d9-4f13-8421-3c9d43b7a57${__threadNum}", + "eventId": "8c7935a4-79d8-4ec0-b661-dcca3cd6800${__threadNum}", + "lastEpochMicrosec": 1597952499468, + "eventName": "Report hostname & IP", + "sourceName": "PNF101", + "reportingEntityName": "DCAE", + "vesEventListenerVersion": "7.1", + "internalHeaderFields": {}, + "version": "4.0.1", + "priority": "Normal", + "sequence": 1, + "domain": "other" + }, + "otherFields": { + "hashMap": { + "hostname": "UNDEFINED", + "pnfId": "927b2580-36d9-4f13-8421-3c9d43b7a57e", + "pnfName": "PNF101", + "ip": "10.101.200.10" + }, + "otherFieldsVersion": "3.0" + } + } +}''' + +def record = new ProducerRecord<>("unauthenticated.dcae_cl_output", jsonString) + +producer.send(record, new Callback() { + @Override + void onCompletion(RecordMetadata metadata, Exception exception) { + if (exception != null) { + exception.printStackTrace() + } else { + println("Sent message to topic ${metadata.topic()} partition ${metadata.partition()} with offset ${metadata.offset()}") + } + } +}) + +producer.close() + + groovy + + + + groovy + + true + import org.apache.kafka.clients.consumer.ConsumerConfig +import org.apache.kafka.clients.consumer.KafkaConsumer +import org.apache.kafka.clients.consumer.ConsumerRecords +import org.apache.kafka.clients.consumer.ConsumerRecord +import org.apache.kafka.common.serialization.StringDeserializer +import groovy.json.JsonSlurper + +// Consumer properties +def props = new Properties() +props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "kafka:9092") // Adjust to your Kafka bootstrap server +props.put(ConsumerConfig.GROUP_ID_CONFIG, "apex-group") +props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName()) +props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName()) +props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest") + +// Create the Kafka consumer +def consumer = new KafkaConsumer<>(props) + +// Subscribe to the topic +consumer.subscribe(["apex-cl-mgt"]) + +// Poll for messages and assert the value +def found = false +def timeout = 10000 // timeout in milliseconds +def startTime = System.currentTimeMillis() + +while (!found && (System.currentTimeMillis() - startTime) < timeout) { + println("Inside while loop") + ConsumerRecords<String, String> records = consumer.poll(1000) + for (ConsumerRecord<String, String> record : records) { + println("Received message: Key=${record.key()}, Value=${record.value()}, Partition=${record.partition()}, Offset=${record.offset()}") + + // Parse the JSON value + def jsonSlurper = new JsonSlurper() + def message = jsonSlurper.parseText(record.value()) + + // Perform assertion on specific fields in the JSON + if ((message?.source == "APEX") || (message?.component?.status == "ACTIVE")) { + found = true + println("Assertion passed: source is 'APEX' or status is 'ACTIVE'") + break + } + } +} + +// Close the consumer +consumer.close() + + + + + + + + groovy + + true + import org.apache.kafka.clients.producer.Callback +import org.apache.kafka.clients.producer.RecordMetadata +import org.apache.kafka.clients.producer.KafkaProducer +import org.apache.kafka.clients.producer.ProducerRecord +import org.apache.kafka.clients.producer.ProducerConfig +import org.apache.kafka.common.serialization.StringSerializer + +def props = new Properties() +props.put("bootstrap.servers", "kafka:9092") +props.put("group.id", "new-group") +props.put("acks", "all") +props.put("retries", 0) +props.put("batch.size", 16384) +props.put("linger.ms", 1) +props.put("buffer.memory", 33554432) +props.put("key.serializer", StringSerializer.class.getName()) +props.put("value.serializer", StringSerializer.class.getName()) + +def producer = new KafkaProducer<>(props) + +def jsonString = '''{ + "event": { + "commonEventHeader": { + "domain": "fault", + "eventId": "fault0000245", + "eventName": "Fault_Vscf:PilotNumberPoolExhaustion", + "lastEpochMicrosec": 1413378172000000, + "priority": "High", + "reportingEntityName": "ibcx0001vm002oam001", + "sequence": 1, + "sourceId": "de305d54-75b4-431b-adb2-eb6b9e546014${__threadNum}", + "sourceName": "vfw-cnf-cds-test-1-vnf", + "startEpochMicrosec": 1413378172000000, + "timeZoneOffset": "UTC-05:30", + "version": "4.0.1", + "vesEventListenerVersion": "7.0.1" + }, + "faultFields": { + "alarmAdditionalInformation": { + "PilotNumberPoolSize": "1000" + }, + "alarmCondition": "PilotNumberPoolExhaustion", + "eventSeverity": "CRITICAL", + "eventSourceType": "other", + "faultFieldsVersion": 4, + "specificProblem": "Calls cannot complete - pilot numbers are unavailable", + "vfStatus": "Active" + } + } +}''' + +def record = new ProducerRecord<>("unauthenticated.dcae_policy_example_output", jsonString) + +producer.send(record, new Callback() { + @Override + void onCompletion(RecordMetadata metadata, Exception exception) { + if (exception != null) { + exception.printStackTrace() + } else { + println("Sent message to topic ${metadata.topic()} partition ${metadata.partition()} with offset ${metadata.offset()}") + } + } +}) + +producer.close() + + + + + groovy - import groovy.json.JsonSlurper; + + true + import org.apache.kafka.clients.consumer.ConsumerConfig +import org.apache.kafka.clients.consumer.KafkaConsumer +import org.apache.kafka.clients.consumer.ConsumerRecords +import org.apache.kafka.clients.consumer.ConsumerRecord +import org.apache.kafka.common.serialization.StringDeserializer +import groovy.json.JsonSlurper + +// Consumer properties +def props = new Properties() +props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "kafka:9092") // Adjust to your Kafka bootstrap server +props.put(ConsumerConfig.GROUP_ID_CONFIG, "apex-group") +props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName()) +props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName()) +props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest") + +// Create the Kafka consumer +def consumer = new KafkaConsumer<>(props) -def res = []; -if (prev.getResponseCode() == '200') { - def jsonSlurper = new JsonSlurper(); - res = jsonSlurper.parseText(prev.getResponseDataAsString()); +// Subscribe to the topic +consumer.subscribe(["apex-cl-mgt"]) - assert res instanceof Map; - assert res.healthy == true; - assert res.message == 'alive'; +// Poll for messages and assert the value +def found = false +def timeout = 10000 // timeout in milliseconds +def startTime = System.currentTimeMillis() + +while (!found && (System.currentTimeMillis() - startTime) < timeout) { + println("Inside while loop") + ConsumerRecords<String, String> records = consumer.poll(1000) + for (ConsumerRecord<String, String> record : records) { + println("Received message: Key=${record.key()}, Value=${record.value()}, Partition=${record.partition()}, Offset=${record.offset()}") + + // Parse the JSON value + def jsonSlurper = new JsonSlurper() + def message = jsonSlurper.parseText(record.value()) + + // Perform assertion on specific fields in the JSON + if ((message?.source == "APEX") || (message?.component?.status == "ACTIVE")) { + found = true + println("Assertion passed: source is 'APEX' or status is 'ACTIVE'") + break + } + } } + +// Close the consumer +consumer.close() + + + + + + + + true + + + import org.apache.kafka.clients.producer.Callback +import org.apache.kafka.clients.producer.RecordMetadata +import org.apache.kafka.clients.producer.KafkaProducer +import org.apache.kafka.clients.producer.ProducerRecord +import org.apache.kafka.clients.producer.ProducerConfig +import org.apache.kafka.common.serialization.StringSerializer + +def props = new Properties() +props.put("bootstrap.servers", "kafka:9092") +props.put("group.id", "new-group") +props.put("acks", "all") +props.put("retries", 0) +props.put("batch.size", 16384) +props.put("linger.ms", 1) +props.put("buffer.memory", 33554432) +props.put("key.serializer", StringSerializer.class.getName()) +props.put("value.serializer", StringSerializer.class.getName()) + +def producer = new KafkaProducer<>(props) + +def jsonString = '''{ + "event": { + "commonEventHeader": { + "startEpochMicrosec": 1597953057126, + "sourceId": "927b2580-36d9-4f13-8421-3c9d43b7a57${__threadNum}", + "eventId": "8c7935a4-79d8-4ec0-b661-dcca3cd6800${__threadNum}", + "lastEpochMicrosec": 1597952499468, + "eventName": "Report hostname & IP", + "sourceName": "PNF101", + "reportingEntityName": "DCAE", + "vesEventListenerVersion": "7.1", + "internalHeaderFields": {}, + "version": "4.0.1", + "priority": "Normal", + "sequence": 1, + "domain": "other" + }, + "otherFields": { + "hashMap": { + "hostname": "UNDEFINED", + "pnfId": "927b2580-36d9-4f13-8421-3c9d43b7a57e", + "pnfName": "PNF_INVALID", + "ip": "10.101.200.10" + }, + "otherFieldsVersion": "3.0" + } + } +}''' + +def record = new ProducerRecord<>("unauthenticated.dcae_cl_output", jsonString) + +producer.send(record, new Callback() { + @Override + void onCompletion(RecordMetadata metadata, Exception exception) { + if (exception != null) { + exception.printStackTrace() + } else { + println("Sent message to topic ${metadata.topic()} partition ${metadata.partition()} with offset ${metadata.offset()}") + } + } +}) + +producer.close() groovy - + + + + groovy + + + true + import org.apache.kafka.clients.consumer.ConsumerConfig +import org.apache.kafka.clients.consumer.KafkaConsumer +import org.apache.kafka.clients.consumer.ConsumerRecords +import org.apache.kafka.clients.consumer.ConsumerRecord +import org.apache.kafka.common.serialization.StringDeserializer +import groovy.json.JsonSlurper + +// Consumer properties +def props = new Properties() +props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "kafka:9092") // Adjust to your Kafka bootstrap server +props.put(ConsumerConfig.GROUP_ID_CONFIG, "apex-group") +props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName()) +props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName()) +props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest") + +// Create the Kafka consumer +def consumer = new KafkaConsumer<>(props) + +// Subscribe to the topic +consumer.subscribe(["apex-cl-mgt"]) + +// Poll for messages and assert the value +def found = false +def timeout = 10000 // timeout in milliseconds +def startTime = System.currentTimeMillis() + +while (!found && (System.currentTimeMillis() - startTime) < timeout) { + println("Inside while loop") + ConsumerRecords<String, String> records = consumer.poll(1000) + for (ConsumerRecord<String, String> record : records) { + println("Received message: Key=${record.key()}, Value=${record.value()}, Partition=${record.partition()}, Offset=${record.offset()}") + + // Parse the JSON value + def jsonSlurper = new JsonSlurper() + def message = jsonSlurper.parseText(record.value()) + + // Perform assertion on specific fields in the JSON + if (!(message?.name != "SUCCESS")) { + found = true + println("Assertion passed") + break + } + } +} + +// Close the consumer +consumer.close() + + - + - - ${threads} - ${threadsTimeOutInMs} - + + true + + + import org.apache.kafka.clients.producer.Callback +import org.apache.kafka.clients.producer.RecordMetadata +import org.apache.kafka.clients.producer.KafkaProducer +import org.apache.kafka.clients.producer.ProducerRecord +import org.apache.kafka.clients.producer.ProducerConfig +import org.apache.kafka.common.serialization.StringSerializer + +def props = new Properties() +props.put("bootstrap.servers", "kafka:9092") +props.put("group.id", "new-group") +props.put("acks", "all") +props.put("retries", 0) +props.put("batch.size", 16384) +props.put("linger.ms", 1) +props.put("buffer.memory", 33554432) +props.put("key.serializer", StringSerializer.class.getName()) +props.put("value.serializer", StringSerializer.class.getName()) + +def producer = new KafkaProducer<>(props) + +def jsonString = '''{ + "event": { + "commonEventHeader": { + "startEpochMicrosec": 1597953057126, + "sourceId": "927b2580-36d9-4f13-8421-3c9d43b7a57${__threadNum}", + "eventId": "8c7935a4-79d8-4ec0-b661-dcca3cd6800${__threadNum}", + "lastEpochMicrosec": 1597952499468, + "eventName": "Report hostname & IP", + "sourceName": "PNF101", + "reportingEntityName": "DCAE", + "vesEventListenerVersion": "7.1", + "internalHeaderFields": {}, + "version": "4.0.1", + "priority": "Normal", + "sequence": 1, + "domain": "other" + }, + "otherFields": { + "hashMap": { + "hostname": "UNDEFINED", + "pnfId": "927b2580-36d9-4f13-8421-3c9d43b7a57e", + "pnfName": "PNF101", + "ip": "10.101.200.10" + }, + "otherFieldsVersion": "3.0" + } + } +}''' + +def record = new ProducerRecord<>("unauthenticated.dcae_policy_example_output", jsonString) + +producer.send(record, new Callback() { + @Override + void onCompletion(RecordMetadata metadata, Exception exception) { + if (exception != null) { + exception.printStackTrace() + } else { + println("Sent message to topic ${metadata.topic()} partition ${metadata.partition()} with offset ${metadata.offset()}") + } + } +}) + +producer.close() + + groovy + + + + groovy + + + true + import org.apache.kafka.clients.consumer.ConsumerConfig +import org.apache.kafka.clients.consumer.KafkaConsumer +import org.apache.kafka.clients.consumer.ConsumerRecords +import org.apache.kafka.clients.consumer.ConsumerRecord +import org.apache.kafka.common.serialization.StringDeserializer +import groovy.json.JsonSlurper + +// Consumer properties +def props = new Properties() +props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "kafka:9092") // Adjust to your Kafka bootstrap server +props.put(ConsumerConfig.GROUP_ID_CONFIG, "apex-group") +props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName()) +props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName()) +props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest") + +// Create the Kafka consumer +def consumer = new KafkaConsumer<>(props) + +// Subscribe to the topic +consumer.subscribe(["apex-cl-mgt"]) + +// Poll for messages and assert the value +def found = false +def timeout = 10000 // timeout in milliseconds +def startTime = System.currentTimeMillis() + +while (!found && (System.currentTimeMillis() - startTime) < timeout) { + println("Inside while loop") + ConsumerRecords<String, String> records = consumer.poll(1000) + for (ConsumerRecord<String, String> record : records) { + println("Received message: Key=${record.key()}, Value=${record.value()}, Partition=${record.partition()}, Offset=${record.offset()}") + + // Parse the JSON value + def jsonSlurper = new JsonSlurper() + def message = jsonSlurper.parseText(record.value()) + + // Perform assertion on specific fields in the JSON + if (!(message?.name == "SUCCESS")) { + found = true + println("Assertion passed: source is 'APEX' or status is 'ACTIVE'") + break + } + } +} + +// Close the consumer +consumer.close() + + - - true - - - - false - { - "changeType": "CREATE", - "closedLoopControlName": "test", - "policyName": "test", - "nfName": "pnf300", - "subscription": { - "subscriptionName": "testPolicyB", - "administrativeState": "UNLOCKED", - "fileBasedGP": 15, - "fileLocation": "/pm/pm.xml", - "measurementGroups": [ - { - "measurementGroup": { - "measurementTypes": [ - { - "measurementType": "countera" - }, - { - "measurementType": "counterb" - } - ], - "managedObjectDNsBasic": [ - { - "DN": "dna" - }, - { - "DN": "dnb" - } - ] - } - }, - { - "measurementGroup": { - "measurementTypes": [ - { - "measurementType": "counterc" - }, - { - "measurementType": "counterd" - } - ], - "managedObjectDNsBasic": [ - { - "DN": "dnc" - }, - { - "DN": "dnd" - } - ] - } - } - ] - } -} - = - - - - ${HOSTNAME} - ${DMAAP_PORT} - http - - /events/unauthenticated.DCAE_CL_OUTPUT - POST - true - false - true - false - - - - Send input event to apex-pdp - - - - - 200 - - - Assertion.response_code - false - 8 - Response code - Assert response code coming back from apex-pdp - - - - ${wait} - - - - - - - - ${HOSTNAME} - ${DMAAP_PORT} - http - - /events/POLICY-CL-MGT/cg${__threadNum}/c1?timeout=30000 - GET - true - false - true - false - - - - Check output event - - - - - 200 - - - Assertion.response_code - false - 8 - Response code - Assert response code coming back from apex-pdp - - - - - org.onap.policy.apex.onap.pmcontrol - CREATE - - - Assertion.response_data - false - 2 - Response code - Assert response message coming back from apex-pdp - - - - ${wait} - - - - + + 1 + 1 + true continue - - false + 1 + false - 1 - 1 - false - - - true + 6 + ${HOSTNAME} + ${PAP_PORT} + http + /policy/pap/v1/pdps/deployments/batch + true + POST + true true @@ -2764,7 +6823,10 @@ if (prev.getResponseCode() == '200') { "action": "DELETE", "policies": [ { - "name": "operational.apex.stabilityTestDefaultDomain", + "name": "onap.policies.apex.Simplecontrolloop", + "version": "1.0.0" + }, { + "name": "onap.policies.apex.Example", "version": "1.0.0" } ] @@ -2777,22 +6839,9 @@ if (prev.getResponseCode() == '200') { - ${HOSTNAME} - ${PAP_PORT} - https - - /policy/pap/v1/pdps/deployments/batch - POST - true - false - true - false - - - - + 202 @@ -2804,25 +6853,47 @@ if (prev.getResponseCode() == '200') { - + 6 + ${HOSTNAME} + ${API_PORT} + http + /policy/api/v1/policytypes/onap.policies.native.Apex/versions/1.0.0/policies/onap.policies.apex.Simplecontrolloop/versions/1.0.0 + true + DELETE + true + false + + + + + + 200 + + + Assertion.response_code + false + 1 + + + + + 6 ${HOSTNAME} ${API_PORT} - https - - /policy/api/v1/policytypes/onap.policies.native.Apex/versions/1.0.0/policies/operational.apex.stabilityTestDefaultDomain/versions/1.0.0 - DELETE + http + /policy/api/v1/policytypes/onap.policies.native.Apex/versions/1.0.0/policies/onap.policies.apex.Example/versions/1.0.0 true - false + DELETE true - false - - - + false + + + - + 200 @@ -2863,11 +6934,12 @@ if (prev.getResponseCode() == '200') { true true true + true true true - /home/adityap/apex_stability/Stability.log + /home/wayne/dev/s3ps/apex-pdp/testsuites/apex-pdp-stability/src/main/resources/s3pTestResults.jtl @@ -2899,14 +6971,15 @@ if (prev.getResponseCode() == '200') { true true true + true true true - /home/adityap/apex_stability/resultTree.log + /home/wayne/dev/s3ps/apex-pdp/testsuites/apex-pdp-stability/src/main/resources/s3pTestResults.jtl - + false saveConfig @@ -2935,11 +7008,12 @@ if (prev.getResponseCode() == '200') { true true true + true true true - /home/adityap/apex_stability/resultTable.log + /home/wayne/dev/s3ps/apex-pdp/testsuites/apex-pdp-stability/src/main/resources/s3pTestResults.jtl