fix: merge local products_url_added.json (synced from zalo-products-all) — newest products on top of modal list

src/vaix-rag.js

@@ -63,6 +63,11 @@ const DETAIL_URL = "https://huggingface.co/datasets/bep40/grob-products-updated/
 // products to the searchable catalog. Shape is the zalobot _scrape_product_url
 // format: {n,l,i,p,pn,c,cs,ci,imgs,sum,desc,specs,feats,sku,vid,mod,brand,slug,...}
 const ADDED_URL = "https://huggingface.co/datasets/bep40/grob-products-updated/resolve/main/products_url_added.json";
+// ── Zalo-sync products (synced from bep40/zalo-products-all by auto_sync_worker) ──
+// The webhook space auto-sync worker prepends NEW products (model-based) to this
+// file ON the vai-market space itself, so the floating product list modal always
+// shows the most-recent products on top. Best-effort (fail → empty list).
+const ADDED_LOCAL_URL = "/products_url_added.json";
 // ── Persistent catalog cache (CacheStorage) ───────────────────────────────
 // The index JSON is ~10 MB. Without a persistent cache every page load
 // re-downloads + re-parses it (cold cache: the "danh sách sản phẩm load chậm"
@@ -1167,6 +1172,59 @@ async function load() {
         }
       }
     } catch (e) { console.warn("[VAIX] products_url_added merge skipped:", e && e.message); }
+    // ── Merge ZALO-SYNC products (newest, synced from zalo-products-all) ──
+    // These live ON the vai-market space itself (written by auto_sync_worker)
+    // and must surface on TOP of the modal product list so the newest
+    // products always appear first. Dedup against BOTH the base catalog and
+    // the previously-merged grob-added products by sku/slug/link/name.
+    try {
+      const localResp = await fetch(ADDED_LOCAL_URL, { signal: AbortSignal.timeout(15000) });
+      if (localResp.ok) {
+        const localRaw = await localResp.json();
+        if (Array.isArray(localRaw) && localRaw.length) {
+          const localAdded = localRaw.map((p) => ({
+            name: p.n || p.name || "", title_clean: p.n || p.name || "",
+            brand: p.brand || "", price: p.p || p.price || "", priceNum: Number(p.pn || 0),
+            listPn: Number(p.listPn || 0) || 0, salePn: Number(p.salePn || p.salePn || p.pn || 0) || 0, priceMode: p.priceMode || "sale",
+            category: normalizeCategory(p.c || p.cat || "", p.n || p.name || ""), category_slug: p.cs || "", category_icon: p.ci || "fa-box",
+            sku: p.sku || p.s || p.mod || "", model: p.mod || p.model || p.sku || "", slug: p.slug || p.sl || "",
+            description: p.desc || p.d || "", summary: p.sum || p.summary || "",
+            features: Array.isArray(p.feats) ? p.feats : (Array.isArray(p.f) ? p.f : []),
+            specs: (p.specs && typeof p.specs === "object") ? p.specs : {},
+            video: p.vid || "", image: p.i || p.image || "",
+            images: Array.isArray(p.imgs) ? p.imgs : (Array.isArray(p.g) ? p.g : []), link: p.l || "",
+            _addedBy: "zalo-products-all-autosync"
+          }));
+          const baseSkus2 = new Set(allProducts.map((p) => String(p.sku).toLowerCase()).filter(Boolean));
+          const baseSlugs2 = new Set(allProducts.map((p) => String(p.slug || "").toLowerCase()).filter(Boolean));
+          const seenKeys2 = new Set();
+          const seenNames2 = new Set();
+          const uniqueLocal = localAdded.filter((p) => {
+            const sk = String(p.sku || "").toLowerCase();
+            const sl = String(p.slug || "").toLowerCase();
+            const lk = String(p.link || "").toLowerCase();
+            const nm = String(p.title_clean || p.name || "").toLowerCase().replace(/\s+/g, " ").trim();
+            if (sk && baseSkus2.has(sk)) return false;
+            if (sl && baseSlugs2.has(sl)) return false;
+            if (nm && seenNames2.has(nm)) return false;
+            if (nm) seenNames2.add(nm);
+            let key = "";
+            if (sk) key = "sku:" + sk;
+            else if (sl) key = "slug:" + sl;
+            else if (lk) key = "link:" + lk;
+            else if (nm) key = "name:" + nm;
+            if (!key) return false;
+            if (seenKeys2.has(key)) return false;
+            seenKeys2.add(key);
+            return true;
+          });
+          if (uniqueLocal.length) {
+            allProducts = uniqueLocal.concat(allProducts);
+            console.log("[VAIX] Merged " + uniqueLocal.length + " zalo-sync products (on top) from local products_url_added.json");
+          }
+        }
+      }
+    } catch (e) { console.warn("[VAIX] local products_url_added merge skipped:", e && e.message); }
     loaded = true;
     console.log("[VAIX] Loaded " + allProducts.length + " products (" + source + ") in " + (Date.now() - _ls) + "ms");
     handleProductUrlParam();