unit uUnitaGoClient;

{==============================================================================
  INTEGRACIÓN OFICIAL UNITAGO AI MIDDLEWARE PARA ERP EN DELPHI
  Compatible con: Delphi XE8, 10 Seattle, 10.1 Berlin, 10.2 Tokyo,
                  10.3 Rio, 10.4 Sydney, 11 Alexandria, 12 Athens.
  Utiliza System.Net.HttpClient (WinHTTP nativo, sin DLLs externas de OpenSSL)
 ==============================================================================}

interface

uses
  System.SysUtils, System.Classes, System.Net.HttpClient, System.Net.Mime, 
  System.Net.URLClient, System.JSON;

type
  EUnitaGoException = class(Exception);

  /// 

  /// Cliente para el envío y extracción con IA de facturas de compras
  /// 
  TUnitaGoClient = class
  private
    FBaseUrl: string;
    FApiKey: string;
    FTimeoutMs: Integer;
  public
    constructor Create(const ABaseUrl, AApiKey: string; ATimeoutMs: Integer = 60000);
    
    /// 

    /// Envía la factura escaneada y devuelve el TJSONObject 'data' estructurado.
    /// Es responsabilidad del llamador liberar el objeto resultante (Result.Free).
    /// 
    function ProcesarFactura(const ARutaArchivo: string; const AInvoiceIdErp: string = ''; const AModelo: string = ''): TJSONObject;
    
    /// 

    /// Consulta el saldo y presupuesto disponible del mes en curso para el ERP.
    /// 
    function ConsultarConsumoMes: TJSONObject;
  end;

implementation

constructor TUnitaGoClient.Create(const ABaseUrl, AApiKey: string; ATimeoutMs: Integer);
begin
  inherited Create;
  FBaseUrl := ABaseUrl.TrimRight(['/']);
  FApiKey := AApiKey;
  FTimeoutMs := ATimeoutMs;
end;

function TUnitaGoClient.ProcesarFactura(const ARutaArchivo, AInvoiceIdErp, AModelo: string): TJSONObject;
var
  LHttpClient: THTTPClient;
  LMultipart: TMultipartFormData;
  LResponse: IHTTPResponse;
  LJsonRoot: TJSONObject;
  LData: TJSONObject;
  LUrl: string;
begin
  Result := nil;
  if not FileExists(ARutaArchivo) then
    raise EUnitaGoException.CreateFmt('No existe el archivo de factura: %s', [ARutaArchivo]);

  LHttpClient := THTTPClient.Create;
  LMultipart := TMultipartFormData.Create;
  try
    LHttpClient.ConnectionTimeout := 20000;
    LHttpClient.ResponseTimeout   := FTimeoutMs;

    // 1. Cabecera obligatoria de autenticación por empresa
    LHttpClient.CustomHeaders['X-API-Key'] := FApiKey;

    // 2. Adjuntar el archivo escaneado (campo multipart 'file')
    LMultipart.AddFile('file', ARutaArchivo);

    // 3. Parámetros opcionales para trazabilidad
    if AInvoiceIdErp <> '' then
      LMultipart.AddField('invoiceIdErp', AInvoiceIdErp);

    if AModelo <> '' then
      LMultipart.AddField('model', AModelo);

    // 4. Invocación HTTP POST
    LUrl := FBaseUrl + '/api/v1/invoices/process';
    LResponse := LHttpClient.Post(LUrl, LMultipart);

    // 5. Validar respuesta y parsear JSON
    if LResponse.StatusCode <> 200 then
      raise EUnitaGoException.CreateFmt('Error HTTP %d desde UnitaGo: %s', 
        [LResponse.StatusCode, LResponse.ContentAsString(TEncoding.UTF8)]);

    LJsonRoot := TJSONObject.ParseJSONValue(LResponse.ContentAsString(TEncoding.UTF8)) as TJSONObject;
    if not Assigned(LJsonRoot) then
      raise EUnitaGoException.Create('La respuesta del servidor no es un JSON válido');

    try
      if not LJsonRoot.GetValue('success', False) then
        raise EUnitaGoException.CreateFmt('Fallo de extracción IA: %s', 
          [LJsonRoot.GetValue('message', 'Error desconocido')]);

      LData := LJsonRoot.GetValue('data');
      if not Assigned(LData) then
        raise EUnitaGoException.Create('No se encontró el nodo "data" en la respuesta');

      Result := LData.Clone as TJSONObject;
    finally
      LJsonRoot.Free;
    end;

  finally
    LMultipart.Free;
    LHttpClient.Free;
  end;
