Adding policy manager and a1 sdnc vth

[it/otf.git] / a1-sdnc-vth / app / helpers / ric_helper.py

diff --git a/a1-sdnc-vth/app/helpers/ric_helper.py b/a1-sdnc-vth/app/helpers/ric_helper.py
new file mode 100644 (file)
index 0000000..47d55c2
--- /dev/null
+++ b/a1-sdnc-vth/app/helpers/ric_helper.py
@@ -0,0 +1,37 @@
+from app.helpers import response_helper as ResponseHelper\r
+from flask import current_app\r
+from app.errors.bad_request_exception import BadRequestException\r
+\r
+def get_ric_using_get(request, response_dict, config):\r
+    json_data = request.get_json()\r
+    #username = config['auth']['username'] if 'username' not in json_data else json_data['username']\r
+    #password = config['auth']['password'] if 'password' not in json_data else json_data['password']\r
+    #creds = (username, password)\r
+    creds = ResponseHelper.get_credentials(json_data, config)\r
+    current_app.logger.info("creds: {}".format(creds))\r
+\r
+    keys = set(json_data.keys())\r
+    required = {'managedElementId'}\r
+    if not required <= keys: raise BadRequestException(406, "Request is missing required values {}".format(required))\r
+\r
+    param = {\r
+            'managedElementId': json_data['managedElementId']\r
+            }\r
+\r
+    response_dict['vthResponse']['resultData'] = param\r
+    #api_response = requests.get(url, credentials=creds, params=param)\r
+    return response_dict\r
+def get_rics_using_get(request, response_dict, config):\r
+    json_data = request.get_json()\r
+    #username = config['auth']['username'] if 'username' not in json_data else json_data['username']\r
+    #password = config['auth']['password'] if 'password' not in json_data else json_data['password']\r
+    #creds = (username, password)\r
+    creds = ResponseHelper.get_credentials(json_data, config)\r
+    current_app.logger.info("creds: {}".format(creds))\r
+    param = {\r
+            "policyType": json_data["policyType"] if "policyType" in json_data else ""\r
+            }\r
+\r
+    response_dict['vthResponse']['resultData'] = param\r
+    #api_response = requests.get(url, credentials=creds, params=param)\r
+    return response_dict\r