merge: unify correos into email_services

Author: DysTelefonica-legacy

README.md

@@ -28,8 +28,7 @@ El **script maestro (`run_master.py`)** es el corazón del sistema y reemplaza a
 5. **Riesgos** (`run_riesgos.py`): Gestión de riesgos empresariales
 
 #### Tareas Continuas (ejecutadas en cada ciclo):
-6. **Correos** (`run_correos.py`): Sistema de envío de correos
-7. **Correo Tareas** (`run_correo_tareas.py`): Sistema de gestión de correos que interactúa con la base de datos de tareas
+6. **Email Services** (`run_email_services.py`): Servicio unificado de envío de correos (fusiona antiguos módulos `correos` y `correo_tareas`)
 
 ### 🆕 Cambios Arquitectónicos Recientes (Refactor 2025)
 
@@ -105,10 +104,10 @@ Ejemplo de runner minimalista:
 ```python
 import sys
 from common.utils import execute_task_with_standard_boilerplate
-from correos.correos_task import CorreosTask
+from email_services.email_task import EmailServicesTask
 
 def main():
-   task = CorreosTask()
+   task = EmailServicesTask()
    code = execute_task_with_standard_boilerplate("CORREOS", task_obj=task)
    sys.exit(code)
 
@@ -247,8 +246,7 @@ scripts-python/
 │   │   └── add_status_to_tareas_db.py # Migración estado tareas
 │   ├── run_agedys.py            # Script para módulo AGEDYS
 │   ├── run_brass.py             # Script principal para módulo BRASS
-│   ├── run_correo_tareas.py     # Script para módulo correo tareas
-│   ├── run_correos.py           # Script para módulo correos
+│   ├── run_email_services.py    # Runner unificado de servicios de correo
 │   ├── run_expedientes.py       # Script para módulo expedientes
 │   ├── run_master.py            # Script maestro - daemon principal con modo verbose
 │   ├── run_no_conformidades.py  # Script para no conformidades
@@ -277,14 +275,10 @@ scripts-python/
 │   │   ├── task_registry.py     # Registro de tareas (TaskRegistry OO)
 │   │   ├── user_adapter.py      # Adaptador de usuarios
 │   │   └── utils.py             # Utilidades HTML, logging, fechas
-│   ├── correo_tareas/           # Módulo de gestión de correos que interactúa con la base de datos de tareas
+│   ├── email_services/          # Módulo unificado de correos (correos + tareas)
 │   │   ├── __init__.py
-│   │   ├── correo_tareas_manager.py # Gestor de correos para tareas empresariales
-│   │   └── correo_tareas_task.py # Tareas de correo
-│   ├── correos/                 # Módulo de correos
-│   │   ├── __init__.py
-│   │   ├── correos_manager.py   # Gestor de correos
-│   │   └── correos_task.py      # Tareas de correos
+│   │   ├── email_manager.py     # Lógica centralizada de envío
+│   │   └── email_task.py        # Task continua unificada
 │   ├── expedientes/             # Módulo de expedientes
 │   │   ├── __init__.py
 │   │   ├── expedientes_manager.py # Gestor de expedientes
@@ -316,8 +310,7 @@ scripts-python/
 │   │   ├── __init__.py
 │   │   ├── agedys/              # Integración del sistema AGEDYS
 │   │   ├── brass/               # Integración del sistema brass
-│   │   ├── correo_tareas/       # Integración del sistema de correo tareas
-│   │   ├── correos/             # Integración del sistema de correos
+│   │   ├── email_services/      # Integración del servicio unificado de correos
 │   │   ├── database/            # Integración con bases de datos
 │   │   ├── expedientes/         # Integración del sistema de expedientes
 │   │   ├── no_conformidades/    # Integración no conformidades
@@ -327,7 +320,7 @@ scripts-python/
 │       ├── agedys/              # Tests específicos AGEDYS
 │       ├── brass/               # Tests específicos BRASS
 │       ├── common/              # Tests módulos comunes
-│       ├── correos/             # Tests del módulo de correos
+│       ├── email_services/      # Tests del servicio unificado de correos
 │       ├── expedientes/         # Tests del módulo de expedientes
 │       ├── no_conformidades/    # Tests no conformidades
 │       └── riesgos/             # Tests del módulo de riesgos
@@ -728,7 +721,7 @@ El sistema soporta dos configuraciones SMTP:
 | `src/common/task_registry.py` | 64% | ✅ |
 | `src/common/notifications.py` | 100% | ✅ |
 | `src/common/utils.py` | 49% | ✅ |
-| `src/correos/correos_manager.py` | 91% | ✅ |
+| `src/email_services/email_manager.py` | 91% | ✅ |
 | `src/expedientes/expedientes_manager.py` | 98% | ✅ |
 | `src/riesgos/riesgos_manager.py` | 90% | ✅ |
 
@@ -1081,15 +1074,12 @@ python scripts/run_riesgos.py                   # Ejecución normal
 python scripts/run_riesgos.py --force           # Fuerza ejecución
 python scripts/run_riesgos.py --dry-run         # Modo simulación
 
-# Correos - Sistema de envío de correos
-python scripts/run_correos.py                   # Ejecución normal
-python scripts/run_correos.py --force           # Fuerza ejecución
-python scripts/run_correos.py --dry-run         # Modo simulación
+# Email Services - Servicio unificado de correo (remplaza correos y correo_tareas)
 
-# Tareas - Sistema de gestión de tareas
-python scripts/run_correo_tareas.py                    # Ejecución normal
-python scripts/run_correo_tareas.py --force            # Fuerza ejecución
-python scripts/run_correo_tareas.py --dry-run          # Modo simulación
+### Manejo de errores transitorios SMTP (Refactor 2025)
+Los errores de conexión SMTP (p.ej. desconexión inesperada, `SMTPConnectError`, `ConnectionRefusedError`) ahora se consideran **transitorios** y no marcan el correo como fallido en la base de datos. El registro permanece pendiente para reintentos en futuros ciclos. Sólo errores definitivos (credenciales inválidas, destinatario rechazado, formato de mensaje inválido) marcan el correo como fallido. Esto incrementa la resiliencia ante caídas puntuales del servidor de correo.
+python scripts/run_email_services.py            # Ejecución normal
+python scripts/run_email_services.py --force    # (Reservado) Fuerza ejecución
 
 # Tests
 python scripts/run_tests.py

scripts/README.md

@@ -7,7 +7,7 @@ Este directorio contiene los scripts de producción del sistema de monitoreo con
 ```
 scripts/
 ├── run_master.py              # 🎯 Script maestro - daemon principal del sistema
