Update app.py

app.py

@@ -9,6 +9,7 @@ import gradio as gr
 import base64
 
 PRINTIFY_BASE = "https://api.printify.com"
+DEFAULT_BASE_PRICE = 24.99
 GRID_FILENAME = "grid.png"
 
 
@@ -89,9 +90,7 @@ def _build_product(blob: Dict[str, Any], currency: str, logs: List[str]) -> Dict
 
     snapshot = []
     for v in variants:
-        cents = v.get("cost")
-        if cents is None:
-            cents = v.get("price")
+        cents = v.get("price")
         cents = int(cents) if isinstance(cents, (int, str)) and str(cents).isdigit() else None
 
         ph = v.get("placeholders")
@@ -113,8 +112,8 @@ def _build_product(blob: Dict[str, Any], currency: str, logs: List[str]) -> Dict
             "sku": v.get("sku"),
             "size": (v.get("options") or {}).get("size"),
             "color": (v.get("options") or {}).get("color"),
-            "costCents": cents,
-            "cost": round(cents / 100, 2) if cents is not None else None,
+            "priceCents": cents,
+            "price": round(cents / 100, 2) if cents is not None else None,
             "placeholders": placeholders,
         })
 
@@ -150,10 +149,8 @@ def _build_product(blob: Dict[str, Any], currency: str, logs: List[str]) -> Dict
         if ph.get("position")
     })
 
-    all_cost_cents = [v["costCents"] for v in snapshot if v["costCents"] is not None]
-    if not all_cost_cents:
-        raise RuntimeError("No variant cost returned by API (expected 'cost' or 'price' in cents).")
-    min_price = round(min(all_cost_cents) / 100, 2)
+    all_cents = [v["priceCents"] for v in snapshot if v["priceCents"] is not None]
+    min_price = round(min(all_cents) / 100, 2) if all_cents else DEFAULT_BASE_PRICE
 
     colors = sorted({v["color"] for v in snapshot if v["color"]})
     sizes = sorted({v["size"] for v in snapshot if v["size"]})
@@ -240,29 +237,6 @@ def _upload_grid_from_file(logs: List[str]) -> Dict[str, Any]:
     )
     return resp
 
-    with open(path, "rb") as f:
-        r = requests.post(
-            f"{PRINTIFY_BASE}/v1/uploads/images.json",
-            headers=_auth_headers(),
-            files={"file": (GRID_FILENAME, f, "image/png")},
-            timeout=60,
-        )
-
-    if r.status_code >= 400:
-        raise RuntimeError(f"UPLOAD_HTTP {r.status_code}: {r.text[:2000]}")
-
-    resp = r.json()
-    if not isinstance(resp, dict) or not resp.get("id"):
-        raise RuntimeError(f"Unexpected upload response: {str(resp)[:500]}")
-
-    _log(
-        logs,
-        f"GRID_UPLOAD id={resp.get('id')} "
-        f"file={resp.get('file_name') or resp.get('name')} "
-        f"w={resp.get('width')} h={resp.get('height')}",
-    )
-    return resp
-
 
 def _scale_fill(ph_w: float, ph_h: float, img_w: float, img_h: float) -> float:
     if ph_w <= 0 or ph_h <= 0 or img_w <= 0 or img_h <= 0:
