Sign Up
Log In
Log In
or
Sign Up
Places
All Projects
Status Monitor
Collapse sidebar
systemsmanagement:Ardana:8:CentOS:7.5
ardana-installer-server
ardana-installer-server-8.0+git.1542817521.6bc7...
Overview
Repositories
Revisions
Requests
Users
Attributes
Meta
File ardana-installer-server-8.0+git.1542817521.6bc7c3b.obscpio of Package ardana-installer-server
07070100000000000081A40000000000000000000000015BF586F10000006B000000000000000000000000000000000000003E00000000ardana-installer-server-8.0+git.1542817521.6bc7c3b/.gitignore.venv .tox dist .eggs *egg-info/ build /data log local.cfg *.pyc AUTHORS ChangeLog etc/service.conf.sample 07070100000001000081A40000000000000000000000015BF586F1000027A1000000000000000000000000000000000000003B00000000ardana-installer-server-8.0+git.1542817521.6bc7c3b/LICENSE 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. 07070100000002000081A40000000000000000000000015BF586F100000473000000000000000000000000000000000000003E00000000ardana-installer-server-8.0+git.1542817521.6bc7c3b/README.rst.. (c) Copyright 2017-2018 SUSE LLC ============================== Ardana Installer Server ============================== REST server for Ardana cloud installer --------------- Getting Started --------------- Start the service using:: Use 'tox -e runserver' to start the server (on port 8081) --- API --- All REST endpoints begin with ``/api/v1``. The following endpoints are supported: ``/api/v1/progress`` (``GET`` or ``POST``) Data to track the progress of the installer. ``/api/v1/server`` (``GET``,``POST``,``PUT``,``DELETE``) Scratch space for general server details ``/api/v1/sm/servers`` (``GET``) Retrieves a list of servers from SUSE Manager ``/api/v1/sm/servers/{id}`` (``GET``) Retrieves the details of the given server from SUSE Manager ``/api/v1/ov/servers`` (``GET``) Retrieves a list of servers from HPE OneView ``/api/v1/ov/servers/{id}`` (``GET``) Retrieves the details of the given server from HPE OneView ``/api/v1/clm/...`` Requests to this URL are forwarded to the corresponding endpoint under ``/api/v2`` in the Ardana Service 07070100000003000041ED0000000000000000000000025BF586F100000000000000000000000000000000000000000000004B00000000ardana-installer-server-8.0+git.1542817521.6bc7c3b/ardana_installer_server07070100000004000081A40000000000000000000000015BF586F10000047C000000000000000000000000000000000000005700000000ardana-installer-server-8.0+git.1542817521.6bc7c3b/ardana_installer_server/__init__.py# (c) Copyright 2017-2018 SUSE LLC # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. from eventlet import monkey_patch as monkey_patch from flask_socketio import SocketIO # IMPORTANT! # When using eventlet, monkey_patch is needed in order to propertly handle # IO asyncronously. Without this, the reading of stdout from the playbook # run will block until after that playbook has finished. monkey_patch() # When using eventlet, it is important to monkeypatch so that the IO does not # hang. When using the "threading" model, long polling is used instead of # WebSockets, and its performance is a bit lower socketio = SocketIO(async_mode="eventlet") 07070100000005000081A40000000000000000000000015BF586F100000709000000000000000000000000000000000000005400000000ardana-installer-server-8.0+git.1542817521.6bc7c3b/ardana_installer_server/admin.py# (c) Copyright 2018 SUSE LLC # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. from flask import Blueprint from flask import jsonify from flask import request from oslo_config import cfg import threading import time from util import ping bp = Blueprint('admin', __name__) CONF = cfg.CONF SUCCESS = {"success": True} def update_trigger_file(): with open(CONF.general.restart_trigger_file, 'w') as f: f.write("Triggered restart at %s\n" % time.asctime()) @bp.route("/api/v1/restart", methods=['POST']) def restart(): """Requests the service to restart after a specified delay, in seconds .. :quickref: Admin; Requests a service restart after a delay **Example Request**: .. sourcecode:: http POST /api/v2/user HTTP/1.1 Content-Type: application/json { "delay": 60 } """ info = request.get_json() or {} delay_secs = int(info.get('delay', 0)) t = threading.Timer(delay_secs, update_trigger_file) t.start() return jsonify(SUCCESS) @bp.route("/api/v1/connection_test", methods=['POST']) def connection_test(): body = request.get_json() or {} host = body['host'] try: ping(host, 22) return jsonify('Success') except Exception as e: return jsonify(error=str(e)), 404 07070100000006000081A40000000000000000000000015BF586F100000396000000000000000000000000000000000000005500000000ardana-installer-server-8.0+git.1542817521.6bc7c3b/ardana_installer_server/ardana.py# (c) Copyright 2017-2018 SUSE LLC # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. from . import util from flask import Blueprint from flask import request from oslo_config import cfg bp = Blueprint('ardana', __name__) @bp.route("/api/v1/clm/<path:url>", methods=['GET', 'POST', 'PUT', 'DELETE']) def ardana(url): url = cfg.CONF.general.ardana_service_url + "/api/v2/" + url return util.forward(url, request) 07070100000007000081A40000000000000000000000015BF586F100000864000000000000000000000000000000000000005500000000ardana-installer-server-8.0+git.1542817521.6bc7c3b/ardana_installer_server/config.py# (c) Copyright 2017-2018 SUSE LLC # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. from oslo_config import cfg general_opts = [ cfg.IPOpt('host', default='0.0.0.0', help='IP address to listen on.'), cfg.PortOpt('port', default=2209, help='Port number to listen on.'), cfg.StrOpt('db_file', default='/tmp/db.json', help='Location of database for discovered servers'), cfg.StrOpt('progress_file', default='/tmp/progress.json', help='Location of file to track progress through UI'), cfg.StrOpt('restart_trigger_file', default='/tmp/cloud_install_ui_trigger.txt', help='Location of file to trigger a flask restart to pickup new configs'), cfg.StrOpt('ui_home', default='web', help='Location of static files to serve'), cfg.URIOpt('ardana_service_url', default='http://localhost:9085', help='URL of ardana service'), ] url_opts = [ cfg.StrOpt('horizon', help='Location of horizon UI'), cfg.StrOpt('opsconsole', help='Location of operations console UI'), ] url_group = cfg.OptGroup(name='urls', title='URLs to be displayed on the completion page') CONF = cfg.CONF CONF.register_opts(general_opts, 'general') CONF.register_group(url_group) CONF.register_opts(url_opts, url_group) # This function is used by "tox -e genopts" to generate a config file # containing all options def list_opts(): return [('general', general_opts), ('urls', url_opts)] 07070100000008000081A40000000000000000000000015BF586F100000C26000000000000000000000000000000000000005300000000ardana-installer-server-8.0+git.1542817521.6bc7c3b/ardana_installer_server/main.py# (c) Copyright 2017-2018 SUSE LLC # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. from flask import Flask from flask_cors import CORS import os from oslo_config import cfg from oslo_log import log as logging import time from ardana_installer_server import admin from ardana_installer_server import ardana from ardana_installer_server import config # noqa: F401 from ardana_installer_server import oneview from ardana_installer_server import socket_proxy from ardana_installer_server import socketio from ardana_installer_server import suse_manager from ardana_installer_server import ui from ardana_installer_server.util import CustomJSONEncoder LOG = logging.getLogger(__name__) CONF = cfg.CONF logging.register_options(CONF) # Load config options from config file or command line CONF() # Setup the logging per the config options logging.setup(CONF, 'ardana_installer_service') app = Flask(__name__, static_url_path='', static_folder=CONF.general.ui_home) app.register_blueprint(admin.bp) app.register_blueprint(ardana.bp) app.register_blueprint(ui.bp) app.register_blueprint(oneview.bp) app.register_blueprint(suse_manager.bp) app.register_blueprint(socket_proxy.bp) app.json_encoder = CustomJSONEncoder # Flask logging is broken, and it is a time bomb: by default it does nothing, # but the first time an exception happens, it creates a new logger that # interferes with normal python logging, which messes up all subsequent log # messages. This bug was reported in # https://github.com/pallets/flask/issues/641 and is expected to be fixed in # the future when Flask 1.0 ships. Referring to app.logger forces this # creation via Flask's logger property handler. We then clean up the mess it # makes app.logger # initialize flask logging (screwing up logging) app.logger.handlers = [] # clear out the newly creating logger app.logger.propagate = True # let messages be handled by normal logging CORS(app) @app.route('/') def root(): return app.send_static_file('index.html') def main(): socketio.init_app(app) with open(CONF.general.restart_trigger_file , 'w') as f: f.write("Started at %s\n" % time.asctime()) # The 'log' parameter avoids running in debug mode, which suppresses the # debug message that is emitted on *every* incoming request. socketio.run(app, host=CONF.general.host, port=CONF.general.port, log=LOG, use_reloader=True, extra_files=[CONF.general.restart_trigger_file]) if __name__ == "__main__": main() 07070100000009000081A40000000000000000000000015BF586F100000B72000000000000000000000000000000000000005600000000ardana-installer-server-8.0+git.1542817521.6bc7c3b/ardana_installer_server/oneview.py# (c) Copyright 2017-2018 SUSE LLC # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. from flask import abort from flask import Blueprint from flask import jsonify from flask import request import json import requests from util import ping bp = Blueprint('oneview', __name__) """ Calls to HPE OneView """ @bp.route("/api/v1/ov/connection_test", methods=['POST']) def connection_test(): creds = request.get_json() or {} host = creds['host'] try: ping(host, 443) except Exception as e: return jsonify(error=str(e)), 404 verify = True secured = request.headers.get('Secured') if secured == 'false': verify = False try: url = "https://" + host + "/rest/login-sessions" headers = {'X-Api-Version': '200', 'Content-Type': 'application/json'} data = {'userName': creds['username'], 'password': creds['password']} response = requests.post(url, data=json.dumps(data), headers=headers, verify=verify) except Exception as e: if 'SSLError' in str(e): return jsonify(error=str(e)), 403 else: return jsonify(error=str(e)), 401 if not response.status_code == 200: return jsonify(error=response.json()['message']), 400 return jsonify(response.json()) @bp.route("/api/v1/ov/servers") def ov_server_list(): verify = True secured = request.headers.get('Secured') if secured == 'false': verify = False key = request.headers.get('Auth-Token') url = request.headers.get('Ov-Url') try: request_url = url + \ '/rest/server-hardware?start=0&count=-1&sort=position:desc' head = {'Auth': key, 'X-Api-Version': '200'} response = requests.get(request_url, headers=head, verify=verify) return jsonify(response.json()) except Exception: abort(400) @bp.route("/api/v1/ov/servers/<id>") def ov_server_details(id): verify = True secured = request.headers.get('Secured') if secured == 'false': verify = False key = request.headers.get('Auth-Token') url = request.headers.get('Ov-Url') try: request_url = url + '/rest/server-hardware/' + id head = {'Auth': key, 'X-Api-Version': '200'} response = requests.get(request_url, headers=head, verify=verify) return jsonify(response.json()) except Exception: abort(400) 0707010000000A000081A40000000000000000000000015BF586F100000ACB000000000000000000000000000000000000005B00000000ardana-installer-server-8.0+git.1542817521.6bc7c3b/ardana_installer_server/socket_proxy.py# (c) Copyright 2017-2018 SUSE LLC # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. from . import socketio import eventlet from flask import Blueprint from flask import copy_current_request_context from flask import request from flask_socketio import emit from oslo_config import cfg from oslo_log import log as logging from socketIO_client import BaseNamespace from socketIO_client import SocketIO import sys if sys.version_info.major < 3: from urlparse import urlparse else: from urllib.parse import urlparse CONF = cfg.CONF LOG = logging.getLogger(__name__) bp = Blueprint('socket_proxy', __name__) LOG_NAMESPACE = '/log' EVENT_NAMESPACE = '/event' class SocketProxy(object): def __init__(self, id, host, port): self.client = SocketIO(host, port, BaseNamespace) self.client.on('log', self.on_log) self.client.on('end', self.on_end) self.client.on('playbook-start', self.on_playbook_start) self.client.on('playbook-stop', self.on_playbook_stop) self.client.on('playbook-error', self.on_playbook_error) self.client.emit('join', id) def on_log(self, message): emit("log", message) def on_end(self, message): emit("end") self.client.disconnect() def on_playbook_start(self, playbook): emit("playbook-start", playbook) def on_playbook_stop(self, playbook): emit("playbook-stop", playbook) def on_playbook_error(self, playbook): emit("playbook-error", playbook) def wait(self): self.client.wait() # seconds=5) # Hack! _close is needed to *really* close the connection self.client._close() @socketio.on('join') def on_join(id): LOG.debug("Received request by %s to join %s", request.sid, id) @copy_current_request_context def wait_for_messages(id): # Per the socketIO-client documentation, the hostname parameter # must be prefixed with https:// in order to use SSL. url = urlparse(CONF.general.ardana_service_url) if url.scheme == 'https': host = 'https://' + url.hostname else: host = url.hostname proxy = SocketProxy(id, host, url.port) proxy.wait() eventlet.spawn(wait_for_messages, id) 0707010000000B000081A40000000000000000000000015BF586F100000D52000000000000000000000000000000000000005B00000000ardana-installer-server-8.0+git.1542817521.6bc7c3b/ardana_installer_server/suse_manager.py# (c) Copyright 2017-2018 SUSE LLC # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. from flask import Blueprint from flask import jsonify from flask import request import socket import ssl import sys if sys.version_info.major < 3: from xmlrpclib import ServerProxy else: from xmlrpc.client import ServerProxy bp = Blueprint('suse-manager', __name__) TIMEOUT = 2 """ Calls to SUSE Manager """ def get_client(url, verify_ssl): context = ssl._create_default_https_context() if verify_ssl == 'false': context = ssl._create_unverified_context() client = ServerProxy(url, verbose=0, context=context) return client @bp.route("/api/v1/sm/connection_test", methods=['POST']) def connection_test(): context = ssl._create_default_https_context() verify_ssl = request.headers.get('Secured') if verify_ssl == 'false': context = ssl._create_unverified_context() creds = request.get_json() or {} port = "443" if creds['port'] and creds['port'] != 0: port = creds['port'] # check the host and port first before login try: s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) s.settimeout(TIMEOUT) s.connect((creds['host'], int(port))) except Exception as e: return jsonify(error=str(e)), 404 # login try: suma_url = "https://" + creds['host'] + ":" + str(port) + "/rpc/api" suma_username = creds['username'] suma_password = creds['password'] client = ServerProxy(suma_url, verbose=0, context=context) key = client.auth.login(suma_username, suma_password) return jsonify(key) except Exception as e: if 'SSL:' in str(e) or 'doesn\'t match' in str(e): return jsonify(error=str(e)), 403 else: return jsonify(error=str(e)), 401 @bp.route("/api/v1/sm/servers") def sm_server_list(): try: key = request.headers.get('Auth-Token') url = request.headers.get('Suse-Manager-Url') verify_ssl = request.headers.get('Secured') client = get_client(url, verify_ssl) server_list = client.system.listActiveSystems(key) return jsonify(server_list) except Exception as e: return jsonify(error=str(e)), 400 @bp.route("/api/v1/sm/servers/<id>") def sm_server_details(id): try: key = request.headers.get('Auth-Token') url = request.headers.get('Suse-Manager-Url') verify_ssl = request.headers.get('Secured') client = get_client(url, verify_ssl) detail_list = client.system.listActiveSystemsDetails(key, int(id)) detail = detail_list[0] detail.update(client.system.getDetails(key, int(id))) detail.update({"running_kernel": client.system.getRunningKernel( key, int(id))}) return jsonify(detail) except Exception as e: return jsonify(error=str(e)), 400 0707010000000C000081A40000000000000000000000015BF586F100001EF2000000000000000000000000000000000000005100000000ardana-installer-server-8.0+git.1542817521.6bc7c3b/ardana_installer_server/ui.py# (c) Copyright 2017-2018 SUSE LLC # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. from flask import abort from flask import Blueprint from flask import jsonify from flask import request import json import os from oslo_config import cfg import pwd import re import subprocess from tinydb import Query from tinydb import TinyDB bp = Blueprint('ui', __name__) SUCCESS = {"success": True} CONF = cfg.CONF """ Calls handled locally to support the UI """ @bp.route("/api/v1/progress", methods=['GET']) def get_progress(): contents = '' try: with open(CONF.general.progress_file) as f: contents = json.load(f) except IOError: pass return jsonify(contents) @bp.route("/api/v1/progress", methods=['POST']) def save_progress(): data = request.get_json() try: with open(CONF.general.progress_file, "w") as f: json.dump(data, f) return jsonify(SUCCESS) except Exception: abort(400) # /server CRUD operations @bp.route("/api/v1/server", methods=['POST']) def insert_servers(): """Inserts a list of servers to the server table. 'uid' and 'source' fields must be unique **Example Request**: .. sourcecode:: http POST /api/v1/server HTTP/1.1 where the body contains a list of server dictionaries """ db = TinyDB(CONF.general.db_file) server_table = db.table('servers') server = Query() try: data = request.get_json() # Check for dupes and missing uid & server keys for entry in data: if not set(['id', 'uid', 'source']).issubset(entry): return jsonify(error="There is one or more entries missing " "id , uid or source"), 400 sid = entry['uid'] src = entry['source'] if not set(src.split(',')).issubset(['sm', 'ov', 'manual']): return jsonify(error="source=%s for uid=%s is " "invalid" % (src, sid)), 400 server_entries = server_table.search( (server.uid == sid) & (server.source == src)) if server_entries: return jsonify(error="There is an entry already matching " "uid=%s and server=%s" % (sid, src)), 400 server_table.insert_multiple(server for server in data) return jsonify(SUCCESS) except Exception: abort(400) @bp.route("/api/v1/server", methods=['GET']) def get_servers(): """Returns a list of server(s) given a list of 'source' 'source' is a comma-delimited list joined by an OR statement **Example Request**: .. sourcecode:: http GET /api/v1/server?source=src1,src2 HTTP/1.1 """ db = TinyDB(CONF.general.db_file) server_table = db.table('servers') try: src = request.args.get('source', None) if not src: return jsonify(server_table.all()) results = server_table.search(create_query(src)) return jsonify(results) except Exception: abort(400) @bp.route("/api/v1/server", methods=['PUT']) def update_server(): """Update a single server entry (dict) into the server table. 'id' and 'source' fields must be unique **Example Request**: .. sourcecode:: http PUT /api/v1/server HTTP/1.1 where the body contains a dictionary containing a server's details """ db = TinyDB(CONF.general.db_file) server_table = db.table('servers') server = Query() try: entry = request.get_json() if not set(['uid', 'source']).issubset(entry): return jsonify(error="There is one or more entries missing " "uid or source"), 400 sid = entry['uid'] src = entry['source'] if not set(src.split(',')).issubset(['sm', 'ov', 'manual']): return jsonify(error="source=%s for uid=%s is " "invalid" % (src, sid)), 400 server_entries = server_table.search( (server.uid == sid) & (server.source == src)) if not server_entries: return jsonify(error="uid:%s; source:%s not found " "to be updated" % (sid, src)), 404 server_table.remove( (server.uid == sid) & (server.source == src)) server_table.insert(entry) return jsonify(SUCCESS) except Exception: abort(400) @bp.route("/api/v1/server", methods=['DELETE']) def delete_server(): """Removes servers given a set of search parameters. The search parameters used are the same as get_servers() **Example Request**: .. sourcecode:: http DELETE /api/v1/server?source=src1,src2&uid=1234 HTTP/1.1 """ db = TinyDB(CONF.general.db_file) server_table = db.table('servers') try: src = request.args.get('source', None) uid = request.args.get('uid', None) if not src: return jsonify(error="source must be specified"), 400 server_table.remove(create_query(src, uid)) return jsonify(SUCCESS) except Exception: abort(400) def create_query(src, uid=None): q = Query() if uid: return (q.uid == uid) if src: if not set(src.split(',')).issubset(['sm', 'ov', 'manual']): return jsonify(error="specified sources are invalid"), 400 query = None for source in src.split(','): if query is None: query = (q.source == source) else: query |= (q.source == source) return query @bp.route("/api/v1/ips", methods=['GET']) def get_ips(): """Returns list of ip addresses of the local host **Example Request**: .. sourcecode:: http GET /api/v1/ips HTTP/1.1 **Example Response**: .. sourcecode:: http HTTP/1.1 200 OK [ "127.0.0.1", "192.168.1.200" ] """ ips = [] pattern = re.compile(r'inet +([0-9.]+)') try: lines = subprocess.check_output(["ip", "-o", "-4", "addr", "show"], universal_newlines=True) for line in lines.split('\n'): match = pattern.search(line) if match: ips.append(match.group(1)) except subprocess.CalledProcessError: pass return jsonify(ips) @bp.route("/api/v1/external_urls", methods=['GET']) def get_external_urls(): """Returns list of external URLs Returns the list of external URLs that the customer can access via the browser once cloud deployment is complete **Example Request**: .. sourcecode:: http GET /api/v1/external_urls HTTP/1.1 **Example Response**: .. sourcecode:: http HTTP/1.1 200 OK { "horizon": "https://192.168.245.6:443", "opsconsole": "https://192.168.245.5:9095" } """ cfg.CONF.reload_config_files() return jsonify(dict(cfg.CONF.urls.items())) @bp.route("/api/v1/user", methods=['GET']) def get_user(): """Returns the username the service is running under **Example Request**: .. sourcecode:: http GET /api/v1/user/1.1 **Example Response**: .. sourcecode:: http HTTP/1.1 200 OK {"username": "myusername"} """ user_dict = {'username': pwd.getpwuid(os.getuid()).pw_name} return jsonify(user_dict) 0707010000000D000081A40000000000000000000000015BF586F1000006E4000000000000000000000000000000000000005300000000ardana-installer-server-8.0+git.1542817521.6bc7c3b/ardana_installer_server/util.py# (c) Copyright 2017-2018 SUSE LLC # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. import datetime from flask import abort from flask.json import JSONEncoder import requests import socket import sys if sys.version_info.major < 3: from xmlrpclib import DateTime else: from xmlrpc.client import DateTime TIMEOUT = 2 class CustomJSONEncoder(JSONEncoder): def default(self, obj): try: if isinstance(obj, DateTime): return datetime.datetime.strptime( obj.value, "%Y%m%dT%H:%M:%S").isoformat() iterable = iter(obj) except TypeError: pass else: return list(iterable) return JSONEncoder.default(self, obj) # Forward the url to the given destination def forward(url, request): req = requests.Request(method=request.method, url=url, params=request.args, headers=request.headers, data=request.data) resp = requests.Session().send(req.prepare()) return (resp.text, resp.status_code, resp.headers.items()) def ping(host, port): try: s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) s.settimeout(TIMEOUT) s.connect((host, port)) except Exception: abort(404) 0707010000000E000041ED0000000000000000000000025BF586F100000000000000000000000000000000000000000000003700000000ardana-installer-server-8.0+git.1542817521.6bc7c3b/etc0707010000000F000081A40000000000000000000000015BF586F100000091000000000000000000000000000000000000004D00000000ardana-installer-server-8.0+git.1542817521.6bc7c3b/etc/config-generator.conf[DEFAULT] output_file = etc/service.conf.sample wrap_width = 79 namespace = ardana_installer_server namespace = oslo.config namespace = oslo.log 07070100000010000081A40000000000000000000000015BF586F1000001B2000000000000000000000000000000000000004400000000ardana-installer-server-8.0+git.1542817521.6bc7c3b/etc/devtest.conf[DEFAULT] # Direct logs to a file if desired: # log_file = /tmp/server.log # The default level of INFO for engineio and socketio yields messages # for every line of every log that is transferred through the socket. # WARN avoids that. default_log_levels = engineio=WARN,socketio=WARN [general] host = 0.0.0.0 port = 8081 db_file = /tmp/db.json progress_file = /tmp/progress.json ardana_service_url = http://localhost:9085 [urls] 07070100000011000081A40000000000000000000000015BF586F100000101000000000000000000000000000000000000004400000000ardana-installer-server-8.0+git.1542817521.6bc7c3b/requirements.txteventlet>=0.20.0 # MIT Flask>=0.10,<1.0 # BSD Flask-Cors # MIT Flask-SocketIO # MIT PyYAML>=3.10.0 # MIT requests # APACHE2 socketIO-client>=0.7.0 # MIT tinydb>=3.5.0 # MIT oslo.config>=4.11.0 # Apache-2.0 oslo.log>=3.30.0 # Apache-2.0 07070100000012000081ED0000000000000000000000015BF586F100000383000000000000000000000000000000000000003D00000000ardana-installer-server-8.0+git.1542817521.6bc7c3b/setup.cfg[metadata] name = ardana-installer-server summary = Ardana OpenStack Cloud Installer Server description-file = README.rst author = Ardana developers author-email = ardana@googlegroups.com home-page = https://github.com/ArdanaCLM/ardana-installer-server classifier = Environment :: OpenStack Intended Audience :: Information Technology Intended Audience :: System Administrators License :: OSI Approved :: Apache Software License Operating System :: POSIX :: Linux Programming Language :: Python Programming Language :: Python :: 2 Programming Language :: Python :: 2.7 Programming Language :: Python :: 3.5 [global] setup-hooks = pbr.hooks.setup_hook [files] packages = ardana_installer_server [entry_points] oslo.config_opts = ardana_installer_server = ardana_installer_server.config:list_opts console_scripts = ardana-installer-server = ardana_installer_server.main:main 07070100000013000081A40000000000000000000000015BF586F1000003EA000000000000000000000000000000000000003C00000000ardana-installer-server-8.0+git.1542817521.6bc7c3b/setup.py# (c) Copyright 2017-2018 SUSE LLC # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. # # THIS FILE IS MANAGED BY THE GLOBAL REQUIREMENTS REPO - DO NOT EDIT import setuptools # In python < 2.7.4, a lazy loading of package `pbr` will break # setuptools if some other modules registered functions in `atexit`. # solution from: http://bugs.python.org/issue15881#msg170215 try: import multiprocessing # noqa except ImportError: pass setuptools.setup( setup_requires=['pbr>=2.0.0'], pbr=True) 07070100000014000081A40000000000000000000000015BF586F100000236000000000000000000000000000000000000004900000000ardana-installer-server-8.0+git.1542817521.6bc7c3b/test-requirements.txt# The order of packages is significant, because pip processes them in the order # of appearance. Changing the order has an impact on the overall integration # process, which may cause wedges in the gate later. # Order matters to the pip dependency resolver, so sorting this file # changes how packages are installed. New dependencies should be # added in alphabetical order, however, some dependencies may need to # be installed in a specific order. # # Hacking should appear first in case something else depends on pep8 hacking!=0.13.0,<0.14,>=0.12.0 # Apache-2.0 07070100000015000081A40000000000000000000000015BF586F100000448000000000000000000000000000000000000003B00000000ardana-installer-server-8.0+git.1542817521.6bc7c3b/tox.ini[tox] envlist = py27,py34,pep8 minversion = 2.0 skipsdist = True [testenv] usedevelop = True install_command = pip install -c{env:UPPER_CONSTRAINTS_FILE:https://git.openstack.org/cgit/openstack/requirements/plain/upper-constraints.txt} {opts} {packages} setenv = VIRTUAL_ENV={envdir} deps = -r{toxinidir}/requirements.txt -r{toxinidir}/test-requirements.txt commands = venv: {posargs} whitelist_externals = bash [testenv:runserver] passenv = REQUESTS_CA_BUNDLE commands = {envpython} ardana_installer_server/main.py --config-file etc/devtest.conf {posargs} [testenv:py27] commands = {envpython} {toxinidir}/setup.py test {posargs} [testenv:py34] commands = {envpython} {toxinidir}/setup.py test {posargs} [testenv:pep8] commands = {envbindir}/flake8 {posargs} . [testenv:testclient] commands = {envpython} client.py {posargs} [testenv:genconfig] commands = oslo-config-generator --config-file=etc/config-generator.conf [flake8] # H102 not ready to require license headers ignore = E251,H102,H304 exclude = .git,.venv,.tox,dist,*egg-info,build,.eggs max-complexity=30 07070100000000000000000000000000000000000000010000000000000000000000000000000000000000000000000000000B00000000TRAILER!!!94 blocks
Locations
Projects
Search
Status Monitor
Help
OpenBuildService.org
Documentation
API Documentation
Code of Conduct
Contact
Support
@OBShq
Terms
openSUSE Build Service is sponsored by
The Open Build Service is an
openSUSE project
.
Sign Up
Log In
Places
Places
All Projects
Status Monitor