Getting Started

El Worker de Evaluación de Reabastecimiento Urgente es un servicio diseñado para monitorear requisitos de pedidos que están en espera debido a reabastecimiento pendiente. Cuando se detectan estos eventos, el worker los evalúa y crea o actualiza alertas de reabastecimiento al nivel “Urgente”. Esto ayuda a priorizar las operaciones de reabastecimiento para artículos que están bloqueando pedidos de clientes.

Tecnologías y Dependencias Clave

Node.js: Entorno de ejecución (v20)
TypeScript: Lenguaje de programación
Express: Framework web para los endpoints de verificación de salud
AWS SDK: Para interactuar con servicios de AWS (SQS)
@justomx/either: Biblioteca para manejo funcional de errores
@justomx/http-client: Cliente HTTP para comunicación con servicios
@justomx/warehouse-commons: Biblioteca para operaciones relacionadas con almacenes
@justomx/fwf: Cliente de servicio de banderas de características
@justomx/context: Gestión de contexto para operaciones asíncronas
cron: Para programar la ejecución del worker

Servicios Externos

Cola SQS: Recibe eventos de requisitos de pedidos en espera
Servicio de Reabastecimiento: Servicio HTTP para gestionar alertas de reabastecimiento
Servicio de Banderas de Características: Utilizado para verificar si un almacén tiene habilitada la bandera “restocking_urgent”

Relación con Otros Microservicios

Este worker interactúa con:

Sistema de Procesamiento de Pedidos: Fuente de eventos de requisitos de pedidos en espera
Servicio de Reabastecimiento: Destino para crear y actualizar alertas de reabastecimiento
Servicio de Almacén: Utilizado para validar información de almacenes

Componente Principal

El punto de entrada principal del worker se encuentra en src/index.ts. Este archivo:

Inicializa la configuración de la aplicación
Configura el monitoreo del estado de salud
Configura e inicia un trabajo cron que ejecuta el worker en intervalos específicos
Importa el servidor web desde bin/www.ts para los endpoints de verificación de salud

El worker se ejecuta según un cronograma definido por la variable de entorno CRON_EXPRESSION. Cuando se ejecuta:

Recupera mensajes de la cola SQS
Procesa cada mensaje para evaluar si requiere una alerta de reabastecimiento urgente
Crea nuevas alertas de reabastecimiento o actualiza las existentes al nivel “Urgente”
Elimina los mensajes procesados de la cola
Registra los resultados del procesamiento

El worker puede ser habilitado o deshabilitado usando la variable de entorno CRON_ENABLED.