CHANGELOG.md

@@ -6,30 +6,6 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.1.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
-## [5.9.0] - 2025-06-16
-
-### Added
-
-- Added changes for oggit
-
-## [5.8.1] - 2025-06-13
-
-### Fixed
-
-- Improve fail condition when no network is detected
-
-## [5.8.0] - 2025-06-12
-
-### Changed
-
-- Agents aren't being sent any signals on user logout. On the server side, assume that client disconnection == logout
-
-## [5.7.1] - 2025-06-05
-
-### Fixed
-
-- Correcly handle UNIX signals in the user instance of the agent
-
 ## [5.7.0] - 2025-05-27
 
 ### Changed

linux/debian/changelog

@@ -1,27 +1,3 @@
-ogagent (5.9.0-1) stable; urgency=medium
-
-  * Add changes for oggit
-
- -- OpenGnsys developers <info@opengnsys.es>  Mon, 16 Jun 2025 11:12:55 +0200
-
-ogagent (5.8.1-1) stable; urgency=medium
-
-  * Improve fail condition when no network is detected
-
- -- OpenGnsys developers <info@opengnsys.es>  Fri, 13 Jun 2025 10:01:43 +0200
-
-ogagent (5.8.0-1) stable; urgency=medium
-
-  * When client disconnect, assume that the user logged out
-
- -- OpenGnsys developers <info@opengnsys.es>  Thu, 12 Jun 2025 15:30:50 +0200
-
-ogagent (5.7.1-1) stable; urgency=medium
-
-  * Correctly handle UNIX signals
-
- -- OpenGnsys developers <info@opengnsys.es>  Thu, 05 Jun 2025 12:07:30 +0200
-
 ogagent (5.7.0-1) stable; urgency=medium
 
   * Use TLS again

src/OGAgentUser.py

@@ -35,8 +35,6 @@ import json
 import sys
 import time
 import os
-import socket
-import signal
 from PyQt6 import QtCore, QtGui, QtWidgets
 
 from about_dialog_ui import Ui_OGAAboutDialog
@@ -330,29 +328,6 @@ if __name__ == '__main__':
         trayIcon.quit()
         sys.exit(1)
 
-    ## begin SIGTERM handling
-    signal_socket = socket.socketpair()
-    signal_socket[0].setblocking(False)
-    signal_socket[1].setblocking(False)
-    signal.set_wakeup_fd(signal_socket[0].fileno())
-
-    def signal_handler(signum, frame):
-        #print (f"Received signal {signum}")
-        pass
-
-    def qt_signal_handler():
-        data = signal_socket[1].recv(1)
-        #print(f"Signal ({data}) received via socket, shutting down gracefully...")
-        if trayIcon:
-            trayIcon.quit()
-
-    signal.signal(signal.SIGTERM, signal_handler)
-    signal.signal(signal.SIGINT, signal_handler)
-
-    notifier = QtCore.QSocketNotifier(signal_socket[1].fileno(), QtCore.QSocketNotifier.Type.Read)
-    notifier.activated.connect(qt_signal_handler)
-    ## end SIGTERM handling
-
     app.aboutToQuit.connect(trayIcon.cleanup)
     trayIcon.show()
 

src/VERSION

@@ -1 +1 @@
-5.9.0
+5.7.0

src/opengnsys/httpserver.py

@@ -167,7 +167,7 @@ class HTTPServerThread(threading.Thread):
             logger.debug ('HTTP server: using certificate/CA from /opt/opengnsys/etc')
             context.load_cert_chain (certfile='/opt/opengnsys/etc/ogagent.crt', keyfile='/opt/opengnsys/etc/ogagent.key')
             context.load_verify_locations (cafile='/opt/opengnsys/etc/ca.crt')
-        elif pf and os.path.exists (os.path.join (pf, 'ogagent.crt')) and os.path.exists (os.path.join (pf, 'ogagent.key')) and os.path.exists (os.path.join (pf, 'ca.crt')):
+        elif os.path.exists (os.path.join (pf, 'ogagent.crt')) and os.path.exists (os.path.join (pf, 'ogagent.key')) and os.path.exists (os.path.join (pf, 'ca.crt')):
             logger.debug (f'HTTP server: using certificate/CA from the installation path ({pf})')
             context.load_cert_chain (certfile=os.path.join (pf, 'ogagent.crt'), keyfile=os.path.join (pf, 'ogagent.key'))
             context.load_verify_locations (cafile=os.path.join (pf, 'ca.crt'))

src/opengnsys/ipc.py

