← back to Filemaker Mcp

auto-save: 2026-07-07T09:29:44 (1 files) — scripts/watch-next-order.mjs

f705ac9cc87b89ee193b0b42df8f0d48a594118a · 2026-07-07 09:29:49 -0700 · Steve Abrams

Files touched

• A scripts/watch-next-order.mjs

Diff

commit f705ac9cc87b89ee193b0b42df8f0d48a594118a
Author: Steve Abrams <steve@designerwallcoverings.com>
Date:   Tue Jul 7 09:29:49 2026 -0700

    auto-save: 2026-07-07T09:29:44 (1 files) — scripts/watch-next-order.mjs
---
 scripts/watch-next-order.mjs | 53 ++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 53 insertions(+)

diff --git a/scripts/watch-next-order.mjs b/scripts/watch-next-order.mjs
new file mode 100644
index 0000000..fc32299
--- /dev/null
+++ b/scripts/watch-next-order.mjs
@@ -0,0 +1,53 @@
+// Watch for the NEXT Shopify order the sync processes (order_number > BASELINE),
+// then print its FileMaker per-SKU invoice breakdown and exit. Polls the sync
+// ledger; on a hit, queries FileMaker (read-only). Auto-exits after the cap.
+import { readFileSync } from 'node:fs';
+import { fileURLToPath } from 'node:url';
+import { dirname, join } from 'node:path';
+import { findRecords } from '../src/fm-client.js';
+const ROOT = join(dirname(fileURLToPath(import.meta.url)), '..');
+for (const l of readFileSync(join(ROOT, '.env'), 'utf8').split('\n')) {
+  const m = l.match(/^([A-Z0-9_]+)=(.*)$/); if (m && !process.env[m[1]]) process.env[m[1]] = m[2];
+}
+const HDR = 'Invoice to Client Copy';
+const LEDGER = join(ROOT, 'data', 'sync-ledger.jsonl');
+const BASELINE = 32547;
+const MAX_POLLS = 240, INTERVAL_MS = 30_000; // ~2 hours
+
+const sleep = (ms) => new Promise((r) => setTimeout(r, ms));
+
+function newProcessedOrders() {
+  let lines = [];
+  try { lines = readFileSync(LEDGER, 'utf8').trim().split('\n'); } catch { return []; }
+  const out = [];
+  for (const l of lines) {
+    try { const d = JSON.parse(l); if (d.action === 'processed' && Number(d.orderNumber) > BASELINE) out.push(d); } catch {}
+  }
+  return out;
+}
+
+async function report(order) {
+  const { records } = await findRecords('invoice', HDR, [{ 'Cust PO': '==' + order.orderNumber }],
+    { limit: 60, sort: [{ fieldName: 'Invoice', sortOrder: 'ascend' }] }).catch(() => ({ records: [] }));
+  console.log(`\n🆕 NEW ORDER PROCESSED — #${order.orderNumber} (${order.company || ''}) at ${order.ts?.slice(0,19)}`);
+  console.log(`   sync reported: first invoice ${order.invoiceNumber} · $${order.invoiceTotal} · ${order.invoiceCount ?? '?'} record(s)`);
+  console.log(`   FileMaker records (Cust PO ${order.orderNumber}):`);
+  let sum = 0;
+  records.forEach((r, i) => {
+    const f = r.fieldData, paid = Number(f['PAID ON ACCOUNT'] || 0), net = Number(f['NET 1(1)'] || 0);
+    sum += paid;
+    console.log(`     ${i === 0 ? 'FIRST ' : 'sku   '} #${f['Invoice']}  NET ${String(net).padStart(8)}  PAID ${String(paid).padStart(8)}  ${String(f['DETAIL 1(1)']||'').slice(0,34)}`);
+  });
+  console.log(`   → sum of PAID across the ${records.length} record(s) = $${sum.toFixed(2)} (should equal the order total; money on the FIRST only)`);
+}
+
+for (let i = 0; i < MAX_POLLS; i++) {
+  const hits = newProcessedOrders();
+  if (hits.length) {
+    for (const o of hits) await report(o);
+    console.log('\n(watcher done — first real per-SKU order observed)');
+    process.exit(0);
+  }
+  await sleep(INTERVAL_MS);
+}
+console.log(`No new order (> #${BASELINE}) processed within the watch window. Re-arm if you still want to catch the first one.`);

← 4dd914e invoicing: fix double-increment so per-SKU invoice numbers a  ·  back to Filemaker Mcp  ·  auto-save: 2026-07-07T13:00:27 (1 files) — scripts/watch-nex 1b0bc8f →