From a0200fa608aea163396bebae8e3c2c43fcfcbf55 Mon Sep 17 00:00:00 2001 From: eikrwaq Date: Tue, 1 May 2018 15:30:21 +0100 Subject: Adding JMeter Test Plan for PDP-D Change-Id: Id9de78a02706dc2c68e0def4e27631964baf3922 Issue-ID: POLICY-525 Signed-off-by: eikrwaq --- .../amsterdam/droolsPdpStabilityTestPlan.jmx | 1879 ++++++++++++++++++++ 1 file changed, 1879 insertions(+) create mode 100644 testsuites/stability/src/main/resources/amsterdam/droolsPdpStabilityTestPlan.jmx (limited to 'testsuites/stability/src/main/resources/amsterdam/droolsPdpStabilityTestPlan.jmx') diff --git a/testsuites/stability/src/main/resources/amsterdam/droolsPdpStabilityTestPlan.jmx b/testsuites/stability/src/main/resources/amsterdam/droolsPdpStabilityTestPlan.jmx new file mode 100644 index 000000000..61f2e59b6 --- /dev/null +++ b/testsuites/stability/src/main/resources/amsterdam/droolsPdpStabilityTestPlan.jmx @@ -0,0 +1,1879 @@ + + + + + + false + true + true + + + + + + + + + + + + + + + @1b3rt + 31nst31n + + + + + + + + + + + + 9696 + http + + + 6 + + + + + + + + size + 2000 + = + max number of VNF instances + + + wait + 500 + = + Sleep time for each request + + + vCPEControlLoop + ControlLoop-vCPE-48f0c2c3-a172-4192-9ae3-052274181b6e + = + vCPE Control loop name + + + vDNSControlLoop + ControlLoop-vDNS-6f37f56d-a87d-4b85-b6a9-cc953cf779b3 + = + vDNS Control loop name + + + vFWControlLoop + ControlLoop-vFirewall-d0a1dfc6-94f5-4fd4-a5b5-4630b438850a + = + vFW Controll loop name + + + VOLTEControlLoop + ControlLoop-VOLTE-2179b738-fd36-4843-a71a-a8c24c70c55b + = + VOLTE Control loop name + + + threads + 2 + = + + + threadsTimeOutInMs + 5000 + = + + + + + + stoptest + + false + -1 + + ${threads} + 1 + false + + + + + + + + + + + + + + + + + policy/pdp/engine/controllers/amsterdam/drools/facts/amsterdam/ + GET + true + false + true + false + + + + + + + + {"org.onap.policy.controlloop.Params":4} + + + Assertion.response_data + false + 16 + + + + + + ${wait} + + + + + + + + Run vCPE Sucess flow + + + + Run vCPE Sucess flow + + + + java + + + true + import java.util.ArrayList; +import java.util.List; + +final List vCPECache = new ArrayList(); +vars.putObject("vCPECache", vCPECache); + + + This sampler intializes cache to store generate requestID for vCPE success flow + + + + 1 + ${size} + 1 + vnfID + vCPE_Infrastructure_vGMUX_demo_app-00 + false + This counter generate unique vnf-id + + + + true + + + import java.util.List; +import java.util.UUID; + +final List vCPECache = vars.getObject("vCPECache"); + +final String uuid = UUID.randomUUID().toString(); +vars.put("requestID",uuid); + +vCPECache.add(uuid); +log.debug("[vCPE] requestID " + uuid); + java + this sampler generates unique requestId using UUID and adds it to local cache + + + + true + + + + false + { + "closedLoopControlName": "${vCPEControlLoop}", + "closedLoopAlarmStart": 1463679805324, + "closedLoopEventClient": "DCAE_INSTANCE_ID.dcae-tca", + "closedLoopEventStatus": "ONSET", + "requestID": "${requestID}", + "target_type": "VNF", + "target": "generic-vnf.vnf-id", + "AAI": { + "vserver.is-closed-loop-disabled": "false", + "generic-vnf.vnf-id": "${vnfID}" + }, + "from": "DCAE", + "version": "1.0.2" +} + + = + + + + + + + + policy/pdp/engine/topics/sources/ueb/unauthenticated.DCAE_CL_OUTPUT/events + PUT + true + false + true + false + + + + + + + + 200 + + + Assertion.response_code + false + 8 + Response code + + + + + ${wait} + + + + true + + + + false + { + "body": { + "output": { + "common-header": { + "timestamp": "2017-08-25T21:06:23.037Z", + "api-ver": "5.00", + "originator-id": "664be3d2-6c12-4f4b-a3e7-c349acced200", + "request-id": "${requestID}", + "sub-request-id": "1", + "flags": {} + }, + "status": { + "code": 400, + "message": "Restart Successful" + } + } + }, + "version": "2.0", + "rpc-name": "restart", + "correlation-id": "664be3d2-6c12-4f4b-a3e7-c349acced200-1", + "type": "response" +} + = + + + + + + + + policy/pdp/engine/topics/sources/ueb/APPC-LCM-WRITE/events + PUT + true + false + true + false + + + + + + + + 200 + + + Assertion.response_code + false + 16 + + + + + ${wait} + + + + true + + + + false + { + "closedLoopControlName": "ControlLoop-vCPE-48f0c2c3-a172-4192-9ae3-052274181b6e", + "closedLoopAlarmStart": 1463679805324, + "closedLoopAlarmEnd": 1463699805324, + "closedLoopEventClient": "DCAE_INSTANCE_ID.dcae-tca", + "closedLoopEventStatus": "ABATED", + "requestID": "${requestID}", + "target_type": "VNF", + "target": "generic-vnf.vnf-id", + "AAI": { + "generic-vnf.is-closed-loop-disabled": "false", + "generic-vnf.vnf-id": "${vnfID}" + }, + "from": "DCAE", + "version": "1.0.2" +} + + = + + + + + + + + policy/pdp/engine/topics/sources/ueb/unauthenticated.DCAE_CL_OUTPUT/events + PUT + true + false + true + false + + + + + + + + 200 + + + Assertion.response_code + false + 16 + + + + + + ${wait} + + + + ${threads} + ${threadsTimeOutInMs} + + + + + + + + + + + + + policy/pdp/engine/topics/sinks/noop/POLICY-CL-MGT + GET + true + false + true + false + + + + + + + result + $ + + + + + java + + + true + import net.minidev.json.parser.JSONParser; +import net.minidev.json.JSONObject; +import net.minidev.json.JSONArray; + +final Map records = new HashMap(); +final JSONParser p = new JSONParser(JSONParser.MODE_PERMISSIVE); + +final String result = vars.get("result"); +final JSONObject jsonObj = (JSONObject) p.parse(result); + + if (jsonObj != null) { + final JSONArray events = (JSONArray) jsonObj.get("recentEvents"); + if (events != null) { + for (int j = 0; j < events.size(); j++) { + final String event = (String) events.get(j); + if (event != null ) { + final JSONParser parser = new JSONParser(JSONParser.MODE_PERMISSIVE); + final JSONObject eventObj = (JSONObject) parser.parse(event); + final String controlLoopName = vars.get("vCPEControlLoop"); + if (eventObj.get("closedLoopControlName").equals(controlLoopName)) { + final String requestId = eventObj.get("requestId"); + final String notification = eventObj.get("notification"); + records.put(requestId, notification); + } + } + } + } + } + +boolean failure = false; +final String expectedNotification = "FINAL: SUCCESS"; +final List cache = vars.getObject("vCPECache"); + +for (int i = 0; i < cache.size(); i++) { + final String requestId = cache.get(i); + final String notification = records.get(requestId); + if (!(notification != null && expectedNotification.equals(notification))) { + log.error("[vCPE] Assertion failed for requestId: " + requestId +" Expected notification: " + expectedNotification + " But found: " + notification); + failure = true; + } +} + +if (failure || cache.isEmpty()) { + final String error = "[vCPE] Unable to find notification with " + expectedNotification + " in topic 'POLICY-CL-MGT'"; + AssertionResult.setFailureMessage(error); + AssertionResult.setFailure(true); + log.error(error); + log.info("[vCPE] vCPECache: " + cache); + log.info("[vCPE] Success Records found: " + records); + log.info("[vCPE] " + result); +} else { + AssertionResult.setFailure(false); +} + + + this assertion handler parse sink event response and checks notification result for each request made + + + + + + + Run vCPE failure flow + + + + Run vCPE failure flow + + + + java + + + true + import java.util.ArrayList; +import java.util.List; + +List vCPEFailureCache = new ArrayList(); +vars.putObject("vCPEFailureCache", vCPEFailureCache); + + + + + 1 + ${size} + 1 + vnfID + vCPE_Infrastructure_vGMUX_demo_app-00 + false + + + + true + + + import java.util.List; +import java.util.UUID; + +final List vCPEFailureCache = vars.getObject("vCPEFailureCache"); + +final String uuid = UUID.randomUUID().toString(); +vars.put("requestID",uuid); + +vCPEFailureCache.add(uuid); +log.debug("[vCPE Failure] requestID "+ uuid); + java + + + + true + + + + false + { + "closedLoopControlName": "${vCPEControlLoop}", + "closedLoopAlarmStart": 1463679805324, + "closedLoopEventClient": "DCAE_INSTANCE_ID.dcae-tca", + "closedLoopEventStatus": "ONSET", + "requestID": "${requestID}", + "target_type": "VNF", + "target": "generic-vnf.vnf-id", + "AAI": { + "vserver.is-closed-loop-disabled": "false", + "generic-vnf.vnf-id": "${vnfID}" + }, + "from": "DCAE", + "version": "1.0.2" +} + + = + + + + + + + + policy/pdp/engine/topics/sources/ueb/unauthenticated.DCAE_CL_OUTPUT/events + PUT + true + false + true + false + + + + + + + + 200 + + + Assertion.response_code + false + 8 + Response code + + + + result + $ + + + + + javascript + + + true + +var result = vars.get("result"); +var count = (result.match(/closedLoopControlName/g) || []).length; + +if(count > 0){ + AssertionResult.setFailure(false); +} else { + AssertionResult.setFailureMessage("Expected atleast 1 closedLoopControlName got :" + count); + AssertionResult.setFailure(true); +} + + + + + ${wait} + + + + true + + + + false + { + "body": { + "output": { + "common-header": { + "timestamp": "2017-08-25T21:06:23.037Z", + "api-ver": "5.00", + "originator-id": "664be3d2-6c12-4f4b-a3e7-c349acced200", + "request-id": "${requestID}", + "sub-request-id": "1", + "flags": {} + }, + "status": { + "code": 500, + "message": "Restart Failed" + } + } + }, + "version": "2.0", + "rpc-name": "restart", + "correlation-id": "664be3d2-6c12-4f4b-a3e7-c349acced200-1", + "type": "response" +} + = + + + + + + + + policy/pdp/engine/topics/sources/ueb/APPC-LCM-WRITE/events + PUT + true + false + true + false + + + + + + + + 200 + + + Assertion.response_code + false + 16 + + + + + + ${wait} + + + + ${threads} + ${threadsTimeOutInMs} + + + + + + + + + + + + + policy/pdp/engine/topics/sinks/noop/POLICY-CL-MGT + GET + true + false + true + false + + + + + + + result + $ + + + + + java + + + true + import net.minidev.json.parser.JSONParser; +import net.minidev.json.JSONObject; +import net.minidev.json.JSONArray; + +final Map records = new HashMap(); +final JSONParser p = new JSONParser(JSONParser.MODE_PERMISSIVE); + +final String result = vars.get("result"); +final JSONObject jsonObj = (JSONObject) p.parse(result); + + if (jsonObj != null) { + final JSONArray events = (JSONArray) jsonObj.get("recentEvents"); + if (events != null) { + for (int j = 0; j < events.size(); j++) { + final String event = (String) events.get(j); + if (event != null ) { + final JSONParser parser = new JSONParser(JSONParser.MODE_PERMISSIVE); + final JSONObject eventObj = (JSONObject) parser.parse(event); + final String controlLoopName = vars.get("vCPEControlLoop"); + if (eventObj.get("closedLoopControlName").equals(controlLoopName)) { + final String requestId = eventObj.get("requestId"); + final String notification = eventObj.get("notification"); + records.put(requestId, notification); + } + } + } + } + } + + +boolean failure = false; +final String expectedNotification = "FINAL: FAILURE"; +final List cache = vars.getObject("vCPEFailureCache"); + +for (int i = 0; i < cache.size(); i++) { + final String requestId = cache.get(i); + final String notification = records.get(requestId); + if (!(notification != null && expectedNotification.equals(notification))) { + log.error("[vCPE Failue] Assertion failed for requestId: " + requestId + + " Expected notification: " + expectedNotification + " But found: " + notification); + failure = true; + } +} + +if (failure || cache.isEmpty()) { + final String error = "[vCPE] Unable to find notification with " + expectedNotification + " in topic 'POLICY-CL-MGT'"; + AssertionResult.setFailureMessage(error); + AssertionResult.setFailure(true); + log.error(error); + log.info("[vCPE Failue] vCPECache: " + cache); + log.info("[vCPE Failue] Success Records found: " + records); + log.info("[vCPE Failue] " + result); +} else { + AssertionResult.setFailure(false); +} + + + + + + + + + + + + java + + + true + import java.util.ArrayList; +import java.util.List; + +final List vDNSCache = new ArrayList(); +vars.putObject("vDNSCache", vDNSCache); + + + + + + 1 + ${size} + 1 + vserver-name + dnsvserver-name-0 + false + + + + true + + + import java.util.List; +import java.util.UUID; + +final List vDNSCache = vars.getObject("vDNSCache"); + +final String uuid = UUID.randomUUID().toString(); +vars.put("requestID", uuid); + +vDNSCache.add(uuid); +log.debug("[vDNS] requestID "+ uuid); + java + + + + true + + + + false + { + "closedLoopControlName": "${vDNSControlLoop}", + "closedLoopAlarmStart": 1484677482204798, + "closedLoopEventClient": "DCAE_INSTANCE_ID.dcae-tca", + "closedLoopEventStatus": "ONSET", + "requestID": "${requestID}", + "target_type": "VNF", + "target": "vserver.vserver-name", + "AAI": { + "vserver.is-closed-loop-disabled": "false", + "vserver.vserver-name": "${vserver-name}" + }, + "from": "DCAE", + "version": "1.0.2" +} + = + + + + + + + + policy/pdp/engine/topics/sources/ueb/unauthenticated.DCAE_CL_OUTPUT/events + PUT + true + false + true + false + + + + + + + + 200 + + + Assertion.response_code + false + 8 + Response code + + + + + + ${wait} + + + + ${threads} + ${threadsTimeOutInMs} + + + + + + + + + + + + + policy/pdp/engine/topics/sinks/noop/POLICY-CL-MGT + GET + true + false + true + false + + + + + + + result + $ + + + + + java + + + true + import net.minidev.json.parser.JSONParser; +import net.minidev.json.JSONObject; +import net.minidev.json.JSONArray; + +final Map records = new HashMap(); +final JSONParser p = new JSONParser(JSONParser.MODE_PERMISSIVE); + +final String result = vars.get("result"); +final JSONObject jsonObj = (JSONObject) p.parse(result); + + if (jsonObj != null) { + final JSONArray events = (JSONArray) jsonObj.get("recentEvents"); + if (events != null) { + for (int j = 0; j < events.size(); j++) { + final String event = (String) events.get(j); + if (event != null ) { + final JSONParser parser = new JSONParser(JSONParser.MODE_PERMISSIVE); + final JSONObject eventObj = (JSONObject) parser.parse(event); + final String controlLoopName = vars.get("vDNSControlLoop"); + if (eventObj.get("closedLoopControlName").equals(controlLoopName)) { + final String requestId = eventObj.get("requestId"); + final String notification = eventObj.get("notification"); + records.put(requestId, notification); + } + } + } + } + } + +boolean failure = false; +final String expectedNotification = "FINAL: SUCCESS"; +final List cache = vars.getObject("vDNSCache"); + +for (int i = 0; i < cache.size(); i++) { + final String requestId = cache.get(i); + final String notification = records.get(requestId); + if (!(notification != null && expectedNotification.equals(notification))) { + log.error("[vDNS] Assertion failed for requestId: " + requestId +" Expected notification: " + expectedNotification + " But found: " + notification); + failure = true; + } +} + +if (failure || cache.isEmpty()) { + final String error = "[vDNS] Unable to find notification with " + expectedNotification + " in topic 'POLICY-CL-MGT'"; + AssertionResult.setFailureMessage(error); + AssertionResult.setFailure(true); + log.error(error); + log.info("[vDNS] vDNSCache: " + cache); + log.info("[vDNS] Success Records found: " + records); + log.info("[vDNS] " + result); +} else { + AssertionResult.setFailure(false); +} + + + + + + + + + + + + + + + java + + + true + import java.util.ArrayList; +import java.util.List; + +final List vFWCache = new ArrayList(); +vars.putObject("vFWCache", vFWCache); + + + + 1 + ${size} + 1 + vnf-id + fwvnfid-0 + false + + + + true + + + import java.util.List; +import java.util.UUID; + +final List vFWCache = vars.getObject("vFWCache"); + +final String uuid = UUID.randomUUID().toString(); +vars.put("requestID", uuid); + +vFWCache.add(uuid); +log.debug("[vFW] requestID "+ uuid); + java + + + + true + + + + false + { + "closedLoopControlName": "${vFWControlLoop}", + "closedLoopAlarmStart": 1463679805324, + "closedLoopEventClient": "microservice.stringmatcher", + "closedLoopEventStatus": "ONSET", + "requestID": "${requestID}", + "target_type": "VNF", + "target": "generic-vnf.vnf-id", + "AAI": { + "generic-vnf.is-closed-loop-disabled": "false", + "generic-vnf.vnf-id": "${vnf-id}" + }, + "from": "DCAE", + "version": "1.0.2" +} + = + + + + + + + + policy/pdp/engine/topics/sources/ueb/unauthenticated.DCAE_CL_OUTPUT/events + PUT + true + false + true + false + + + + + + + + 200 + + + Assertion.response_code + false + 8 + Response code + + + + + ${wait} + + + + true + + + + false + { + "CommonHeader": { + "TimeStamp": 1506051879001, + "APIver": "1.01", + "RequestID": "${requestID}", + "SubRequestID": "1", + "RequestTrack": [], + "Flags": [] + }, + "Status": { + "Code": 400, + "Value": "SUCCESS" + }, + "Payload": { + "generic-vnf.vnf-id": "${vnf-id}", + "pg-streams": { + "pg-stream": [ + { + "id": "fw_udp1", + "is-enabled": "true" + }, + { + "id": "fw_udp2", + "is-enabled": "true" + }, + { + "id": "fw_udp3", + "is-enabled": "true" + }, + { + "id": "fw_udp4", + "is-enabled": "true" + }, + { + "id": "fw_udp5", + "is-enabled": "true" + } + ] + } + } +} + = + + + + + + + + policy/pdp/engine/topics/sources/ueb/APPC-CL/events + PUT + true + false + true + false + + + + + + + + 200 + + + Assertion.response_code + false + 16 + + + + + + ${wait} + + + + ${threads} + ${threadsTimeOutInMs} + + + + + + + + + + + + + policy/pdp/engine/topics/sinks/noop/POLICY-CL-MGT + GET + true + false + true + false + + + + + + + result + $ + + + + + java + + + true + import net.minidev.json.parser.JSONParser; +import net.minidev.json.JSONObject; +import net.minidev.json.JSONArray; + +final Map records = new HashMap(); +final JSONParser p = new JSONParser(JSONParser.MODE_PERMISSIVE); + +final String result = vars.get("result"); +final JSONObject jsonObj = (JSONObject) p.parse(result); + + if (jsonObj != null) { + final JSONArray events = (JSONArray) jsonObj.get("recentEvents"); + if (events != null) { + for (int j = 0; j < events.size(); j++) { + final String event = (String) events.get(j); + if (event != null ) { + final JSONParser parser = new JSONParser(JSONParser.MODE_PERMISSIVE); + final JSONObject eventObj = (JSONObject) parser.parse(event); + final String controlLoopName = vars.get("vFWControlLoop"); + if (eventObj.get("closedLoopControlName").equals(controlLoopName)) { + final String requestId = eventObj.get("requestId"); + final String notification = eventObj.get("notification"); + records.put(requestId, notification); + } + } + } + } + } + +boolean failure = false; +final String expectedNotification = "FINAL: SUCCESS"; +final List cache = vars.getObject("vFWCache"); + +for (int i = 0; i < cache.size(); i++) { + final String requestId = cache.get(i); + final String notification = records.get(requestId); + if (!(notification != null && expectedNotification.equals(notification))) { + log.error("[vFW] Assertion failed for requestId: " + requestId +" Expected notification: " + expectedNotification + " But found: " + notification); + failure = true; + } +} + +if (failure || cache.isEmpty()) { + final String error = "[vFW] Unable to find notification with " + expectedNotification + " in topic 'POLICY-CL-MGT'"; + AssertionResult.setFailureMessage(error); + AssertionResult.setFailure(true); + log.error(error); + log.info("[vFW] vFWCache: " + cache); + log.info("[vFW] Success Records found: " + records); + log.info("[vFW] " + result); +} else { + AssertionResult.setFailure(false); +} + + + + + + + + + + + + + java + + + true + import java.util.ArrayList; +import java.util.List; + +final List vFWFailueCache = new ArrayList(); +vars.putObject("vFWFailueCache", vFWFailueCache); + + + + 1 + ${size} + 1 + vnf-id + fwvnfid-0 + false + + + + true + + + import java.util.List; +import java.util.UUID; + +final List vFWFailueCache = vars.getObject("vFWFailueCache"); + +final String uuid = UUID.randomUUID().toString(); +vars.put("requestID", uuid); + +vFWFailueCache.add(uuid); +log.debug("[vFW FAILURE] requestID "+ uuid); + java + + + + true + + + + false + { + "closedLoopControlName": "${vFWControlLoop}", + "closedLoopAlarmStart": 1463679805324, + "closedLoopEventClient": "microservice.stringmatcher", + "closedLoopEventStatus": "ONSET", + "requestID": "${requestID}", + "target_type": "VNF", + "target": "generic-vnf.vnf-id", + "AAI": { + "generic-vnf.is-closed-loop-disabled": "false", + "generic-vnf.vnf-id": "${vnf-id}" + }, + "from": "DCAE", + "version": "1.0.2" +} + = + + + + + + + + policy/pdp/engine/topics/sources/ueb/unauthenticated.DCAE_CL_OUTPUT/events + PUT + true + false + true + false + + + + + + + + 200 + + + Assertion.response_code + false + 8 + Response code + + + + + ${wait} + + + + true + + + + false + { + "CommonHeader": { + "TimeStamp": 1506051879001, + "APIver": "1.01", + "RequestID": "${requestID}", + "SubRequestID": "1", + "RequestTrack": [], + "Flags": [] + }, + "Status": { + "Code": 500, + "Value": "FAILED" + }, + "Payload": { + "generic-vnf.vnf-id": "${vnf-id}", + "pg-streams": { + "pg-stream": [ + { + "id": "fw_udp1", + "is-enabled": "true" + }, + { + "id": "fw_udp2", + "is-enabled": "true" + }, + { + "id": "fw_udp3", + "is-enabled": "true" + }, + { + "id": "fw_udp4", + "is-enabled": "true" + }, + { + "id": "fw_udp5", + "is-enabled": "true" + } + ] + } + } +} + = + + + + + + + + policy/pdp/engine/topics/sources/ueb/APPC-CL/events + PUT + true + false + true + false + + + + + + + + 200 + + + Assertion.response_code + false + 16 + + + + + + ${wait} + + + + ${threads} + ${threadsTimeOutInMs} + + + + + + + + + + + + + policy/pdp/engine/topics/sinks/noop/POLICY-CL-MGT + GET + true + false + true + false + + + + + + + result + $ + + + + + java + + + true + import net.minidev.json.parser.JSONParser; +import net.minidev.json.JSONObject; +import net.minidev.json.JSONArray; + +final Map records = new HashMap(); +final JSONParser p = new JSONParser(JSONParser.MODE_PERMISSIVE); + +final String result = vars.get("result"); +final JSONObject jsonObj = (JSONObject) p.parse(result); + + if (jsonObj != null) { + final JSONArray events = (JSONArray) jsonObj.get("recentEvents"); + if (events != null) { + for (int j = 0; j < events.size(); j++) { + final String event = (String) events.get(j); + if (event != null ) { + final JSONParser parser = new JSONParser(JSONParser.MODE_PERMISSIVE); + final JSONObject eventObj = (JSONObject) parser.parse(event); + final String controlLoopName = vars.get("vFWControlLoop"); + if (eventObj.get("closedLoopControlName").equals(controlLoopName)) { + final String requestId = eventObj.get("requestId"); + final String notification = eventObj.get("notification"); + records.put(requestId, notification); + } + } + } + } + } + +boolean failure = false; +final String expectedNotification = "FINAL: FAILURE"; +final List cache = vars.getObject("vFWFailueCache"); + +for (int i = 0; i < cache.size(); i++) { + final String requestId = cache.get(i); + final String notification = records.get(requestId); + if (!(notification != null && expectedNotification.equals(notification))) { + log.error("[vFW] Assertion failed for requestId: " + requestId +" Expected notification: " + expectedNotification + " But found: " + notification); + failure = true; + } +} + +if (failure || cache.isEmpty()) { + final String error = "[vFW] Unable to find notification with " + expectedNotification + " in topic 'POLICY-CL-MGT'"; + AssertionResult.setFailureMessage(error); + AssertionResult.setFailure(true); + log.error(error); + log.info("[vFW] vFWCache: " + cache); + log.info("[vFW] Success Records found: " + records); + log.info("[vFW] " + result); +} else { + AssertionResult.setFailure(false); +} + + + + + + + + + + + + java + + + true + import java.util.ArrayList; +import java.util.List; + +final List vVOLTECache = new ArrayList(); +vars.putObject("vVOLTECache", vVOLTECache); + + + + + + true + + + import java.util.List; +import java.util.UUID; + +final List vVOLTECache = vars.getObject("vVOLTECache"); + +final String uuid = UUID.randomUUID().toString(); +vars.put("requestID",uuid); + +vVOLTECache.add(uuid); +log.debug("[VOLTE] requestID "+ uuid); + java + + + + 1 + ${size} + 1 + service-instance-id + volte-service-instance-id-0 + false + + + + 1 + ${size} + 1 + vserver-name + dnsvserver-name-0 + false + + + + true + + + + false + { + "closedLoopControlName":"${VOLTEControlLoop}", + "closedLoopAlarmStart":1484677482204798, + "closedLoopEventClient":"DCAE.HolmesInstance", + "closedLoopEventStatus":"ONSET", + "requestID":"${requestID}", + "target_type":"VM", + "target":"vserver.vserver-name", + "AAI":{ + "vserver.is-closed-loop-disabled":"false", + "vserver.vserver-name":"${vserver-name}", + "service-instance.service-instance-id":"vserver-name-${service-instance-id}", + "generic-vnf.vnf-id":"vnf-id-${service-instance-id}", + "generic-vnf.vnf-name":"vnf-name-${service-instance-id}" + }, + "from":"DCAE", + "version":"1.0.2" +} + = + + + + + + + + policy/pdp/engine/topics/sources/ueb/unauthenticated.DCAE_CL_OUTPUT/events + PUT + true + false + true + false + + + + + + + + 200 + + + Assertion.response_code + false + 8 + Response code + + + + + ${wait} + + + + ${threads} + ${threadsTimeOutInMs} + + + + + + + + + + + + + policy/pdp/engine/topics/sinks/noop/POLICY-CL-MGT + GET + true + false + true + false + + + + + + + result + $ + + + + + java + + + true + import net.minidev.json.parser.JSONParser; +import net.minidev.json.JSONObject; +import net.minidev.json.JSONArray; + +final Map records = new HashMap(); +final JSONParser p = new JSONParser(JSONParser.MODE_PERMISSIVE); + +final String result = vars.get("result"); +final JSONObject jsonObj = (JSONObject) p.parse(result); + + if (jsonObj != null) { + final JSONArray events = (JSONArray) jsonObj.get("recentEvents"); + if (events != null) { + for (int j = 0; j < events.size(); j++) { + final String event = (String) events.get(j); + if (event != null ) { + final JSONParser parser = new JSONParser(JSONParser.MODE_PERMISSIVE); + final JSONObject eventObj = (JSONObject) parser.parse(event); + final String controlLoopName = vars.get("VOLTEControlLoop"); + if (eventObj.get("closedLoopControlName").equals(controlLoopName)) { + final String requestId = eventObj.get("requestId"); + final String notification = eventObj.get("notification"); + records.put(requestId, notification); + } + } + } + } + } + +boolean failure = false; +final String expectedNotification = "FINAL: SUCCESS"; +final List cache = vars.getObject("vVOLTECache"); + +for (int i = 0; i < cache.size(); i++) { + final String requestId = cache.get(i); + final String notification = records.get(requestId); + if (!(notification != null && expectedNotification.equals(notification))) { + log.error("[VOLTE] Assertion failed for requestId: " + requestId +" Expected notification: " + expectedNotification + " But found: " + notification); + failure = true; + } +} + +if (failure || cache.isEmpty()) { + final String error = "[VOLTE] Unable to find notification with " + expectedNotification + " in topic 'POLICY-CL-MGT'"; + AssertionResult.setFailureMessage(error); + AssertionResult.setFailure(true); + log.error(error); + log.info("[VOLTE] vVOLTECache: " + cache); + log.info("[VOLTE] Success Records found: " + records); + log.info("[VOLTE] " + result); +} else { + AssertionResult.setFailure(false); +} + + + + + + + + + + + + + ${wait} + + + + + + + + + + + policy/pdp/engine/controllers/amsterdam/drools/facts/amsterdam/ + GET + true + false + true + false + + + + + + + + {"org.onap.policy.controlloop.Params":4} + + + Assertion.response_data + false + 16 + + + + + + + + false + + saveConfig + + + true + true + true + + true + true + true + true + false + true + true + false + false + false + true + false + false + false + true + 0 + true + true + true + true + true + + + + + + + false + + saveConfig + + + true + true + true + + true + true + true + true + false + true + true + false + false + false + true + false + false + false + true + 0 + true + true + true + true + true + + + + + + + false + + saveConfig + + + true + true + true + + true + true + true + true + false + true + true + false + false + false + true + false + false + false + true + 0 + true + true + true + true + true + + + + + + + + -- cgit 1.2.3-korg