`scripts/check_sp_inventory.js`

81 lines
#!/usr/bin/env node
/**
 * Audit inventory_quantity across every Sister Parish variant on the DW sandbox.
 * Reports how many variants are at the standing-rule qty (2026) vs. off.
 * With --fix, sets every off-target variant to 2026.
 */
require('dotenv').config({ path: require('path').join(__dirname, '..', '.env') });

const SHOP = process.env.SHOPIFY_STORE;
const TOKEN = process.env.SHOPIFY_ADMIN_TOKEN;
if (!SHOP || !TOKEN) { console.error('Need SHOPIFY_STORE + SHOPIFY_ADMIN_TOKEN'); process.exit(1); }

const BASE = `https://${SHOP}/admin/api/2026-01`;
const TARGET = 2026;
const RATE_DELAY_MS = 350;
const FIX = process.argv.includes('--fix');
const sleep = ms => new Promise(r => setTimeout(r, ms));

async function shopify(method, url, body) {
  const res = await fetch(url.startsWith('http') ? url : `${BASE}${url}`, {
    method,
    headers: { 'X-Shopify-Access-Token': TOKEN, 'Content-Type': 'application/json' },
    body: body ? JSON.stringify(body) : undefined,
  });
  const text = await res.text();
  let json; try { json = JSON.parse(text); } catch { json = { raw: text }; }
  if (!res.ok) { const e = new Error(`${method} ${url} → ${res.status}: ${text.slice(0,300)}`); e.status = res.status; throw e; }
  return { json, link: res.headers.get('link') || '' };
}
const nextPage = link => {
  const m = link.split(',').find(s => s.includes('rel="next"'));
  return m ? m.match(/<([^>]+)>/)[1] : null;
};

(async () => {
  const products = [];
  let url = `${BASE}/products.json?vendor=${encodeURIComponent('Sister Parish')}&limit=250`;
  while (url) {
    const { json, link } = await shopify('GET', url);
    products.push(...json.products);
    url = nextPage(link);
    if (url) await sleep(RATE_DELAY_MS);
  }

  const variants = products.flatMap(p => p.variants.map(v => ({ ...v, _title: p.title })));
  const onTarget = variants.filter(v => v.inventory_quantity === TARGET);
  const off = variants.filter(v => v.inventory_quantity !== TARGET);
  const untracked = variants.filter(v => v.inventory_management !== 'shopify');

  console.log(`Sister Parish: ${products.length} products, ${variants.length} variants`);
  console.log(`  inventory_quantity == ${TARGET}: ${onTarget.length}`);
  console.log(`  off-target:                  ${off.length}`);
  console.log(`  not tracked by Shopify:      ${untracked.length}`);
  if (off.length && off.length <= 60) {
    console.log('\nOff-target variants:');
    for (const v of off) console.log(`  ${v._title} [${v.sku || v.id}] qty=${v.inventory_quantity} tracked=${v.inventory_management || 'none'}`);
  }

  if (!FIX || !off.length) { if (FIX) console.log('\nNothing to fix.'); return; }

  console.log(`\n--fix: setting ${off.length} variants to ${TARGET}…`);
  // Token lacks read_locations — derive location_id from an existing inventory level instead.
  const sampleIid = off[0].inventory_item_id;
  const lvl = (await shopify('GET', `/inventory_levels.json?inventory_item_ids=${sampleIid}`)).json.inventory_levels[0];
  const locationId = lvl.location_id;
  await sleep(RATE_DELAY_MS);
  let ok = 0, fail = 0;
  for (let i = 0; i < off.length; i++) {
    const v = off[i];
    const stamp = `[${String(i+1).padStart(3,'0')}/${off.length}]`;
    try {
      await shopify('POST', '/inventory_levels/set.json', { location_id: locationId, inventory_item_id: v.inventory_item_id, available: TARGET });
      ok++; console.log(`${stamp} ✓ ${v._title} [${v.sku || v.id}] → ${TARGET}`);
    } catch (e) {
      fail++; console.log(`${stamp} ✗ ${v._title} [${v.sku || v.id}]: ${e.message.slice(0,150)}`);
    }
    await sleep(RATE_DELAY_MS);
  }
  console.log(`\nFixed: ${ok}   Failed: ${fail}`);
})().catch(e => { console.error('FATAL', e); process.exit(1); });