@@ -30,7 +30,6 @@
 """
 
 
-import os
 import json
 import queue
 import socket
@@ -194,8 +193,6 @@ class ClientProcessor(threading.Thread):
                 logger.error('Invalid message in queue: {}'.format(e))
 
         logger.debug('Client processor stopped')
-        if os.path.exists ('/windows/temp'): open ('/windows/temp/ogagentuser_died', 'w').close()
-        else:                                open (         '/tmp/ogagentuser_died', 'w').close()
         try:
             self.clientSocket.close()
         except Exception:

src/opengnsys/modules/server/OpenGnSys/__init__.py

@@ -147,11 +147,7 @@ class OpenGnSysWorker(ServerWorker):
         for t in range(0, 300):
             try:
                 # Get the first network interface
-                nets = list (operations.getNetworkInfo())
+                self.interface = list(operations.getNetworkInfo())[0]
-                if 0 == len (nets):
-                    logger.error ('No network interfaces found')
-                    raise Exception ('No network interfaces found')
-                self.interface = nets[0]
             except Exception as e:
                 # Wait 1 sec. and retry
                 logger.warn (e)

src/opengnsys/modules/server/ogAdmClient/__init__.py

@@ -360,60 +360,6 @@ class ogAdmClientWorker (ogLiveWorker):
         }
         return self.respuestaEjecucionComando (cmd, herror, ids)
 
-    def do_CrearImagenGit (self, post_params):
-        for k in ['dsk', 'par', 'cpt', 'idi', 'nci', 'ipr', 'nfn', 'ids']:
-            if k not in post_params:
-                logger.error (f'required parameter ({k}) not in POST params')
-                return {}
-
-        dsk = post_params['dsk'] ## Disco
-        par = post_params['par'] ## Número de partición
-        cpt = post_params['cpt'] ## Código de la partición
-        idi = post_params['idi'] ## Identificador de la imagen
-        nci = post_params['nci'] ## Nombre canónico de la imagen
-        ipr = post_params['ipr'] ## Ip del repositorio
-        nfn = post_params['nfn']
-        ids = post_params['ids']
-        tag = post_params['tag'] ## Tag a crear en git una vez hecho el commit
-
-        self.muestraMensaje (7)
-
-        try:
-            res = self.InventariandoSoftware (dsk, par, 'InventarioSoftware')   ## Crea inventario Software previamente
-        except:
-            logger.warning ('Error al ejecutar el comando')
-            return {}
-
-        if res['contents']:
-            self.muestraMensaje (2)
-            inv_sft = res['contents']
-            try:
-                self.interfaceAdmin (nfn, [dsk, par, nci, ipr, tag])
-                self.muestraMensaje (9)
-                herror = 0
-            except:
-                logger.warning ('Error al ejecutar el comando')
-                self.muestraMensaje (10)
-                herror = 1
-        else:
-            logger.warning ('Error al ejecutar el comando')
-            herror = 1
-            inv_sft = ''
-
-        self.muestraMenu()
-
-        cmd = {
-            'nfn':     'RESPUESTA_CrearImagenGit',
-            'idi':     idi,    ## Identificador de la imagen
-            'dsk':     dsk,    ## Número de disco
-            'par':     par,    ## Número de partición de donde se creó
-            'cpt':     cpt,    ## Tipo o código de partición
-            'ipr':     ipr,    ## Ip del repositorio donde se alojó
-            'inv_sft': inv_sft
-        }
-        return self.respuestaEjecucionComando (cmd, herror, ids)
-
-
     def do_RestaurarImagen (self, post_params):
         for k in ['dsk', 'par', 'idi', 'ipr', 'nci', 'ifs', 'ptc', 'nfn', 'ids']:
             if k not in post_params:
@@ -460,54 +406,6 @@ class ogAdmClientWorker (ogLiveWorker):
         }
         return self.respuestaEjecucionComando (cmd, herror, ids)
 
-    def do_RestaurarImagenGit (self, post_params):
-        for k in ['dsk', 'par', 'idi', 'ipr', 'nci', 'ifs', 'ptc', 'nfn', 'ids', 'ref']:
-            if k not in post_params:
-                logger.error (f'required parameter ({k}) not in POST params')
-                return {}
-
-        dsk = post_params['dsk']
-        par = post_params['par']
-        idi = post_params['idi']
-        ipr = post_params['ipr']
-        nci = post_params['nci']
-        ifs = post_params['ifs']
-        ptc = post_params['ptc']    ## Protocolo de clonación: Unicast, Multicast, Torrent
-        nfn = post_params['nfn']
-        ids = post_params['ids']
-        ref = post_params['ref']    ## Referencia de git a restaurar
-
-        self.muestraMensaje (3)
-
-        try:
-            ## the ptc.split() is useless right now, since interfaceAdmin() does ' '.join(params) in order to spawn a shell
-            ## however we're going to need it in the future (when everything gets translated into python), plus it's harmless now. So let's do it
-            #self.interfaceAdmin (nfn, [dsk, par, nci, ipr, ptc])
-            self.interfaceAdmin (nfn, [dsk, par, nci, ipr, ref] + ptc.split())
-            self.muestraMensaje (11)
-            herror = 0
-        except:
-            logger.warning ('Error al ejecutar el comando')
-            self.muestraMensaje (12)
-            herror = 1
-
-        cfg = self.LeeConfiguracion()
-        if not cfg:
-            logger.warning ('No se ha podido recuperar la configuración de las particiones del disco')
-
-        self.muestraMenu()
-
-        cmd = {
-            'nfn': 'RESPUESTA_RestaurarImagenGit',
-            'idi': idi,                  ## Identificador de la imagen
-            'dsk': dsk,                  ## Número de disco
-            'par': par,                  ## Número de partición
-            'ifs': ifs,                  ## Identificador del perfil software
-            'cfg': self.cfg2obj(cfg),    ## Configuración de discos
-        }
-        return self.respuestaEjecucionComando (cmd, herror, ids)
-
-
     def do_Configurar (self, post_params):
         for k in ['nfn', 'dsk', 'cfg', 'ids']:
             if k not in post_params:
@@ -918,16 +816,6 @@ class ogAdmClientWorker (ogLiveWorker):
         logger.debug ('type(post_params) "{}"'.format (type (post_params)))
         return self._long_running_job ('CrearImagen', self.do_CrearImagen, args=(post_params,))
 
-    def process_CrearImagenGit (self, path, get_params, post_params, server):
-        logger.debug ('in process_CrearImagenGit, path "{}" get_params "{}" post_params "{}" server "{}"'.format (path, get_params, post_params, server))
-        logger.debug ('type(post_params) "{}"'.format (type (post_params)))
-        return self._long_running_job ('CrearImagenGit', self.do_CrearImagenGit, args=(post_params,))
-
-    def process_RestaurarImagenGit (self, path, get_params, post_params, server):
-        logger.debug ('in process_RestaurarImagenGit, path "{}" get_params "{}" post_params "{}" server "{}"'.format (path, get_params, post_params, server))
-        logger.debug ('type(post_params) "{}"'.format (type (post_params)))
-        return self._long_running_job ('RestaurarImagenGit', self.do_RestaurarImagenGit, args=(post_params,))
-
     #def process_CrearImagenBasica (self, path, get_params, post_params, server):
     #    logger.debug ('in process_CrearImagenBasica, path "{}" get_params "{}" post_params "{}" server "{}"'.format (path, get_params, post_params, server))
     #    logger.warning ('this method has been removed')

src/opengnsys/service.py

@@ -30,7 +30,6 @@
 @author: Adolfo Gómez, dkmaster at dkmon dot com
 """
 