-├── run_correos.py             # 📧 Gestión y envío de correos electrónicos
+├── run_email_services.py      # 📧 Servicios unificados de envío de correos
 ├── run_brass.py               # 🔧 Procesamiento de datos BRASS
 ├── run_expedientes.py         # 📋 Gestión de expedientes y ofertas
 ├── run_riesgos.py             # ⚠️  Análisis y gestión de riesgos
@@ -31,18 +31,18 @@ El **Master Runner** es el corazón del sistema de monitoreo continuo. Ejecuta d
 - **Configuración flexible**: Variables de entorno para todos los parámetros
 
 ### Scripts Gestionados:
-1. **correos** → `run_correos.py` (continuo)
+1. **email_services** → `run_email_services.py` (continuo unificado)
 2. **riesgos** → `run_riesgos.py` (diario)
 3. **brass** → `run_brass.py` (diario)
 4. **expedientes** → `run_expedientes.py` (diario)
 5. **no_conformidades** → `run_no_conformidades.py` (diario)
 
 ## 📧 Scripts de Producción
 
-### run_correos.py
-- **Función**: Gestión y envío de correos electrónicos
+### run_email_services.py
+- **Función**: Gestión unificada de servicios de correo (reemplaza correos y correo_tareas)
 - **Tipo**: Tarea continua (ejecutada en cada ciclo)
-- **Descripción**: Procesa colas de correo y envía notificaciones
+- **Descripción**: Procesa colas de correo de múltiples orígenes (correos, tareas) y envía notificaciones
 
 ### run_brass.py
 - **Función**: Procesamiento de datos BRASS
