API Perunio

import { writeFile } from "node:fs/promises";

const API = "https://api.perunio.pe/v1";
const KEY = process.env.PERUNIO_API_KEY; // prn_live_…

async function call(path, init = {}) {
  const res = await fetch(API + path, {
    ...init,
    headers: { Authorization: `Bearer ${KEY}`, ...init.headers },
  });
  if (res.status >= 400) {
    const { error } = await res.json();
    throw new Error(`${error.code}: ${error.message}`);
  }
  return res;
}

// 1. Crear la descarga masiva
const created = await call("/bulk-downloads", {
  method: "POST",
  headers: {
    "Content-Type": "application/json",
    "Idempotency-Key": "rce-202609-run-1",
  },
  body: JSON.stringify({
    registro: "rce",
    period: "202609",
    fileTypes: ["xml", "pdf"],
    // Sin items: Perunio lista el periodo completo en SIRE y descarga todos sus
    // comprobantes descargables.
    items: [
      { rucEmisor: "20100070970", codTipoCdp: "01", serie: "F001", numero: "12345" },
      { rucEmisor: "20100070970", codTipoCdp: "07", serie: "FC01", numero: "321" },
      { rucEmisor: "20512345678", codTipoCdp: "03", serie: "B001", numero: "4567" },
    ],
  }),
});
let job = await created.json();

// 2. Consultar cada 5 segundos hasta que termine
while (!["completed", "failed", "cancelled"].includes(job.status)) {
  await new Promise((resolve) => setTimeout(resolve, 5000));
  const res = await call(`/bulk-downloads/${job.id}`);
  job = await res.json();
}
if (job.status !== "completed") throw new Error(job.error?.code ?? job.status);
console.log(`${job.downloadedFiles} archivos, ${job.failedFiles} fallidos`);

// 3. Ver qué falló y por qué. Un comprobante con el XML pero sin el PDF
// queda "completed": revisa failedFiles, no solo status=failed.
for (let cursor = ""; job.failedFiles > 0; ) {
  const res = await call(`/bulk-downloads/${job.id}/items?limit=1000${cursor}`);
  const page = await res.json();
  for (const item of page.data) {
    for (const f of item.failedFiles) {
      console.warn(`${item.serie}-${item.numero} ${f.fileType}: ${f.code} ${f.message}`);
    }
  }
  if (!page.nextCursor) break;
  cursor = `&cursor=${page.nextCursor}`;
}

// 4. Bajar el ZIP: /file redirige a un enlace temporal
const file = await call(`/bulk-downloads/${job.id}/file`, { redirect: "manual" });
const zip = await fetch(file.headers.get("location"));
await writeFile("comprobantes.zip", Buffer.from(await zip.arrayBuffer()));

const API = "https://api.perunio.pe/v1";

const res = await fetch(`${API}/openapi.json`);
const result = await res.json();
if (!res.ok) throw new Error(`${result.error.code}: ${result.error.message}`);

console.log(result);

import { writeFile } from "node:fs/promises";

const API = "https://api.perunio.pe/v1";
const KEY = process.env.PERUNIO_API_KEY; // prn_live_…

const res = await fetch(`${API}/comprobantes/rce/20100070970/01/F001/12345/xml`, {
  headers: { Authorization: `Bearer ${KEY}` },
});
if (!res.ok) {
  const { error } = await res.json();
  throw new Error(`${error.code}: ${error.message}`);
}

// El nombre del archivo viene en Content-Disposition
const name = res.headers.get("content-disposition").match(/filename="(.+)"/)[1];
await writeFile(name, Buffer.from(await res.arrayBuffer()));

const API = "https://api.perunio.pe/v1";
const KEY = process.env.PERUNIO_API_KEY; // prn_live_…

const res = await fetch(`${API}/bulk-downloads`, {
  method: "POST",
  headers: {
    Authorization: `Bearer ${KEY}`,
    "Content-Type": "application/json",
    "Idempotency-Key": "rce-202609-run-1",
  },
  body: JSON.stringify({
    registro: "rce",
    period: "202609",
    fileTypes: ["xml", "pdf"],
    // Sin items: Perunio lista el periodo completo en SIRE y descarga todos sus
    // comprobantes descargables.
    items: [
      { rucEmisor: "20100070970", codTipoCdp: "01", serie: "F001", numero: "12345" },
      { rucEmisor: "20100070970", codTipoCdp: "07", serie: "FC01", numero: "321" },
      { rucEmisor: "20512345678", codTipoCdp: "03", serie: "B001", numero: "4567" },
    ],
  }),
});
const result = await res.json();
if (!res.ok) throw new Error(`${result.error.code}: ${result.error.message}`);

console.log(result);

const API = "https://api.perunio.pe/v1";
const KEY = process.env.PERUNIO_API_KEY; // prn_live_…

const res = await fetch(`${API}/bulk-downloads`, {
  headers: { Authorization: `Bearer ${KEY}` },
});
const result = await res.json();
if (!res.ok) throw new Error(`${result.error.code}: ${result.error.message}`);

console.log(result.data);
// Hay más páginas mientras result.nextCursor no sea null: pásalo como ?cursor=

const API = "https://api.perunio.pe/v1";
const KEY = process.env.PERUNIO_API_KEY; // prn_live_…

const res = await fetch(`${API}/bulk-downloads/3f2a9c0e-8b1d-4e6f-a7c5-b2d1e0f9a8b7`, {
  headers: { Authorization: `Bearer ${KEY}` },
});
const result = await res.json();
if (!res.ok) throw new Error(`${result.error.code}: ${result.error.message}`);

console.log(result);

const API = "https://api.perunio.pe/v1";
const KEY = process.env.PERUNIO_API_KEY; // prn_live_…

const res = await fetch(`${API}/bulk-downloads/3f2a9c0e-8b1d-4e6f-a7c5-b2d1e0f9a8b7`, {
  method: "DELETE",
  headers: { Authorization: `Bearer ${KEY}` },
});
const result = await res.json();
if (!res.ok) throw new Error(`${result.error.code}: ${result.error.message}`);

console.log(result);

const API = "https://api.perunio.pe/v1";
const KEY = process.env.PERUNIO_API_KEY; // prn_live_…

const res = await fetch(`${API}/bulk-downloads/3f2a9c0e-8b1d-4e6f-a7c5-b2d1e0f9a8b7/items`, {
  headers: { Authorization: `Bearer ${KEY}` },
});
const result = await res.json();
if (!res.ok) throw new Error(`${result.error.code}: ${result.error.message}`);

console.log(result.data);
// Hay más páginas mientras result.nextCursor no sea null: pásalo como ?cursor=

import { writeFile } from "node:fs/promises";

const API = "https://api.perunio.pe/v1";
const KEY = process.env.PERUNIO_API_KEY; // prn_live_…

const res = await fetch(`${API}/bulk-downloads/3f2a9c0e-8b1d-4e6f-a7c5-b2d1e0f9a8b7/file`, {
  headers: { Authorization: `Bearer ${KEY}` },
  redirect: "manual",
});
if (res.status !== 302) {
  const { error } = await res.json();
  throw new Error(`${error.code}: ${error.message}`);
}

// Enlace temporal de 15 minutos: descárgalo enseguida, sin la clave
const zip = await fetch(res.headers.get("location"));
await writeFile("comprobantes.zip", Buffer.from(await zip.arrayBuffer()));