aboutsummaryrefslogtreecommitdiffstats
path: root/moonv4/moon_consul
diff options
context:
space:
mode:
authorRHE <rebirthmonkey@gmail.com>2017-11-28 13:11:09 +0100
committerRHE <rebirthmonkey@gmail.com>2017-11-28 13:11:09 +0100
commit337031d5e14ab89b1fb9b24b7bfdc6e66e5ca8af (patch)
treef14cce0a766ca8fc6b805c01d90428957a496174 /moonv4/moon_consul
parent920a49cfa055733d575282973e23558c33087a4a (diff)
moonv4 clean up
Change-Id: Ied1e065f941e59bf9a75545436b7ac09174942fa
Diffstat (limited to 'moonv4/moon_consul')
-rw-r--r--moonv4/moon_consul/Changelog13
-rw-r--r--moonv4/moon_consul/Dockerfile37
-rw-r--r--moonv4/moon_consul/LICENSE204
-rw-r--r--moonv4/moon_consul/MANIFEST.in11
-rw-r--r--moonv4/moon_consul/README.md9
-rw-r--r--moonv4/moon_consul/moon_consul/__init__.py1
-rw-r--r--moonv4/moon_consul/moon_consul/__main__.py3
-rw-r--r--moonv4/moon_consul/moon_consul/api/__init__.py0
-rw-r--r--moonv4/moon_consul/moon_consul/api/database.py72
-rw-r--r--moonv4/moon_consul/moon_consul/api/generic.py78
-rw-r--r--moonv4/moon_consul/moon_consul/api/messenger.py67
-rw-r--r--moonv4/moon_consul/moon_consul/api/openstack.py63
-rw-r--r--moonv4/moon_consul/moon_consul/api/slave.py72
-rw-r--r--moonv4/moon_consul/moon_consul/api/system.py169
-rw-r--r--moonv4/moon_consul/moon_consul/http_server.py134
-rw-r--r--moonv4/moon_consul/moon_consul/server.py82
-rw-r--r--moonv4/moon_consul/requirements.txt5
-rw-r--r--moonv4/moon_consul/setup.py50
18 files changed, 0 insertions, 1070 deletions
diff --git a/moonv4/moon_consul/Changelog b/moonv4/moon_consul/Changelog
deleted file mode 100644
index 5ccc3c27..00000000
--- a/moonv4/moon_consul/Changelog
+++ /dev/null
@@ -1,13 +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'.
-
-
-CHANGES
-=======
-
-0.1.0
------
-- First version of the moon_consul component.
-
diff --git a/moonv4/moon_consul/Dockerfile b/moonv4/moon_consul/Dockerfile
deleted file mode 100644
index 1d3c7108..00000000
--- a/moonv4/moon_consul/Dockerfile
+++ /dev/null
@@ -1,37 +0,0 @@
-# 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
diff --git a/moonv4/moon_consul/LICENSE b/moonv4/moon_consul/LICENSE
deleted file mode 100644
index 4143aac2..00000000
--- a/moonv4/moon_consul/LICENSE
+++ /dev/null
@@ -1,204 +0,0 @@
-
- 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.
diff --git a/moonv4/moon_consul/MANIFEST.in b/moonv4/moon_consul/MANIFEST.in
deleted file mode 100644
index ba8a657e..00000000
--- a/moonv4/moon_consul/MANIFEST.in
+++ /dev/null
@@ -1,11 +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'.
-
-include README.rst
-include LICENSE
-include setup.py
-include requirements.txt
-# graft tests
-graft bin \ No newline at end of file
diff --git a/moonv4/moon_consul/README.md b/moonv4/moon_consul/README.md
deleted file mode 100644
index afee9be5..00000000
--- a/moonv4/moon_consul/README.md
+++ /dev/null
@@ -1,9 +0,0 @@
-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
diff --git a/moonv4/moon_consul/moon_consul/__init__.py b/moonv4/moon_consul/moon_consul/__init__.py
deleted file mode 100644
index 3dc1f76b..00000000
--- a/moonv4/moon_consul/moon_consul/__init__.py
+++ /dev/null
@@ -1 +0,0 @@
-__version__ = "0.1.0"
diff --git a/moonv4/moon_consul/moon_consul/__main__.py b/moonv4/moon_consul/moon_consul/__main__.py
deleted file mode 100644
index 4d64288e..00000000
--- a/moonv4/moon_consul/moon_consul/__main__.py
+++ /dev/null
@@ -1,3 +0,0 @@
-from moon_consul.server import main
-
-main()
diff --git a/moonv4/moon_consul/moon_consul/api/__init__.py b/moonv4/moon_consul/moon_consul/api/__init__.py
deleted file mode 100644
index e69de29b..00000000
--- a/moonv4/moon_consul/moon_consul/api/__init__.py
+++ /dev/null
diff --git a/moonv4/moon_consul/moon_consul/api/database.py b/moonv4/moon_consul/moon_consul/api/database.py
deleted file mode 100644
index 5533b1a5..00000000
--- a/moonv4/moon_consul/moon_consul/api/database.py
+++ /dev/null
@@ -1,72 +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'.
-"""
-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
- }
- }
-
diff --git a/moonv4/moon_consul/moon_consul/api/generic.py b/moonv4/moon_consul/moon_consul/api/generic.py
deleted file mode 100644
index 69f25eef..00000000
--- a/moonv4/moon_consul/moon_consul/api/generic.py
+++ /dev/null
@@ -1,78 +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'.
-"""
-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
-
diff --git a/moonv4/moon_consul/moon_consul/api/messenger.py b/moonv4/moon_consul/moon_consul/api/messenger.py
deleted file mode 100644
index 28026baf..00000000
--- a/moonv4/moon_consul/moon_consul/api/messenger.py
+++ /dev/null
@@ -1,67 +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'.
-"""
-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,
- }
- }
-
diff --git a/moonv4/moon_consul/moon_consul/api/openstack.py b/moonv4/moon_consul/moon_consul/api/openstack.py
deleted file mode 100644
index 5d776981..00000000
--- a/moonv4/moon_consul/moon_consul/api/openstack.py
+++ /dev/null
@@ -1,63 +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'.
-"""
-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
- }
- }
-
diff --git a/moonv4/moon_consul/moon_consul/api/slave.py b/moonv4/moon_consul/moon_consul/api/slave.py
deleted file mode 100644
index 7f8acb28..00000000
--- a/moonv4/moon_consul/moon_consul/api/slave.py
+++ /dev/null
@@ -1,72 +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'.
-"""
-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": {}}
-
diff --git a/moonv4/moon_consul/moon_consul/api/system.py b/moonv4/moon_consul/moon_consul/api/system.py
deleted file mode 100644
index e21d9de2..00000000
--- a/moonv4/moon_consul/moon_consul/api/system.py
+++ /dev/null
@@ -1,169 +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'.
-"""
-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
-
diff --git a/moonv4/moon_consul/moon_consul/http_server.py b/moonv4/moon_consul/moon_consul/http_server.py
deleted file mode 100644
index c3d13378..00000000
--- a/moonv4/moon_consul/moon_consul/http_server.py
+++ /dev/null
@@ -1,134 +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'.
-
-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
-
diff --git a/moonv4/moon_consul/moon_consul/server.py b/moonv4/moon_consul/moon_consul/server.py
deleted file mode 100644
index 7d42228b..00000000
--- a/moonv4/moon_consul/moon_consul/server.py
+++ /dev/null
@@ -1,82 +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 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()
diff --git a/moonv4/moon_consul/requirements.txt b/moonv4/moon_consul/requirements.txt
deleted file mode 100644
index ab99edaa..00000000
--- a/moonv4/moon_consul/requirements.txt
+++ /dev/null
@@ -1,5 +0,0 @@
-oslo.messaging
-flask
-flask_restful
-flask_cors
-moon_utilities \ No newline at end of file
diff --git a/moonv4/moon_consul/setup.py b/moonv4/moon_consul/setup.py
deleted file mode 100644
index d4aac83c..00000000
--- a/moonv4/moon_consul/setup.py
+++ /dev/null
@@ -1,50 +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'.
-
-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',
- ],
- }
-
-)