diff options
author | FrancescoFioraEst <francesco.fiora@est.tech> | 2022-08-19 12:09:51 +0100 |
---|---|---|
committer | FrancescoFioraEst <francesco.fiora@est.tech> | 2022-08-30 09:25:21 +0100 |
commit | 35e46060a44f17c68cff654c5f65e3831af03847 (patch) | |
tree | 273af6038f340070a4e253d3ba340a4d8e826cc8 /examples/examples-acm/src/main/resources/logic | |
parent | fddb2c8664d73ea6041c3111f4a5e894c7c5103c (diff) |
Add example policy for AC element microservice test
Issue-ID: POLICY-4307
Change-Id: I0275bbacb3d2689f50f93eef541cd43601aab8ef
Signed-off-by: FrancescoFioraEst <francesco.fiora@est.tech>
Diffstat (limited to 'examples/examples-acm/src/main/resources/logic')
-rw-r--r-- | examples/examples-acm/src/main/resources/logic/ForwardPayloadTask.js | 58 |
1 files changed, 58 insertions, 0 deletions
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; |