end;

function TUnitaGoClient.ConsultarConsumoMes: TJSONObject;
var
  LHttpClient: THTTPClient;
  LResponse: IHTTPResponse;
begin
  Result := nil;
  LHttpClient := THTTPClient.Create;
  try
    LHttpClient.CustomHeaders['X-API-Key'] := FApiKey;
    LResponse := LHttpClient.Get(FBaseUrl + '/api/v1/invoices/my-usage');
    if LResponse.StatusCode = 200 then
      Result := TJSONObject.ParseJSONValue(LResponse.ContentAsString(TEncoding.UTF8)) as TJSONObject;
  finally
    LHttpClient.Free;
  end;
end;

// =========================================================================
// EJEMPLO DE USO DESDE UN FORMULARIO O DATASET DEL ERP:
// =========================================================================
{
procedure TfrmFacturasCompra.btnEscanearFacturaClick(Sender: TObject);
var
  LClient: TUnitaGoClient;
  LFactura: TJSONObject;
  LEmisor, LDatosFactura, LTotales, LLinea: TJSONObject;
  LLineas: TJSONArray;
  I: Integer;
begin
  LClient := TUnitaGoClient.Create(
    'http://localhost:3000', // En producción: https://ia.tudominio.com
    'ndg_live_demo_1234567890abcdef1234567890abcdef'
  );
  try
    Screen.Cursor := crHourGlass;
    try
      LFactura := LClient.ProcesarFactura('C:\Scans\Factura_001.pdf', 'DOC-ERP-2026');
      try
        LEmisor       := LFactura.GetValue('emisor');
        LDatosFactura := LFactura.GetValue('factura');
        LTotales      := LFactura.GetValue('totales');

        // Asignación directa a tablas contables del ERP (ej: FireDAC / Zeos / ADO):
        qryFacturas.Append;
        qryFacturas.FieldByName('PROV_NOMBRE').AsString := LEmisor.GetValue('razon_social', '');
        qryFacturas.FieldByName('PROV_CIF').AsString    := LEmisor.GetValue('cif_nif', '');
        qryFacturas.FieldByName('NUM_FACTURA').AsString := LDatosFactura.GetValue('numero_factura', '');
        qryFacturas.FieldByName('FECHA').AsString       := LDatosFactura.GetValue('fecha_emision', '');
        qryFacturas.FieldByName('IBAN').AsString        := LDatosFactura.GetValue('iban', '');
        qryFacturas.FieldByName('BASE_IMPONIBLE').AsFloat := LTotales.GetValue('subtotal_base_imponible', 0);
        qryFacturas.FieldByName('TOTAL_IVA').AsFloat    := LTotales.GetValue('total_iva', 0);
        qryFacturas.FieldByName('TOTAL_FACT').AsFloat   := LTotales.GetValue('total_factura', 0);
        qryFacturas.Post;

        // Líneas de artículos:
        LLineas := LFactura.GetValue('lineas_detalle');
        if Assigned(LLineas) then
        begin
          for I := 0 to LLineas.Count - 1 do
          begin
            LLinea := LLineas.Items[I] as TJSONObject;
            qryLineas.Append;
            qryLineas.FieldByName('DESCRIPCION').AsString := LLinea.GetValue('descripcion', '');
            qryLineas.FieldByName('REFERENCIA').AsString  := LLinea.GetValue('referencia', '');
            qryLineas.FieldByName('CANTIDAD').AsFloat     := LLinea.GetValue('cantidad', 1);
            qryLineas.FieldByName('PRECIO').AsFloat       := LLinea.GetValue('precio_unitario', 0);
            qryLineas.FieldByName('TOTAL').AsFloat        := LLinea.GetValue('importe_linea', 0);
            qryLineas.Post;
          end;
        end;

        ShowMessage('Factura contabilizada automáticamente con éxito.');
      finally
        LFactura.Free;
      end;
    finally
      Screen.Cursor := crDefault;
    end;
  finally
    LClient.Free;
  end;
end;
}
end.

unit uFormNeoCopilot;

{==============================================================================
  INTEGRACIÓN DE NEO COPILOTO / PORTAL EN FORMULARIO DELPHI (VCL / FIREMONKEY)
  Permite incrustar el Asistente IA Neo Copilot o el Portal de Facturas
  dentro de cualquier ventana (TForm) o panel dockeado del ERP de escritorio.
  
  Componente recomendado: TEdgeBrowser (WebView2 Chromium nativo)
  Disponible en: Delphi 10.4 Sydney, 11 Alexandria, 12 Athens y posteriores.
  Requisito en cliente: Microsoft Edge WebView2 Runtime (incluido en Windows 10/11).
  Alternativa en versiones anteriores: TWebBrowser o CEF4Delphi.
 ==============================================================================}

