[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_263":264,"_265":266},"routes/_app.x.$handle.$name",{"_97":96,"_31":44,"_106":87,"_26":107,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":24,"_121":122,"_123":24,"_124":-5,"_125":-5,"_126":127},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_31":44,"_37":45,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":-5,"_56":24,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":68,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":24},"version",12,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":24},"previous","deleted",false,"deletedHere","path","backend/icons.ts","latestPath","fileId","f99aa3b0-6654-11f1-8113-1607ee4eb77e","name","icons.ts","fileType","script","content","/**\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","createdAt",["D",1781265057605],"branchVersion","branchId","17148dea-1f11-4e39-b566-7dfac4b67420","id","7d5b16ae-5c7c-4ac0-bf56-1b4e7583327f","sal-kniyot",["D",1781264881516],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Hebrew shopping list PWA with real Israeli grocery prices","imageUrl","f9a9d73d-189d-4a89-b651-a98dd96ccd85","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019ebad4-b39c-7578-b99d-98184cb7486b","tursoName","7d5b16ae5c7c4ac0bf561b4e7583327f","tursoHostname","7d5b16ae5c7c4ac0bf561b4e7583327f-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789535451117],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_97":96,"_105":101},"org",{"_97":96,"_98":99,"_100":101,"_18":54,"_102":103,"_104":24},"branch",{"_13":86,"_31":87,"_42":41,"_88":43,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":44,"_95":96},"isOwned",32,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","Yaniv","handle","displayName","Yaniv Bitton","avatar","https://lh3.googleusercontent.com/a/ACg8ocJyc9WiOwnFbdo0vUbRiTCBw7JbZp4Zdp9SivQ_duK8hZjZGjml=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_42":43,"_31":44,"_37":258,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":-5,"_56":24,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":259,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":260,"_81":261,"_83":262,"_85":24},"tree",[202,203,204,208,209,210,211,212],"files",[202,203,204,205,206,207,208,209,210,211,212],"counts",{"_192":60,"_193":159,"_194":60,"_195":196,"_197":198},"contents",[128,129,130,131,132,133,134,135],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":186,"_31":187,"_29":188,"_139":-5,"_40":41,"_39":189,"_141":142,"_37":190,"_13":60,"_33":167,"_35":-5,"_23":24,"_145":-5,"_26":191},{"_42":180,"_31":181,"_29":182,"_139":-5,"_40":41,"_39":183,"_141":142,"_37":184,"_13":60,"_33":167,"_35":-5,"_23":24,"_145":-5,"_26":185},{"_42":175,"_31":176,"_29":177,"_139":-5,"_40":41,"_39":159,"_141":142,"_37":178,"_13":60,"_33":167,"_35":-5,"_23":24,"_145":-5,"_26":179},{"_42":169,"_31":170,"_29":171,"_139":-5,"_40":41,"_39":172,"_141":142,"_37":173,"_13":60,"_33":167,"_35":-5,"_23":24,"_145":-5,"_26":174},{"_42":162,"_31":163,"_29":164,"_139":-5,"_40":41,"_39":165,"_141":142,"_37":166,"_13":60,"_33":167,"_35":-5,"_23":24,"_145":-5,"_26":168},{"_42":154,"_31":155,"_29":156,"_139":-5,"_40":41,"_39":157,"_141":142,"_37":158,"_13":159,"_33":20,"_35":160,"_23":24,"_145":-5,"_26":161},{"_42":147,"_31":148,"_29":149,"_139":-5,"_40":41,"_39":150,"_141":142,"_37":151,"_13":60,"_33":20,"_35":152,"_23":24,"_145":-5,"_26":153},{"_42":136,"_31":137,"_29":138,"_139":-5,"_40":41,"_39":140,"_141":142,"_37":143,"_13":60,"_33":20,"_35":144,"_23":24,"_145":-5,"_26":146},"ce2b1d1b-f072-4312-8aae-bab8a1f0a5ca","deno.json","936e2152-6654-11f1-9094-1607ee4eb77e","parentId",6,"latest",true,["D",1781264886189],"{\r\n \"lock\": false,\r\n \"compilerOptions\": {\r\n \"lib\": [\"deno.window\", \"dom\"]\r\n },\r\n \"lint\": {\r\n \"exclude\": [\"frontend/\"]\r\n }\r\n}\r\n","label",[137],"76fdd81a-7e51-48f1-8761-e73f55907983","README.md","93ae3b02-6654-11f1-98fc-1607ee4eb77e",7,["D",1781264886602],"# סל קניות — Shopping List PWA\r\n\r\nA Hebrew, RTL, mobile-first shopping list and cart app, hosted entirely on [Val Town](https://val.town).\r\nReal Israeli grocery products and prices come from the free [Cheapersal API](https://cheapersal.co.il/developers)\r\n(built on the government price-transparency data).\r\n\r\n## Features\r\n\r\n- Search real grocery products in Hebrew (local catalog, instant, zero API quota).\r\n- Cart for the next shopping run with a live projected total (₪), based on the average price across chains.\r\n- Favorites for one-tap re-adding of staples.\r\n- Custom items with a user-set price for anything not in the catalog.\r\n- Shopping mode: scan barcodes (EAN-13/EAN-8) with the phone camera as items go into the physical cart,\r\n building the real expected total, then compare planned vs. scanned at checkout to catch register mistakes.\r\n- \"My store\" setting: scan lookups prefer your branch's actual price over the national average.\r\n- Installable PWA (Add to Home Screen on iPhone/Android), cart viewable offline in-store.\r\n\r\n## Project structure\r\n\r\n```\r\nbackend/\r\n index.http.ts Hono HTTP trigger: JSON API + serves the frontend, manifest, SW, icons\r\n db.ts SQLite schema + query helpers\r\n cheapersal.ts Cheapersal API client (throttle, daily budget, 24h price cache)\r\n icons.ts App icon (SVG -> PNG via resvg-wasm, cached in blob storage)\r\n syncCatalog.cron.ts Incremental catalog sync (cron trigger)\r\nfrontend/\r\n index.html, styles.css, manifest.json, sw.js\r\n index.js, app.js, views.js, scanner.js, api.js (React 18 + htm, no build step)\r\nshared/\r\n types.ts\r\n```\r\n\r\n## One-time setup\r\n\r\n1. Get a free API key at [cheapersal.co.il/developers](https://cheapersal.co.il/developers) (\"קבלו מפתח API\").\r\n2. Install [Deno](https://deno.land), then the Val Town CLI: `deno install -grAf jsr:@valtown/vt`, and run `vt` to log in.\r\n3. From this folder: `vt create sal-kniyot` (or `vt push` if the val exists).\r\n4. In the val's settings on val.town set environment variables:\r\n - `CHEAPERSAL_API_KEY` — your Cheapersal key.\r\n - `APP_PIN` — optional numeric PIN that gates the app (leave unset for no PIN).\r\n5. Set the cron schedule for `backend/syncCatalog.cron.ts` (e.g. every 30 minutes). The first runs build\r\n the local product catalog; afterwards it refreshes weekly.\r\n6. On the phone, open the val URL → Share → Add to Home Screen.\r\n\r\n## API quota strategy\r\n\r\nFree tier is 100 requests/day (10/minute). The app stays well inside it:\r\n\r\n- Product name search runs against the local SQLite catalog — zero quota.\r\n- Catalog sync uses a small request budget per cron run and stops at ~55 requests/day.\r\n- Live price lookups happen only when adding an item (cached 24h) or scanning an unknown barcode.\r\n- The settings sheet shows the remaining daily quota as reported by the API.\r\n",[148],"0d5f50ee-59c8-4c88-a552-84335087cdd1",".vtignore","93313bc0-6654-11f1-9529-1607ee4eb77e",9,["D",1781264955145],1,".git\r\n.git/**\r\n.vt\r\n.vt/**\r\n*.lock\r\nnode_modules/**\r\n",[155],"cd304fb9-8c75-4c5f-9592-65425d2ce241","shared","927c54f8-6654-11f1-aca0-1607ee4eb77e",3,["D",1781264884601],"directory",[163],"a76bc93f-97d0-4df8-9445-600c21b1eb32","frontend","92500ed4-6654-11f1-b967-1607ee4eb77e",2,["D",1781264884294],[170],"957b7828-2037-4489-87e5-b59a5c295272","backend","922a324a-6654-11f1-9e0e-1607ee4eb77e",["D",1781264884030],[176],"aa4c5e77-addb-4ead-adc7-cc2fbef21e6a",".vt","bb7ec82c-6654-11f1-98fc-1607ee4eb77e",8,["D",1781264953400],[181],"7b603636-18b2-423f-88d7-d7dee3c0d631",".git","929e2830-6654-11f1-92f4-1607ee4eb77e",4,["D",1781264884823],[187],"pulls","branches","forks","envVars",{"_199":172,"_201":60},"connections",{"_199":60,"_200":60},"count","unfilledCount","emptyCount",{"_42":186,"_31":187,"_29":188,"_139":-5,"_40":41,"_39":189,"_141":142,"_37":255,"_13":60,"_33":167,"_35":-5,"_23":24,"_145":-5,"_214":256,"_26":257},{"_42":180,"_31":181,"_29":182,"_139":-5,"_40":41,"_39":183,"_141":142,"_37":252,"_13":60,"_33":167,"_35":-5,"_23":24,"_145":-5,"_214":253,"_26":254},{"_42":175,"_31":176,"_29":177,"_139":-5,"_40":41,"_39":159,"_141":142,"_37":249,"_13":60,"_33":167,"_35":-5,"_23":24,"_145":-5,"_214":250,"_26":251},{"_42":241,"_31":242,"_29":243,"_139":177,"_40":41,"_39":244,"_141":142,"_37":245,"_13":60,"_33":34,"_35":246,"_23":24,"_145":-5,"_214":247,"_26":248},{"_42":233,"_31":234,"_29":235,"_139":177,"_40":41,"_39":236,"_141":142,"_37":237,"_13":60,"_33":34,"_35":238,"_23":24,"_145":-5,"_214":239,"_26":240},{"_42":229,"_31":32,"_29":30,"_139":177,"_40":41,"_39":14,"_141":142,"_37":230,"_13":60,"_33":34,"_35":36,"_23":24,"_145":-5,"_214":231,"_26":232},{"_42":169,"_31":170,"_29":171,"_139":-5,"_40":41,"_39":172,"_141":142,"_37":226,"_13":60,"_33":167,"_35":-5,"_23":24,"_145":-5,"_214":227,"_26":228},{"_42":162,"_31":163,"_29":164,"_139":-5,"_40":41,"_39":165,"_141":142,"_37":223,"_13":60,"_33":167,"_35":-5,"_23":24,"_145":-5,"_214":224,"_26":225},{"_42":154,"_31":155,"_29":156,"_139":-5,"_40":41,"_39":157,"_141":142,"_37":220,"_13":159,"_33":20,"_35":160,"_23":24,"_145":-5,"_214":221,"_26":222},{"_42":147,"_31":148,"_29":149,"_139":-5,"_40":41,"_39":150,"_141":142,"_37":217,"_13":60,"_33":20,"_35":152,"_23":24,"_145":-5,"_214":218,"_26":219},{"_42":136,"_31":137,"_29":138,"_139":-5,"_40":41,"_39":140,"_141":142,"_37":213,"_13":60,"_33":20,"_35":144,"_23":24,"_145":-5,"_214":215,"_26":216},["D",1781264886189],"children",[],[137],["D",1781264886602],[],[148],["D",1781264955145],[],[155],["D",1781264884601],[],[163],["D",1781264884294],[],[170],"54f701cd-de91-4039-a609-9e3afb5f0045",["D",1781265057605],[],[176,32],"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,234],"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,242],["D",1781264884030],[205,206,207],[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,"_125":296,"_297":298,"_299":300,"_301":24,"_302":24,"_303":24,"_304":142,"_305":-5,"_306":-7,"_307":-7,"_308":60,"_309":24,"_310":24,"_311":-5,"_312":24,"_313":24,"_314":24,"_315":-5},"ENV",{"_267":268,"_269":270,"_271":87,"_272":273,"_274":275,"_276":277,"_278":279,"_280":281,"_282":283,"_284":285,"_286":287,"_288":289,"_290":291,"_292":293,"_294":295},"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 · v12