@@ -89,7 +89,7 @@ python run_master.py --dry-run
 ### Ejecución Individual de Scripts:
 ```bash
 # Ejecutar script específico
-python run_correos.py
+python run_email_services.py
 python run_brass.py
 python run_expedientes.py
 python run_riesgos.py

scripts/run_correos.py

@@ -1,35 +1,39 @@
-"""Runner estandarizado para notificaciones de tareas (correo_tareas)."""
+"""Runner estandarizado para la tarea unificada de servicios de correo (correos + tareas)."""
 from __future__ import annotations
 
 import sys
 import argparse
-import logging
 from pathlib import Path
 
+# Ajuste de sys.path para asegurar importaciones desde src/
 _PROJECT_ROOT = Path(__file__).resolve().parent.parent
 _SRC_DIR = _PROJECT_ROOT / "src"
 if str(_SRC_DIR) not in sys.path:
     sys.path.insert(0, str(_SRC_DIR))
 from common.utils import ensure_project_root_in_path  # type: ignore
 ensure_project_root_in_path()
 
-from correo_tareas.correo_tareas_task import CorreoTareasTask  # type: ignore
+from email_services.email_task import EmailServicesTask  # type: ignore
 from common.utils import execute_task_with_standard_boilerplate  # type: ignore
 
 
 def parse_args(argv: list[str] | None = None) -> argparse.Namespace:
-    parser = argparse.ArgumentParser(description="Ejecuta notificaciones de correo de tareas.")
+    parser = argparse.ArgumentParser(
+        description="Ejecuta el servicio unificado de envío de correos (correos + tareas)."
+    )
     parser.add_argument(
-        "--force", action="store_true", help="(Reservado) Fuerza ejecución incluso sin criterios.",
+        "--force",
+        action="store_true",
+        help="(Reservado) Fuerza la ejecución incluso sin criterios adicionales.",
     )
     return parser.parse_args(argv)
 
 
 def main(argv: list[str] | None = None):  # pragma: no cover
     _ = parse_args(argv)
-    task = CorreoTareasTask()
+    task = EmailServicesTask()
     exit_code = execute_task_with_standard_boilerplate(
-        "CORREO_TAREAS", task_obj=task
+        "EMAIL_SERVICES", task_obj=task
     )
     sys.exit(exit_code)
 

scripts/run_correo_tareas.py scripts/run_email_services.pyscripts/run_correo_tareas.py renamed to scripts/run_email_services.py

@@ -674,16 +674,15 @@ def ejecutar_script(self, script_name: str) -> Dict[str, any]:
 
     def ejecutar_tareas_diarias(self) -> Dict[str, any]:
         """Ejecuta las tareas diarias consultando la lógica OO de cada TareaDiaria."""
-        # Asegurar path
         src_path = Path(__file__).parent.parent / 'src'
         if str(src_path) not in sys.path:
             sys.path.insert(0, str(src_path))
-            try:
-                from common.task_registry import TaskRegistry  # import diferido
-                task_instances = TaskRegistry().get_daily_tasks()
-            except Exception as e:  # pragma: no cover - fallback
-                self.logger_adapter.warning(f"No se pudo importar task_registry: {e}. Saltando tareas diarias.")
-                return {}
+        try:
+            from common.task_registry import TaskRegistry  # import diferido
+            task_instances = TaskRegistry().get_daily_tasks()
+        except Exception as e:  # pragma: no cover - fallback
+            self.logger_adapter.warning(f"No se pudo importar task_registry: {e}. Saltando tareas diarias.")
+            return {}
         # Mapa filename->key en available_scripts
         file_to_key = {v: k for k, v in self.available_scripts.items()}
         if self.verbose_mode:

scripts/run_master.py

@@ -1,7 +1,6 @@
 {
   "scripts": {
-    "correos": {"file": "run_correos.py", "type": "continuous"},
-    "tareas": {"file": "run_correo_tareas.py", "type": "continuous"},
+    "email_services": {"file": "run_email_services.py", "type": "continuous"},
     "brass": {"file": "run_brass.py", "type": "daily", "task_name": "BRASSDiario"},
     "expedientes": {"file": "run_expedientes.py", "type": "daily", "task_name": "ExpedientesDiario"},
     "no_conformidades": {"file": "run_no_conformidades.py", "type": "daily", "task_name": ["NoConformidadesCalidad", "NoConformidadesTecnica"]},

scripts_config.json

@@ -23,15 +23,13 @@
     from src.expedientes.expedientes_task import ExpedientesTask  # type: ignore
     from src.no_conformidades.no_conformidades_task import NoConformidadesTask  # type: ignore
     from src.agedys.agedys_task import AgedysTask  # type: ignore
-    from src.correos.correos_task import CorreosTask  # type: ignore
-    from src.correo_tareas.correo_tareas_task import CorreoTareasTask  # type: ignore
+    from src.email_services.email_task import EmailServicesTask  # type: ignore
 except ModuleNotFoundError:
     from brass.brass_task import BrassTask  # type: ignore
     from expedientes.expedientes_task import ExpedientesTask  # type: ignore
     from no_conformidades.no_conformidades_task import NoConformidadesTask  # type: ignore
     from agedys.agedys_task import AgedysTask  # type: ignore
-    from correos.correos_task import CorreosTask  # type: ignore
-    from correo_tareas.correo_tareas_task import CorreoTareasTask  # type: ignore
+    from email_services.email_task import EmailServicesTask  # type: ignore
 
 # Intento de importación ligera de RiesgosTask; si falla, se crea stub para tests unitarios
 try:
@@ -188,25 +186,40 @@ def __init__(self):
         )
 
 
-class CorreosTask(TareaContinua):
-    """Tarea continua para envío de correos pendientes"""
-    
-    def __init__(self):
-        super().__init__(
-            name="Correos",
-            script_filename="run_correos.py"
-        )
+class EmailServicesRegistryTask(TareaContinua):
+    """Wrapper de registro para tarea unificada de servicios de correo.
 
+    Se mantiene un wrapper mínimo para no acoplar directamente TaskRegistry
+    a la implementación concreta y facilitar futuras extensiones (p.ej. división).
+    """
 
-class CorreoTareasTask(TareaContinua):
-    """Tarea continua para notificaciones de tareas"""
-    
     def __init__(self):
         super().__init__(
-            name="CorreoTareas",
-            script_filename="run_correo_tareas.py"
+            name="EmailServices",
+            script_filename="run_email_services.py"
         )
 
+    # Delegación: la lógica real vive en EmailServicesTask ejecutada vía runner.
+    # Aquí podríamos, en el futuro, instanciar y ejecutar EmailServicesTask directamente
+    # si migramos completamente al modelo TaskRegistry para continuas.
+    def execute_specific_logic(self) -> bool:  # pragma: no cover - mínima
+        """Ejecuta la lógica de email unificado.
+
+        Si la variable de entorno EMAIL_SERVICES_REGISTRY_MODE == 'direct', instancia y
+        ejecuta el EmailServicesTask directamente (útil en modo simple / tests).
+        En otro caso devuelve True (no-op) dejando que el runner continuo lo gestione.
+        """
+        import os
+        mode = os.getenv('EMAIL_SERVICES_REGISTRY_MODE', 'delegate').lower()
+        if mode == 'direct':
+            try:
+                from email_services.email_task import EmailServicesTask  # import local para evitar ciclos
+                task = EmailServicesTask()
+                return task.execute_specific_logic()
+            except Exception:
+                return False
+        return True
+
 
 class TaskRegistry:
     """Registro encapsulado de tareas.
@@ -235,8 +248,7 @@ def __init__(self,
             ])
         if include_continuous:
             self._continuous_tasks.extend([
-                CorreosTask(),
-                CorreoTareasTask()
+                EmailServicesRegistryTask()
             ])
         if extra_daily:
             self._daily_tasks.extend(extra_daily)
@@ -289,5 +301,5 @@ def get_all_tasks() -> List:  # pragma: no cover - compat
     'get_all_tasks',
     # Clases de tareas
     'RiesgosTask', 'BrassTask', 'ExpedientesTask', 'NoConformidadesTask', 'AgedysTask',
-    'CorreosTask', 'CorreoTareasTask'
+    'EmailServicesRegistryTask'
 ]