- VERSION 5.09.18

- feat(manager): Implementa recarga granular (Hot-Swap).
- Actualiza manager.html para solicitar la DB Key a recargar (ej: DB2).
- Se modifica Manager.bas para leer este parámetro y ejecutar el Hot-Swap de forma atómica solo en el pool de conexión especificado, lo cual mejora la eficiencia y la disponibilidad del servicio.

Cambios.bas

@@ -21,11 +21,23 @@ Sub Process_Globals
 '	  los dominios permitidos.
 '	- Ej: token:1224abcd5678fghi, dominio:"keymon.net"
 '	- Ej: token:4321abcd8765fghi, dominio:"*"
-'	- Que los logs, en lugar de guardar de uno en uno en la BD Sqlte, se guarden en memoria, se junten ... por ejemplo 100 y ya que haya 100, se guarden
-'	  en una solo query a la BD Sqlite.
 '	- Que en el reporte de "Queries lentos" se pueda especificar de cuanto tiempo, ahorita esta de la ultima hora, pero que se pueda seleccionar desde una
 '	  lista, por ejemplo 15, 30, 45 y 60 minutos antes.
 
+'	- VERSION 5.09.18
+'	- feat(manager): Implementa recarga granular (Hot-Swap).
+'	- Actualiza manager.html para solicitar la DB Key a recargar (ej: DB2).
+'	- Se modifica Manager.bas para leer este parámetro y ejecutar el Hot-Swap de forma atómica solo en el pool de conexión especificado, lo cual mejora la eficiencia y la disponibilidad del servicio.
+
+'	- VERSION 5.09.17
+'	- fix(handlers, logs): Reporte robusto de AffectedRows (simbólico) y limpieza de tabla de errores
+'	- Aborda dos problemas críticos para la estabilidad y fiabilidad del servidor: el manejo del conteo de filas afectadas en DMLs y la gestión del crecimiento de la tabla de logs de errores.
+
+	' - Cambios Principales:
+
+	' 1. Fix AffectedRows (ExecuteBatch V1 y DBHandlerJSON): Dada la imposibilidad de capturar el conteo de filas afectadas real (Null) de forma segura o la falla total en tiempo de ejecución (Method: ExecNonQuery2 not matched) al usar reflexión, se revierte la lógica a la llamada directa de ExecNonQuery2. Si el comando DML se ejecuta sin lanzar una excepción SQL, se reporta simbólicamente '1' fila afectada al cliente (en el Protocolo V1 y en la respuesta JSON para executecommand) para confirmar el éxito de la operación.
+	' 2. Limpieza de Tabla de Errores: Se corrigió la subrutina Main.borraArribaDe15000Logs para incluir la tabla `errores` en la limpieza periódica. Esto asegura que el log de errores no crezca indefinidamente, manteniendo solo los 15,000 registros más recientes y realizando la optimización de espacio en disco con `vacuum`.
+
 '	- VERSION 5.09.16.2
 '	- feat(logs): Implementación de Cacheo y Escritura Transaccional en Lotes
 '	

DBHandlerB4X.bas

@@ -17,15 +17,15 @@ Sub Class_Globals
 	' La siguiente sección de constantes y utilidades se compila condicionalmente
 	' solo si la directiva #if VERSION1 está activa. Esto es para dar soporte
 	' a una versión antigua del protocolo de comunicación de DBRequestManager.
-'    #if VERSION1
+	'    #if VERSION1
 	' Constantes para identificar los tipos de datos en la serialización personalizada (protocolo V1).
-    Private const T_NULL = 0, T_STRING = 1, T_SHORT = 2, T_INT = 3, T_LONG = 4, T_FLOAT = 5 _
+	Private const T_NULL = 0, T_STRING = 1, T_SHORT = 2, T_INT = 3, T_LONG = 4, T_FLOAT = 5 _
     ,T_DOUBLE = 6, T_BOOLEAN = 7, T_BLOB = 8 As Byte
 	' Utilidades para convertir entre tipos de datos y arrays de bytes.
-    Private bc As ByteConverter
+	Private bc As ByteConverter
 	' Utilidad para comprimir/descomprimir streams de datos (usado en V1).
-    Private cs As CompressedStreams
+	Private cs As CompressedStreams
-'    #end if
+	'    #end if
 
 	' Mapa para convertir tipos de columna JDBC de fecha/hora a los nombres de métodos de Java
 	' para obtener los valores correctos de ResultSet.
@@ -105,17 +105,34 @@ Sub Handle(req As ServletRequest, resp As ServletResponse)
 
 		con = Connector.GetConnection(dbKey) ' ¡La conexión a la BD se obtiene aquí del pool de conexiones!
 
-		' <<<< ¡BUSY_CONNECTIONS YA SE CAPTURABA BIEN! >>>>
 		' Este bloque captura el número de conexiones actualmente ocupadas en el pool
 		' *después* de que esta petición ha obtenido la suya.
 		If Connector.IsInitialized Then
 			Dim poolStats As Map = Connector.GetPoolStats
 			If poolStats.ContainsKey("BusyConnections") Then
-				' <<<< ¡CORRECCIÓN CLAVE: Aseguramos que el valor sea Int! >>>>
 				poolBusyConnectionsForLog = poolStats.Get("BusyConnections").As(Int) ' Capturamos el valor.
+				Log($">>>>>>>>>>  ${poolStats.Get("BusyConnections")} "$)
 			End If
 		End If
-		' <<<< ¡FIN DE CAPTURA! >>>>
+
+		Dim cachedStatsB4X As Map = Main.LatestPoolStats.Get(dbKey).As(Map)
+
+		If cachedStatsB4X.IsInitialized Then
+			' 1. Actualizar Busy Connections y Active Requests
+			cachedStatsB4X.Put("BusyConnections", poolBusyConnectionsForLog)
+			cachedStatsB4X.Put("HandlerActiveRequests", requestsBeforeDecrement)
+
+			' 2. Capturar TotalConnections y IdleConnections (ya disponibles en poolStats)
+			If poolStats.ContainsKey("TotalConnections") Then
+				cachedStatsB4X.Put("TotalConnections", poolStats.Get("TotalConnections"))
+			End If
+			If poolStats.ContainsKey("IdleConnections") Then
+				cachedStatsB4X.Put("IdleConnections", poolStats.Get("IdleConnections"))
+			End If
+
+			' 3. Re-escribir el mapa en el cache global (es Thread-Safe)
+			Main.LatestPoolStats.Put(dbKey, cachedStatsB4X)
+		End If
 
 '		Log("Metodo: " & method) ' Log de depuración para identificar el método de la petición.
 
@@ -128,25 +145,25 @@ Sub Handle(req As ServletRequest, resp As ServletResponse)
 				CleanupAndLog(dbKey, "error_in_" & method, duration, req.RemoteAddress, requestsBeforeDecrement, poolBusyConnectionsForLog, con)
 				Return ' Salida temprana si hay un error.
 			End If
-'        #if VERSION1
+			'        #if VERSION1
 			' Estas ramas se compilan solo si #if VERSION1 está activo (para protocolo antiguo).
-        Else if method = "query" Then
+		Else if method = "query" Then
-            in = cs.WrapInputStream(in, "gzip") ' Descomprime el stream de entrada si es protocolo V1.
+			in = cs.WrapInputStream(in, "gzip") ' Descomprime el stream de entrada si es protocolo V1.
-            q = ExecuteQuery(dbKey, con, in, resp)
+			q = ExecuteQuery(dbKey, con, in, resp)
-            If q = "error" Then
+			If q = "error" Then
-                duration = DateTime.Now - start
+				duration = DateTime.Now - start
-                CleanupAndLog(dbKey, "error_in_" & method, duration, req.RemoteAddress, requestsBeforeDecrement, poolBusyConnectionsForLog, con)
+				CleanupAndLog(dbKey, "error_in_" & method, duration, req.RemoteAddress, requestsBeforeDecrement, poolBusyConnectionsForLog, con)
-                Return
+				Return
-            End If
+			End If
-        Else if method = "batch" Then
+		Else if method = "batch" Then
-            in = cs.WrapInputStream(in, "gzip") ' Descomprime el stream de entrada si es protocolo V1.
+			in = cs.WrapInputStream(in, "gzip") ' Descomprime el stream de entrada si es protocolo V1.
-            q = ExecuteBatch(dbKey, con, in, resp)
+			q = ExecuteBatch(dbKey, con, in, resp)
-            If q = "error" Then
+			If q = "error" Then
-                duration = DateTime.Now - start
+				duration = DateTime.Now - start
-                CleanupAndLog(dbKey, "error_in_" & method, duration, req.RemoteAddress, requestsBeforeDecrement, poolBusyConnectionsForLog, con)
+				CleanupAndLog(dbKey, "error_in_" & method, duration, req.RemoteAddress, requestsBeforeDecrement, poolBusyConnectionsForLog, con)
-                Return
+				Return
-            End If
+			End If
-'        #end if
+			'        #end if
 		Else if method = "batch2" Then
 			' Ejecuta un lote de comandos (INSERT, UPDATE, DELETE) utilizando el protocolo V2.
 			q = ExecuteBatch2(dbKey, con, in, resp)
@@ -167,9 +184,16 @@ Sub Handle(req As ServletRequest, resp As ServletResponse)
 		End If
 
 	Catch ' --- CATCH: Maneja errores generales de ejecución o de SQL ---
-		Log(LastException) ' Registra la excepción completa en el log.
+		Dim errorMessage As String = LastException.Message
-		Main.LogServerError("ERROR", "DBHandlerB4X.Handle", LastException.Message, dbKey, q, req.RemoteAddress) ' <-- Nuevo Log
+		If errorMessage.Contains("ORA-01002") Or errorMessage.Contains("recuperación fuera de secuencia") Then
-		SendPlainTextError(resp, 500, LastException.Message) ' Envía un error 500 al cliente.
+			errorMessage = "SE USA EXECUTEQUERY EN LUGAR DE EXECUTECOMMAND: " & errorMessage
+		else If errorMessage.Contains("ORA-17003") Or errorMessage.Contains("Índice de columnas no válido") Then
+			errorMessage = "NUMERO DE PARAMETROS EQUIVOCADO: " & errorMessage
+		End If
+		
+		Log(errorMessage) ' Registra la excepción completa en el log.
+		Main.LogServerError("ERROR", "DBHandlerB4X.Handle", errorMessage, dbKey, q, req.RemoteAddress) ' <-- Nuevo Log
+		SendPlainTextError(resp, 500, errorMessage) ' Envía un error 500 al cliente.
 		q = "error_in_b4x_handler" ' Aseguramos un valor para 'q' en caso de excepción.
 	End Try ' --- FIN: Bloque Try principal ---
 