interface

uses
  Winapi.Windows, Winapi.Messages, System.SysUtils, System.Variants, 
  System.Classes, Vcl.Graphics, Vcl.Controls, Vcl.Forms, Vcl.Dialogs,
  Vcl.ExtCtrls, Vcl.StdCtrls, Winapi.WebView2, Winapi.ActiveX, Vcl.Edge,
  System.Net.HttpClient, System.Net.Mime;

type
  /// 

  /// Modos de visualización del asistente embebido dentro del ERP
  /// 
  TModoCopiloto = (
    mcAsistenteFlotante, // Carga el portal con el asistente Neo Copilot activo en modo embebido
    mcScannerDirecto,    // Carga el escáner rápido de facturas para arrastrar archivos en el ERP
    mcPortalCompleto     // Carga el portal de cliente con métricas, consumos y catálogo
  );

  TFormNeoCopilot = class(TForm)
    PnlTop: TPanel;
    LblTitulo: TLabel;
    BtnRecargar: TButton;
    BtnCerrar: TButton;
    EdgeBrowserCopilot: TEdgeBrowser;
    procedure FormCreate(Sender: TObject);
    procedure FormShow(Sender: TObject);
    procedure BtnRecargarClick(Sender: TObject);
    procedure BtnCerrarClick(Sender: TObject);
    procedure EdgeBrowserCopilotCreateWebViewCompleted(Sender: TCustomEdgeBrowser; AStatus: HRESULT);
  private
    FBaseUrl: string;
    FApiKey: string;
    FModoActual: TModoCopiloto;
    FWebViewListo: Boolean;
    function ConstruirUrlDestino(AModo: TModoCopiloto): string;
  public
    /// 

    /// Configura y navega a la URL con tu token de empresa y modo embebido
    /// 
    procedure CargarCopiloto(const AApiKey: string = ''; AModo: TModoCopiloto = mcAsistenteFlotante);
    
    /// 

    /// Permite inyectar preguntas o contexto desde el ERP directamente al JavaScript de Neo Copilot
    /// 
    procedure EnviarMensajeACopilot(const AMensaje: string);
  end;

var
  FormNeoCopilot: TFormNeoCopilot;

implementation

{$R *.dfm}

procedure TFormNeoCopilot.FormCreate(Sender: TObject);
begin
  // URL base del servidor UnitaGo (ej: http://localhost:3000 o https://ia.tudominio.com)
  FBaseUrl := 'https://ia.tudominio.com';
  FApiKey := 'ndg_live_demo_1234567890abcdef1234567890abcdef';
  FModoActual := mcAsistenteFlotante;
  FWebViewListo := False;

  // Ajustes del componente en el formulario
  EdgeBrowserCopilot.Align := alClient;
end;

procedure TFormNeoCopilot.FormShow(Sender: TObject);
begin
  if FWebViewListo then
    EdgeBrowserCopilot.Navigate(ConstruirUrlDestino(FModoActual));
end;

procedure TFormNeoCopilot.EdgeBrowserCopilotCreateWebViewCompleted(
  Sender: TCustomEdgeBrowser; AStatus: HRESULT);
begin
  if Succeeded(AStatus) then
  begin
    FWebViewListo := True;
    // Navegar en cuanto WebView2 termine de inicializar su hilo
    EdgeBrowserCopilot.Navigate(ConstruirUrlDestino(FModoActual));
  end
  else
  begin
    ShowMessage('Aviso: No se pudo inicializar WebView2. ' +
                'Asegúrese de tener instalado Microsoft Edge WebView2 Runtime.');
  end;
end;

function TFormNeoCopilot.ConstruirUrlDestino(AModo: TModoCopiloto): string;
var
  LToken: string;
  LRuta: string;
begin
  LToken := Trim(FApiKey);
  
  case AModo of
    mcScannerDirecto:
      LRuta := '/scanner';
    mcPortalCompleto:
      LRuta := '/portal';
    else
      // Modo Asistente / Copiloto embebido (sin barras superiores web)
      LRuta := '/portal';
  end;

  // El parámetro embed=true optimiza la interfaz ocultando cabeceras web
  Result := Format('%s%s?token=%s&embed=true', [FBaseUrl, LRuta, LToken]);
