Cómo manejar colas de trabajo y reintentos

Si la venta espera la respuesta del SRI, cada lentitud se vuelve una venta lenta. En vez de eso, guarda el comprobante pendiente en la misma transacción que la venta y deja que un proceso aparte lo envíe. Este patrón se llama outbox.

CREATE TABLE comprobantes_pendientes (
  id INTEGER PRIMARY KEY AUTOINCREMENT,
  documento_id TEXT NOT NULL UNIQUE,   -- una venta = un comprobante
  secuencial TEXT NOT NULL,            -- asignado UNA vez, se reutiliza en cada reintento
  clave_acceso TEXT,                   -- se guarda en cuanto se conoce
  payload TEXT NOT NULL,
  estado TEXT NOT NULL DEFAULT 'PENDIENTE',
  intentos INTEGER NOT NULL DEFAULT 0,
  proximo_intento TEXT
);

La venta termina rápido. El comprobante se emite en segundo plano.

Este es el error que más duplicados provoca. Si cada reintento genera un nuevo secuencial, un envío que sí llegó al SRI se vuelve dos comprobantes. Asigna el secuencial y la clave de acceso una vez, guárdalos y reutilízalos en cada reintento.

SRI 43 · Clave de acceso registrada SRI 45 · Secuencial registrado

Si perdiste la respuesta (un timeout, una caída de red), no sabes si el SRI recibió el comprobante. Antes de reenviar, consulta su estado por clave de acceso. Si existe, no lo envíes de nuevo.

Un reintento a ciegas de un error de datos solo llena tu cola de basura.

Si mil comprobantes fallan a la vez y todos reintentan a los 5 segundos, vuelves a saturar el servicio. Usa espera exponencial con variación aleatoria (full jitter):

const dormir = (ms) => new Promise((r) => setTimeout(r, ms));

// Reintenta solo lo que tiene sentido reintentar
export const esReintentable = (err) =>
  err.codigo === "RED" || err.status === 429 || err.status >= 500;

export async function conReintentos(
  operacion,
  { max = 5, baseMs = 500, maxMs = 20000, reintentable = esReintentable } = {}
) {
  let ultimoError;

  for (let intento = 1; intento <= max; intento++) {
    try {
      return await operacion(intento);
    } catch (err) {
      ultimoError = err;
      if (!reintentable(err) || intento === max) break;

      const tope = Math.min(maxMs, baseMs * 2 ** (intento - 1));
      await dormir(Math.random() * tope); // "full jitter": evita que todos reintenten a la vez
    }
  }
  throw ultimoError;
}

• Define un máximo de intentos.
• Al agotarlos, mueve el comprobante a una cola de revisión (dead-letter) y avisa a una persona.
• Nunca dejes un reintento infinito: oculta problemas reales.

Si detectas que muchos envíos seguidos fallan por caída del SRI, pausa los envíos unos minutos en vez de seguir golpeando. Reanuda con pocas solicitudes de prueba. Si la caída es prolongada, revisa el procedimiento de contingencia vigente.

Para saber el estado sin consultar sin parar, combina esta cola con webhooks.

Webhooks vs polling