Polling de Resultados SIFEN

PENDIENTE → EN_LOTE → ENVIADO → APROBADO     ← estado terminal exitoso
                              → RECHAZADO    ← estado terminal con error SIFEN
                              → ERROR        ← falla técnica de envío/procesamiento
APROBADO            → CANCELADO              ← después de un evento de cancelación
                                  DESCONOCIDO ← caso raro de inconsistencia

PREPARADO → INTENTANDO → ENVIADO → PROCESADO   ← éxito
                                 → ERROR        ← falló al procesar
                                 → FALLIDO      ← falló al enviar

type EstadoDE =
  | "PENDIENTE"
  | "EN_LOTE"
  | "ENVIADO"
  | "APROBADO"
  | "RECHAZADO"
  | "ERROR"
  | "CANCELADO"
  | "DESCONOCIDO";

interface EstadoResponse {
  cdc: string;
  estado: EstadoDE;
  iTiDe: number;
  numeroDocumento: number; // Long en backend
  fechaCreacion: string;
  protocoloAutorizacion: string | null;
  mensajeRechazo: string | null;
}

async function consultarEstado(cdc: string): Promise<EstadoResponse> {
  const response = await fetch(
    `https://api.sifende.com.py/api/v1/documento-electronico/status/${cdc}`,
    {
      headers: { "Authorization": `Bearer ${process.env.SIFENDE_API_KEY}` },
    }
  );
  if (!response.ok) throw new Error(`HTTP ${response.status}`);
  return response.json();
}

async function esperarResultado(
  cdc: string,
  timeoutMs = 10 * 60 * 1000
): Promise<EstadoResponse> {
  const inicio = Date.now();
  let intento = 0;

  while (Date.now() - inicio < timeoutMs) {
    const espera = Math.min(2000 * Math.pow(1.6, intento), 30000);
    await new Promise((r) => setTimeout(r, espera));

    const resultado = await consultarEstado(cdc);

    if (resultado.estado === "APROBADO") return resultado;
    if (resultado.estado === "RECHAZADO") {
      throw new Error(`SIFEN rechazó el DE: ${resultado.mensajeRechazo}`);
    }
    if (resultado.estado === "ERROR") {
      throw new Error(`Falla técnica al procesar el DE: ${resultado.mensajeRechazo ?? 'sin detalle'}`);
    }
    if (resultado.estado === "CANCELADO") return resultado;

    intento++;
  }

  throw new Error(`Timeout esperando resultado para CDC ${cdc}`);
}

// Uso
try {
  const resultado = await esperarResultado(cdc);
  console.log("DE aprobado:", resultado.cdc);
} catch (err) {
  console.error("Error:", err.message);
}

// Pseudocódigo
async function emitirYPersistir(payload: any) {
  const { id, cdc } = await emitirDE(payload);
  await db.documentos.insert({ id, cdc, estado: "PENDIENTE" });

  // Polling en background: incluso si el proceso muere, el DE queda persistido
  pollearYActualizar(cdc).catch(console.error);

  return { id, cdc };
}

// Worker independiente para retomar PENDIENTES después de un crash
async function reanudarPendientes() {
  const pendientes = await db.documentos.where({ estado: "PENDIENTE" });
  for (const doc of pendientes) {
    pollearYActualizar(doc.cdc).catch(console.error);
  }
}