--- /dev/null
+# 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'.
+
+
+CHANGES
+=======
+
+0.1.0
+-----
+- First version of the moon_consul component.
+
--- /dev/null
+# Pull base image.
+FROM ubuntu:latest
+
+ENV DB_URL="mysql+pymysql://moon:p4sswOrd1@db/moon"
+ENV DB_DRIVER=sql
+ENV TRANSPORT_URL="rabbit://moon:p4sswOrd1@messenger:5672/moon"
+ENV DOCKER_URL="unix://var/run/docker.sock"
+ENV SLAVE_NAME=
+ENV MASTER_URL=
+ENV MASTER_LOGIN=
+ENV MASTER_PASSWORD=
+ENV INTERFACE_PORT=8080
+ENV CONSUL_HOST="172.88.88.88"
+ENV CONSUL_PORT=88
+ENV KEYSTONE_URL="http://keystone:5000/v3"
+ENV KEYSTONE_USER=admin
+ENV KEYSTONE_PASSWORD=p4ssw0rd
+ENV KEYSTONE_DOMAIN=default
+ENV KEYSTONE_PROJECT=admin
+ENV KEYSTONE_CHECK_TOKEN=False
+ENV KEYSTONE_SERVER_CRT=False
+ENV PLUGIN_CONTAINERS="asteroide/authz:latest,asteroide/session:latest"
+ENV COMPONENTS_PORT_START=38001
+
+RUN apt-get update && apt-get install python3.5 python3-pip -y
+
+RUN pip3 install pip --upgrade
+#RUN pip3 install moon_db
+
+ADD . /root
+
+WORKDIR /root/
+RUN pip3 install -r requirements.txt
+RUN pip3 install .
+EXPOSE ${CONSUL_PORT}
+
+CMD ["python3", "-m", "moon_consul"]
\ No newline at end of file
--- /dev/null
+
+ Apache License
+ Version 2.0, January 2004
+ http://www.apache.org/licenses/
+
+ TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
+
+ 1. Definitions.
+
+ "License" shall mean the terms and conditions for use, reproduction,
+ and distribution as defined by Sections 1 through 9 of this document.
+
+ "Licensor" shall mean the copyright owner or entity authorized by
+ the copyright owner that is granting the License.
+
+ "Legal Entity" shall mean the union of the acting entity and all
+ other entities that control, are controlled by, or are under common
+ control with that entity. For the purposes of this definition,
+ "control" means (i) the power, direct or indirect, to cause the
+ direction or management of such entity, whether by contract or
+ otherwise, or (ii) ownership of fifty percent (50%) or more of the
+ outstanding shares, or (iii) beneficial ownership of such entity.
+
+ "You" (or "Your") shall mean an individual or Legal Entity
+ exercising permissions granted by this License.
+
+ "Source" form shall mean the preferred form for making modifications,
+ including but not limited to software source code, documentation
+ source, and configuration files.
+
+ "Object" form shall mean any form resulting from mechanical
+ transformation or translation of a Source form, including but
+ not limited to compiled object code, generated documentation,
+ and conversions to other media types.
+
+ "Work" shall mean the work of authorship, whether in Source or
+ Object form, made available under the License, as indicated by a
+ copyright notice that is included in or attached to the work
+ (an example is provided in the Appendix below).
+
+ "Derivative Works" shall mean any work, whether in Source or Object
+ form, that is based on (or derived from) the Work and for which the
+ editorial revisions, annotations, elaborations, or other modifications
+ represent, as a whole, an original work of authorship. For the purposes
+ of this License, Derivative Works shall not include works that remain
+ separable from, or merely link (or bind by name) to the interfaces of,
+ the Work and Derivative Works thereof.
+
+ "Contribution" shall mean any work of authorship, including
+ the original version of the Work and any modifications or additions
+ to that Work or Derivative Works thereof, that is intentionally
+ submitted to Licensor for inclusion in the Work by the copyright owner
+ or by an individual or Legal Entity authorized to submit on behalf of
+ the copyright owner. For the purposes of this definition, "submitted"
+ means any form of electronic, verbal, or written communication sent
+ to the Licensor or its representatives, including but not limited to
+ communication on electronic mailing lists, source code control systems,
+ and issue tracking systems that are managed by, or on behalf of, the
+ Licensor for the purpose of discussing and improving the Work, but
+ excluding communication that is conspicuously marked or otherwise
+ designated in writing by the copyright owner as "Not a Contribution."
+
+ "Contributor" shall mean Licensor and any individual or Legal Entity
+ on behalf of whom a Contribution has been received by Licensor and
+ subsequently incorporated within the Work.
+
+ 2. Grant of Copyright License. Subject to the terms and conditions of
+ this License, each Contributor hereby grants to You a perpetual,
+ worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+ copyright license to reproduce, prepare Derivative Works of,
+ publicly display, publicly perform, sublicense, and distribute the
+ Work and such Derivative Works in Source or Object form.
+
+ 3. Grant of Patent License. Subject to the terms and conditions of
+ this License, each Contributor hereby grants to You a perpetual,
+ worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+ (except as stated in this section) patent license to make, have made,
+ use, offer to sell, sell, import, and otherwise transfer the Work,
+ where such license applies only to those patent claims licensable
+ by such Contributor that are necessarily infringed by their
+ Contribution(s) alone or by combination of their Contribution(s)
+ with the Work to which such Contribution(s) was submitted. If You
+ institute patent litigation against any entity (including a
+ cross-claim or counterclaim in a lawsuit) alleging that the Work
+ or a Contribution incorporated within the Work constitutes direct
+ or contributory patent infringement, then any patent licenses
+ granted to You under this License for that Work shall terminate
+ as of the date such litigation is filed.
+
+ 4. Redistribution. You may reproduce and distribute copies of the
+ Work or Derivative Works thereof in any medium, with or without
+ modifications, and in Source or Object form, provided that You
+ meet the following conditions:
+
+ (a) You must give any other recipients of the Work or
+ Derivative Works a copy of this License; and
+
+ (b) You must cause any modified files to carry prominent notices
+ stating that You changed the files; and
+
+ (c) You must retain, in the Source form of any Derivative Works
+ that You distribute, all copyright, patent, trademark, and
+ attribution notices from the Source form of the Work,
+ excluding those notices that do not pertain to any part of
+ the Derivative Works; and
+
+ (d) If the Work includes a "NOTICE" text file as part of its
+ distribution, then any Derivative Works that You distribute must
+ include a readable copy of the attribution notices contained
+ within such NOTICE file, excluding those notices that do not
+ pertain to any part of the Derivative Works, in at least one
+ of the following places: within a NOTICE text file distributed
+ as part of the Derivative Works; within the Source form or
+ documentation, if provided along with the Derivative Works; or,
+ within a display generated by the Derivative Works, if and
+ wherever such third-party notices normally appear. The contents
+ of the NOTICE file are for informational purposes only and
+ do not modify the License. You may add Your own attribution
+ notices within Derivative Works that You distribute, alongside
+ or as an addendum to the NOTICE text from the Work, provided
+ that such additional attribution notices cannot be construed
+ as modifying the License.
+
+ You may add Your own copyright statement to Your modifications and
+ may provide additional or different license terms and conditions
+ for use, reproduction, or distribution of Your modifications, or
+ for any such Derivative Works as a whole, provided Your use,
+ reproduction, and distribution of the Work otherwise complies with
+ the conditions stated in this License.
+
+ 5. Submission of Contributions. Unless You explicitly state otherwise,
+ any Contribution intentionally submitted for inclusion in the Work
+ by You to the Licensor shall be under the terms and conditions of
+ this License, without any additional terms or conditions.
+ Notwithstanding the above, nothing herein shall supersede or modify
+ the terms of any separate license agreement you may have executed
+ with Licensor regarding such Contributions.
+
+ 6. Trademarks. This License does not grant permission to use the trade
+ names, trademarks, service marks, or product names of the Licensor,
+ except as required for reasonable and customary use in describing the
+ origin of the Work and reproducing the content of the NOTICE file.
+
+ 7. Disclaimer of Warranty. Unless required by applicable law or
+ agreed to in writing, Licensor provides the Work (and each
+ Contributor provides its Contributions) on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ implied, including, without limitation, any warranties or conditions
+ of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
+ PARTICULAR PURPOSE. You are solely responsible for determining the
+ appropriateness of using or redistributing the Work and assume any
+ risks associated with Your exercise of permissions under this License.
+
+ 8. Limitation of Liability. In no event and under no legal theory,
+ whether in tort (including negligence), contract, or otherwise,
+ unless required by applicable law (such as deliberate and grossly
+ negligent acts) or agreed to in writing, shall any Contributor be
+ liable to You for damages, including any direct, indirect, special,
+ incidental, or consequential damages of any character arising as a
+ result of this License or out of the use or inability to use the
+ Work (including but not limited to damages for loss of goodwill,
+ work stoppage, computer failure or malfunction, or any and all
+ other commercial damages or losses), even if such Contributor
+ has been advised of the possibility of such damages.
+
+ 9. Accepting Warranty or Additional Liability. While redistributing
+ the Work or Derivative Works thereof, You may choose to offer,
+ and charge a fee for, acceptance of support, warranty, indemnity,
+ or other liability obligations and/or rights consistent with this
+ License. However, in accepting such obligations, You may act only
+ on Your own behalf and on Your sole responsibility, not on behalf
+ of any other Contributor, and only if You agree to indemnify,
+ defend, and hold each Contributor harmless for any liability
+ incurred by, or claims asserted against, such Contributor by reason
+ of your accepting any such warranty or additional liability.
+
+--- License for python-keystoneclient versions prior to 2.1 ---
+
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+ 1. Redistributions of source code must retain the above copyright notice,
+ this list of conditions and the following disclaimer.
+
+ 2. Redistributions in binary form must reproduce the above copyright
+ notice, this list of conditions and the following disclaimer in the
+ documentation and/or other materials provided with the distribution.
+
+ 3. Neither the name of this project nor the names of its contributors may
+ be used to endorse or promote products derived from this software without
+ specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE
+FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
+CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
+OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
--- /dev/null
+# 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'.
+
+include README.rst
+include LICENSE
+include setup.py
+include requirements.txt
+# graft tests
+graft bin
\ No newline at end of file
--- /dev/null
+DB module for the Moon project
+==============================
+
+This package contains the database module for the Moon project
+It is designed to provide a driver to access the Moon database.
+
+For any other information, refer to the parent project:
+
+ https://git.opnfv.org/moon
--- /dev/null
+__version__ = "0.1.0"
--- /dev/null
+from moon_consul.server import main
+
+main()
--- /dev/null
+# 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'.
+"""
+Assignments allow to connect data with elements of perimeter
+
+"""
+
+from flask import request
+from flask_restful import Resource
+# from oslo_config import cfg
+from oslo_log import log as logging
+# from moon_interface.tools import check_auth
+
+__version__ = "0.1.0"
+
+LOG = logging.getLogger(__name__)
+# CONF = cfg.CONF
+
+
+class Database(Resource):
+ """
+ Endpoint for database requests
+ """
+
+ __urls__ = (
+ "/configuration/database",
+ )
+
+ def __init__(self, *args, **kwargs):
+ self.conf = kwargs.get('conf', {})
+
+ # @check_auth
+ def get(self):
+ """Retrieve database configuration
+
+ :return: {
+ "database": {
+ "hostname": "hostname for the main database",
+ "port": "port for the main database",
+ "user": "user for the main database",
+ "password": "password for the main database",
+ "protocol": "protocol to use (eg. mysql+pymysql)",
+ "driver": "driver to use",
+ }
+ }
+ """
+ url = self.conf.DB_URL
+ driver = self.conf.DB_DRIVER
+ hostname = url.split("@")[-1].split(":")[0].split("/")[0]
+ try:
+ port = int(url.split("@")[-1].split(":")[1].split("/")[0])
+ except ValueError:
+ port = None
+ except IndexError:
+ port = None
+ user = url.split("//")[1].split(":")[0]
+ # TODO: password must be encrypted
+ password = url.split(":")[2].split("@")[0]
+ protocol = url.split(":")[0]
+ return {
+ "database": {
+ "hostname": hostname,
+ "port": port,
+ "user": user,
+ "password": password,
+ "protocol": protocol,
+ "driver": driver
+ }
+ }
+
--- /dev/null
+# 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_config import cfg
+from oslo_log import log as logging
+# from moon_utilities.security_functions import call
+import moon_consul.api
+# from moon_utilities.auth import check_auth
+
+__version__ = "0.1.0"
+
+LOG = logging.getLogger(__name__)
+# CONF = cfg.CONF
+
+
+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_consul.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
+
--- /dev/null
+# 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'.
+"""
+Assignments allow to connect data with elements of perimeter
+
+"""
+
+from flask import request
+from flask_restful import Resource
+# from oslo_config import cfg
+from oslo_log import log as logging
+# from moon_interface.tools import check_auth
+
+__version__ = "0.1.0"
+
+LOG = logging.getLogger(__name__)
+# CONF = cfg.CONF
+
+
+class Messenger(Resource):
+ """
+ Endpoint for messenger requests
+ """
+
+ __urls__ = (
+ "/configuration/messenger",
+ )
+
+ def __init__(self, *args, **kwargs):
+ self.conf = kwargs.get('conf', {})
+
+ # @check_auth
+ def get(self):
+ """Retrieve messenger configuration
+
+ :return: {
+ "messenger": {
+ "hostname": "hostname for the messenger server",
+ "port": "port for the main messenger server",
+ "user": "user for the main messenger server",
+ "password": "password for the main messenger server",
+ "protocol": "protocol to use (eg. rabbit)"
+ }
+ }
+ """
+ url = self.conf.TRANSPORT_URL
+ hostname = url.split("@")[-1].split(":")[0].split("/")[0]
+ try:
+ port = int(url.split("@")[-1].split(":")[1].split("/")[0])
+ except ValueError:
+ port = None
+ user = url.split("//")[1].split(":")[0]
+ # TODO: password must be encrypted
+ password = url.split(":")[2].split("@")[0]
+ protocol = url.split(":")[0]
+ return {
+ "messenger": {
+ "hostname": hostname,
+ "port": port,
+ "user": user,
+ "password": password,
+ "protocol": protocol,
+ }
+ }
+
--- /dev/null
+# 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'.
+"""
+Assignments allow to connect data with elements of perimeter
+
+"""
+
+from flask import request
+from flask_restful import Resource
+# from oslo_config import cfg
+from oslo_log import log as logging
+# from moon_interface.tools import check_auth
+
+__version__ = "0.1.0"
+
+LOG = logging.getLogger(__name__)
+# CONF = cfg.CONF
+
+
+class Keystone(Resource):
+ """
+ Endpoint for Keystone requests
+ """
+
+ __urls__ = (
+ "/configuration/os/keystone",
+ )
+
+ def __init__(self, *args, **kwargs):
+ self.conf = kwargs.get('conf', {})
+
+ # @check_auth
+ def get(self):
+ """Retrieve Keystone configuration
+
+ :return: {
+ "keystone": {
+ "url": "hostname for the Keystone server",
+ "user": "user for the Keystone server",
+ "password": "password for the Keystone server",
+ "domain": "domain to use against Keystone server",
+ "project": "main project to use",
+ "check_token": "yes, no or strict",
+ "server_crt": "certificate to use when using https"
+ }
+ }
+ """
+ # TODO: password must be encrypted
+ # TODO: check_token is a sensitive information it must not be update through the network
+ return {
+ "keystone": {
+ "url": self.conf.KEYSTONE_URL,
+ "user": self.conf.KEYSTONE_USER,
+ "password": self.conf.KEYSTONE_PASSWORD,
+ "domain": self.conf.KEYSTONE_DOMAIN,
+ "project": self.conf.KEYSTONE_PROJECT,
+ "check_token": self.conf.KEYSTONE_CHECK_TOKEN,
+ "server_crt": self.conf.KEYSTONE_SERVER_CRT
+ }
+ }
+
--- /dev/null
+# 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'.
+"""
+Assignments allow to connect data with elements of perimeter
+
+"""
+
+from flask import request
+from flask_restful import Resource
+# from oslo_config import cfg
+from oslo_log import log as logging
+# from moon_interface.tools import check_auth
+
+__version__ = "0.1.0"
+
+LOG = logging.getLogger(__name__)
+# CONF = cfg.CONF
+
+
+class Slave(Resource):
+ """
+ Endpoint for slave requests
+ """
+
+ __urls__ = (
+ "/configuration/slave",
+ )
+
+ def __init__(self, *args, **kwargs):
+ self.conf = kwargs.get('conf', {})
+
+ # @check_auth
+ def get(self):
+ """Retrieve slave configuration
+
+ If current server is a slave:
+ :return: {
+ "slave": {
+ "name": "name of the slave",
+ "master_url": "URL of the master",
+ "user": [
+ {
+ "username": "user to be used to connect to the master",
+ "password": "password to be used to connect to the master"
+ }
+ ]
+ }
+ }
+ else:
+ :return: {
+ "slave": {}
+ }
+ """
+ # TODO: password must be encrypted
+ if self.conf.SLAVE_NAME:
+ return {
+ "slave": {
+ "name": self.conf.SLAVE_NAME,
+ "master_url": self.conf.MASTER_URL,
+ "user": [
+ {
+ "username": self.conf.MASTER_LOGIN,
+ "password": self.conf.MASTER_PASSWORD
+ }
+ ]
+ }
+ }
+ else:
+ return {"slave": {}}
+
--- /dev/null
+# 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'.
+"""
+Assignments allow to connect data with elements of perimeter
+
+"""
+
+from flask import request
+from flask_restful import Resource
+# from oslo_config import cfg
+from oslo_log import log as logging
+# from moon_interface.tools import check_auth
+
+__version__ = "0.1.0"
+
+LOG = logging.getLogger(__name__)
+# CONF = cfg.CONF
+
+
+class Docker(Resource):
+ """
+ Endpoint for system requests
+ """
+
+ __urls__ = (
+ "/configuration/docker",
+ )
+
+ def __init__(self, *args, **kwargs):
+ self.conf = kwargs.get('conf', {})
+
+ # @check_auth
+ def get(self):
+ """Retrieve docker configuration
+
+ :return: {
+ "docker": {
+ "url": "hostname for the docker server (eg. /var/run/docker.sock)",
+ "port": "port of the server",
+ "user": "user of the server",
+ "password": "password of the server",
+ "protocol": "protocol to use (eg. unix)"
+ }
+ }
+ """
+ url = self.conf.DOCKER_URL
+ # LOG.info(url)
+ # hostname = url.split("@")[-1].split(":")[0].split("/")[0]
+ # try:
+ # port = int(url.split("@")[-1].split(":")[1].split("/")[0])
+ # except ValueError:
+ # port = None
+ # user = url.split("//")[1].split(":")[0]
+ # # TODO: password must be encrypted
+ # try:
+ # password = url.split(":")[2].split("@")[0]
+ # except IndexError:
+ # password = ""
+ # protocol = url.split(":")[0]
+ return {
+ "docker": {
+ "url": self.conf.DOCKER_URL,
+ # "port": port,
+ # "user": user,
+ # "password": password,
+ # "protocol": protocol,
+ }
+ }
+
+
+class Components(Resource):
+ """
+ Endpoint for requests on components
+ """
+
+ __urls__ = (
+ "/configuration/components",
+ "/configuration/components/",
+ "/configuration/components/<string:id_or_name>",
+ )
+
+ def __init__(self, *args, **kwargs):
+ self.conf = kwargs.get('conf', {})
+
+ # @check_auth
+ def get(self, id_or_name=None):
+ """Retrieve component list
+
+ :param id_or_name: ID or name of the component
+
+ :return: {
+ "components": [
+ {
+ "hostname": "hostname of the component",
+ "port": "port of the server in this component",
+ "id": "id of the component",
+ "keystone_id": "Keystone project ID served by this component if needed"
+ },
+ ]
+ }
+ """
+ if id_or_name:
+ for _component in self.conf.COMPONENTS:
+ if id_or_name in (_component["hostname"], _component["id"]):
+ return {
+ "components": [_component, ]
+ }
+ return {"components": []}
+ return {"components": self.conf.COMPONENTS}
+
+ # @check_auth
+ def put(self, id_or_name=None):
+ """Ask for adding a new component
+ The response gives the TCP port to be used
+
+ :param id_or_name: ID or name of the component
+ :request body: {
+ "hostname": "hostname of the new component",
+ "keystone_id": "Keystone ID mapped to that component (if needed)"
+ }
+ :return: {
+ "components": [
+ {
+ "hostname": "hostname of the component",
+ "port": "port of the server in this component",
+ "id": "id of the component",
+ "keystone_id": "Keystone project ID served by this component"
+ }
+ ]
+ }
+ """
+ if not id_or_name:
+ return "Need a name for that component", 400
+ for _component in self.conf.COMPONENTS:
+ if id_or_name in (_component["hostname"], _component["id"]):
+ return "ID already used", 409
+ self.conf.COMPONENTS_PORT_START += 1
+ port = self.conf.COMPONENTS_PORT_START
+ data = request.json
+ new_component = {
+ "hostname": data.get("hostname", id_or_name),
+ "port": port,
+ "id": id_or_name,
+ "keystone_id": data.get("keystone_id", "")
+ }
+ self.conf.COMPONENTS.append(new_component)
+ return {
+ "components": [new_component, ]
+ }
+
+ # @check_auth
+ def delete(self, id_or_name=None):
+ """Delete a component
+
+ :param id_or_name: ID or name of the component
+ :return: {
+ "result": true
+ }
+ """
+ if not id_or_name:
+ return "Need a name for that component", 400
+ for index, _component in enumerate(self.conf.COMPONENTS):
+ if id_or_name in (_component["hostname"], _component["id"]):
+ self.conf.COMPONENTS.pop(index)
+ return {"result": True}
+ return "Cannot find component named {}".format(id_or_name), 403
+
--- /dev/null
+# 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'.
+
+from flask import Flask, request
+from flask_cors import CORS, cross_origin
+from flask_restful import Resource, Api, reqparse
+import logging
+from moon_consul import __version__
+from moon_consul.api.generic import API
+from moon_consul.api.database import Database
+from moon_consul.api.messenger import Messenger
+from moon_consul.api.openstack import Keystone
+from moon_consul.api.slave import Slave
+from moon_consul.api.system import Docker, Components
+from moon_utilities import exceptions
+
+logger = logging.getLogger(__name__)
+
+
+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__ = (
+ API,
+ Database, Docker, Messenger, Keystone, Slave, Components
+ )
+
+
+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
+ }
+
+
+class HTTPServer(Server):
+
+ def __init__(self, host="localhost", port=80, conf=None, **kwargs):
+ super(HTTPServer, self).__init__(host=host, port=port, **kwargs)
+ self.app = Flask(__name__)
+ self.conf = conf
+ # Todo : specify only few urls instead of *
+ # CORS(self.app)
+ 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={
+ "conf": self.conf,
+ }
+ )
+
+ def run(self):
+ self.app.run(debug=True, host=self._host, port=self._port) # nosec
+
--- /dev/null
+# 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 os
+# from oslo_config import cfg
+from oslo_log import log as logging
+# from moon_utilities import options # noqa
+from moon_consul.http_server import HTTPServer
+
+LOG = logging.getLogger(__name__)
+# CONF = cfg.CONF
+# DOMAIN = "moon_consul"
+
+# __CWD__ = os.path.dirname(os.path.abspath(__file__))
+
+
+class Configuration:
+ DB_URL = None
+ DB_DRIVER = None
+ TRANSPORT_URL = None
+ DOCKER_URL = None
+ SLAVE_NAME = None
+ MASTER_URL = None
+ MASTER_LOGIN = None
+ MASTER_PASSWORD = None
+ INTERFACE_PORT = None
+ CONSUL_HOST = None
+ CONSUL_PORT = None
+ KEYSTONE_URL = None
+ KEYSTONE_USER = None
+ KEYSTONE_PASSWORD = None
+ KEYSTONE_DOMAIN = None
+ KEYSTONE_PROJECT = None
+ KEYSTONE_CHECK_TOKEN = None
+ KEYSTONE_SERVER_CRT = None
+ PLUGIN_CONTAINERS = None
+
+
+def get_configuration():
+ conf = Configuration()
+ conf.DB_URL = os.getenv("DB_URL", "mysql+pymysql://moon:p4sswOrd1@db/moon")
+ conf.DB_DRIVER = os.getenv("DB_DRIVER", "sql")
+ conf.TRANSPORT_URL = os.getenv("TRANSPORT_URL", "rabbit://moon:p4sswOrd1@messenger:5672/moon")
+ conf.DOCKER_URL = os.getenv("DOCKER_URL", "unix://var/run/docker.sock")
+ conf.SLAVE_NAME = os.getenv("SLAVE_NAME", "")
+ conf.MASTER_URL = os.getenv("MASTER_URL", "")
+ conf.MASTER_LOGIN = os.getenv("MASTER_LOGIN", "")
+ conf.MASTER_PASSWORD = os.getenv("MASTER_PASSWORD", "")
+ conf.INTERFACE_PORT = os.getenv("INTERFACE_PORT", "8080")
+ conf.CONSUL_HOST = os.getenv("CONSUL_HOST", "172.88.88.88")
+ conf.CONSUL_PORT = os.getenv("CONSUL_PORT", "88")
+ conf.KEYSTONE_URL = os.getenv("KEYSTONE_URL", "http://keystone:5000/v3")
+ conf.KEYSTONE_USER = os.getenv("KEYSTONE_USER", "admin")
+ conf.KEYSTONE_PASSWORD = os.getenv("KEYSTONE_PASSWORD", "p4ssw0rd")
+ conf.KEYSTONE_DOMAIN = os.getenv("KEYSTONE_DOMAIN", "default")
+ conf.KEYSTONE_PROJECT = os.getenv("KEYSTONE_PROJECT", "admin")
+ conf.KEYSTONE_CHECK_TOKEN = os.getenv("KEYSTONE_CHECK_TOKEN", False)
+ conf.KEYSTONE_SERVER_CRT = os.getenv("KEYSTONE_SERVER_CRT", False)
+ conf.PLUGIN_CONTAINERS = os.getenv("PLUGIN_CONTAINERS", "asteroide/authz:latest,asteroide/session:latest")
+ conf.COMPONENTS_PORT_START = int(os.getenv("COMPONENTS_PORT_START", "38001"))
+ conf.COMPONENTS = [
+ {
+ "hostname": conf.CONSUL_HOST,
+ "port": conf.CONSUL_PORT,
+ "id": "consul",
+ "keystone_id": None
+ },
+ ]
+ return conf
+
+
+def main():
+ conf = get_configuration()
+ LOG.info("Starting server with IP {} on port {}".format(conf.CONSUL_HOST, conf.CONSUL_PORT))
+ server = HTTPServer(host=conf.CONSUL_HOST, port=int(conf.CONSUL_PORT), conf=conf)
+ server.run()
+
+
+if __name__ == '__main__':
+ main()
--- /dev/null
+oslo.messaging
+flask
+flask_restful
+flask_cors
+moon_utilities
\ No newline at end of file
--- /dev/null
+# 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'.
+
+from setuptools import setup, find_packages
+import moon_consul
+
+
+with open('requirements.txt') as f:
+ required = f.read().splitlines()
+
+setup(
+
+ name='moon_consul',
+
+ version=moon_consul.__version__,
+
+ packages=find_packages(),
+
+ author="Thomas Duval",
+
+ author_email="thomas.duval@orange.com",
+
+ description="This component is a helper to retrieve configuration across the Moon platform.",
+
+ long_description=open('README.md').read(),
+
+ install_requires=required,
+
+ include_package_data=True,
+
+ url='https://git.opnfv.org/cgit/moon/',
+
+ classifiers=[
+ "Programming Language :: Python",
+ "Development Status :: 1 - Planning",
+ "License :: OSI Approved",
+ "Natural Language :: English",
+ "Operating System :: OS Independent",
+ "Programming Language :: Python :: 3",
+ ],
+
+ entry_points={
+ 'console_scripts': [
+ 'moon_consul = moon_consul.server:run',
+ ],
+ }
+
+)
Code Review / moon.git / commitdiff