Update app.py

app.py

@@ -8,6 +8,7 @@ import requests
 import gradio as gr
 import base64
 import re
+import hashlib
 
 PRINTIFY_BASE = "https://api.printify.com"
 DEFAULT_BASE_PRICE = 0.001
@@ -32,6 +33,18 @@ def _auth_headers() -> Dict[str, str]:
     return {"Authorization": f"Bearer {token}"}
 
 
+def _batch_fingerprint(shop_id: str, blueprint_id: int, provider_id: int, enabled_variant_ids: List[int]) -> str:
+    ids = sorted(int(x) for x in enabled_variant_ids)
+    payload = {
+        "shop_id": str(shop_id),
+        "blueprint_id": int(blueprint_id),
+        "provider_id": int(provider_id),
+        "enabled_variant_ids": ids,
+    }
+    raw = json.dumps(payload, separators=(",", ":"), sort_keys=True).encode("utf-8")
+    return hashlib.sha1(raw).hexdigest()
+
+
 def _parse_retry_after_seconds(r: requests.Response) -> Optional[float]:
     ra = r.headers.get("Retry-After")
     if ra:
@@ -65,9 +78,15 @@ def _req(
     path: str,
     json_body: Optional[Dict[str, Any]] = None,
     logs: Optional[List[str]] = None,
+    extra_headers: Optional[Dict[str, str]] = None,
 ) -> Any:
+    headers = _auth_headers()
+    if extra_headers:
+        for k, v in extra_headers.items():
+            headers[str(k)] = str(v)
+
     kwargs: Dict[str, Any] = {
-        "headers": _auth_headers(),
+        "headers": headers,
         "timeout": 60,
     }
     if json_body is not None:
@@ -466,6 +485,8 @@ def _create_product_all_variants_with_grid(
             except Exception:
                 continue
 
+    fp = _batch_fingerprint(str(shop_id), int(bp_id), int(provider_id), sorted(list(enabled_ids)))
+
     img_id = upload.get("id")
     img_w = float(upload.get("width") or 0)
     img_h = float(upload.get("height") or 0)
@@ -551,7 +572,7 @@ def _create_product_all_variants_with_grid(
     provider_name = provider_details.get("title") or provider_details.get("name") or str(provider_id)
 
     title = (product_info.get("name") or "Printify Grid Test") + f" — {provider_name}"
-    description = product_info.get("description") or ""
+    description = (product_info.get("description") or "") + f"\n\nBATCH_FP={fp}"
 
     payload = {
         "title": title,
@@ -565,7 +586,8 @@ def _create_product_all_variants_with_grid(
     _log(
         logs,
         f"PHASE_B_CREATE shop_id={shop_id} blueprint_id={bp_id} provider_id={provider_id} "
-        f"variants_payload_total={len(variants_payload)} enabled={enabled_count} print_areas_payload={len(print_areas_payload)}",
+        f"variants_payload_total={len(variants_payload)} enabled={enabled_count} print_areas_payload={len(print_areas_payload)} "
+        f"idempotency_key={fp}",
     )
 
     created = _req(
@@ -573,6 +595,7 @@ def _create_product_all_variants_with_grid(
         f"/v1/shops/{shop_id}/products.json",
         json_body=payload,
         logs=logs,
+        extra_headers={"Idempotency-Key": fp},
     )
     if not isinstance(created, Dict):
         raise RuntimeError(f"Unexpected create response: {str(created)[:500]}")