סל קניות

\r\n

\r\n בפועל ${shekel(cart.totals.scanned)}\r\n מתוכנן ${shekel(cart.totals.planned)}\r\n

\r\n \r\n

\r\n\r\n ${!cameraError && html`\r\n

\r\n

`}\r\n\r\n

\r\n ${cameraError && html`

<${Icon} name=\"alert\" size=\"17\" /> ${cameraError}

`}\r\n\r\n ${last?.status === \"error\" && html`\r\n

<${Icon} name=\"alert\" size=\"17\" /> ${last.message}

`}\r\n\r\n ${last?.status === \"matched\" && !pending && html`\r\n

\r\n <${Icon} name=\"check\" size=\"18\" />\r\n

\r\n ${last.name}\r\n ${shekel(last.price)} · נסרקו ${last.scannedQty} · ${SOURCE_LABEL[last.source] || \"\"}\r\n

\r\n

`}\r\n\r\n ${last?.status === \"added\" && !pending && html`\r\n

\r\n <${Icon} name=\"check\" size=\"18\" />\r\n

\r\n ${last.name}\r\n נוסף לקנייה · ${shekel(last.price)}\r\n

\r\n

`}\r\n\r\n ${pending?.status === \"found\" && html`\r\n

\r\n

\r\n ${pending.name}\r\n ${shekel(pending.price)} · ${SOURCE_LABEL[pending.source] || \"\"} · לא ברשימה שלכם\r\n

\r\n

\r\n \r\n \r\n

\r\n

`}\r\n\r\n ${pending?.status === \"unknown\" && html`\r\n

\r\n

\r\n ברקוד ${pending.barcode} לא מוכר\r\n הוסיפו אותו ידנית עם שם ומחיר\r\n

\r\n

\r\n setUnknownName(e.target.value)} />\r\n setUnknownPrice(e.target.value)} />\r\n

\r\n

\r\n \r\n \r\n

\r\n

`}\r\n\r\n ${manualOpen && html`\r\n

\r\n

`;\r\n}\r\n",[],[170,258],"9f22763e-e7c3-4368-87c7-5d70861a5617","manifest.json","fab7b2a6-6654-11f1-9e0e-1607ee4eb77e",19,["D",1781265059468],"{\r\n \"name\": \"סל קניות\",\r\n \"short_name\": \"סל\",\r\n \"description\": \"רשימת קניות חכמה עם מחירים אמיתיים מהסופרים בישראל\",\r\n \"lang\": \"he\",\r\n \"dir\": \"rtl\",\r\n \"start_url\": \"/\",\r\n \"scope\": \"/\",\r\n \"display\": \"standalone\",\r\n \"orientation\": \"portrait\",\r\n \"background_color\": \"#f2f5f7\",\r\n \"theme_color\": \"#047857\",\r\n \"icons\": [\r\n { \"src\": \"/icons/icon-192.png\", \"sizes\": \"192x192\", \"type\": \"image/png\" },\r\n { \"src\": \"/icons/icon-512.png\", \"sizes\": \"512x512\", \"type\": \"image/png\" },\r\n { \"src\": \"/icons/icon-512.png\", \"sizes\": \"512x512\", \"type\": \"image/png\", \"purpose\": \"maskable\" },\r\n { \"src\": \"/icons/icon.svg\", \"sizes\": \"any\", \"type\": \"image/svg+xml\" }\r\n ]\r\n}\r\n",[],[170,266],"9cd6ca67-c486-461d-b0be-934183779896","index.js","fa93870a-6654-11f1-b6a0-1607ee4eb77e",18,["D",1781265059239],"import React from \"https://esm.sh/react@18.3.1\";\r\nimport { createRoot } from \"https://esm.sh/react-dom@18.3.1/client\";\r\nimport { App } from \"./app.js\";\r\n\r\ncreateRoot(document.getElementById(\"root\")).render(React.createElement(App));\r\n",[],[170,274],"850c2115-23b5-4939-898d-7c4f99d42600","index.html","fa71d22c-6654-11f1-8aaf-1607ee4eb77e",17,["D",1781265059012],"\r\n\r\n\r\n \r\n \r\n סל קניות\r\n \r\n \r\n \r\n \r\n \r\n \r\n \r\n \r\n \r\n \r\n \r\n \r\n \r\n \r\n\r\n\r\n

\r\n

\r\n \r\n

\r\n

טוען את הסל…

\r\n

\r\n \r\n \r\n \r\n\r\n\r\n",[],[170,282],"a0420aef-774f-46a7-b36f-cbe0bff0c205","app.js","fa47b1f4-6654-11f1-98a0-1607ee4eb77e",16,["D",1781265058738],"import { html, useCallback, useEffect, useRef, useState } from \"./ui.js\";\r\nimport { api, friendlyError, getPin, setPin } from \"./api.js\";\r\nimport {\r\n CartView,\r\n FavoritesView,\r\n Icon,\r\n PinScreen,\r\n SearchView,\r\n SettingsSheet,\r\n SummarySheet,\r\n Toast,\r\n} from \"./views.js\";\r\nimport { ScannerOverlay } from \"./scanner.js\";\r\n\r\nconst EMPTY_CART = { items: [], totals: { planned: 0, scanned: 0, itemCount: 0, checkedCount: 0 } };\r\nconst CART_CACHE_KEY = \"sal_cart_cache\";\r\n\r\nexport function App() {\r\n const [config, setConfig] = useState(null);\r\n const [authed, setAuthed] = useState(false);\r\n const [pinError, setPinError] = useState(\"\");\r\n const [pinBusy, setPinBusy] = useState(false);\r\n\r\n const [tab, setTab] = useState(\"cart\");\r\n const [cart, setCart] = useState(EMPTY_CART);\r\n const [cartLoaded, setCartLoaded] = useState(false);\r\n const [offline, setOffline] = useState(false);\r\n\r\n const [shopping, setShopping] = useState(false);\r\n const [scannerOpen, setScannerOpen] = useState(false);\r\n const [summaryOpen, setSummaryOpen] = useState(false);\r\n const [settingsOpen, setSettingsOpen] = useState(false);\r\n const [refreshing, setRefreshing] = useState(false);\r\n\r\n const [toast, setToast] = useState(null);\r\n const toastTimer = useRef(null);\r\n\r\n const showToast = useCallback((msg, type = \"info\") => {\r\n clearTimeout(toastTimer.current);\r\n setToast({ msg, type, key: Date.now() });\r\n toastTimer.current = setTimeout(() => setToast(null), 2600);\r\n }, []);\r\n\r\n // ---------- boot ----------\r\n\r\n useEffect(() => {\r\n (async () => {\r\n try {\r\n const cfg = await api(\"/api/config\");\r\n setConfig(cfg);\r\n setAuthed(!cfg.authRequired || !!getPin());\r\n } catch {\r\n setConfig({ authRequired: false, hasApiKey: false });\r\n setAuthed(true);\r\n setOffline(true);\r\n }\r\n })();\r\n }, []);\r\n\r\n useEffect(() => {\r\n const onUnauthorized = () => {\r\n setAuthed(false);\r\n setPinError(\"הקוד השתנה — יש להזין שוב\");\r\n };\r\n window.addEventListener(\"sal:unauthorized\", onUnauthorized);\r\n return () => window.removeEventListener(\"sal:unauthorized\", onUnauthorized);\r\n }, []);\r\n\r\n const refreshCart = useCallback(async () => {\r\n try {\r\n const data = await api(\"/api/cart\");\r\n setCart(data);\r\n setCartLoaded(true);\r\n setOffline(false);\r\n } catch (e) {\r\n if (e.status === 401) return;\r\n const cached = localStorage.getItem(CART_CACHE_KEY);\r\n if (cached) {\r\n try {\r\n setCart(JSON.parse(cached));\r\n setCartLoaded(true);\r\n } catch { /* corrupt cache */ }\r\n }\r\n setOffline(true);\r\n }\r\n }, []);\r\n\r\n useEffect(() => {\r\n if (authed) refreshCart();\r\n }, [authed, refreshCart]);\r\n\r\n useEffect(() => {\r\n if (cartLoaded && !offline) localStorage.setItem(CART_CACHE_KEY, JSON.stringify(cart));\r\n }, [cart, cartLoaded, offline]);\r\n\r\n // ---------- pin ----------\r\n\r\n const submitPin = useCallback(async (pin) => {\r\n setPinBusy(true);\r\n setPinError(\"\");\r\n try {\r\n const r = await api(\"/api/auth/verify\", { method: \"POST\", body: { pin } });\r\n if (r.ok) {\r\n setPin(pin);\r\n setAuthed(true);\r\n } else {\r\n setPinError(\"קוד שגוי, נסו שוב\");\r\n }\r\n } catch (e) {\r\n setPinError(friendlyError(e));\r\n } finally {\r\n setPinBusy(false);\r\n }\r\n }, []);\r\n\r\n // ---------- cart actions ----------\r\n\r\n const applyCart = useCallback((data) => {\r\n if (data?.items) {\r\n setCart(data);\r\n setCartLoaded(true);\r\n }\r\n }, []);\r\n\r\n const addToCart = useCallback(async (ref, name) => {\r\n try {\r\n applyCart(await api(\"/api/cart\", { method: \"POST\", body: ref }));\r\n showToast(name ? `\"${name}\" נוסף לסל` : \"נוסף לסל\", \"ok\");\r\n return true;\r\n } catch (e) {\r\n showToast(friendlyError(e), \"error\");\r\n return false;\r\n }\r\n }, [applyCart, showToast]);\r\n\r\n const patchItem = useCallback(async (id, fields) => {\r\n try {\r\n applyCart(await api(`/api/cart/${id}`, { method: \"PATCH\", body: fields }));\r\n } catch (e) {\r\n showToast(friendlyError(e), \"error\");\r\n }\r\n }, [applyCart, showToast]);\r\n\r\n const removeItem = useCallback(async (id) => {\r\n try {\r\n applyCart(await api(`/api/cart/${id}`, { method: \"DELETE\" }));\r\n } catch (e) {\r\n showToast(friendlyError(e), \"error\");\r\n }\r\n }, [applyCart, showToast]);\r\n\r\n const clearCart = useCallback(async (mode) => {\r\n try {\r\n applyCart(await api(\"/api/cart/clear\", { method: \"POST\", body: { mode } }));\r\n showToast(mode === \"checked\" ? \"הפריטים שנקנו נמחקו\" : \"הסל נוקה\", \"ok\");\r\n } catch (e) {\r\n showToast(friendlyError(e), \"error\");\r\n }\r\n }, [applyCart, showToast]);\r\n\r\n const refreshPrices = useCallback(async () => {\r\n if (refreshing) return;\r\n setRefreshing(true);\r\n try {\r\n let rounds = 0;\r\n let res;\r\n do {\r\n res = await api(\"/api/cart/refresh-prices\", { method: \"POST\", body: {} });\r\n applyCart(res);\r\n rounds++;\r\n if (res.stopped) {\r\n showToast(friendlyError({ code: res.stopped }), \"warn\");\r\n break;\r\n }\r\n } while (res.remaining > 0 && rounds < 4);\r\n if (!res?.stopped) showToast(\"המחירים עודכנו\", \"ok\");\r\n } catch (e) {\r\n showToast(friendlyError(e), \"error\");\r\n } finally {\r\n setRefreshing(false);\r\n }\r\n }, [refreshing, applyCart, showToast]);\r\n\r\n // ---------- shopping mode / scanning ----------\r\n\r\n const handleScan = useCallback(async (code) => {\r\n try {\r\n const r = await api(`/api/lookup/${code}`);\r\n if (r.inCart) {\r\n const it = r.inCart;\r\n const scannedQty = Number(it.scanned_qty || 0) + 1;\r\n const actual = r.branchPrice ?? r.avgPrice ?? (it.actual_price != null ? Number(it.actual_price) : Number(it.unit_price));\r\n const data = await api(`/api/cart/${it.id}`, {\r\n method: \"PATCH\",\r\n body: { checked: 1, scanned_qty: scannedQty, actual_price: actual },\r\n });\r\n applyCart(data);\r\n return { status: \"matched\", name: it.name, price: actual, scannedQty, source: r.source };\r\n }\r\n if (r.found && r.name) {\r\n return { status: \"found\", barcode: code, name: r.name, price: r.expectedPrice, source: r.source };\r\n }\r\n return { status: \"unknown\", barcode: code };\r\n } catch (e) {\r\n return { status: \"error\", barcode: code, message: friendlyError(e) };\r\n }\r\n }, [applyCart]);\r\n\r\n const addUnplanned = useCallback(async ({ barcode, name, price, source }) => {\r\n try {\r\n applyCart(await api(\"/api/cart/unplanned\", { method: \"POST\", body: { barcode, name, price, source } }));\r\n showToast(`\"${name}\" נוסף לקנייה`, \"ok\");\r\n return true;\r\n } catch (e) {\r\n showToast(friendlyError(e), \"error\");\r\n return false;\r\n }\r\n }, [applyCart, showToast]);\r\n\r\n const startShopping = useCallback(() => {\r\n setTab(\"cart\");\r\n setShopping(true);\r\n }, []);\r\n\r\n const exitShopping = useCallback((clearMode) => {\r\n setSummaryOpen(false);\r\n setScannerOpen(false);\r\n setShopping(false);\r\n if (clearMode) clearCart(clearMode);\r\n }, [clearCart]);\r\n\r\n // ---------- render ----------\r\n\r\n if (!config) {\r\n return html`

<${Icon} name=\"cart\" size=\"34\" />

טוען את הסל…

`;\r\n }\r\n\r\n if (config.authRequired && !authed) {\r\n return html`<${PinScreen} onSubmit=${submitPin} error=${pinError} busy=${pinBusy} />`;\r\n }\r\n\r\n return html`\r\n

\r\n \r\n\r\n

\r\n ${tab === \"cart\" && html`\r\n <${CartView}\r\n cart=${cart}\r\n loaded=${cartLoaded}\r\n shopping=${shopping}\r\n refreshing=${refreshing}\r\n hasApiKey=${config.hasApiKey}\r\n onPatch=${patchItem}\r\n onRemove=${removeItem}\r\n onClear=${clearCart}\r\n onRefreshPrices=${refreshPrices}\r\n onStartShopping=${startShopping}\r\n onGoSearch=${() => setTab(\"search\")}\r\n />`}\r\n ${tab === \"search\" && html`\r\n <${SearchView}\r\n onAddToCart=${addToCart}\r\n showToast=${showToast}\r\n />`}\r\n ${tab === \"favorites\" && html`\r\n <${FavoritesView}\r\n onAddToCart=${addToCart}\r\n showToast=${showToast}\r\n />`}\r\n

\r\n\r\n ${!shopping && html`\r\n

\r\n ${[\r\n { id: \"cart\", label: \"סל\", icon: \"cart\", badge: cart.totals.itemCount || null },\r\n { id: \"search\", label: \"חיפוש\", icon: \"search\" },\r\n { id: \"favorites\", label: \"מועדפים\", icon: \"star\" },\r\n ].map((t) => html`\r\n `)}\r\n

`}\r\n\r\n ${shopping && html`\r\n

\r\n \r\n \r\n \r\n

`}\r\n\r\n ${scannerOpen && html`\r\n <${ScannerOverlay}\r\n cart=${cart}\r\n onScan=${handleScan}\r\n onAddUnplanned=${addUnplanned}\r\n onClose=${() => setScannerOpen(false)}\r\n />`}\r\n\r\n ${summaryOpen && html`\r\n <${SummarySheet}\r\n cart=${cart}\r\n onClose=${() => setSummaryOpen(false)}\r\n onFinish=${exitShopping}\r\n />`}\r\n\r\n ${settingsOpen && html`\r\n <${SettingsSheet}\r\n config=${config}\r\n showToast=${showToast}\r\n onClose=${() => setSettingsOpen(false)}\r\n />`}\r\n\r\n <${Toast} toast=${toast} />\r\n

`;\r\n}\r\n",[],[170,290],"7d95b84d-e213-4359-ab23-b0dae066a57f","api.js","fa2305fc-6654-11f1-98fc-1607ee4eb77e",15,["D",1781265058499],"const PIN_KEY = \"sal_pin\";\r\n\r\nexport function getPin() {\r\n return localStorage.getItem(PIN_KEY) || \"\";\r\n}\r\nexport function setPin(pin) {\r\n localStorage.setItem(PIN_KEY, pin);\r\n}\r\nexport function clearPin() {\r\n localStorage.removeItem(PIN_KEY);\r\n}\r\n\r\nexport class ApiError extends Error {\r\n constructor(message, status, code) {\r\n super(message);\r\n this.status = status;\r\n this.code = code;\r\n }\r\n}\r\n\r\nexport async function api(path, { method = \"GET\", body } = {}) {\r\n const res = await fetch(path, {\r\n method,\r\n headers: {\r\n ...(body !== undefined ? { \"content-type\": \"application/json\" } : {}),\r\n \"x-app-pin\": getPin(),\r\n },\r\n body: body !== undefined ? JSON.stringify(body) : undefined,\r\n });\r\n let data = null;\r\n try {\r\n data = await res.json();\r\n } catch {\r\n // empty / non-JSON response\r\n }\r\n if (!res.ok) {\r\n if (res.status === 401) window.dispatchEvent(new CustomEvent(\"sal:unauthorized\"));\r\n throw new ApiError(data?.error || res.statusText || \"שגיאה\", res.status, data?.code);\r\n }\r\n return data;\r\n}\r\n\r\nconst fmt = new Intl.NumberFormat(\"he-IL\", { style: \"currency\", currency: \"ILS\", maximumFractionDigits: 2 });\r\n\r\nexport function shekel(n) {\r\n if (n === null || n === undefined || Number.isNaN(Number(n))) return \"—\";\r\n return fmt.format(Number(n));\r\n}\r\n\r\nexport function friendlyError(e) {\r\n if (e?.code === \"NO_KEY\") return \"מפתח ה-API של Cheapersal עדיין לא הוגדר\";\r\n if (e?.code === \"BUDGET\") return \"נגמרה מכסת הבקשות היומית ל-API המחירים\";\r\n if (e?.code === \"RATE_LIMIT_EXCEEDED\") return \"יותר מדי בקשות בדקה — נסו שוב עוד רגע\";\r\n if (e?.status === 0 || e?.message === \"Failed to fetch\") return \"אין חיבור לרשת\";\r\n return e?.message || \"משהו השתבש\";\r\n}\r\n",[],[170,298],["D",1781264884294],[211,212,213,214,215,216,217,218,219],[170],"292c1ad7-763d-4786-bd18-418e0303eff7","syncCatalog.cron.ts","f9e31c62-6654-11f1-b2c2-1607ee4eb77e",14,["D",1781265058079],"interval","import {\r\n ensureSchema,\r\n getSettingJSON,\r\n getSyncStates,\r\n setSettingJSON,\r\n upsertCatalogBatch,\r\n upsertSyncState,\r\n} from \"./db.ts\";\r\nimport {\r\n CheapersalError,\r\n getBranchProducts,\r\n getUsage,\r\n hasApiKey,\r\n listBranches,\r\n sleep,\r\n} from \"./cheapersal.ts\";\r\nimport type { SyncBranch } from \"../shared/types.ts\";\r\n\r\n// Sync may consume at most this many of the 100 daily requests,\r\n// leaving the rest for live price lookups and scans.\r\nconst SYNC_DAILY_BUDGET = 55;\r\nconst PAGES_PER_RUN = 5;\r\nconst PAGE_LIMIT = 200;\r\nconst PAGE_PAUSE_MS = 6500; // stay under the 10 requests/minute limit\r\nconst REFRESH_AFTER_DAYS = 7;\r\n\r\nconst BIG_CHAINS = [\"שופרסל\", \"רמי לוי\", \"ויקטורי\", \"יוחננוף\", \"אושר עד\", \"טיב טעם\", \"קרפור\", \"מגה\"];\r\n\r\nfunction chainScore(name: string): number {\r\n const i = BIG_CHAINS.findIndex((c) => name.includes(c));\r\n return i === -1 ? BIG_CHAINS.length : i;\r\n}\r\n\r\n/**\r\n * Returns the branches whose catalogs we sync. If none are configured yet,\r\n * auto-picks branches of 3 distinct large chains (preferring online stores,\r\n * which carry the fullest assortment) and saves them to settings.\r\n */\r\nexport async function ensureSyncBranches(): Promise {\r\n let branches = await getSettingJSON(\"sync_branches\", []);\r\n if (branches.length) return branches;\r\n\r\n let data = await listBranches({ online: \"true\", limit: 100 });\r\n let list: any[] = data?.branches ?? [];\r\n if (!list.length) {\r\n data = await listBranches({ limit: 100 });\r\n list = data?.branches ?? [];\r\n }\r\n const byChain = new Map();\r\n for (const b of list) {\r\n const cid = String(b?.chain?.id ?? b?.chain?.name ?? \"?\");\r\n if (!byChain.has(cid)) byChain.set(cid, b);\r\n }\r\n const scored = [...byChain.values()]\r\n .map((b) => ({ b, score: chainScore(String(b?.chain?.name ?? \"\")) }))\r\n .sort((a, z) => a.score - z.score);\r\n branches = scored.slice(0, 3).map(({ b }) => ({\r\n id: String(b.id),\r\n name: [b?.chain?.name, b?.name].filter(Boolean).join(\" — \") || String(b.id),\r\n }));\r\n if (branches.length) await setSettingJSON(\"sync_branches\", branches);\r\n return branches;\r\n}\r\n\r\nexport interface SyncResult {\r\n ran: boolean;\r\n branch: string | null;\r\n pages: number;\r\n upserted: number;\r\n message: string;\r\n}\r\n\r\n/**\r\n * One incremental sync slice: picks the branch that needs work (in-progress\r\n * first, then the stalest completed one past the refresh window) and pages\r\n * through its product list, upserting into the local catalog.\r\n */\r\nexport async function runSyncSlice(maxPages = PAGES_PER_RUN, pauseMs = PAGE_PAUSE_MS): Promise {\r\n await ensureSchema();\r\n const result: SyncResult = { ran: false, branch: null, pages: 0, upserted: 0, message: \"\" };\r\n\r\n if (!hasApiKey()) {\r\n result.message = \"CHEAPERSAL_API_KEY not configured\";\r\n return result;\r\n }\r\n const usage = await getUsage();\r\n if (usage.count >= SYNC_DAILY_BUDGET) {\r\n result.message = \"daily sync budget reached\";\r\n return result;\r\n }\r\n\r\n let branches: SyncBranch[];\r\n try {\r\n branches = await ensureSyncBranches();\r\n } catch (e) {\r\n result.message = `branch discovery failed: ${(e as Error).message}`;\r\n return result;\r\n }\r\n if (!branches.length) {\r\n result.message = \"no sync branches available\";\r\n return result;\r\n }\r\n\r\n let states = await getSyncStates();\r\n for (const b of branches) {\r\n if (!states.some((s) => s.branch_id === b.id)) {\r\n await upsertSyncState({ branch_id: b.id, branch_name: b.name, next_skip: 0, done_at: null });\r\n }\r\n }\r\n states = await getSyncStates();\r\n const candidates = states.filter((s) => branches.some((b) => b.id === s.branch_id));\r\n\r\n let target = candidates.find((s) => !s.done_at) ?? null;\r\n if (!target) {\r\n const cutoff = Date.now() - REFRESH_AFTER_DAYS * 86_400_000;\r\n const stale = candidates\r\n .filter((s) => Date.parse(s.done_at!) < cutoff)\r\n .sort((a, z) => Date.parse(a.done_at!) - Date.parse(z.done_at!));\r\n if (stale.length) {\r\n target = stale[0];\r\n await upsertSyncState({ branch_id: target.branch_id, next_skip: 0, done_at: null });\r\n target.next_skip = 0;\r\n }\r\n }\r\n if (!target) {\r\n result.message = \"catalog up to date\";\r\n return result;\r\n }\r\n\r\n result.ran = true;\r\n result.branch = target.branch_name || target.branch_id;\r\n let skip = target.next_skip ?? 0;\r\n\r\n for (let i = 0; i < maxPages; i++) {\r\n let page;\r\n try {\r\n page = await getBranchProducts(target.branch_id, skip, PAGE_LIMIT, SYNC_DAILY_BUDGET);\r\n } catch (e) {\r\n result.message = e instanceof CheapersalError ? `stopped: ${e.code}` : `error: ${(e as Error).message}`;\r\n return result;\r\n }\r\n const items = page.products\r\n .filter((p) => p?.barcode && p?.name)\r\n .map((p) => ({\r\n barcode: String(p.barcode),\r\n name: String(p.name),\r\n brand: p.brand ?? \"\",\r\n category: p.category ?? \"\",\r\n price: typeof p.price === \"number\" ? p.price : null,\r\n }));\r\n await upsertCatalogBatch(items);\r\n result.pages++;\r\n result.upserted += items.length;\r\n skip += page.products.length;\r\n\r\n const finished = page.products.length < PAGE_LIMIT || (page.total > 0 && skip >= page.total);\r\n if (finished) {\r\n await upsertSyncState({\r\n branch_id: target.branch_id,\r\n next_skip: 0,\r\n total: page.total,\r\n done_at: new Date().toISOString(),\r\n });\r\n result.message = \"branch complete\";\r\n return result;\r\n }\r\n await upsertSyncState({ branch_id: target.branch_id, next_skip: skip, total: page.total });\r\n if (i < maxPages - 1) await sleep(pauseMs);\r\n }\r\n\r\n result.message = \"slice done\";\r\n return result;\r\n}\r\n\r\nexport default async function syncCatalogCron() {\r\n const r = await runSyncSlice();\r\n console.log(\"catalog sync:\", JSON.stringify(r));\r\n}\r\n",[],[176,309],"b258df52-fa16-4ebc-ba10-daf3d7a09137","index.http.ts","f9be78d0-6654-11f1-ad40-1607ee4eb77e",13,["D",1781265057832],"http","import { Hono } from \"npm:hono@4\";\r\nimport { readFile } from \"https://esm.town/v/std/utils/index.ts\";\r\nimport {\r\n addFavorite,\r\n cartBarcodes,\r\n catalogCount,\r\n clearCart,\r\n createCustomItem,\r\n deleteCartItem,\r\n deleteCustomItem,\r\n ensureSchema,\r\n favoriteKeys,\r\n findCartByRef,\r\n getCachedPrice,\r\n getCartItem,\r\n getCatalogItem,\r\n getCustomItem,\r\n getSetting,\r\n getSettingJSON,\r\n insertCartItem,\r\n isFresh,\r\n lastSyncAt,\r\n listCart,\r\n listFavorites,\r\n patchCartItem,\r\n q,\r\n removeFavorite,\r\n run,\r\n searchCatalog,\r\n searchCustomItems,\r\n setSetting,\r\n setSettingJSON,\r\n stalePriceBarcodes,\r\n updateCustomItem,\r\n upsertSyncState,\r\n} from \"./db.ts\";\r\nimport {\r\n CheapersalError,\r\n getUsage,\r\n hasApiKey,\r\n listBranches,\r\n listCities,\r\n refreshPrice,\r\n remainingReported,\r\n sleep,\r\n} from \"./cheapersal.ts\";\r\nimport { ensureSyncBranches, runSyncSlice } from \"./syncCatalog.cron.ts\";\r\nimport { iconPng, iconSvg } from \"./icons.ts\";\r\nimport type { CartItem, SyncBranch } from \"../shared/types.ts\";\r\n\r\nconst app = new Hono();\r\n\r\n// ---------- errors ----------\r\n\r\napp.onError((err, c) => {\r\n if (err instanceof CheapersalError) {\r\n const status = err.code === \"NO_KEY\" ? 503 : err.code === \"BUDGET\" || err.code.includes(\"LIMIT\") ? 429 : 502;\r\n return c.json({ error: err.message, code: err.code }, status);\r\n }\r\n console.error(\"unhandled error:\", err);\r\n return c.json({ error: (err as Error).message ?? \"internal error\" }, 500);\r\n});\r\n\r\n// ---------- PIN gate ----------\r\n\r\nconst OPEN_API_PATHS = new Set([\"/api/config\", \"/api/auth/verify\"]);\r\n\r\napp.use(\"/api/*\", async (c, next) => {\r\n const pin = Deno.env.get(\"APP_PIN\");\r\n if (!pin || OPEN_API_PATHS.has(c.req.path)) return await next();\r\n if (c.req.header(\"x-app-pin\") === pin) return await next();\r\n return c.json({ error: \"unauthorized\", code: \"PIN\" }, 401);\r\n});\r\n\r\napp.use(\"/api/*\", async (c, next) => {\r\n await ensureSchema();\r\n await next();\r\n});\r\n\r\n// ---------- auth / config ----------\r\n\r\napp.get(\"/api/config\", (c) => {\r\n return c.json({ authRequired: !!Deno.env.get(\"APP_PIN\"), hasApiKey: hasApiKey() });\r\n});\r\n\r\napp.post(\"/api/auth/verify\", async (c) => {\r\n const body = await c.req.json().catch(() => ({}));\r\n const pin = Deno.env.get(\"APP_PIN\");\r\n return c.json({ ok: !pin || String(body.pin ?? \"\") === pin });\r\n});\r\n\r\n// ---------- helpers ----------\r\n\r\nfunction num(v: unknown): number | undefined {\r\n if (v === undefined || v === null || v === \"\") return undefined;\r\n const n = Number(v);\r\n return Number.isFinite(n) ? n : undefined;\r\n}\r\n\r\ninterface ResolvedPrice {\r\n price: number;\r\n source: string;\r\n}\r\n\r\n/** Best known planning price for a catalog product (cached average preferred). */\r\nasync function resolveCatalogPrice(barcode: string): Promise {\r\n let cached = await getCachedPrice(barcode);\r\n if (!isFresh(cached)) {\r\n if (hasApiKey()) {\r\n try {\r\n cached = await refreshPrice(barcode);\r\n } catch {\r\n // budget/network issues: fall through to whatever we have\r\n }\r\n }\r\n }\r\n if (cached?.avg_price != null) return { price: Number(cached.avg_price), source: \"average\" };\r\n if (cached?.branch_price != null) return { price: Number(cached.branch_price), source: \"branch\" };\r\n const item = await getCatalogItem(barcode);\r\n if (item?.ref_price != null) return { price: Number(item.ref_price), source: \"catalog\" };\r\n return { price: 0, source: \"none\" };\r\n}\r\n\r\nfunction cartTotals(items: CartItem[]) {\r\n let planned = 0;\r\n let scanned = 0;\r\n let checkedCount = 0;\r\n for (const it of items) {\r\n planned += Number(it.qty) * Number(it.unit_price);\r\n if (Number(it.scanned_qty) > 0) {\r\n scanned += Number(it.scanned_qty) * Number(it.actual_price ?? it.unit_price);\r\n }\r\n if (it.checked) checkedCount++;\r\n }\r\n return {\r\n planned: Math.round(planned * 100) / 100,\r\n scanned: Math.round(scanned * 100) / 100,\r\n itemCount: items.length,\r\n checkedCount,\r\n };\r\n}\r\n\r\nasync function cartPayload() {\r\n const items = await listCart();\r\n return { items, totals: cartTotals(items) };\r\n}\r\n\r\n// ---------- search ----------\r\n\r\napp.get(\"/api/search\", async (c) => {\r\n const query = (c.req.query(\"q\") ?? \"\").trim();\r\n if (!query) return c.json({ results: [] });\r\n\r\n const [catalog, custom, favs, cart] = await Promise.all([\r\n searchCatalog(query, 25),\r\n searchCustomItems(query, 10),\r\n favoriteKeys(),\r\n listCart(),\r\n ]);\r\n\r\n const cartByRef = new Map();\r\n for (const it of cart) {\r\n cartByRef.set(it.kind === \"catalog\" ? `catalog:${it.barcode}` : `custom:${it.custom_id}`, it);\r\n }\r\n\r\n const barcodes = catalog.map((i) => i.barcode);\r\n const priceMap = new Map();\r\n if (barcodes.length) {\r\n const placeholders = barcodes.map(() => \"?\").join(\",\");\r\n const rows = await q(\r\n `SELECT barcode, avg_price, fetched_at FROM sal_price_cache WHERE barcode IN (${placeholders})`,\r\n barcodes,\r\n );\r\n for (const r of rows) priceMap.set(String(r.barcode), r);\r\n }\r\n\r\n const results = [\r\n ...custom.map((ci) => {\r\n const inCart = cartByRef.get(`custom:${ci.id}`);\r\n return {\r\n kind: \"custom\",\r\n custom_id: ci.id,\r\n name: ci.name,\r\n brand: \"\",\r\n unit_qty: \"\",\r\n price: Number(ci.price),\r\n priceKind: \"manual\",\r\n fav: favs.has(`custom:${ci.id}`),\r\n inCartId: inCart?.id ?? null,\r\n inCartQty: inCart ? Number(inCart.qty) : 0,\r\n };\r\n }),\r\n ...catalog.map((it) => {\r\n const cachedRow = priceMap.get(it.barcode);\r\n const cachedFresh = cachedRow && Date.now() - Date.parse(String(cachedRow.fetched_at)) < 24 * 3600 * 1000;\r\n const price = cachedFresh && cachedRow.avg_price != null\r\n ? Number(cachedRow.avg_price)\r\n : it.ref_price != null\r\n ? Number(it.ref_price)\r\n : null;\r\n const inCart = cartByRef.get(`catalog:${it.barcode}`);\r\n return {\r\n kind: \"catalog\",\r\n barcode: it.barcode,\r\n name: it.name,\r\n brand: it.brand ?? \"\",\r\n unit_qty: it.unit_qty ?? \"\",\r\n price,\r\n priceKind: cachedFresh ? \"avg\" : \"ref\",\r\n fav: favs.has(`catalog:${it.barcode}`),\r\n inCartId: inCart?.id ?? null,\r\n inCartQty: inCart ? Number(inCart.qty) : 0,\r\n };\r\n }),\r\n ];\r\n return c.json({ results });\r\n});\r\n\r\n// ---------- custom items ----------\r\n\r\napp.post(\"/api/custom-items\", async (c) => {\r\n const body = await c.req.json().catch(() => ({}));\r\n const name = String(body.name ?? \"\").trim();\r\n const price = num(body.price) ?? 0;\r\n if (!name) return c.json({ error: \"name is required\" }, 400);\r\n const item = await createCustomItem(name, price);\r\n return c.json({ item });\r\n});\r\n\r\napp.patch(\"/api/custom-items/:id\", async (c) => {\r\n const id = Number(c.req.param(\"id\"));\r\n const body = await c.req.json().catch(() => ({}));\r\n const fields: { name?: string; price?: number } = {};\r\n if (body.name !== undefined) fields.name = String(body.name).trim();\r\n const price = num(body.price);\r\n if (price !== undefined) fields.price = price;\r\n await updateCustomItem(id, fields);\r\n return c.json({ ok: true });\r\n});\r\n\r\napp.delete(\"/api/custom-items/:id\", async (c) => {\r\n await deleteCustomItem(Number(c.req.param(\"id\")));\r\n return c.json({ ok: true });\r\n});\r\n\r\n// ---------- cart ----------\r\n\r\napp.get(\"/api/cart\", async (c) => c.json(await cartPayload()));\r\n\r\napp.post(\"/api/cart\", async (c) => {\r\n const body = await c.req.json().catch(() => ({}));\r\n const kind = body.kind === \"custom\" ? \"custom\" : \"catalog\";\r\n const addQty = num(body.qty) ?? 1;\r\n\r\n if (kind === \"catalog\") {\r\n const barcode = String(body.barcode ?? \"\").trim();\r\n if (!barcode) return c.json({ error: \"barcode is required\" }, 400);\r\n\r\n const existing = await findCartByRef(\"catalog\", barcode, null);\r\n if (existing) {\r\n await patchCartItem(existing.id, { qty: Number(existing.qty) + addQty, checked: 0 });\r\n return c.json(await cartPayload());\r\n }\r\n\r\n let item = await getCatalogItem(barcode);\r\n const { price, source } = await resolveCatalogPrice(barcode);\r\n if (!item) item = await getCatalogItem(barcode); // refreshPrice may have learned it\r\n if (!item) return c.json({ error: \"product not found\", code: \"UNKNOWN_PRODUCT\" }, 404);\r\n\r\n await insertCartItem({\r\n kind: \"catalog\",\r\n barcode,\r\n name: item.name,\r\n unit_price: price,\r\n qty: addQty,\r\n price_source: source,\r\n });\r\n return c.json(await cartPayload());\r\n }\r\n\r\n const customId = Number(body.custom_id);\r\n const ci = await getCustomItem(customId);\r\n if (!ci) return c.json({ error: \"custom item not found\" }, 404);\r\n const existing = await findCartByRef(\"custom\", null, customId);\r\n if (existing) {\r\n await patchCartItem(existing.id, { qty: Number(existing.qty) + addQty, checked: 0 });\r\n } else {\r\n await insertCartItem({\r\n kind: \"custom\",\r\n custom_id: customId,\r\n name: ci.name,\r\n unit_price: Number(ci.price),\r\n qty: addQty,\r\n price_source: \"manual\",\r\n });\r\n }\r\n return c.json(await cartPayload());\r\n});\r\n\r\napp.patch(\"/api/cart/:id\", async (c) => {\r\n const id = Number(c.req.param(\"id\"));\r\n const body = await c.req.json().catch(() => ({}));\r\n const fields: Record = {};\r\n for (const key of [\"qty\", \"unit_price\", \"scanned_qty\", \"actual_price\"]) {\r\n const v = num(body[key]);\r\n if (v !== undefined) fields[key] = v;\r\n }\r\n if (body.checked !== undefined) fields.checked = body.checked ? 1 : 0;\r\n if (body.name !== undefined) fields.name = String(body.name).trim();\r\n if (body.price_source !== undefined) fields.price_source = String(body.price_source);\r\n if (fields.qty !== undefined && fields.qty <= 0) {\r\n await deleteCartItem(id);\r\n } else {\r\n await patchCartItem(id, fields);\r\n }\r\n return c.json(await cartPayload());\r\n});\r\n\r\napp.delete(\"/api/cart/:id\", async (c) => {\r\n await deleteCartItem(Number(c.req.param(\"id\")));\r\n return c.json(await cartPayload());\r\n});\r\n\r\napp.post(\"/api/cart/clear\", async (c) => {\r\n const body = await c.req.json().catch(() => ({}));\r\n await clearCart(body.mode === \"checked\" ? \"checked\" : \"all\");\r\n return c.json(await cartPayload());\r\n});\r\n\r\napp.post(\"/api/cart/refresh-prices\", async (c) => {\r\n const barcodes = await cartBarcodes();\r\n const staleAll = await stalePriceBarcodes(barcodes, barcodes.length);\r\n const batch = staleAll.slice(0, 8);\r\n let refreshed = 0;\r\n let stopped: string | null = null;\r\n for (const barcode of batch) {\r\n try {\r\n const info = await refreshPrice(barcode);\r\n if (info.avg_price != null) {\r\n await run(\r\n `UPDATE sal_cart SET unit_price = ?, price_source = 'average'\r\n WHERE kind = 'catalog' AND barcode = ? AND price_source != 'manual'`,\r\n [Number(info.avg_price), barcode],\r\n );\r\n }\r\n refreshed++;\r\n if (refreshed < batch.length) await sleep(1100);\r\n } catch (e) {\r\n stopped = e instanceof CheapersalError ? e.code : \"ERROR\";\r\n break;\r\n }\r\n }\r\n const payload = await cartPayload();\r\n return c.json({ ...payload, refreshed, remaining: Math.max(0, staleAll.length - refreshed), stopped });\r\n});\r\n\r\n// ---------- shopping mode ----------\r\n\r\napp.get(\"/api/lookup/:barcode\", async (c) => {\r\n const barcode = String(c.req.param(\"barcode\")).replace(/\\D/g, \"\");\r\n if (!barcode) return c.json({ error: \"invalid barcode\" }, 400);\r\n\r\n const inCart = await findCartByRef(\"catalog\", barcode, null);\r\n let catalog = await getCatalogItem(barcode);\r\n let cached = await getCachedPrice(barcode);\r\n\r\n if (!isFresh(cached) && hasApiKey()) {\r\n try {\r\n cached = await refreshPrice(barcode);\r\n if (!catalog) catalog = await getCatalogItem(barcode);\r\n } catch {\r\n // keep whatever stale data we have\r\n }\r\n }\r\n\r\n const avgPrice = cached?.avg_price != null ? Number(cached.avg_price) : null;\r\n const branchPrice = cached?.branch_price != null ? Number(cached.branch_price) : null;\r\n const expectedPrice = branchPrice ??\r\n avgPrice ??\r\n (inCart ? Number(inCart.unit_price) : null) ??\r\n (catalog?.ref_price != null ? Number(catalog.ref_price) : null);\r\n\r\n const source = branchPrice != null\r\n ? \"branch\"\r\n : avgPrice != null\r\n ? \"average\"\r\n : catalog?.ref_price != null\r\n ? \"catalog\"\r\n : inCart\r\n ? \"cart\"\r\n : \"none\";\r\n\r\n return c.json({\r\n found: !!(catalog || inCart || avgPrice != null),\r\n barcode,\r\n name: catalog?.name ?? inCart?.name ?? null,\r\n brand: catalog?.brand ?? null,\r\n expectedPrice,\r\n avgPrice,\r\n branchPrice,\r\n source,\r\n inCart: inCart ?? null,\r\n });\r\n});\r\n\r\napp.post(\"/api/cart/unplanned\", async (c) => {\r\n const body = await c.req.json().catch(() => ({}));\r\n const name = String(body.name ?? \"\").trim();\r\n const price = num(body.price) ?? 0;\r\n const qty = num(body.qty) ?? 1;\r\n const barcode = String(body.barcode ?? \"\").replace(/\\D/g, \"\") || null;\r\n if (!name) return c.json({ error: \"name is required\" }, 400);\r\n\r\n await insertCartItem({\r\n kind: barcode ? \"catalog\" : \"custom\",\r\n barcode,\r\n name,\r\n unit_price: price,\r\n qty,\r\n checked: 1,\r\n scanned_qty: qty,\r\n actual_price: price,\r\n unplanned: 1,\r\n price_source: body.source === \"manual\" ? \"manual\" : \"scan\",\r\n });\r\n return c.json(await cartPayload());\r\n});\r\n\r\n// ---------- favorites ----------\r\n\r\napp.get(\"/api/favorites\", async (c) => {\r\n const rows = await listFavorites();\r\n const cart = await listCart();\r\n const cartByRef = new Map();\r\n for (const it of cart) {\r\n cartByRef.set(it.kind === \"catalog\" ? `catalog:${it.barcode}` : `custom:${it.custom_id}`, it);\r\n }\r\n const favorites = rows\r\n .filter((r) => r.name)\r\n .map((r) => {\r\n const key = r.kind === \"catalog\" ? `catalog:${r.barcode}` : `custom:${r.custom_id}`;\r\n const inCart = cartByRef.get(key);\r\n return { ...r, price: r.price != null ? Number(r.price) : null, inCartId: inCart?.id ?? null, inCartQty: inCart ? Number(inCart.qty) : 0 };\r\n });\r\n return c.json({ favorites });\r\n});\r\n\r\napp.post(\"/api/favorites\", async (c) => {\r\n const body = await c.req.json().catch(() => ({}));\r\n const kind = body.kind === \"custom\" ? \"custom\" : \"catalog\";\r\n await addFavorite(kind, body.barcode ? String(body.barcode) : null, num(body.custom_id) ?? null);\r\n return c.json({ ok: true });\r\n});\r\n\r\napp.delete(\"/api/favorites\", async (c) => {\r\n const kind = c.req.query(\"kind\") === \"custom\" ? \"custom\" : \"catalog\";\r\n await removeFavorite(kind, c.req.query(\"barcode\") ?? null, num(c.req.query(\"custom_id\")) ?? null);\r\n return c.json({ ok: true });\r\n});\r\n\r\n// ---------- settings / status / sync ----------\r\n\r\napp.get(\"/api/settings\", async (c) => {\r\n const [branchId, branchName, city, syncBranches] = await Promise.all([\r\n getSetting(\"my_branch_id\"),\r\n getSetting(\"my_branch_name\"),\r\n getSetting(\"my_city\"),\r\n getSettingJSON(\"sync_branches\", []),\r\n ]);\r\n return c.json({ my_branch_id: branchId, my_branch_name: branchName, my_city: city, sync_branches: syncBranches });\r\n});\r\n\r\napp.patch(\"/api/settings\", async (c) => {\r\n const body = await c.req.json().catch(() => ({}));\r\n if (body.my_branch_id !== undefined) {\r\n const prev = await getSetting(\"my_branch_id\");\r\n await setSetting(\"my_branch_id\", body.my_branch_id ? String(body.my_branch_id) : null);\r\n await setSetting(\"my_branch_name\", body.my_branch_name ? String(body.my_branch_name) : null);\r\n if (prev !== (body.my_branch_id || null)) {\r\n // branch-specific cached prices belong to the old store\r\n await run(`UPDATE sal_price_cache SET branch_price = NULL`, []);\r\n }\r\n }\r\n if (body.my_city !== undefined) await setSetting(\"my_city\", body.my_city ? String(body.my_city) : null);\r\n if (Array.isArray(body.sync_branches)) {\r\n const branches = body.sync_branches\r\n .filter((b: any) => b?.id)\r\n .map((b: any) => ({ id: String(b.id), name: String(b.name ?? b.id) }));\r\n await setSettingJSON(\"sync_branches\", branches);\r\n for (const b of branches) {\r\n await upsertSyncState({ branch_id: b.id, branch_name: b.name });\r\n }\r\n }\r\n return c.json({ ok: true });\r\n});\r\n\r\napp.get(\"/api/branches\", async (c) => {\r\n const data = await listBranches({\r\n city: c.req.query(\"city\") || undefined,\r\n online: c.req.query(\"online\") || undefined,\r\n limit: 100,\r\n });\r\n return c.json({ branches: data?.branches ?? [] });\r\n});\r\n\r\napp.get(\"/api/cities\", async (c) => {\r\n const data = await listCities();\r\n return c.json({ cities: Array.isArray(data) ? data : [] });\r\n});\r\n\r\napp.post(\"/api/sync/run\", async (c) => {\r\n const body = await c.req.json().catch(() => ({}));\r\n const pages = Math.min(num(body.pages) ?? 2, 3);\r\n const result = await runSyncSlice(pages, 1500);\r\n return c.json(result);\r\n});\r\n\r\napp.get(\"/api/status\", async (c) => {\r\n const [count, usage, remaining, last, syncBranches, branchId, branchName] = await Promise.all([\r\n catalogCount(),\r\n getUsage(),\r\n remainingReported(),\r\n lastSyncAt(),\r\n getSettingJSON(\"sync_branches\", []),\r\n getSetting(\"my_branch_id\"),\r\n getSetting(\"my_branch_name\"),\r\n ]);\r\n return c.json({\r\n catalogCount: count,\r\n apiUsedToday: usage.count,\r\n apiRemaining: remaining,\r\n hasApiKey: hasApiKey(),\r\n authRequired: !!Deno.env.get(\"APP_PIN\"),\r\n lastSync: last,\r\n syncBranches,\r\n myBranch: branchId ? { id: branchId, name: branchName ?? branchId } : null,\r\n });\r\n});\r\n\r\n// ---------- static files / PWA ----------\r\n\r\nconst MIME: Record = {\r\n html: \"text/html; charset=utf-8\",\r\n js: \"text/javascript; charset=utf-8\",\r\n css: \"text/css; charset=utf-8\",\r\n json: \"application/json; charset=utf-8\",\r\n svg: \"image/svg+xml\",\r\n png: \"image/png\",\r\n txt: \"text/plain; charset=utf-8\",\r\n webmanifest: \"application/manifest+json\",\r\n};\r\n\r\nasync function serveStatic(path: string, cacheSeconds: number): Promise {\r\n const ext = path.split(\".\").pop() ?? \"txt\";\r\n const content = await readFile(path, import.meta.url);\r\n return new Response(content, {\r\n headers: {\r\n \"content-type\": MIME[ext] ?? \"text/plain; charset=utf-8\",\r\n \"cache-control\": cacheSeconds > 0 ? `public, max-age=${cacheSeconds}` : \"no-cache\",\r\n },\r\n });\r\n}\r\n\r\napp.get(\"/\", () => serveStatic(\"/frontend/index.html\", 0));\r\napp.get(\"/index.html\", () => serveStatic(\"/frontend/index.html\", 0));\r\napp.get(\"/manifest.json\", () => serveStatic(\"/frontend/manifest.json\", 300));\r\napp.get(\"/sw.js\", () => serveStatic(\"/frontend/sw.js\", 0));\r\n\r\napp.get(\"/frontend/*\", (c) => {\r\n const path = c.req.path;\r\n if (path.includes(\"..\")) return c.text(\"bad path\", 400);\r\n return serveStatic(path, 300);\r\n});\r\n\r\napp.get(\"/icons/icon.svg\", () =>\r\n new Response(iconSvg(), {\r\n headers: { \"content-type\": \"image/svg+xml\", \"cache-control\": \"public, max-age=86400\" },\r\n }));\r\n\r\napp.get(\"/icons/:file\", async (c) => {\r\n const m = c.req.param(\"file\").match(/^icon-(\\d+)\\.png$/);\r\n if (!m) return c.notFound();\r\n const size = Math.min(Number(m[1]) || 192, 1024);\r\n const png = await iconPng(size);\r\n if (png) {\r\n return new Response(png.buffer as ArrayBuffer, {\r\n headers: { \"content-type\": \"image/png\", \"cache-control\": \"public, max-age=86400\" },\r\n });\r\n }\r\n // Fallback: SVG body (most browsers sniff and render it; iOS will show a default icon)\r\n return new Response(iconSvg(), {\r\n headers: { \"content-type\": \"image/svg+xml\", \"cache-control\": \"public, max-age=3600\" },\r\n });\r\n});\r\n\r\napp.get(\"/favicon.ico\", (c) => c.redirect(\"/icons/icon.svg\", 301));\r\n\r\nexport default app.fetch;\r\n",[],[176,318],"54f701cd-de91-4039-a609-9e3afb5f0045","icons.ts","f99aa3b0-6654-11f1-8113-1607ee4eb77e",12,["D",1781265057605],"/**\r\n * App icon, generated from a single SVG source.\r\n * PNG variants (needed for iOS apple-touch-icon and the manifest) are rendered\r\n * at runtime with resvg-wasm and cached in blob storage + memory.\r\n */\r\n\r\nconst ICON_VERSION = \"v1\";\r\n\r\nexport function iconSvg(): string {\r\n return ``;\r\n}\r\n\r\nconst memCache = new Map();\r\nlet wasmInit: Promise | null = null;\r\n\r\nasync function renderPng(size: number): Promise {\r\n const resvg = await import(\"https://esm.sh/@resvg/resvg-wasm@2.6.2\");\r\n if (!wasmInit) {\r\n wasmInit = resvg\r\n .initWasm(fetch(\"https://esm.sh/@resvg/resvg-wasm@2.6.2/index_bg.wasm\"))\r\n .catch((e: Error) => {\r\n if (/already/i.test(e.message)) return;\r\n wasmInit = null;\r\n throw e;\r\n });\r\n }\r\n await wasmInit;\r\n const renderer = new resvg.Resvg(iconSvg(), { fitTo: { mode: \"width\", value: size } });\r\n return renderer.render().asPng();\r\n}\r\n\r\nexport async function iconPng(size: number): Promise {\r\n const cached = memCache.get(size);\r\n if (cached) return cached;\r\n\r\n const key = `sal_icon_${ICON_VERSION}_${size}`;\r\n try {\r\n const { blob } = await import(\"https://esm.town/v/std/blob\");\r\n try {\r\n const stored: any = await blob.get(key);\r\n const buf = new Uint8Array(await stored.arrayBuffer());\r\n if (buf.length > 0) {\r\n memCache.set(size, buf);\r\n return buf;\r\n }\r\n } catch {\r\n // not cached yet\r\n }\r\n const png = await renderPng(size);\r\n memCache.set(size, png);\r\n try {\r\n await blob.set(key, png.buffer as ArrayBuffer);\r\n } catch {\r\n // blob storage is best-effort; memory cache still works\r\n }\r\n return png;\r\n } catch {\r\n // resvg/blob unavailable; caller falls back to SVG\r\n try {\r\n const png = await renderPng(size);\r\n memCache.set(size, png);\r\n return png;\r\n } catch {\r\n return null;\r\n }\r\n }\r\n}\r\n",[],[176,327],"d3210b14-0752-4078-b9f0-c86f803859de","db.ts","f9794986-6654-11f1-8113-1607ee4eb77e",11,["D",1781265057385],"import sqlite from \"https://esm.town/v/std/sqlite/main.ts\";\r\nimport type { CartItem, CatalogItem, CustomItem, PriceInfo, SyncBranch } from \"../shared/types.ts\";\r\n\r\ntype Row = Record;\r\n\r\nconst DDL = [\r\n `CREATE TABLE IF NOT EXISTS sal_catalog (\r\n barcode TEXT PRIMARY KEY,\r\n name TEXT NOT NULL,\r\n brand TEXT NOT NULL DEFAULT '',\r\n category TEXT NOT NULL DEFAULT '',\r\n unit_qty TEXT NOT NULL DEFAULT '',\r\n ref_price REAL,\r\n search_text TEXT NOT NULL DEFAULT '',\r\n updated_at TEXT\r\n )`,\r\n `CREATE INDEX IF NOT EXISTS idx_sal_catalog_search ON sal_catalog(search_text)`,\r\n `CREATE TABLE IF NOT EXISTS sal_custom_items (\r\n id INTEGER PRIMARY KEY AUTOINCREMENT,\r\n name TEXT NOT NULL,\r\n price REAL NOT NULL DEFAULT 0,\r\n search_text TEXT NOT NULL DEFAULT '',\r\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\r\n )`,\r\n `CREATE TABLE IF NOT EXISTS sal_favorites (\r\n id INTEGER PRIMARY KEY AUTOINCREMENT,\r\n kind TEXT NOT NULL,\r\n barcode TEXT NOT NULL DEFAULT '',\r\n custom_id INTEGER NOT NULL DEFAULT 0,\r\n created_at TEXT NOT NULL DEFAULT (datetime('now')),\r\n UNIQUE(kind, barcode, custom_id)\r\n )`,\r\n `CREATE TABLE IF NOT EXISTS sal_cart (\r\n id INTEGER PRIMARY KEY AUTOINCREMENT,\r\n kind TEXT NOT NULL,\r\n barcode TEXT,\r\n custom_id INTEGER,\r\n name TEXT NOT NULL,\r\n unit_price REAL NOT NULL DEFAULT 0,\r\n qty REAL NOT NULL DEFAULT 1,\r\n checked INTEGER NOT NULL DEFAULT 0,\r\n scanned_qty REAL NOT NULL DEFAULT 0,\r\n actual_price REAL,\r\n unplanned INTEGER NOT NULL DEFAULT 0,\r\n price_source TEXT NOT NULL DEFAULT '',\r\n added_at TEXT NOT NULL DEFAULT (datetime('now'))\r\n )`,\r\n `CREATE TABLE IF NOT EXISTS sal_price_cache (\r\n barcode TEXT PRIMARY KEY,\r\n avg_price REAL,\r\n min_price REAL,\r\n max_price REAL,\r\n cheapest_chain TEXT,\r\n store_count INTEGER,\r\n branch_price REAL,\r\n fetched_at TEXT NOT NULL\r\n )`,\r\n `CREATE TABLE IF NOT EXISTS sal_sync_state (\r\n branch_id TEXT PRIMARY KEY,\r\n branch_name TEXT NOT NULL DEFAULT '',\r\n next_skip INTEGER NOT NULL DEFAULT 0,\r\n total INTEGER,\r\n done_at TEXT,\r\n updated_at TEXT\r\n )`,\r\n `CREATE TABLE IF NOT EXISTS sal_settings (\r\n key TEXT PRIMARY KEY,\r\n value TEXT\r\n )`,\r\n];\r\n\r\nlet schemaReady = false;\r\nexport async function ensureSchema(): Promise {\r\n if (schemaReady) return;\r\n await sqlite.batch(DDL);\r\n schemaReady = true;\r\n}\r\n\r\nfunction toObjects(rs: { columns: string[]; rows: any[] }): Row[] {\r\n return rs.rows.map((r) =>\r\n Object.fromEntries(rs.columns.map((c, i) => [c, r[i] !== undefined ? r[i] : r[c]]))\r\n );\r\n}\r\n\r\nexport async function q(sql: string, args: any[] = []): Promise {\r\n const rs = await sqlite.execute({ sql, args });\r\n return toObjects(rs as any);\r\n}\r\n\r\nexport async function run(sql: string, args: any[] = []): Promise<{ lastId: number }> {\r\n const rs: any = await sqlite.execute({ sql, args });\r\n return { lastId: rs.lastInsertRowid != null ? Number(rs.lastInsertRowid) : 0 };\r\n}\r\n\r\n// ---------- Hebrew text normalization ----------\r\n\r\nconst FINALS: Record = { \"ך\": \"כ\", \"ם\": \"מ\", \"ן\": \"נ\", \"ף\": \"פ\", \"ץ\": \"צ\" };\r\n\r\nexport function normalizeHe(s: string): string {\r\n return (s || \"\")\r\n .replace(/[\"'`׳״\\u05F3\\u05F4]/g, \"\")\r\n .replace(/[ךםןףץ]/g, (ch) => FINALS[ch])\r\n .replace(/[\\u0591-\\u05C7]/g, \"\") // niqqud\r\n .replace(/\\s+/g, \" \")\r\n .trim()\r\n .toLowerCase();\r\n}\r\n\r\nfunction likeEscape(s: string): string {\r\n return s.replace(/([\\\\%_])/g, \"\\\\$1\");\r\n}\r\n\r\n// ---------- Settings ----------\r\n\r\nexport async function getSetting(key: string): Promise {\r\n const rows = await q(`SELECT value FROM sal_settings WHERE key = ?`, [key]);\r\n return rows.length ? (rows[0].value as string) : null;\r\n}\r\n\r\nexport async function setSetting(key: string, value: string | null): Promise {\r\n if (value === null) {\r\n await run(`DELETE FROM sal_settings WHERE key = ?`, [key]);\r\n } else {\r\n await run(\r\n `INSERT INTO sal_settings (key, value) VALUES (?, ?)\r\n ON CONFLICT(key) DO UPDATE SET value = excluded.value`,\r\n [key, value],\r\n );\r\n }\r\n}\r\n\r\nexport async function getSettingJSON(key: string, fallback: T): Promise {\r\n const v = await getSetting(key);\r\n if (!v) return fallback;\r\n try {\r\n return JSON.parse(v) as T;\r\n } catch {\r\n return fallback;\r\n }\r\n}\r\n\r\nexport async function setSettingJSON(key: string, value: unknown): Promise {\r\n await setSetting(key, JSON.stringify(value));\r\n}\r\n\r\n// ---------- Catalog ----------\r\n\r\nexport interface CatalogUpsert {\r\n barcode: string;\r\n name: string;\r\n brand?: string;\r\n category?: string;\r\n unit_qty?: string;\r\n price?: number | null;\r\n}\r\n\r\nexport async function upsertCatalogBatch(products: CatalogUpsert[]): Promise {\r\n if (!products.length) return;\r\n const now = new Date().toISOString();\r\n const stmts = products\r\n .filter((p) => p.barcode && p.name)\r\n .map((p) => ({\r\n sql: `INSERT INTO sal_catalog (barcode, name, brand, category, unit_qty, ref_price, search_text, updated_at)\r\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)\r\n ON CONFLICT(barcode) DO UPDATE SET\r\n name = excluded.name,\r\n brand = excluded.brand,\r\n category = excluded.category,\r\n unit_qty = CASE WHEN excluded.unit_qty != '' THEN excluded.unit_qty ELSE sal_catalog.unit_qty END,\r\n ref_price = COALESCE(excluded.ref_price, sal_catalog.ref_price),\r\n search_text = excluded.search_text,\r\n updated_at = excluded.updated_at`,\r\n args: [\r\n String(p.barcode),\r\n p.name,\r\n p.brand ?? \"\",\r\n p.category ?? \"\",\r\n p.unit_qty ?? \"\",\r\n p.price ?? null,\r\n normalizeHe(`${p.name} ${p.brand ?? \"\"}`),\r\n now,\r\n ],\r\n }));\r\n await sqlite.batch(stmts as any);\r\n}\r\n\r\nexport async function searchCatalog(query: string, limit = 25): Promise {\r\n const norm = normalizeHe(query);\r\n const terms = norm.split(\" \").filter(Boolean).slice(0, 6);\r\n if (!terms.length) return [];\r\n const where = terms.map(() => `search_text LIKE ? ESCAPE '\\\\'`).join(\" AND \");\r\n const args: any[] = terms.map((t) => `%${likeEscape(t)}%`);\r\n args.push(`${likeEscape(terms[0])}%`);\r\n args.push(limit);\r\n const rows = await q(\r\n `SELECT barcode, name, brand, category, unit_qty, ref_price, updated_at\r\n FROM sal_catalog\r\n WHERE ${where}\r\n ORDER BY (CASE WHEN search_text LIKE ? ESCAPE '\\\\' THEN 0 ELSE 1 END), length(name) ASC\r\n LIMIT ?`,\r\n args,\r\n );\r\n return rows as unknown as CatalogItem[];\r\n}\r\n\r\nexport async function getCatalogItem(barcode: string): Promise {\r\n const rows = await q(\r\n `SELECT barcode, name, brand, category, unit_qty, ref_price, updated_at FROM sal_catalog WHERE barcode = ?`,\r\n [barcode],\r\n );\r\n return rows.length ? (rows[0] as unknown as CatalogItem) : null;\r\n}\r\n\r\nexport async function catalogCount(): Promise {\r\n const rows = await q(`SELECT COUNT(*) AS n FROM sal_catalog`);\r\n return Number(rows[0]?.n ?? 0);\r\n}\r\n\r\n// ---------- Custom items ----------\r\n\r\nexport async function createCustomItem(name: string, price: number): Promise {\r\n const { lastId } = await run(\r\n `INSERT INTO sal_custom_items (name, price, search_text) VALUES (?, ?, ?)`,\r\n [name, price, normalizeHe(name)],\r\n );\r\n const rows = await q(`SELECT id, name, price, created_at FROM sal_custom_items WHERE id = ?`, [lastId]);\r\n return rows[0] as unknown as CustomItem;\r\n}\r\n\r\nexport async function updateCustomItem(id: number, fields: { name?: string; price?: number }): Promise {\r\n const sets: string[] = [];\r\n const args: any[] = [];\r\n if (fields.name !== undefined) {\r\n sets.push(\"name = ?\", \"search_text = ?\");\r\n args.push(fields.name, normalizeHe(fields.name));\r\n }\r\n if (fields.price !== undefined) {\r\n sets.push(\"price = ?\");\r\n args.push(fields.price);\r\n }\r\n if (!sets.length) return;\r\n args.push(id);\r\n await run(`UPDATE sal_custom_items SET ${sets.join(\", \")} WHERE id = ?`, args);\r\n // Propagate to unchecked cart rows that reference this custom item.\r\n if (fields.name !== undefined || fields.price !== undefined) {\r\n const sets2: string[] = [];\r\n const args2: any[] = [];\r\n if (fields.name !== undefined) {\r\n sets2.push(\"name = ?\");\r\n args2.push(fields.name);\r\n }\r\n if (fields.price !== undefined) {\r\n sets2.push(\"unit_price = ?\");\r\n args2.push(fields.price);\r\n }\r\n args2.push(id);\r\n await run(`UPDATE sal_cart SET ${sets2.join(\", \")} WHERE kind = 'custom' AND custom_id = ? AND checked = 0`, args2);\r\n }\r\n}\r\n\r\nexport async function deleteCustomItem(id: number): Promise {\r\n await run(`DELETE FROM sal_custom_items WHERE id = ?`, [id]);\r\n await run(`DELETE FROM sal_favorites WHERE kind = 'custom' AND custom_id = ?`, [id]);\r\n}\r\n\r\nexport async function getCustomItem(id: number): Promise {\r\n const rows = await q(`SELECT id, name, price, created_at FROM sal_custom_items WHERE id = ?`, [id]);\r\n return rows.length ? (rows[0] as unknown as CustomItem) : null;\r\n}\r\n\r\nexport async function searchCustomItems(query: string, limit = 10): Promise {\r\n const norm = normalizeHe(query);\r\n const terms = norm.split(\" \").filter(Boolean).slice(0, 6);\r\n if (!terms.length) return [];\r\n const where = terms.map(() => `search_text LIKE ? ESCAPE '\\\\'`).join(\" AND \");\r\n const args: any[] = terms.map((t) => `%${likeEscape(t)}%`);\r\n args.push(limit);\r\n const rows = await q(\r\n `SELECT id, name, price, created_at FROM sal_custom_items WHERE ${where} ORDER BY length(name) LIMIT ?`,\r\n args,\r\n );\r\n return rows as unknown as CustomItem[];\r\n}\r\n\r\n// ---------- Favorites ----------\r\n\r\nexport async function listFavorites(): Promise {\r\n return await q(\r\n `SELECT f.id, f.kind, f.barcode, f.custom_id, f.created_at,\r\n COALESCE(c.name, ci.name) AS name,\r\n COALESCE(c.brand, '') AS brand,\r\n c.unit_qty AS unit_qty,\r\n COALESCE(p.avg_price, c.ref_price, ci.price) AS price\r\n FROM sal_favorites f\r\n LEFT JOIN sal_catalog c ON f.kind = 'catalog' AND c.barcode = f.barcode\r\n LEFT JOIN sal_custom_items ci ON f.kind = 'custom' AND ci.id = f.custom_id\r\n LEFT JOIN sal_price_cache p ON f.kind = 'catalog' AND p.barcode = f.barcode\r\n ORDER BY f.created_at DESC`,\r\n );\r\n}\r\n\r\nexport async function addFavorite(kind: string, barcode: string | null, customId: number | null): Promise {\r\n await run(\r\n `INSERT OR IGNORE INTO sal_favorites (kind, barcode, custom_id) VALUES (?, ?, ?)`,\r\n [kind, barcode ?? \"\", customId ?? 0],\r\n );\r\n}\r\n\r\nexport async function removeFavorite(kind: string, barcode: string | null, customId: number | null): Promise {\r\n await run(\r\n `DELETE FROM sal_favorites WHERE kind = ? AND barcode = ? AND custom_id = ?`,\r\n [kind, barcode ?? \"\", customId ?? 0],\r\n );\r\n}\r\n\r\nexport async function favoriteKeys(): Promise> {\r\n const rows = await q(`SELECT kind, barcode, custom_id FROM sal_favorites`);\r\n return new Set(rows.map((r) => (r.kind === \"catalog\" ? `catalog:${r.barcode}` : `custom:${r.custom_id}`)));\r\n}\r\n\r\n// ---------- Cart ----------\r\n\r\nexport async function listCart(): Promise {\r\n const rows = await q(`SELECT * FROM sal_cart ORDER BY checked ASC, added_at DESC, id DESC`);\r\n return rows as unknown as CartItem[];\r\n}\r\n\r\nexport async function getCartItem(id: number): Promise {\r\n const rows = await q(`SELECT * FROM sal_cart WHERE id = ?`, [id]);\r\n return rows.length ? (rows[0] as unknown as CartItem) : null;\r\n}\r\n\r\nexport async function findCartByRef(kind: string, barcode: string | null, customId: number | null): Promise {\r\n const rows = kind === \"catalog\"\r\n ? await q(`SELECT * FROM sal_cart WHERE kind = 'catalog' AND barcode = ? LIMIT 1`, [barcode])\r\n : await q(`SELECT * FROM sal_cart WHERE kind = 'custom' AND custom_id = ? LIMIT 1`, [customId]);\r\n return rows.length ? (rows[0] as unknown as CartItem) : null;\r\n}\r\n\r\nexport interface CartInsert {\r\n kind: string;\r\n barcode?: string | null;\r\n custom_id?: number | null;\r\n name: string;\r\n unit_price: number;\r\n qty?: number;\r\n checked?: number;\r\n scanned_qty?: number;\r\n actual_price?: number | null;\r\n unplanned?: number;\r\n price_source?: string;\r\n}\r\n\r\nexport async function insertCartItem(item: CartInsert): Promise {\r\n const { lastId } = await run(\r\n `INSERT INTO sal_cart (kind, barcode, custom_id, name, unit_price, qty, checked, scanned_qty, actual_price, unplanned, price_source)\r\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\r\n [\r\n item.kind,\r\n item.barcode ?? null,\r\n item.custom_id ?? null,\r\n item.name,\r\n item.unit_price,\r\n item.qty ?? 1,\r\n item.checked ?? 0,\r\n item.scanned_qty ?? 0,\r\n item.actual_price ?? null,\r\n item.unplanned ?? 0,\r\n item.price_source ?? \"\",\r\n ],\r\n );\r\n return lastId;\r\n}\r\n\r\nconst CART_PATCHABLE = [\"qty\", \"checked\", \"unit_price\", \"scanned_qty\", \"actual_price\", \"name\", \"price_source\"];\r\n\r\nexport async function patchCartItem(id: number, fields: Record): Promise {\r\n const sets: string[] = [];\r\n const args: any[] = [];\r\n for (const key of CART_PATCHABLE) {\r\n if (fields[key] !== undefined) {\r\n sets.push(`${key} = ?`);\r\n args.push(fields[key]);\r\n }\r\n }\r\n if (!sets.length) return;\r\n args.push(id);\r\n await run(`UPDATE sal_cart SET ${sets.join(\", \")} WHERE id = ?`, args);\r\n}\r\n\r\nexport async function deleteCartItem(id: number): Promise {\r\n await run(`DELETE FROM sal_cart WHERE id = ?`, [id]);\r\n}\r\n\r\nexport async function clearCart(mode: \"all\" | \"checked\"): Promise {\r\n if (mode === \"checked\") {\r\n await run(`DELETE FROM sal_cart WHERE checked = 1`);\r\n } else {\r\n await run(`DELETE FROM sal_cart`);\r\n }\r\n}\r\n\r\nexport async function cartBarcodes(): Promise {\r\n const rows = await q(`SELECT DISTINCT barcode FROM sal_cart WHERE kind = 'catalog' AND barcode IS NOT NULL`);\r\n return rows.map((r) => String(r.barcode));\r\n}\r\n\r\n// ---------- Price cache ----------\r\n\r\nconst PRICE_TTL_MS = 24 * 60 * 60 * 1000;\r\n\r\nexport async function getCachedPrice(barcode: string): Promise {\r\n const rows = await q(`SELECT * FROM sal_price_cache WHERE barcode = ?`, [barcode]);\r\n return rows.length ? (rows[0] as unknown as PriceInfo) : null;\r\n}\r\n\r\nexport function isFresh(info: PriceInfo | null): boolean {\r\n if (!info?.fetched_at) return false;\r\n return Date.now() - Date.parse(info.fetched_at) < PRICE_TTL_MS;\r\n}\r\n\r\nexport async function setCachedPrice(info: Omit): Promise {\r\n await run(\r\n `INSERT INTO sal_price_cache (barcode, avg_price, min_price, max_price, cheapest_chain, store_count, branch_price, fetched_at)\r\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)\r\n ON CONFLICT(barcode) DO UPDATE SET\r\n avg_price = excluded.avg_price,\r\n min_price = excluded.min_price,\r\n max_price = excluded.max_price,\r\n cheapest_chain = excluded.cheapest_chain,\r\n store_count = excluded.store_count,\r\n branch_price = excluded.branch_price,\r\n fetched_at = excluded.fetched_at`,\r\n [\r\n info.barcode,\r\n info.avg_price,\r\n info.min_price,\r\n info.max_price,\r\n info.cheapest_chain,\r\n info.store_count,\r\n info.branch_price,\r\n new Date().toISOString(),\r\n ],\r\n );\r\n}\r\n\r\nexport async function stalePriceBarcodes(barcodes: string[], limit: number): Promise {\r\n if (!barcodes.length) return [];\r\n const placeholders = barcodes.map(() => \"?\").join(\",\");\r\n const rows = await q(\r\n `SELECT barcode, fetched_at FROM sal_price_cache WHERE barcode IN (${placeholders})`,\r\n barcodes,\r\n );\r\n const fresh = new Set(\r\n rows.filter((r) => Date.now() - Date.parse(String(r.fetched_at)) < PRICE_TTL_MS).map((r) => String(r.barcode)),\r\n );\r\n return barcodes.filter((b) => !fresh.has(b)).slice(0, limit);\r\n}\r\n\r\n// ---------- Sync state ----------\r\n\r\nexport interface SyncState {\r\n branch_id: string;\r\n branch_name: string;\r\n next_skip: number;\r\n total: number | null;\r\n done_at: string | null;\r\n updated_at: string | null;\r\n}\r\n\r\nexport async function getSyncStates(): Promise {\r\n const rows = await q(`SELECT * FROM sal_sync_state`);\r\n return rows as unknown as SyncState[];\r\n}\r\n\r\nexport async function upsertSyncState(s: Partial & { branch_id: string }): Promise {\r\n const existing = await q(`SELECT branch_id FROM sal_sync_state WHERE branch_id = ?`, [s.branch_id]);\r\n if (!existing.length) {\r\n await run(\r\n `INSERT INTO sal_sync_state (branch_id, branch_name, next_skip, total, done_at, updated_at) VALUES (?, ?, ?, ?, ?, ?)`,\r\n [s.branch_id, s.branch_name ?? \"\", s.next_skip ?? 0, s.total ?? null, s.done_at ?? null, new Date().toISOString()],\r\n );\r\n return;\r\n }\r\n const sets: string[] = [\"updated_at = ?\"];\r\n const args: any[] = [new Date().toISOString()];\r\n for (const key of [\"branch_name\", \"next_skip\", \"total\", \"done_at\"] as const) {\r\n if (s[key] !== undefined) {\r\n sets.push(`${key} = ?`);\r\n args.push(s[key]);\r\n }\r\n }\r\n args.push(s.branch_id);\r\n await run(`UPDATE sal_sync_state SET ${sets.join(\", \")} WHERE branch_id = ?`, args);\r\n}\r\n\r\nexport async function lastSyncAt(): Promise {\r\n const rows = await q(`SELECT MAX(updated_at) AS t FROM sal_sync_state`);\r\n return rows[0]?.t ? String(rows[0].t) : null;\r\n}\r\n\r\nexport type { SyncBranch };\r\n",[],[176,335],"d1aba5d3-b6c2-415e-9044-b637533de144","cheapersal.ts","f9525e2a-6654-11f1-b751-1607ee4eb77e",10,["D",1781265057129],"import {\r\n getSetting,\r\n getSettingJSON,\r\n setCachedPrice,\r\n setSetting,\r\n setSettingJSON,\r\n upsertCatalogBatch,\r\n} from \"./db.ts\";\r\nimport type { PriceInfo } from \"../shared/types.ts\";\r\n\r\nconst BASE = \"https://api.cheapersal.co.il/api/v1\";\r\n\r\n// Free tier: 100 requests/day, 3,000/month, 10/minute. Keep a margin under the daily cap.\r\nconst DAILY_HARD_CAP = 95;\r\n\r\nexport class CheapersalError extends Error {\r\n code: string;\r\n constructor(message: string, code: string) {\r\n super(message);\r\n this.code = code;\r\n }\r\n}\r\n\r\nexport function hasApiKey(): boolean {\r\n return !!Deno.env.get(\"CHEAPERSAL_API_KEY\");\r\n}\r\n\r\nexport function sleep(ms: number): Promise {\r\n return new Promise((resolve) => setTimeout(resolve, ms));\r\n}\r\n\r\n// ---------- Daily usage accounting (UTC, matches Cheapersal's reset) ----------\r\n\r\ninterface Usage {\r\n date: string;\r\n count: number;\r\n}\r\n\r\nfunction todayUTC(): string {\r\n return new Date().toISOString().slice(0, 10);\r\n}\r\n\r\nexport async function getUsage(): Promise {\r\n const u = await getSettingJSON(\"api_usage\", { date: todayUTC(), count: 0 });\r\n return u.date === todayUTC() ? u : { date: todayUTC(), count: 0 };\r\n}\r\n\r\nasync function bumpUsage(): Promise {\r\n const u = await getUsage();\r\n u.count += 1;\r\n await setSettingJSON(\"api_usage\", u);\r\n}\r\n\r\nexport async function remainingReported(): Promise {\r\n const v = await getSetting(\"api_remaining\");\r\n return v === null ? null : Number(v);\r\n}\r\n\r\n// ---------- Core fetch ----------\r\n\r\nexport async function cheapersalGet(\r\n path: string,\r\n params: Record = {},\r\n opts: { budget?: number } = {},\r\n): Promise {\r\n const key = Deno.env.get(\"CHEAPERSAL_API_KEY\");\r\n if (!key) throw new CheapersalError(\"CHEAPERSAL_API_KEY is not configured\", \"NO_KEY\");\r\n\r\n const usage = await getUsage();\r\n const cap = Math.min(opts.budget ?? DAILY_HARD_CAP, DAILY_HARD_CAP);\r\n if (usage.count >= cap) {\r\n throw new CheapersalError(\"Daily Cheapersal request budget exhausted\", \"BUDGET\");\r\n }\r\n\r\n const url = new URL(BASE + path);\r\n for (const [k, v] of Object.entries(params)) {\r\n if (v !== undefined && v !== \"\") url.searchParams.set(k, String(v));\r\n }\r\n\r\n const res = await fetch(url, { headers: { \"X-API-Key\": key } });\r\n await bumpUsage();\r\n\r\n let body: any = null;\r\n try {\r\n body = await res.json();\r\n } catch {\r\n // non-JSON response; handled below via status\r\n }\r\n const remaining = body?.meta?.usage?.remaining;\r\n if (remaining !== undefined && remaining !== null) {\r\n await setSetting(\"api_remaining\", String(remaining));\r\n }\r\n if (!res.ok || body?.success === false) {\r\n const code = body?.error?.code ?? `HTTP_${res.status}`;\r\n const msg = body?.error?.message ?? `Cheapersal request failed (${res.status})`;\r\n throw new CheapersalError(msg, code);\r\n }\r\n return body?.data;\r\n}\r\n\r\n// ---------- Domain calls ----------\r\n\r\nexport interface PricesResult {\r\n product: { barcode?: string; name?: string; manufacturer?: string; category?: string; unitQty?: string } | null;\r\n average: number | null;\r\n cheapest: number | null;\r\n mostExpensive: number | null;\r\n storeCount: number | null;\r\n cheapestChain: string | null;\r\n branchPrice: number | null;\r\n}\r\n\r\nexport async function fetchPrices(barcode: string, myBranchId?: string | null): Promise {\r\n const data = await cheapersalGet(`/products/${encodeURIComponent(barcode)}/prices`);\r\n const summary = data?.summary ?? {};\r\n let branchPrice: number | null = null;\r\n if (myBranchId && Array.isArray(data?.prices)) {\r\n const hit = data.prices.find((p: any) => p?.branch?.id === myBranchId);\r\n if (hit) branchPrice = hit.promo?.promoPrice ?? hit.price ?? null;\r\n }\r\n return {\r\n product: data?.product ?? null,\r\n average: summary.average ?? null,\r\n cheapest: summary.cheapest ?? null,\r\n mostExpensive: summary.mostExpensive ?? null,\r\n storeCount: summary.storeCount ?? null,\r\n cheapestChain: summary.cheapestChain?.name ?? null,\r\n branchPrice,\r\n };\r\n}\r\n\r\n/**\r\n * Fetch live prices for a barcode, store them in the price cache, and make sure\r\n * the product exists in the local catalog (so future searches find it).\r\n */\r\nexport async function refreshPrice(barcode: string): Promise {\r\n const myBranchId = await getSetting(\"my_branch_id\");\r\n const r = await fetchPrices(barcode, myBranchId);\r\n const info = {\r\n barcode,\r\n avg_price: r.average,\r\n min_price: r.cheapest,\r\n max_price: r.mostExpensive,\r\n cheapest_chain: r.cheapestChain,\r\n store_count: r.storeCount,\r\n branch_price: r.branchPrice,\r\n };\r\n await setCachedPrice(info);\r\n if (r.product?.name) {\r\n await upsertCatalogBatch([{\r\n barcode,\r\n name: r.product.name,\r\n brand: r.product.manufacturer ?? \"\",\r\n category: r.product.category ?? \"\",\r\n unit_qty: r.product.unitQty ?? \"\",\r\n price: r.average,\r\n }]);\r\n }\r\n return { ...info, fetched_at: new Date().toISOString() };\r\n}\r\n\r\nexport interface BranchProductsPage {\r\n products: Array<{ barcode: string; name: string; brand?: string; price?: number; category?: string }>;\r\n total: number;\r\n skip: number;\r\n limit: number;\r\n}\r\n\r\nexport async function getBranchProducts(branchId: string, skip: number, limit = 200, budget?: number): Promise {\r\n const data = await cheapersalGet(\r\n `/branches/${encodeURIComponent(branchId)}/products`,\r\n { skip, limit },\r\n { budget },\r\n );\r\n return {\r\n products: Array.isArray(data?.products) ? data.products : [],\r\n total: Number(data?.total ?? 0),\r\n skip: Number(data?.skip ?? skip),\r\n limit: Number(data?.limit ?? limit),\r\n };\r\n}\r\n\r\nexport async function listBranches(params: { city?: string; chainId?: string; online?: string; limit?: number; skip?: number }): Promise {\r\n return await cheapersalGet(\"/branches\", params as Record);\r\n}\r\n\r\nexport async function listCities(): Promise {\r\n return await cheapersalGet(\"/cities\");\r\n}\r\n",[],[176,343],["D",1781264884030],[205,206,207,208,209],[176],["D",1781264953400],[],[181],["D",1781264884823],[],[187],["D",1781264881516],["D",1789535451117],{"_97":96,"_105":101},{"_97":96,"_98":99,"_100":101,"_18":54,"_102":103,"_104":24},{"_13":86,"_31":87,"_42":41,"_88":43,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":44,"_95":96},"ctx",{"_79":-5,"_126":397,"_398":399,"_400":401,"_402":24,"_403":24,"_404":24,"_405":124,"_406":-5,"_407":-7,"_408":-7,"_409":60,"_410":24,"_411":24,"_412":-5,"_413":24,"_414":24,"_415":24,"_416":-5},"ENV",{"_368":369,"_370":371,"_372":87,"_373":374,"_375":376,"_377":378,"_379":380,"_381":382,"_383":384,"_385":386,"_387":388,"_389":390,"_391":392,"_393":394,"_395":396},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v23