Maquina de estados
4.3 Orquestación vs. Coreografía
Se opta por un enfoque de orquestación para la máquina de estados dentro del Módulo de Integración de SPPD.
La máquina de estados centraliza la lógica de control del ciclo de vida de cada transacción de sincronización originada en SPPD.
Funcionalidades que incluye:
- 🚀 Iniciar el envío del mensaje
- ⏳ Esperar y procesar la respuesta de Power Street
- ⏱️ Manejar timeouts si no se recibe respuesta
- 🔁 Gestionar la lógica de reintentos
- ❗ Transitar la transacción a estados de fallo que requieran intervención manual
- 🛠️ Manejar el reseteo de reintentos y el reenvío de mensajes corregidos
Esta orquestación interna en SPPD proporciona:
- Un control más granular
- Mejor visibilidad sobre el estado de cada transacción
- Soporte para el dashboard de operaciones
- Capacidad de intervención manual cuando sea necesario
🔄 Nota: El patrón general entre SPPD y Power Street sigue siendo de coreografía (cada sistema reacciona a eventos en el broker),
pero el manejo interno de la transacción en SPPD es orquestado para garantizar robustez y trazabilidad.
5. Máquina de Estados (Spring State Machine para SPPD)
5.1 Introducción al Modelo de Estados
La máquina de estados controlará el ciclo de vida de cada transacción de sincronización de producto en el sistema SPPD.
🧠 Especificación Detallada de la Máquina de Estados (SPPD) - AJUSTADA
#### 5.2 Catálogo de Estados
| Estado | Descripción |
|---|---|
NEW | Transacción recién creada, pendiente de validación inicial. |
PENDING_PUBLISH | Transacción validada, lista para ser publicada o republicada en el Message Broker. |
FATAL_ERROR | Error irrecuperable durante la validación inicial o un fallo crítico. Estado final. |
MESSAGE_PUBLISHED | Mensaje enviado al Message Broker. Esperando respuesta de Power Street o timeout. |
PROCESSING_RESPONSE | Respuesta recibida de Power Street, se está evaluando. |
RETRYABLE_FAILURE | Ocurrió un error reintentable (fallo de envío, timeout o error reintentable de Power Street), y aún quedan intentos o se está evaluando. |
PENDING_RETRY_PUBLISH | Programada para un reintento, esperando que se cumpla el intervalo de espera. |
MAX_RETRIES_REACHED | Se alcanzó el número máximo de reintentos o Power Street reportó un error fatal. Requiere intervención manual. |
MANUAL_CORRECTION_PENDING_PUBLISH | Un operador ha editado el payload; la transacción está lista para ser republicada. |
COMPLETED_SUCCESS | Power Street procesó la transacción exitosamente. Estado final. |
COMPLETED_SUCCESS_CORRECTED | Power Street procesó exitosamente después de una corrección manual. Estado final. |
5.3 Catálogo de Eventos Externos
| Evento | Desencadenante |
|---|---|
EV_PUBLISH_REQUESTED | SPPD Core solicita la sincronización de un producto. |
EV_VALIDATION_SUCCESS | (Puede ser un evento interno o resultado de una acción) Validación interna del payload es exitosa. |
EV_VALIDATION_FAILURE | (Puede ser un evento interno o resultado de una acción) Validación interna del payload falla. |
EV_MESSAGE_SENT_TO_BROKER_FAIL | El publicador interno de SPPD no pudo enviar el mensaje al Message Broker. |
EV_RESPONSE_RECEIVED | Se recibe un mensaje de respuesta desde Power Street. |
EV_RESPONSE_TIMEOUT | Expiró el tiempo de espera para recibir una respuesta de Power Street. |
EV_PROCESS_RESPONSE_SUCCESS | (Evento interno generado por la acción storeRawResponse si la respuesta fue éxito) |
EV_PROCESS_RESPONSE_ERROR_RETRY | (Evento interno generado por la acción storeRawResponse si la respuesta fue error reintentable) |
EV_PROCESS_RESPONSE_ERROR_FATAL | (Evento interno generado por la acción storeRawResponse si la respuesta fue error fatal de Power Street) |
EV_RETRY_TIMER_EXPIRED | El temporizador para el intervalo de reintento ha expirado. |
EV_MANUAL_CORRECTION_APPLIED | Un operador ha guardado cambios en una transacción desde el dashboard. |
🔄 Transiciones y Acciones (Alineado con el Diagrama)
| Desde Estado | Evento | Hacia Estado | Guardia / Condición | Acción(es) de Transición / Salida / Entrada |
|---|---|---|---|---|
[*] (Inicio) | EV_PUBLISH_REQUESTED | NEW | Entrada a NEW: initializeTransaction(payload, metadata) | |
NEW | EV_VALIDATION_SUCCESS | PENDING_PUBLISH | Acción: prepareInitialMessage() | |
NEW | EV_VALIDATION_FAILURE | FATAL_ERROR | Acción: logValidationError(), updateTransactionStatus(FATAL_ERROR) | |
PENDING_PUBLISH (on entry) | — | MESSAGE_PUBLISHED | Acción de Entrada: incrementRetryAttempt(), publishMessageToBroker(), startResponseTimer(), updateTransactionStatus(MESSAGE_PUBLISHED) | |
PENDING_PUBLISH | EV_MESSAGE_SENT_TO_BROKER_FAIL | RETRYABLE_FAILURE | Acción: logBrokerPublishError(), updateTransactionStatus(RETRYABLE_FAILURE)Entrada a RETRYABLE_FAILURE: checkRetryLimitAndDetermineNextStep() | |
MESSAGE_PUBLISHED | EV_RESPONSE_RECEIVED | PROCESSING_RESPONSE | Acción: stopResponseTimer(), storeRawResponseAndDetermineInternalEvent() (genera eventos internos) | |
MESSAGE_PUBLISHED | EV_RESPONSE_TIMEOUT | RETRYABLE_FAILURE | Acción: logResponseTimeout(), updateTransactionStatus(RETRYABLE_FAILURE)Entrada a RETRYABLE_FAILURE: checkRetryLimitAndDetermineNextStep() | |
PROCESSING_RESPONSE | EV_PROCESS_RESPONSE_SUCCESS | COMPLETED_SUCCESS | !transaction.isCorrected | Acción: parseSuccessResponse(), updateTransactionStatus(COMPLETED_SUCCESS), notifySPPDCore() |
PROCESSING_RESPONSE | EV_PROCESS_RESPONSE_SUCCESS | COMPLETED_SUCCESS_CORRECTED | transaction.isCorrected | Acción: parseSuccessResponse(), updateTransactionStatus(COMPLETED_SUCCESS_CORRECTED), markAsCorrectedInDBComplete(), notifySPPDCore() |
PROCESSING_RESPONSE | EV_PROCESS_RESPONSE_ERROR_RETRY | RETRYABLE_FAILURE | Acción: parseErrorResponse(), logRetryableErrorFromPS(), updateTransactionStatus(RETRYABLE_FAILURE)Entrada a RETRYABLE_FAILURE: checkRetryLimitAndDetermineNextStep() | |
PROCESSING_RESPONSE | EV_PROCESS_RESPONSE_ERROR_FATAL | MAX_RETRIES_REACHED | Acción: parseErrorResponse(), logFatalErrorFromPS(), updateTransactionStatus(MAX_RETRIES_REACHED), notifyOperatorDashboard() | |
RETRYABLE_FAILURE (on entry) | — | PENDING_RETRY_PUBLISH | (si es elegible para retry) | Acción de Entrada: scheduleRetryTimer(), updateTransactionStatus(PENDING_RETRY_PUBLISH) |
RETRYABLE_FAILURE (on entry) | — | MAX_RETRIES_REACHED | (si NO es elegible para retry) | Acción de Entrada: notifyOperatorDashboard(), updateTransactionStatus(MAX_RETRIES_REACHED) |
PENDING_RETRY_PUBLISH | EV_RETRY_TIMER_EXPIRED | PENDING_PUBLISH | Acción: prepareRetryMessage() (La entrada a PENDING_PUBLISH se encarga del resto) | |
MAX_RETRIES_REACHED | EV_MANUAL_CORRECTION_APPLIED | MANUAL_CORRECTION_PENDING_PUBLISH | Acción: resetRetryAttempt(), updatePayloadFromCorrection(correctedPayload), logOperatorCorrectionDetails(), updateTransactionStatus(MANUAL_CORRECTION_PENDING_PUBLISH) | |
MANUAL_CORRECTION_PENDING_PUBLISH (on entry) | — | PENDING_PUBLISH | Acción de Entrada: markTxAsPendingCorrectedPublish() (La entrada a PENDING_PUBLISH se encarga de la publicación) | |
COMPLETED_SUCCESS | — | [*] (Fin) | — | |
COMPLETED_SUCCESS_CORRECTED | — | [*] (Fin) | — | |
FATAL_ERROR |