1 files changed, 0 insertions, 120 deletions
diff --git a/moonv4/moon_wrapper/moon_wrapper/api/wrapper.py b/moonv4/moon_wrapper/moon_wrapper/api/wrapper.py
deleted file mode 100644
index e1ce783a..00000000
--- a/moonv4/moon_wrapper/moon_wrapper/api/wrapper.py
+++ /dev/null
@@ -1,120 +0,0 @@
-# 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'.
-"""
-Authz is the endpoint to get authorization response
-"""
-
-import flask
-from flask import request
-from flask_restful import Resource
-import logging
-import json
-import requests
-from python_moonutilities import exceptions
-
-__version__ = "0.1.0"
-
-LOG = logging.getLogger("moon.wrapper.api." + __name__)
-
-
-class Wrapper(Resource):
-    """
-    Endpoint for authz requests
-    """
-
-    __urls__ = (
-        "/authz",
-        "/authz/",
-    )
-
-    def __init__(self, **kwargs):
-        self.port = kwargs.get("port")
-        self.CACHE = kwargs.get("cache", {})
-        self.TIMEOUT = 5
-
-    # def get(self):
-    #     LOG.info("GET")
-    #     return self.manage_data()
-
-    def post(self):
-        LOG.debug("POST {}".format(request.form))
-        response = flask.make_response("False")
-        if self.manage_data():
-            response = flask.make_response("True")
-        response.headers['content-type'] = 'application/octet-stream'
-        return response
-
-    @staticmethod
-    def __get_subject(target, credentials):
-        _subject = target.get("user_id", "")
-        if not _subject:
-            _subject = credentials.get("user_id", "none")
-        return _subject
-
-    @staticmethod
-    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", "none")
-
-    @staticmethod
-    def __get_project_id(target, credentials):
-        LOG.info("__get_project_id {}".format(target))
-        return target.get("project_id", "none")
-
-    def get_interface_url(self, project_id):
-        LOG.info("project_id {}".format(project_id))
-        for containers in self.CACHE.containers.values():
-            LOG.info("containers {}".format(containers))
-            for container in containers:
-                if container.get("keystone_project_id") == project_id:
-                    if "interface" in container['name']:
-                        return "http://{}:{}".format(
-                            container['name'],
-                            container['port'])
-        self.CACHE.update()
-        # Note (asteroide): test an other time after the update
-        for containers in self.CACHE.containers.values():
-            for container in containers:
-                if container.get("keystone_project_id") == project_id:
-                    if "interface" in container['name']:
-                        return "http://{}:{}".format(
-                            container['name'],
-                            container['port'])
-        raise exceptions.AuthzException("Keystone Project "
-                                        "ID ({}) is unknown or not mapped "
-                                        "to a PDP.".format(project_id))
-
-    def manage_data(self):
-        data = request.form
-        if not dict(request.form):
-            data = json.loads(request.data.decode("utf-8"))
-        target = json.loads(data.get('target', {}))
-        credentials = json.loads(data.get('credentials', {}))
-        rule = data.get('rule', "")
-        _subject = self.__get_subject(target, credentials)
-        _object = self.__get_object(target, credentials)
-        _project_id = self.__get_project_id(target, credentials)
-        LOG.debug("POST with args project={} / "
-                  "subject={} - object={} - action={}".format(
-                    _project_id, _subject, _object, rule))
-        interface_url = self.get_interface_url(_project_id)
-        LOG.debug("interface_url={}".format(interface_url))
-        req = requests.get("{}/authz/{}/{}/{}/{}".format(
-            interface_url,
-            _project_id,
-            _subject,
-            _object,
-            rule
-        ))
-        LOG.debug("Get interface {}".format(req.text))
-        if req.status_code == 200:
-            if req.json().get("result", False):
-                return True