Add metadata filtering

Issue-ID: DCAEGEN2-1286
Change-Id: Icfee7f24cb97b429e8b0db2d67da2f21e413cea0
Signed-off-by: dfarrelly <david.farrelly@est.tech>

5 files changed, 83 insertions, 2 deletions

diff --git a/src/test/resources/incorrect_metadata.json b/src/test/resources/incorrect_metadata.json
new file mode 100644
index 0000000..e61e94f
--- /dev/null
+++ b/src/test/resources/incorrect_metadata.json
@@ -0,0 +1,12 @@
+{
+  "productName": "LTE",
+  "vendorName": "Ericsson",
+  "lastEpochMicrosec": "1538478000000",
+  "sourceName": "oteNB5309",
+  "startEpochMicrosec": "1538478900000",
+  "timeZoneOffset": "UTC+05.00",
+  "location": "ftpes://192.168.0.101:22/ftp/rop/A20161224.1045-1100.bin.gz",
+  "compression": "gzip",
+  "fileFormatType": "org.3GPP.32.435#measCollec",
+  "fileFormatVersion": "V8"
+}
\ No newline at end of file
diff --git a/src/test/resources/multiple_filter_mapper_config.json b/src/test/resources/multiple_filter_mapper_config.json
new file mode 100644
index 0000000..89bca57
--- /dev/null
+++ b/src/test/resources/multiple_filter_mapper_config.json
@@ -0,0 +1,34 @@
+{
+  "pm-mapper-filter": {"filters":[{"pmDefVsn": "V8","nfType": "LTE","vendor": "Ericsson","measTypes": [ "A", "B" ]},{"pmDefVsn": "V9","nfType": "NrRadio","vendor": "Ericsson","measTypes": [ "A", "B" ]}]},
+  "streams_subscribes": {
+    "dmaap_subscriber": {
+      "type": "data_router",
+      "aaf_username": null,
+      "aaf_password": null,
+      "dmaap_info": {
+        "location": "location",
+        "delivery_url": "delivery_url",
+        "username": "username",
+        "password": "password",
+        "subscriber_id": "subscriber_id"
+      }
+    }
+  },
+  "streams_publishes": {
+    "dmaap_publisher": {
+      "type": "message_router",
+      "aaf_password": null,
+      "dmaap_info": {
+        "topic_url": "https://message-router.onap.svc.cluster.local:3904/events/some-topic",
+        "client_role": null,
+        "location": null,
+        "client_id": null
+      },
+      "aaf_username": null
+    }
+  },
+  "dmaap_dr_feed_id": "2",
+  "buscontroller_feed_subscription_endpoint": "http://dmaap-bc.onap.svc.cluster.local:8080/webapi/dr_subs",
+  "dmaap_dr_delete_endpoint": "http://dmaap-dr-node.onap.svc.cluster.local:8443/delete",
+  "services_calls": {}
+}
\ No newline at end of file
diff --git a/src/test/resources/no_filter_mapper_config.json b/src/test/resources/no_filter_mapper_config.json
new file mode 100644
index 0000000..3f855cf
--- /dev/null
+++ b/src/test/resources/no_filter_mapper_config.json
@@ -0,0 +1,34 @@
+{
+  "pm-mapper-filter": {"filters":[]},
+  "streams_subscribes": {
+    "dmaap_subscriber": {
+      "type": "data_router",
+      "aaf_username": null,
+      "aaf_password": null,
+      "dmaap_info": {
+        "location": "location",
+        "delivery_url": "delivery_url",
+        "username": "username",
+        "password": "password",
+        "subscriber_id": "subscriber_id"
+      }
+    }
+  },
+  "streams_publishes": {
+    "dmaap_publisher": {
+      "type": "message_router",
+      "aaf_password": null,
+      "dmaap_info": {
+        "topic_url": "https://message-router.onap.svc.cluster.local:3904/events/some-topic",
+        "client_role": null,
+        "location": null,
+        "client_id": null
+      },
+      "aaf_username": null
+    }
+  },
+  "dmaap_dr_feed_id": "2",
+  "buscontroller_feed_subscription_endpoint": "http://dmaap-bc.onap.svc.cluster.local:8080/webapi/dr_subs",
+  "dmaap_dr_delete_endpoint": "http://dmaap-dr-node.onap.svc.cluster.local:8443/delete",
+  "services_calls": {}
+}
\ No newline at end of file
diff --git a/src/test/resources/valid_mapper_config.json b/src/test/resources/valid_mapper_config.json
index 6cd76bd..040406f 100644
--- a/src/test/resources/valid_mapper_config.json
+++ b/src/test/resources/valid_mapper_config.json
@@ -1,5 +1,5 @@
 {

-    "pm-mapper-filter": {"filters":[]},

+    "pm-mapper-filter": {"filters":[{"pmDefVsn": "V9","nfType": "NrRadio","vendor": "Ericsson","measTypes": [ "A", "B" ]}]},

     "streams_subscribes": {

         "dmaap_subscriber": {

             "type": "data_router",

diff --git a/src/test/resources/valid_metadata.json b/src/test/resources/valid_metadata.json
index 21de3fb..cf21437 100644
--- a/src/test/resources/valid_metadata.json
+++ b/src/test/resources/valid_metadata.json
@@ -8,5 +8,6 @@
   "location": "ftpes://192.168.0.101:22/ftp/rop/A20161224.1045-1100.bin.gz",
   "compression": "gzip",
   "fileFormatType": "org.3GPP.32.435#measCollec",
-  "fileFormatVersion": "V9"
+  "fileFormatVersion": "V9",
+  "decompression_status": "false"
 }
\ No newline at end of file