1 files changed, 76 insertions, 0 deletions
diff --git a/moonv4/moon_wrapper/moon_wrapper/http_server.py b/moonv4/moon_wrapper/moon_wrapper/http_server.py
new file mode 100644
index 00000000..ba2caf84
--- /dev/null
+++ b/moonv4/moon_wrapper/moon_wrapper/http_server.py
@@ -0,0 +1,76 @@
+# Copyright 2015 Open Platform for NFV Project, Inc. and its contributors
+# This software is distributed under the terms and conditions of the 'Apache-2.0'
+# license which can be found in the file 'LICENSE' in this package distribution
+# or at 'http://www.apache.org/licenses/LICENSE-2.0'.
+
+import requests
+import json
+from flask import Flask, request
+import logging
+from moon_utilities import configuration
+
+logger = logging.getLogger("moon.wrapper.http")
+
+
+def __get_subject(target, credentials):
+    _subject = target.get("user_id", "")
+    if not _subject:
+        _subject = credentials.get("user_id", "")
+    return _subject
+
+
+def __get_object(target, credentials):
+    try:
+        # note: case of Glance
+        return target['target']['name']
+    except KeyError:
+        pass
+
+    # note: default case
+    return target.get("project_id", "")
+
+
+def __get_project_id(target, credentials):
+    return target.get("project_id", "")
+
+
+def HTTPServer(host, port):
+    app = Flask(__name__)
+    conf = configuration.get_configuration("components/wrapper")
+    timeout = conf["components/wrapper"].get("timeout", 5)
+    conf = configuration.get_configuration("components/interface")
+    interface_hostname = conf["components/interface"].get("hostname", "interface")
+    interface_port = conf["components/interface"].get("port", 80)
+    conf = configuration.get_configuration("logging")
+    try:
+        debug = conf["logging"]["loggers"]['moon']['level'] == "DEBUG"
+    except KeyError:
+        debug = False
+
+    @app.route("/", methods=['POST', 'GET'])
+    def wrapper():
+        try:
+            target = json.loads(request.form.get('target', {}))
+            credentials = json.loads(request.form.get('credentials', {}))
+            rule = request.form.get('rule', "")
+            _subject = __get_subject(target, credentials)
+            _object = __get_object(target, credentials)
+            _project_id = __get_project_id(target, credentials)
+            logger.info("GET with args {} / {} - {} - {}".format(_project_id, _subject, _object, rule))
+            _url = "http://{}:{}/{}/{}/{}/{}".format(
+                interface_hostname,
+                interface_port,
+                _project_id,
+                _subject,
+                _object,
+                rule
+            )
+            req = requests.get(url=_url, timeout=timeout)
+            logger.info("req txt={}".format(req.text))
+            if req.json()["result"] == True:
+                return "True"
+        except Exception as e:
+            logger.exception("An exception occurred: {}".format(e))
+        return "False"
+
+    app.run(debug=debug, host=host, port=port)