🖥️ Consola Interactiva y WAF

Para demostrar el procesamiento de los datos ingestados, el Pipeline expone un endpoint que permite ejecutar sentencias SQL reales directamente contra la base de datos PostgreSQL desde una terminal interactiva. Dado el riesgo crítico que esto representa al abrir la base de datos al exterior, el endpoint está blindado por múltiples capas de seguridad y un filtro de expresiones regulares a nivel de controlador.

🔌 Endpoint de Consulta Dinámica

/api/v1/etl/query

Ejecuta una consulta SQL de solo lectura y devuelve los resultados serializados.

📦 Payload de la Petición

El endpoint espera un objeto JSON simple con la consulta a ejecutar:

{
  "query": "SELECT vehicle_vin, odometer_km FROM logiflow_telemetry WHERE vehicle_status = 'MOVING'"
}

🛡️ Filtro de Seguridad (WAF Simulado)

Para evitar inyecciones SQL y la ejecución de sentencias destructivas, el controlador intercepta la consulta cruda y la pasa por una serie de validaciones estrictas antes de enviarla a JdbcTemplate.

🛑 Reglas del Firewall

Exclusividad de Lectura: La sentencia debe iniciar estrictamente con la palabra clave SELECT.
Sentencias Únicas: Se prohíbe el apilamiento de múltiples consultas mediante el uso intermedio de punto y coma (;).
Lista Negra de Palabras Clave: Se escanea el texto mediante expresiones regulares contra comandos peligrosos para neutralizar la manipulación de la estructura o accesos.

// Lista de palabras prohibidas en EtlController.java
String[] forbiddenKeywords = {"INSERT", "UPDATE", "DELETE", "DROP", "ALTER", "TRUNCATE", "GRANT", "REVOKE", "COMMIT", "ROLLBACK", "EXEC", "UNION", "SLEEP", "PG_SLEEP"};
for (String keyword : forbiddenKeywords) {
    if (upperSql.matches(".*\\b" + keyword + "\\b.*")) {
        return ResponseEntity.status(HttpStatus.FORBIDDEN)
                .body(Map.of("error", "[SECURITY ALERT] Posible inyección SQL detectada."));
    }
}

🚦 Protección contra Saturación de Red

Como última línea de defensa, la transacción a nivel de base de datos se marca como de solo lectura (@Transactional(readOnly = true)). Además, si la consulta original del usuario omite una cláusula de límite, el servidor inyecta automáticamente un LIMIT 15. Esto evita la saturación de la red y el colapso de la memoria en el frontend en caso de que se ejecute un SELECT * masivo sobre una tabla con decenas de miles de registros logísticos.

// Inyección dinámica de límite en EtlController.java
if (!upperSql.contains("LIMIT")) {
    finalSql = finalSql + " LIMIT 15";
}

HUB Principal

Motor Transaccional

Generador de Reportes

Pipeline de Ingesta Masiva

Gestión de Identidad y Acceso

🔌 Endpoint de Consulta Dinámica

📦 Payload de la Petición

🛡️ Filtro de Seguridad (WAF Simulado)

🛑 Reglas del Firewall

🚦 Protección contra Saturación de Red

​🔌 Endpoint de Consulta Dinámica

​📦 Payload de la Petición

​🛡️ Filtro de Seguridad (WAF Simulado)

​🛑 Reglas del Firewall

​🚦 Protección contra Saturación de Red

🔌 Endpoint de Consulta Dinámica

📦 Payload de la Petición

🛡️ Filtro de Seguridad (WAF Simulado)

🛑 Reglas del Firewall

🚦 Protección contra Saturación de Red