Add /api/promos overlay store + BIG SALE SEO meta

index.ts

@@ -69,6 +69,36 @@ async function loadVaixProducts(): Promise<void> {
 loadVaixProducts().catch(() => {});
 setTimeout(() => { if (!VAIX_LOADED) loadVaixProducts().catch(() => {}); }, 3000);
 
+// ── Promo overlay store (product edits + BIGSALE + COMBO) ──
+// Durable truth lives in the dataset bep40/vaistudio-data/promos.json (never the
+// Space repo, so saving never triggers a rebuild). Shape:
+//   { productEdits: {<sku>:{name,description,priceNum,image,images[],specs{},features[],deleted}},
+//     bigsale: [ {code,name,category,price,bigsale,discount,status,qty,image} ],
+//     combo:  [ {code,name,price,items:[{name,sku,price,image}]} ] }
+const PROMOS_DATASET = "bep40/vaistudio-data";
+const PROMOS_FILE = "promos.json";
+async function readPromos(token?: string): Promise<any> {
+  try {
+    const h = token ? { Authorization: "Bearer " + token } : {};
+    const r = await fetch("https://huggingface.co/datasets/" + PROMOS_DATASET + "/resolve/main/" + PROMOS_FILE, { headers: h, signal: AbortSignal.timeout(6000) });
+    if (r.ok) { const d = await r.json(); if (d && typeof d === "object") return d; }
+  } catch (e: any) { /* ignore */ }
+  return { productEdits: {}, bigsale: [], combo: [] };
+}
+async function writePromos(token: string, data: any): Promise<void> {
+  const content = JSON.stringify(data);
+  const payload = [
+    { key: "header", value: { summary: "Update promos via api", repo: { type: "dataset", id: PROMOS_DATASET } } },
+    { key: "file", value: { path: PROMOS_FILE, content } },
+  ].map((x) => JSON.stringify(x)).join("\n");
+  const commit = await fetch("https://huggingface.co/api/datasets/" + PROMOS_DATASET + "/commit/main", {
+    method: "POST",
+    headers: { Authorization: "Bearer " + token, "Content-Type": "application/x-ndjson" },
+    body: payload,
+  });
+  if (!commit.ok) throw new Error("Commit failed: HTTP " + commit.status + " " + (await commit.text().catch(() => "")).slice(0, 300));
+}
+
 function norm(s: string): string {
   return String(s || "").toLowerCase().normalize("NFD").replace(/[\u0300-\u036f]/g, "").replace(/[đĐ]/g, "d").replace(/[.\-\s]/g, "");
 }
@@ -218,6 +248,31 @@ async function serveProductOG(req: Request): Promise<Response> {
     }
   }
 
+  // ── BIG SALE deep-link SEO (?bigsale=<code>) ── shows the discounted price.
+  const bigsaleCodeRaw = url.searchParams.get("bigsale");
+  if (bigsaleCodeRaw && !productSlug) {
+    try {
+      const token = (process.env.HF_INFERENCE_TOKEN || process.env.HF_TOKEN || "").trim();
+      const promos = await readPromos(token ? token : undefined);
+      const normBs = (s: string) => String(s || "").trim().toUpperCase().replace(/\s+/g, " ");
+      const target = normBs(decodeURIComponent(bigsaleCodeRaw));
+      const bsProd = (Array.isArray(promos.bigsale) ? promos.bigsale : []).find((b: any) => normBs(b.code) === target);
+      if (bsProd) {
+        const bsName = esc(bsProd.name || bsProd.code || "Sản phẩm BIG SALE");
+        const bsPrice = Number(String(bsProd.bigsale || "").replace(/\./g, "")) || 0;
+        const bsImgRaw = bsProd.image || "";
+        const bsImg = bsImgRaw ? escURL(bsImgRaw) : fallbackImg;
+        const ogTitle = "🔥 BIG SALE: " + bsName + (bsPrice > 0 ? " - " + Number(bsPrice).toLocaleString("vi-VN") + "₫" : "") + " | V.AI STUDIO";
+        const ogDesc = (bsPrice > 0 ? "Giá BIG SALE " + bsName + " chỉ còn " + Number(bsPrice).toLocaleString("vi-VN") + "₫" : "Chương trình BIG SALE V.AI STUDIO") + " | Giảm " + esc("-" + (bsProd.discount || "0%"));
+        const ogTags = buildOGTags(ogTitle, ogDesc, bsImg, url.href, true, bsPrice);
+        return new Response(index.replace(/<\/head>/, ogTags + "\n  </head>"), {
+          status: 200,
+          headers: { "Content-Type": "text/html; charset=utf-8", "Cache-Control": "no-cache, no-store, must-revalidate", "Pragma": "no-cache", "Expires": "0" },
+        });
+      }
+    } catch (e: any) { /* fall through to default og */ }
+  }
+
   // Fallback OG tags — always set for any request (no product match or no ?product param)
   const fallbackTitle = "Gemma Avatar + V.AI STUDIO - Chat & Voice AI";
   const fallbackDesc = "Trò chuyện voice/text với Gemma 4. Khám phá 8000+ sản phẩm gia dụng.";
@@ -1423,6 +1478,36 @@ const server = Bun.serve({
         }
       },
     },
+    "/api/promos": {
+      GET: async () => {
+        try {
+          const token = (process.env.HF_INFERENCE_TOKEN || process.env.HF_TOKEN || "").trim();
+          return Response.json(await readPromos(token || undefined));
+        } catch (e: any) { return Response.json({ error: e.message }, { status: 500 }); }
+      },
+      POST: async (req: Request) => {
+        try {
+          const token = (process.env.HF_INFERENCE_TOKEN || process.env.HF_TOKEN || "").trim();
+          if (!token) return Response.json({ error: "No write token on server" }, { status: 500 });
+          let body: any = {};
+          try { body = await req.json(); } catch (_) {}
+          if (!body || typeof body !== "object") return Response.json({ error: "Bad body" }, { status: 400 });
+          const cur = await readPromos(token);
+          const merge = cur;
+          if (!merge.productEdits || typeof merge.productEdits !== "object") merge.productEdits = {};
+          if (body.resetProductEdits) { merge.productEdits = {}; }
+          if (body.productEdits && typeof body.productEdits === "object" && !body.resetProductEdits) {
+            for (const k in body.productEdits) merge.productEdits[k] = body.productEdits[k];
+          }
+          if (body.resetBigsale === true) { merge.bigsale = Array.isArray(body.bigsale) ? body.bigsale : []; }
+          else if (Array.isArray(body.bigsale)) { merge.bigsale = body.bigsale; }
+          if (body.resetCombo === true) { merge.combo = Array.isArray(body.combo) ? body.combo : []; }
+          else if (Array.isArray(body.combo)) { merge.combo = body.combo; }
+          await writePromos(token, merge);
+          return Response.json({ ok: true, promos: merge });
+        } catch (e: any) { return Response.json({ error: e.message }, { status: 502 }); }
+      },
+    },
     "/api/customers": {
       GET: async () => {
         try {