commit 20da522bf441015f55cb35f3b904ef3d9b388154
author ecaiyanlinux <martin.c.yan@est.tech> Tue May 11 22:54:26 2021 +0800
committer ecaiyanlinux <martin.c.yan@est.tech> Mon May 31 23:07:50 2021 +0800
tree 2292bc312d26b5f0f6b4c85096a013bb1a06ef99
parent 01b64b350211e0bfc16af343402dedc55020917b

Add k8s yml file for oru application

kubernetes deployment file for oru application

Change-Id: I6608a544a75dca1f7bad0c827201d5ed95bedbfb
Issue-ID: NONRTRIC-496
Signed-off-by: ecaiyanlinux <martin.c.yan@est.tech>

test/mrstub/app/main.py

diff --git a/test/mrstub/app/main.py b/test/mrstub/app/main.py
index 40707d6..90924b1 100644
--- a/test/mrstub/app/main.py
+++ b/test/mrstub/app/main.py
@@ -54,6 +54,8 @@
 cntr_msg_responses_fetched=0
 
 # Request and response constants
+ORU_WRITE_URL="/events/unauthenticated.SEC_FAULT_OUTPUT"
+ORU_READ_URL="/events/unauthenticated.SEC_FAULT_OUTPUT/users/test/"
 AGENT_WRITE_URL="/events/A1-POLICY-AGENT-WRITE"
 AGENT_READ_URL="/events/A1-POLICY-AGENT-READ/users/policy-agent"
 APP_WRITE_URL="/send-request"
@@ -344,6 +346,24 @@
 
         return Response('{}', status=200, mimetype=MIME_JSON)
 
+@app.route(ORU_WRITE_URL,
+    methods=['PUT','POST'])
+def oru_write():
+    global msg_requests
+    msg=json.dumps(request.json)
+    msg_requests.append(msg)
+    return Response('{}', status=200, mimetype=MIME_JSON)
+
+@app.route(ORU_READ_URL,
+    methods=['GET'])
+def oru_read():
+    global msg_requests
+    if(len(msg_requests)>0):
+        rsp=msg_requests.pop(0)
+        res=[]
+        res.append(rsp)
+        return Response(json.dumps(res), status=200, mimetype=MIME_JSON)
+    return Response("[]", status=200, mimetype=MIME_JSON)
 
 ### Functions for metrics read out ###