opengnsys
/
ogrepository
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

refs #631 - Modify 'repo_api.py'

pull/1/head
Gerardo GIl Elizeire 2024-11-08 14:03:11 +01:00
parent b3e31219dc
commit 5c233f6c11
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
api/repo_api.py
View File

@ -42,7 +42,7 @@ script_path = '/opt/opengnsys/ogrepository/bin'
repo_file = '/opt/opengnsys/ogrepository/etc/repoinfo.json'
trash_file = '/opt/opengnsys/ogrepository/etc/trashinfo.json'
ogcore_ip = '192.168.56.101' # En la versión final, se tendrá que pillar de una variable de entorno
ogcore_ip = '172.17.8.26' # En la versión final, se tendrá que pillar de una variable de entorno
"""
repo_path = '/home/user/images/'
@ -271,8 +271,8 @@ def recall_ogcore(data):
Se utiliza para informar a ogCore del resultado de una tarea asíncrona,
que estaba corriendo en un proceso independiente (no controlado por los endpoints).
"""
# Almacenamos la URL del endpoint de ogCore:
endpoint_url = f"http://{ogcore_ip}:8006//ogcore/v1/test"
# Almacenamos la URL del endpoint de ogCore (prueba):
endpoint_url = f"http://{ogcore_ip}:8006/ogcore/v1/test"
# Almacenamos los headers, y convertiomos "data" a JSON:
headers = {'content-type': 'application/json'}
@ -670,7 +670,7 @@ def import_image():
result = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE, encoding='UTF8')
# Generamos el ID para identificar el trabajo asíncrono:
job_id = '{}-{}'.format ('ImportImage', ''.join(random.choice('0123456789abcdef') for _ in range(8)))
job_id = f"ImportImage_{''.join(random.choice('0123456789abcdef') for char in range(8))}"
# Evaluamos el resultado de la ejecución, y devolvemos una respuesta:
if result.returncode is None:
@ -757,7 +757,7 @@ def export_image():
result = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE, encoding='UTF8')
# Generamos el ID para identificar el trabajo asíncrono:
job_id = '{}-{}'.format ('ExportImage', ''.join(random.choice('0123456789abcdef') for _ in range(8)))
job_id = f"ExportImage_{''.join(random.choice('0123456789abcdef') for char in range(8))}"
# Evaluamos el resultado de la ejecución, y devolvemos una respuesta:
if result.returncode is None:
@ -832,7 +832,7 @@ def create_torrent_sum():
result = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE, encoding='UTF8')
# Generamos el ID para identificar el trabajo asíncrono:
job_id = '{}-{}'.format ('CreateAuxiliarFiles', ''.join(random.choice('0123456789abcdef') for _ in range(8)))
job_id = f"CreateAuxiliarFiles_{''.join(random.choice('0123456789abcdef') for char in range(8))}"
# Evaluamos el resultado de la ejecución, y devolvemos una respuesta:
if result.returncode is None: