[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_189":190,"_191":192},"routes/_app.x.$handle.$name",{"_106":105,"_38":51,"_114":96,"_33":115,"_13":14,"_116":-5,"_11":117,"_118":119,"_120":121,"_122":123,"_124":125,"_26":-5,"_126":-5,"_127":-5,"_128":31,"_129":130,"_131":65,"_132":-5,"_133":-5,"_134":135},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_49":50,"_38":51,"_44":52,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":69,"_70":71,"_72":73,"_74":75,"_76":77,"_78":-5,"_79":80,"_81":80,"_82":83,"_84":83,"_85":83,"_86":80,"_87":80,"_88":89,"_90":91,"_92":93,"_94":31},"version",6,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","8eb9acac-7b11-4e97-910d-72f0a80d6465","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":29,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":34,"_39":40,"_41":43,"_44":45,"_46":14,"_47":48,"_30":31},"previous",{"_36":37,"_38":34,"_39":40,"_41":42},"deleted",false,"deletedHere","path","lib.ts","latestPath","fileId","2e999f58-af11-11f1-99c2-1607ee4eb77e","name","fileType","script","content","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport {\n Create,\n Deserialize,\n Serialize,\n collections,\n index,\n query,\n} from \"npm:@koda.oss/glyph@1.0.0\";\n\n/** Sessions expire after 5 minutes of inactivity. */\nexport const SESSION_TTL_MS = 5 * 60 * 1000;\n\nexport type SessionInfo = { name: string; expiresAt: number };\n\nconst now = () => Date.now();\n\n/** Idempotent schema setup. */\nexport async function init() {\n await sqlite.batch([\n {\n sql:\n `CREATE TABLE IF NOT EXISTS sessions (\n name TEXT PRIMARY KEY,\n last_activity INTEGER NOT NULL\n )`,\n },\n {\n sql:\n `CREATE TABLE IF NOT EXISTS observations (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n session TEXT NOT NULL,\n glyph TEXT NOT NULL,\n context TEXT NOT NULL\n )`,\n },\n {\n sql: `CREATE INDEX IF NOT EXISTS idx_obs_session ON observations(session)`,\n },\n ]);\n}\n\nasync function existsSession(name: string): Promise {\n const res = await sqlite.execute(\n \"SELECT last_activity FROM sessions WHERE name = ?\",\n [name],\n );\n if (res.rows.length === 0) return undefined;\n return Number(res.rows[0].last_activity);\n}\n\n/**\n * If the session exists but its last activity is older than the TTL, the\n * session has expired: wipe its observations and delete the row.\n * Returns true if we now have a live session under this name.\n */\nexport async function expireIfStale(name: string): Promise {\n const last = await existsSession(name);\n if (last === undefined) return false;\n if (now() - last > SESSION_TTL_MS) {\n await sqlite.batch([\n { sql: \"DELETE FROM observations WHERE session = ?\", args: [name] },\n { sql: \"DELETE FROM sessions WHERE name = ?\", args: [name] },\n ]);\n return false;\n }\n return true;\n}\n\nexport async function touch(name: string) {\n await sqlite.execute(\n \"UPDATE sessions SET last_activity = ? WHERE name = ?\",\n [now(), name],\n );\n}\n\n/**\n * Create a session with an arbitrary name. Idempotent: returns the existing\n * session if one is still active (callers rely on expireIfStale having run\n * first).\n */\nexport async function createSession(name: string): Promise {\n const active = await expireIfStale(name);\n let last: number;\n if (active) {\n const existing = await existsSession(name);\n last = existing!;\n await touch(name);\n } else {\n last = now();\n await sqlite.execute(\n \"INSERT INTO sessions (name, last_activity) VALUES (?, ?)\",\n [name, last],\n );\n }\n return { name, expiresAt: last + SESSION_TTL_MS };\n}\n\nexport type Observation = { id: number; glyph: string; context: string };\n\n/**\n * Preserve context given a set of observations.\n *\n * The observations are *not* stored. They are added to a Glyph collection,\n * whose aggregated glyph `col.glyph` is serialized and stored as a single\n * observation glyph. The raw context text is stored keyed to that glyph.\n */\nexport async function preserve(\n session: string,\n observations: string[],\n context: string,\n): Promise {\n const col = collections.New();\n observations.forEach((obs, i) => col.Add(String(i), obs));\n const glyphStr = Serialize(col.glyph);\n\n const res = await sqlite.execute(\n \"INSERT INTO observations (session, glyph, context) VALUES (?, ?, ?)\",\n [session, glyphStr, context],\n );\n await touch(session);\n\n return {\n id: Number(res.lastInsertRowid),\n glyph: glyphStr,\n context,\n };\n}\n\n/**\n * Recall context. All preserved observation glyphs for the session are\n * collected, deserialized into an in-memory index, and searched with a probe\n * glyph built from `query`. The context of the top `limit` hits is returned.\n */\nexport async function recall(\n session: string,\n queryText: string,\n limit = 3,\n): Promise<{ id: number; similarity: number; context: string }[]> {\n const rows = await sqlite.execute(\n \"SELECT id, glyph, context FROM observations WHERE session = ?\",\n [session],\n );\n\n // Sessions hold a small number of observation glyphs, so an exact scan\n // (mode \"direct\") ranks every entry reliably instead of relying on LSH band\n // candidates which can miss short/aggregated glyphs.\n const idx = index.New({ mode: \"direct\" });\n const contextById = new Map();\n for (const row of rows.rows) {\n const id = Number(row.id);\n idx.Set(String(id), Deserialize(String(row.glyph)));\n contextById.set(id, String(row.context));\n }\n\n const probe = Create(queryText).glyph;\n const hits = query.New(idx).Search(probe, {\n limit,\n threshold: 0,\n normalize: true,\n });\n\n await touch(session);\n\n return hits.map((h) => ({\n id: Number(h.key),\n similarity: h.similarity,\n context: contextById.get(Number(h.key)) ?? \"\",\n }));\n}\n","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport {\n CollectionAggregatorMin,\n Create,\n Deserialize,\n Serialize,\n collections,\n index,\n query,\n} from \"npm:@koda.oss/glyph@1.0.0\";\n\n/** Sessions expire after 5 minutes of inactivity. */\nexport const SESSION_TTL_MS = 5 * 60 * 1000;\n\nexport type SessionInfo = { name: string; expiresAt: number };\n\nconst now = () => Date.now();\n\n/** Idempotent schema setup. */\nexport async function init() {\n await sqlite.batch([\n {\n sql:\n `CREATE TABLE IF NOT EXISTS sessions (\n name TEXT PRIMARY KEY,\n last_activity INTEGER NOT NULL\n )`,\n },\n {\n sql:\n `CREATE TABLE IF NOT EXISTS observations (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n session TEXT NOT NULL,\n glyph TEXT NOT NULL,\n context TEXT NOT NULL\n )`,\n },\n {\n sql: `CREATE INDEX IF NOT EXISTS idx_obs_session ON observations(session)`,\n },\n ]);\n}\n\nasync function existsSession(name: string): Promise {\n const res = await sqlite.execute(\n \"SELECT last_activity FROM sessions WHERE name = ?\",\n [name],\n );\n if (res.rows.length === 0) return undefined;\n return Number(res.rows[0].last_activity);\n}\n\n/**\n * If the session exists but its last activity is older than the TTL, the\n * session has expired: wipe its observations and delete the row.\n * Returns true if we now have a live session under this name.\n */\nexport async function expireIfStale(name: string): Promise {\n const last = await existsSession(name);\n if (last === undefined) return false;\n if (now() - last > SESSION_TTL_MS) {\n await sqlite.batch([\n { sql: \"DELETE FROM observations WHERE session = ?\", args: [name] },\n { sql: \"DELETE FROM sessions WHERE name = ?\", args: [name] },\n ]);\n return false;\n }\n return true;\n}\n\nexport async function touch(name: string) {\n await sqlite.execute(\n \"UPDATE sessions SET last_activity = ? WHERE name = ?\",\n [now(), name],\n );\n}\n\n/**\n * Create a session with an arbitrary name. Idempotent: returns the existing\n * session if one is still active (callers rely on expireIfStale having run\n * first).\n */\nexport async function createSession(name: string): Promise {\n const active = await expireIfStale(name);\n let last: number;\n if (active) {\n const existing = await existsSession(name);\n last = existing!;\n await touch(name);\n } else {\n last = now();\n await sqlite.execute(\n \"INSERT INTO sessions (name, last_activity) VALUES (?, ?)\",\n [name, last],\n );\n }\n return { name, expiresAt: last + SESSION_TTL_MS };\n}\n\nexport type Observation = { id: number; glyph: string; context: string };\n\n/**\n * Preserve context given a set of observations.\n *\n * The observations are *not* stored. They are added to a Glyph collection,\n * whose aggregated glyph `col.glyph` is serialized and stored as a single\n * observation glyph. The raw context text is stored keyed to that glyph.\n */\nexport async function preserve(\n session: string,\n observations: string[],\n context: string,\n): Promise {\n const col = collections.New();\n observations.forEach((obs, i) => col.Add(String(i), obs));\n const glyphStr = Serialize(col.glyph);\n\n const res = await sqlite.execute(\n \"INSERT INTO observations (session, glyph, context) VALUES (?, ?, ?)\",\n [session, glyphStr, context],\n );\n await touch(session);\n\n return {\n id: Number(res.lastInsertRowid),\n glyph: glyphStr,\n context,\n };\n}\n\n/**\n * Recall context. All preserved observation glyphs for the session are\n * collected, deserialized into an in-memory index, and searched with a probe\n * glyph built from `query`. The context of the top `limit` hits is returned.\n */\nexport async function recall(\n session: string,\n queryText: string,\n limit = 3,\n): Promise<{ id: number; similarity: number; context: string }[]> {\n const rows = await sqlite.execute(\n \"SELECT id, glyph, context FROM observations WHERE session = ?\",\n [session],\n );\n\n // Sessions hold a small number of observation glyphs, so an exact scan\n // (mode \"direct\") ranks every entry reliably instead of relying on LSH band\n // candidates which can miss short/aggregated glyphs.\n const idx = index.New({ mode: \"direct\" });\n const contextById = new Map();\n for (const row of rows.rows) {\n const id = Number(row.id);\n idx.Set(String(id), Deserialize(String(row.glyph)));\n contextById.set(id, String(row.context));\n }\n\n const probe = Create(queryText).glyph;\n const hits = query.New(idx).Search(probe, {\n limit,\n threshold: 0,\n normalize: true,\n });\n\n await touch(session);\n\n return hits.map((h) => ({\n id: Number(h.key),\n similarity: h.similarity,\n context: contextById.get(Number(h.key)) ?? \"\",\n }));\n}\n","createdAt",["D",1789262610025],"branchVersion","branchId","b6266b42-3115-423f-90c4-eade8b285202","id","dc7c0eba-7a05-443d-bdd7-f856500b08d1","tcall",["D",1789262359413],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","TCall - Glyph-based session search engine","imageUrl","6c384150-64ca-4244-b2ee-7b84c0f6699d","pinnedFileId","360aa886-af11-11f1-9b64-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","5a43150a-9237-460e-8c20-357c1305f22b","tursoName","dc7c0eba7a05443dbdd7f856500b08d1","tursoHostname","dc7c0eba7a05443dbdd7f856500b08d1-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789530055570],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_106":105,"_113":109},"org",{"_106":105,"_107":-5,"_108":109,"_19":61,"_110":111,"_112":31},"branch",{"_13":95,"_38":96,"_49":48,"_97":50,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":-5,"_103":51,"_104":105},"isOwned",33,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","lucidpurplee","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18ybGZQNVFqVDhtY0NpaFBhU0tsVFY4dGVKWncifQ","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_49":50,"_38":51,"_44":184,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":69,"_70":71,"_72":73,"_74":75,"_76":185,"_78":-5,"_79":80,"_81":80,"_82":83,"_84":83,"_85":83,"_86":80,"_87":80,"_88":186,"_90":187,"_92":188,"_94":31},"tree",[171,172,173],"files",[171,172,173],"counts",{"_160":69,"_161":162,"_163":69,"_164":165,"_166":167},"contents",[136,137,138],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_49":153,"_38":154,"_36":155,"_141":-5,"_47":48,"_46":156,"_143":31,"_44":157,"_13":69,"_39":40,"_41":158,"_30":31,"_147":-5,"_33":159},{"_49":149,"_38":34,"_36":37,"_141":-5,"_47":48,"_46":14,"_143":31,"_44":150,"_13":151,"_39":40,"_41":43,"_30":31,"_147":-5,"_33":152},{"_49":139,"_38":140,"_36":63,"_141":-5,"_47":48,"_46":142,"_143":31,"_44":144,"_13":69,"_39":145,"_41":146,"_30":31,"_147":51,"_33":148},"610eb7b5-6b15-4d45-ac4a-1eefee14f86b","main.ts","parentId",2,"latest",["D",1789262388065],"http","import { Hono } from \"npm:hono\";\nimport {\n createSession,\n expireIfStale,\n init,\n preserve,\n recall,\n} from \"./lib.ts\";\n\nconst app = new Hono();\n\nawait init();\n\n// 404 if the session doesn't exist or has expired.\nasync function requireSession(c: any): Promise {\n const body = (await c.req.json().catch(() => ({}))) as any;\n const name = String(body.session ?? \"\").trim();\n if (!name) {\n c.status(400);\n c.body(JSON.stringify({ error: \"Missing session name\" }));\n return false;\n }\n const live = await expireIfStale(name);\n if (!live) {\n c.status(404);\n c.body(\n JSON.stringify({\n error: \"Session does not exist or has expired\",\n session: name,\n }),\n );\n return false;\n }\n c.set(\"session\", name);\n return true;\n}\n\n// POST /session/create { name, [ttlMinutes] }\napp.post(\"/session/create\", async (c) => {\n const body = (await c.req.json().catch(() => ({}))) as any;\n const name = String(body.name ?? \"\").trim();\n if (!name) {\n return c.json({ error: \"Missing name\" }, 400);\n }\n const session = await createSession(name);\n return c.json({\n ok: true,\n session: session.name,\n expiresInSeconds: 5 * 60,\n expiresAt: new Date(session.expiresAt).toISOString(),\n });\n});\n\n// POST /session/preserve\n// { session, observations: string[], context: string }\napp.post(\"/session/preserve\", async (c) => {\n if (!(await requireSession(c))) return c;\n const name = c.get(\"session\");\n const body = (await c.req.json().catch(() => ({}))) as any;\n const observations: string[] = Array.isArray(body.observations)\n ? body.observations.map(String)\n : [];\n const context = String(body.context ?? \"\").trim();\n if (observations.length === 0 || !context) {\n return c.json(\n { error: \"observations (array) and context (string) are required\" },\n 400,\n );\n }\n const obs = await preserve(name, observations, context);\n return c.json({ ok: true, id: obs.id });\n});\n\n// POST /session/recall\n// { session, query: string, limit?: number }\napp.post(\"/session/recall\", async (c) => {\n if (!(await requireSession(c))) return c;\n const name = c.get(\"session\");\n const body = (await c.req.json().catch(() => ({}))) as any;\n const queryText = String(body.query ?? \"\").trim();\n const limit = Math.max(\n 1,\n Math.min(20, Number(body.limit ?? 3) || 3),\n );\n if (!queryText) {\n return c.json({ error: \"Missing query\" }, 400);\n }\n const results = await recall(name, queryText, limit);\n const total = await count(name);\n return c.json({ ok: true, query: queryText, total, results });\n});\n\nasync function count(name: string): Promise {\n const { sqlite } = await import(\"https://esm.town/v/std/sqlite/main.ts\");\n const res = await sqlite.execute(\n \"SELECT COUNT(*) AS n FROM observations WHERE session = ?\",\n [name],\n );\n return Number(res.rows[0].n);\n}\n\nexport default app.fetch;\n","label",[140],"014f1386-a0d2-4ef6-91fd-922de5406757",["D",1789262610025],3,[34],"c1f2124f-9aef-4887-aeec-ac98df0a8a65","debug-glyph.ts","b38067ec-af11-11f1-9c07-1607ee4eb77e",5,["D",1789262598587],"import {\n CollectionAggregatorMin,\n CollectionAggregatorSoftmax,\n Compare,\n Create,\n collections,\n} from \"npm:@koda.oss/glyph@1.0.0\";\n\nconst observations = [\n \"the new pricing is forty nine dollars per seat for the pro tier\",\n \"we raised prices effective next quarter\",\n \"annual plans get a twenty percent discount\",\n];\n\nconst query = \"what did we decide about pricing per seat\";\n\nfor (const [label, agg] of [\n [\"softmax\", CollectionAggregatorSoftmax],\n [\"min\", CollectionAggregatorMin],\n] as const) {\n const col = collections.New({ aggregator: agg });\n observations.forEach((o, i) => col.Add(String(i), o));\n const probe = Create(query).glyph;\n const sim = Compare(probe, col.glyph).similarity;\n const exact = Compare(\n Create(\"the new pricing is forty nine dollars per seat for the pro tier\").glyph,\n col.glyph,\n ).similarity;\n console.log(label, \"query-sim\", sim.toFixed(3), \"exact-obs-sim\", exact.toFixed(3));\n}\n",[154],"pulls","branches",1,"forks","envVars",{"_168":69,"_170":69},"connections",{"_168":69,"_169":69},"count","unfilledCount","emptyCount",{"_49":153,"_38":154,"_36":155,"_141":-5,"_47":48,"_46":156,"_143":31,"_44":181,"_13":69,"_39":40,"_41":158,"_30":31,"_147":-5,"_175":182,"_33":183},{"_49":149,"_38":34,"_36":37,"_141":-5,"_47":48,"_46":14,"_143":31,"_44":178,"_13":151,"_39":40,"_41":43,"_30":31,"_147":-5,"_175":179,"_33":180},{"_49":139,"_38":140,"_36":63,"_141":-5,"_47":48,"_46":142,"_143":31,"_44":174,"_13":69,"_39":145,"_41":146,"_30":31,"_147":51,"_175":176,"_33":177},["D",1789262388065],"children",[],[140],["D",1789262610025],[],[34],["D",1789262598587],[],[154],["D",1789262359413],["D",1789530055570],{"_106":105,"_113":109},{"_106":105,"_107":-5,"_108":109,"_19":61,"_110":111,"_112":31},{"_13":95,"_38":96,"_49":48,"_97":50,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":-5,"_103":51,"_104":105},"ctx",{"_88":-5,"_133":222,"_223":224,"_225":226,"_227":31,"_228":31,"_229":31,"_230":65,"_231":-5,"_232":-7,"_233":-7,"_234":69,"_235":31,"_236":31,"_237":-5,"_238":31,"_239":31,"_240":31,"_241":-5},"ENV",{"_193":194,"_195":196,"_197":96,"_198":199,"_200":201,"_202":203,"_204":205,"_206":207,"_208":209,"_210":211,"_212":213,"_214":215,"_216":217,"_218":219,"_220":221},"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 · v6