external/HyperProxmox
1
0
Fork 0
mirror of https://github.com/ThomasGsp/HyperProxmox.git synced 2025-02-13 11:42:13 +00:00
Code Issues Releases Wiki Activity

General update

Browse source
This commit is contained in:
thomas.guiseppin 2017-10-29 18:00:00 +01:00
parent e283d0f2f7
commit f0e67d1aed
2 changed files with 51 additions and 25 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
code/scripts/main/api/v1/api.py
View file

@ -11,6 +11,12 @@ import random
import ast import ast
def cooktheticket(ticket, action, target):
if ticket == "aaa":
return True
else:
return False
class Auth: class Auth:
def POST(self): def POST(self):
# '{"username":"fff", "password":"azerty"}' # '{"username":"fff", "password":"azerty"}'
@ -19,8 +25,12 @@ class Auth:
# Test Login # Test Login
# If true generate an ticket # If true generate an ticket
# use date and ip
i = web.input(ticket='aaa')
web.setcookie('ticket', i.ticket, 3600)
return return
class Cluster: class Cluster:
def GET(self, cluster=None): def GET(self, cluster=None):
try: try:
@ -72,21 +82,20 @@ class Cluster:
return result return result
# Ajouter le retour d'erreur des requetes foireuses
class Instance: class Instance:
def GET(self, vmid=None, status=None): def GET(self, vmid=None, status=None):
try: try:
if status: if status:
""" GET INSTANCE STATUS """ """ GET INSTANCE STATUS """
result = core.status_instance(vmid, status) result = core.status_instance(vmid, status)
elif vmid: else:
""" GET INSTANCE INFORMATION """ """ GET INSTANCE INFORMATION """
result = core.info_instance(vmid) result = core.info_instance(vmid)
except BaseException as e: except BaseException as e:
result = { result = {
"result": "ERROR", "result": "ERROR",
"type": "PYTHON - API", "type": "PYTHON - API",
"value": "{0} {1}".format("Invalid request:", e) "value": "Invalid request: {0}".format(e)
} }
return result return result

61
code/scripts/main/core/core.py
View file

