Initial import of zappier-accounting-export from zapier monorepo

README.md

@@ -0,0 +1,18 @@
+# zappier-accounting-export
+
+Accounting-department export of **invoices, billing, and payment history** to **QuickBooks IIF** and generic CSV (also usable in other ledgers).
+
+**Forgejo:** https://git.georgelambert.org/marchon/zappier-accounting-export  
+**Catalog:** https://zapier.georgelambert.org/packages/zappier-accounting-export/README.pdf
+
+Reads issued/paid invoices from zappier-edge (`ZAPPIER_ADMIN_URL`).
+
+```bash
+PORT=3013 node src/server.js
+curl 'http://127.0.0.1:3013/export/quickbooks.iif?period=2026-07' -o zappier.iif
+curl 'http://127.0.0.1:3013/export/accounting.csv?period=2026-07' -o zappier.csv
+```
+
+Import the IIF in QuickBooks Desktop: **File → Utilities → Import → IIF**. The CSV is a flat invoice register for other systems.
+
+History is the invoice list on zappier-edge (draft / issued / paid) plus CS credit ledger and portal prepaid reloads.

package.json

@@ -0,0 +1,11 @@
+{
+  "name": "zappier-accounting-export",
+  "version": "0.1.0",
+  "private": true,
+  "type": "module",
+  "description": "Export zappier invoices to QuickBooks IIF and accounting CSV",
+  "scripts": {
+    "start": "node src/server.js",
+    "test": "node --test test/*.test.js"
+  }
+}

src/server.js

@@ -0,0 +1,42 @@
+#!/usr/bin/env node
+/** Accounting department: QuickBooks IIF + CSV from zappier-edge invoices. */
+import http from 'node:http';
+
+const PORT = Number(process.env.PORT || 3013);
+const EDGE = (process.env.ZAPPIER_ADMIN_URL || 'http://127.0.0.1:3000').replace(/\/$/, '');
+const KEY = process.env.ZAPPIER_ADMIN_KEY || 'admin-dev-key';
+
+async function edge(pathname) {
+  const r = await fetch(`${EDGE}${pathname}`, { headers: { 'x-admin-key': KEY } });
+  return r;
+}
+
+const server = http.createServer(async (req, res) => {
+  const url = new URL(req.url || '/', `http://127.0.0.1:${PORT}`);
+  const send = (code, type, body) => {
+    res.writeHead(code, { 'content-type': type });
+    res.end(body);
+  };
+  try {
+    if (req.method === 'GET' && url.pathname === '/health') {
+      return send(200, 'application/json', JSON.stringify({ ok: true, role: 'zappier-accounting-export' }));
+    }
+    const period = url.searchParams.get('period');
+    const q = period ? `?period=${encodeURIComponent(period)}` : '';
+    if (req.method === 'GET' && url.pathname === '/export/quickbooks.iif') {
+      const r = await edge(`/admin/api/exports/quickbooks.iif${q}`);
+      return send(r.status, 'text/plain', await r.text());
+    }
+    if (req.method === 'GET' && url.pathname === '/export/accounting.csv') {
+      const r = await edge(`/admin/api/exports/accounting.csv${q}`);
+      return send(r.status, 'text/csv', await r.text());
+    }
+    send(404, 'application/json', JSON.stringify({ error: 'not found' }));
+  } catch (err) {
+    send(502, 'application/json', JSON.stringify({ error: err.message }));
+  }
+});
+
+server.listen(PORT, '0.0.0.0', () => {
+  process.stdout.write(`zappier-accounting-export http://127.0.0.1:${PORT}/\n`);
+});

test/health.test.js

@@ -0,0 +1,23 @@
+import { test } from 'node:test';
+import assert from 'node:assert/strict';
+import { spawn } from 'node:child_process';
+import { fileURLToPath } from 'node:url';
+import path from 'node:path';
+
+const root = path.join(path.dirname(fileURLToPath(import.meta.url)), '..');
+
+test('accounting-export health', async () => {
+  const port = 18013;
+  const child = spawn(process.execPath, ['src/server.js'], {
+    cwd: root,
+    env: { ...process.env, PORT: String(port) },
+    stdio: ['ignore', 'pipe', 'pipe'],
+  });
+  await new Promise((r) => setTimeout(r, 400));
+  try {
+    const r = await fetch(`http://127.0.0.1:${port}/health`);
+    assert.equal((await r.json()).role, 'zappier-accounting-export');
+  } finally {
+    child.kill('SIGTERM');
+  }
+});