[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_109":110,"_111":112},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","dominik1","name","lista-zakupow","path","backend/db.ts","project",{"_22":48,"_11":12,"_35":49,"_50":-5,"_51":44,"_52":53,"_54":53,"_55":56,"_57":-5,"_58":59,"_60":61,"_62":34,"_63":-5,"_64":-5,"_65":66,"_67":68,"_69":70,"_71":72,"_73":74,"_75":-5,"_76":77,"_78":77,"_79":80,"_81":80,"_82":80,"_83":77,"_84":77,"_85":86,"_87":88,"_89":90,"_91":44},"file",{"_22":23,"_11":24,"_25":26,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":-5,"_13":46},"permalink","https://www.val.town/x/dominik1/lista-zakupow/code/backend/db.ts","extension","id","d5da89f2-37c4-4c78-af43-9ba4b283e073","db.ts","fileId","8ade08fc-afb2-11f1-8e1c-1607ee4eb77e","parentId","3b059627-8b90-4bc3-aa9f-68c1803f7f50","branchId","2b7f7d5b-efff-44e5-9962-373315ac0749","branchVersion",27,"latest",true,"createdAt",["D",1789333870539],"version",1,"fileType","script","content","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { isPerson, type Person } from \"../shared/people.ts\";\nimport { type Item, keyOf, type Op, SHOPPING_TTL_MS, type Shopping, type State } from \"../shared/types.ts\";\n\nconst ITEMS = \"zakupy_items\";\nconst HISTORY = \"zakupy_history\";\nconst SHOPPING = \"zakupy_shopping\";\nconst PUSH = \"zakupy_push\";\nconst LOGIN_FAILS = \"zakupy_login_fails\";\n\nconst DAY_MS = 24 * 60 * 60 * 1000;\n\n// What applying ops changed, used to decide who gets a notification\nexport interface Effects {\n added: { by: Person; name: string }[];\n startedShopping: Person[];\n}\n\nexport interface PushSubscriptionRow {\n endpoint: string;\n p256dh: string;\n auth: string;\n}\n\nexport async function initDb() {\n await sqlite.batch([\n {\n sql: `CREATE TABLE IF NOT EXISTS ${ITEMS} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n uid TEXT,\n name TEXT NOT NULL,\n name_key TEXT NOT NULL,\n added_by TEXT NOT NULL,\n created_at INTEGER NOT NULL,\n bought_by TEXT,\n bought_at INTEGER\n )`,\n args: [],\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS ${HISTORY} (\n name_key TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n uses INTEGER NOT NULL DEFAULT 0,\n last_at INTEGER NOT NULL\n )`,\n args: [],\n },\n { sql: `CREATE TABLE IF NOT EXISTS ${SHOPPING} (person TEXT PRIMARY KEY, since INTEGER)`, args: [] },\n {\n sql: `CREATE TABLE IF NOT EXISTS ${PUSH} (\n endpoint TEXT PRIMARY KEY,\n person TEXT NOT NULL,\n p256dh TEXT NOT NULL,\n auth TEXT NOT NULL,\n created_at INTEGER NOT NULL\n )`,\n args: [],\n },\n { sql: `CREATE TABLE IF NOT EXISTS ${LOGIN_FAILS} (ip TEXT NOT NULL, at INTEGER NOT NULL)`, args: [] },\n ]);\n\n // The first version addressed items by numeric id; give those rows stable uids\n try {\n await sqlite.execute(`ALTER TABLE ${ITEMS} ADD COLUMN uid TEXT`);\n } catch {\n // column already exists\n }\n await sqlite.batch([\n { sql: `UPDATE ${ITEMS} SET uid = 'legacy-' || id WHERE uid IS NULL`, args: [] },\n { sql: `CREATE UNIQUE INDEX IF NOT EXISTS zakupy_items_uid ON ${ITEMS} (uid)`, args: [] },\n ]);\n}\n\n// ---------- list state ----------\n\nfunction toItem(r: Record): Item {\n return {\n uid: String(r.uid),\n name: String(r.name),\n added_by: r.added_by as Person,\n created_at: Number(r.created_at),\n bought_by: (r.bought_by ?? null) as Person | null,\n bought_at: r.bought_at == null ? null : Number(r.bought_at),\n };\n}\n\nasync function listItems(): Promise {\n const { rows } = await sqlite.execute(\n `SELECT uid, name, added_by, created_at, bought_by, bought_at FROM ${ITEMS} ORDER BY created_at, id`,\n );\n return rows.map(toItem);\n}\n\n// Most frequently added products, used for quick-add suggestions\nasync function listHistory(): Promise {\n const { rows } = await sqlite.execute(\n `SELECT name FROM ${HISTORY} ORDER BY uses DESC, last_at DESC LIMIT 60`,\n );\n return rows.map((r) => String(r.name));\n}\n\nexport async function getShopping(): Promise {\n const { rows } = await sqlite.execute(`SELECT person, since FROM ${SHOPPING}`);\n const cutoff = Date.now() - SHOPPING_TTL_MS;\n const shopping: Shopping = { Aga: null, Dominik: null };\n for (const r of rows) {\n const since = r.since == null ? null : Number(r.since);\n if (isPerson(r.person) && since != null && since > cutoff) shopping[r.person] = since;\n }\n return shopping;\n}\n\nexport async function getState(): Promise {\n const [items, history, shopping] = await Promise.all([listItems(), listHistory(), getShopping()]);\n return { items, history, shopping };\n}\n\n// Names still on the list that a person added since a moment in time\nexport async function namesAddedSince(by: Person, since: number): Promise {\n const { rows } = await sqlite.execute({\n sql: `SELECT name FROM ${ITEMS} WHERE added_by = ? AND created_at >= ? AND bought_at IS NULL\n ORDER BY created_at LIMIT 10`,\n args: [by, since],\n });\n return rows.map((r) => String(r.name));\n}\n\n// ---------- ops ----------\n\nexport async function applyOps(ops: Op[]): Promise {\n const effects: Effects = { added: [], startedShopping: [] };\n const now = Date.now();\n\n for (const op of ops) {\n // client clocks can be off; keep timestamps within a sane range\n const at = Math.min(Math.max(op.at, now - 30 * DAY_MS), now);\n\n switch (op.type) {\n case \"add\": {\n const key = keyOf(op.name);\n const { rows } = await sqlite.execute({\n sql: `SELECT uid, bought_at FROM ${ITEMS} WHERE uid = ? OR name_key = ? LIMIT 2`,\n args: [op.uid, key],\n });\n if (rows.some((r) => r.uid === op.uid)) break; // retried request\n const history = {\n sql: `INSERT INTO ${HISTORY} (name_key, name, uses, last_at) VALUES (?, ?, 1, ?)\n ON CONFLICT(name_key) DO UPDATE SET uses = uses + 1, name = excluded.name, last_at = excluded.last_at`,\n args: [key, op.name, at],\n };\n const existing = rows[0];\n if (existing) {\n // already on the list: no duplicate, just bring it back if it was bought\n await sqlite.batch([\n {\n sql: `UPDATE ${ITEMS} SET bought_by = NULL, bought_at = NULL WHERE uid = ?`,\n args: [String(existing.uid)],\n },\n history,\n ]);\n if (existing.bought_at != null) effects.added.push({ by: op.by, name: op.name });\n } else {\n await sqlite.batch([\n {\n sql: `INSERT INTO ${ITEMS} (uid, name, name_key, added_by, created_at) VALUES (?, ?, ?, ?, ?)`,\n args: [op.uid, op.name, key, op.by, at],\n },\n history,\n ]);\n effects.added.push({ by: op.by, name: op.name });\n }\n break;\n }\n\n case \"set_bought\":\n await sqlite.execute({\n sql: `UPDATE ${ITEMS} SET bought_by = ?, bought_at = ? WHERE uid = ?`,\n args: op.bought ? [op.by, at, op.uid] : [null, null, op.uid],\n });\n break;\n\n case \"delete\":\n if (op.uids.length === 0) break;\n await sqlite.execute({\n sql: `DELETE FROM ${ITEMS} WHERE uid IN (${op.uids.map(() => \"?\").join(\", \")})`,\n args: op.uids,\n });\n break;\n\n case \"shopping\":\n if (op.on) {\n if (at < now - SHOPPING_TTL_MS) break; // queued offline so long ago it no longer applies\n const current = await getShopping();\n await sqlite.execute({\n sql: `INSERT INTO ${SHOPPING} (person, since) VALUES (?, ?)\n ON CONFLICT(person) DO UPDATE SET since = excluded.since`,\n args: [op.by, at],\n });\n if (current[op.by] == null) effects.startedShopping.push(op.by);\n } else {\n await sqlite.execute({\n sql: `UPDATE ${SHOPPING} SET since = NULL WHERE person = ?`,\n args: [op.by],\n });\n }\n break;\n }\n }\n\n return effects;\n}\n\n// ---------- push subscriptions ----------\n\nexport async function saveSubscription(endpoint: string, p256dh: string, auth: string, person: Person) {\n await sqlite.execute({\n sql: `INSERT INTO ${PUSH} (endpoint, person, p256dh, auth, created_at) VALUES (?, ?, ?, ?, ?)\n ON CONFLICT(endpoint) DO UPDATE SET person = excluded.person, p256dh = excluded.p256dh, auth = excluded.auth`,\n args: [endpoint, person, p256dh, auth, Date.now()],\n });\n}\n\nexport async function deleteSubscription(endpoint: string) {\n await sqlite.execute({ sql: `DELETE FROM ${PUSH} WHERE endpoint = ?`, args: [endpoint] });\n}\n\nexport async function subscriptionsFor(people: Person[]): Promise {\n if (people.length === 0) return [];\n const { rows } = await sqlite.execute({\n sql: `SELECT endpoint, p256dh, auth FROM ${PUSH} WHERE person IN (${people.map(() => \"?\").join(\", \")})`,\n args: people,\n });\n return rows.map((r) => ({ endpoint: String(r.endpoint), p256dh: String(r.p256dh), auth: String(r.auth) }));\n}\n\n// ---------- PIN attempts ----------\n\nexport async function countLoginFails(ip: string, since: number) {\n const { rows } = await sqlite.execute({\n sql: `SELECT COUNT(*) AS total, COALESCE(SUM(CASE WHEN ip = ? THEN 1 ELSE 0 END), 0) AS mine\n FROM ${LOGIN_FAILS} WHERE at >= ?`,\n args: [ip, since],\n });\n return { total: Number(rows[0]?.total ?? 0), mine: Number(rows[0]?.mine ?? 0) };\n}\n\nexport async function recordLoginFail(ip: string) {\n const now = Date.now();\n await sqlite.batch([\n { sql: `DELETE FROM ${LOGIN_FAILS} WHERE at < ?`, args: [now - DAY_MS] },\n { sql: `INSERT INTO ${LOGIN_FAILS} (ip, at) VALUES (?, ?)`, args: [ip, now] },\n ]);\n}\n\nexport async function clearLoginFails(ip: string) {\n await sqlite.execute({ sql: `DELETE FROM ${LOGIN_FAILS} WHERE ip = ?`, args: [ip] });\n}\n","deleted",false,"label",[47,24],"backend","f99be336-a8c3-4900-9595-c5bea7024466",["D",1789331428995],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Wspólna lista zakupów Agi i Dominika (mobile)","imageUrl","userId","5dd5cdfa-b36a-42e1-a911-81ba86e3b64c","pinnedFileId","01a09c76-d795-72a1-be82-f37a11bb083f","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a09aab-d118-725d-b44f-c12d328bfdc6","tursoName","f99be336a8c349009595c5bea7024466","tursoHostname","f99be336a8c349009595c5bea7024466-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789504321592],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_108":104},"org",{"_9":10,"_101":102,"_103":104,"_58":59,"_105":106,"_107":44},"branch",{"_37":32,"_11":92,"_22":30,"_93":48,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":12,"_100":10},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Dominik","avatar","","tier","free","canRestrictVals","profileImageUrl","ctx",{"_85":-5,"_142":143,"_144":145,"_146":147,"_148":44,"_149":44,"_150":44,"_151":34,"_152":-5,"_153":-7,"_154":-7,"_155":66,"_156":44,"_157":44,"_158":-5,"_159":44,"_160":44,"_161":44,"_162":-5},"ENV",{"_113":114,"_115":116,"_117":92,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137,"_138":139,"_140":141},"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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]