API de facturación electrónica para sistemas POS

CREATE TABLE comprobantes_pendientes (
  id INTEGER PRIMARY KEY AUTOINCREMENT,
  venta_id TEXT NOT NULL UNIQUE,
  payload TEXT NOT NULL,
  intentos INTEGER NOT NULL DEFAULT 0,
  estado TEXT NOT NULL DEFAULT 'PENDIENTE',
  clave_acceso TEXT
);

// worker.mjs: procesa la cola de comprobantes pendientes del POS
const BASE_URL = "https://api.flashpi.ec/v1";
const API_KEY = process.env.FLASHPI_API_KEY;
const MAX_INTENTOS = 8;

async function emitir(pendiente) {
  const res = await fetch(`${BASE_URL}/facturas`, {
    method: "POST",
    headers: {
      Authorization: `Bearer ${API_KEY}`,
      "Content-Type": "application/json",
    },
    body: pendiente.payload,
  });
  const data = await res.json();
  if (!res.ok) throw new Error(`Flashpi ${res.status}`);
  return data;
}

// Ejecútala cada pocos segundos con tu planificador de tareas
export async function procesarCola(db) {
  const pendientes = await db.pendientes(20); // tu capa de acceso a datos

  for (const p of pendientes) {
    try {
      // Si un intento anterior pudo llegar al SRI y perdiste la respuesta,
      // consulta el estado antes de reenviar para no duplicar el comprobante.
      const r = await emitir(p);
      await db.marcarEmitido(p.id, r.clave_acceso, r.estado);
    } catch (err) {
      const intentos = p.intentos + 1;
      const estado = intentos >= MAX_INTENTOS ? "REVISAR" : "PENDIENTE";
      await db.registrarFallo(p.id, intentos, estado);
    }
  }
}

{
  "estado": "AUTORIZADO",
  "clave_acceso": "(49 dígitos)",
  "numero_autorizacion": "(número de autorización del SRI)",
  "fecha_autorizacion": "(fecha y hora)"
}