-import os
 import json
 import socket
 import time
@@ -198,16 +197,6 @@ class CommonService(object):
         Invoked to wait a bit
         CAN be OVERRIDDEN
         """
-        client_died=False
-        if os.path.exists ('/windows/temp/ogagentuser_died'):
-            os.unlink ('/windows/temp/ogagentuser_died')
-            client_died=True
-        elif os.path.exists ('/tmp/ogagentuser_died'):
-            os.unlink ('/tmp/ogagentuser_died')
-            client_died=True
-        if client_died:
-            self.notifyLogout (b'')
-
         time.sleep(float(miliseconds) / 1000)
 
     def notifyStop(self):

src/opengnsys/workers/oglive_worker.py

@@ -259,7 +259,7 @@ class ogLiveWorker(ServerWorker):
                 self.REST.sendMessage ('clients/status/webhook', body)
 
     def interfaceAdmin (self, method, parametros=[]):
-        if method in ['Apagar', 'CambiarAcceso', 'Configurar', 'CrearImagen', 'CrearImagenGit', 'EjecutarScript', 'getConfiguration', 'getIpAddress', 'IniciarSesion', 'InventarioHardware', 'InventarioSoftware', 'Reiniciar', 'RestaurarImagen', 'RestaurarImagenGit']:
+        if method in ['Apagar', 'CambiarAcceso', 'Configurar', 'CrearImagen', 'EjecutarScript', 'getConfiguration', 'getIpAddress', 'IniciarSesion', 'InventarioHardware', 'InventarioSoftware', 'Reiniciar', 'RestaurarImagen']:
             ## python
             logger.debug (f'({method}) is a python method')
             exe = '{}/{}.py'.format (self.pathinterface, method)