[{"_1":2,"_183":-5,"_184":-5},"loaderData",{"_3":4,"_93":94},"root",{"_5":6,"_36":37,"_66":67},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesChatPanelState","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63,"_64":65},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","e9e636d7b466d0cb012ac9b89f74068c1d9c5525","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","clerkState",{"_68":69},"__internal_clerk_state",{"_70":71,"_72":47,"_73":74,"_75":74,"_76":20,"_77":74,"_78":74,"_79":74,"_80":74,"_81":82,"_91":20,"_92":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_83":20,"_19":20,"_84":74,"_85":86,"_87":74,"_88":47,"_89":20,"_90":74},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_95":96,"_97":98,"_99":100,"_101":102,"_156":157,"_180":181,"_182":-5},"handle","catalloc","name","catnip","path","discord/persistence/kv.ts","project",{"_103":104,"_97":98,"_105":106,"_107":-5,"_108":20,"_109":110,"_111":112,"_113":-5,"_12":114,"_115":-5,"_116":20,"_117":-5,"_118":-5,"_119":33,"_14":120,"_121":122,"_123":124,"_125":126,"_127":126,"_128":129,"_130":129,"_131":129,"_132":126,"_133":126,"_23":134,"_137":138,"_142":143,"_155":20},"id","f89e4358-134e-11f1-911b-42dde27851f2","createdAt",["D",1772136532467],"deletedAt","legacyEnvVars","privacy","public","description","Open source Discord bot template built for Val Town","imageUrl","d06b6c80-f3a1-11ef-89a3-8735e07158f4","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","e03963fb-ecc4-48fb-bc25-0173a8b9a8c8","tursoName","f89e4358134e11f1911b42dde27851f2","tursoHostname","f89e4358134e11f1911b42dde27851f2-val-town.aws-us-east-2.turso.io","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_95":96,"_135":136},"profileImageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/0478d851-5bca-4d5e-6593-fb952af01c00/square512","org",{"_95":96,"_139":136,"_12":114,"_140":141},"avatar","tier","pro","branch",{"_144":145,"_97":45,"_103":146,"_147":104,"_148":-5,"_149":-5,"_150":-5,"_151":-5,"_152":-5,"_153":98,"_154":96},"version",233,"f89e7d78-134e-11f1-911b-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_103":158,"_97":159,"_160":161,"_162":163,"_164":146,"_165":166,"_167":168,"_105":169,"_144":170,"_171":172,"_173":174,"_175":20,"_176":-5,"_99":177},"33810acc-1521-11f1-b5fb-42dde27851f2","kv.ts","fileId","fa6f4ff6-134e-11f1-8484-42dde27851f2","parentId","f931fa9e-134e-11f1-aa99-42dde27851f2","branchId","branchVersion",231,"latest",true,["D",1772336776712],5,"fileType","script","content","/**\n * discord/persistence/kv.ts\n *\n * Minimal key-value store wrapping Val Town SQLite.\n * Auto-creates the table on first use.\n *\n * Supports an optional `due_at` column (epoch ms) for time-based queries,\n * enabling cron jobs to fetch only due items via `listDue()` instead of\n * loading all entries and filtering in JS.\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst TABLE = \"kv_store\";\nlet initialized = false;\n\nasync function ensureTable(): Promise {\n if (initialized) return;\n await sqlite.execute(\n `CREATE TABLE IF NOT EXISTS ${TABLE} (key TEXT PRIMARY KEY, value TEXT NOT NULL, due_at INTEGER)`,\n );\n await sqlite.execute(\n `CREATE INDEX IF NOT EXISTS idx_kv_due_at ON ${TABLE} (due_at) WHERE due_at IS NOT NULL`,\n );\n initialized = true;\n}\n\nfunction escapeLikePrefix(prefix: string): string {\n return prefix.replace(/[\\\\%_]/g, (ch) => `\\\\${ch}`);\n}\n\nfunction safeParse(raw: string): T | null {\n try {\n return JSON.parse(raw) as T;\n } catch {\n return null;\n }\n}\n\nexport const kv = {\n async get(key: string): Promise {\n await ensureTable();\n const result = await sqlite.execute({\n sql: `SELECT value FROM ${TABLE} WHERE key = ?`,\n args: [key],\n });\n if (result.rows.length === 0) return null;\n return safeParse(result.rows[0][0] as string);\n },\n\n async set(key: string, value: unknown, dueAt?: number): Promise {\n await ensureTable();\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO ${TABLE} (key, value, due_at) VALUES (?, ?, ?)`,\n args: [key, JSON.stringify(value), dueAt ?? null],\n });\n },\n\n async delete(key: string): Promise {\n await ensureTable();\n await sqlite.execute({\n sql: `DELETE FROM ${TABLE} WHERE key = ?`,\n args: [key],\n });\n },\n\n /**\n * Atomically delete a key and return whether it actually existed.\n * Only one concurrent caller can \"win\" the delete — use this as a\n * claim mechanism so overlapping cron runs don't double-process items.\n */\n async claimDelete(key: string): Promise {\n await ensureTable();\n const result = await sqlite.execute({\n sql: `DELETE FROM ${TABLE} WHERE key = ?`,\n args: [key],\n });\n return result.rowsAffected > 0;\n },\n\n async list(prefix?: string): Promise> {\n await ensureTable();\n const result = prefix\n ? await sqlite.execute({\n sql: `SELECT key, value FROM ${TABLE} WHERE key LIKE ? ESCAPE '\\\\'`,\n args: [`${escapeLikePrefix(prefix)}%`],\n })\n : await sqlite.execute(`SELECT key, value FROM ${TABLE}`);\n const entries: Array<{ key: string; value: unknown }> = [];\n for (const row of result.rows) {\n const parsed = safeParse(row[1] as string);\n if (parsed !== null) {\n entries.push({ key: row[0] as string, value: parsed });\n }\n }\n return entries;\n },\n\n /**\n * List entries whose `due_at` is at or before the given timestamp.\n * Uses the indexed due_at column — much faster than list() + JS filter.\n * Optionally filtered by key prefix.\n */\n async listDue(now: number, prefix?: string): Promise> {\n await ensureTable();\n const result = prefix\n ? await sqlite.execute({\n sql: `SELECT key, value FROM ${TABLE} WHERE due_at IS NOT NULL AND due_at <= ? AND key LIKE ? ESCAPE '\\\\'`,\n args: [now, `${escapeLikePrefix(prefix)}%`],\n })\n : await sqlite.execute({\n sql: `SELECT key, value FROM ${TABLE} WHERE due_at IS NOT NULL AND due_at <= ?`,\n args: [now],\n });\n const entries: Array<{ key: string; value: unknown }> = [];\n for (const row of result.rows) {\n const parsed = safeParse(row[1] as string);\n if (parsed !== null) {\n entries.push({ key: row[0] as string, value: parsed });\n }\n }\n return entries;\n },\n\n /**\n * Atomic read-modify-write. Reads the current value, passes it to `fn`,\n * and writes the result back. Retries up to `maxRetries` times on conflict\n * (value changed between read and write).\n */\n async update(key: string, fn: (current: T | null) => T, maxRetries = 3): Promise {\n await ensureTable();\n for (let attempt = 0; attempt <= maxRetries; attempt++) {\n const result = await sqlite.execute({\n sql: `SELECT value FROM ${TABLE} WHERE key = ?`,\n args: [key],\n });\n const oldRaw = result.rows.length > 0 ? (result.rows[0][0] as string) : null;\n const current = oldRaw !== null ? safeParse(oldRaw) : null;\n const next = fn(current);\n const nextRaw = JSON.stringify(next);\n\n // Optimistic concurrency: only write if the value hasn't changed since we read it\n const writeResult = oldRaw !== null\n ? await sqlite.execute({\n sql: `UPDATE ${TABLE} SET value = ? WHERE key = ? AND value = ?`,\n args: [nextRaw, key, oldRaw],\n })\n : await sqlite.execute({\n sql: `INSERT OR IGNORE INTO ${TABLE} (key, value) VALUES (?, ?)`,\n args: [key, nextRaw],\n });\n\n if (writeResult.rowsAffected > 0) return next;\n }\n // Final fallback: unconditional write (better than losing the operation)\n const result = await sqlite.execute({\n sql: `SELECT value, due_at FROM ${TABLE} WHERE key = ?`,\n args: [key],\n });\n const raw = result.rows.length > 0 ? (result.rows[0][0] as string) : null;\n const existingDueAt = result.rows.length > 0 ? (result.rows[0][1] as number | null) : null;\n const current = raw !== null ? safeParse(raw) : null;\n const next = fn(current);\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO ${TABLE} (key, value, due_at) VALUES (?, ?, ?)`,\n args: [key, JSON.stringify(next), existingDueAt ?? null],\n });\n return next;\n },\n};\n\nexport const _internals = { safeParse, escapeLikePrefix };\n","deleted","label",[178,179,159],"discord","persistence","permalink","https://www.val.town/x/catalloc/catnip/code/discord/persistence/kv.ts","extension","actionData","errors"]