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

diff --git a/tests/test_rest.py b/tests/test_rest.py
new file mode 100644
index 0000000..d03e594
--- /dev/null
+++ b/tests/test_rest.py
@@ -0,0 +1,74 @@
+import requests
+import ricxappframe.xapp_rest
+
+
+def doGetRequest(url):
+    proxies = {"http": "", "https": ""}    # disable proxy usage
+    return requests.get(url, proxies=proxies)
+
+
+def doDeleteRequest(url):
+    proxies = {"http": "", "https": ""}    # disable proxy usage
+    return requests.delete(url, proxies=proxies)
+
+
+def doPostRequest(url, data):
+    proxies = {"http": "", "https": ""}    # disable proxy usage
+    return requests.post(url, data, proxies=proxies)
+
+
+def respPostHandler(name, path, data, ctype):
+    response = ricxappframe.xapp_rest.initResponse()
+    response['payload'] = data.decode("utf-8")
+    return response
+
+
+def respGetHandler(name, path, data, ctype):
+    response = ricxappframe.xapp_rest.initResponse()
+    response['payload'] = ('{ "Testitem": "Testdata"}')
+    return response
+
+
+def respDeleteHandler(name, path, data, ctype):
+    response = ricxappframe.xapp_rest.initResponse()
+    response['payload'] = None
+    response['status'] = 204
+    return response
+
+
+def respGetEmptyHandler(name, path, data, ctype):
+    response = ricxappframe.xapp_rest.initResponse()
+    response['payload'] = None
+    response['status'] = 204
+    return response
+
+
+def test_subscribe(monkeypatch):
+
+    server = ricxappframe.xapp_rest.ThreadedHTTPServer("127.0.0.1", 18088)
+    # trick to get the own handler with defined
+    server.handler.add_handler(server.handler, "GET", "get", "/ric/v1/subscriptions", respGetHandler)
+    server.handler.add_handler(server.handler, "GET", "getempty", "/ric/v1/empty", respGetEmptyHandler)
+    server.handler.add_handler(server.handler, "POST", "post", "/ric/v1", respPostHandler)
+    server.handler.add_handler(server.handler, "DELETE", "delete", "/ric/v1/delete", respDeleteHandler)
+    server.start()
+
+    resp = doGetRequest('http://127.0.0.1:18088/ric/v1/subscriptions')
+    assert resp.text == '{ "Testitem": "Testdata"}'
+    assert resp.status_code == 200
+
+    resp = doGetRequest('http://127.0.0.1:18088/ric/v1/empty')
+    assert resp.text == ""
+    assert resp.status_code == 204
+
+    resp = doPostRequest('http://127.0.0.1:18088/ric/v1', '{"Testdataitem": "foobar"}')
+    assert resp.text == '{"Testdataitem": "foobar"}'
+    assert resp.status_code == 200
+
+    resp = doDeleteRequest('http://127.0.0.1:18088/ric/v1/delete')
+    assert resp.text == ""
+    assert resp.status_code == 204
+    # not found case
+    resp = doGetRequest('http://127.0.0.1:18088/ricci/v1/subscriptions')
+    assert resp.text == ""
+    assert resp.status_code == 404