X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=scripts%2Fdcaegen2-services-slice-analysis-ms%2Fslice-analysis-ms%2Fconfigdb-des-sim.py;fp=scripts%2Fdcaegen2-services-slice-analysis-ms%2Fconfigdb-sim.py;h=fb7915622a097a780f061f156002c89593df4cdd;hb=refs%2Fchanges%2F99%2F127999%2F3;hp=bcda08d5aaf4a6eacfc8dd69da82b375252a7bf8;hpb=8f88f01b9fbbdd2af363a747ecf43b9de15a9b6e;p=integration%2Fcsit.git

diff --git a/scripts/dcaegen2-services-slice-analysis-ms/configdb-sim.py b/scripts/dcaegen2-services-slice-analysis-ms/slice-analysis-ms/configdb-des-sim.py
similarity index 82%
rename from scripts/dcaegen2-services-slice-analysis-ms/configdb-sim.py
rename to scripts/dcaegen2-services-slice-analysis-ms/slice-analysis-ms/configdb-des-sim.py
index bcda08d5..fb791562 100644
--- a/scripts/dcaegen2-services-slice-analysis-ms/configdb-sim.py
+++ b/scripts/dcaegen2-services-slice-analysis-ms/slice-analysis-ms/configdb-des-sim.py
@@ -70,6 +70,17 @@ def get_subscriber_details_for_nssai(snssai):
         return {"Error": "Unable to read file"}, 503
     return data, None
 
+def get_pm_data_for_snssai(snssai):
+    if str(snssai) == 'SM.PrbUsedDl.01-06E442':
+        with open('pm_data_01_06E442.json') as pm_data:
+            data = json.load(pm_data)
+    else:
+        with open('pm_data_01_B989BD.json') as pm_data:
+            data = json.load(pm_data)
+    if not data:
+        return {"Error": "Unable to read file"}, 503
+    return data, None
+
 
 @app.route("/api/sdnc-config-db/v4/du-list/<snssai>", methods=["GET"])
 def get_du_list(snssai):
@@ -111,5 +122,17 @@ def get_subscriber_details(snssai):
         return jsonify(data)
     return data, 503
 
+@app.route("/datalake/v1/exposure/pm_data",
+           methods=["POST"])
+def get_pm_data():
+    request_data = request.get_json()
+    snssai = None
+    if request_data:
+        if 'snssai' in request_data:
+            snssai = request_data['snssai']
+            data, status = get_pm_data_for_snssai(snssai)
+    if not status:
+        return jsonify(data)
+    return data, 503
 
 app.run(host='0.0.0.0')