Método Async — Frontend / Backend

import { EcfClient } from "@ssddo/ecf-sdk";

const ecfClient = new EcfClient({
apiKey: process.env.ECF_BACKEND_TOKEN,
environment: "prod",
});

// Endpoint de facturación — envía y retorna inmediatamente
app.post("/api/v1/invoices", async (req, res) => {
const invoice = await validateAndSave(req.body);

// Construir el ECF desde tu modelo de negocio
const ecf = {
  encabezado: {
    idDoc: {
      tipoeCF: "FacturaDeCreditoFiscalElectronica",
      encf: invoice.encf,
    },
    emisor: {
      rncEmisor: tenant.rnc,
      razonSocialEmisor: tenant.razonSocial,
      direccionEmisor: tenant.direccion,
      fechaEmision: new Date().toISOString(),
    },
    comprador: {
      rncComprador: invoice.clienteRnc,
      razonSocialComprador: invoice.clienteNombre,
    },
    totales: {
      montoGravadoTotal: invoice.subtotal,
      totalITBIS: invoice.itbis,
      montoTotal: invoice.total,
    },
  },
  detallesItems: invoice.items.map((item) => ({
    nombreItem: item.nombre,
    indicadorFacturacion: 3,
    cantidadItem: item.cantidad,
    precioUnitarioItem: item.precio,
    montoItem: item.cantidad * item.precio,
  })),
};

// POST directo al API — NO usa sendEcf (que haría polling)
const { data } = await ecfClient.raw.POST("/ecf/31", { body: ecf });

// Guardar el messageId para tracking
await updateInvoice(invoice.id, { messageId: data.messageId });

// Retornar inmediatamente — el frontend hará el polling
res.json({
  id: invoice.id,
  messageId: data.messageId,
  rnc: tenant.rnc,
  encf: invoice.encf,
});
});

// Endpoint para generar token de solo lectura para el frontend
app.get("/api/v1/ecf-token", async (req, res) => {
const { data } = await ecfClient.createApiKey({
  rnc: tenant.rnc,
});
res.json({ apiKey: data.token });
});

import { createEcfFrontendReactClient } from "@ssddo/ecf-react";

// 1. Crear cliente de solo lectura
//    getToken se llama automáticamente cuando se necesita
const { $api } = createEcfFrontendReactClient({
environment: "prod",
getToken: async () => {
  const res = await fetch("/api/v1/ecf-token");
  const { apiKey } = await res.json();
  return apiKey;
},
});

// 2. Componente para enviar la factura al backend
function EnviarFactura() {
const handleSubmit = async (invoiceData) => {
  const res = await fetch("/api/v1/invoices", {
    method: "POST",
    headers: { "Content-Type": "application/json" },
    body: JSON.stringify(invoiceData),
  });
  const { rnc, encf } = await res.json();

  // No espera — navega a la página de estado
  navigate(`/ecf-status/${rnc}/${encf}`);
};

return <button onClick={() => handleSubmit(datos)}>Enviar factura</button>;
}

// 3. Componente que hace polling del estado en tiempo real
function EstadoEcf({ rnc, encf }: { rnc: string; encf: string }) {
const { data } = $api.useQuery("get", "/ecf/{rnc}/{encf}", {
  params: { path: { rnc, encf } },
  refetchInterval: 3000, // Consulta cada 3 segundos
});

if (!data) return <p>Conectando...</p>;

if (data.progress === "Finished") {
  return (
    <div>
      <h2>Comprobante aceptado</h2>
      <p>Código de seguridad: {data.codSec}</p>
      <p>Fecha de firma: {data.fechaFirma}</p>
      <QRCode value={data.impresionUrl} />
    </div>
  );
}

if (data.progress === "Error") {
  return <p>Error: {data.mensaje}</p>;
}

// Muestra progreso en tiempo real
return (
  <div>
    <p>Procesando comprobante...</p>
    <p>Estado: {data.progress}</p>
    {/* Queued → Sending → Polling → Finished */}
  </div>
);
}

import { createFrontendClient } from "@ssddo/ecf-sdk";

const frontend = createFrontendClient({
environment: "prod",
getToken: async () => {
  const res = await fetch("/api/v1/ecf-token");
  const { apiKey } = await res.json();
  return apiKey;
},
});

// Polling manual
async function esperarResultado(rnc: string, encf: string) {
let result;
do {
  const { data } = await frontend.raw.GET("/ecf/{rnc}/{encf}", {
    params: { path: { rnc, encf } },
  });
  result = data;

  if (result.progress === "Finished") {
    console.log("Código seguridad:", result.codSec);
    console.log("QR:", result.impresionUrl);
    return result;
  }

  if (result.progress === "Error") {
    throw new Error(result.mensaje);
  }

  // Esperar antes de reintentar
  await new Promise((r) => setTimeout(r, 3000));
} while (true);
}