Data Flow

External Client
     ↓
  [POST /scrapping]
     ↓
Express Server (server.ts)
     ↓
  ┌─────────────────────────────────┐
  │  Corprecam PHP Backend APIs     │
  │  - get_compra.php               │
  │  - get_compra_items.php         │
  │  - get_materiales.php           │
  │  - get_microruta.php            │
  └─────────────────────────────────┘
     ↓
Data Transformation (transfromDs)
     ↓
  DocumentoSoporte Object
     ├─→ corprecam: Products[]
     └─→ reciclemos: Products[]
     ↓
Playwright Orchestrator (main.ts)
     ├─→ [If corprecam.length > 0]
     │       ↓
     │   Siigo Session (NIT: 900142913)
     │       ↓
     │   Browser Automation
     │
     └─→ [If reciclemos.length > 0]
             ↓
         Siigo Session (NIT: 901328575)
             ↓
         Browser Automation
     ↓
Siigo Nube (Draft Documents)
     ↓
HTTP Response {"message": "ok"}

{
  compra: string;  // Purchase order ID (e.g., "12345")
}

{
  "compra": "67890"
}

interface Compra {
  com_codigo: number;        // Purchase order number
  comp_asociado: string;     // Supplier NIT/ID
  com_micro_ruta: string;    // Micro-route code reference
}

{
  "com_codigo": 67890,
  "comp_asociado": "123456789",
  "com_micro_ruta": "5"
}

interface CompraItem {
  citem_codigo: number;          // Line item ID
  citem_id_compra: number;       // FK to purchase order
  citem_material: number;        // FK to material
  citem_cantidad: number;        // Quantity purchased
  citem_valor_unitario: number;  // Unit price
  citem_total: number;           // Line total
  citem_rechazo: number;         // Rejection quantity
}

[
  {
    "citem_codigo": 1,
    "citem_id_compra": 67890,
    "citem_material": 42,
    "citem_cantidad": 100,
    "citem_valor_unitario": 50,
    "citem_total": 5000,
    "citem_rechazo": 0
  },
  {
    "citem_codigo": 2,
    "citem_id_compra": 67890,
    "citem_material": 83,
    "citem_cantidad": 50,
    "citem_valor_unitario": 120,
    "citem_total": 6000,
    "citem_rechazo": 0
  }
]

interface Material {
  mat_id: number;        // Material ID
  mat_codigo: string;    // Siigo product code
  mat_nom: string;       // Product name
  emp_id_fk: number;     // Company ID (1=Corprecam, 2=Reciclemos)
}

[
  {
    "mat_id": 42,
    "mat_codigo": "PLAST-001",
    "mat_nom": "Plastico PET",
    "emp_id_fk": 1
  },
  {
    "mat_id": 83,
    "mat_codigo": "CARTON-002",
    "mat_nom": "Carton Corrugado",
    "emp_id_fk": 2
  }
]

interface Micro {
  mic_nom: string;  // Route name/description
}

{
  "mic_nom": "Ruta Centro"
}

interface Products {
  codigo: string;     // mat_codigo from Material
  cantidad: number;   // citem_cantidad from CompraItem
  precio: number;     // citem_valor_unitario from CompraItem
  empresa: number | undefined;  // emp_id_fk from Material
}

[
  {
    codigo: "PLAST-001",
    cantidad: 100,
    precio: 50,
    empresa: 1  // Corprecam
  },
  {
    codigo: "CARTON-002",
    cantidad: 50,
    precio: 120,
    empresa: 2  // Reciclemos
  }
]

interface DocumentoSoporte {
  proveedor_id: string;     // Supplier NIT
  micro_id: string;         // Route name
  corprecam: Products[];    // Products for company 1
  reciclemos: Products[];   // Products for company 2
}

const [corprecam, reciclemos] = productos.reduce(
  (acc: [Array<Products>, Array<Products>], pro: Products) => {
    if (pro.empresa === 1) {
      acc[0].push(pro);  // Corprecam array
    } else {
      acc[1].push(pro);  // Reciclemos array
    }
    return acc;
  },
  [[], []]  // Initial: two empty arrays
);

{
  "proveedor_id": "123456789",
  "micro_id": "Ruta Centro",
  "corprecam": [
    {
      "codigo": "PLAST-001",
      "cantidad": 100,
      "precio": 50
    }
  ],
  "reciclemos": [
    {
      "codigo": "CARTON-002",
      "cantidad": 50,
      "precio": 120
    }
  ]
}

