aboutsummaryrefslogtreecommitdiffstats
path: root/moonv4/moon_wrapper/moon_wrapper/api/generic.py
blob: 68687ddbca461d750dd8c42eaefb8c8856266faf (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
# 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'.
"""
Those API are helping API used to manage the Moon platform.
"""

from flask_restful import Resource, request
from oslo_log import log as logging
import moon_wrapper.api
from moon_utilities.security_functions import check_auth

__version__ = "0.1.0"

LOG = logging.getLogger("moon.manager.api." + __name__)


class Status(Resource):
    """
    Endpoint for status requests
    """

    __urls__ = ("/status", "/status/", "/status/<string:component_id>")

    def get(self, component_id=None):
        """Retrieve status of all components

        :return: {
          "orchestrator": {
            "status": "Running"
          },
          "security_router": {
            "status": "Running"
          }
        }
        """
        raise NotImplemented


class Logs(Resource):
    """
    Endpoint for logs requests
    """

    __urls__ = ("/logs", "/logs/", "/logs/<string:component_id>")

    def get(self, component_id=None):
        """Get logs from the Moon platform

        :param component_id: the ID of the component your are looking for (optional)
        :return: [
            "2015-04-15-13:45:20
            "2015-04-15-13:45:21
            "2015-04-15-13:45:22
            "2015-04-15-13:45:23
        ]
        """
        filter_str = request.args.get('filter', '')
        from_str = request.args.get('from', '')
        to_str = request.args.get('to', '')
        event_number = request.args.get('event_number', '')
        try:
            event_number = int(event_number)
        except ValueError:
            event_number = None
        args = dict()
        args["filter"] = filter_str
        args["from"] = from_str
        args["to"] = to_str
        args["event_number"] = event_number

        raise NotImplemented


class API(Resource):
    """
    Endpoint for API requests
    """

    __urls__ = (
        "/api",
        "/api/",
        "/api/<string:group_id>",
        "/api/<string:group_id>/",
        "/api/<string:group_id>/<string:endpoint_id>")

    @check_auth
    def get(self, group_id="", endpoint_id="", user_id=""):
        """Retrieve all API endpoints or a specific endpoint if endpoint_id is given

        :param group_id: the name of one existing group (ie generic, ...)
        :param endpoint_id: the name of one existing component (ie Logs, Status, ...)
        :return: {
            "group_name": {
                "endpoint_name": {
                    "description": "a description",
                    "methods": {
                        "get": "description of the HTTP method"
                    },
                    "urls": ('/api', '/api/', '/api/<string:endpoint_id>')
                }
        }
        """
        __methods = ("get", "post", "put", "delete", "options", "patch")
        api_list = filter(lambda x: "__" not in x, dir(moon_wrapper.api))
        api_desc = dict()
        for api_name in api_list:
            api_desc[api_name] = {}
            group_api_obj = eval("moon_interface.api.{}".format(api_name))
            api_desc[api_name]["description"] = group_api_obj.__doc__
            if "__version__" in dir(group_api_obj):
                api_desc[api_name]["version"] = group_api_obj.__version__
            object_list = list(filter(lambda x: "__" not in x, dir(group_api_obj)))
            for obj in map(lambda x: eval("moon_interface.api.{}.{}".format(api_name, x)), object_list):
                if "__urls__" in dir(obj):
                    api_desc[api_name][obj.__name__] = dict()
                    api_desc[api_name][obj.__name__]["urls"] = obj.__urls__
                    api_desc[api_name][obj.__name__]["methods"] = dict()
                    for _method in filter(lambda x: x in __methods, dir(obj)):
                        docstring = eval("moon_interface.api.{}.{}.{}.__doc__".format(api_name, obj.__name__, _method))
                        api_desc[api_name][obj.__name__]["methods"][_method] = docstring
                    api_desc[api_name][obj.__name__]["description"] = str(obj.__doc__)
        if group_id in api_desc:
            if endpoint_id in api_desc[group_id]:
                return {group_id: {endpoint_id: api_desc[group_id][endpoint_id]}}
            elif len(endpoint_id) > 0:
                LOG.error("Unknown endpoint_id {}".format(endpoint_id))
                return {"error": "Unknown endpoint_id {}".format(endpoint_id)}
            return {group_id: api_desc[group_id]}
        return api_desc