// Supabase Edge Function: factura-inbound // Recibe webhook de Resend/Postmark con email del proveedor // Parsea XML CFDI adjunto, hace match con OCs, guarda resultado import { createClient } from "https://esm.sh/@supabase/supabase-js@2"; Deno.serve(async (req) => { const db = createClient( Deno.env.get("SUPABASE_URL"), Deno.env.get("SUPABASE_SERVICE_ROLE_KEY") ); const payload = await req.json(); // Extract email data (Resend format) const from = payload.from || payload.From || ""; const subject = payload.subject || payload.Subject || ""; const attachments = payload.attachments || payload.Attachments || []; let cfdiData = null; // Parse XML attachment (CFDI) for (const att of attachments) { const name = (att.filename || att.Name || "").toLowerCase(); if (name.endsWith(".xml")) { const content = att.content || att.Content || ""; const xmlStr = typeof content === "string" ? content.includes("base64") ? atob(content.split(",")[1] || content) : content : new TextDecoder().decode(Uint8Array.from(atob(content), c => c.charCodeAt(0))); cfdiData = parseCFDI(xmlStr); break; } } if (!cfdiData) { return new Response(JSON.stringify({ ok: false, error: "No XML CFDI found" }), { status: 200 }); } // Match against OCs const { data: ocs } = await db .from("compras_ordenes") .select("*") .eq("estado", "Pendiente") .eq("proveedor_email", from.split("<").pop().replace(">", "").trim()); const matchResult = matchCFDIvsOC(cfdiData, ocs || []); // Save to compras_facturas_inbox await db.from("compras_facturas_inbox").insert({ uuid_cfdi: cfdiData.uuid, emisor_rfc: cfdiData.rfcEmisor, emisor_nombre: cfdiData.nombreEmisor, receptor_rfc: cfdiData.rfcReceptor, fecha: cfdiData.fecha, subtotal: cfdiData.subtotal, total: cfdiData.total, moneda: cfdiData.moneda, concepto: cfdiData.concepto, email_origen: from, subject: subject, oc_match: matchResult.ocNum, match_status: matchResult.status, match_detalle: JSON.stringify(matchResult.checks), xml_raw: cfdiData.xmlRaw?.substring(0, 5000), estado: matchResult.status === "match" ? "Match automático" : "Requiere revisión" }); return new Response(JSON.stringify({ ok: true, match: matchResult }), { status: 200 }); }); function parseCFDI(xml) { const get = (tag) => xml.match(new RegExp(tag + '[^>]*>([^<]*)', 'i'))?.[1]?.trim() || ""; const attr = (tag, att) => xml.match(new RegExp('<(?:cfdi:)?'+tag+'[^>]+'+att+'="([^"]+)"', 'i'))?.[1] || ""; return { uuid: attr("Complemento", "UUID") || xml.match(/UUID="([^"]+)"/i)?.[1] || "", rfcEmisor: attr("Emisor", "Rfc") || xml.match(/Emisor[^>]+Rfc="([^"]+)"/i)?.[1] || "", nombreEmisor: attr("Emisor", "Nombre") || "", rfcReceptor: attr("Receptor", "Rfc") || "", fecha: attr("Comprobante", "Fecha")?.slice(0,10) || "", subtotal: parseFloat(attr("Comprobante", "SubTotal")) || 0, total: parseFloat(attr("Comprobante", "Total")) || 0, moneda: attr("Comprobante", "Moneda") || "MXN", concepto: attr("Concepto", "Descripcion") || "", xmlRaw: xml }; } function matchCFDIvsOC(cfdi, ocs) { if (!ocs.length) return { status: "sin_oc", ocNum: null, checks: ["Sin OCs pendientes para este proveedor"] }; for (const oc of ocs) { const diff = Math.abs((oc.total || 0) - cfdi.total) / Math.max(oc.total || 1, 1); if (diff < 0.05) { return { status: "match", ocNum: oc.numero_oc, checks: [`Monto coincide: $${cfdi.total} vs OC $${oc.total}`, `RFC: ${cfdi.rfcEmisor}`] }; } } return { status: "no_match", ocNum: null, checks: [`Total CFDI $${cfdi.total} no coincide con ninguna OC pendiente`] }; }