X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=examples%2Frestserversimu.py;fp=examples%2Frestserversimu.py;h=bf7e20e098a648b5df0f0bed75456740a55bab5b;hb=12486343219663d484705f05ab8d2ed3306f66d7;hp=0000000000000000000000000000000000000000;hpb=9c09be1e9598d4e145faea412b047b64d38feb22;p=ric-plt%2Fxapp-frame-py.git

diff --git a/examples/restserversimu.py b/examples/restserversimu.py
new file mode 100644
index 0000000..bf7e20e
--- /dev/null
+++ b/examples/restserversimu.py
@@ -0,0 +1,82 @@
+import sys
+import time
+import json
+import argparse
+
+sys.path.insert(0, './')
+
+import ricxappframe.xapp_rest as ricrest
+
+def respPostHandler(name, path, data, ctype):
+    print(name)
+    print(path)
+    print(data)
+    response = ricrest.initResponse()
+    response['payload'] = ('{ "SubscriptionResponse": {'
+        '"SubscriptionId": "testing",'
+        '"SubscriptionInstances": [{'
+            '"XappEventInstanceID": "16253",'
+            '"E2EventInstanceID": "1241"'
+            '}]'
+        '}'
+    '}')
+    return response
+
+
+def respSymptomGetHandler(name, path, data, ctype):
+    print(name)
+    print(path)
+    response = ricrest.initResponse()
+    response['payload'] = ('[{"service" : "xapp-test"}]')
+    print(json.loads(response['payload']))
+    return response
+
+def respGetHandler(name, path, data, ctype):
+    print(name)
+    print(path)
+    response = ricrest.initResponse()
+    response['payload'] = ('{ "SubscriptionList": [{'
+            '"SubscriptionId": "12345",'
+            '"Meid": "gnb123456",'
+			'"ClientEndpoint": ["127.0.0.1:4056"],'
+            '"SubscriptionInstances": [{'
+                '"XappEventInstanceID": "16253",'
+                '"E2EventInstanceID": "1241"'
+                '}]'
+            '}]'
+        '}')
+    return response
+
+def respDeleteHandler(name, path, data, ctype):
+    print(name)
+    print(path)
+    response = ricrest.initResponse()
+    response['payload'] = ('{}')
+    return response
+
+if __name__ == "__main__":
+    parser = argparse.ArgumentParser()
+    parser.add_argument('-port', dest='port', help='HTTP rest server listen port', required=False, type=int)
+    parser.add_argument('-address', dest='address', help='HTTP rest IP listen address, default all interfaces', required=False, type=str)
+    
+    args = parser.parse_args()
+    
+    if args.port is None:
+        args.port = 8088 
+    if args.address is None:
+        args.address = "0.0.0.0"
+
+    # create the thread HTTP server
+    server = ricrest.ThreadedHTTPServer(args.address, args.port)
+    # trick to get the own handler with defined 
+    server.handler.add_handler(server.handler, "GET", "response", "/ric/v1/subscriptions", respGetHandler)
+    server.handler.add_handler(server.handler, "DELETE", "delete", "/ric/v1/subscriptions/", respDeleteHandler)
+    server.handler.add_handler(server.handler, "GET", "lwsdget", "/ric/v1/lwsd", respSymptomGetHandler)
+    server.handler.add_handler(server.handler, "POST", "lwsdpost", "/ric/v1/lwsd", respSymptomGetHandler)
+    server.handler.add_handler(server.handler, "POST", "responsepost", "/ric/v1", respPostHandler)
+    # for symptomdata subscription
+
+    server.start()
+    while True:
+        time.sleep(60)
+    server.stop()