`mdc-activate.js`

102 lines
// MDC → Phillipe Romano (Type II) PRIVATE-LABEL settlement-gated activator.
// Sibling of cmo-activate.js. Reuses the REAL SettlementGate (legal gate) +
// validateBeforeActivate (5-field/specs gate). DRAFT→ACTIVE + publish ex-Google.
//
// PRIVATE-LABEL SCOPING: "Phillipe Romano" is shared by three place-name lines
// (MDC=world capitals, Command54=East-Coast beaches, Greenland=coastal cities), so a
// vendor:'Phillipe Romano' query would over-match. This activator is driven by the
// EXACT shopify_product_id set recorded in dw_unified.mdc_catalog — the authoritative
// MDC set, nothing else.
//
// HARD RAILS
//  * Re-runs a distinctive private-label LEAK guard on the customer-facing surface
//    (title/tags/body) right before ACTIVE — an MDC/book/designer coinage → HOLD,
//    never activate (activation is the customer-facing moment).
//  * The 48 "Dublin Vital" rows (generic word, but the MDC line name) are HELD for
//    human review unless --allow-vital is passed.
//  * Quote-only line: sample + `quotes` tag + ≥2 tags exemption; publish EX-Google
//    (quote-only stays off Google Shopping).
//  * DRY by default. --commit performs the live activation. --limit N samples.
//
// Cost: settlement gate may hit a paid vision tier on some images; tracked + printed.
//
// Usage:
//   node mdc-activate.js --limit 20            # DRY sample (prove + estimate settlement $)
//   node mdc-activate.js                       # DRY over the full MDC set
//   node mdc-activate.js --commit              # LIVE activate (Steve-gated)
const fs=require('fs'), os=require('os'), path=require('path');
const { SettlementGate } = require('./lib/settlement-gate.js');
const { validateBeforeActivate } = require(path.join(os.homedir(),'Projects/Designer-Wallcoverings/shopify/scripts/lib/validate-before-activate.js'));
const { execSync } = require('child_process');
const TOK=fs.readFileSync('/Users/macstudio3/Projects/secrets-manager/.env','utf8').split('\n').find(l=>l.startsWith('SHOPIFY_ADMIN_TOKEN=')).split('=')[1];
const STORE='designer-laboratory-sandbox.myshopify.com', API='2024-10';
const GOOGLE='gid://shopify/Publication/29646651457';
const DRY = !process.argv.includes('--commit');
const ALLOW_VITAL = process.argv.includes('--allow-vital');
const LIMIT = process.argv.includes('--limit') ? parseInt(process.argv[process.argv.indexOf('--limit')+1],10) : Infinity;
const sleep=ms=>new Promise(r=>setTimeout(r,ms));
const L=fs.createWriteStream('/tmp/mdc_activate.log',{flags:'w'});
const P=m=>{L.write(m+'\n');console.log(m);};

// distinctive private-label coinages that must NEVER go customer-facing (generic
// words like "vital" are handled separately via the Dublin-Vital hold below).
const HARD_LEAK=/\b(mdc|mdcwall|vycon|genon|bolta|lentex|nvolve|candice\s+olson|thom\s+filicia|jonathan\s+mark|taniya\s+nayak)\b/i;

async function gql(q,v){ for(let a=0;a<4;a++){ try{ const r=await fetch(`https://${STORE}/admin/api/${API}/graphql.json`,{method:'POST',headers:{'X-Shopify-Access-Token':TOK,'Content-Type':'application/json'},body:JSON.stringify({query:q,variables:v})}); const j=await r.json(); if(j.errors&&a<3){await sleep(1500);continue;} return j;}catch(e){await sleep(1500);} } return {}; }
const mfVal=(mfs,ns,k)=>{const x=mfs.find(m=>m.namespace===ns&&m.key===k);return x?x.value:'';};
async function loadPubs(){ const r=await gql(`{publications(first:50){edges{node{id name}}}}`,{}); return (r.data?.publications?.edges||[]).map(e=>e.node).filter(p=>p.id!==GOOGLE); }
async function setHold(id,verdict,reason){ await gql(`mutation($mfs:[MetafieldsSetInput!]!){metafieldsSet(metafields:$mfs){userErrors{message}}}`,{mfs:[{ownerId:id,namespace:'internal',key:'settlement_hold',type:'single_line_text_field',value:`${verdict}:${reason}`.slice(0,250)}]}); }

// ---- MDC set from staging (authoritative). PID -> {mfr,material,width,dw_sku,vital}
const rows=execSync(`psql "host=/tmp dbname=dw_unified" -tAF '\t' -c "SELECT shopify_product_id,mfr_sku,coalesce(material,''),coalesce(width,''),dw_sku,(private_label_collection='Dublin' AND pattern_name ~* 'vital') FROM mdc_catalog WHERE shopify_product_id IS NOT NULL ORDER BY dw_sku;"`).toString().trim().split('\n');
const SET=rows.map(l=>{const[pid,mfr,mat,width,dw,vital]=l.split('\t');return{pid,mfr,mat,width,dw,vital:vital==='t'};}).filter(r=>r.pid);

