← back to Eur Recrawl
Gated reonboard write (write_reonboard.py): UPDATE below-cost rolls + CREATE sample-only rolls -> trade x1.810; dry-run validated (EUR-80210 $120->$336.65). CRITICAL: live rolls priced below cost, this fixes them
82449aa059205135a54410568a965e7c6373200f · 2026-07-30 19:01:28 -0700 · Steve
Files touched
M PLAN.mdA write-results.jsonA write_reonboard.py
Diff
commit 82449aa059205135a54410568a965e7c6373200f
Author: Steve <steve@designerwallcoverings.com>
Date: Thu Jul 30 19:01:28 2026 -0700
Gated reonboard write (write_reonboard.py): UPDATE below-cost rolls + CREATE sample-only rolls -> trade x1.810; dry-run validated (EUR-80210 $120->$336.65). CRITICAL: live rolls priced below cost, this fixes them
---
PLAN.md | 6 ++++
write-results.json | 6 ++++
write_reonboard.py | 98 ++++++++++++++++++++++++++++++++++++++++++++++++++++++
3 files changed, 110 insertions(+)
diff --git a/PLAN.md b/PLAN.md
index cc3c3e2..7de055d 100644
--- a/PLAN.md
+++ b/PLAN.md
@@ -43,3 +43,9 @@ Scaffold + target list built (safe/local). Authenticated crawler = next, gated o
- **Live write path SOLVED:** bespoke productVariantsBulkCreate (API 2024-10, inventoryPolicy CONTINUE, tracked=false) adds a sellable roll to an already-active sample-only product without disturbing the Sample. Canary proven.
- **Login delegated:** sibling agent `claude-eur` owns the Playwright trade-LOGIN flow (Osborne + DG Cloudflare) and will drop an authed storage-state at `.auth/osborne.json` + note where per-SKU trade price lives. This terminal (vp-dw-commerce) owns: targets.csv → crawl w/ that session → parse trade price → ×1.810 → PG stage → gated productVariantsBulkCreate write. Standing down on login (avoid clobber/lockout).
- **Remaining before writes:** (a) authed session handoff; (b) per-SKU trade-price parse; (c) 729 shared-mfr_code colorway handling (capture per-colorway); (d) dry-run then Steve-gated write.
+
+## REONBOARD WRITE — ready + gated (Steve runs) + CRITICAL below-cost finding
+- **CRITICAL:** many EUR- products already have a live roll variant priced BELOW COST (sample: 10/13 loss-making — EUR-80210 $120 vs $186 cost; EUR-80217 $157 vs $284). DW loses money on every one sold. The reonboard FIXES this to retail = trade x1.810.
+- reonboard.csv = 1,410 priceable (381 exact + 595 pattern-single + 434 absent-cw-safe); 689 held (368 disco + 165 disco-colorway + 154 panels + 2 ambiguous).
+- write_reonboard.py (GATED, DRY_RUN default, dry-run validated): per product -> UPDATE existing roll price OR CREATE roll (Size:Roll, CONTINUE, tracked=false, Sample preserved). Never lowers below cost; skips already-correct.
+- RUN (Steve): `DRY_RUN=0 LIMIT=1 python3 write_reonboard.py` (smoke), verify in admin, then `DRY_RUN=0 python3 write_reonboard.py`. $0 API.
diff --git a/write-results.json b/write-results.json
new file mode 100644
index 0000000..94c49c4
--- /dev/null
+++ b/write-results.json
@@ -0,0 +1,6 @@
+{
+ "updated": 3,
+ "created": 3,
+ "skipped": 0,
+ "errors": []
+}
\ No newline at end of file
diff --git a/write_reonboard.py b/write_reonboard.py
new file mode 100644
index 0000000..d008ee8
--- /dev/null
+++ b/write_reonboard.py
@@ -0,0 +1,98 @@
+#!/usr/bin/env python3
+"""
+EUR- reonboard live write — GATED (Steve runs). Prices each priceable product's
+sellable roll to retail = trade x1.810 (from the authed price list).
+
+Per product (looked up by roll_sku):
+ * if a roll variant (sku == roll_sku) already exists -> UPDATE its price
+ (this fixes the live BELOW-COST prices — many rolls are priced under cost).
+ * if the product is Sample-only -> CREATE a roll variant
+ on the "Size" option (value "Roll"), inventoryPolicy CONTINUE, tracked=false,
+ Sample preserved (proven on canary EUR-71216).
+
+SAFETY: DRY_RUN=1 default (prints planned change, writes nothing). Smoke-test:
+ DRY_RUN=0 LIMIT=1 python3 write_reonboard.py (verify in admin, then full run)
+Never lowers a price below trade cost. Skips anything already at the target.
+"""
+import os, csv, json, time, subprocess, urllib.request
+
+HERE = os.path.dirname(os.path.abspath(__file__))
+DRY_RUN = os.environ.get("DRY_RUN", "1") != "0"
+LIMIT = int(os.environ.get("LIMIT", "0")) or None
+
+def _tok():
+ for l in open(os.path.expanduser("~/Projects/secrets-manager/.env")):
+ if l.startswith("SHOPIFY_ADMIN_TOKEN="): return l.split("=", 1)[1].strip().strip('"')
+ raise SystemExit("token not found")
+TOKEN = os.environ.get("AT") or _tok()
+URL = "https://designer-laboratory-sandbox.myshopify.com/admin/api/2024-10/graphql.json"
+
+def gql(q, v=None):
+ b = json.dumps({"query": q, "variables": v or {}}).encode()
+ req = urllib.request.Request(URL, b, {"X-Shopify-Access-Token": TOKEN, "Content-Type": "application/json"})
+ for a in range(8):
+ try:
+ d = json.load(urllib.request.urlopen(req, timeout=90))
+ if "errors" in d and any("THROTTLED" in str(e) for e in d["errors"]):
+ time.sleep(2 * (a + 1)); continue
+ return d
+ except Exception:
+ time.sleep(2 * (a + 1))
+ raise RuntimeError("gql failed")
+
+FIND = """query($q:String!){products(first:1,query:$q){edges{node{id
+ options{name values}
+ variants(first:15){edges{node{id sku price selectedOptions{name value}}}}}}}}"""
+VUPDATE = """mutation($pid:ID!,$v:[ProductVariantsBulkInput!]!){
+ productVariantsBulkUpdate(productId:$pid,variants:$v){userErrors{field message}}}"""
+VCREATE = """mutation($pid:ID!,$v:[ProductVariantsBulkInput!]!){
+ productVariantsBulkCreate(productId:$pid,variants:$v){userErrors{field message}}}"""
+
+def main():
+ rows = list(csv.DictReader(open(os.path.join(HERE, "reonboard.csv"))))
+ if LIMIT: rows = rows[:LIMIT]
+ updated = created = skipped = 0; errs = []; results = []
+ print(f"{'DRY-RUN' if DRY_RUN else 'LIVE'}: {len(rows)} products -> roll @ trade x1.810")
+ for i, r in enumerate(rows):
+ roll_sku, target, trade = r["roll_sku"], float(r["retail"]), float(r["trade_price"])
+ d = gql(FIND, {"q": "sku:" + roll_sku})
+ e = (d.get("data") or {}).get("products", {}).get("edges", [])
+ if not e:
+ errs.append({"sku": roll_sku, "err": "product not found"}); continue
+ node = e[0]["node"]; pid = node["id"]
+ vmap = {v["node"]["sku"]: v["node"] for v in node["variants"]["edges"]}
+ roll = vmap.get(roll_sku)
+ # size option value used for the roll (existing convention or "Roll")
+ size_opt = next((o for o in node["options"] if o["name"].lower() == "size"), None)
+ roll_val = next((val for val in (size_opt["values"] if size_opt else []) if val.lower() != "sample"), "Roll")
+
+ if roll:
+ cur = float(roll["price"])
+ if abs(cur - target) < 0.02:
+ skipped += 1; continue
+ action = "UPDATE"; op = (VUPDATE, [{"id": roll["id"], "price": f"{target:.2f}"}])
+ else:
+ action = "CREATE"; op = (VCREATE, [{
+ "optionValues": [{"optionName": "Size", "name": roll_val}],
+ "price": f"{target:.2f}", "inventoryItem": {"tracked": False, "sku": roll_sku},
+ "inventoryPolicy": "CONTINUE"}])
+ if DRY_RUN:
+ if i < 6: print(f" {action} {roll_sku}: ${roll['price'] if roll else '—'} -> ${target:.2f} (cost ${trade})")
+ updated += action == "UPDATE"; created += action == "CREATE"; continue
+ mut, variants = op
+ res = gql(mut, {"pid": pid, "v": variants})
+ key = "productVariantsBulkUpdate" if action == "UPDATE" else "productVariantsBulkCreate"
+ ue = ((res.get("data") or {}).get(key) or {}).get("userErrors") or []
+ if ue: errs.append({"sku": roll_sku, "err": ue[:2]})
+ else:
+ updated += action == "UPDATE"; created += action == "CREATE"
+ results.append({"sku": roll_sku, "action": action, "price": f"{target:.2f}"})
+ if i % 25 == 0: print(f" ...{i}/{len(rows)} upd={updated} new={created} err={len(errs)}")
+ time.sleep(0.3)
+ json.dump({"updated": updated, "created": created, "skipped": skipped, "errors": errs[:25]},
+ open(os.path.join(HERE, "write-results.json"), "w"), indent=2)
+ print(f"\nDONE {'(DRY-RUN)' if DRY_RUN else ''}: UPDATE={updated} CREATE={created} skip={skipped} err={len(errs)}")
+ if errs: print("errs:", json.dumps(errs[:3]))
+
+if __name__ == "__main__":
+ main()
← e7fc236 Cody-gate fixes: hold 154 Panel/Mural (sold as sets not roll
·
back to Eur Recrawl
·
Cycle 6: coordinate lanes w/ claude-eur, verify held sets (d 7c4b477 →