Merge branch 'main' into flask

test.py

@@ -0,0 +1,164 @@
+import base64
+from codecs import Codec
+from time import sleep
+from openstack import connection as connexion
+
+#Constants 
+PRIVATE_NETWORK_ID = "0d49c37b-7077-4152-985c-f5a00ad20677"
+EXTERNAL_NETWORK_ID = "e64da4e4-57c4-473a-9b4d-548c800b654a"
+
+with open("pw.sec", "r") as f:
+    pw = f.readlines()
+
+### Connexion ; décommenter les deux lignes pour l'utilisateur voulu et ne pas oublier de recommenter les 2 autres
+# etudiant1
+# password = pw[0]
+# conn = connexion.Connection(auth_url="http://172.10.3.60:5000/v3", project_name="etudiant1", username="etudiant1", password=password, user_domain_id="default", project_domain_id="default")
+# admin
+
+password = "3pMrmW899b9y^2kiJa!6#Z#kE%@a2r"
+conn = connexion.Connection(auth_url="http://172.10.3.60:5000/v3", project_name="admin", username="admin", password=password, user_domain_id="default", project_domain_id="default")
+
+###############################
+#  ___ _   _ _____ ___  ____  #
+# |_ _| \ | |  ___/ _ \/ ___| #
+#  | ||  \| | |_ | | | \___ \ #
+#  | || |\  |  _|| |_| |___) |#
+# |___|_| \_|_|   \___/|____/ #
+###############################
+def get_infos(conn):
+    for server in conn.compute.servers():
+        print(f"Server name : {server.name}\n")
+
+    for image in conn.compute.images():
+        print("Image name : " + image.name)
+def get_flavor(conn):
+    for flavor in conn.compute.flavors():
+        print("Flavor name : " + flavor.name)
+def get_network(conn):
+    print("--------------------")
+    for network in conn.network.networks():
+        print("Network name : " + network.name)
+        print("Network id : " + network.id)
+        print("Network status : " + network.status)
+        print("--------------------")
+def get_infos_project(conn, print_infos=True):
+    project = conn.identity.find_project("admin")
+    nova_client = conn.compute
+    quota_info = nova_client.get(f"/os-quota-sets/{project.id}?usage=True").json()['quota_set']
+    usage_info = nova_client.get(f"/os-simple-tenant-usage/{project.id}").json()['tenant_usage']
+
+    quota_ram = quota_info['ram']
+    quota_servers = quota_info['instances']
+    quota_vcpu = quota_info['cores']
+
+    quotas = [quota_servers, quota_ram, quota_vcpu]
+
+
+#    print(quota_info)
+#    print(usage_info)
+
+    servers = nova_client.servers(details=True, project_id=project.id)
+
+    total_ram_used = 0
+    total_vcpu_used = 0
+#    total_disk_used = 0
+    nb_servers = 0
+
+    for server in servers:
+        total_ram_used += server.to_dict()['flavor']['ram']
+        total_vcpu_used += server.to_dict()['flavor']['vcpus']
+#        total_disk_used += server.to_dict()['flavor']['disk']
+        nb_servers += 1
+
+    used = [nb_servers, total_ram_used, total_vcpu_used]
+    if print_infos:
+        print("Project Name:", project.name)
+        print("NB Servers:", nb_servers)
+        print("Total RAM Used (MB):", total_ram_used)
+        print("Total vCPU Used:", total_vcpu_used)
+#    print("Total Disk Used:", total_disk_used)
+    return [quotas, used]
+def get_console_url(conn, vm_name:str):
+    server = conn.compute.find_server(vm_name)
+    print(server.get_console_url(conn.compute, "novnc"))
+### Admin only
+def get_endpoint(conn):
+    for endpoint in conn.identity.endpoints():
+        print(f"Endpoint name : {endpoint.name}")
+def get_projects(conn):
+    for project in conn.identity.projects():
+        print(f"Project name : {project.name}")
+def get_users(conn):
+    for user in conn.identity.users():
+        print(f"User name : {user.name}")
+def get_floating_IPs(conn):
+    for ip in conn.network.ips():
+        print(f"IP name : {ip.name}")
+
+    #create a new floating ip (fonctionne)
+    # ip = conn.network.create_ip(floating_network_id=EXTERNAL_NETWORK_ID)
+
+#######################################################
+#   ____ ____  _____    _  _____ _____                #
+#  / ___|  _ \| ____|  / \|_   _| ____|               #
+# | |   | |_) |  _|   / _ \ | | |  _|                 #
+# | |___|  _ <| |___ / ___ \| | | |___                #
+#  \____|_| \_\_____/_/   \_\_| |_____|               #
+#                                                     # 
+#######################################################
+def create_instance(conn, vm_name:str, vm_image:str):
+    image = conn.compute.find_image(f"{vm_image}")
+    flavor = conn.compute.find_flavor(f"m1.{vm_image}")
+    # print(flavor)
+    template_ram = flavor.ram
+    template_vcpu = flavor.vcpus
+    template_disk = flavor.disk
+    # Get Quotas and Used
+    quota, used = get_infos_project(conn, print_infos=False)
+    if (used[0] < quota[0]) and (template_ram <= quota[1]-used[1]) and (template_vcpu <= quota[2]-used[2]):
+        # key_pair = conn.compute.find_keypair("etudiant1-MB")
+        userdata = """#!/bin/sh\nuserdel -rf user\nuseradd -m -s /bin/bash hugo\necho "hugo:azerty" | chpasswd\nsystemctl disable ssh\nsystemctl stop ssh\n"""
+        server = conn.compute.create_server(
+            name=vm_name,
+            image_id=image.id,
+            flavor_id=flavor.id,
+            networks=[{"uuid": PRIVATE_NETWORK_ID}],
+            user_data=base64.b64encode(userdata.encode("utf-8")).decode("utf-8"),
+        )
+        server = conn.compute.wait_for_server(server)
+        return 0
+    else:
+        return 1
+def create_floating_IP(conn):
+    ip = conn.network.create_ip(floating_network_id=EXTERNAL_NETWORK_ID)
+    return ip.floating_ip_address
+
+#######################################################
+#  ____  _____ __  __  _____     _______              #
+# |  _ \| ____|  \/  |/ _ \ \   / / ____|             #
+# | |_) |  _| | |\/| | | | \ \ / /|  _|               #
+# |  _ <| |___| |  | | |_| |\ V / | |___              #
+# |_| \_\_____|_|  |_|\___/  \_/  |_____|             #                       
+#######################################################
+def remove_instance(conn, name:str):
+    server = conn.compute.find_server(name)
+    conn.compute.delete_server(server)
+    print(server.name + " deleted")
+
+def remove_all_instances(conn):
+    for server in conn.compute.servers():
+        conn.compute.delete_server(server)
+        print(server.name + " deleted")
+
+def remove_floating_IP(conn, ip:str):
+    conn.network.delete_ip(ip)
+
+remove_all_instances(conn)
+# for i in range(35):
+#     results = create_instance(conn, f"test{i}", "kali")
+#     if (results == 0):
+#        print(f"test{i} created")
+#        get_console_url(conn, f"test{i}")
+#     else:
+#        print("Quota exceeded, VM not created")