aboutsummaryrefslogtreecommitdiffstats
path: root/moon_authz/moon_authz/http_server.py
diff options
context:
space:
mode:
Diffstat (limited to 'moon_authz/moon_authz/http_server.py')
-rw-r--r--moon_authz/moon_authz/http_server.py142
1 files changed, 0 insertions, 142 deletions
diff --git a/moon_authz/moon_authz/http_server.py b/moon_authz/moon_authz/http_server.py
deleted file mode 100644
index 86d8a914..00000000
--- a/moon_authz/moon_authz/http_server.py
+++ /dev/null
@@ -1,142 +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'.
-
-import logging
-from flask import Flask
-from flask_restful import Resource, Api
-from moon_authz import __version__
-from moon_authz.api.authorization import Authz
-from moon_authz.api.update import Update
-from python_moonutilities.cache import Cache
-from python_moonutilities import exceptions
-
-LOGGER = logging.getLogger("moon.authz.http_server")
-
-CACHE = Cache()
-CACHE.update()
-
-
-class Server:
- """Base class for HTTP server"""
-
- def __init__(self, host="localhost", port=80, api=None, **kwargs):
- """Run a server
-
- :param host: hostname of the server
- :param port: port for the running server
- :param kwargs: optional parameters
- :return: a running server
- """
- self._host = host
- self._port = port
- self._api = api
- self._extra = kwargs
-
- @property
- def host(self):
- return self._host
-
- @host.setter
- def host(self, name):
- self._host = name
-
- @host.deleter
- def host(self):
- self._host = ""
-
- @property
- def port(self):
- return self._port
-
- @port.setter
- def port(self, number):
- self._port = number
-
- @port.deleter
- def port(self):
- self._port = 80
-
- def run(self):
- raise NotImplementedError()
-
-
-__API__ = (
- Authz, Update
-)
-
-
-class Root(Resource):
- """
- The root of the web service
- """
- __urls__ = ("/",)
- __methods = ("get", "post", "put", "delete", "options")
-
- def get(self):
- tree = {"/": {"methods": ("get",),
- "description": "List all methods for that service."}}
- for item in __API__:
- tree[item.__name__] = {"urls": item.__urls__}
- _methods = []
- for _method in self.__methods:
- if _method in dir(item):
- _methods.append(_method)
- tree[item.__name__]["methods"] = _methods
- tree[item.__name__]["description"] = item.__doc__.strip()
- return {
- "version": __version__,
- "tree": tree
- }
-
- def head(self):
- return "", 201
-
-
-class HTTPServer(Server):
- def __init__(self, host="localhost", port=38001, **kwargs):
- super(HTTPServer, self).__init__(host=host, port=port, **kwargs)
- self.component_data = kwargs.get("component_data", {})
- LOGGER.info("HTTPServer port={} {}".format(port, kwargs))
- self.app = Flask(__name__)
- self._port = port
- self._host = host
- self.component_id = kwargs.get("component_id")
- self.keystone_project_id = kwargs.get("keystone_project_id")
- self.container_chaining = kwargs.get("container_chaining")
- self.api = Api(self.app)
- self.__set_route()
-
- # self.__hook_errors()
-
- @self.app.errorhandler(exceptions.AuthException)
- def _auth_exception(error):
- return {"error": "Unauthorized"}, 401
-
- def __hook_errors(self):
- # FIXME (dthom): it doesn't work
- def get_404_json(e):
- return {"error": "Error", "code": 404, "description": e}
-
- self.app.register_error_handler(404, get_404_json)
-
- def get_400_json(e):
- return {"error": "Error", "code": 400, "description": e}
-
- self.app.register_error_handler(400, lambda e: get_400_json)
- self.app.register_error_handler(403, exceptions.AuthException)
-
- def __set_route(self):
- self.api.add_resource(Root, '/')
-
- for api in __API__:
- self.api.add_resource(api, *api.__urls__,
- resource_class_kwargs={
- "component_data": self.component_data,
- "cache": CACHE
- }
- )
-
- def run(self):
- self.app.run(host=self._host, port=self._port, threaded=True) # nosec