Emitir una boleta

import { mkdir, readFile, writeFile } from 'node:fs/promises'
import {
  createEnvelope,
  createFolioConsumption,
  createSiiClient,
  encodeLatin1,
  folioConsumptionEntryFromDocument,
  isDteError,
  issueDocument,
  loadCertificateFromPkcs12,
  parseCaf,
  signEnvelope,
  signFolioConsumption,
  uploadEnvelope,
  uploadFolioConsumption,
  waitForUploadStatus,
  type DocumentInput,
  type Environment,
  type SignedDocument,
} from 'dte-sdk'
import { createDirectoryCapture, createDirectoryFolioRegistry, createDirectoryUploadArchive } from 'dte-sdk/node'
 
const COMPANY_RUT = '76543210-3'
const ENVIRONMENT = (process.env.SII_ENVIRONMENT ?? 'certification') as Environment // o 'production'
const resolution = {
  date: process.env.SII_RESOLUTION_DATE!, // AAAA-MM-DD
  number: Number(process.env.SII_RESOLUTION_NUMBER ?? 0),
}
 
const issuer = {
  rut: COMPANY_RUT,
  businessName: 'Comercial Andina SpA',
  businessActivity: 'Cafetería',
  address: 'Av. Los Aromos 1540',
  commune: 'Santiago',
}
 
// Dos ventas. Los precios son lo que paga el cliente: ya incluyen IVA
const SALES: DocumentInput['items'][] = [
  [
    { name: 'Café americano', quantity: 2, unitPrice: 2500 },
    { name: 'Medialuna', quantity: 3, unitPrice: 1200 },
  ],
  [{ name: 'Café americano', quantity: 1, unitPrice: 2500 }],
]
 
const certificate = loadCertificateFromPkcs12(await readFile('firma.pfx'), process.env.PFX_PASSWORD!)
const caf = parseCaf(await readFile('caf-39.xml', 'latin1')) // el CAF del tipo 39
 
const folios = createDirectoryFolioRegistry({ dir: './data/folios' })
const scope = { companyRut: COMPANY_RUT, type: 39, range: caf.range, environment: ENVIRONMENT } as const
 
const sii = createSiiClient({
  environment: ENVIRONMENT,
  certificate,
  companyRut: COMPANY_RUT,
  capture: createDirectoryCapture({ dir: './data/capture' }),
  archive: createDirectoryUploadArchive({ dir: './data/uploads' }),
})
 
try {
  // 1. Una boleta por venta: sin receptor (consumidor final), precios con IVA
  const receipts: SignedDocument[] = []
  for (const items of SALES) {
    const folio = await folios.reserve(scope)
    const receipt = issueDocument({
      document: { type: 39, folio, issuer, items, pricesIncludeVat: true },
      caf,
      certificate,
    })
    receipts.push(receipt)
    console.log(`receipt 39 #${folio}`, JSON.stringify(receipt.header.totals))
  }
 
  // 2. Todas en un solo EnvioBOLETA
  const envelope = signEnvelope(
    createEnvelope({
      kind: 'receipt',
      documents: receipts,
      cover: {
        issuerRut: COMPANY_RUT,
        senderRut: certificate.rut!,
        resolutionDate: resolution.date,
        resolutionNumber: resolution.number,
      },
    }),
    certificate,
  )
  await mkdir('./data/signed', { recursive: true })
  await writeFile(`./data/signed/39-${receipts[0].header.folio}.xml`, encodeLatin1(envelope.xml))
 
  // 3. Envío: REST en producción, DTEUpload en certificación (sii.receiptsChannel dice cuál)
  const upload = await uploadEnvelope(sii, { envelope })
  for (const receipt of receipts) await folios.markSent(scope, receipt.header.folio, { trackId: upload.trackId })
  console.log(`uploaded through ${upload.channel}, track id ${upload.trackId}`)
 
  // 4. Esperar por el mismo canal por el que fue el archivo
  const status = await waitForUploadStatus(sii, { trackId: upload.trackId, channel: upload.channel })
  console.log(`envelope ${status.code} ${status.status}: ${status.message}`)
 
  // 5. Reporte de consumo de folios: la certificación de boletas lo pide
  if (ENVIRONMENT === 'certification' && status.status !== 'rejected') {
    const report = signFolioConsumption(
      createFolioConsumption({
        cover: {
          issuerRut: COMPANY_RUT,
          senderRut: certificate.rut!,
          resolutionDate: resolution.date,
          resolutionNumber: resolution.number,
        },
        entries: receipts.map(folioConsumptionEntryFromDocument),
      }),
      certificate,
    )
    console.log('consumption', JSON.stringify(report.summaries))
    const consumption = await uploadFolioConsumption(sii, { xml: report.xml })
    const consumptionStatus = await waitForUploadStatus(sii, { trackId: consumption.trackId })
    console.log(`consumption ${consumptionStatus.code} ${consumptionStatus.status}: ${consumptionStatus.message}`)
  }
} catch (error) {
  if (!isDteError(error)) throw error
  console.error(error.code, error.details)
  process.exitCode = 1
}

const receipt = issueDocument({
  document: {
    type: 39,
    folio,
    issuer,
    items,
    pricesIncludeVat: true,
    // en el set de pruebas de certificación cada boleta apunta a su caso
    receiptReferences: [{ code: 'SET', reason: 'CASO-1' }],
  },
  caf,
  certificate,
})

// una boleta exenta (tipo 41): su propio CAF, sin IVA y sin pricesIncludeVat
const caf41 = parseCaf(await readFile('caf-41.xml', 'latin1'))
const scope41 = { companyRut: COMPANY_RUT, type: 41, range: caf41.range, environment: ENVIRONMENT } as const
 
const exempt = issueDocument({
  document: {
    type: 41,
    folio: await folios.reserve(scope41),
    issuer,
    items: [{ name: 'Entrada al museo', quantity: 2, unitPrice: 3000 }],
  },
  caf: caf41,
  certificate,
})
exempt.header.totals // { exemptAmount: 6000, totalAmount: 6000 }

receipt 39 #1 {"netAmount":7227,"vatAmount":1373,"totalAmount":8600}
receipt 39 #2 {"netAmount":2101,"vatAmount":399,"totalAmount":2500}
uploaded through soap, track id 4503230
envelope EPR accepted: Envío procesado
consumption [{"type":39,"netAmount":9328,"vatAmount":1772,"vatRate":19,"exemptAmount":0,"totalAmount":11100,"issuedCount":2,"voidedCount":0,"usedCount":2,"usedRanges":[{"from":1,"to":2}],"voidedRanges":[]}]
consumption EPR accepted: Envío procesado