1 files changed, 138 insertions, 0 deletions
diff --git a/old/moon_bouchon/moon_bouchon/server.py b/old/moon_bouchon/moon_bouchon/server.py
new file mode 100644
index 00000000..29e9101e
--- /dev/null
+++ b/old/moon_bouchon/moon_bouchon/server.py
@@ -0,0 +1,138 @@
+# 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 sys
+import flask
+from flask import Flask
+from flask import request
+import json
+import logging
+import random
+
+logger = logging.getLogger(__name__)
+app = Flask(__name__)
+
+
+@app.route("/interface/authz/grant/<string:project_id>/<string:subject_name>/"
+           "<string:object_name>/<string:action_name>",
+           methods=["GET"])
+def interface_grant(project_id, subject_name, object_name, action_name):
+    logger.info("Requesting interface authz on {} {} {} {}".format(
+        project_id, subject_name, object_name, action_name))
+    return json.dumps({
+        "result": True,
+        "context": {
+            "project_id": project_id,
+            "subject_name": subject_name,
+            "object_name": object_name,
+            "action_name": action_name
+        }
+    })
+
+
+@app.route("/interface/authz/deny/<string:project_id>/<string:subject_name>/"
+           "<string:object_name>/<string:action_name>",
+           methods=["GET"])
+def interface_deny(project_id, subject_name, object_name, action_name):
+    logger.info("Requesting interface authz on {} {} {} {}".format(
+        project_id, subject_name, object_name, action_name))
+    return json.dumps({
+        "result": False,
+        "context": {
+            "project_id": project_id,
+            "subject_name": subject_name,
+            "object_name": object_name,
+            "action_name": action_name
+        }
+    })
+
+
+@app.route("/interface/authz/<string:project_id>/<string:subject_name>/"
+           "<string:object_name>/<string:action_name>",
+           methods=["GET"])
+def interface_authz(project_id, subject_name, object_name, action_name):
+    logger.info("Requesting interface authz on {} {} {} {}".format(
+        project_id, subject_name, object_name, action_name))
+    return json.dumps({
+        "result": random.choice((True, False)),
+        "context": {
+            "project_id": project_id,
+            "subject_name": subject_name,
+            "object_name": object_name,
+            "action_name": action_name
+        }
+    })
+
+
+def test_data():
+    data = request.form
+    if not dict(request.form):
+        data = json.loads(request.data.decode("utf-8"))
+    try:
+        target = json.loads(data.get('target', {}))
+    except Exception:
+        raise Exception("Error reading target")
+    try:
+        credentials = json.loads(data.get('credentials', {}))
+    except Exception:
+        raise Exception("Error reading credentials")
+    try:
+        rule = data.get('rule', "")
+    except Exception:
+        raise Exception("Error reading rule")
+
+
+@app.route("/wrapper/authz/grant", methods=["POST"])
+def wrapper_grant():
+    logger.info("Requesting wrapper authz")
+    try:
+        test_data()
+    except Exception as e:
+        logger.exception(e)
+        return str(e), 400
+    response = flask.make_response("True")
+    response.headers['content-type'] = 'application/octet-stream'
+    return response
+
+
+@app.route("/wrapper/authz/deny", methods=["POST"])
+def wrapper_deny():
+    logger.info("Requesting wrapper authz")
+    try:
+        test_data()
+    except Exception as e:
+        logger.exception(e)
+        return str(e), 400
+    response = flask.make_response("False")
+    response.headers['content-type'] = 'application/octet-stream'
+    return response
+
+
+@app.route("/wrapper/authz", methods=["POST"])
+def wrapper_authz():
+    logger.info("Requesting wrapper authz")
+    try:
+        test_data()
+    except Exception as e:
+        logger.exception(e)
+        return str(e), 400
+    response = flask.make_response(random.choice(("True", "False")))
+    response.headers['content-type'] = 'application/octet-stream'
+    return response
+
+
+def main():
+    port = 31002
+    if len(sys.argv) > 1:
+        try:
+            port = int(sys.argv[1])
+        except ValueError:
+            logger.error("Argument for Port in command line is not an integer")
+            sys.exit(1)
+    app.run(host="0.0.0.0", port=port)
+
+
+if __name__ == "__main__":
+    main()