1 files changed, 110 insertions, 0 deletions
diff --git a/moon_manager/moon_manager/api/slaves.py b/moon_manager/moon_manager/api/slaves.py
new file mode 100644
index 00000000..f5b3fa14
--- /dev/null
+++ b/moon_manager/moon_manager/api/slaves.py
@@ -0,0 +1,110 @@
+# 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'.
+"""
+PDP are Policy Decision Point.
+
+"""
+
+from flask import request
+from flask_restful import Resource
+import logging
+import requests
+import time
+from python_moonutilities.security_functions import check_auth
+from python_moondb.core import PDPManager
+from python_moondb.core import PolicyManager
+from python_moondb.core import ModelManager
+from python_moonutilities import configuration, exceptions
+
+__version__ = "4.3.0"
+
+logger = logging.getLogger("moon.manager.api." + __name__)
+
+
+class Slaves(Resource):
+    """
+    Endpoint for pdp requests
+    """
+
+    __urls__ = (
+        "/slaves",
+        "/slaves/",
+        "/slaves/<string:uuid>",
+        "/slaves/<string:uuid>/",
+    )
+
+    def __init__(self, **kwargs):
+        conf = configuration.get_configuration("components/orchestrator")
+        self.orchestrator_hostname = conf["components/orchestrator"].get("hostname",
+                                                                         "orchestrator")
+        self.orchestrator_port = conf["components/orchestrator"].get("port",
+                                                                     80)
+
+    @check_auth
+    def get(self, uuid=None, user_id=None):
+        """Retrieve all slaves
+
+        :param uuid: uuid of the slave
+        :param user_id: user ID who do the request
+        :return: {
+            "slaves": {
+                "XXX": {
+                    "name": "...",
+                    "installed": True
+                },
+                "YYY": {
+                    "name": "...",
+                    "installed": False
+                }
+            }
+        }
+        """
+        req = requests.get("http://{}:{}/slaves".format(
+            self.orchestrator_hostname, self.orchestrator_port
+        ))
+        return {"slaves": req.json().get("slaves", dict())}
+
+    @check_auth
+    def patch(self, uuid=None, user_id=None):
+        """Update a slave
+
+        :param uuid: uuid of the slave to update
+        :param user_id: user ID who do the request
+        :request body: {
+            "op": "replace",
+            "variable": "configured",
+            "value": True,
+        }
+        :return: 204
+        :internal_api: add_pdp
+        """
+        logger.info("Will made a request for {}".format(uuid))
+        if request.json.get("op") == "replace" \
+            and request.json.get("variable") == "configured" \
+                and request.json.get("value"):
+            req = requests.post("http://{}:{}/pods".format(
+                self.orchestrator_hostname, self.orchestrator_port,
+                ),
+                json={"slave_name": uuid}
+            )
+            if req.status_code != 200:
+                logger.warning("Get error from Orchestrator {} {}".format(
+                    req.reason, req.status_code
+                ))
+                return "Orchestrator: " + str(req.reason), req.status_code
+        elif request.json.get("op") == "replace" \
+            and request.json.get("variable") == "configured" \
+                and not request.json.get("value"):
+            req = requests.delete("http://{}:{}/pods/{}".format(
+                self.orchestrator_hostname, self.orchestrator_port, uuid
+            ))
+            if req.status_code != 200:
+                logger.warning("Get error from Orchestrator {} {}".format(
+                    req.reason, req.status_code
+                ))
+                return "Orchestrator: " + str(req.reason), req.status_code
+        else:
+            return "Malformed request", 400
+        return {"slaves": req.json()}