From 35e46060a44f17c68cff654c5f65e3831af03847 Mon Sep 17 00:00:00 2001 From: FrancescoFioraEst Date: Fri, 19 Aug 2022 12:09:51 +0100 Subject: Add example policy for AC element microservice test Issue-ID: POLICY-4307 Change-Id: I0275bbacb3d2689f50f93eef541cd43601aab8ef Signed-off-by: FrancescoFioraEst --- .../src/main/resources/logic/ForwardPayloadTask.js | 58 ++++++++++++++++++++++ 1 file changed, 58 insertions(+) create mode 100644 examples/examples-acm/src/main/resources/logic/ForwardPayloadTask.js (limited to 'examples/examples-acm/src/main/resources/logic') diff --git a/examples/examples-acm/src/main/resources/logic/ForwardPayloadTask.js b/examples/examples-acm/src/main/resources/logic/ForwardPayloadTask.js new file mode 100644 index 000000000..d48b0dcb7 --- /dev/null +++ b/examples/examples-acm/src/main/resources/logic/ForwardPayloadTask.js @@ -0,0 +1,58 @@ +/* + * ============LICENSE_START======================================================= + * Copyright (C) 2022 Nordix. All rights reserved. + * ================================================================================ + * Licensed under the Apache License, Version 2.0 (the 'License'); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an 'AS IS' BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + * SPDX-License-Identifier: Apache-2.0 + * ============LICENSE_END========================================================= + */ + +executor.logger.info(executor.subject.id); +executor.logger.info(executor.inFields); + +var msgResponse = executor.inFields.get('DmaapResponseEvent'); +executor.logger.info('Task in progress with mesages: ' + msgResponse); + +var elementId = msgResponse.get('elementId').get('name'); + +if (msgResponse.get('messageType') == 'STATUS' && + (elementId == 'onap.policy.clamp.ac.startertobridge' + || elementId == 'onap.policy.clamp.ac.bridgetosink')) { + + var receiverId = ''; + if (elementId == 'onap.policy.clamp.ac.startertobridge') { + receiverId = 'onap.policy.clamp.ac.bridge'; + } else { + receiverId = 'onap.policy.clamp.ac.sink'; + } + + var elementIdResponse = new java.util.HashMap(); + elementIdResponse.put('name', receiverId); + elementIdResponse.put('version', msgResponse.get('elementId').get('version')); + + var dmaapResponse = new java.util.HashMap(); + dmaapResponse.put('elementId', elementIdResponse); + + var message = msgResponse.get('message') + ' trace added from policy'; + dmaapResponse.put('message', message); + dmaapResponse.put('messageType', 'STATUS'); + dmaapResponse.put('messageId', msgResponse.get('messageId')); + dmaapResponse.put('timestamp', msgResponse.get('timestamp')); + + executor.logger.info('Sending forwarding Event to Ac element: ' + dmaapResponse); + + executor.outFields.put('DmaapResponseStatusEvent', dmaapResponse); +} + +true; -- cgit 1.2.3-korg