(async()=>{
  const gate=new SettlementGate(); P(`settlement lock: ${JSON.stringify(gate.lockStatus())}  mode=${DRY?'DRY':'COMMIT'}  mdc_set=${SET.length}  allowVital=${ALLOW_VITAL}`);
  const pubs=DRY?[]:await loadPubs(); if(!DRY)P(`publications (ex-Google): ${pubs.map(p=>p.name).join(', ')}`);
  let scanned=0,activated=0,publishedN=0,heldSettle=0,heldValidate=0,blocked=0,heldLeak=0,heldVital=0,cost=0;
  const todo=SET.slice(0,LIMIT===Infinity?SET.length:LIMIT);
  for(const row of todo){
    scanned++;
    const gid=`gid://shopify/Product/${row.pid}`;
    const r=await gql(`query($id:ID!){product(id:$id){id title status tags descriptionHtml featuredImage{url} images(first:6){nodes{url}} variants(first:5){nodes{sku price}} metafields(first:40){nodes{namespace key value}}}}`,{id:gid});
    const n=r.data?.product; if(!n){P(`load-miss ${row.dw} pid=${row.pid}`);continue;}
    if(n.status!=='DRAFT'){P(`skip ${row.dw}: status=${n.status}`);continue;}
    const mfs=n.metafields.nodes; const imgs=(n.images.nodes||[]).map(i=>i.url);
    const width=mfVal(mfs,'global','width')||row.width;
    // (0) private-label leak guard on customer-facing surface — HARD, never activate a leak
    const surface=`${n.title} ${(n.tags||[]).join(' ')} ${n.descriptionHtml||''}`;
    if(HARD_LEAK.test(surface)){ heldLeak++; P(`HOLD(leak) ${row.dw} ${row.mfr}`); if(!DRY) await gql(`mutation($id:ID!,$t:[String!]!){tagsAdd(id:$id,tags:$t){userErrors{message}}}`,{id:n.id,t:['Hold-Leak-Review']}); continue; }
    // (0b) Dublin "Vital" generic-word hold — needs human OK before customer-facing
    if(row.vital && !ALLOW_VITAL){ heldVital++; P(`HOLD(vital-review) ${row.dw} ${n.title}`); if(!DRY) await gql(`mutation($id:ID!,$t:[String!]!){tagsAdd(id:$id,tags:$t){userErrors{message}}}`,{id:n.id,t:['Hold-Review']}); continue; }
    // (1) 5-field / specs gate (real validator)
    const val=validateBeforeActivate({title:n.title,dwSku:row.dw,vendor:'Phillipe Romano',tags:n.tags||[],
      descriptionHtml:n.descriptionHtml,variants:n.variants.nodes,
      specs:{width,material:row.mat,repeat:'Free match'},vendorSpecs:{width,material:row.mat},
      images:imgs,vendorImages:imgs});
    const hasSample=(n.variants.nodes||[]).some(v=>/-sample$/i.test(v.sku||''));
    const extraOk=hasSample && (n.tags||[]).length>=2;
    if(!val.ok || !extraOk){ heldValidate++; const why=[...(val.reasons||[]),...(!hasSample?['no-sample']:[])].join(',');
      P(`HOLD(validate) ${row.dw} ${row.mfr} :: ${why}`);
      if(!DRY) await gql(`mutation($id:ID!,$t:[String!]!){tagsAdd(id:$id,tags:$t){userErrors{message}}}`,{id:n.id,t:['Needs-Description']}); continue; }
    // (2) settlement (legal) gate
    const sv=await gate.evaluate({shopify_id:n.id,title:n.title,vendor:'Phillipe Romano',dw_sku:row.dw,material:row.mat,imageUrl:n.featuredImage?.url||imgs[0]||''});
    cost+=sv.cost||0;
    if(sv.verdict!=='PASS'){ if(sv.verdict==='BLOCK')blocked++;else heldSettle++;
      P(`HOLD(settlement:${sv.verdict}) ${row.dw} ${row.mfr} [${sv.tier}] :: ${sv.reason}`);
      if(!DRY) await setHold(n.id,sv.verdict,sv.reason); continue; }
    // PASS → activate + New Arrival + publish (ex-Google)
    if(DRY){ activated++; continue; }
    const ar=await gql(`mutation($id:ID!){productUpdate(input:{id:$id,status:ACTIVE}){userErrors{message}}}`,{id:n.id});
    const ue=ar.data?.productUpdate?.userErrors||[]; if(ue.length){P(`ACTIVATE-ERR ${row.dw}: ${JSON.stringify(ue)}`);continue;}
    activated++;
    await gql(`mutation($id:ID!,$t:[String!]!){tagsAdd(id:$id,tags:$t){userErrors{message}}}`,{id:n.id,t:['New Arrival']});
    const pp=await gql(`mutation($id:ID!,$in:[PublicationInput!]!){publishablePublish(id:$id,input:$in){userErrors{message}}}`,{id:n.id,in:pubs.map(p=>({publicationId:p.id}))});
    const pe=(pp.data?.publishablePublish?.userErrors||[]).filter(e=>!/already/i.test(e.message||''));
    if(!pe.length) publishedN++;
    if(activated%25===0)P(`  ...activated ${activated}`);
    await sleep(300);
  }
  P(`\nDONE ${DRY?'(DRY)':''}: scanned=${scanned} ${DRY?'wouldActivate':'activated'}=${activated} published=${publishedN} heldSettlement=${heldSettle} blocked=${blocked} heldValidate=${heldValidate} heldLeak=${heldLeak} heldVital=${heldVital}  settlement_cost=$${cost.toFixed(4)}`);
})();