[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_106":107,"_108":109},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","omriluz","name","telegram-city-network","path","store.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":58,"_59":32,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/omriluz/telegram-city-network/code/store.ts","extension","id","a415515a-67a3-4e94-be3c-0913aff0350b","fileId","2b090e9e-b256-11f1-ad06-1607ee4eb77e","parentId","branchId","6de82370-98e9-41cd-add4-480bf35c921b","branchVersion",50,"latest",true,"createdAt",["D",1789637658104],"version",3,"fileType","script","content","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { cities, hash, match, validateEvent, type EventData } from \"./core.ts\";\nexport interface Statement { sql: string; args?: (string | number | null)[]; }\nexport interface Result { rows: Record[]; rowsAffected: number; }\nexport interface Database { execute(q: Statement | string): Promise; batch(q: Statement[], mode?: \"write\" | \"read\" | \"deferred\"): Promise; }\nexport const database = sqlite as unknown as Database;\nexport function createStore(db: Database, prefix = \"ccn_\") {\n if (!/^ccn_(?:test_[a-f0-9]+_)?$/.test(prefix)) throw new Error(\"Invalid storage namespace\");\n const sql = (text: string) => text.replaceAll(\"ccn_\", prefix);\n const q = (text: string, args: (string | number | null)[] = []) => db.execute({ sql: sql(text), args });\n const batch = (items: Statement[]) => db.batch(items.map((x) => ({ ...x, sql: sql(x.sql) })), \"write\");\n let ready: Promise | undefined;\n async function init(): Promise {\n if (ready) return ready;\n ready = (async () => {\n const schemas = [\n \"CREATE TABLE IF NOT EXISTS ccn_migrations (version INTEGER PRIMARY KEY, applied_at INTEGER NOT NULL)\",\n \"CREATE TABLE IF NOT EXISTS ccn_events (id TEXT PRIMARY KEY, city TEXT NOT NULL, source TEXT NOT NULL, json TEXT NOT NULL, hash TEXT NOT NULL, translation TEXT, translation_hash TEXT, review TEXT NOT NULL DEFAULT 'draft', approved_hash TEXT, duplicate_of TEXT, first_seen INTEGER NOT NULL, last_seen INTEGER NOT NULL, verified INTEGER NOT NULL, fixture INTEGER NOT NULL DEFAULT 0)\",\n \"CREATE INDEX IF NOT EXISTS ccn_events_city ON ccn_events(city, review)\",\n \"CREATE TABLE IF NOT EXISTS ccn_records (key TEXT PRIMARY KEY, event_id TEXT NOT NULL, source TEXT NOT NULL, city TEXT NOT NULL, url TEXT NOT NULL, json TEXT NOT NULL, hash TEXT NOT NULL, first_seen INTEGER NOT NULL, last_seen INTEGER NOT NULL, verified INTEGER NOT NULL)\",\n \"CREATE TABLE IF NOT EXISTS ccn_duplicates (id TEXT PRIMARY KEY, left_id TEXT NOT NULL, right_id TEXT NOT NULL, state TEXT NOT NULL, reason TEXT NOT NULL, created INTEGER NOT NULL)\",\n \"CREATE TABLE IF NOT EXISTS ccn_editorial (id TEXT PRIMARY KEY, event_id TEXT, action TEXT NOT NULL, note TEXT NOT NULL, seconds INTEGER NOT NULL DEFAULT 0, at INTEGER NOT NULL)\",\n \"CREATE TABLE IF NOT EXISTS ccn_publications (key TEXT PRIMARY KEY, city TEXT NOT NULL, mode TEXT NOT NULL, destination TEXT NOT NULL, text TEXT NOT NULL, state TEXT NOT NULL, attempts INTEGER NOT NULL DEFAULT 0, retry_at INTEGER NOT NULL DEFAULT 0, claimed_at INTEGER, claim_token TEXT, message_id TEXT, created INTEGER NOT NULL, expires INTEGER NOT NULL, needs_correction INTEGER NOT NULL DEFAULT 0, reason TEXT)\",\n \"CREATE TABLE IF NOT EXISTS ccn_publication_items (publication_key TEXT NOT NULL, event_id TEXT NOT NULL, hash TEXT NOT NULL, PRIMARY KEY (publication_key, event_id))\",\n \"CREATE TABLE IF NOT EXISTS ccn_sources (id TEXT PRIMARY KEY, permission TEXT NOT NULL DEFAULT 'pending', poll_allowed INTEGER NOT NULL DEFAULT 0, checked INTEGER, next_due INTEGER NOT NULL DEFAULT 0, count INTEGER NOT NULL DEFAULT 0, status TEXT NOT NULL DEFAULT 'unverified', error TEXT, basis TEXT NOT NULL DEFAULT '')\",\n \"CREATE TABLE IF NOT EXISTS ccn_cache (url TEXT PRIMARY KEY, body TEXT NOT NULL, etag TEXT, expires INTEGER NOT NULL)\",\n \"CREATE TABLE IF NOT EXISTS ccn_translations (key TEXT PRIMARY KEY, status TEXT NOT NULL, json TEXT, provider TEXT NOT NULL, tokens INTEGER NOT NULL DEFAULT 0, error TEXT, created INTEGER NOT NULL)\",\n \"CREATE TABLE IF NOT EXISTS ccn_usage (day TEXT PRIMARY KEY, requests INTEGER NOT NULL DEFAULT 0, tokens INTEGER NOT NULL DEFAULT 0)\",\n \"CREATE TABLE IF NOT EXISTS ccn_settings (key TEXT PRIMARY KEY, value TEXT NOT NULL)\",\n \"CREATE TABLE IF NOT EXISTS ccn_runs (id TEXT PRIMARY KEY, kind TEXT NOT NULL, city TEXT, status TEXT NOT NULL, summary TEXT NOT NULL, at INTEGER NOT NULL, duration INTEGER NOT NULL)\",\n \"CREATE TABLE IF NOT EXISTS ccn_leases (name TEXT PRIMARY KEY, owner TEXT NOT NULL, until_at INTEGER NOT NULL)\",\n \"CREATE TABLE IF NOT EXISTS ccn_submissions (id TEXT PRIMARY KEY, kind TEXT NOT NULL, json TEXT NOT NULL, contact TEXT NOT NULL, status TEXT NOT NULL DEFAULT 'pending', at INTEGER NOT NULL)\",\n \"CREATE TABLE IF NOT EXISTS ccn_clicks (day TEXT NOT NULL, campaign TEXT NOT NULL, kind TEXT NOT NULL, target TEXT NOT NULL, count INTEGER NOT NULL, PRIMARY KEY(day,campaign,kind,target))\",\n \"CREATE TABLE IF NOT EXISTS ccn_subscribers (day TEXT NOT NULL, city TEXT NOT NULL, total INTEGER, status TEXT NOT NULL, PRIMARY KEY(day,city))\",\n \"CREATE TABLE IF NOT EXISTS ccn_rates (key TEXT PRIMARY KEY, count INTEGER NOT NULL, expires INTEGER NOT NULL)\",\n ];\n await batch(schemas.map((text) => ({ sql: text })));\n await q(\"INSERT OR IGNORE INTO ccn_migrations VALUES (1, ?)\", [Date.now()]);\n for (const [key, value] of [[\"kill\", \"1\"], [\"translation_daily_cap\", \"12\"], ...Object.keys(cities).flatMap((city) => [[`${city}:paused`, \"1\"], [`${city}:enabled`, \"0\"], [`${city}:dryRun`, \"1\"]])]) await q(\"INSERT OR IGNORE INTO ccn_settings VALUES (?, ?)\", [key, value]);\n })().catch((e) => { ready = undefined; throw e; });\n return ready;\n }\n async function setting(key: string, fallback = \"\"): Promise { await init(); const r = await q(\"SELECT value FROM ccn_settings WHERE key=?\", [key]); return r.rows.length ? String(r.rows[0].value) : fallback; }\n async function set(key: string, value: string): Promise { await init(); await q(\"INSERT INTO ccn_settings VALUES (?,?) ON CONFLICT(key) DO UPDATE SET value=excluded.value\", [key, value]); }\n async function flags(city: string) { return { kill: (await setting(\"kill\", \"1\")) !== \"0\", paused: (await setting(`${city}:paused`, \"1\")) !== \"0\", enabled: (await setting(`${city}:enabled`, \"0\")) === \"1\", dryRun: (await setting(`${city}:dryRun`, \"1\")) !== \"0\" }; }\n async function lease(name: string, ttl = 90000): Promise {\n await init(); const owner = crypto.randomUUID(), now = Date.now();\n const r = await q(\"INSERT INTO ccn_leases VALUES (?,?,?) ON CONFLICT(name) DO UPDATE SET owner=excluded.owner, until_at=excluded.until_at WHERE ccn_leases.until_at {\n await batch([\n { sql: \"UPDATE ccn_events SET review='draft', approved_hash=NULL, translation=NULL, translation_hash=NULL WHERE id=?\", args: [id] },\n { sql: \"UPDATE ccn_publications SET needs_correction=1, reason=? WHERE key IN (SELECT publication_key FROM ccn_publication_items WHERE event_id=?) AND state IN ('sent','sending','delivery_unknown')\", args: [reason, id] },\n { sql: \"UPDATE ccn_publications SET state='invalidated', reason=? WHERE key IN (SELECT publication_key FROM ccn_publication_items WHERE event_id=?) AND state IN ('pending','retry')\", args: [reason, id] },\n ]);\n // Migration 2 is optional for legacy/test stores. Flag new-feed posts too.\n if ((await q(\"SELECT name FROM sqlite_master WHERE type='table' AND name='ccn_feed_deliveries'\")).rows.length) await q(\"UPDATE ccn_feed_deliveries SET state=CASE WHEN state IN ('pending','retry') THEN 'invalidated' ELSE state END,reason=? WHERE state IN ('pending','retry','sent','sending','delivery_unknown') AND EXISTS (SELECT 1 FROM json_each(ccn_feed_deliveries.items) item WHERE json_extract(item.value,'$.id')=?)\", [reason, id]);\n }\n async function ingest(events: EventData[]): Promise<{ inserted: number; unchanged: number; changed: number; duplicates: number; review: number }> {\n await init(); const stats = { inserted: 0, unchanged: 0, changed: 0, duplicates: 0, review: 0 };\n for (const raw of events.slice(0, 40)) {\n validateEvent(raw); const now = Date.now(); const key = await hash(`${raw.city}|${raw.source}|${raw.sourceItemId}|${raw.date}|${raw.start}`); const event = { ...raw, id: key }; const text = JSON.stringify(event); const digest = await hash(text);\n const old = (await q(\"SELECT * FROM ccn_records WHERE key=?\", [key])).rows[0];\n if (old) {\n await q(\"UPDATE ccn_records SET last_seen=?, verified=? WHERE key=?\", [now, now, key]);\n if (old.hash === digest) { await q(\"UPDATE ccn_events SET last_seen=?, verified=? WHERE id=?\", [now, now, String(old.event_id)]); stats.unchanged++; continue; }\n const canonical = String(old.event_id);\n await invalidate(canonical, \"Source details changed; check affected Telegram messages\");\n await q(\"UPDATE ccn_records SET json=?,hash=?,last_seen=?,verified=? WHERE key=?\", [text, digest, now, now, key]);\n if (canonical === key) await q(\"UPDATE ccn_events SET json=?,hash=?,last_seen=?,verified=? WHERE id=?\", [text, digest, now, now, canonical]);\n stats.changed++; continue;\n }\n const existing = await q(\"SELECT id,json FROM ccn_events WHERE city=? AND duplicate_of IS NULL AND fixture=0 LIMIT 1001\", [event.city]);\n if (existing.rows.length > 1000) throw new Error(\"Manual archival required: matching set exceeds safety limit\");\n let canonical = key; const uncertain: string[] = [];\n for (const row of existing.rows) { const decision = match(event, JSON.parse(String(row.json)) as EventData); if (decision === \"same\") { canonical = String(row.id); break; } if (decision === \"review\") uncertain.push(String(row.id)); }\n const statements: Statement[] = [{ sql: \"INSERT INTO ccn_records VALUES (?,?,?,?,?,?,?,?,?,?)\", args: [key, canonical, event.source, event.city, event.url, text, digest, now, now, now] }];\n if (canonical === key) statements.push({ sql: \"INSERT INTO ccn_events (id,city,source,json,hash,review,first_seen,last_seen,verified) VALUES (?,?,?,?,?,?,?,?,?)\", args: [key, event.city, event.source, text, digest, uncertain.length ? \"duplicate_review\" : \"draft\", now, now, now] });\n for (const other of uncertain) if (canonical === key) statements.push({ sql: \"INSERT OR IGNORE INTO ccn_duplicates VALUES (?,?,?,?,?,?)\", args: [[key, other].sort().join(\":\"), key, other, \"pending\", \"Similar title or same venue/time; human review required\", now] });\n await batch(statements);\n if (canonical !== key) { stats.duplicates++; await invalidate(canonical, \"New source provenance added; verify conflicting metadata\"); } else { stats.inserted++; if (uncertain.length) stats.review++; }\n }\n // A verified detail page changing its occurrence list is a review signal,\n // not evidence of cancellation. Merely absent listing cards never reach here.\n const refreshed = new Map }>();\n for (const event of events.slice(0, 40)) {\n if (event.source === \"organizer\") continue;\n const group = `${event.city}|${event.source}|${event.url}`;\n const entry = refreshed.get(group) || { event, keys: new Set() };\n entry.keys.add(await hash(`${event.city}|${event.source}|${event.sourceItemId}|${event.date}|${event.start}`));\n refreshed.set(group, entry);\n }\n for (const { event, keys } of refreshed.values()) {\n const previous = (await q(\"SELECT r.key,r.event_id,e.review FROM ccn_records r JOIN ccn_events e ON e.id=r.event_id WHERE r.city=? AND r.source=? AND r.url=?\", [event.city, event.source, event.url])).rows;\n for (const row of previous) if (!keys.has(String(row.key)) && row.review !== \"source_review\") {\n await invalidate(String(row.event_id), \"Verified detail-page occurrence list changed; confirm old schedule, do not assume cancellation\");\n await q(\"UPDATE ccn_events SET review='source_review' WHERE id=? AND duplicate_of IS NULL\", [String(row.event_id)]);\n await audit(String(row.event_id), \"schedule_review\", \"Prior occurrence missing from a newly verified detail-page response; cancellation remains unknown\");\n }\n }\n return stats;\n }\n async function audit(eventId: string | null, action: string, note = \"\", seconds = 0) { await q(\"INSERT INTO ccn_editorial VALUES (?,?,?,?,?,?)\", [crypto.randomUUID(), eventId, action, note.slice(0, 1000), Math.min(3600, Math.max(0, seconds)), Date.now()]); }\n async function budget(cap: number, day = new Date().toISOString().slice(0, 10)): Promise {\n if (!Number.isFinite(cap) || cap < 1) return false;\n const r = await q(\"INSERT INTO ccn_usage(day,requests,tokens) VALUES (?,1,0) ON CONFLICT(day) DO UPDATE SET requests=ccn_usage.requests+1 WHERE ccn_usage.requests 0;\n }\n async function rate(key: string, limit: number, ttl: number): Promise {\n const now = Date.now(); const r = await q(\"INSERT INTO ccn_rates VALUES (?,1,?) ON CONFLICT(key) DO UPDATE SET count=CASE WHEN ccn_rates.expires 0;\n }\n async function claim(key: string): Promise | null> {\n const now = Date.now(), token = crypto.randomUUID();\n const r = await q(\"UPDATE ccn_publications SET state='sending',attempts=attempts+1,claimed_at=?,claim_token=? WHERE key=? AND state IN ('pending','retry') AND retry_at<=? AND expires>? AND attempts<3 RETURNING *\", [now, token, key, now, now]); return r.rows[0] || null;\n }\n async function recover(): Promise {\n const now = Date.now();\n await q(\"UPDATE ccn_publications SET state='delivery_unknown', reason='Worker ended during send; reconcile manually' WHERE state='sending' AND claimed_at;\n","deleted",false,"label",[14],"47a79ebc-05ee-454e-983d-7f48a62bccc0",["D",1789621418009],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","City events: Shymkent review pilot, isolated from live Almaty","imageUrl","userId","f5be24e4-c798-4816-91e5-037b60b986f5","pinnedFileId","01a0adbf-b85c-735b-b5fd-9913cdd6d31f","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","7f67379d-2d38-49bd-81ac-2c7f92a739e2","tursoName","47a79ebc05ee454e983d7f48a62bccc0","tursoHostname","47a79ebc05ee454e983d7f48a62bccc0-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789710048837],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_105":101},"org",{"_9":10,"_99":-5,"_100":101,"_55":56,"_102":103,"_104":42},"branch",{"_35":89,"_11":90,"_22":28,"_91":45,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":12,"_98":10},"isOwned",59,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18ycWxkOWxiOE00SkVtZENmRWM4YWxLWTRVUFMifQ","tier","free","canRestrictVals","profileImageUrl","ctx",{"_82":-5,"_139":140,"_141":142,"_143":144,"_145":42,"_146":42,"_147":42,"_148":32,"_149":-5,"_150":-7,"_151":-7,"_152":63,"_153":42,"_154":42,"_155":-5,"_156":42,"_157":42,"_158":42,"_159":-5},"ENV",{"_110":111,"_112":113,"_114":90,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","71c1b20804b3232a7e513be260cfffc1932a9e97","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"]