Shopify: one webhook, a service in the middle and an invoice

import crypto from "node:crypto";

const BASE = "https://erp.cairos.es/api/v1";

// 1 · La firma de Shopify: HMAC-SHA256 en base64 del cuerpo
//     crudo, con el secreto de tu aplicación. Cuerpo CRUDO:
//     si lo reserializas, no cuadra.
function deShopify(crudo, firma, secreto) {
  const esperada = crypto
    .createHmac("sha256", secreto)
    .update(crudo, "utf8")
    .digest("base64");
  const a = Buffer.from(esperada);
  const b = Buffer.from(String(firma));
  return a.length === b.length && crypto.timingSafeEqual(a, b);
}

async function cairos(ruta, cuerpo, llave) {
  const cabeceras = {
    Authorization: "Bearer " + process.env.CAIROS_CLAVE,
    "Content-Type": "application/json",
  };
  if (llave) cabeceras["Idempotency-Key"] = llave;

  const r = await fetch(BASE + ruta, {
    method: "POST",
    headers: cabeceras,
    body: cuerpo ? JSON.stringify(cuerpo) : undefined,
  });

  const datos = await r.json();
  if (!r.ok) {
    throw new Error("Cairos " + r.status + ": " + datos.error.codigo);
  }
  return datos;
}

export async function handler(peticion) {
  const crudo = await peticion.text();

  if (!deShopify(crudo, peticion.headers.get("x-shopify-hmac-sha256"),
                 process.env.SHOPIFY_SECRETO)) {
    return new Response("Firma no valida", { status: 401 });
  }

  const pedido = JSON.parse(crudo);
  const llave = "shopify-" + pedido.id;

  // "tipo" es un enumerado en ingles: customer o supplier.
  const contacto = await cairos("/contactos/upsert", {
    nombre: pedido.billing_address.company || pedido.billing_address.name,
    nif: (pedido.note_attributes || [])
      .find((a) => a.name === "nif")?.value,
    email: pedido.email,
    tipo: "customer",
    buscar_por: "email",
  }, llave + "-contacto");

  // El texto de la linea es "descripcion" y el impuesto
  // "tipo_iva". "concepto" e "iva" no existen: 422.
  const lineas = pedido.line_items.map((l) => ({
    descripcion: l.title,
    cantidad: l.quantity,
    precio: Number(l.price),
    tipo_iva: 21,
  }));

  const factura = await cairos("/facturas", {
    contacto_id: contacto.id,
    serie: "WEB",
    fecha_emision: pedido.created_at.slice(0, 10),
    // El precio de Shopify es el del escaparate, con el IVA
    // dentro: que lo desglose el servidor y no un nodo tuyo.
    precios_con_iva: true,
    lineas,
  }, llave);

  const emitida = await cairos(
    "/facturas/" + factura.id + "/emitir",
    null,
    llave + "-emitir"
  );

  await cairos("/cobros", {
    factura_id: factura.id,
    fecha: pedido.created_at.slice(0, 10),
    importe: Number(pedido.total_price),
    metodo: "card",
    notas: "Shopify · pedido " + pedido.name,
  }, llave + "-cobro");

  // Responder rápido: Shopify reintenta si tardas.
  // "referencia" es lo que se imprime; "numero" es un entero.
  return Response.json({ referencia: emitida.referencia });
}