@@ -344,11 +368,12 @@ Private Sub ExecuteBatch2(DB As String, con As SQL, in As InputStream, resp As S
 	Dim m As Map = ser.ConvertBytesToObject(Bit.InputStreamToBytes(in))
 	' Obtiene la lista de objetos DBCommand.
 	Dim commands As List = m.Get("commands")
+	Dim totalAffectedRows As Int = 0 ' Contador para acumular el total de filas afectadas.
 
 	' Prepara un objeto DBResult para la respuesta (aunque para batch no devuelve datos, solo confirmación).
 	Dim res As DBResult
 	res.Initialize
-	res.columns = CreateMap("AffectedRows (N/A)": 0) ' Columna simbólica.
+	res.columns = CreateMap("AffectedRows": 0) ' Columna simbólica.
 	res.Rows.Initialize
 	res.Tag = Null
 
@@ -390,10 +415,14 @@ Private Sub ExecuteBatch2(DB As String, con As SQL, in As InputStream, resp As S
 			End If
 
 			con.ExecNonQuery2(sqlCommand, validationResult.ParamsToExecute) ' Ejecuta el comando con la lista de parámetros validada.
+			
+			totalAffectedRows = totalAffectedRows + 1 ' Acumulamos 1 por cada comando ejecutado sin error.
+			
 			' <<< FIN VALIDACIÓN DE PARÁMETROS CENTRALIZADA DENTRO DEL BATCH >>>
+			
 		Next
 
-		res.Rows.Add(Array As Object(0)) ' Añade una fila simbólica al resultado para indicar éxito.
+		res.Rows.Add(Array As Object(totalAffectedRows)) ' Añade una fila simbólica al resultado para indicar éxito.
 		con.TransactionSuccessful ' Si todos los comandos se ejecutaron sin error, confirma la transacción.
 	Catch
 		' Si cualquier comando falla, se captura el error.
@@ -427,34 +456,41 @@ End Sub
 
 ' Ejecuta un lote de comandos usando el protocolo V1.
 Private Sub ExecuteBatch(DB As String, con As SQL, in As InputStream, resp As ServletResponse) As String
-    ' Lee y descarta la versión del cliente.
+'	Log($"ExecuteBatch ${DB}"$)
-    Dim clientVersion As Float = ReadObject(in) 'ignore
+	' Lee y descarta la versión del cliente.
-    ' Lee cuántos comandos vienen en el lote.
+	Dim clientVersion As Float = ReadObject(in) 'ignore
-    Dim numberOfStatements As Int = ReadInt(in)
+	' Lee cuántos comandos vienen en el lote.
-    Dim res(numberOfStatements) As Int ' Array para resultados (aunque no se usa).
+	Dim numberOfStatements As Int = ReadInt(in)
+	Dim res(numberOfStatements) As Int ' Array para resultados (aunque no se usa).
 	Dim singleQueryName As String = ""
+	Dim affectedCounts As List
+	Dim totalAffectedRows As Int
+	affectedCounts.Initialize
 
-    Try
+	Try
-        con.BeginTransaction
+		con.BeginTransaction
-        ' Itera para procesar cada comando del lote.
+		' Itera para procesar cada comando del lote.
-        For i = 0 To numberOfStatements - 1
+'		Log(numberOfStatements)
-            ' Lee el nombre del comando y la lista de parámetros usando el deserializador V1.
+		For i = 0 To numberOfStatements - 1
-            Dim queryName As String = ReadObject(in)
+'			Log($"i: ${i}"$)
-            Dim params As List = ReadList(in)
+			' Lee el nombre del comando y la lista de parámetros usando el deserializador V1.
+			Dim queryName As String = ReadObject(in)
+			Dim params As List = ReadList(in)
+'			Log(params)
 			If numberOfStatements = 1 Then
 				singleQueryName = queryName 'Capturamos el nombre del query.
 			End If
-            Dim sqlCommand As String = Connector.GetCommand(DB, queryName)
+			Dim sqlCommand As String = Connector.GetCommand(DB, queryName)
-
+'			Log(sqlCommand)
-            ' <<< INICIO NUEVA VALIDACIÓN: VERIFICAR SI EL COMANDO EXISTE (V1) >>>
+			' <<< INICIO NUEVA VALIDACIÓN: VERIFICAR SI EL COMANDO EXISTE (V1) >>>
-            If sqlCommand = Null Or sqlCommand = "null" Or sqlCommand.Trim = "" Then
+			If sqlCommand = Null Or sqlCommand = "null" Or sqlCommand.Trim = "" Then
-                con.Rollback ' Deshace la transacción si un comando es inválido.
+				con.Rollback ' Deshace la transacción si un comando es inválido.
-                Dim errorMessage As String = $"El comando '${queryName}' no fue encontrado en el config.properties de '${DB}'."$
+				Dim errorMessage As String = $"El comando '${queryName}' no fue encontrado en el config.properties de '${DB}'."$
-                Log(errorMessage)
+				Log(errorMessage)
 				Main.LogServerError("ERROR", "DBHandlerB4X.ExecuteBatch (V1)", errorMessage, DB, queryName, Null)
-                SendPlainTextError(resp, 400, errorMessage)
+				SendPlainTextError(resp, 400, errorMessage)
-                Return "error"
+				Return "error"
-            End If
+			End If
 			' <<< FIN NUEVA VALIDACIÓN >>>
 
 			' <<< INICIO VALIDACIÓN DE PARÁMETROS CENTRALIZADA DENTRO DEL BATCH (V1) >>>
@@ -466,28 +502,38 @@ Private Sub ExecuteBatch(DB As String, con As SQL, in As InputStream, resp As Se
 				Return "error" ' Salida temprana si la validación falla.
 			End If
 			
+'			Log(validationResult.ParamsToExecute)
+			
+			Dim affectedCount As Int = 1 ' Asumimos éxito (1) ya que la llamada directa es la única que ejecuta el SQL sin fallar en runtime.
+
 			con.ExecNonQuery2(sqlCommand, validationResult.ParamsToExecute) ' Ejecuta el comando con la lista de parámetros validada.
 			' <<< FIN VALIDACIÓN DE PARÁMETROS CENTRALIZADA DENTRO DEL BATCH (V1) >>>
-        Next
+			affectedCounts.Add(affectedCount) ' Añadimos el resultado (1) a la lista de respuesta V1
+			totalAffectedRows = totalAffectedRows + affectedCount ' Acumulamos el total para el log (aunque sea 1 simbólico)
 			
-        con.TransactionSuccessful ' Confirma la transacción.
+		Next
 
-        Dim out As OutputStream = cs.WrapOutputStream(resp.OutputStream, "gzip") ' Comprime la salida antes de enviarla.
+		con.TransactionSuccessful ' Confirma la transacción.
-        ' Escribe la respuesta usando el serializador V1.
-        WriteObject(Main.VERSION, out)
-        WriteObject("batch", out)
-        WriteInt(res.Length, out)
-        For Each r As Int In res
-            WriteInt(r, out)
-        Next
-        out.Close
 		
-    Catch
+'		Log("Transaction succesfull")
-        con.Rollback
+
-        Log(LastException)
+		Dim out As OutputStream = cs.WrapOutputStream(resp.OutputStream, "gzip") ' Comprime la salida antes de enviarla.
+		' Escribe la respuesta usando el serializador V1.
+		WriteObject(Main.VERSION, out)
+		WriteObject("batch", out)
+		WriteInt(res.Length, out)
+'		Log(affectedCounts.Size)
+		For Each r As Int In affectedCounts
+			WriteInt(r, out)
+		Next
+		out.Close
+
+	Catch
+		con.Rollback
+		Log(LastException)
 		Main.LogServerError("ERROR", "DBHandlerB4X.ExecuteBatch (V1)", LastException.Message, DB, "batch_execution_error_v1", Null)
-        SendPlainTextError(resp, 500, LastException.Message)
+		SendPlainTextError(resp, 500, LastException.Message)
-    End Try
+	End Try
 
 '	Return $"batch (size=${numberOfStatements})"$
 	If numberOfStatements = 1 And singleQueryName <> "" Then
@@ -499,24 +545,24 @@ End Sub
 
 ' Ejecuta una consulta única usando el protocolo V1.
 Private Sub ExecuteQuery(DB As String, con As SQL, in As InputStream, resp As ServletResponse) As String
-'    Log("====================== ExecuteQuery =====================")
+	'    Log("====================== ExecuteQuery =====================")
-    ' Deserializa los datos de la petición usando el protocolo V1.
+	' Deserializa los datos de la petición usando el protocolo V1.
-    Dim clientVersion As Float = ReadObject(in) 'ignore
+	Dim clientVersion As Float = ReadObject(in) 'ignore
-    Dim queryName As String = ReadObject(in)
+	Dim queryName As String = ReadObject(in)
-    Dim limit As Int = ReadInt(in)
+	Dim limit As Int = ReadInt(in)
-    Dim params As List = ReadList(in)
+	Dim params As List = ReadList(in)
 
-    ' Obtiene la sentencia SQL.
+	' Obtiene la sentencia SQL.
-    Dim theSql As String = Connector.GetCommand(DB, queryName)
+	Dim theSql As String = Connector.GetCommand(DB, queryName)
 
-    ' <<< INICIO NUEVA VALIDACIÓN: VERIFICAR SI EL COMANDO EXISTE (V1) >>>
+	' <<< INICIO NUEVA VALIDACIÓN: VERIFICAR SI EL COMANDO EXISTE (V1) >>>
-    If theSql = Null Or theSql ="null" Or theSql.Trim = "" Then
+	If theSql = Null Or theSql ="null" Or theSql.Trim = "" Then
-        Dim errorMessage As String = $"El comando '${queryName}' no fue encontrado en el config.properties de '${DB}'."$
+		Dim errorMessage As String = $"El comando '${queryName}' no fue encontrado en el config.properties de '${DB}'."$
-        Log(errorMessage)
+		Log(errorMessage)
 		Main.LogServerError("ERROR", "DBHandlerB4X.ExecuteQuery (V1)", errorMessage, DB, queryName, Null)
-        SendPlainTextError(resp, 400, errorMessage)
+		SendPlainTextError(resp, 400, errorMessage)
-        Return "error"
+		Return "error"
-    End If
+	End If
 	' <<< FIN NUEVA VALIDACIÓN >>>
 
 	' <<< INICIO VALIDACIÓN DE PARÁMETROS CENTRALIZADA (V1) >>>
@@ -531,177 +577,177 @@ Private Sub ExecuteQuery(DB As String, con As SQL, in As InputStream, resp As Se
 	Dim rs As ResultSet = con.ExecQuery2(theSql, validationResult.ParamsToExecute)
 	' <<< FIN VALIDACIÓN DE PARÁMETROS CENTRALIZADA (V1) >>>
 
-    If limit <= 0 Then limit = 0x7fffffff 'max int
+	If limit <= 0 Then limit = 0x7fffffff 'max int
 
-    Dim jrs As JavaObject = rs
+	Dim jrs As JavaObject = rs
-    Dim rsmd As JavaObject = jrs.RunMethod("getMetaData", Null)
+	Dim rsmd As JavaObject = jrs.RunMethod("getMetaData", Null)
-    Dim cols As Int = rs.ColumnCount
+	Dim cols As Int = rs.ColumnCount
 
-    Dim out As OutputStream = cs.WrapOutputStream(resp.OutputStream, "gzip") ' Comprime el stream de salida.
+	Dim out As OutputStream = cs.WrapOutputStream(resp.OutputStream, "gzip") ' Comprime el stream de salida.
 
-    ' Escribe la cabecera de la respuesta V1.
+	' Escribe la cabecera de la respuesta V1.
-    WriteObject(Main.VERSION, out)
+	WriteObject(Main.VERSION, out)
-    WriteObject("query", out)
+	WriteObject("query", out)
-    WriteInt(rs.ColumnCount, out)
+	WriteInt(rs.ColumnCount, out)
 
-    ' Escribe los nombres de las columnas.
+	' Escribe los nombres de las columnas.
-    For i = 0 To cols - 1
+	For i = 0 To cols - 1
-        WriteObject(rs.GetColumnName(i), out)
+		WriteObject(rs.GetColumnName(i), out)
-    Next
+	Next
 
-    ' Itera sobre las filas del resultado.
+	' Itera sobre las filas del resultado.
-    Do While rs.NextRow And limit > 0
+	Do While rs.NextRow And limit > 0
-        WriteByte(1, out) ' Escribe un byte '1' para indicar que viene una fila.
+		WriteByte(1, out) ' Escribe un byte '1' para indicar que viene una fila.
-        ' Itera sobre las columnas de la fila.
+		' Itera sobre las columnas de la fila.
-        For i = 0 To cols - 1
+		For i = 0 To cols - 1
-            Dim ct As Int = rsmd.RunMethod("getColumnType", Array(i + 1))
+			Dim ct As Int = rsmd.RunMethod("getColumnType", Array(i + 1))
-            ' Maneja los tipos de datos binarios de forma especial.
+			' Maneja los tipos de datos binarios de forma especial.
-            If ct = -2 Or ct = 2004 Or ct = -3 Or ct = -4 Then
+			If ct = -2 Or ct = 2004 Or ct = -3 Or ct = -4 Then
-                WriteObject(rs.GetBlob2(i), out)
+				WriteObject(rs.GetBlob2(i), out)
-            Else
+			Else
-                ' Escribe el valor de la columna.
+				' Escribe el valor de la columna.
-                WriteObject(jrs.RunMethod("getObject", Array(i + 1)), out)
+				WriteObject(jrs.RunMethod("getObject", Array(i + 1)), out)
-            End If
+			End If
-        Next
+		Next
-        limit = limit - 1
+		limit = limit - 1
-    Loop
+	Loop
 
-    ' Escribe un byte '0' para indicar el fin de las filas.
+	' Escribe un byte '0' para indicar el fin de las filas.
-    WriteByte(0, out)
+	WriteByte(0, out)
-    out.Close
+	out.Close
-    rs.Close
+	rs.Close
 
-    Return "query: " & queryName
+	Return "query: " & queryName
 End Sub
 
 ' Escribe un único byte en el stream de salida.
 Private Sub WriteByte(value As Byte, out As OutputStream)
-    out.WriteBytes(Array As Byte(value), 0, 1)
+	out.WriteBytes(Array As Byte(value), 0, 1)
 End Sub
 
 ' Serializador principal para el protocolo V1. Escribe un objeto al stream.
 Private Sub WriteObject(o As Object, out As OutputStream)
-    Dim data() As Byte
+	Dim data() As Byte
-    ' Escribe un byte de tipo seguido de los datos.
+	' Escribe un byte de tipo seguido de los datos.
-    If o = Null Then
+	If o = Null Then
-        out.WriteBytes(Array As Byte(T_NULL), 0, 1)
+		out.WriteBytes(Array As Byte(T_NULL), 0, 1)
-    Else If o Is Short Then
+	Else If o Is Short Then
-        out.WriteBytes(Array As Byte(T_SHORT), 0, 1)
+		out.WriteBytes(Array As Byte(T_SHORT), 0, 1)
-        data = bc.ShortsToBytes(Array As Short(o))
+		data = bc.ShortsToBytes(Array As Short(o))
-    Else If o Is Int Then
+	Else If o Is Int Then
-        out.WriteBytes(Array As Byte(T_INT), 0, 1)
+		out.WriteBytes(Array As Byte(T_INT), 0, 1)
-        data = bc.IntsToBytes(Array As Int(o))
+		data = bc.IntsToBytes(Array As Int(o))
-    Else If o Is Float Then
+	Else If o Is Float Then
-        out.WriteBytes(Array As Byte(T_FLOAT), 0, 1)
+		out.WriteBytes(Array As Byte(T_FLOAT), 0, 1)
-        data = bc.FloatsToBytes(Array As Float(o))
+		data = bc.FloatsToBytes(Array As Float(o))
-    Else If o Is Double Then
+	Else If o Is Double Then
-        out.WriteBytes(Array As Byte(T_DOUBLE), 0, 1)
+		out.WriteBytes(Array As Byte(T_DOUBLE), 0, 1)
-        data = bc.DoublesToBytes(Array As Double(o))
+		data = bc.DoublesToBytes(Array As Double(o))
-    Else If o Is Long Then
+	Else If o Is Long Then
-        out.WriteBytes(Array As Byte(T_LONG), 0, 1)
+		out.WriteBytes(Array As Byte(T_LONG), 0, 1)
-        data = bc.LongsToBytes(Array As Long(o))
+		data = bc.LongsToBytes(Array As Long(o))
-    Else If o Is Boolean Then
+	Else If o Is Boolean Then
-        out.WriteBytes(Array As Byte(T_BOOLEAN), 0, 1)
+		out.WriteBytes(Array As Byte(T_BOOLEAN), 0, 1)
-        Dim b As Boolean = o
+		Dim b As Boolean = o
-        Dim data(1) As Byte
+		Dim data(1) As Byte
-        If b Then data(0) = 1 Else data(0) = 0
+		If b Then data(0) = 1 Else data(0) = 0
-    Else If GetType(o) = "[B" Then ' Si el objeto es un array de bytes (BLOB)
+	Else If GetType(o) = "[B" Then ' Si el objeto es un array de bytes (BLOB)
-        data = o
+		data = o
-        out.WriteBytes(Array As Byte(T_BLOB), 0, 1)
+		out.WriteBytes(Array As Byte(T_BLOB), 0, 1)
-        ' Escribe la longitud de los datos antes de los datos mismos.
+		' Escribe la longitud de los datos antes de los datos mismos.
-        WriteInt(data.Length, out)
+		WriteInt(data.Length, out)
-    Else ' Trata todo lo demás como un String
+	Else ' Trata todo lo demás como un String
-        out.WriteBytes(Array As Byte(T_STRING), 0, 1)
+		out.WriteBytes(Array As Byte(T_STRING), 0, 1)
-        data = bc.StringToBytes(o, "UTF8")
+		data = bc.StringToBytes(o, "UTF8")
-        ' Escribe la longitud del string antes del string.
+		' Escribe la longitud del string antes del string.
-        WriteInt(data.Length, out)
+		WriteInt(data.Length, out)
-    End If
+	End If
-    ' Escribe los bytes del dato.
+	' Escribe los bytes del dato.
-    If data.Length > 0 Then out.WriteBytes(data, 0, data.Length)
+	If data.Length > 0 Then out.WriteBytes(data, 0, data.Length)
 End Sub
 
 ' Deserializador principal para el protocolo V1. Lee un objeto del stream.
 Private Sub ReadObject(In As InputStream) As Object
-    ' Lee el primer byte para determinar el tipo de dato.
+	' Lee el primer byte para determinar el tipo de dato.
-    Dim data(1) As Byte
+	Dim data(1) As Byte
-    In.ReadBytes(data, 0, 1)
+	In.ReadBytes(data, 0, 1)
-    Select data(0)
+	Select data(0)
-        Case T_NULL
+		Case T_NULL
-            Return Null
+			Return Null
-        Case T_SHORT
+		Case T_SHORT
-            Dim data(2) As Byte
+			Dim data(2) As Byte
-            Return bc.ShortsFromBytes(ReadBytesFully(In, data, data.Length))(0)
+			Return bc.ShortsFromBytes(ReadBytesFully(In, data, data.Length))(0)
-        Case T_INT
+		Case T_INT
-            Dim data(4) As Byte
+			Dim data(4) As Byte
-            Return bc.IntsFromBytes(ReadBytesFully(In, data, data.Length))(0)
+			Return bc.IntsFromBytes(ReadBytesFully(In, data, data.Length))(0)
-        Case T_LONG
+		Case T_LONG
-            Dim data(8) As Byte
+			Dim data(8) As Byte
-            Return bc.LongsFromBytes(ReadBytesFully(In, data, data.Length))(0)
+			Return bc.LongsFromBytes(ReadBytesFully(In, data, data.Length))(0)
-        Case T_FLOAT
+		Case T_FLOAT
-            Dim data(4) As Byte
+			Dim data(4) As Byte
-            Return bc.FloatsFromBytes(ReadBytesFully(In, data, data.Length))(0)
+			Return bc.FloatsFromBytes(ReadBytesFully(In, data, data.Length))(0)
-        Case T_DOUBLE
+		Case T_DOUBLE
-            Dim data(8) As Byte
+			Dim data(8) As Byte
-            Return bc.DoublesFromBytes(ReadBytesFully(In, data, data.Length))(0)
+			Return bc.DoublesFromBytes(ReadBytesFully(In, data, data.Length))(0)
-        Case T_BOOLEAN
+		Case T_BOOLEAN
-            Dim b As Byte = ReadByte(In)
+			Dim b As Byte = ReadByte(In)
-            Return b = 1
+			Return b = 1
-        Case T_BLOB
+		Case T_BLOB
-            ' Lee la longitud, luego lee esa cantidad de bytes.
+			' Lee la longitud, luego lee esa cantidad de bytes.
-            Dim len As Int = ReadInt(In)
+			Dim len As Int = ReadInt(In)
-            Dim data(len) As Byte
+			Dim data(len) As Byte
-            Return ReadBytesFully(In, data, data.Length)
+			Return ReadBytesFully(In, data, data.Length)
-        Case Else ' T_STRING
+		Case Else ' T_STRING
-            ' Lee la longitud, luego lee esa cantidad de bytes y los convierte a string.
+			' Lee la longitud, luego lee esa cantidad de bytes y los convierte a string.
-            Dim len As Int = ReadInt(In)
+			Dim len As Int = ReadInt(In)
-            Dim data(len) As Byte
+			Dim data(len) As Byte
-            ReadBytesFully(In, data, data.Length)
+			ReadBytesFully(In, data, data.Length)
-            Return BytesToString(data, 0, data.Length, "UTF8")
+			Return BytesToString(data, 0, data.Length, "UTF8")
-    End Select
+	End Select
 End Sub
 
 ' Se asegura de leer exactamente la cantidad de bytes solicitada del stream.
 Private Sub ReadBytesFully(In As InputStream, Data() As Byte, Len As Int) As Byte()
-    Dim count = 0, Read As Int
+	Dim count = 0, Read As Int
-    ' Sigue leyendo en un bucle hasta llenar el buffer, por si los datos llegan en partes.
+	' Sigue leyendo en un bucle hasta llenar el buffer, por si los datos llegan en partes.
-    Do While count < Len And Read > -1
+	Do While count < Len And Read > -1
-        Read = In.ReadBytes(Data, count, Len - count)
+		Read = In.ReadBytes(Data, count, Len - count)
-        count = count + Read
+		count = count + Read
-    Loop
+	Loop
-    Return Data
+	Return Data
 End Sub
 
 ' Escribe un entero (4 bytes) en el stream.
 Private Sub WriteInt(i As Int, out As OutputStream)
-    Dim data() As Byte
+	Dim data() As Byte
-    data = bc.IntsToBytes(Array As Int(i))
+	data = bc.IntsToBytes(Array As Int(i))
-    out.WriteBytes(data, 0, data.Length)
+	out.WriteBytes(data, 0, data.Length)
 End Sub
 
 ' Lee un entero (4 bytes) del stream.
 Private Sub ReadInt(In As InputStream) As Int
-    Dim data(4) As Byte
+	Dim data(4) As Byte
-    Return bc.IntsFromBytes(ReadBytesFully(In, data, data.Length))(0)
+	Return bc.IntsFromBytes(ReadBytesFully(In, data, data.Length))(0)
 End Sub
 
 ' Lee un solo byte del stream.
 Private Sub ReadByte(In As InputStream) As Byte
-    Dim data(1) As Byte
+	Dim data(1) As Byte
-    In.ReadBytes(data, 0, 1)
+	In.ReadBytes(data, 0, 1)
-    Return data(0)
+	Return data(0)
 End Sub
 
 ' Lee una lista de objetos del stream (protocolo V1).
 Private Sub ReadList(in As InputStream) As List
-    ' Primero lee la cantidad de elementos en la lista.
+	' Primero lee la cantidad de elementos en la lista.
-    Dim len As Int = ReadInt(in)
+	Dim len As Int = ReadInt(in)
-    Dim l1 As List
+	Dim l1 As List
-    l1.Initialize
+	l1.Initialize
-    ' Luego lee cada objeto uno por uno y lo añade a la lista.
+	' Luego lee cada objeto uno por uno y lo añade a la lista.
-    For i = 0 To len - 1
+	For i = 0 To len - 1
-        l1.Add(ReadObject(in))
+		l1.Add(ReadObject(in))
-    Next
+	Next
-    Return l1
+	Return l1
 End Sub
 
 '#end If ' Fin del bloque de compilación condicional para VERSION1

DBHandlerJSON.bas

@@ -44,6 +44,7 @@ Sub Handle(req As ServletRequest, resp As ServletResponse)
 	Dim poolBusyConnectionsForLog As Int = 0 ' Contiene el número de conexiones ocupadas del pool.
 	Dim finalDbKey As String = "DB1" ' Identificador de la base de datos, con valor por defecto "DB1".
 	Dim requestsBeforeDecrement As Int = 0 ' Contador de peticiones activas antes de decrementar, inicializado en 0.
+	Dim Total As Int = 0
 
 	Try ' --- INICIO: Bloque Try que envuelve la lógica principal del Handler ---
 
@@ -127,10 +128,30 @@ Sub Handle(req As ServletRequest, resp As ServletResponse)
 			If poolStats.ContainsKey("BusyConnections") Then
 				' <<<< ¡CORRECCIÓN CLAVE: Aseguramos que el valor sea Int! >>>>
 				poolBusyConnectionsForLog = poolStats.Get("BusyConnections").As(Int) ' Capturamos el valor.
+'				Log($">>>>>>>>>>  ${poolStats.Get("BusyConnections")} "$)
 			End If
 		End If
 		' <<<< ¡FIN DE CAPTURA! >>>>
 		
+		Dim cachedStatsJSON As Map = Main.LatestPoolStats.Get(finalDbKey).As(Map)
+
+		If cachedStatsJSON.IsInitialized Then
+			' Los valores ya fueron capturados: poolBusyConnectionsForLog y requestsBeforeDecrement
+			cachedStatsJSON.Put("BusyConnections", poolBusyConnectionsForLog)
+			cachedStatsJSON.Put("HandlerActiveRequests", requestsBeforeDecrement)
+			If poolStats.ContainsKey("TotalConnections") Then
+				cachedStatsJSON.Put("TotalConnections", poolStats.Get("TotalConnections"))
+			End If
+			If poolStats.ContainsKey("IdleConnections") Then
+				cachedStatsJSON.Put("IdleConnections", poolStats.Get("IdleConnections"))
+			End If
+			' Re-escribir el mapa en el cache global (es Thread-Safe)
+			Main.LatestPoolStats.Put(finalDbKey, cachedStatsJSON)
+'			Log(Main.LatestPoolStats)
+		End If
+		
+'		Log($"Total:  ${poolStats.Get("TotalConnections")}, Idle:  ${poolStats.Get("IdleConnections")}, busy: ${poolBusyConnectionsForLog}, active: ${requestsBeforeDecrement}"$)
+
 		' Obtiene la sentencia SQL correspondiente al nombre del comando desde config.properties.
 		Dim sqlCommand As String = Connector.GetCommand(finalDbKey, queryNameForLog)
 
@@ -191,9 +212,9 @@ Sub Handle(req As ServletRequest, resp As ServletResponse)
 				CleanupAndLog(finalDbKey, queryNameForLog, duration, req.RemoteAddress, requestsBeforeDecrement, poolBusyConnectionsForLog, con)
 				Return ' Salida temprana.
 			End If
-
+			Dim affectedCount As Int = 1 ' Asumimos éxito (1) si ExecNonQuery2 no lanza una excepción.
 			con.ExecNonQuery2(sqlCommand, validationResult.ParamsToExecute) ' Ejecuta un comando con la lista de parámetros validada.
-			SendSuccessResponse(resp, CreateMap("message": "Command executed successfully")) ' Envía confirmación de éxito.
+			SendSuccessResponse(resp, CreateMap("affectedRows": affectedCount, "message": "Command executed successfully")) ' Envía confirmación de éxito.
 			' --- FIN VALIDACIÓN DE PARÁMETROS CENTRALIZADA ---
 		Else
 			Dim ErrorMsg As String = "Parámetro 'exec' inválido. '" & execType & "' no es un valor permitido."
@@ -201,7 +222,6 @@ Sub Handle(req As ServletRequest, resp As ServletResponse)
 			Main.LogServerError("ERROR", "DBHandlerJSON.Handle", ErrorMsg, finalDbKey, queryNameForLog, req.RemoteAddress) ' <-- Nuevo Log
 			' El flujo continúa hasta la limpieza final si no hay un Return explícito.
 		End If
-
 	Catch ' --- CATCH: Maneja errores generales de ejecución o de SQL/JSON ---
 		Log(LastException) ' Registra la excepción completa en el log.
 		Main.LogServerError("ERROR", "DBHandlerJSON.Handle", LastException.Message, finalDbKey, queryNameForLog, req.RemoteAddress) ' <-- Nuevo Log
@@ -215,7 +235,6 @@ Sub Handle(req As ServletRequest, resp As ServletResponse)
 	duration = DateTime.Now - start ' Calcula la duración total de la petición.
 	' Llama a la subrutina centralizada para registrar el rendimiento y limpiar recursos.
 	CleanupAndLog(finalDbKey, queryNameForLog, duration, req.RemoteAddress, requestsBeforeDecrement, poolBusyConnectionsForLog, con)
-
 End Sub
 
 ' --- NUEVA SUBRUTINA: Centraliza el logging de rendimiento y la limpieza de recursos ---

Files/www/manager.html

@@ -0,0 +1,391 @@
+<!DOCTYPE html>
+<html lang="es">
+  <head>
+    <meta charset="UTF-8" />
+    <meta name="viewport" content="width=device-width, initial-scale=1.0" />
+    <title>jRDC2-Multi - Panel de Administración</title>
+    <style>
+      body {
+        font-family: -apple-system, BlinkMacSystemFont, "Segoe UI", Roboto,
+          Helvetica, Arial, sans-serif;
+        background-color: #f8f9fa;
+        color: #212529;
+        margin: 0;
+        padding: 0;
+      }
+      .admin-menu {
+        background-color: #e9ecef;
+        padding: 1.5em 2em;
+        border-bottom: 1px solid #dee2e6;
+      }
+      .admin-menu h2 {
+        margin: 0 0 0.2em 0;
+        color: #343a40;
+      }
+      .admin-menu p {
+        margin: 0 0 1em 0;
+        color: #495057;
+      }
+      .admin-menu a {
+        color: #007bff;
+        text-decoration: none;
+        font-weight: 500;
+        margin-right: 0.5em;
+        padding-right: 0.5em;
+        border-right: 1px solid #ccc;
+        cursor: pointer;
+      }
+      .admin-menu a:last-child {
+        border-right: none;
+      }
+      .admin-menu a:hover {
+        text-decoration: underline;
+      }
+      .main-content {
+        padding: 2em;
+      }
+      #output-container {
+        background: #fff;
+        padding: 1em;
+        border: 1px solid #eee;
+        border-radius: 8px;
+        font-family: monospace;
+        white-space: pre-wrap;
+        word-wrap: break-word;
+        min-height: 200px;
+        overflow-x: auto;
+      }
+      table {
+        width: 100%;
+        border-collapse: collapse;
+        margin-top: 1.5em;
+        font-family: sans-serif;
+        font-size: 0.9em;
+      }
+      th,
+      td {
+        padding: 10px 12px;
+        text-align: center;
+        border-bottom: 1px solid #dee2e6;
+      }
+      thead {
+        background-color: #007bff;
+        color: #fff;
+      }
+      th {
+        font-weight: 600;
+        cursor: help;
+      }
+      tbody td:first-child {
+        font-weight: bold;
+        color: #0056b3;
+        text-align: left;
+      }
+
+      /* --- ESTILOS PARA EL INDICADOR SSE --- */
+      .sse-status-container {
+        display: flex;
+        align-items: center;
+        margin-top: 1em;
+        font-size: 0.8em;
+      }
+      .sse-status {
+        display: inline-block;
+        padding: 4px 8px;
+        border-radius: 4px;
+        font-weight: bold;
+        margin-left: 10px;
+        min-width: 80px;
+        text-align: center;
+      }
+      .sse-connected {
+        background-color: #28a745;
+        color: white;
+      }
+      .sse-disconnected {
+        background-color: #dc3545;
+        color: white;
+      }
+      .sse-connecting {
+        background-color: #ffc107;
+        color: #212529;
+      }
+      .cell-update {
+        animation: flash 0.7s ease-out;
+      }
+      @keyframes flash {
+        0% {
+          background-color: #ffc107;
+        }
+        100% {
+          background-color: transparent;
+        }
+      }
+    </style>
+  </head>
+  <body>
+    <div class="admin-menu">
+      <h2>Panel de Administración jRDC</h2>
+      <p>Bienvenido, <strong>admin</strong></p>
+      <nav id="main-nav">
+        <a data-command="test">Test</a>
+        <a data-command="ping">Ping</a>
+        <a data-command="reload">Reload</a>
+        <a data-command="slowqueries">Queries Lentas</a>
+        <a data-command="getstats">Estadísticas Pool</a>
+        <a data-command="rpm2">Reiniciar (pm2)</a>
+        <a data-command="reviveBow">Revive Bow</a>
+      </nav>
+      <div class="sse-status-container">
+        <span>Estado de Estadísticas en Tiempo Real:</span>
+        <span id="sse-status" class="sse-status sse-disconnected"
+          >Desconectado</span
+        >
+      </div>
+    </div>
+
+    <div class="main-content">
+      <h1 id="content-title">Bienvenido</h1>
+      <div id="output-container">
+        <p style="font-family: sans-serif">
+          Selecciona una opción del menú para comenzar.
+        </p>
+      </div>
+    </div>
+
+    <script>
+      const outputContainer = document.getElementById("output-container");
+      const contentTitle = document.getElementById("content-title");
+      const sseStatus = document.getElementById("sse-status");
+      let sseConnection = null;
+
+      // --- CONFIGURACIÓN PARA LA TABLA DE ESTADÍSTICAS ---
+      const COLUMN_ORDER = [
+        "InitialPoolSize",
+        "MinPoolSize",
+        "MaxPoolSize",
+        "AcquireIncrement",
+        "TotalConnections",
+        "BusyConnections",
+        "IdleConnections",
+        "CheckoutTimeout",
+        "MaxIdleTime",
+        "MaxConnectionAge",
+      ];
+      const HEADER_TOOLTIPS = {
+        InitialPoolSize:
+          "Número de conexiones que el pool intenta adquirir al arrancar.",
+        MinPoolSize: "Número mínimo de conexiones que el pool mantendrá.",
+        MaxPoolSize: "Número máximo de conexiones que el pool puede mantener.",
+        AcquireIncrement:
+          "Número de conexiones a adquirir cuando el pool se queda sin conexiones.",
+        TotalConnections: "Número total de conexiones (ocupadas + libres).",
+        BusyConnections: "Número de conexiones activamente en uso.",
+        IdleConnections: "Número de conexiones disponibles en el pool.",
+        CheckoutTimeout: "Tiempo máximo de espera por una conexión (ms).",
+        MaxIdleTime:
+          "Tiempo máximo que una conexión puede estar inactiva (segundos).",
+        MaxConnectionAge: "Tiempo máximo de vida de una conexión (segundos).",
+      };
+
+      // --- MANEJO DE LA CONEXIÓN SSE ---
+
+      function connectSSE() {
+        if (sseConnection && sseConnection.readyState !== EventSource.CLOSED) {
+          return; // Ya está conectado o conectando
+        }
+
+        outputContainer.innerHTML =
+          '<p style="font-family: sans-serif;">Esperando datos del pool de conexiones...</p>';
+        updateSSEStatus("connecting");
+
+        // La ruta debe coincidir con la que registraste en srvr.AddHandler
+        const SSE_ENDPOINT = "/stats-stream";
+        sseConnection = new EventSource(SSE_ENDPOINT);
+
+        sseConnection.onopen = () => {
+          console.log("Conexión SSE establecida.");
+          updateSSEStatus("connected");
+        };
+
+        // Escucha el evento específico "stats_update"
+        sseConnection.addEventListener("stats_update", (event) => {
+          try {
+            const data = JSON.parse(event.data);
+            renderOrUpdateStatsTable(data);
+          } catch (e) {
+            console.error("Error al parsear datos SSE:", e);
+          }
+        });
+
+        sseConnection.onerror = () => {
+          console.error("Error en la conexión SSE. Reintentando...");
+          updateSSEStatus("disconnected");
+          sseConnection.close();
+          // El navegador reintentará automáticamente la conexión
+        };
+      }
+
+      function disconnectSSE() {
+        if (sseConnection) {
+          sseConnection.close();
+          sseConnection = null;
+          console.log("Conexión SSE cerrada.");
+          updateSSEStatus("disconnected");
+        }
+      }
+
+      function updateSSEStatus(status) {
+        switch (status) {
+          case "connected":
+            sseStatus.textContent = "Conectado";
+            sseStatus.className = "sse-status sse-connected";
+            break;
+          case "connecting":
+            sseStatus.textContent = "Conectando";
+            sseStatus.className = "sse-status sse-connecting";
+            break;
+          case "disconnected":
+            sseStatus.textContent = "Desconectado";
+            sseStatus.className = "sse-status sse-disconnected";
+            break;
+        }
+      }
+
+      // --- RENDERIZADO Y ACTUALIZACIÓN DE LA TABLA ---
+
+      function renderOrUpdateStatsTable(data) {
+        const table = document.getElementById("stats-table");
+        // Si la tabla no existe, la crea
+        if (!table) {
+          outputContainer.innerHTML = createStatsTableHTML(data);
+          return;
+        }
+
+        // Si la tabla ya existe, solo actualiza las celdas
+        for (const dbKey in data) {
+          const poolData = data[dbKey];
+          COLUMN_ORDER.forEach((metric) => {
+            const cell = document.getElementById(`${dbKey}_${metric}`);
+            if (cell && cell.textContent != poolData[metric]) {
+              cell.textContent = poolData[metric];
+              cell.classList.add("cell-update");
+              setTimeout(() => cell.classList.remove("cell-update"), 700);
+            }
+          });
+        }
+      }
+
+      function createStatsTableHTML(data) {
+        let tableHtml = `<table id="stats-table"><thead><tr><th title="Nombre de la Base de Datos">DB Key</th>`;
+        COLUMN_ORDER.forEach((key) => {
+          tableHtml += `<th title="${HEADER_TOOLTIPS[key] || ""}">${key}</th>`;
+        });
+        tableHtml += `</tr></thead><tbody>`;
+        for (const dbKey in data) {
+          const poolData = data[dbKey];
+          tableHtml += `<tr><td>${dbKey}</td>`;
+          COLUMN_ORDER.forEach((metric) => {
+            // Se añade un ID único a cada celda: "DB1_TotalConnections"
+            tableHtml += `<td id="${dbKey}_${metric}">${
+              poolData[metric] ?? "N/A"
+            }</td>`;
+          });
+          tableHtml += `</tr>`;
+        }
+        tableHtml += `</tbody></table>`;
+        return tableHtml;
+      }
+
+      // --- MANEJO DE COMANDOS ESTÁTICOS (SIN CAMBIOS) ---
+
+      async function loadStaticContent(command) {
+        contentTitle.textContent = `Resultado del Comando: '${command}'`;
+        outputContainer.innerHTML = "Cargando...";
+        try {
+          const response = await fetch(`/manager?command=${command}`);
+          const responseText = await response.text();
+          if (!response.ok)
+            throw new Error(
+              `Error del servidor (${response.status}): ${responseText}`
+            );
+
+          const contentType = response.headers.get("content-type");
+          if (contentType && contentType.includes("application/json")) {
+            const data = JSON.parse(responseText);
+            if (command === "slowqueries") {
+              outputContainer.innerHTML = data.message
+                ? `<p>${data.message}</p>`
+                : createTableFromJSON(data.data);
+            } else {
+              outputContainer.textContent = JSON.stringify(data, null, 2);
+            }
+          } else {
+            outputContainer.textContent = responseText;
+          }
+        } catch (error) {
+          outputContainer.textContent = `Error al procesar la respuesta:\n${error.message}`;
+        }
+      }
+
+      function createTableFromJSON(data) {
+        if (!data || data.length === 0)
+          return "<p>No se encontraron queries lentas.</p>";
+        const headers = Object.keys(data[0]);
+        let table = "<table><thead><tr>";
+        headers.forEach((h) => (table += `<th>${h.replace(/_/g, " ")}</th>`));
+        table += "</tr></thead><tbody>";
+        data.forEach((row) => {
+          table += "<tr>";
+          headers.forEach((h) => (table += `<td>${row[h]}</td>`));
+          table += "</tr>";
+        });
+        table += "</tbody></table>";
+        return table;
+      }
+
+      // --- EVENT LISTENER PRINCIPAL ---
+
+      document.getElementById("main-nav").addEventListener("click", (event) => {
+        if (event.target.tagName === "A") {
+          const command = event.target.dataset.command;
+          if (!command) return;
+
+          if (command === "reload") {
+            // Pedimos al usuario la DB Key. Si la deja vacía, se asume recarga total.
+            const dbKey = prompt(
+              "Ingrese la llave de la DB a recargar (ej: DB2, DB3). Deje vacío para recargar TODAS:",
+              ""
+            );
+            if (dbKey === null) {
+              // El usuario presionó Cancelar o cerró la ventana. NO HACER NADA.
+              outputContainer.textContent = "Recarga cancelada por el usuario.";
+              contentTitle.textContent = "Administración";
+              return;
+            }
+            let finalCommand = "reload";
+            if (dbKey && dbKey.trim() !== "") {
+              // Si el usuario especificó una DB (ej. DB2), construimos el comando con el parámetro 'db'.
+              const key = dbKey.toUpperCase().trim();
+              finalCommand = `reload&db=${key}`;
+              outputContainer.innerHTML = `<p style="font-family: sans-serif;">Intentando recargar: <b>${key}</b> (Hot-Swap)...</p>`;
+            } else {
+              // Recarga total.
+              outputContainer.innerHTML = `<p style="font-family: sans-serif;">Intentando recargar: <b>TODAS</b> (Hot-Swap)...</p>`;
+            }
+            disconnectSSE();
+            // Llamamos a la función loadStaticContent con el comando completo (ej: 'reload&db=DB2' o 'reload')
+            loadStaticContent(finalCommand);
+          } else if (command === "getstats") {
+            contentTitle.textContent = `Estadísticas del Pool en Tiempo Real`;
+            connectSSE();
+          } else {
+            // Si se selecciona cualquier otro comando, se desconecta del SSE
+            disconnectSSE();
+            loadStaticContent(command);
+          }
+        }
+      });
+    </script>
+  </body>
+</html>

Manager.bas

@@ -2,7 +2,7 @@
 Group=Default Group
 ModulesStructureVersion=1
 Type=Class
-Version=8.8
+Version=10.3
 @EndOfDesignText@
 ' Módulo de clase: Manager
 ' Este handler proporciona un panel de administración web para el servidor jRDC2-Multi.
@@ -24,398 +24,344 @@ End Sub
 ' Método principal que maneja las peticiones HTTP para el panel de administración.
 ' req: El objeto ServletRequest que contiene la información de la petición entrante.
 ' resp: El objeto ServletResponse para construir y enviar la respuesta al cliente.
+' Módulo de clase: Manager
+' ... (tu código de Class_Globals e Initialize se queda igual) ...
+
+' Método principal que maneja las peticiones HTTP para el panel de administración.
+' Refactorizado para funcionar como una API con un frontend estático.
 Sub Handle(req As ServletRequest, resp As ServletResponse)
-	' --- 1. Bloque de Seguridad: Autenticación de Usuario ---
+
-	' Verifica si el usuario actual ha iniciado sesión y está autorizado.
+	' --- 1. Bloque de Seguridad ---
-	' Si no está autorizado, se le redirige a la página de login.
 	If req.GetSession.GetAttribute2("user_is_authorized", False) = False Then
 		resp.SendRedirect("/login")
-		Return ' Termina la ejecución si no está autorizado.
+		Return
 	End If
 
-	' Obtiene el comando solicitado de los parámetros de la URL (ej. "?command=reload").
 	Dim Command As String = req.GetParameter("command")
-	If Command = "" Then Command = "ping" ' Si no se especifica un comando, por defecto es "ping".
 
-	Log($"Command: ${Command}"$)
+	' --- 2. Servidor de la Página Principal ---
-
+	If Command = "" Then
-	' --- MANEJO ESPECIAL PARA SNAPSHOT ---
-	' El comando "snapshot" no devuelve HTML, sino una imagen. Lo manejamos por separado al principio.
-	If Command = "snapshot" Then
-'		Try
-'			resp.ContentType = "image/png"
-'			Dim robot, toolkit As JavaObject
-'			robot.InitializeNewInstance("java.awt.Robot", Null)
-'			toolkit.InitializeStatic("java.awt.Toolkit")
-'			Dim screenRect As JavaObject
-'			screenRect.InitializeNewInstance("java.awt.Rectangle", Array As Object( _
-		'                toolkit.RunMethodJO("getDefaultToolkit", Null).RunMethod("getScreenSize", Null)))
-'			Dim image As JavaObject = robot.RunMethod("createScreenCapture", Array As Object(screenRect))
-'			Dim ImageIO As JavaObject
-'			ImageIO.InitializeStatic("javax.imageio.ImageIO").RunMethod("write", Array As Object(image, "png", resp.OutputStream))
-'		Catch
-'			resp.SendError(500, LastException.Message)
-'		End Try
-'		Return ' Detenemos la ejecución aquí para no enviar más HTML.
-	End If
-	' --- FIN DE MANEJO ESPECIAL ---
-
-	' Para todos los demás comandos, construimos la página HTML de respuesta.
-	resp.ContentType = "text/html" ' Establece el tipo de contenido como HTML.
-	Dim sb As StringBuilder ' Usamos StringBuilder para construir eficientemente el HTML.
-	sb.Initialize
-
-	' --- Estilos y JavaScript (igual que antes) ---
-	sb.Append("<html><head><style>")
-	sb.Append("body {font-family: sans-serif; margin: 2em; background-color: #f9f9f9;} ")
-	sb.Append("h1, h2 {color: #333;} hr {margin: 2em 0; border: 0; border-top: 1px solid #ddd;} ")
-	sb.Append("input {display: block; width: 95%; padding: 8px; margin-bottom: 10px; border: 1px solid #ccc; border-radius: 4px;} ")
-	sb.Append("button {padding: 10px 15px; border: none; background-color: #007bff; color: white; cursor: pointer; border-radius: 4px; margin-right: 1em;} ")
-	sb.Append(".nav a, .logout a {text-decoration: none; margin-right: 10px; color: #007bff;} ")
-	sb.Append(".output {background: #fff; padding: 1em; border: 1px solid #eee; border-radius: 8px; font-family: monospace; white-space: pre-wrap; word-wrap: break-word;} ")
-	sb.Append("#changePassForm {background: #f0f0f0; padding: 1.5em; border-radius: 8px; max-width: 400px; margin-top: 1em;} ")
-	sb.Append("</style>")
-	sb.Append("<script>function toggleForm() {var form = document.getElementById('changePassForm'); if (form.style.display === 'none') {form.style.display = 'block';} else {form.style.display = 'none';}}</script>")
-	sb.Append("</head><body>")
-
-	' --- Cabecera de la Página y Mensaje de Bienvenida ---
-	sb.Append("<h1>Panel de Administración jRDC</h1>")
-	sb.Append($"<p>Bienvenido, <strong>${req.GetSession.GetAttribute("username")}</strong></p>"$)
-	
-	' --- Menú de Navegación del Manager ---
-	' Este menú incluye las opciones para interactuar con el servidor.
-	sb.Append("<div class='menu'>")
-	sb.Append("<a href='/manager?command=test'>Test</a> | ")
-	sb.Append("<a href='/manager?command=ping'>Ping</a> | ")
-	sb.Append("<a href='/manager?command=reload'>Reload</a> | ")
-	sb.Append("<a href='/manager?command=slowqueries'>Queries Lentas</a> | ") ' Nuevo enlace para queries lentas.
-	sb.Append("<a href='/manager?command=totalcon'>Estadísticas Pool</a> | ") ' Nuevo enlace para estadísticas del pool.
-	sb.Append("<a href='/manager?command=rpm2'>Reiniciar (pm2)</a> | ")
-	sb.Append("<a href='/manager?command=reviveBow'>Revive Bow</a>")
-	sb.Append("</div>")
-	sb.Append("<hr>")
-
-	sb.Append("<div id='changePassForm' style='display:none;'>")
-	sb.Append("<h2>Cambiar Contraseña</h2><form action='/changepass' method='post'>")
-	sb.Append("Contraseña Actual: <input type='password' name='current_password' required><br>")
-	sb.Append("Nueva Contraseña: <input type='password' name='new_password' required><br>")
-	sb.Append("Confirmar Nueva Contraseña: <input type='password' name='confirm_password' required><br>")
-	sb.Append("<button type='submit'>Actualizar Contraseña</button> <button onclick='toggleForm()'>Cancelar</button></form></div>")
-
-	' --- Resultado del Comando ---
-	sb.Append("<h2>Resultado del Comando: '" & Command & "'</h2>")
-	sb.Append("<div class='output'>")
-
-	' =========================================================================
-	' ### INICIO DE TU LÓGICA DE COMANDOS INTEGRADA ###
-	' =========================================================================
-	If Command = "reload" Then
-
-		Dim sbTemp As StringBuilder
-		sbTemp.Initialize
-		sbTemp.Append($"Iniciando recarga de configuración (Hot-Swap) ($DateTime{DateTime.Now})"$).Append(" " & CRLF)
-    
-		' <<< PASO CLAVE 1: DETENER TIMER DE LOGS (ZONA SEGURA DE SQLite) >>>
-		' Detenemos el timer incondicionalmente al inicio para evitar conflictos de bloqueo con SQLite
-		' durante la inicialización de conectores.
-		Dim oldTimerState As Boolean = Main.timerLogs.Enabled
-		If oldTimerState Then
-			Main.timerLogs.Enabled = False
-			sbTemp.Append(" -> Timer de limpieza de logs (SQLite) detenido temporalmente.").Append(" " & CRLF)
-		End If
-    
-		' 1. Crear un nuevo mapa temporal para almacenar los conectores recién inicializados.
-		Dim newConnectors As Map
-		newConnectors.Initialize
-    
-		Dim oldConnectors As Map
-		Dim reloadSuccessful As Boolean = True
-    
-		' *** INICIO DEL BLOQUE CRÍTICO 1: Obtener oldConnectors con ReentrantLock ***
-		Dim lock1Acquired As Boolean = False
 		Try
-			Main.MainConnectorsLock.RunMethod("lock", Null)
+			resp.ContentType = "text/html; charset=utf-8"
-			lock1Acquired = True
+			resp.Write(File.ReadString(File.DirApp, "www/manager.html"))
-			oldConnectors = Main.Connectors
 		Catch
-			sbTemp.Append($" -> ERROR CRÍTICO: No se pudo adquirir el bloqueo para leer conectores antiguos: ${LastException.Message}"$).Append(" " & CRLF)
+			resp.SendError(500, "Error: No se pudo encontrar el archivo principal del panel (www/manager.html). " & LastException.Message)
-			reloadSuccessful = False
 		End Try
+		Return
+	End If
 
-		If lock1Acquired Then
+	' --- 3. Manejo de Comandos como API ---
-			Main.MainConnectorsLock.RunMethod("unlock", Null)
+	Select Command.ToLowerCase
-		End If
         
-		If Not(reloadSuccessful) Then
+		' --- Comandos que devuelven JSON (Métricas del Pool) ---
-			' Si el bloqueo inicial falló, restauramos el Timer al estado anterior y salimos.
+		Case "getstatsold"
-			If oldTimerState Then Main.timerLogs.Enabled = True
+			resp.ContentType = "application/json; charset=utf-8"
-			sb.Append(sbTemp.ToString)
+			Dim allPoolStats As Map
-			sb.Append($"¡ERROR: La recarga de configuración falló en la fase de bloqueo inicial! Los conectores antiguos siguen activos."$).Append(" " & CRLF)
+			allPoolStats.Initialize
+			For Each dbKey As String In Main.listaDeCP
+				Dim connector As RDCConnector = Main.Connectors.Get(dbKey)
+				If connector.IsInitialized Then
+					allPoolStats.Put(dbKey, connector.GetPoolStats)
+				Else
+					allPoolStats.Put(dbKey, CreateMap("Error": "Conector no inicializado"))
+				End If
+			Next
+			j.Initialize(allPoolStats)
+			resp.Write(j.ToString)
 			Return
-		End If
             
-		' 2. Iterar sobre las bases de datos configuradas y crear *nuevas* instancias de RDCConnector.
+		Case "getstats"
-		For Each dbKey As String In Main.listaDeCP
+			resp.ContentType = "application/json; charset=utf-8"
+			Dim allPoolStats As Map
+            
+			' Leemos del caché global actualizado por el Timer SSE
+			allPoolStats = Main.LatestPoolStats
+            
+			For Each dbKey As String In Main.listaDeCP
+				If allPoolStats.ContainsKey(dbKey) = False Then
+					allPoolStats.Put(dbKey, CreateMap("Error": "Métricas no disponibles/Pool no inicializado"))
+				End If
+			Next
+            
+			j.Initialize(allPoolStats)
+			resp.Write(j.ToString)
+			Return
+            
+		Case "slowqueries"
+			resp.ContentType = "application/json; charset=utf-8"
+			Dim results As List
+			results.Initialize
             
 			Try
-				Dim newRDC As RDCConnector
+				' Verifica la existencia de la tabla de logs antes de consultar
-				newRDC.Initialize(dbKey) ' Inicializa la nueva instancia con la configuración fresca.
+				Dim tableExists As Boolean = Main.SQL1.ExecQuerySingleResult($"SELECT name FROM sqlite_master WHERE type='table' AND name='query_logs';"$) <> Null
                 
-				' <<< PASO CLAVE 2: LEER Y ALMACENAR EL NUEVO ESTADO DE LOGS PARA CADA DB >>>
+				If tableExists = False Then
-				' Leemos la configuración 'enableSQLiteLogs' de esta DBkey.
+					j.Initialize(CreateMap("message": "La tabla de logs ('query_logs') no existe. Habilita 'enableSQLiteLogs=1' en la configuración."))
-				Dim enableLogsSetting As Int = newRDC.config.GetDefault("enableSQLiteLogs", 0).As(Int)
+					resp.Write(j.ToString)
-				Dim isEnabled As Boolean = (enableLogsSetting = 1)
+					Return
+				End If
                 
-				' Almacenamos el estado temporalmente en el mapa newConnectors bajo una clave única.
+				' Consulta las 20 queries más lentas de la última hora
-				newConnectors.Put(dbKey & "_LOG_STATE", isEnabled)
+				Dim oneHourAgoMs As Long = DateTime.Now - 3600000
-				sbTemp.Append($" -> Logs de ${dbKey} activados: ${isEnabled}"$).Append(" " & CRLF)
+				Dim rs As ResultSet = Main.SQL1.ExecQuery($"SELECT query_name, duration_ms, datetime(timestamp / 1000, 'unixepoch', 'localtime') as timestamp_local, db_key, client_ip, busy_connections, handler_active_requests FROM query_logs WHERE timestamp >= ${oneHourAgoMs} ORDER BY duration_ms DESC LIMIT 20"$)
-				' <<< FIN PASO CLAVE 2 >>>
                 
-				newConnectors.Put(dbKey, newRDC)
+				Do While rs.NextRow
+					Dim row As Map
+					row.Initialize
+					row.Put("Query", rs.GetString("query_name"))
+					row.Put("Duracion_ms", rs.GetLong("duration_ms"))
+					row.Put("Fecha_Hora", rs.GetString("timestamp_local"))
+					row.Put("DB_Key", rs.GetString("db_key"))
+					row.Put("Cliente_IP", rs.GetString("client_ip"))
+					row.Put("Conexiones_Ocupadas", rs.GetInt("busy_connections"))
+					row.Put("Peticiones_Activas", rs.GetInt("handler_active_requests"))
+					results.Add(row)
+				Loop
+				rs.Close
                 
-				Dim newPoolStats As Map = newRDC.GetPoolStats
+				Dim root As Map
-				sbTemp.Append($" -> ${dbKey}: Nuevo conector inicializado. Conexiones: ${newPoolStats.Get("TotalConnections")}"$).Append(" " & CRLF)
+				root.Initialize
+				root.Put("data", results)
+				j.Initialize(root)
+				resp.Write(j.ToString)
                 
-				Catch
-				sbTemp.Append($" -> ERROR CRÍTICO al inicializar nuevo conector para ${dbKey}: ${LastException.Message}"$).Append(" " & CRLF)
-				reloadSuccessful = False
-				Exit ' Si uno falla, abortamos la recarga.
-			End Try
-
-		Next
-
-		sb.Append(sbTemp.ToString)
-
-		If reloadSuccessful Then
-        
-			' 3. Si todo fue exitoso, hacemos el Hot-Swap atómico.
-			' *** INICIO DEL BLOQUE CRÍTICO 2: Reemplazar Main.Connectors con ReentrantLock ***
-        
-			Dim lock2Acquired As Boolean = False
-			Try
-				Main.MainConnectorsLock.RunMethod("lock", Null)
-				lock2Acquired = True
-				Main.Connectors = newConnectors ' Reemplazamos el mapa de conectores completo por el nuevo.
 			Catch
-				sb.Append($" -> ERROR CRÍTICO: No se pudo adquirir el bloqueo para reemplazar conectores: ${LastException.Message}"$).Append(" " & CRLF)
+				Log("Error CRÍTICO al obtener queries lentas en Manager API: " & LastException.Message)
-				reloadSuccessful = False
+				resp.Status = 500
-			End Try
                 
-			If lock2Acquired Then
+				Dim root As Map
-				Main.MainConnectorsLock.RunMethod("unlock", Null)
+				root.Initialize
+				root.Put("data", results)
+				j.Initialize(root)
+				resp.Write(j.ToString)
+			End Try
+			Return
+            
+		Case "logs", "totalrequests", "totalblocked"
+			resp.ContentType = "application/json; charset=utf-8"
+			Dim mp As Map
+			If Command = "logs" And GlobalParameters.mpLogs.IsInitialized Then mp = GlobalParameters.mpLogs
+			If Command = "totalrequests" And GlobalParameters.mpTotalRequests.IsInitialized Then mp = GlobalParameters.mpTotalRequests
+			If Command = "totalblocked" And GlobalParameters.mpBlockConnection.IsInitialized Then mp = GlobalParameters.mpBlockConnection
+            
+			If mp.IsInitialized Then
+				j.Initialize(mp)
+				resp.Write(j.ToString)
+			Else
+				resp.Write("{}")
+			End If
+			Return
+            
+			' --- Comandos que devuelven TEXTO PLANO ---
+		Case "ping"
+			resp.ContentType = "text/plain"
+			resp.Write($"Pong ($DateTime{DateTime.Now})"$)
+			Return
+            
+		Case "reload"
+			resp.ContentType = "text/plain; charset=utf-8"
+			Dim sbTemp As StringBuilder
+			sbTemp.Initialize
+            
+			' ***** LÓGICA DE RECARGA GRANULAR/SELECTIVA *****
+			Dim dbKeyToReload As String = req.GetParameter("db").ToUpperCase ' Leer parámetro 'db' opcional (ej: /manager?command=reload&db=DB3)
+			Dim targets As List ' Lista de DBKeys a recargar.
+			targets.Initialize
+            
+			' 1. Determinar el alcance de la recarga (selectiva o total)
+			If dbKeyToReload.Length > 0 Then
+				' Recarga selectiva
+				If Main.listaDeCP.IndexOf(dbKeyToReload) = -1 Then
+					resp.Write($"ERROR: DBKey '${dbKeyToReload}' no es válida o no está configurada."$)
+					Return
+				End If
+				targets.Add(dbKeyToReload)
+				sbTemp.Append($"Iniciando recarga selectiva de ${dbKeyToReload} (Hot-Swap)..."$).Append(" " & CRLF)
+			Else
+				' Recarga completa (comportamiento por defecto)
+				targets.AddAll(Main.listaDeCP)
+				sbTemp.Append($"Iniciando recarga COMPLETA de configuración (Hot-Swap) ($DateTime{DateTime.Now})"$).Append(" " & CRLF)
 			End If
             
-			If reloadSuccessful Then ' Si el swap fue exitoso
+			' 2. Deshabilitar el Timer de logs (si es necesario)
+			Dim oldTimerState As Boolean = Main.timerLogs.Enabled
+			If oldTimerState Then
+				Main.timerLogs.Enabled = False
+				sbTemp.Append(" -> Timer de limpieza de logs (SQLite) detenido temporalmente.").Append(" " & CRLF)
+			End If
             
-				' <<< PASO CLAVE 3: APLICAR EL NUEVO ESTADO GLOBAL GRANULAR Y REINICIAR TIMER >>>
+			Dim reloadSuccessful As Boolean = True
+			Dim oldConnectorsToClose As Map ' Guardaremos los conectores antiguos aquí.
+			oldConnectorsToClose.Initialize
             
-				' 3a. Reemplazar el mapa de estados de logging granular
+			' 3. Procesar solo los conectores objetivos
-				Main.SQLiteLoggingStatusByDB.Clear ' Limpiamos el mapa global
+			For Each dbKey As String In targets
+				sbTemp.Append($" -> Procesando recarga de ${dbKey}..."$).Append(CRLF)
+				Dim newRDC As RDCConnector
                 
-				Dim isAnyEnabled As Boolean = False
+				Try
-				For Each dbKey As String In Main.listaDeCP
+					' Crear el nuevo conector con la configuración fresca
-					' Recuperamos el estado logueado temporalmente.
+					newRDC.Initialize(dbKey)
-					Dim isEnabled As Boolean = newConnectors.Get(dbKey & "_LOG_STATE").As(Boolean)
-					Main.SQLiteLoggingStatusByDB.Put(dbKey, isEnabled) ' Aplicamos el estado al mapa global
                     
-					If isEnabled Then isAnyEnabled = True ' Calculamos el flag general
+					' Adquirimos el lock para el reemplazo atómico
+					Main.MainConnectorsLock.RunMethod("lock", Null)
+                    
+					' Guardamos el conector antiguo (si existe)
+					Dim oldRDC As RDCConnector = Main.Connectors.Get(dbKey)
+                    
+					' Reemplazo atómico en el mapa global compartido
+					Main.Connectors.Put(dbKey, newRDC)
+                    
+					' Liberamos el bloqueo inmediatamente
+					Main.MainConnectorsLock.RunMethod("unlock", Null)
+                    
+					' Si había un conector antiguo, lo guardamos para cerrarlo después
+					If oldRDC.IsInitialized Then
+						oldConnectorsToClose.Put(dbKey, oldRDC)
+					End If
+
+					' 4. Actualizar el estado de logs (Granular)
+					Dim enableLogsSetting As Int = newRDC.config.GetDefault("enableSQLiteLogs", 0)
+					Dim isEnabled As Boolean = (enableLogsSetting = 1)
+					Main.SQLiteLoggingStatusByDB.Put(dbKey, isEnabled)
+					sbTemp.Append($" -> ${dbKey} recargado. Logs (config): ${isEnabled}"$).Append(CRLF)
+                    
+				Catch
+					' Si falla la inicialización del pool, no actualizamos Main.Connectors
+                    
+					' ¡CRÍTICO! Aseguramos que el lock se libere si hubo excepción antes de liberar.
+					If Main.MainConnectorsLock.RunMethod("isHeldByCurrentThread", Null).As(Boolean) Then
+						Main.MainConnectorsLock.RunMethod("unlock", Null)
+					End If
+                    
+					sbTemp.Append($" -> ERROR CRÍTICO al inicializar conector para ${dbKey}: ${LastException.Message}"$).Append(" " & CRLF)
+					reloadSuccessful = False
+					Exit
+				End Try
+			Next
+            
+			' 5. Cerrar los pools antiguos liberados (FUERA del Lock)
+			If reloadSuccessful Then
+				For Each dbKey As String In oldConnectorsToClose.Keys
+					Dim oldRDC As RDCConnector = oldConnectorsToClose.Get(dbKey)
+					oldRDC.Close ' Cierre limpio del pool C3P0
+					sbTemp.Append($" -> Pool antiguo de ${dbKey} cerrado limpiamente."$).Append(" " & CRLF)
 				Next
                 
-				' 3b. Controlar el Timer y el flag global
+				' 6. Re-evaluar el estado global de Logs (CRÍTICO: debe revisar TODAS las DBs)
-				Main.IsAnySQLiteLoggingEnabled = isAnyEnabled ' Actualizamos el flag global
+				Main.IsAnySQLiteLoggingEnabled = False
+                
+				For Each dbKey As String In Main.listaDeCP
+					' Revisamos el estado de log de CADA conector activo
+					If Main.SQLiteLoggingStatusByDB.GetDefault(dbKey, False) Then
+						Main.IsAnySQLiteLoggingEnabled = True
+						Exit
+					End If
+				Next
                 
 				If Main.IsAnySQLiteLoggingEnabled Then
 					Main.timerLogs.Enabled = True
-					sb.Append($" -> Logs de SQLite HABILITADOS (Granular). Timer de limpieza ACTIVADO."$).Append(" " & CRLF)
+					sbTemp.Append($" -> Timer de limpieza de logs ACTIVADO (estado global: HABILITADO)."$).Append(" " & CRLF)
-					Else
-					Main.timerLogs.Enabled = False
-					sb.Append($" -> Logs de SQLite DESHABILITADOS (Total). Timer de limpieza PERMANECERÁ DETENIDO."$).Append(" " & CRLF)
-				End If
-				' <<< FIN PASO CLAVE 3 >>>
-            
-				sb.Append($"¡Recarga de configuración completada con éxito (Hot-Swap)!"$).Append(" " & CRLF)
-            
-				' ... (Resto del código: Mostrar estado de pools y Cierre explícito de oldConnectors) ...
-
 				Else
-				sb.Append($"¡ERROR: La recarga de configuración falló en la fase de reemplazo de conectores! Los conectores antiguos siguen activos."$).Append(" " & CRLF)
+					Main.timerLogs.Enabled = False
-			End If
+					sbTemp.Append($" -> Timer de limpieza de logs DESHABILITADO (estado global: DESHABILITADO)."$).Append(" " & CRLF)
-
-		Else ' Falla en inicialización (Punto 2)
-        
-			' Si falla la recarga, restauramos el Timer al estado anterior.
-			If oldTimerState Then
-				Main.timerLogs.Enabled = True
-				sb.Append(" -> Restaurando Timer de limpieza de logs (SQLite) al estado ACTIVO debido a fallo en recarga.").Append(" " & CRLF)
-			End If
-        
-			sb.Append($"¡ERROR: La recarga de configuración falló durante la inicialización de nuevos conectores! Los conectores antiguos siguen activos."$).Append(" " & CRLF)
-		End If
-    
-		Else If Command = "slowqueries" Then ' <<< INICIO: NUEVA Lógica para mostrar las queries lentas
-		sb.Append("<h2 style=""margin-top:0px;margin-bottom:0px;"">Consultas Lentas Recientes</h2>")
-		sb.Append("(Este registro depende de que los logs estén habilitados con del parámetro ""enableSQLiteLogs=1"" en config properties)<br><br>")
-		Try
-			' 1. Calcular el límite de tiempo: el tiempo actual (en milisegundos) menos 1 hora (3,600,000 ms).
-			Dim oneHourAgoMs As Long = DateTime.Now - 3600000
-			
-			' Ajusta la consulta SQL para obtener las 20 queries más lentas.
-			' Utilizamos datetime con 'unixepoch' y 'localtime' para una visualización legible del timestamp.
-			Dim rs As ResultSet = Main.SQL1.ExecQuery($"SELECT query_name, duration_ms, datetime(timestamp / 1000, 'unixepoch', 'localtime') as timestamp_local, db_key, client_ip, busy_connections, handler_active_requests FROM query_logs WHERE timestamp >= ${oneHourAgoMs} ORDER BY duration_ms DESC LIMIT 20"$)
-        
-			sb.Append("<table border='1' style='width:100%; text-align:left; border-collapse: collapse;'>")
-			sb.Append("<thead><tr><th>Query</th><th>Duración (ms)</th><th>Fecha/Hora Local</th><th>DB Key</th><th>Cliente IP</th><th>Conex. Ocupadas</th><th>Peticiones Activas</th></tr></thead>")
-			sb.Append("<tbody>")
-        
-			Do While rs.NextRow
-				sb.Append("<tr>")
-				sb.Append($"<td>${rs.GetString("query_name")}</td>"$)
-				sb.Append($"<td>${rs.GetLong("duration_ms")}</td>"$)
-				sb.Append($"<td>${rs.GetString("timestamp_local")}</td>"$)
-				sb.Append($"<td>${rs.GetString("db_key")}</td>"$)
-				sb.Append($"<td>${rs.GetString("client_ip")}</td>"$)
-				sb.Append($"<td>${rs.GetInt("busy_connections")}</td>"$)
-				sb.Append($"<td>${rs.GetInt("handler_active_requests")}</td>"$)
-				sb.Append("</tr>")
-			Loop
-			sb.Append("</tbody>")
-			sb.Append("</table>")
-			rs.Close
-		Catch
-			Log("Error al obtener queries lentas en Manager: " & LastException.Message)
-			sb.Append($"<p style='color:red;'>Error al cargar queries lentas: ${LastException.Message}</p>"$)
-		End Try
-	Else If Command = "test" Then
-		Try
-			Dim con As SQL = Main.Connectors.Get("DB1").As(RDCConnector).GetConnection("")
-			sb.Append("Connection successful.</br></br>")
-			Private estaDB As String = ""
-			Log(Main.listaDeCP)
-			For i = 0 To Main.listaDeCP.Size - 1
-				If Main.listaDeCP.get(i) <> "" Then estaDB = "." & Main.listaDeCP.get(i)
-				sb.Append($"Using config${estaDB}.properties<br/>"$)
-			Next
-			con.Close
-		Catch
-			resp.Write("Error fetching connection.")
-		End Try
-	Else If Command = "stop" Then
-		' Public shl As Shell...
-	Else If Command = "rsx" Then
-		Log($"Ejecutamos ${File.DirApp}\start.bat"$)
-		sb.Append($"Ejecutamos ${File.DirApp}\start.bat"$)
-		Public shl As Shell
-		shl.Initialize("shl","cmd",Array("/c",File.DirApp & "\start.bat " & Main.srvr.Port))
-		shl.WorkingDirectory = File.DirApp
-		shl.Run(-1)
-	Else If Command = "rpm2" Then
-		Log($"Ejecutamos ${File.DirApp}\reiniciaProcesoPM2.bat"$)
-		sb.Append($"Ejecutamos ${File.DirApp}\reiniciaProcesoPM2.bat"$)
-		Public shl As Shell
-		shl.Initialize("shl","cmd",Array("/c",File.DirApp & "\reiniciaProcesoPM2.bat " & Main.srvr.Port))
-		shl.WorkingDirectory = File.DirApp
-		shl.Run(-1)
-	Else If Command = "reviveBow" Then
-		Log($"Ejecutamos ${File.DirApp}\reiniciaProcesoBow.bat"$)
-		sb.Append($"Ejecutamos ${File.DirApp}\reiniciaProcesoBow.bat<br><br>"$)
-		sb.Append($"!!!BOW REINICIANDO!!!"$)
-		Public shl As Shell
-		shl.Initialize("shl","cmd",Array("/c",File.DirApp & "\reiniciaProcesoBow.bat " & Main.srvr.Port))
-		shl.WorkingDirectory = File.DirApp
-		shl.Run(-1)
-	Else If Command = "paused" Then
-		GlobalParameters.IsPaused = 1
-		sb.Append("Servidor pausado.")
-	Else If Command = "continue" Then
-		GlobalParameters.IsPaused = 0
-		sb.Append("Servidor reanudado.")
-	Else If Command = "logs" Then
-		If GlobalParameters.mpLogs.IsInitialized Then
-			j.Initialize(GlobalParameters.mpLogs)
-			sb.Append(j.ToString)
-		End If
-	Else If Command = "block" Then
-		Dim BlockedConIP As String = req.GetParameter("IP")
-		If GlobalParameters.mpBlockConnection.IsInitialized Then
-			GlobalParameters.mpBlockConnection.Put(BlockedConIP, BlockedConIP)
-			sb.Append("IP bloqueada: " & BlockedConIP)
-		End If
-	Else If Command = "unblock" Then
-		Dim UnBlockedConIP As String = req.GetParameter("IP")
-		If GlobalParameters.mpBlockConnection.IsInitialized Then
-			GlobalParameters.mpBlockConnection.Remove(UnBlockedConIP)
-			sb.Append("IP desbloqueada: " & UnBlockedConIP)
-		End If
-	Else If Command = "restartserver" Then
-		Log($"Ejecutamos ${File.DirApp}/restarServer.bat"$)
-		sb.Append("Reiniciando servidor...")
-	Else If Command = "runatstartup" Then
-		File.Copy("C:\jrdcinterface", "startup.bat", "C:\ProgramData\Microsoft\Windows\Start Menu\Programs\StartUp", "startup.bat")
-		sb.Append("Script de inicio añadido.")
-	Else If Command = "stoprunatstartup" Then
-		File.Delete("C:\ProgramData\Microsoft\Windows\Start Menu\Programs\StartUp", "startup.bat")
-		sb.Append("Script de inicio eliminado.")
-	Else If Command = "totalrequests" Then
-		If GlobalParameters.mpTotalRequests.IsInitialized Then
-			j.Initialize(GlobalParameters.mpTotalRequests)
-			sb.Append(j.ToString)
-		End If
-	Else If Command = "totalblocked" Then
-		If GlobalParameters.mpBlockConnection.IsInitialized Then
-'			j.Initialize(Global.mpBlockConnection)
-			sb.Append(j.ToString)
-		End If
-	Else If Command = "ping" Then
-		sb.Append($"Pong ($DateTime{DateTime.Now})"$)
-	Else If Command = "totalcon" Then ' <<< Modificado: Ahora usa GetPoolStats para cada pool
-		' Verificamos que el mapa global de conexiones esté inicializado.
-		' Aunque no lo poblamos directamente, es un buen chequeo de estado.
-		If GlobalParameters.mpTotalConnections.IsInitialized Then
-			sb.Append("<h2>Estadísticas del Pool de Conexiones por DB:</h2>")
-        
-			' Creamos un mapa LOCAL para almacenar las estadísticas de TODOS los pools de conexiones.
-			Dim allPoolStats As Map
-			allPoolStats.Initialize
-        
-			' Iteramos sobre cada clave de base de datos que tenemos configurada (DB1, DB2, etc.).
-			For Each dbKey As String In Main.listaDeCP
-				' Obtenemos el conector RDC para la base de datos actual.
-				Dim connector As RDCConnector = Main.Connectors.Get(dbKey).As(RDCConnector)
-            
-				' Si el conector no está inicializado (lo cual no debería ocurrir si Main.AppStart funcionó),
-				' registramos un error y pasamos al siguiente.
-				If connector.IsInitialized = False Then
-					Log($"Manager: ADVERTENCIA: El conector para ${dbKey} no está inicializado."$)
-					Dim errorMap As Map = CreateMap("Error": "Conector no inicializado o no cargado correctamente")
-					allPoolStats.Put(dbKey, errorMap)
-					Continue ' Salta a la siguiente iteración del bucle.
 				End If
                 
-				' Llamamos al método GetPoolStats del conector para obtener las métricas de su pool.
+				sbTemp.Append($"¡Recarga de configuración completada con éxito!"$).Append(" " & CRLF)
-				Dim poolStats As Map = connector.GetPoolStats
                 
-				' Añadimos las estadísticas de este pool (poolStats) al mapa general (allPoolStats),
+			Else
-				' usando la clave de la base de datos (dbKey) como su identificador.
-				allPoolStats.Put(dbKey, poolStats)
-			Next
                 
-			' Inicializamos el generador JSON con el mapa 'allPoolStats' (que ahora sí debería contener datos).
+				' Si falló, restauramos el estado del timer anterior.
-			' (La variable 'j' ya está declarada en Class_Globals de Manager.bas, no la declares de nuevo aquí).
+				If oldTimerState Then
-			j.Initialize(allPoolStats)
+					Main.timerLogs.Enabled = True
+					sbTemp.Append(" -> Restaurando Timer de limpieza de logs al estado ACTIVO debido a fallo en recarga.").Append(" " & CRLF)
+				End If
+				sbTemp.Append($"¡ERROR: La recarga de configuración falló! Los conectores antiguos siguen activos."$).Append(" " & CRLF)
+			End If
             
-			' Añadimos la representación JSON de las estadísticas al StringBuilder para la respuesta HTML.
+			resp.Write(sbTemp.ToString)
-			sb.Append(j.ToString)
+			Return
-		Else
-			sb.Append("El mapa de conexiones GlobalParameters.mpTotalConnections no está inicializado.")
-		End If
-	End If
-	' =========================================================================
-	' ### FIN DE TU LÓGICA DE COMANDOS ###
-	' =========================================================================
             
-	' --- Cerramos la página y la enviamos ---
+		Case "test"
-	sb.Append("</div><p class='logout'><a href='/logout'>Cerrar Sesión</a> | <a href=# onclick='toggleForm()'>Cambiar Contraseña</a></p></body></html>")
+			resp.ContentType = "text/plain; charset=utf-8"
-	resp.Write(sb.ToString)
+			Dim sb As StringBuilder
+			sb.Initialize
             
-	If GlobalParameters.mpLogs.IsInitialized Then GlobalParameters.mpLogs.Put(Command, "Manager : " & Command & "  - Time : " & DateTime.Time(DateTime.Now))
+			Try
+				Dim con As SQL = Main.Connectors.Get("DB1").As(RDCConnector).GetConnection("")
+				sb.Append("Connection successful." & CRLF & CRLF)
+				Dim estaDB As String = ""
+				Log(Main.listaDeCP)
+				For i = 0 To Main.listaDeCP.Size - 1
+					If Main.listaDeCP.get(i) <> "" Then estaDB = "." & Main.listaDeCP.get(i)
+					sb.Append($"Using config${estaDB}.properties"$ & CRLF)
+				Next
+				con.Close
+				resp.Write(sb.ToString)
+			Catch
+				resp.Write("Error fetching connection: " & LastException.Message)
+			End Try
+			Return
+            
+		Case "rsx", "rpm2", "revivebow", "restartserver"
+			resp.ContentType = "text/plain; charset=utf-8"
+			Dim batFile As String
+			Select Command
+				Case "rsx": batFile = "start.bat"
+				Case "rpm2": batFile = "reiniciaProcesoPM2.bat"
+				Case "reviveBow": batFile = "reiniciaProcesoBow.bat"
+				Case "restartserver": batFile = "restarServer.bat" ' Nota: este bat no estaba definido, se usó el nombre del comando
+			End Select
+			
+			Log($"Ejecutando ${File.DirApp}\${batFile}"$)
+			Try
+				Dim shl As Shell
+				shl.Initialize("shl","cmd", Array("/c", File.DirApp & "\" & batFile & " " & Main.srvr.Port))
+				shl.WorkingDirectory = File.DirApp
+				shl.Run(-1)
+				resp.Write($"Comando '${Command}' ejecutado. Script invocado: ${batFile}"$)
+			Catch
+				resp.Write($"Error al ejecutar el script para '${Command}': ${LastException.Message}"$)
+			End Try
+			Return
+			
+		Case "paused", "continue"
+			resp.ContentType = "text/plain; charset=utf-8"
+			If Command = "paused" Then
+				GlobalParameters.IsPaused = 1
+				resp.Write("Servidor pausado.")
+			Else
+				GlobalParameters.IsPaused = 0
+				resp.Write("Servidor reanudado.")
+			End If
+			Return
+			
+		Case "block", "unblock"
+			resp.ContentType = "text/plain; charset=utf-8"
+			Dim ip As String = req.GetParameter("IP")
+			
+			If ip = "" Then
+				resp.Write("Error: El parámetro IP es requerido.")
+				Return
+			End If
+            
+			If GlobalParameters.mpBlockConnection.IsInitialized Then
+				If Command = "block" Then
+					GlobalParameters.mpBlockConnection.Put(ip, ip)
+					resp.Write($"IP bloqueada: ${ip}"$)
+				Else
+					GlobalParameters.mpBlockConnection.Remove(ip)
+					resp.Write($"IP desbloqueada: ${ip}"$)
+				End If
+			Else
+				resp.Write("Error: El mapa de bloqueo no está inicializado.")
+			End If
+			Return
+            
+		Case Else
+			resp.ContentType = "text/plain; charset=utf-8"
+			resp.SendError(404, $"Comando desconocido: '{Command}'"$)
+			Return
+	End Select
 End Sub

ParameterValidationUtils.bas

@@ -50,6 +50,7 @@ Public Sub ValidateAndAdjustParameters (CommandName As String, DBKey As String,
 			res.Success = True
 			Dim WarningMsg As String = $"ADVERTENCIA: Se recibieron más parámetros de los esperados para "${CommandName}" (DB: ${DBKey}). Se esperaban ${expectedParams} y se recibieron ${receivedParamsSize}. Se ajustó la lista de parámetros a ${expectedParams} elementos."$
 			Log(WarningMsg)
+			Log("Cache: " & Main.LOG_CACHE_THRESHOLD & "|" & Main.ErrorLogCache.Size)
 			Main.LogServerError("ADVERTENCIA", "ParameterValidationUtils.ValidateAndAdjustParameters", WarningMsg, DBKey, CommandName, Null) ' <-- Nuevo Log [6]
 		Else
 			' Si la tolerancia NO está habilitada, esto es un error crítico.

RDCConnector.bas

@@ -78,15 +78,18 @@ Public Sub Initialize(DB As String)
 		Dim minPoolSize As Int = config.GetDefault("MinPoolSize", 2)
 		Dim maxPoolSize As Int = config.GetDefault("MaxPoolSize", 5)
 		Dim acquireIncrement As Int = config.GetDefault("AcquireIncrement", 5)
+		Dim maxIdleTime As Int = config.GetDefault("MaxIdleTime", 300)
+		Dim maxConnectionAge As Int = config.GetDefault("MaxConnectionAge", 900)
+		Dim checkoutTimeout As Int = config.GetDefault("CheckoutTimeout", 60000)
 
 		' Configuración de los parámetros del pool de conexiones C3P0:
-		jo.RunMethod("setInitialPoolSize", Array(initialPoolSize))         ' Define el número de conexiones que se intentarán crear al iniciar el pool.
+		jo.RunMethod("setInitialPoolSize", Array(initialPoolSize))			' Define el número de conexiones que se intentarán crear al iniciar el pool.
-		jo.RunMethod("setMinPoolSize", Array(minPoolSize))                 ' Fija el número mínimo de conexiones que el pool mantendrá abiertas.
+		jo.RunMethod("setMinPoolSize", Array(minPoolSize))					' Fija el número mínimo de conexiones que el pool mantendrá abiertas.
-		jo.RunMethod("setMaxPoolSize", Array(maxPoolSize))                 ' Define el número máximo de conexiones simultáneas.
+		jo.RunMethod("setMaxPoolSize", Array(maxPoolSize))					' Define el número máximo de conexiones simultáneas.
-		jo.RunMethod("setAcquireIncrement", Array(acquireIncrement))       ' Cuántas conexiones nuevas se añaden en lote si el pool se queda sin disponibles.
+		jo.RunMethod("setAcquireIncrement", Array(acquireIncrement))		' Cuántas conexiones nuevas se añaden en lote si el pool se queda sin disponibles.
-		jo.RunMethod("setMaxIdleTime", Array As Object(config.GetDefault("MaxIdleTime", 300)))           ' Tiempo máximo de inactividad de una conexión antes de cerrarse (segundos).
+		jo.RunMethod("setMaxIdleTime", Array As Object(maxIdleTime))		'  Es el tiempo máximo (en segundos) que una conexión puede permanecer inactiva en el pool antes de ser cerrada para ahorrar recursos.
-		jo.RunMethod("setMaxConnectionAge", Array As Object(config.GetDefault("MaxConnectionAge", 900))) ' Tiempo máximo de vida de una conexión (segundos).
+		jo.RunMethod("setMaxConnectionAge", Array As Object(maxConnectionAge)) ' Tiempo máximo de vida de una conexión (segundos), previene conexiones viciadas.
-		jo.RunMethod("setCheckoutTimeout", Array As Object(config.GetDefault("CheckoutTimeout", 60000))) ' Tiempo máximo de espera por una conexión del pool (milisegundos).
+		jo.RunMethod("setCheckoutTimeout", Array As Object(checkoutTimeout)) ' Tiempo máximo de espera por una conexión del pool (milisegundos).
 
 		' LÍNEAS CRÍTICAS PARA FORZAR UN COMPORTAMIENTO NO SILENCIOSO DE C3P0:
 		' Por defecto, C3P0 puede reintentar muchas veces y no lanzar una excepción si las conexiones iniciales fallan.
@@ -103,6 +106,16 @@ Public Sub Initialize(DB As String)
 			tempCon.Close ' Devolvemos la conexión inmediatamente al pool para que esté disponible.
 		End If
 		
+		' Cargar configuración estática en el cache global
+		Dim dbKeyToStore As String = DB
+		If dbKeyToStore = "" Then dbKeyToStore = "DB1" ' Aseguramos la llave si era DB1
+		Dim initialPoolStats As Map = GetPoolStats ' Llama a la función que usa JavaObject
+    
+		' PASO C: Almacenamos el mapa completo (estático + dinámico inicial) en el cache global.
+		Main.LatestPoolStats.Put(dbKeyToStore, initialPoolStats)
+		
+		Log(Main.LatestPoolStats)
+		
 '		com.mchange.v2.c3p0.ComboPooledDataSource [
 '		acquireIncrement -> 3,
 '		acquireRetryAttempts -> 30,

SSE.bas

@@ -0,0 +1,187 @@
+B4J=true
+Group=Default Group
+ModulesStructureVersion=1
+Type=StaticCode
+Version=10.3
+@EndOfDesignText@
+' Módulo para gestionar conexiones y transmisiones de Server-Sent Events (SSE).
+
+' Declaración de variables globales a nivel de proceso.
+Sub Process_Globals
+	' 'Connections' es un mapa (diccionario) para almacenar las conexiones SSE activas.
+	' La clave será una combinación del 'path' y un GUID único, y el valor será el OutputStream de la respuesta.
+	' Se usará un 'ThreadSafeMap' para evitar problemas de concurrencia entre hilos.
+	Dim Connections As Map
+	
+	
+	' Timer #1 ("El Vigilante"): Se encarga de detectar y eliminar conexiones muertas.
+	Private RemoveTimer As Timer
+	
+	' Timer #2 ("El Informante"): Se encarga de recolectar y enviar los datos de estadísticas.
+	Dim StatsTimer As Timer
+	Dim const UPDATE_INTERVAL_MS As Long = 2000 ' Intervalo de envío de estadísticas: 2 segundos.
+End Sub
+
+' Subrutina de inicialización del módulo. Se llama una vez cuando el objeto es creado.
+public Sub Initialize()
+	' Crea el mapa 'Connections' como un mapa seguro para hilos (ThreadSafeMap).
+	' Esto es fundamental porque múltiples peticiones (hilos) pueden intentar agregar o remover conexiones simultáneamente.
+	Connections = Main.srvr.CreateThreadSafeMap
+	
+	' Inicializa el temporizador 'RemoveTimer' para que dispare el evento "RemoveTimer" cada 5000 milisegundos (5 segundos).
+	RemoveTimer.Initialize("RemoveTimer", 5000)
+	
+	' Habilita el temporizador para que comience a funcionar.
+	RemoveTimer.Enabled = True
+	
+	
+	Log("Stats SSE Handler Initialized (Singleton Mode)")
+
+	' Crea el mapa de conexiones, asegurando que sea seguro para el manejo de múltiples hilos.
+	Connections = Main.srvr.CreateThreadSafeMap
+
+	' Configura y activa el timer para la limpieza de conexiones cada 5 segundos.
+	' NOTA: El EventName "RemoveTimer" debe coincidir con el nombre de la subrutina del tick.
+	RemoveTimer.Initialize("RemoveTimer", 5000)
+	RemoveTimer.Enabled = True
+
+	' Configura y activa el timer para el envío de estadísticas.
+	' NOTA: El EventName "StatsTimer" debe coincidir con el nombre de la subrutina del tick.
+	StatsTimer.Initialize("StatsTimer", UPDATE_INTERVAL_MS)
+	StatsTimer.Enabled = True
+End Sub
+
+' Subrutina para agregar un nuevo cliente (target) al stream de eventos SSE.
+' Se llama cuando un cliente se conecta al endpoint SSE.
+' Registra formalmente a un nuevo cliente en el sistema.
+Sub AddTarget(path As String, resp As ServletResponse)
+	' Genera una clave única para esta conexión específica.
+	Dim connectionKey As String = path & "|" & GetGUID
+	Log("--- [SSE] Cliente conectado: " & connectionKey & " ---")
+
+	' Configura las cabeceras HTTP necesarias para que el navegador mantenga la conexión abierta.
+	resp.ContentType = "text/event-stream"
+	resp.SetHeader("Cache-Control", "no-cache")
+	resp.SetHeader("Connection", "keep-alive")
+	resp.CharacterEncoding = "UTF-8"
+	resp.Status = 200
+
+	' Añade al cliente y su canal de comunicación al mapa central.
+	Connections.Put(connectionKey, resp.OutputStream)
+	' Envía un primer mensaje de bienvenida para confirmar la conexión.
+	SendMessage(resp.OutputStream, "open", "Connection established", 0, connectionKey)
+End Sub
+
+' Envía un mensaje a todos los clientes suscritos a un "path" específico.
+Sub Broadcast(Path As String, EventName As String, Message As String, Retry As Long)
+	' Itera sobre la lista de clientes activos.
+	For Each key As String In Connections.Keys
+'		Log(key)
+		' Filtra para enviar solo a los clientes del path correcto (en este caso, "stats").
+		If key.StartsWith(Path & "|") Then
+			Try
+				' Llama a la función de bajo nivel para enviar el mensaje formateado.
+				SendMessage(Connections.Get(key), EventName, Message, Retry, DateTime.Now)
+			Catch
+				' Si el envío falla, asume que el cliente se desconectó y lo elimina.
+				Log("######################")
+				Log("##   Removing (broadcast failed): " & key)
+				Log("######################")
+				Connections.Remove(key)
+			End Try
+		End If
+	Next
+End Sub
+
+' Formatea y envía un único mensaje SSE a un cliente específico.
+Sub SendMessage(out As OutputStream, eventName As String, message As String, retry As Int, id As String)
+	' Construye el mensaje siguiendo el formato oficial del protocolo SSE.
+	Dim sb As StringBuilder
+	sb.Initialize
+	sb.Append("id: " & id).Append(CRLF)
+	sb.Append("event: " & eventName).Append(CRLF)
+	If message <> "" Then
+		sb.Append("data: " & message).Append(CRLF)
+	End If
+	If retry > 0 Then
+		sb.Append("retry: " & retry).Append(CRLF)
+	End If
+	sb.Append(CRLF) ' El doble salto de línea final es obligatorio.
+	
+	' Convierte el texto a bytes y lo escribe en el canal de comunicación del cliente.
+	Dim Bytes() As Byte = sb.ToString.GetBytes("UTF-8")
+	out.WriteBytes(Bytes, 0, Bytes.Length)
+	out.Flush ' Fuerza el envío inmediato de los datos.
+End Sub
+
+' Genera un Identificador Único Global (GUID) para cada conexión.
+Private Sub GetGUID() As String
+	Dim jo As JavaObject
+	Return jo.InitializeStatic("java.util.UUID").RunMethod("randomUUID", Null)
+End Sub
+
+
+' Evento que se dispara cada vez que el 'RemoveTimer' completa su intervalo (cada 5 segundos).
+' Su propósito es proactivamente limpiar conexiones muertas.
+Sub RemoveTimer_Tick
+'	Log("remove timer")
+	' Itera sobre todas las conexiones activas.
+	For Each key As String In Connections.Keys
+		' Intenta enviar un mensaje de prueba ("ping" o "heartbeat") a cada cliente.
+		Try
+			' Obtiene el OutputStream del cliente.
+			Dim out As OutputStream = Connections.Get(key)
+			' Envía un evento de tipo "Test" sin datos. Si la conexión está viva, esto no hará nada visible.
+			SendMessage(out, "Test", "", 0, "")
+		Catch
+			' Si el 'SendMessage' falla, significa que el socket está cerrado (el cliente se desconectó).
+			' Registra en el log que se está eliminando una conexión muerta.
+			Log("######################")
+			Log("##   Removing (timer): " & key)
+			Log("######################")
+			' Elimina la conexión del mapa para liberar recursos.
+			Connections.Remove(key)
+		End Try
+	Next
+End Sub
+
+' Evento del Timer #2 ("El Informante"): se dispara cada 2 segundos.
+public Sub StatsTimer_Tick
+	' Optimización: si no hay nadie conectado, no realiza el trabajo pesado.
+'	Log($"Conexiones: ${Connections.Size}"$)
+	If Connections.Size = 0 Then Return
+
+	Try
+		' Prepara un mapa para almacenar las estadísticas recolectadas.
+		Dim allPoolStats As Map
+		allPoolStats.Initialize
+		
+		' Bloquea el acceso a los conectores para leer sus datos de forma segura.
+		Main.MainConnectorsLock.RunMethod("lock", Null)
+		For Each dbKey As String In Main.listaDeCP
+			Dim connector As RDCConnector
+			If Main.Connectors.ContainsKey(dbKey) Then
+				connector = Main.Connectors.Get(dbKey)
+				If connector.IsInitialized Then
+					allPoolStats.Put(dbKey, connector.GetPoolStats)
+				Else
+					allPoolStats.Put(dbKey, CreateMap("Error": "Conector no inicializado"))
+				End If
+			End If
+		Next
+		' Libera el bloqueo para que otras partes del programa puedan usar los conectores.
+		Main.MainConnectorsLock.RunMethod("unlock", Null)
+		
+		' Convierte el mapa de estadísticas a un formato de texto JSON.
+		Dim j As JSONGenerator
+		j.Initialize(allPoolStats)
+		Dim jsonStats As String = j.ToString
+		
+		' Llama al "locutor" para enviar el JSON a todos los clientes conectados.
+		Broadcast("stats", "stats_update", jsonStats, 0)
+
+	Catch
+		' Captura y registra cualquier error que ocurra durante la recolección de datos.
+		Log($"[SSE] Error CRÍTICO durante la adquisición de estadísticas: ${LastException.Message}"$)
+	End Try
+End Sub

jRDC_Multi.b4j

@@ -1,17 +1,19 @@
 AppType=StandardJava
 Build1=Default,b4j.JRDCMulti
 File1=config.DB2.properties
-File10=stop.bat
+File10=start2.bat
+File11=stop.bat
 File2=config.DB3.properties
 File3=config.DB4.properties
 File4=config.properties
 File5=login.html
-File6=reiniciaProcesoBow.bat
+File6=manager.html
-File7=reiniciaProcesoPM2.bat
+File7=reiniciaProcesoBow.bat
-File8=start.bat
+File8=reiniciaProcesoPM2.bat
-File9=start2.bat
+File9=start.bat
 FileGroup1=Default Group
 FileGroup10=Default Group
+FileGroup11=Default Group
 FileGroup2=Default Group
 FileGroup3=Default Group
 FileGroup4=Default Group
@@ -32,10 +34,13 @@ Library8=jsql
 Library9=bcrypt
 Module1=Cambios
 Module10=Manager
-Module11=ParameterValidationUtils
+Module11=Manager0
-Module12=ping
+Module12=ParameterValidationUtils
-Module13=RDCConnector
+Module13=ping
-Module14=TestHandler
+Module14=RDCConnector
+Module15=SSE
+Module16=SSEHandler
+Module17=TestHandler
 Module2=ChangePassHandler
 Module3=DBHandlerB4X
 Module4=DBHandlerJSON
@@ -44,9 +49,9 @@ Module6=faviconHandler
 Module7=GlobalParameters
 Module8=LoginHandler
 Module9=LogoutHandler
-NumberOfFiles=10
+NumberOfFiles=11
 NumberOfLibraries=9
-NumberOfModules=14
+NumberOfModules=17
 Version=10.3
 @EndOfDesignText@
 'Non-UI application (console / server application)
@@ -55,7 +60,7 @@ Version=10.3
 
 #CommandLineArgs:
 #MergeLibraries: True
-' VERSION 5.09.16.2
+' VERSION 5.09.18
 '###########################################################################################################
 '###################### PULL #############################################################
 'Ctrl + click ide://run?file=%WINDIR%\System32\cmd.exe&Args=/c&Args=git&Args=pull
@@ -125,19 +130,26 @@ Sub Process_Globals
 	
 	Public QueryLogCache As List ' Cache para los logs de rendimiento (query_logs)
 	Public ErrorLogCache As List ' Cache para los logs de errores y advertencias
-	Public Const LOG_CACHE_THRESHOLD As Int = 10 ' Umbral de registros para forzar la escritura
+	Public LOG_CACHE_THRESHOLD As Int = 350 ' Umbral de registros para forzar la escritura
 	
 	Dim logger As Boolean
+	
+	Public LatestPoolStats As Map ' Mapa Thread-Safe para almacenar las últimas métricas de cada pool.
 End Sub
 
 Sub AppStart (Args() As String)
+	
+	SSE.Initialize
 	#if DEBUG
 	logger = True
+	LOG_CACHE_THRESHOLD = 10
 	#else
 		logger = False
 	#End If
 	' --- Subrutina principal que se ejecuta al iniciar la aplicación ---
 	
+'	SSE.Initialize
+    
 	bc.Initialize("BC")
 	QueryLogCache.Initialize
 	ErrorLogCache.Initialize
@@ -159,6 +171,7 @@ Sub AppStart (Args() As String)
 	srvr.Initialize("")
 	Connectors = srvr.CreateThreadSafeMap
 	commandsMap.Initialize
+	LatestPoolStats = srvr.CreateThreadSafeMap ' Inicializar el mapa de estadísticas como Thread-Safe
     
 	' NUEVO: Inicializar el mapa de estado de logs granular
 	SQLiteLoggingStatusByDB.Initialize
@@ -178,7 +191,7 @@ Sub AppStart (Args() As String)
 		Log($"Main.AppStart: Conector 'DB1' inicializado exitosamente en puerto: ${srvr.Port}"$)
         
 		' Lógica de Logs para DB1 (Fuente principal de configuración)
-		Dim enableLogsSetting As Int = con1.config.GetDefault("enableSQLiteLogs", 1).As(Int)
+		Dim enableLogsSetting As Int = con1.config.GetDefault("enableSQLiteLogs", 0).As(Int)
 		Dim isEnabled As Boolean = (enableLogsSetting = 1)
 		SQLiteLoggingStatusByDB.Put("DB1", isEnabled) ' Guardar el estado
         
@@ -309,6 +322,7 @@ Sub AppStart (Args() As String)
 	srvr.AddHandler("/DBJ", "DBHandlerJSON", False)
 	srvr.AddHandler("/dbrquery", "DBHandlerJSON", False)
 	srvr.AddHandler("/favicon.ico", "faviconHandler", False)
+	srvr.AddHandler("/stats-stream", "SSEHandler", False)
 	srvr.AddHandler("/*", "DBHandlerB4X", False)
 
 	' 7. Inicia el servidor HTTP.
@@ -543,7 +557,7 @@ Public Sub WriteQueryLogsBatch
     
 	MainConnectorsLock.RunMethod("unlock", Null)
     
-	If logger Then Log($"[LOG BATCH] Iniciando escritura transaccional de ${batchSize} logs de rendimiento. Logs copiados: ${logsToWrite.Size}"$)
+'	If logger Then Log($"[LOG BATCH] Iniciando escritura transaccional de ${batchSize} logs de rendimiento. Logs copiados: ${logsToWrite.Size}"$)
 
 	' === PASO 2: Escritura Transaccional a SQLite ===
 
@@ -561,7 +575,7 @@ Public Sub WriteQueryLogsBatch
 		' 2. Finalizar la transacción: Escritura eficiente a disco.
 		SQL1.TransactionSuccessful
         
-		if logger then Log($"[LOG BATCH] Lote de ${batchSize} logs de rendimiento escrito exitosamente."$)
+		If logger Then Log($"[LOG BATCH] Lote de ${batchSize} logs de rendimiento escrito exitosamente."$)
 
 	Catch
 		' Si falla, deshacemos todos los logs del lote y registramos el fallo.
@@ -661,8 +675,16 @@ End Sub
 Sub borraArribaDe15000Logs 'ignore
     
 	If IsAnySQLiteLoggingEnabled Then ' Solo ejecutar si al menos una DB requiere logs.
+		If logger Then Log("Recortando la tabla de 'query_logs', límite de 15,000 registros.")
+		' 1. Limpieza de Logs de Rendimiento (query_logs)
 		If logger Then Log("Recortando la tabla de 'query_logs', límite de 15,000 registros.")
 		SQL1.ExecNonQuery("DELETE FROM query_logs WHERE timestamp NOT in (SELECT timestamp FROM query_logs ORDER BY timestamp desc LIMIT 15000 )")
+
+		' 2. Limpieza de Logs de Errores (errores)
+		If logger Then Log("Recortando la tabla de 'errores', límite de 15,000 registros.")
+		SQL1.ExecNonQuery("DELETE FROM errores WHERE timestamp NOT in (SELECT timestamp FROM errores ORDER BY timestamp desc LIMIT 15000 )")
+    
+		' 3. Optimización de disco
 		SQL1.ExecNonQuery("vacuum;")
 	Else
 		' Si IsAnySQLiteLoggingEnabled es False, el Timer no debería estar activo.

jRDC_Multi.b4j.meta

@@ -5,6 +5,9 @@ ModuleBookmarks11=
 ModuleBookmarks12=
 ModuleBookmarks13=
 ModuleBookmarks14=
+ModuleBookmarks15=
+ModuleBookmarks16=
+ModuleBookmarks17=
 ModuleBookmarks2=
 ModuleBookmarks3=
 ModuleBookmarks4=
@@ -20,6 +23,9 @@ ModuleBreakpoints11=
 ModuleBreakpoints12=
 ModuleBreakpoints13=
 ModuleBreakpoints14=
+ModuleBreakpoints15=
+ModuleBreakpoints16=
+ModuleBreakpoints17=
 ModuleBreakpoints2=
 ModuleBreakpoints3=
 ModuleBreakpoints4=
@@ -35,14 +41,17 @@ ModuleClosedNodes11=
 ModuleClosedNodes12=
 ModuleClosedNodes13=
 ModuleClosedNodes14=
+ModuleClosedNodes15=3,5,6
+ModuleClosedNodes16=2,3
+ModuleClosedNodes17=
 ModuleClosedNodes2=
-ModuleClosedNodes3=9,10,11,12,13,14,15,16
+ModuleClosedNodes3=
 ModuleClosedNodes4=
 ModuleClosedNodes5=
 ModuleClosedNodes6=
 ModuleClosedNodes7=
 ModuleClosedNodes8=
 ModuleClosedNodes9=
-NavigationStack=Main,TimerLogs_Tick,533,0,Main,LogQueryPerformance,414,5,Main,LogServerError,459,0,Main,AppStart,244,0,Main,WriteQueryLogsBatch,512,1,Main,borraArribaDe15000Logs,617,0,Main,WriteErrorLogsBatch,602,1,Main,InitializeSQLiteDatabase,365,0,Main,Process_Globals,76,4,Cambios,Process_Globals,22,6
+NavigationStack=SSE,GetGUID,115,0,SSE,RemoveTimer_Tick,124,5,RDCConnector,GetPoolStats,255,0,Manager,Class_Globals,10,0,Manager,Initialize,24,0,Manager,Handle,149,0,SSEHandler,RemoveTimer_Tick,66,0,SSEHandler,Class_Globals,16,0,Main,AppStart,265,0,Cambios,Process_Globals,25,0
 SelectedBuild=0
-VisibleModules=3,4,13,1,10,11,14,2
+VisibleModules=3,4,14,1,10,15,16,17,13