[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_104":105,"_106":107},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","omriluz","name","almaty-expats-events","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":-5,"_58":42,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":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/almaty-expats-events/code/store.ts","extension","id","b7a60118-451b-4796-9a5c-1f83702579ab","fileId","b8a2f178-af47-11f1-a7f2-1607ee4eb77e","parentId","branchId","e4a77bba-1aa1-485e-b111-fe8857841a88","branchVersion",19,"latest",true,"createdAt",["D",1789297619593],"version",1,"fileType","script","content","import { sqlite } from 'https://esm.town/v/std/sqlite/main.ts';\nimport type { Event } from './source.ts';\nexport { sqlite };\nexport async function init() {\n await sqlite.batch([\n `CREATE TABLE IF NOT EXISTS events (id TEXT PRIMARY KEY, url TEXT NOT NULL, starts_ms INTEGER NOT NULL, raw_json TEXT NOT NULL, english_json TEXT, state TEXT NOT NULL DEFAULT 'queued', created_ms INTEGER NOT NULL, updated_ms INTEGER NOT NULL, retry_after_ms INTEGER NOT NULL DEFAULT 0, posted_ms INTEGER, message_id INTEGER, error TEXT)`,\n `CREATE INDEX IF NOT EXISTS events_queue ON events(state,starts_ms)`,\n `CREATE INDEX IF NOT EXISTS events_dates ON events(starts_ms)`,\n `CREATE TABLE IF NOT EXISTS event_matches (event_id TEXT PRIMARY KEY, canonical_id TEXT NOT NULL, decision TEXT NOT NULL, score REAL NOT NULL, reason TEXT NOT NULL, updated_ms INTEGER NOT NULL)`,\n `CREATE INDEX IF NOT EXISTS matches_canonical ON event_matches(canonical_id)`,\n `CREATE TABLE IF NOT EXISTS source_checks (url TEXT PRIMARY KEY, checked_ms INTEGER NOT NULL, error TEXT)`,\n `CREATE TABLE IF NOT EXISTS locks (name TEXT PRIMARY KEY, token TEXT NOT NULL, expires_ms INTEGER NOT NULL)`,\n `CREATE TABLE IF NOT EXISTS outbox (hour_slot INTEGER PRIMARY KEY, event_id TEXT NOT NULL, target TEXT NOT NULL, state TEXT NOT NULL, created_ms INTEGER NOT NULL, message_id INTEGER, error TEXT)`,\n `CREATE TABLE IF NOT EXISTS runs (id TEXT PRIMARY KEY, started_ms INTEGER NOT NULL, status TEXT NOT NULL, details TEXT)`\n ]);\n}\nexport async function lock(token:string):Promise {\n const now=Date.now();\n const r=await sqlite.execute({sql:`INSERT INTO locks(name,token,expires_ms) VALUES('hourly',?,?) ON CONFLICT(name) DO UPDATE SET token=excluded.token,expires_ms=excluded.expires_ms WHERE locks.expires_ms0;\n}\nexport async function unlock(token:string) {await sqlite.execute({sql:`DELETE FROM locks WHERE name='hourly' AND token=?`,args:[token]});}\nexport async function saveEvent(e:Event):Promise {\n const raw=JSON.stringify(e),now=Date.now();\n const r=await sqlite.execute({sql:`INSERT OR IGNORE INTO events(id,url,starts_ms,raw_json,created_ms,updated_ms) VALUES(?,?,?,?,?,?)`,args:[e.id,e.url,e.startsMs,raw,now,now]});\n if (!r.rowsAffected) await sqlite.execute({sql:`UPDATE events SET english_json=CASE WHEN raw_json=? THEN english_json ELSE NULL END, state=CASE WHEN raw_json=? THEN state ELSE 'queued' END, raw_json=?,updated_ms=? WHERE id=? AND state IN ('queued','ready')`,args:[raw,raw,raw,now,e.id]});\n return r.rowsAffected>0;\n}\nexport async function saveCheck(url:string,error:string|null=null) {\n await sqlite.execute({sql:`INSERT INTO source_checks(url,checked_ms,error) VALUES(?,?,?) ON CONFLICT(url) DO UPDATE SET checked_ms=excluded.checked_ms,error=excluded.error`,args:[url,Date.now(),error]});\n}\nexport async function checkTimes():Promise> {\n const r=await sqlite.execute(`SELECT url,checked_ms FROM source_checks`);\n return new Map(r.rows.map(r=>[String(r.url),Number(r.checked_ms)]));\n}\nexport async function candidates() {\n const now=Date.now();\n await sqlite.execute({sql:`UPDATE events SET state='expired' WHERE state IN ('queued','ready') AND starts_ms=? AND starts_ms<=? AND retry_after_ms<=? ORDER BY starts_ms ASC LIMIT 5`,args:[now+3600000,now+14*86400000,now]})).rows;\n}\nexport async function recordRun(id:string,started:number,status:string,details:unknown) {\n await sqlite.execute({sql:`INSERT OR REPLACE INTO runs(id,started_ms,status,details) VALUES(?,?,?,?)`,args:[id,started,status,JSON.stringify(details)]});\n await sqlite.execute({sql:`DELETE FROM runs WHERE started_ms