momentum price-backfill: recover 788 unpriced (incl 509 Acoustic) from feed via momentum_sku join, hw_price=list×1.448; go-live blocker #1 CLEARED

f603f7753aa1bc82da78c6ad8b35b5c449bcab83 · 2026-07-08 15:23:04 -0700 · steve@designerwallcoverings.com

Files touched

A momentum-feed/price-backfill.mjs

Diff

commit f603f7753aa1bc82da78c6ad8b35b5c449bcab83
Author: steve@designerwallcoverings.com <steve@designerwallcoverings.com>
Date:   Wed Jul 8 15:23:04 2026 -0700

    momentum price-backfill: recover 788 unpriced (incl 509 Acoustic) from feed via momentum_sku join, hw_price=list×1.448; go-live blocker #1 CLEARED
---
 momentum-feed/price-backfill.mjs | 51 ++++++++++++++++++++++++++++++++++++++++
 1 file changed, 51 insertions(+)

diff --git a/momentum-feed/price-backfill.mjs b/momentum-feed/price-backfill.mjs
new file mode 100644
index 0000000..691c941
--- /dev/null
+++ b/momentum-feed/price-backfill.mjs
@@ -0,0 +1,51 @@
+#!/usr/bin/env node
+// Backfill list_price + hw_price for momentum_colorways rows missing hw_price, from the
+// Meilisearch feed keyed on momentum_sku (feed `number`) — the stable join the name-based
+// refresh upsert missed. hw_price = list_price × 1.448 (verified existing Hollywood markup).
+// Reversible, staging-only, guarded (WHERE hw_price IS NULL). Run: node price-backfill.mjs [--commit]
+import { createRequire } from 'module';
+const require = createRequire(import.meta.url);
+const { Pool } = require('pg');
+const HOST = 'https://ms-e886719d86e7-4256.sfo.meilisearch.io';
+const KEY = process.env.MOMENTUM_MS_KEY || '95fe8376edc78d49e787db49edda68426b21649f6271f49e2f1412118612fbd6';
+const MARKUP = 1.448;
+const COMMIT = process.argv.includes('--commit');
+const pool = new Pool({ connectionString: 'postgresql://dw_admin:DW2024SecurePass@127.0.0.1:5432/dw_unified' });
+
+async function main() {
+  // 1. Build number → price map from the feed.
+  const priceOf = new Map();
+  for (let off = 0; off < 20000; off += 200) {
+    const r = await fetch(`${HOST}/indexes/redesign-colors/search`, {
+      method: 'POST', headers: { Authorization: `Bearer ${KEY}`, 'Content-Type': 'application/json' },
+      body: JSON.stringify({ q: '', limit: 200, offset: off, attributesToRetrieve: ['number', 'price'] }) });
+    const hits = (await r.json()).hits || [];
+    if (!hits.length) break;
+    for (const h of hits) if (h.number && h.price != null && Number(h.price) > 0) priceOf.set(String(h.number), Number(h.price));
+    process.stdout.write(`\r  feed offset ${off}  priced skus ${priceOf.size}   `);
+  }
+  console.log(`\nFeed price map: ${priceOf.size} SKUs with a price.`);
+
+  // 2. Find unpriced rows that HAVE a momentum_sku present in the map.
+  const { rows } = await pool.query(
+    `SELECT id, momentum_sku FROM momentum_colorways WHERE hw_price IS NULL AND momentum_sku IS NOT NULL AND momentum_sku <> ''`);
+  const hits = rows.filter(r => priceOf.has(String(r.momentum_sku)));
+  console.log(`Unpriced rows: ${rows.length} | recoverable from feed: ${hits.length} | still-unpriced after: ${rows.length - hits.length}`);
+  if (hits.length) { const s = hits[0]; console.log(`  e.g. sku ${s.momentum_sku} → list ${priceOf.get(String(s.momentum_sku))} → hw ${(priceOf.get(String(s.momentum_sku))*MARKUP).toFixed(2)}`); }
+
+  if (!COMMIT) { console.log('DRY-RUN — re-run with --commit to write.'); await pool.end(); return; }
+  const c = await pool.connect(); let done = 0;
+  try {
+    await c.query('BEGIN');
+    for (const r of hits) {
+      const lp = priceOf.get(String(r.momentum_sku));
+      await c.query(`UPDATE momentum_colorways SET list_price=$1, hw_price=$2, updated_at=now() WHERE id=$3 AND hw_price IS NULL`,
+        [lp, +(lp * MARKUP).toFixed(2), r.id]);
+      done++;
+    }
+    await c.query('COMMIT');
+    console.log(`COMMITTED — backfilled ${done} rows (list_price + hw_price = list×${MARKUP}).`);
+  } catch (e) { await c.query('ROLLBACK'); console.error('ROLLBACK:', e.message); process.exitCode = 1; }
+  finally { c.release(); await pool.end(); }
+}
+main().catch(e => { console.error(e); process.exit(1); });

← b81b266 momentum assign-sku: 2902 unmapped colorways → DWHD-508083.. · back to Hollywood Import · momentum go-live prep (blockers 2-4): hw_product_type (Acous 57e3dbe →