end;

procedure TFormNeoCopilot.CargarCopiloto(const AApiKey: string; AModo: TModoCopiloto);
begin
  if AApiKey <> '' then
    FApiKey := AApiKey;
  FModoActual := AModo;

  if FWebViewListo then
    EdgeBrowserCopilot.Navigate(ConstruirUrlDestino(FModoActual));
end;

procedure TFormNeoCopilot.EnviarMensajeACopilot(const AMensaje: string);
var
  LJsCode: string;
  LMsgEscapado: string;
begin
  if not FWebViewListo then Exit;

  // Escapar comillas para la inyección JavaScript
  LMsgEscapado := AMensaje.Replace('\', '\\').Replace('''', '\''').Replace(#13#10, '\n');

  // Invocar al objeto global de Neo Copilot en la ventana web
  LJsCode := Format('if (window.NeoCopilot) { window.NeoCopilot.ask("%s"); }', [LMsgEscapado]);
  EdgeBrowserCopilot.ExecuteScript(LJsCode);
end;

procedure TFormNeoCopilot.BtnRecargarClick(Sender: TObject);
begin
  if FWebViewListo then
    EdgeBrowserCopilot.Navigate(ConstruirUrlDestino(FModoActual));
end;

procedure TFormNeoCopilot.BtnCerrarClick(Sender: TObject);
begin
  Close;
end;

{==============================================================================
  EJEMPLO 1: ABRIR EL COPILOTO EN VENTANA MODAL O FLOTANTE DESDE EL MENÚ ERP
 ==============================================================================}
procedure AbrirVentanaCopilotoDesdeERP(const ATokenEmpresa: string);
var
  LFrm: TFormNeoCopilot;
begin
  LFrm := TFormNeoCopilot.Create(Application);
  try
    LFrm.Caption := 'Neo Copilot - Asistente de Inteligencia Artificial';
    LFrm.Width := 460;
    LFrm.Height := 720;
    LFrm.Position := poScreenCenter;
    LFrm.CargarCopiloto(ATokenEmpresa, mcAsistenteFlotante);
    LFrm.ShowModal;
  finally
    LFrm.Free;
  end;
end;

{==============================================================================
  EJEMPLO 2: INCRUSTAR EL COPILOTO DIRECTAMENTE EN UN PANEL DOCKED DE TFORMPRINCIPAL
 ==============================================================================}
procedure IncrustarCopilotEnPanel(APanelContenedor: TPanel; const AToken: string);
var
  LEdge: TEdgeBrowser;
  LUrl: string;
begin
  LEdge := TEdgeBrowser.Create(APanelContenedor);
  LEdge.Parent := APanelContenedor;
  LEdge.Align := alClient;
  
  // URL embebida oficial con tu clave de empresa
  LUrl := 'https://ia.tudominio.com/portal?token=' + AToken + '&embed=true';
  LEdge.Navigate(LUrl);
end;

end.

{==============================================================================
  ALTERNATIVA INDY (TIdHTTP) PARA VERSIONES ANTERIORES DE DELPHI
  Uses: IdHTTP, IdMultipartFormData, IdSSLOpenSSL;
  Requiere las DLLs de OpenSSL (libeay32.dll y ssleay32.dll) junto al ejecutable.
 ==============================================================================}

function ProcesarFacturaIndy(const ARutaArchivo, AApiKey: string; const AInvoiceIdErp: string = ''): string;
var
  LIdHTTP: TIdHTTP;
  LIdSSL: TIdSSLIOHandlerSocketOpenSSL;
  LFormData: TIdMultiPartFormDataStream;
  LResponseJsonStr: string;
begin
  Result := '';
  if not FileExists(ARutaArchivo) then
    raise Exception.CreateFmt('No existe el archivo: %s', [ARutaArchivo]);

  LIdHTTP := TIdHTTP.Create(nil);
  LIdSSL := TIdSSLIOHandlerSocketOpenSSL.Create(nil);
  LFormData := TIdMultiPartFormDataStream.Create;
  try
    // Configuración SSL/TLS
    LIdSSL.SSLOptions.Method := sslvTLSv1_2;
    LIdSSL.SSLOptions.SSLVersions := [sslvTLSv1_2];
    LIdHTTP.IOHandler := LIdSSL;
    LIdHTTP.ReadTimeout := 60000;
    LIdHTTP.ConnectTimeout := 20000;

    // Cabecera X-API-Key obligatoria
    LIdHTTP.Request.CustomHeaders.Values['X-API-Key'] := AApiKey;

    // Adjuntar archivo en el campo 'file'
    LFormData.AddFile('file', ARutaArchivo, 'application/octet-stream');

    if AInvoiceIdErp <> '' then
      LFormData.AddFormField('invoiceIdErp', AInvoiceIdErp);

    // En producción: https://ia.tudominio.com/api/v1/invoices/process
    LResponseJsonStr := LIdHTTP.Post('http://localhost:3000/api/v1/invoices/process', LFormData);
    Result := LResponseJsonStr;

  finally
    LFormData.Free;
    LIdSSL.Free;
    LIdHTTP.Free;
  end;
end;

<?php
/**
 * Integración UnitaGo AI desde PHP para el ERP
 * Envía un archivo escaneado y retorna el JSON estructurado
 */
function procesarFacturaConUnitaGo($rutaArchivo, $apiKey, $invoiceIdErp = null) {
    // En producción cambiar por la URL del hosting (ej: https://ia.tudominio.com/api/v1/invoices/process)
    $url = 'http://localhost:3000/api/v1/invoices/process';

    if (!file_exists($rutaArchivo)) {
        throw new InvalidArgumentException("El archivo no existe: " . $rutaArchivo);
    }

    $cFile = new CURLFile($rutaArchivo);
    $postData = [
        'file' => $cFile
    ];

    if ($invoiceIdErp) {
        $postData['invoiceIdErp'] = $invoiceIdErp;
    }

    $ch = curl_init();
    curl_setopt_array($ch, [
        CURLOPT_URL => $url,
        CURLOPT_POST => true,
        CURLOPT_POSTFIELDS => $postData,
        CURLOPT_RETURNTRANSFER => true,
        CURLOPT_HTTPHEADER => [
            'X-API-Key: ' . $apiKey
        ],
        CURLOPT_TIMEOUT => 60
    ]);

    $response = curl_exec($ch);
    $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    $curlError = curl_error($ch);
    curl_close($ch);

    if ($curlError) {
        throw new Exception("Error de conexión cURL: " . $curlError);
    }

    $resultado = json_decode($response, true);

    if ($httpCode !== 200 || empty($resultado['success'])) {
        $msg = $resultado['message'] ?? 'Error desconocido del servidor';
        throw new Exception("Error UnitaGo ({$httpCode}): " . $msg);
    }

    // Datos listos para insertar en el ERP:
    return $resultado['data'];
}

// ==========================================
// Ejemplo de llamada desde el módulo contable:
// ==========================================
try {
    $apiKey = 'ndg_live_demo_1234567890abcdef1234567890abcdef';
    $rutaPdf = '/var/scans/factura_compra_001.pdf';

    $factura = procesarFacturaConUnitaGo($rutaPdf, $apiKey, 'ERP-DOC-2026-901');

    echo "=== FACTURA PROCESADA EXITOSAMENTE ===\n";
    echo "Proveedor: " . $factura['emisor']['razon_social'] . " (CIF: " . $factura['emisor']['cif_nif'] . ")\n";
    echo "Número Factura: " . $factura['factura']['numero_factura'] . "\n";
    echo "Fecha Emisión: " . $factura['factura']['fecha_emision'] . "\n";
    echo "Base Imponible: " . $factura['totales']['subtotal_base_imponible'] . " €\n";
    echo "Total Factura: " . $factura['totales']['total_factura'] . " €\n";
    echo "IBAN para pago: " . ($factura['factura']['iban'] ?? 'No especificado') . "\n";

} catch (Exception $e) {
    echo "Fallo en procesamiento: " . $e->getMessage() . "\n";
}

using System;
using System.IO;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Threading.Tasks;
using System.Text.Json;

public class UnitaGoClient
{
    private readonly HttpClient _httpClient;
    private readonly string _apiKey;

    public UnitaGoClient(string baseUrl, string apiKey)
    {
        _httpClient = new HttpClient { BaseAddress = new Uri(baseUrl) };
        _apiKey = apiKey;
    }

    /// <summary>
    /// Envía un documento de compra a procesar con IA
    /// </summary>
    public async Task<JsonElement> ProcesarFacturaAsync(string filePath, string invoiceIdErp = null)
    {
        if (!File.Exists(filePath))
            throw new FileNotFoundException("Archivo de factura no encontrado", filePath);

        using var form = new MultipartFormDataContent();
        
        using var fileStream = File.OpenRead(filePath);
        using var streamContent = new StreamContent(fileStream);
        
        // Detectar mime type básico
        string ext = Path.GetExtension(filePath).ToLower();
        string mime = ext == ".pdf" ? "application/pdf" : "image/jpeg";
        streamContent.Headers.ContentType = new MediaTypeHeaderValue(mime);
        
        form.Add(streamContent, "file", Path.GetFileName(filePath));
        
        if (!string.IsNullOrEmpty(invoiceIdErp))
        {
            form.Add(new StringContent(invoiceIdErp), "invoiceIdErp");
        }

        using var request = new HttpRequestMessage(HttpMethod.Post, "/api/v1/invoices/process")
        {
            Content = form
        };
        request.Headers.Add("X-API-Key", _apiKey);

        var response = await _httpClient.SendAsync(request);
        var responseString = await response.Content.ReadAsStringAsync();

        if (!response.IsSuccessStatusCode)
        {
            throw new HttpRequestException($"Error UnitaGo ({response.StatusCode}): {responseString}");
        }

        using var doc = JsonDocument.Parse(responseString);
        return doc.RootElement.GetProperty("data").Clone();
    }
}

// Ejemplo de uso en .NET / C#:
// var client = new UnitaGoClient("http://localhost:3000", "ndg_live_demo_1234567890abcdef1234567890abcdef");
// var datosFactura = await client.ProcesarFacturaAsync(@"C:\Escaneos\factura.pdf", "FAC-2026-001");
// Console.WriteLine(datosFactura.GetProperty("factura").GetProperty("numero_factura").GetString());

import requests

def procesar_factura_unitago(ruta_archivo, api_key, invoice_id_erp=None, base_url="http://localhost:3000"):
    """
    Envía una factura al middleware UnitaGo y retorna el JSON estructurado.
    """
    endpoint = f"{base_url}/api/v1/invoices/process"
    headers = {
        "X-API-Key": api_key
    }
    
    with open(ruta_archivo, "rb") as f:
        # Detectar mimetype
        mime_type = "application/pdf" if ruta_archivo.endswith(".pdf") else "image/jpeg"
        files = {
            "file": (ruta_archivo, f, mime_type)
        }
        data = {}
        if invoice_id_erp:
            data["invoiceIdErp"] = invoice_id_erp
            
        res = requests.post(endpoint, headers=headers, files=files, data=data, timeout=60)
        
    if res.status_code != 200:
        raise Exception(f"Error UnitaGo ({res.status_code}): {res.text}")
        
    respuesta = res.json()
    if not respuesta.get("success"):
        raise Exception(f"Fallo en extracción: {respuesta.get('message')}")
        
    return respuesta["data"]

# Ejemplo de uso:
if __name__ == "__main__":
    TOKEN = "ndg_live_demo_1234567890abcdef1234567890abcdef"
    datos = procesar_factura_unitago("factura_compra.pdf", TOKEN, invoice_id_erp="ERP-PY-01")
    
    print(f"Emisor: {datos['emisor']['razon_social']}")
    print(f"NIF: {datos['emisor']['cif_nif']}")
    print(f"Total: {datos['totales']['total_factura']} {datos['totales']['moneda']}")

import fs from 'fs';
import FormData from 'form-data';
import fetch from 'node-fetch';

/**
 * Función para Node.js / Backend de ERP
 */
async function procesarFacturaConUnitaGo(filePath, apiKey, invoiceIdErp = null) {
  const form = new FormData();
  form.append('file', fs.createReadStream(filePath));
  
  if (invoiceIdErp) {
    form.append('invoiceIdErp', invoiceIdErp);
  }

  const res = await fetch('http://localhost:3000/api/v1/invoices/process', {
    method: 'POST',
    headers: {
      'X-API-Key': apiKey,
      ...form.getHeaders()
    },
    body: form
  });

  const json = await res.json();
  if (!res.ok || !json.success) {
    throw new Error(`Error UnitaGo (${res.status}): ${json.message || 'Desconocido'}`);
  }

  return json.data;
}

// Ejemplo:
// const data = await procesarFacturaConUnitaGo('./factura.pdf', 'ndg_live_demo_1234567890abcdef1234567890abcdef');
// console.log('Total factura:', data.totales.total_factura);

# Prueba rápida de envío de factura desde terminal:
curl -X POST http://localhost:3000/api/v1/invoices/process \
  -H "X-API-Key: ndg_live_demo_1234567890abcdef1234567890abcdef" \
  -F "file=@factura_proveedor.pdf" \
  -F "invoiceIdErp=FAC-2026-0042"