@ -72,10 +72,10 @@ class Core:
proxmox_cluster_url = cluster_informations["url"] proxmox_cluster_url = cluster_informations["url"]
proxmox_cluster_port = cluster_informations["port"] proxmox_cluster_port = cluster_informations["port"]
proxmox_cluster_user = pdecrypt(base64.b64decode(cluster["user"]), proxmox_cluster_user = pdecrypt(base64.b64decode(cluster_informations["user"]),
self.generalconf["keys"]["key_pvt"])["data"].decode('utf-8') self.generalconf["keys"]["key_pvt"])["data"].decode('utf-8')
proxmox_cluster_pwd = pdecrypt(base64.b64decode(cluster["password"]), proxmox_cluster_pwd = pdecrypt(base64.b64decode(cluster_informations["password"]),
self.generalconf["keys"]["key_pvt"])["data"].decode('utf-8') self.generalconf["keys"]["key_pvt"])["data"].decode('utf-8')
proxmox_template = cluster_informations["template"] proxmox_template = cluster_informations["template"]
@ -114,7 +114,7 @@ class Core:
ip = str(get_info_system["IP_free"][0]) ip = str(get_info_system["IP_free"][0])
self.mongo.update_system_delete_ip(ip) self.mongo.update_system_delete_ip(ip)
# insert check duplicate entry
""" INSTANCE DEFINITION """ """ INSTANCE DEFINITION """
data = { data = {
'ostemplate': proxmox_template, 'ostemplate': proxmox_template,
@ -134,11 +134,14 @@ class Core:
} }
""" INSTANCE INSERTION """ """ INSTANCE INSERTION """
result_new = {}
#while not proxmox.retry_on_errorcode(result_new['result']):
result_new = proxmox.create_instance("{0}:{1}".format(proxmox_cluster_url, result_new = proxmox.create_instance("{0}:{1}".format(proxmox_cluster_url,
int(proxmox_cluster_port)), target, "lxc", int(proxmox_cluster_port)), target, "lxc",
data) data)
""" Get first digest """
digest_init = proxmox.get_config("{0}:{1}".format(proxmox_cluster_url,
int(proxmox_cluster_port)),
target, "lxc", next_instance_id)['value']['data']['digest']
""" VERIFY THE RESULT BY PROXMOX STATUS REQUEST CODE """ """ VERIFY THE RESULT BY PROXMOX STATUS REQUEST CODE """
if result_new['result'] == "OK": if result_new['result'] == "OK":
@ -154,8 +157,11 @@ class Core:
data["ip"] = ip data["ip"] = ip
self.mongo.insert_instance(data) self.mongo.insert_instance(data)
""" BREAK the loop due to valid creation """ """ Limit creation DDOS based on digest """
while digest_init == proxmox.get_config("{0}:{1}".format(proxmox_cluster_url,
int(proxmox_cluster_port)),
target, "lxc", next_instance_id)['value']['data']['digest']:
time.sleep(5)
returnlistresult.append(result_new) returnlistresult.append(result_new)
@ -175,9 +181,11 @@ class Core:
proxmox_cluster_url = cluster_informations["url"] proxmox_cluster_url = cluster_informations["url"]
proxmox_cluster_port = cluster_informations["port"] proxmox_cluster_port = cluster_informations["port"]
proxmox_cluster_user = pdecrypt(cluster_informations["user"],self.generalconf["keys"]["key_pvt"]) proxmox_cluster_user = pdecrypt(base64.b64decode(cluster_informations["user"]),
proxmox_cluster_pwd = pdecrypt(cluster_informations["password"], self.generalconf["keys"]["key_pvt"]) self.generalconf["keys"]["key_pvt"])["data"].decode('utf-8')
proxmox_cluster_pwd = pdecrypt(base64.b64decode(cluster_informations["password"]),
self.generalconf["keys"]["key_pvt"])["data"].decode('utf-8')
""" LOAD PROXMOX """ """ LOAD PROXMOX """
proxmox = Proxmox(instance_informations['node']) proxmox = Proxmox(instance_informations['node'])
proxmox.get_ticket("{0}:{1}".format(proxmox_cluster_url, proxmox.get_ticket("{0}:{1}".format(proxmox_cluster_url,
@ -211,9 +219,11 @@ class Core:
proxmox_cluster_url = cluster_informations["url"] proxmox_cluster_url = cluster_informations["url"]
proxmox_cluster_port = cluster_informations["port"] proxmox_cluster_port = cluster_informations["port"]
proxmox_cluster_user = pdecrypt(cluster_informations["user"],self.generalconf["keys"]["key_pvt"]) proxmox_cluster_user = pdecrypt(base64.b64decode(cluster_informations["user"]),
proxmox_cluster_pwd = pdecrypt(cluster_informations["password"], self.generalconf["keys"]["key_pvt"]) self.generalconf["keys"]["key_pvt"])["data"].decode('utf-8')
proxmox_cluster_pwd = pdecrypt(base64.b64decode(cluster_informations["password"]),
self.generalconf["keys"]["key_pvt"])["data"].decode('utf-8')
""" LOAD PROXMOX """ """ LOAD PROXMOX """
proxmox = Proxmox(instance_informations['node']) proxmox = Proxmox(instance_informations['node'])
proxmox.get_ticket("{0}:{1}".format(proxmox_cluster_url, proxmox.get_ticket("{0}:{1}".format(proxmox_cluster_url,
@ -246,9 +256,11 @@ class Core:
proxmox_cluster_url = cluster_informations["url"] proxmox_cluster_url = cluster_informations["url"]
proxmox_cluster_port = cluster_informations["port"] proxmox_cluster_port = cluster_informations["port"]
proxmox_cluster_user = pdecrypt(cluster_informations["user"],self.generalconf["keys"]["key_pvt"]) proxmox_cluster_user = pdecrypt(base64.b64decode(cluster_informations["user"]),
proxmox_cluster_pwd = pdecrypt(cluster_informations["password"], self.generalconf["keys"]["key_pvt"]) self.generalconf["keys"]["key_pvt"])["data"].decode('utf-8')
proxmox_cluster_pwd = pdecrypt(base64.b64decode(cluster_informations["password"]),
self.generalconf["keys"]["key_pvt"])["data"].decode('utf-8')
""" LOAD PROXMOX """ """ LOAD PROXMOX """
proxmox = Proxmox(instance_informations['node']) proxmox = Proxmox(instance_informations['node'])
proxmox.get_ticket("{0}:{1}".format(proxmox_cluster_url, proxmox.get_ticket("{0}:{1}".format(proxmox_cluster_url,
@ -281,9 +293,11 @@ class Core:
proxmox_cluster_url = cluster_informations["url"] proxmox_cluster_url = cluster_informations["url"]
proxmox_cluster_port = cluster_informations["port"] proxmox_cluster_port = cluster_informations["port"]
proxmox_cluster_user = pdecrypt(cluster_informations["user"],self.generalconf["keys"]["key_pvt"]) proxmox_cluster_user = pdecrypt(base64.b64decode(cluster_informations["user"]),
proxmox_cluster_pwd = pdecrypt(cluster_informations["password"], self.generalconf["keys"]["key_pvt"]) self.generalconf["keys"]["key_pvt"])["data"].decode('utf-8')
proxmox_cluster_pwd = pdecrypt(base64.b64decode(cluster_informations["password"]),
self.generalconf["keys"]["key_pvt"])["data"].decode('utf-8')
""" LOAD PROXMOX """ """ LOAD PROXMOX """
proxmox = Proxmox(instance_informations['node']) proxmox = Proxmox(instance_informations['node'])
@ -307,8 +321,8 @@ class Core:
"type": "PROXMOX - VALUES", "type": "PROXMOX - VALUES",
"value": "{0} is not a valid VMID: {1}".format(vmid, ierror) "value": "{0} is not a valid VMID: {1}".format(vmid, ierror)
} }
# Voir comment return ça proprement
return return result
""" """
####################### #######################
@ -331,25 +345,28 @@ class Core:
new_cluster = self.mongo.insert_new_cluster(data) new_cluster = self.mongo.insert_new_cluster(data)
else: else:
new_cluster = { new_cluster = {
"value": "{0}".format("Duplicate entry, please delete the current cluster or update it") "value": "{0}".format("Duplicate entry, please delete the current cluster or update it"),
"result": "ERROR", "result": "ERROR",
"type": "PROXMOX - VALUES" "type": "PROXMOX - VALUES"
} }
else: else:
new_cluster = { new_cluster = {
"value": "{1} {0}".format(testdata, "Invalid or miss paramettrer") "value": "{1} {0}".format(testdata, "Invalid or miss paramettrer"),
"result": "ERROR", "result": "ERROR",
"type": "PROXMOX - VALUES" "type": "PROXMOX - VALUES"
} }
return new_cluster return new_cluster
def change_cluster(self, cluster, data): def change_cluster(self, cluster, data):
return cluster_update = self.mongo.update_cluster(cluster, data)
return cluster_update
def delete_cluster(self, cluster): def delete_cluster(self, cluster):
return """ Find cluster informations from node """
cluster_delete = self.mongo.delete_cluster(cluster)
return cluster_delete
def valid_cluster_data(data): def valid_cluster_data(data):