1234 lines
63 KiB
Python
1234 lines
63 KiB
Python
from flask import jsonify, request
|
|
import json
|
|
import requests
|
|
import os
|
|
import time
|
|
from lxconsole import db
|
|
from lxconsole.models import Server
|
|
from datetime import datetime
|
|
from flask_login import login_required
|
|
from lxconsole.api.access_controls import privilege_check
|
|
|
|
|
|
def get_client_crt():
|
|
return 'certs/client.crt'
|
|
|
|
def get_client_key():
|
|
return 'certs/client.key'
|
|
|
|
@login_required
|
|
def api_instance_endpoint(endpoint):
|
|
|
|
if not privilege_check(endpoint, request.args.get('id')):
|
|
return jsonify({'data': [], 'metadata':[], 'error': 'not authorized', 'error_code': 403})
|
|
|
|
|
|
if endpoint == 'add_instance_disk_device':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
instance = request.args.get('instance')
|
|
server = Server.query.filter_by(id=id).first()
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + instance + '?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
results = requests.get(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
instance = json.dumps(results.json())
|
|
instance = json.loads(instance)
|
|
# Before applying PATCH, check to make sure device does not already exists so that we do not overwrite an existing device
|
|
if request.form.get('name') in instance['metadata']['devices'].keys():
|
|
return jsonify({"type": "error","error": "Unable to add new device. Device name already exists","error_code": 409,"metadata": {"error": "Unable to add new device. Device name already exists"}})
|
|
description = instance['metadata']['description']
|
|
data = {}
|
|
device = {}
|
|
device.update({'type': 'disk'})
|
|
device.update({'pool': request.form.get('pool')}) if request.form.get('pool') else False
|
|
device.update({'source': request.form.get('source')}) if request.form.get('source') else False
|
|
device.update({'path': request.form.get('path')}) if request.form.get('path') else False
|
|
device.update({'limits_read': request.form.get('limits_read')}) if request.form.get('limits_read') else False
|
|
device.update({'limits_write': request.form.get('limits_write')}) if request.form.get('limits_write') else False
|
|
device.update({'limits_max': request.form.get('limits_max')}) if request.form.get('limits_max') else False
|
|
device.update({'required': request.form.get('required')}) if request.form.get('required') else False
|
|
device.update({'read_only': request.form.get('read_only')}) if request.form.get('read_only') else False
|
|
device.update({'size': request.form.get('size')}) if request.form.get('size') else False
|
|
device.update({'size_state': request.form.get('size_state')}) if request.form.get('size_state') else False
|
|
device.update({'recursive': request.form.get('recursive')}) if request.form.get('recursive') else False
|
|
device.update({'propagation': request.form.get('propagation')}) if request.form.get('propagation') else False
|
|
device.update({'shift': request.form.get('shift')}) if request.form.get('shift') else False
|
|
device.update({'raw_mount_options': request.form.get('raw_mount_options')}) if request.form.get('raw_mount_options') else False
|
|
device.update({'ceph_user_name': request.form.get('ceph_user_name')}) if request.form.get('ceph_user_name') else False
|
|
device.update({'ceph_cluster_name': request.form.get('ceph_cluster_name')}) if request.form.get('ceph_cluster_name') else False
|
|
device.update({'boot_priority': request.form.get('boot_priority')}) if request.form.get('boot_priority') else False
|
|
|
|
devices = {}
|
|
devices.update({request.form.get('name'): device})
|
|
data.update({'description': description})
|
|
data.update({'devices': devices})
|
|
results = requests.patch(url, verify=server.ssl_verify, cert=(client_cert, client_key), json=data)
|
|
return jsonify(results.json())
|
|
|
|
|
|
if endpoint == 'add_instance_gpu_device':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
instance = request.args.get('instance')
|
|
server = Server.query.filter_by(id=id).first()
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + instance + '?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
results = requests.get(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
instance = json.dumps(results.json())
|
|
instance = json.loads(instance)
|
|
# Before applying PATCH, check to make sure device does not already exists so that we do not overwrite an existing device
|
|
if request.form.get('name') in instance['metadata']['devices'].keys():
|
|
return jsonify({"type": "error","error": "Unable to add new device. Device name already exists","error_code": 409,"metadata": {"error": "Unable to add new device. Device name already exists"}})
|
|
description = instance['metadata']['description']
|
|
data = {}
|
|
device = {}
|
|
device.update({'type': 'gpu'})
|
|
device.update({'gputype': request.form.get('gputype')}) if request.form.get('gputype') else False
|
|
device.update({'vendorid': request.form.get('vendorid')}) if request.form.get('vendorid') else False
|
|
device.update({'productid': request.form.get('productid')}) if request.form.get('productid') else False
|
|
device.update({'id': request.form.get('id')}) if request.form.get('id') else False
|
|
device.update({'pci': request.form.get('pci')}) if request.form.get('pci') else False
|
|
device.update({'uid': request.form.get('uid')}) if request.form.get('uid') else False
|
|
device.update({'gid': request.form.get('gid')}) if request.form.get('gid') else False
|
|
device.update({'mode': request.form.get('mode')}) if request.form.get('mode') else False
|
|
device.update({'mig.ci': request.form.get('mig.ci')}) if request.form.get('mig.ci') else False
|
|
device.update({'mig.gi': request.form.get('mig.gi')}) if request.form.get('mig.gi') else False
|
|
devices = {}
|
|
devices.update({request.form.get('name'): device})
|
|
data.update({'description': description})
|
|
data.update({'devices': devices})
|
|
results = requests.patch(url, verify=server.ssl_verify, cert=(client_cert, client_key), json=data)
|
|
return jsonify(results.json())
|
|
|
|
|
|
if endpoint == 'add_instance_network_device':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
instance = request.args.get('instance')
|
|
server = Server.query.filter_by(id=id).first()
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + instance + '?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
results = requests.get(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
instance = json.dumps(results.json())
|
|
instance = json.loads(instance)
|
|
# Before applying PATCH, check to make sure device does not already exists so that we do not overwrite an existing device
|
|
if request.form.get('name') in instance['metadata']['devices'].keys():
|
|
return jsonify({"type": "error","error": "Unable to add new device. Device name already exists","error_code": 409,"metadata": {"error": "Unable to add new device. Device name already exists"}})
|
|
description = instance['metadata']['description']
|
|
data = {}
|
|
device = {}
|
|
device.update({'type': 'nic'})
|
|
device.update({'nictype': request.form.get('nictype')}) if request.form.get('nictype') else False
|
|
device.update({'parent': request.form.get('parent')}) if request.form.get('parent') else False
|
|
device.update({'network': request.form.get('network')}) if request.form.get('network') else False
|
|
device.update({'interface_name': request.form.get('interface_name')}) if request.form.get('interface_name') else False
|
|
device.update({'mtu': request.form.get('mtu')}) if request.form.get('mtu') else False
|
|
device.update({'mode': request.form.get('mode')}) if request.form.get('mode') else False
|
|
device.update({'hwaddr': request.form.get('hwaddr')}) if request.form.get('hwaddr') else False
|
|
device.update({'host_name': request.form.get('host_name')}) if request.form.get('host_name') else False
|
|
device.update({'limits_ingress': request.form.get('limits_ingress')}) if request.form.get('limits_ingress') else False
|
|
device.update({'limits_egress': request.form.get('limits_egress')}) if request.form.get('limits_egress') else False
|
|
device.update({'limits_max': request.form.get('limits_max')}) if request.form.get('limits_max') else False
|
|
device.update({'ipv4_address': request.form.get('ipv4_address')}) if request.form.get('ipv4_address') else False
|
|
device.update({'ipv4_gateway': request.form.get('ipv4_gateway')}) if request.form.get('ipv4_gateway') else False
|
|
device.update({'ipv4_host_table': request.form.get('ipv4_host_table')}) if request.form.get('ipv4_host_table') else False
|
|
device.update({'ipv4_host_address': request.form.get('ipv4_host_address')}) if request.form.get('ipv4_host_address') else False
|
|
device.update({'ipv4_routes': request.form.get('ipv4_routes')}) if request.form.get('ipv4_routes') else False
|
|
device.update({'ipv4_routes_external': request.form.get('ipv4_routes_external')}) if request.form.get('ipv4_routes_external') else False
|
|
device.update({'ipv6_address': request.form.get('ipv6_address')}) if request.form.get('ipv6_address') else False
|
|
device.update({'ipv6_gateway': request.form.get('ipv6_gateway')}) if request.form.get('ipv6_gateway') else False
|
|
device.update({'ipv6_host_table': request.form.get('ipv6_host_table')}) if request.form.get('ipv6_host_table') else False
|
|
device.update({'ipv6_host_address': request.form.get('ipv6_host_address')}) if request.form.get('ipv6_host_address') else False
|
|
device.update({'ipv6_routes': request.form.get('ipv6_routes')}) if request.form.get('ipv6_routes') else False
|
|
device.update({'ipv6_routes_external': request.form.get('ipv6_routes_external')}) if request.form.get('ipv6_routes_external') else False
|
|
device.update({'security_mac_filtering': request.form.get('security_mac_filtering')}) if request.form.get('security_mac_filtering') else False
|
|
device.update({'security_ipv4_filtering': request.form.get('security_ipv4_filtering')}) if request.form.get('security_ipv4_filtering') else False
|
|
device.update({'security_ipv6_filtering': request.form.get('security_ipv6_filtering')}) if request.form.get('security_ipv6_filtering') else False
|
|
device.update({'maas_subnet_ipv4': request.form.get('maas_subnet_ipv4')}) if request.form.get('maas_subnet_ipv4') else False
|
|
device.update({'maas_subnet_ipv6': request.form.get('maas_subnet_ipv6')}) if request.form.get('maas_subnet_ipv6') else False
|
|
device.update({'boot_priority': request.form.get('boot_priority')}) if request.form.get('boot_priority') else False
|
|
device.update({'vlan': request.form.get('vlan')}) if request.form.get('vlan') else False
|
|
device.update({'vlan_tagged': request.form.get('vlan_tagged')}) if request.form.get('vlan_tagged') else False
|
|
device.update({'security_port_isolation': request.form.get('security_port_isolation')}) if request.form.get('security_port_isolation') else False
|
|
device.update({'gvrp': request.form.get('gvrp')}) if request.form.get('gvrp') else False
|
|
device.update({'security_acls': request.form.get('security_acls')}) if request.form.get('security_acls') else False
|
|
device.update({'security_acls_default_ingress_action': request.form.get('security_acls_default_ingress_action')}) if request.form.get('security_acls_default_ingress_action') else False
|
|
device.update({'security_acls_default_egress_action': request.form.get('security_acls_default_egress_action')}) if request.form.get('security_acls_default_egress_action') else False
|
|
device.update({'security_acls_default_ingress_logged': request.form.get('security_acls_default_ingress_logged')}) if request.form.get('security_acls_default_ingress_logged') else False
|
|
device.update({'security_acls_default_egress_logged': request.form.get('security_acls_default_egress_logged')}) if request.form.get('security_acls_default_egress_logged') else False
|
|
devices = {}
|
|
devices.update({request.form.get('name'): device})
|
|
data.update({'description': description})
|
|
data.update({'devices': devices})
|
|
results = requests.patch(url, verify=server.ssl_verify, cert=(client_cert, client_key), json=data)
|
|
return jsonify(results.json())
|
|
|
|
|
|
if endpoint == 'add_instance_proxy_device':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
instance = request.args.get('instance')
|
|
server = Server.query.filter_by(id=id).first()
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + instance + '?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
results = requests.get(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
instance = json.dumps(results.json())
|
|
instance = json.loads(instance)
|
|
# Before applying PATCH, check to make sure device does not already exists so that we do not overwrite an existing device
|
|
if request.form.get('name') in instance['metadata']['devices'].keys():
|
|
return jsonify({"type": "error","error": "Unable to add new device. Device name already exists","error_code": 409,"metadata": {"error": "Unable to add new device. Device name already exists"}})
|
|
description = instance['metadata']['description']
|
|
data = {}
|
|
device = {}
|
|
device.update({'type': 'proxy'})
|
|
device.update({'listen': request.form.get('listen')}) if request.form.get('listen') else False
|
|
device.update({'connect': request.form.get('connect')}) if request.form.get('connect') else False
|
|
device.update({'bind': request.form.get('bind')}) if request.form.get('bind') else False
|
|
device.update({'uid': request.form.get('uid')}) if request.form.get('uid') else False
|
|
device.update({'gid': request.form.get('gid')}) if request.form.get('gid') else False
|
|
device.update({'mode': request.form.get('mode')}) if request.form.get('mode') else False
|
|
device.update({'nat': request.form.get('nat')}) if request.form.get('nat') else False
|
|
device.update({'proxy_protocol': request.form.get('proxy_protocol')}) if request.form.get('proxy_protocol') else False
|
|
device.update({'security_uid': request.form.get('security_uid')}) if request.form.get('security_uid') else False
|
|
device.update({'security_gid': request.form.get('security_gid')}) if request.form.get('security_gid') else False
|
|
devices = {}
|
|
devices.update({request.form.get('name'): device})
|
|
data.update({'description': description})
|
|
data.update({'devices': devices})
|
|
results = requests.patch(url, verify=server.ssl_verify, cert=(client_cert, client_key), json=data)
|
|
return jsonify(results.json())
|
|
|
|
|
|
if endpoint == 'add_instance_unix_device':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
instance = request.args.get('instance')
|
|
server = Server.query.filter_by(id=id).first()
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + instance + '?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
results = requests.get(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
instance = json.dumps(results.json())
|
|
instance = json.loads(instance)
|
|
# Before applying PATCH, check to make sure device does not already exists so that we do not overwrite an existing device
|
|
if request.form.get('name') in instance['metadata']['devices'].keys():
|
|
return jsonify({"type": "error","error": "Unable to add new device. Device name already exists","error_code": 409,"metadata": {"error": "Unable to add new device. Device name already exists"}})
|
|
description = instance['metadata']['description']
|
|
data = {}
|
|
device = {}
|
|
device.update({'type': request.form.get('type')}) if request.form.get('type') else False
|
|
device.update({'source': request.form.get('source')}) if request.form.get('source') else False
|
|
device.update({'path': request.form.get('path')}) if request.form.get('path') else False
|
|
device.update({'major': request.form.get('major')}) if request.form.get('major') else False
|
|
device.update({'minor': request.form.get('minor')}) if request.form.get('minor') else False
|
|
device.update({'uid': request.form.get('uid')}) if request.form.get('uid') else False
|
|
device.update({'gid': request.form.get('gid')}) if request.form.get('gid') else False
|
|
device.update({'mode': request.form.get('mode')}) if request.form.get('mode') else False
|
|
device.update({'required': request.form.get('required')}) if request.form.get('required') else False
|
|
devices = {}
|
|
devices.update({request.form.get('name'): device})
|
|
data.update({'description': description})
|
|
data.update({'devices': devices})
|
|
results = requests.patch(url, verify=server.ssl_verify, cert=(client_cert, client_key), json=data)
|
|
return jsonify(results.json())
|
|
|
|
|
|
if endpoint == 'add_instance_usb_device':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
instance = request.args.get('instance')
|
|
server = Server.query.filter_by(id=id).first()
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + instance + '?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
results = requests.get(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
instance = json.dumps(results.json())
|
|
instance = json.loads(instance)
|
|
# Before applying PATCH, check to make sure device does not already exists so that we do not overwrite an existing device
|
|
if request.form.get('name') in instance['metadata']['devices'].keys():
|
|
return jsonify({"type": "error","error": "Unable to add new device. Device name already exists","error_code": 409,"metadata": {"error": "Unable to add new device. Device name already exists"}})
|
|
description = instance['metadata']['description']
|
|
data = {}
|
|
device = {}
|
|
device.update({'type': 'usb'})
|
|
device.update({'vendorid': request.form.get('vendorid')}) if request.form.get('vendorid') else False
|
|
device.update({'productid': request.form.get('productid')}) if request.form.get('productid') else False
|
|
device.update({'uid': request.form.get('uid')}) if request.form.get('uid') else False
|
|
device.update({'gid': request.form.get('gid')}) if request.form.get('gid') else False
|
|
device.update({'mode': request.form.get('mode')}) if request.form.get('mode') else False
|
|
devices = {}
|
|
devices.update({request.form.get('name'): device})
|
|
data.update({'description': description})
|
|
data.update({'devices': devices})
|
|
results = requests.patch(url, verify=server.ssl_verify, cert=(client_cert, client_key), json=data)
|
|
return jsonify(results.json())
|
|
|
|
|
|
if endpoint == 'attach_instance_profile':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
instance = request.args.get('instance')
|
|
server = Server.query.filter_by(id=id).first()
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + instance + '?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
results = requests.get(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
instance = json.dumps(results.json())
|
|
instance = json.loads(instance)
|
|
description = instance['metadata']['description']
|
|
data = {}
|
|
profiles = instance['metadata']['profiles']
|
|
if request.form.get('name') not in profiles:
|
|
profiles.append(request.form.get('name'))
|
|
data.update({'description': description})
|
|
data.update({'profiles': profiles})
|
|
results = requests.patch(url, verify=server.ssl_verify, cert=(client_cert, client_key), json=data)
|
|
return jsonify(results.json())
|
|
|
|
|
|
if endpoint == 'change_instance_state':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
instance = request.form.get('instance')
|
|
action = request.form.get('action')
|
|
force = request.form.get('force')
|
|
server = Server.query.filter_by(id=id).first()
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + instance + '/state?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
if force == 'true':
|
|
data = { 'action': action, 'force': True }
|
|
else:
|
|
data = { 'action': action, 'force': False }
|
|
results = requests.put(url, verify=server.ssl_verify, cert=(client_cert, client_key), json=data)
|
|
return jsonify(results.json())
|
|
|
|
|
|
if endpoint == 'copy_instance':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
instance = request.args.get('instance')
|
|
server = Server.query.filter_by(id=id).first()
|
|
location = request.args.get('location')
|
|
#Target location is needed for clustered servers and not allowed on non-clustered servers
|
|
if location == 'none':
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances?project=' + project
|
|
else:
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances?target='+location+'&project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
data = {}
|
|
data.update({'name': request.form.get('name')})
|
|
source = {}
|
|
source.update({'type': 'copy'})
|
|
source.update({'source': instance })
|
|
source.update({'project': project})
|
|
data.update({'source': source})
|
|
results = requests.post(url, verify=server.ssl_verify, cert=(client_cert, client_key), json=data)
|
|
return jsonify(results.json())
|
|
|
|
|
|
if endpoint == 'create_instance_backup':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
instance = request.args.get('instance')
|
|
server = Server.query.filter_by(id=id).first()
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + instance + '/backups?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
|
|
# Determine file name
|
|
name = request.form.get('name')
|
|
if not name:
|
|
now = datetime.now()
|
|
dt_string = now.strftime("%Y%m%d%H%M%S")
|
|
name = instance + '-' + dt_string
|
|
|
|
# Determine file extenstion
|
|
compression_algorithm = request.form.get('compression_algorithm')
|
|
if compression_algorithm == 'bzip2':
|
|
extenstion = '.tar.bz2'
|
|
elif compression_algorithm == 'gzip':
|
|
extenstion = '.tar.gz'
|
|
elif compression_algorithm == 'lzma':
|
|
extenstion = '.tar.lzma'
|
|
elif compression_algorithm == 'xz':
|
|
extenstion = '.tar.xz'
|
|
elif compression_algorithm == 'zstd':
|
|
extenstion = '.tar.zst'
|
|
else:
|
|
extenstion = '.tar'
|
|
|
|
# Append file extension to name
|
|
name = name + extenstion
|
|
|
|
data = {}
|
|
data.update({'name': name})
|
|
data.update({'instance_only': True }) if request.form.get('instance_only') == 'true' else data.update({'instance_only': False })
|
|
data.update({'optimized_storage': True }) if request.form.get('optimized_storage') == 'true' else data.update({'optimized_storage': False })
|
|
data.update({'compression_algorithm': request.form.get('compression_algorithm')}) if request.form.get('compression_algorithm') else False
|
|
results = requests.post(url, verify=server.ssl_verify, cert=(client_cert, client_key), json=data)
|
|
return jsonify(results.json())
|
|
|
|
|
|
if endpoint == 'create_instance_snapshot':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
instance = request.args.get('instance')
|
|
server = Server.query.filter_by(id=id).first()
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + instance + '/snapshots?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
data = {}
|
|
data.update({'name': request.form.get('name')})
|
|
if request.form.get('stateful') == 'true':
|
|
data.update({'stateful': True})
|
|
else:
|
|
data.update({'stateful': False})
|
|
results = requests.post(url, verify=server.ssl_verify, cert=(client_cert, client_key), json=data)
|
|
return jsonify(results.json())
|
|
|
|
|
|
if endpoint == 'create_instance_snapshot_instance':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
instance = request.args.get('instance')
|
|
server = Server.query.filter_by(id=id).first()
|
|
location = request.args.get('location')
|
|
#Target location is needed for clustered servers and not allowed on non-clustered servers
|
|
if location == 'none':
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances?project=' + project
|
|
else:
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances?target='+location+'&project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
data = {}
|
|
data.update({'name': request.form.get('name')})
|
|
source = {}
|
|
source.update({'type': 'copy'})
|
|
source.update({'instance_only': True})
|
|
source.update({'source': instance + '/' + request.form.get('snapshot')})
|
|
source.update({'project': project})
|
|
data.update({'source': source})
|
|
results = requests.post(url, verify=server.ssl_verify, cert=(client_cert, client_key), json=data)
|
|
return jsonify(results.json())
|
|
|
|
|
|
if endpoint == 'delete_instance_backup':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
instance = request.args.get('instance')
|
|
backup = request.args.get('backup')
|
|
server = Server.query.filter_by(id=id).first()
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + instance + '/backups/' + backup + '?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
if os.path.isfile('backups/' + str(server.id) + '/' + project + '/' + instance + '/' + backup):
|
|
os.unlink('backups/' + str(server.id) + '/' + project + '/' + instance + '/' + backup)
|
|
results = requests.delete(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
return jsonify(results.json())
|
|
|
|
|
|
if endpoint == 'delete_instance_device':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
instance = request.args.get('instance')
|
|
device = request.args.get('device')
|
|
server = Server.query.filter_by(id=id).first()
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + instance + '?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
results = requests.get(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
instance = json.dumps(results.json())
|
|
instance = json.loads(instance)
|
|
data = instance['metadata']
|
|
data['devices'].pop(device)
|
|
results = requests.put(url, verify=server.ssl_verify, cert=(client_cert, client_key), json=data)
|
|
return jsonify(results.json())
|
|
|
|
|
|
if endpoint == 'delete_instance':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
instance = request.form.get('instance')
|
|
server = Server.query.filter_by(id=id).first()
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + instance + '?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
results = requests.delete(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
return jsonify(results.json())
|
|
|
|
|
|
if endpoint == 'delete_instance_log':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
log = request.args.get('log')
|
|
server = Server.query.filter_by(id=id).first()
|
|
url = 'https://' + server.addr + ':' + str(server.port) + log + '?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
results = requests.delete(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
return jsonify(results.json())
|
|
|
|
|
|
if endpoint == 'delete_instance_snapshot':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
instance = request.args.get('instance')
|
|
snapshot = request.args.get('snapshot')
|
|
server = Server.query.filter_by(id=id).first()
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + instance + '/snapshots/' + snapshot + '?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
results = requests.delete(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
return jsonify(results.json())
|
|
|
|
|
|
if endpoint == 'detach_instance_profile':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
instance = request.args.get('instance')
|
|
profile = request.args.get('profile')
|
|
server = Server.query.filter_by(id=id).first()
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + instance + '?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
results = requests.get(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
instance = json.dumps(results.json())
|
|
instance = json.loads(instance)
|
|
instance = instance['metadata']
|
|
description = instance['description']
|
|
instance_profiles = instance['profiles']
|
|
instance_profiles.remove(profile)
|
|
data = {}
|
|
data.update({ 'description': description })
|
|
data.update({ 'profiles': instance_profiles})
|
|
results = requests.patch(url, verify=server.ssl_verify, cert=(client_cert, client_key), json=data)
|
|
return jsonify(results.json())
|
|
|
|
|
|
if endpoint == 'display_instance_log':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
server = Server.query.filter_by(id=id).first()
|
|
log = request.args.get('log')
|
|
url = 'https://' + server.addr + ':' + str(server.port) + log + '?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
results = requests.get(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
return results.text
|
|
|
|
|
|
if endpoint == 'establish_instance_console_websocket':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
instance = request.args.get('instance')
|
|
server = Server.query.filter_by(id=id).first()
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + instance + '/console?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
data = {}
|
|
data.update({'type': 'console'})
|
|
data.update({'width': int(request.form.get('width'))})
|
|
data.update({'height': int(request.form.get('height'))})
|
|
results = requests.post(url, verify=server.ssl_verify, cert=(client_cert, client_key), json=data)
|
|
results = json.dumps(results.json())
|
|
results = json.loads(results)
|
|
|
|
operation = results['operation'] if results['operation'] else ''
|
|
secret = str(results['metadata']['metadata']['fds']['0']) if str(results['metadata']['metadata']['fds']['0']) else ''
|
|
control = str(results['metadata']['metadata']['fds']['control']) if str(results['metadata']['metadata']['fds']['control']) else ''
|
|
|
|
return jsonify({'operation': operation, 'secret': secret, 'control': control})
|
|
|
|
|
|
if endpoint == 'establish_instance_exec_websocket':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
instance = request.args.get('instance')
|
|
server = Server.query.filter_by(id=id).first()
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + instance + '/exec?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
data = {}
|
|
if request.form.get('shell') == "sh":
|
|
data.update({'command': ["/bin/sh"]})
|
|
else:
|
|
data.update({'command': ["/bin/bash"]})
|
|
data.update({'wait-for-websocket':True})
|
|
data.update({'interactive': True})
|
|
data.update({'width': int(request.form.get('width'))})
|
|
data.update({'height': int(request.form.get('height'))})
|
|
environment = {}
|
|
environment.update({'HOME': '/root'})
|
|
environment.update({'TERM': 'xterm'})
|
|
environment.update({'USER': 'root'})
|
|
data.update({'environment': environment})
|
|
results = requests.post(url, verify=server.ssl_verify, cert=(client_cert, client_key), json=data)
|
|
results = json.dumps(results.json())
|
|
results = json.loads(results)
|
|
|
|
operation = results['operation'] if results['operation'] else ''
|
|
secret = str(results['metadata']['metadata']['fds']['0']) if str(results['metadata']['metadata']['fds']['0']) else ''
|
|
control = str(results['metadata']['metadata']['fds']['control']) if str(results['metadata']['metadata']['fds']['control']) else ''
|
|
|
|
return jsonify({'operation': operation, 'secret': secret, 'control': control})
|
|
|
|
|
|
if endpoint == 'export_instance_backup':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
server = Server.query.filter_by(id=id).first()
|
|
instance = request.args.get('instance')
|
|
backup = request.args.get('backup')
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + instance + '/backups/' + backup + '/export?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
os.system('mkdir -p backups/' + str(server.id) + '/' + project + '/' + instance)
|
|
filename = 'backups/' + str(server.id) + '/' + project + '/' + instance + '/' + backup
|
|
with requests.get(url, stream=True, verify=server.ssl_verify, cert=(client_cert, client_key)) as r:
|
|
r.raise_for_status()
|
|
with open(filename, 'wb') as f:
|
|
for chunk in r.iter_content(chunk_size=8192):
|
|
f.write(chunk)
|
|
return jsonify({"status": "Ok", "status_code": 200, "metadata": "{}"})
|
|
|
|
|
|
if endpoint == 'get_instance':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
server = Server.query.filter_by(id=id).first()
|
|
name = request.args.get('name')
|
|
recursion = request.args.get('recursion')
|
|
if recursion == '1':
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '?recursion=1&project=' + project
|
|
else:
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
results = requests.get(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
return jsonify(results.json())
|
|
|
|
# Virtual Machine only
|
|
if endpoint == 'copy_instance_proc_stat':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
server = Server.query.filter_by(id=id).first()
|
|
name = request.args.get('name')
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
|
|
# Unable to read /proc/stat directly on virtual machines use lxd files api...getting an EOF error
|
|
# So we will copy /proc/stat to /tmp/stat and then read that file as a work around
|
|
data = {}
|
|
data.update({'command': ['/bin/sh', '-c', 'cat /proc/stat \u003e /tmp/stat' ]})
|
|
#data.update({'command': ['cat', '/proc/stat']})
|
|
#data.update({'command': ['cp', '/proc/stat', '/tmp/stat']})
|
|
data.update({'wait-for-websocket': False})
|
|
data.update({'interactive': False})
|
|
data.update({'width': 80 })
|
|
data.update({'height': 24 })
|
|
data.update({'user': 0 })
|
|
data.update({'group': 0 })
|
|
data.update({'cwd': "/" })
|
|
data.update({'record-output': False })
|
|
data.update({'environment': {} })
|
|
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '/exec?project=' + project
|
|
results = requests.post(url, verify=server.ssl_verify, cert=(client_cert, client_key), json=data)
|
|
|
|
#Using record-output no longer appears to work, but it looks like lxd has code to use a new method of recording logs with exec-output as an option in the near future
|
|
#Set record-output: true in command
|
|
#exec_rtn = json.dumps(results.json())
|
|
#exec_rtn = json.loads(exec_rtn)
|
|
#Use operation to check for return value and get log output information
|
|
#operation = exec_rtn['operation']
|
|
#Check the logs/exec-ouput with get request to see if log exists /1.0/instances/{name}/logs/exec-output
|
|
#url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '/logs/exec-output?project=' + project
|
|
#results = requests.get(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
#results return a list of urls of exec-output files. Should be able to match operation to a file in the list
|
|
#example url: url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/test/logs/exec-output/exec_fea46679-fdaa-48f4-9079-502a090c4fb5.stdout'
|
|
#results = requests.get(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
#The returned value should be text: return results.text
|
|
#Check stdout log with get request "/1.0/instances/foo/logs/exec-output/exec_d0a89537-0617-4ed6-a79b-c2e88a970965.stdout",
|
|
#return results.text
|
|
#Check stderr log with get request "/1.0/instances/foo/logs/exec-output/exec_d0a89537-0617-4ed6-a79b-c2e88a970965.stderr",
|
|
#Else delete to delete log at /1.0/instances/{name}/logs/exec-output/{filename}
|
|
|
|
return jsonify(results.json())
|
|
|
|
# Virtual Machine only
|
|
if endpoint == 'get_instance_proc_stat':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
server = Server.query.filter_by(id=id).first()
|
|
name = request.args.get('name')
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
|
|
#Get /proc/stat information but from /tmp/stat
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '/files?project=' + project + '&path=/tmp/stat'
|
|
results = requests.get(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
if 'cpu' in results.text:
|
|
results = results.text.split('\n')
|
|
for result in results:
|
|
stats = result.split()
|
|
if 'cpu' in stats:
|
|
user_time = int(stats[1])
|
|
system_time= int(stats[3])
|
|
idle_time = int(stats[4])
|
|
return jsonify({'user_time':user_time, 'system_time':system_time, 'idle_time':idle_time})
|
|
return jsonify({'user_time':0, 'system_time':0, 'idle_time':0})
|
|
|
|
|
|
if endpoint == 'get_instance_cpu_usage':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
server = Server.query.filter_by(id=id).first()
|
|
name = request.args.get('name')
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
|
|
#Get instance state to retrieve instance cpu usage
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '/state?project=' + project
|
|
results = requests.get(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
results = json.dumps(results.json())
|
|
results = json.loads(results)
|
|
#Get cpu usage
|
|
if 'cpu' in results['metadata']:
|
|
if 'usage' in results['metadata']['cpu']:
|
|
#Usage is reported in nanoseconds
|
|
instance_cpu_time = int(results['metadata']['cpu']['usage'])
|
|
else:
|
|
instance_cpu_time = 0
|
|
else:
|
|
instance_cpu_time = 0
|
|
|
|
#Get /proc/stat information
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '/files?project=' + project + '&path=/proc/stat'
|
|
results = requests.get(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
if 'cpu' in results.text:
|
|
results = results.text.split('\n')
|
|
for result in results:
|
|
stats = result.split()
|
|
if stats[0] == 'cpu':
|
|
#0 = 'cpu'
|
|
#1 = <user time>
|
|
#2 = <nice time>
|
|
#3 = <system time>
|
|
#4 = <idle time>
|
|
user_time = int(stats[1])
|
|
system_time= int(stats[3])
|
|
idle_time = int(stats[4])
|
|
host_cpu_time = user_time + system_time + idle_time
|
|
|
|
return jsonify({'instance_cpu_time':instance_cpu_time,'host_cpu_time': host_cpu_time})
|
|
|
|
return jsonify({'instance_cpu_time':0,'host_cpu_time': 0})
|
|
|
|
|
|
if endpoint == 'get_instance_disk_devices':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
server = Server.query.filter_by(id=id).first()
|
|
name = request.args.get('name')
|
|
recursion = request.args.get('recursion')
|
|
if recursion == '1':
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '?recursion=1&project=' + project
|
|
else:
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
results = requests.get(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
instance = json.dumps(results.json())
|
|
instance = json.loads(instance)
|
|
expanded_devices = instance['metadata']['expanded_devices']
|
|
devices = []
|
|
instance_state_url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '/state?project=' + project
|
|
instance_state = requests.get(instance_state_url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
instance_state = json.dumps(instance_state.json())
|
|
instance_state = json.loads(instance_state)
|
|
if expanded_devices:
|
|
for expanded_device in expanded_devices:
|
|
if expanded_devices[expanded_device]['type'] == 'disk':
|
|
device = {}
|
|
device.update({ 'device': expanded_device })
|
|
device.update({ 'type': expanded_devices[expanded_device]['type'] })
|
|
if 'path' in expanded_devices[expanded_device]:
|
|
device.update({ 'path': expanded_devices[expanded_device]['path'] })
|
|
if 'pool' in expanded_devices[expanded_device]:
|
|
device.update({ 'pool': expanded_devices[expanded_device]['pool'] })
|
|
if expanded_device in instance_state['metadata']['disk']:
|
|
if 'usage' in instance_state['metadata']['disk'][expanded_device]:
|
|
device.update({ 'usage': instance_state['metadata']['disk'][expanded_device]['usage'] })
|
|
|
|
devices.append(device)
|
|
return jsonify({ 'data': devices })
|
|
|
|
|
|
if endpoint == 'get_instance_gpu_devices':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
server = Server.query.filter_by(id=id).first()
|
|
name = request.args.get('name')
|
|
recursion = request.args.get('recursion')
|
|
if recursion == '1':
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '?recursion=1&project=' + project
|
|
else:
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
results = requests.get(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
instance = json.dumps(results.json())
|
|
instance = json.loads(instance)
|
|
expanded_devices = instance['metadata']['expanded_devices']
|
|
devices = []
|
|
if expanded_devices:
|
|
for expanded_device in expanded_devices:
|
|
if expanded_devices[expanded_device]['type'] == 'gpu':
|
|
device = {}
|
|
device.update({ 'device': expanded_device })
|
|
device.update({ 'type': expanded_devices[expanded_device]['type'] })
|
|
if 'gputype' in expanded_devices[expanded_device]:
|
|
device.update({ 'gputype': expanded_devices[expanded_device]['gputype'] })
|
|
if 'vendorid' in expanded_devices[expanded_device]:
|
|
device.update({ 'vendorid': expanded_devices[expanded_device]['vendorid'] })
|
|
if 'productid' in expanded_devices[expanded_device]:
|
|
device.update({ 'productid': expanded_devices[expanded_device]['productid'] })
|
|
if 'id' in expanded_devices[expanded_device]:
|
|
device.update({ 'id': expanded_devices[expanded_device]['id'] })
|
|
if 'pci' in expanded_devices[expanded_device]:
|
|
device.update({ 'pci': expanded_devices[expanded_device]['pci'] })
|
|
if 'uid' in expanded_devices[expanded_device]:
|
|
device.update({ 'uid': expanded_devices[expanded_device]['uid'] })
|
|
if 'gid' in expanded_devices[expanded_device]:
|
|
device.update({ 'gid': expanded_devices[expanded_device]['gid'] })
|
|
if 'mode' in expanded_devices[expanded_device]:
|
|
device.update({ 'mode': expanded_devices[expanded_device]['mode'] })
|
|
if 'mig.ci' in expanded_devices[expanded_device]:
|
|
device.update({ 'mig.ci': expanded_devices[expanded_device]['mig.ci'] })
|
|
if 'mig.gi' in expanded_devices[expanded_device]:
|
|
device.update({ 'mig.gi': expanded_devices[expanded_device]['mig.gi'] })
|
|
devices.append(device)
|
|
return jsonify({ 'data': devices })
|
|
|
|
|
|
if endpoint == 'get_instance_interfaces':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
server = Server.query.filter_by(id=id).first()
|
|
name = request.args.get('name')
|
|
recursion = request.args.get('recursion')
|
|
if recursion == '1':
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '/state?recursion=1&project=' + project
|
|
else:
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '/state?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
results = requests.get(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
instance = json.dumps(results.json())
|
|
instance = json.loads(instance)
|
|
networks = instance['metadata']['network']
|
|
interfaces = []
|
|
if networks:
|
|
for network in networks:
|
|
if network:
|
|
interface = {}
|
|
interface.update({ 'name': network })
|
|
interface.update({ 'hwaddr': networks[network]['hwaddr'] })
|
|
interface.update({ 'state': networks[network]['state'] })
|
|
addresses = networks[network]['addresses']
|
|
interface.update({ 'ipv4_addresses': [] })
|
|
interface.update({ 'ipv6_addresses': [] })
|
|
for address in addresses:
|
|
#if address['family'] == 'inet' and address['scope'] == 'global':
|
|
if address['family'] == 'inet':
|
|
interface['ipv4_addresses'] += [ address['address'] ]
|
|
if address['family'] == 'inet6':
|
|
interface['ipv6_addresses'] += [ address['address'] ]
|
|
interfaces.append(interface)
|
|
return jsonify({ 'data': interfaces })
|
|
|
|
|
|
if endpoint == 'get_instance_network_devices':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
server = Server.query.filter_by(id=id).first()
|
|
name = request.args.get('name')
|
|
recursion = request.args.get('recursion')
|
|
if recursion == '1':
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '?recursion=1&project=' + project
|
|
else:
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
results = requests.get(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
instance = json.dumps(results.json())
|
|
instance = json.loads(instance)
|
|
expanded_devices = instance['metadata']['expanded_devices']
|
|
devices = []
|
|
if expanded_devices:
|
|
for expanded_device in expanded_devices:
|
|
if expanded_devices[expanded_device]['type'] == 'nic':
|
|
device = {}
|
|
device.update({ 'device': expanded_device })
|
|
device.update({ 'type': expanded_devices[expanded_device]['type'] })
|
|
if 'name' in expanded_devices[expanded_device]:
|
|
device.update({ 'name': expanded_devices[expanded_device]['name'] })
|
|
if 'network' in expanded_devices[expanded_device]:
|
|
device.update({ 'network': expanded_devices[expanded_device]['network'] })
|
|
if 'nictype' in expanded_devices[expanded_device]:
|
|
device.update({ 'nictype': expanded_devices[expanded_device]['nictype'] })
|
|
if 'parent' in expanded_devices[expanded_device]:
|
|
device.update({ 'parent': expanded_devices[expanded_device]['parent'] })
|
|
devices.append(device)
|
|
return jsonify({ 'data': devices })
|
|
|
|
|
|
if endpoint == 'get_instance_proxy_devices':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
server = Server.query.filter_by(id=id).first()
|
|
name = request.args.get('name')
|
|
recursion = request.args.get('recursion')
|
|
if recursion == '1':
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '?recursion=1&project=' + project
|
|
else:
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
results = requests.get(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
instance = json.dumps(results.json())
|
|
instance = json.loads(instance)
|
|
expanded_devices = instance['metadata']['expanded_devices']
|
|
devices = []
|
|
if expanded_devices:
|
|
for expanded_device in expanded_devices:
|
|
if expanded_devices[expanded_device]['type'] == 'proxy':
|
|
device = {}
|
|
device.update({ 'device': expanded_device })
|
|
device.update({ 'type': expanded_devices[expanded_device]['type'] })
|
|
if 'connect' in expanded_devices[expanded_device]:
|
|
device.update({ 'connect': expanded_devices[expanded_device]['connect'] })
|
|
if 'listen' in expanded_devices[expanded_device]:
|
|
device.update({ 'listen': expanded_devices[expanded_device]['listen'] })
|
|
devices.append(device)
|
|
return jsonify({ 'data': devices })
|
|
|
|
|
|
if endpoint == 'get_instance_state':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
server = Server.query.filter_by(id=id).first()
|
|
name = request.args.get('name')
|
|
recursion = request.args.get('recursion')
|
|
if recursion == '1':
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '/state?recursion=1&project=' + project
|
|
else:
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '/state?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
results = requests.get(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
return jsonify(results.json())
|
|
|
|
# Container only
|
|
if endpoint == 'get_instance_unix_devices':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
server = Server.query.filter_by(id=id).first()
|
|
name = request.args.get('name')
|
|
recursion = request.args.get('recursion')
|
|
if recursion == '1':
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '?recursion=1&project=' + project
|
|
else:
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
results = requests.get(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
instance = json.dumps(results.json())
|
|
instance = json.loads(instance)
|
|
expanded_devices = instance['metadata']['expanded_devices']
|
|
devices = []
|
|
if expanded_devices:
|
|
for expanded_device in expanded_devices:
|
|
if expanded_devices[expanded_device]['type'] == 'unix-block' or expanded_devices[expanded_device]['type'] == 'unix-char':
|
|
device = {}
|
|
device.update({ 'device': expanded_device })
|
|
device.update({ 'type': expanded_devices[expanded_device]['type'] })
|
|
if 'source' in expanded_devices[expanded_device]:
|
|
device.update({ 'source': expanded_devices[expanded_device]['source'] })
|
|
if 'path' in expanded_devices[expanded_device]:
|
|
device.update({ 'path': expanded_devices[expanded_device]['path'] })
|
|
if 'major' in expanded_devices[expanded_device]:
|
|
device.update({ 'major': expanded_devices[expanded_device]['major'] })
|
|
if 'minor' in expanded_devices[expanded_device]:
|
|
device.update({ 'minor': expanded_devices[expanded_device]['minor'] })
|
|
if 'uid' in expanded_devices[expanded_device]:
|
|
device.update({ 'uid': expanded_devices[expanded_device]['uid'] })
|
|
if 'gid' in expanded_devices[expanded_device]:
|
|
device.update({ 'gid': expanded_devices[expanded_device]['gid'] })
|
|
if 'mode' in expanded_devices[expanded_device]:
|
|
device.update({ 'mode': expanded_devices[expanded_device]['mode'] })
|
|
if 'required' in expanded_devices[expanded_device]:
|
|
device.update({ 'required': expanded_devices[expanded_device]['required'] })
|
|
devices.append(device)
|
|
return jsonify({ 'data': devices })
|
|
|
|
|
|
if endpoint == 'get_instance_usb_devices':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
server = Server.query.filter_by(id=id).first()
|
|
name = request.args.get('name')
|
|
recursion = request.args.get('recursion')
|
|
if recursion == '1':
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '?recursion=1&project=' + project
|
|
else:
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
results = requests.get(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
instance = json.dumps(results.json())
|
|
instance = json.loads(instance)
|
|
expanded_devices = instance['metadata']['expanded_devices']
|
|
devices = []
|
|
if expanded_devices:
|
|
for expanded_device in expanded_devices:
|
|
if expanded_devices[expanded_device]['type'] == 'usb':
|
|
device = {}
|
|
device.update({ 'device': expanded_device })
|
|
device.update({ 'type': expanded_devices[expanded_device]['type'] })
|
|
if 'vendorid' in expanded_devices[expanded_device]:
|
|
device.update({ 'vendorid': expanded_devices[expanded_device]['vendorid'] })
|
|
if 'productid' in expanded_devices[expanded_device]:
|
|
device.update({ 'productid': expanded_devices[expanded_device]['productid'] })
|
|
if 'uid' in expanded_devices[expanded_device]:
|
|
device.update({ 'uid': expanded_devices[expanded_device]['uid'] })
|
|
if 'gid' in expanded_devices[expanded_device]:
|
|
device.update({ 'gid': expanded_devices[expanded_device]['gid'] })
|
|
if 'mode' in expanded_devices[expanded_device]:
|
|
device.update({ 'mode': expanded_devices[expanded_device]['mode'] })
|
|
if 'required' in expanded_devices[expanded_device]:
|
|
device.update({ 'required': expanded_devices[expanded_device]['required'] })
|
|
devices.append(device)
|
|
return jsonify({ 'data': devices })
|
|
|
|
|
|
if endpoint == 'get_instance_websocket_host':
|
|
id = request.args.get('id')
|
|
server = Server.query.filter_by(id=id).first()
|
|
return jsonify({ 'addr': server.addr, 'port': server.port, 'proxy': server.proxy })
|
|
|
|
|
|
if endpoint == 'list_instance_backups':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
server = Server.query.filter_by(id=id).first()
|
|
name = request.args.get('name')
|
|
recursion = request.args.get('recursion')
|
|
if recursion == '1':
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '/backups?recursion=1&project=' + project
|
|
else:
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '/backups?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
results = requests.get(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
backups = json.dumps(results.json())
|
|
backups = json.loads(backups)
|
|
devices = []
|
|
if backups:
|
|
for backup in backups['metadata']:
|
|
# Check if backup file exists
|
|
if os.path.isfile('backups/' + str(server.id) + '/' + project + '/' + name + '/' + backup['name']):
|
|
backup.update({'backup_file_exists': True})
|
|
backup.update({'backup_file_size': os.path.getsize('backups/' + str(server.id) + '/' + project + '/' + name + '/' + backup['name'])})
|
|
else:
|
|
backup.update({'backup_file_exists': False})
|
|
|
|
return jsonify(backups)
|
|
|
|
|
|
if endpoint == 'list_instance_logs':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
server = Server.query.filter_by(id=id).first()
|
|
name = request.args.get('name')
|
|
recursion = request.args.get('recursion')
|
|
if recursion == '1':
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '/logs?recursion=1&project=' + project
|
|
else:
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '/logs?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
results = requests.get(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
|
|
# Newly created VMs will not have logs until it starts, causing a 404 error
|
|
results = json.dumps(results.json())
|
|
results = json.loads(results)
|
|
if results['metadata'] is None:
|
|
return jsonify({"metadata":[]})
|
|
return jsonify(results)
|
|
|
|
|
|
if endpoint == 'list_instance_snapshots':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
server = Server.query.filter_by(id=id).first()
|
|
name = request.args.get('name')
|
|
recursion = request.args.get('recursion')
|
|
if recursion == '1':
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '/snapshots?recursion=1&project=' + project
|
|
else:
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + name + '/snapshots?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
results = requests.get(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
return jsonify(results.json())
|
|
|
|
|
|
if endpoint == 'migrate_instance':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
instance = request.args.get('instance')
|
|
server = Server.query.filter_by(id=id).first()
|
|
location = request.args.get('location')
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + instance + '?target='+location+'&project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
data = {}
|
|
data.update({'name': instance })
|
|
data.update({'migration': True})
|
|
data.update({'live': False})
|
|
results = requests.post(url, verify=server.ssl_verify, cert=(client_cert, client_key), json=data)
|
|
return jsonify(results.json())
|
|
|
|
|
|
if endpoint == 'publish_instance':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
instance = request.args.get('instance')
|
|
server = Server.query.filter_by(id=id).first()
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/images?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
data = {}
|
|
properties = {}
|
|
properties.update({ 'description':request.form.get('description') })
|
|
properties.update({ 'os': request.form.get('os') })
|
|
properties.update({ 'release': request.form.get('release') })
|
|
data.update({ 'properties': properties })
|
|
source = {}
|
|
source.update({ 'type': 'instance' })
|
|
source.update({ 'name': instance })
|
|
data.update({ 'source': source })
|
|
if request.form.get('public') == 'true':
|
|
data.update({'public': True})
|
|
else:
|
|
data.update({'public': False})
|
|
results = requests.post(url, verify=server.ssl_verify, cert=(client_cert, client_key), json=data)
|
|
return jsonify(results.json())
|
|
|
|
|
|
if endpoint == 'publish_instance_snapshot':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
instance = request.args.get('instance')
|
|
snapshot = request.args.get('snapshot')
|
|
server = Server.query.filter_by(id=id).first()
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/images?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
data = {}
|
|
properties = {}
|
|
properties.update({ 'description':request.form.get('description') })
|
|
properties.update({ 'os': request.form.get('os') })
|
|
properties.update({ 'release': request.form.get('release') })
|
|
data.update({ 'properties': properties })
|
|
source = {}
|
|
source.update({ 'type': 'snapshot' })
|
|
source.update({ 'name': instance + '/' + snapshot })
|
|
data.update({ 'source': source })
|
|
if request.form.get('public') == 'true':
|
|
data.update({'public': True})
|
|
else:
|
|
data.update({'public': False})
|
|
results = requests.post(url, verify=server.ssl_verify, cert=(client_cert, client_key), json=data)
|
|
return jsonify(results.json())
|
|
|
|
|
|
if endpoint == 'rename_instance':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
instance = request.args.get('instance')
|
|
server = Server.query.filter_by(id=id).first()
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + instance + '?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
data = {}
|
|
data.update({'name': request.form.get('name')})
|
|
results = requests.post(url, verify=server.ssl_verify, cert=(client_cert, client_key), json=data)
|
|
return jsonify(results.json())
|
|
|
|
|
|
if endpoint == 'restore_instance_snapshot':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
instance = request.args.get('instance')
|
|
server = Server.query.filter_by(id=id).first()
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + instance + '?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
|
|
data = {}
|
|
data.update({'restore': request.form.get('name')})
|
|
results = requests.put(url, verify=server.ssl_verify, cert=(client_cert, client_key), json=data)
|
|
|
|
return jsonify(results.json())
|
|
|
|
|
|
if endpoint == 'update_instance':
|
|
id = request.args.get('id')
|
|
project = request.args.get('project')
|
|
instance = request.args.get('instance')
|
|
server = Server.query.filter_by(id=id).first()
|
|
url = 'https://' + server.addr + ':' + str(server.port) + '/1.0/instances/' + instance + '?project=' + project
|
|
client_cert = get_client_crt()
|
|
client_key = get_client_key()
|
|
|
|
# If the update was from JSON tab, update it with a PUT request
|
|
if request.form.get('json'):
|
|
data = request.form.get('json')
|
|
results = requests.put(url, verify=server.ssl_verify, cert=(client_cert, client_key), data=data)
|
|
return jsonify(results.json())
|
|
|
|
# Get the current config
|
|
results = requests.get(url, verify=server.ssl_verify, cert=(client_cert, client_key))
|
|
instance = json.dumps(results.json())
|
|
instance = json.loads(instance)
|
|
existing_config = instance['metadata']['config']
|
|
|
|
# Create a new dict to hold the differences between existing config and form config
|
|
updated_config = {}
|
|
# Loop through and compare differences between existing config and form config
|
|
for key, val in request.form.items():
|
|
# If key is description, continue as it is not part of config
|
|
if key == 'description':
|
|
continue
|
|
# If the key does not exist in existing config, create and set it to empty string so we can compare it to form config
|
|
if not key in existing_config:
|
|
existing_config.update( { key: '' } )
|
|
# If the post key is different than existing key capture this difference in new dict
|
|
if request.form.get(key) != existing_config[key]:
|
|
updated_config.update({key: request.form.get(key)})
|
|
|
|
# Send a PATCH request to update only the differences in config
|
|
data = {}
|
|
data.update({'description': request.form.get('description')})
|
|
data.update({'config' : updated_config })
|
|
results = requests.patch(url, verify=server.ssl_verify, cert=(client_cert, client_key), json=data)
|
|
return jsonify(results.json())
|