@@ -344,7 +318,7 @@ def _create_one_product_with_grid(
         "print_provider_id": int(provider_id),
         "variants": [{
             "id": int(variant_id),
-            "price": int(product_info.get("price") * 100),
+            "price": 1,
             "is_enabled": True,
         }],
         "print_areas": [{
@@ -356,8 +330,7 @@ def _create_one_product_with_grid(
     _log(
         logs,
         f"PHASE_B_CREATE shop_id={shop_id} "
-        f"blueprint_id={bp_id} provider_id={provider_id} variant_id={variant_id} "
-        f"price_cents={int(product_info.get('price') * 100)}",
+        f"blueprint_id={bp_id} provider_id={provider_id} variant_id={variant_id}",
     )
 
     created = _req(
@@ -455,16 +428,97 @@ def phase_b(currency: str) -> Generator[Tuple[str, str], None, None]:
         yield flush()
 
 
+def phase_c(currency: str, product_id: str) -> Generator[Tuple[str, str], None, None]:
+    logs: List[str] = []
+    result: Dict[str, Any] = {}
+
+    def flush():
+        return "\n".join(logs), json.dumps(result, indent=2)
+
+    try:
+        _log(logs, "PHASE_C_START")
+        yield flush()
+
+        if not product_id or not str(product_id).strip():
+            raise RuntimeError("Missing product_id.")
+
+        shops = _req("GET", "/v1/shops.json")
+        _log(logs, f"SHOP_LIST {json.dumps(shops)}")
+        yield flush()
+
+        shop_id = _pick_shop_id(shops)
+        _log(logs, f"SHOP_ID {shop_id}")
+        yield flush()
+
+        pid = str(product_id).strip()
+        _log(logs, f"PHASE_C_GET_PRODUCT product_id={pid}")
+        prod = _req("GET", f"/v1/shops/{shop_id}/products/{pid}.json")
+        result["productDetails"] = prod
+        yield flush()
+
+        variants = prod.get("variants") or []
+        if not isinstance(variants, list) or not variants:
+            raise RuntimeError("Product details missing variants.")
+
+        update_variants = []
+        for v in variants:
+            vid = v.get("id")
+            cost = v.get("cost")
+            if vid is None or cost is None:
+                _log(logs, f"COST_MISSING variant_id={vid} cost={cost}")
+                continue
+            try:
+                vid_i = int(vid)
+                cost_i = int(cost)
+            except Exception:
+                _log(logs, f"COST_BAD variant_id={vid} cost={cost}")
+                continue
+
+            update_variants.append({
+                "id": vid_i,
+                "price": cost_i,
+                "is_enabled": bool(v.get("is_enabled")),
+            })
+
+            _log(
+                logs,
+                f"PRICE_RECONCILE variant_id={vid_i} cost={cost_i} "
+                f"old_price={v.get('price')} enabled={bool(v.get('is_enabled'))}",
+            )
+
+        if not update_variants:
+            raise RuntimeError("No variants with cost found to reconcile pricing.")
+
+        payload = {"variants": update_variants}
+
+        _log(logs, f"PHASE_C_UPDATE_PRICES count={len(update_variants)}")
+        updated = _req("PUT", f"/v1/shops/{shop_id}/products/{pid}.json", json_body=payload)
+        result["priceUpdateResponse"] = updated
+        yield flush()
+
+        _log(logs, "PHASE_C_DONE")
+        yield flush()
+
+    except Exception as e:
+        _log(logs, f"ERROR: {e}")
+        result = {"error": str(e)}
+        yield flush()
+
+
 with gr.Blocks(title="Printify Catalog Probe") as demo:
     gr.Markdown("Extract and normalize ONE Printify blueprint/provider into a structured JSON object.")
 
     currency = gr.Textbox(label="Currency", value="USD")
-    btn = gr.Button("Run")
-    btn_b = gr.Button("Phase B (Test)")
+    product_id = gr.Textbox(label="Product ID (for Phase C)", value="")
+
+    btn = gr.Button("Run (A)")
+    btn_b = gr.Button("Phase B (Create Test)")
+    btn_c = gr.Button("Phase C (Pricing Reconciliation)")
     logs = gr.Textbox(label="Logs", lines=18)
     out = gr.Textbox(label="Output JSON", lines=18)
 
     btn.click(run, inputs=[currency], outputs=[logs, out])
     btn_b.click(phase_b, inputs=[currency], outputs=[logs, out])
+    btn_c.click(phase_c, inputs=[currency, product_id], outputs=[logs, out])
 
 demo.queue().launch()