Update app.py

app.py

@@ -9,7 +9,6 @@ import gradio as gr
 import base64
 
 PRINTIFY_BASE = "https://api.printify.com"
-DEFAULT_BASE_PRICE = 24.99
 GRID_FILENAME = "grid.png"
 
 
@@ -90,7 +89,9 @@ def _build_product(blob: Dict[str, Any], currency: str, logs: List[str]) -> Dict
 
     snapshot = []
     for v in variants:
-        cents = v.get("price")
+        cents = v.get("cost")
+        if cents is None:
+            cents = v.get("price")
         cents = int(cents) if isinstance(cents, (int, str)) and str(cents).isdigit() else None
 
         ph = v.get("placeholders")
@@ -112,8 +113,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"),
-            "priceCents": cents,
-            "price": round(cents / 100, 2) if cents is not None else None,
+            "costCents": cents,
+            "cost": round(cents / 100, 2) if cents is not None else None,
             "placeholders": placeholders,
         })
 
@@ -149,8 +150,10 @@ def _build_product(blob: Dict[str, Any], currency: str, logs: List[str]) -> Dict
         if ph.get("position")
     })
 
-    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
+    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)
 
     colors = sorted({v["color"] for v in snapshot if v["color"]})
     sizes = sorted({v["size"] for v in snapshot if v["size"]})
@@ -237,6 +240,29 @@ 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:
@@ -318,7 +344,7 @@ def _create_one_product_with_grid(
         "print_provider_id": int(provider_id),
         "variants": [{
             "id": int(variant_id),
-            "price": 1,
+            "price": int(product_info.get("price") * 100),
             "is_enabled": True,
         }],
         "print_areas": [{
@@ -330,7 +356,8 @@ 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"blueprint_id={bp_id} provider_id={provider_id} variant_id={variant_id} "
+        f"price_cents={int(product_info.get('price') * 100)}",
     )
 
     created = _req(
@@ -428,97 +455,16 @@ 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")
-    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)")
+    btn = gr.Button("Run")
+    btn_b = gr.Button("Phase B (Test)")
     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()