Descargar archivos de transacciones

// Node.js 18 o superior. Descarga los archivos de las transacciones pagadas desde una fecha.
import { createHash } from 'node:crypto';
import { mkdir, writeFile } from 'node:fs/promises';

const HOST = 'https://mx.stage.app.mendel.com';
const headers = { 'X-API-KEY': process.env.MENDEL_API_KEY, Accept: 'application/json' };

async function get(path) {
  const res = await fetch(`${HOST}/api/public/v1${path}`, { headers });
  if (!res.ok) throw new Error(`${res.status} en ${path}`);
  return res.json();
}

// 1. Los uniqueCode de las transacciones, recorriendo todas las páginas.
async function purchaseCodes(filters) {
  const codes = [];
  for (let page = 0, totalPages = 1; page < totalPages; page++) {
    const query = new URLSearchParams({
      ...filters, page, size: 500,
      'sort[0].property': 'createdDate', 'sort[0].direction': 'DESC',
    });
    const body = await get(`/purchases?${query}`);
    codes.push(...(body._embedded?.purchases ?? []).map((p) => p.uniqueCode));
    totalPages = body.page.totalPages;
  }
  return codes;
}

// 2. Sus archivos, en tandas de 100 transacciones.
async function* purchaseFiles(codes) {
  for (let i = 0; i < codes.length; i += 100) {
    const query = new URLSearchParams({ size: 100 });
    for (const code of codes.slice(i, i + 100)) query.append('purchaseCodes', code);
    const body = await get(`/purchases/files?${query}`);
    yield* body._embedded?.purchasesFiles ?? [];
  }
}

// 3. Descarga cada archivo (sin la API key) y verifica su hash.
const codes = await purchaseCodes({ dateFrom: '2026-10-01T00:00:00Z' });
for await (const purchase of purchaseFiles(codes)) {
  const files = [
    ...(purchase.ticketFiles ?? []),
    ...(purchase.invoiceFiles ?? []),
    ...(purchase.digitalInvoiceFiles ?? []),
  ];
  await mkdir(`archivos/${purchase.purchaseCode}`, { recursive: true });
  for (const file of files) {
    const res = await fetch(file._links.bytes.href);
    if (!res.ok) throw new Error(`${res.status} al descargar ${file.uniqueCode}`);
    const bytes = Buffer.from(await res.arrayBuffer());
    const digest = createHash('sha256').update(bytes).digest('hex');
    if (digest !== file.fileDigest) throw new Error(`Hash distinto en ${file.uniqueCode}`);
    await writeFile(`archivos/${purchase.purchaseCode}/${file.uniqueCode}.${file.extension}`, bytes);
  }
}