[DCAEGEN2] Enhance (KPI-MS) KpiComputation for SUM-RATIO operation.

Issue-ID: DCAEGEN2-2989
Signed-off-by: Venkata Molluru <venkatamuralimohanreddy.molluru@techmahindra.com>
Change-Id: Iba9dc9cab49fc085dc2f987cea65ad258d937d5b

5 files changed, 320 insertions, 0 deletions

diff --git a/components/kpi-computation-ms/src/test/resources/kpi/cbs_config3.json b/components/kpi-computation-ms/src/test/resources/kpi/cbs_config3.json
new file mode 100644
index 00000000..33ae3111
--- /dev/null
+++ b/components/kpi-computation-ms/src/test/resources/kpi/cbs_config3.json
@@ -0,0 +1,38 @@
+{
+    "config": {
+        "pollingInterval": 20,
+        "aafUsername": "dcae@dcae.onap.org",
+        "cbsPollingInterval": 60,
+        "mongo.host": "192.168.225.61",
+        "cid": "kpi-cid",
+        "trust_store_pass_path": "/opt/app/kpims/etc/cert/trust.pass",
+        "cg": "kpi-cg",
+        "mongo.port": 27017,
+        "mongo.databasename": "datalake",
+        "streams_subscribes": {
+            "performance_management_topic": {
+                "aaf_password": "demo123456!",
+                "type": "message-router",
+                "dmaap_info": {
+                    "topic_url": "https://message-router.onap.svc.cluster.local:3905/events/org.onap.dmaap.mr.PERFORMANCE_MEASUREMENTS"
+                },
+                "aaf_username": "dcae@dcae.onap.org"
+            }
+        },
+        "trust_store_path": "/opt/app/kpims/etc/cert/trust.jks",
+        "pollingTimeout": 60,
+        "streams_publishes": {
+            "kpi_topic": {
+                "aaf_password": "demo123456!",
+                "type": "message-router",
+                "dmaap_info": {
+                    "topic_url": "https://message-router.onap.svc.cluster.local:3905/events/unauthenticated.DCAE_KPI_OUTPUT"
+                },
+                "aaf_username": "dcae@dcae.onap.org"
+            }
+        },
+        "aafPassword": "demo123456!",
+        "kpi.policy": "{\"domain\":\"measurementsForKpi\",\"methodForKpi\":[{\"eventName\":\"perf3gpp_CORE-AMF_pmMeasResult\",\"controlLoopSchemaType\":\"SLICE\",\"policyScope\":\"resource=networkSlice;type=configuration\",\"policyName\":\"configuration.dcae.microservice.pm-mapper.xml\",\"policyVersion\":\"v0.0.1\",\"kpis\":[{\"measType\":\"AMFRegNbr\",\"operation\":\"SUM\",\"operands\":[\"RM.RegisteredSubNbrMean\"]}]},{\"eventName\":\"perf3gpp_AcmeNode-Acme_pmMeasResult\",\"controlLoopSchemaType\":\"SLICE\",\"policyScope\":\"resource=networkSlice;type=configuration\",\"policyName\":\"configuration.dcae.microservice.pm-mapper.xml\",\"policyVersion\":\"v0.0.1\",\"kpis\":[{\"measType\":\"UpstreamThr\",\"operation\":\"SUMRATIO\",\"operands\":[\"GTP.InDataOctN3UPF\",\"GTP.OutDataOctN3UPF\"]},{\"measType\":\"DownstreamThr\",\"operation\":\"SUMRATIO\",\"operands\":[\"GTP.InDataOctN3UPF\",\"GTP.OutDataOctN3UPF\"]}]}]}",
+        "dmaap.server": ["message-router"]
+    }
+}
diff --git a/components/kpi-computation-ms/src/test/resources/kpi/kpi_config_sumratio.json b/components/kpi-computation-ms/src/test/resources/kpi/kpi_config_sumratio.json
new file mode 100644
index 00000000..1c6f79b9
--- /dev/null
+++ b/components/kpi-computation-ms/src/test/resources/kpi/kpi_config_sumratio.json
@@ -0,0 +1,34 @@
+{
+    "domain": "measurementsForKpi",
+    "methodForKpi": [{
+            "eventName": "perf3gpp_CORE_AMF_pmMeasResult",
+            "controlLoopSchemaType": "SLICE",
+            "policyScope": "resource=networkSlice;type=configuration",
+            "policyName": "configuration.dcae.microservice.pm-mapper.xml",
+            "policyVersion": "v0.0.1",
+            "kpis": [{
+                "measType": "AMFRegNbr",
+                "operation": "SUM",
+                "operands": ["RM.RegisteredSubNbrMean"]
+            }]
+        },
+        {
+            "eventName": "perf3gpp_AcmeNode-Acme_pmMeasResult",
+            "controlLoopSchemaType": "SLICE",
+            "policyScope": "resource=networkSlice;type=configuration",
+            "policyName": "configuration.dcae.microservice.pm-mapper.xml",
+            "policyVersion": "v0.0.1",
+            "kpis": [{
+                    "measType": "UpstreamThr",
+                    "operation": "SUMRATIO",
+                    "operands": ["GTP.InDataOctN3UPF","GTP.OutDataOctN3UPF"]
+                },
+                {
+                    "measType": "DownstreamThr",
+                    "operation": "SUMRATIO",
+                    "operands": ["GTP.InDataOctN3UPF","GTP.OutDataOctN3UPF"]
+                }
+            ]
+        }
+    ]
+}
diff --git a/components/kpi-computation-ms/src/test/resources/kpi/ves_message_empty.json b/components/kpi-computation-ms/src/test/resources/kpi/ves_message_empty.json
new file mode 100644
index 00000000..b2988a33
--- /dev/null
+++ b/components/kpi-computation-ms/src/test/resources/kpi/ves_message_empty.json
@@ -0,0 +1,84 @@
+{
+    "event": {
+        "commonEventHeader": {
+            "domain": "perf3gpp",
+            "eventId": "14618daf-c0ce-4ccc-9169-9e1ac79971f2",
+            "sequence": 0,
+            "eventName": "perf3gpp_AcmeNode-Acme_pmMeasResult",
+            "sourceName": "oteNB5309",
+            "reportingEntityName": "",
+            "priority": "Normal",
+            "startEpochMicrosec": 1591099200000,
+            "lastEpochMicrosec": 1591100100000,
+            "version": "4.0",
+            "vesEventListenerVersion": "7.1",
+            "timeZoneOffset": "UTC+05:00"
+        },
+        "perf3gppFields": {
+            "perf3gppFieldsVersion": "1.0",
+            "measDataCollection": {
+                "granularityPeriod": 1591100100000,
+                "measuredEntityUserName": "",
+                "measuredEntityDn": "UPFMeasurement",
+                "measuredEntitySoftwareVersion": "r0.1",
+                "measInfoList": [
+                    {
+                        "measInfoId": {
+                            "sMeasInfoId": "UPFFunction0"
+                        },
+                        "measTypes": {
+                            "sMeasTypesList": [
+                                "RRC.RrcConnectionSuccess.08_010101",
+                                "RRC.RrcConnectionTotal.08_010101"
+                            ]
+                        },
+                        "measValuesList": [
+                            {
+                                "measObjInstId": "some measObjLdn",
+                                "suspectFlag": "false",
+                                "measResults": [
+                                    {
+                                        "p": 1,
+                                        "sValue": "10"
+                                    },
+                                    {
+                                        "p": 2,
+                                        "sValue": "0"
+                                    }
+                                ]
+                            }
+                        ]
+                    },
+                    {
+                        "measInfoId": {
+                            "sMeasInfoId": "UPFFunction1"
+                        },
+                        "measTypes": {
+                            "sMeasTypesList": [
+                                "RRC.RrcConnectionSuccess.08_010101",
+                                "RRC.RrcConnectionTotal.08_010101"
+                            ]
+                        },
+                        "measValuesList": [
+                            {
+                                "measObjInstId": "some measObjLdn",
+                                "suspectFlag": "false",
+                                "measResults": [
+                                    {
+                                        "p": 1,
+                                        "sValue": "30"
+                                    },
+                                    {
+                                        "p": 2,
+                                        "sValue": "0"
+                                    }
+                                ]
+                            }
+                        ]
+                    }
+                ]
+            }
+        }
+    }
+}
+
diff --git a/components/kpi-computation-ms/src/test/resources/kpi/ves_message_eventname.json b/components/kpi-computation-ms/src/test/resources/kpi/ves_message_eventname.json
new file mode 100644
index 00000000..be7225e0
--- /dev/null
+++ b/components/kpi-computation-ms/src/test/resources/kpi/ves_message_eventname.json
@@ -0,0 +1,84 @@
+{
+    "event": {
+        "commonEventHeader": {
+            "domain": "perf3gpp",
+            "eventId": "14618daf-c0ce-4ccc-9169-9e1ac79971f2",
+            "sequence": 0,
+            "eventName": "perf3gpp_AcmeNode-Acme",
+            "sourceName": "oteNB5309",
+            "reportingEntityName": "",
+            "priority": "Normal",
+            "startEpochMicrosec": 1591099200000,
+            "lastEpochMicrosec": 1591100100000,
+            "version": "4.0",
+            "vesEventListenerVersion": "7.1",
+            "timeZoneOffset": "UTC+05:00"
+        },
+        "perf3gppFields": {
+            "perf3gppFieldsVersion": "1.0",
+            "measDataCollection": {
+                "granularityPeriod": 1591100100000,
+                "measuredEntityUserName": "",
+                "measuredEntityDn": "UPFMeasurement",
+                "measuredEntitySoftwareVersion": "r0.1",
+                "measInfoList": [
+                    {
+                        "measInfoId": {
+                            "sMeasInfoId": "UPFFunction0"
+                        },
+                        "measTypes": {
+                            "sMeasTypesList": [
+                                "RRC.RrcConnectionSuccess.08_010101",
+                                "RRC.RrcConnectionTotal.08_010101"
+                            ]
+                        },
+                        "measValuesList": [
+                            {
+                                "measObjInstId": "some measObjLdn",
+                                "suspectFlag": "false",
+                                "measResults": [
+                                    {
+                                        "p": 1,
+                                        "sValue": "10"
+                                    },
+                                    {
+                                        "p": 2,
+                                        "sValue": "20"
+                                    }
+                                ]
+                            }
+                        ]
+                    },
+                    {
+                        "measInfoId": {
+                            "sMeasInfoId": "UPFFunction1"
+                        },
+                        "measTypes": {
+                            "sMeasTypesList": [
+                                "RRC.RrcConnectionSuccess.08_010101",
+                                "RRC.RrcConnectionTotal.08_010101"
+                            ]
+                        },
+                        "measValuesList": [
+                            {
+                                "measObjInstId": "some measObjLdn",
+                                "suspectFlag": "false",
+                                "measResults": [
+                                    {
+                                        "p": 1,
+                                        "sValue": "30"
+                                    },
+                                    {
+                                        "p": 2,
+                                        "sValue": "40"
+                                    }
+
+                                ]
+                            }
+                        ]
+                    }
+                ]
+            }
+        }
+    }
+}
diff --git a/components/kpi-computation-ms/src/test/resources/kpi/ves_message_null.json b/components/kpi-computation-ms/src/test/resources/kpi/ves_message_null.json
new file mode 100644
index 00000000..98656859
--- /dev/null
+++ b/components/kpi-computation-ms/src/test/resources/kpi/ves_message_null.json
@@ -0,0 +1,80 @@
+{
+    "event": {
+        "commonEventHeader": {
+            "domain": "perf3gpp",
+            "eventId": "14618daf-c0ce-4ccc-9169-9e1ac79971f2",
+            "sequence": 0,
+            "eventName": "perf3gpp_AcmeNode-Acme_pmMeasResult",
+            "sourceName": "oteNB5309",
+            "reportingEntityName": "",
+            "priority": "Normal",
+            "startEpochMicrosec": 1591099200000,
+            "lastEpochMicrosec": 1591100100000,
+            "version": "4.0",
+            "vesEventListenerVersion": "7.1",
+            "timeZoneOffset": "UTC+05:00"
+        },
+        "perf3gppFields": {
+            "perf3gppFieldsVersion": "1.0",
+            "measDataCollection": {
+                "granularityPeriod": 1591100100000,
+                "measuredEntityUserName": "",
+                "measuredEntityDn": "UPFMeasurement",
+                "measuredEntitySoftwareVersion": "r0.1",
+                "measInfoList": [
+                    {
+                        "measInfoId": {
+                            "sMeasInfoId": "UPFFunction0"
+                        },
+                        "measTypes": {
+                            "sMeasTypesList": [
+                                "RRC.RrcConnectionSuccess.08_010101",
+                                "RRC.RrcConnectionTotal.08_010101"
+                            ]
+                        },
+                        "measValuesList": [
+                            {
+                                "measObjInstId": "some measObjLdn",
+                                "suspectFlag": "false",
+                                "measResults": [
+                                    {
+                                        "p": 1,
+                                        "sValue": "10"
+                                    },
+                                    {
+                                        "p": 2,
+                                        "sValue": "20"
+                                    }
+                                ]
+                            }
+                        ]
+                    },
+                    {
+                        "measInfoId": {
+                            "sMeasInfoId": "UPFFunction1"
+                        },
+                        "measTypes": {
+                            "sMeasTypesList": [
+                                "RRC.RrcConnectionSuccess.08_010101",
+                                "RRC.RrcConnectionTotal.08_010101"
+                            ]
+                        },
+                        "measValuesList": [
+                            {
+                                "measObjInstId": "some measObjLdn",
+                                "suspectFlag": "false",
+                                "measResults": [
+                                    {
+                                        "p": 1,
+                                        "sValue": "30"
+                                    }
+                                ]
+                            }
+                        ]
+                    }
+                ]
+            }
+        }
+    }
+}
+