// Line 24: Fetch header
const compra = await getCompras(body.compra);

// Line 26: Fetch items
const compraItems = await getCompraItems(body.compra);

// Line 28: Extract material IDs
const citem_material = compraItems.map((row) => row.citem_material);

// Line 30: Fetch materials in batch
const materiales = await getMateriales(citem_material);

// Line 32: Fetch route info
const micro = await getMicro(Number(compra[0].com_micro_ruta));

// Line 34: Transform to DocumentoSoporte
const ds = transfromDs(compra[0], compraItems, materiales, micro);

// Line 16-27: Process Corprecam products if present
if (documentoSoporte.corprecam.length > 0) {
  await playwright_corprecam_reciclemos(
    documentoSoporte.corprecam,          // Products array
    "25470",                             // Document type
    " BODEGA DE RIOHACHA ",              // Warehouse
    " CAJA RIOHACHA ",                   // Account
    documentoSoporte.proveedor_id,       // Supplier
    config.USER_SIIGO_CORPRECAM,         // Credentials
    config.PASSWORD_SIIGO_CORPRECAM,
    "900142913"                          // Corprecam NIT
  );
}

// Line 29-40: Process Reciclemos products if present
if (documentoSoporte.reciclemos.length > 0) {
  await playwright_corprecam_reciclemos(
    documentoSoporte.reciclemos,         // Different products
    "25470",
    " BODEGA DE RIOHACHA ",
    " Efectivo ",                        // Different account
    documentoSoporte.proveedor_id,
    config.USER_SIIGO_CORPRECAM,
    config.PASSWORD_SIIGO_CORPRECAM,
    "901328575"                          // Reciclemos NIT
  );
}

const productos = compraItems.map((item): Products => {
  const material = materiales.find(
    (material) => material.mat_id === item.citem_material
  );
  return {
    codigo: material?.mat_codigo || "",
    cantidad: item.citem_cantidad,
    precio: item.citem_valor_unitario,
    empresa: material?.emp_id_fk,
  };
});

const [corprecam, reciclemos] = productos.reduce(
  (acc, pro) => {
    if (pro.empresa === 1) {
      acc[0].push(pro);
    } else {
      acc[1].push(pro);
    }
    return acc;
  },
  [[], []]
);

return {
  proveedor_id: compra.comp_asociado,
  micro_id: String(micros.mic_nom) || "",
  corprecam: corprecam,
  reciclemos: reciclemos,
};

// Line 104: Type slowly to trigger autocomplete
await input.pressSequentially(codigo, { delay: 150 });

// Line 107: Wait for suggestions
await page.locator(".siigo-ac-table tr").first().waitFor();

// Line 110-115: Find exact match
await page
  .locator(".siigo-ac-table tr", {
    has: page.locator(`div:text-is("${codigo}")`),
  })
  .first()
  .click();

// Line 211: Fill quantity
await inputCantidad.fill(cantidad.toString());

// Line 214: Fill price
await inputValor.fill(valor.toString());

// Line 225: Submit row
await botonAgregar.click({ force: true });

// Line 233-234: Wait for DOM to reset
await expect(inputCantidad).toHaveValue("", { timeout: 10000 });
await page.waitForTimeout(1000);

// Line 254: Open account dropdown
await dropdownAcc.click();

// Line 256: Wait for options
await page.locator(".suggestions .siigo-ac-table").first().waitFor();

// Line 258-262: Select by text match
await page
  .locator(
    `.suggestions .siigo-ac-table tr:has(div:has-text("${cuentaNombre}"))`
  )
  .click();

// main.ts:13-14
console.log(documentoSoporte.corprecam);
console.log(documentoSoporte.reciclemos);

const material = materiales.find(
  (material) => material.mat_id === item.citem_material
);
// material = undefined

return {
  codigo: material?.mat_codigo || "",  // Empty string!
  // ...
};

// Scenario: All products have emp_id_fk === 1
{
  corprecam: [/* 5 products */],
  reciclemos: []  // Empty array
}

// main.ts:29
if (documentoSoporte.reciclemos.length > 0) {
  // Skipped - no execution for empty array
}

// server.ts:24
const compra = await getCompras(body.compra);
// Throws unhandled promise rejection

{
  "message": "ok"
}

{
  "link": "https://abc123.ngrok.io"
}