[{"_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","7721b06a805a6662fde743a1ec849364175efb5b","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,"_157":158,"_180":181,"_182":-5},"handle","colel","name","rust-nyc-talk-submissions","path","backend/autothread/store.ts","project",{"_103":104,"_97":98,"_105":106,"_107":-5,"_108":20,"_109":110,"_111":112,"_113":114,"_12":115,"_116":117,"_118":119,"_120":119,"_121":-5,"_122":33,"_14":123,"_124":-5,"_125":-5,"_126":127,"_128":127,"_129":130,"_131":130,"_132":130,"_133":127,"_134":127,"_23":135,"_138":139,"_143":144,"_156":20},"id","240b2d8a-4b86-11f0-94fc-76b3cceeab13","createdAt",["D",1750169995086],"deletedAt","legacyEnvVars","privacy","public","description","https://github.com/colelawrence/rust-nyc-talk-submissions","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/40c3f457-a412-4e39-8a41-e53f83b5a100/square512","c821e8f7-4cc4-4c23-96f1-319b8f33d4b7","pinnedFileId","1a35e418-5107-11f0-8713-f69ea79377d9","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","6b193d60-e165-45a9-869c-c3f886455f3e","tursoName","tursoHostname","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_95":96,"_136":137},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJ6RVZCOExVNXBIT3FrVDh5a0VZQTNRRG5ycCJ9","org",{"_95":96,"_140":137,"_12":115,"_141":142},"avatar","tier","pro","branch",{"_145":146,"_97":45,"_103":147,"_148":104,"_149":-5,"_150":-5,"_151":-5,"_152":-5,"_153":-5,"_154":98,"_155":96},"version",176,"240b9f7c-4b86-11f0-94fc-76b3cceeab13","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_103":159,"_97":160,"_161":162,"_163":164,"_165":147,"_166":167,"_168":119,"_105":169,"_145":170,"_171":172,"_173":174,"_175":20,"_176":-5,"_99":177},"03c72b42-05d4-11f1-86b4-42dde27851f2","store.ts","fileId","6e8bc98e-fd3b-11f0-b5ff-42dde27851f2","parentId","6e3fdb3c-fd3b-11f0-94eb-42dde27851f2","branchId","branchVersion",166,"latest",["D",1770654357964],3,"fileType","script","content","/**\n * Autothread Store\n *\n * Database operations for the autothread system with namespace support.\n */\n\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport type { Namespace, TableNames, RunEvent } from \"./types.ts\";\nimport { getTableNames } from \"./types.ts\";\n\nfunction toSqliteTimestamp(date: Date): string {\n // Matches SQLite CURRENT_TIMESTAMP format: \"YYYY-MM-DD HH:MM:SS\" (UTC)\n return date.toISOString().replace(\"T\", \" \").replace(/\\.\\d{3}Z$/, \"\");\n}\n\nexport class AutothreadStore {\n public readonly tables: TableNames;\n\n constructor(public readonly namespace: Namespace) {\n this.tables = getTableNames(namespace);\n }\n\n async initTables(): Promise {\n console.log(\n `💾 [Autothread:${this.namespace}] Initializing database tables`,\n );\n\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ${this.tables.channels} (\n channel_id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n topic TEXT,\n last_message_id TEXT,\n last_seen_at DATETIME DEFAULT CURRENT_TIMESTAMP\n )`);\n\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ${this.tables.processed} (\n channel_id TEXT NOT NULL,\n message_id TEXT NOT NULL,\n thread_id TEXT,\n status TEXT NOT NULL,\n error TEXT,\n processed_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n PRIMARY KEY (channel_id, message_id)\n )`);\n\n // Composite index for cooldown check query (channel_id, status, processed_at)\n await sqlite.execute(\n `CREATE INDEX IF NOT EXISTS idx_${this.tables.processed}_cooldown\n ON ${this.tables.processed} (channel_id, status, processed_at)`,\n );\n\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ${this.tables.stats} (\n channel_id TEXT NOT NULL,\n date TEXT NOT NULL,\n threads_created INTEGER DEFAULT 0,\n last_thread_at DATETIME,\n PRIMARY KEY (channel_id, date)\n )`);\n\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ${this.tables.runs} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n started_at DATETIME NOT NULL,\n ended_at DATETIME,\n status TEXT NOT NULL,\n mode TEXT,\n iterations INTEGER DEFAULT 0,\n threads_created INTEGER DEFAULT 0,\n error_count INTEGER DEFAULT 0,\n last_error TEXT\n )`);\n\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ${this.tables.events} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n run_id INTEGER,\n ts DATETIME DEFAULT CURRENT_TIMESTAMP,\n level TEXT NOT NULL,\n event TEXT NOT NULL,\n channel_id TEXT,\n message_id TEXT,\n details_json TEXT\n )`);\n\n console.log(`✅ [Autothread:${this.namespace}] Database tables ready`);\n }\n\n // Run tracking\n async startRun(mode: string): Promise {\n const result = await sqlite.execute(\n `INSERT INTO ${this.tables.runs} (started_at, status, mode) VALUES (CURRENT_TIMESTAMP, 'running', ?)`,\n [mode],\n );\n return result.lastInsertRowid!;\n }\n\n async endRun(\n runId: bigint,\n status: string,\n iterations: number,\n threadsCreated: number,\n errorCount: number,\n lastError: string | null,\n ): Promise {\n await sqlite.execute(\n `UPDATE ${this.tables.runs} SET\n ended_at = CURRENT_TIMESTAMP,\n status = ?,\n iterations = ?,\n threads_created = ?,\n error_count = ?,\n last_error = ?\n WHERE id = ?`,\n [status, iterations, threadsCreated, errorCount, lastError, runId.toString()],\n );\n }\n\n async getLastRun(): Promise | null> {\n const result = await sqlite.execute(\n `SELECT * FROM ${this.tables.runs} ORDER BY id DESC LIMIT 1`,\n );\n return (result.rows[0] as Record) ?? null;\n }\n\n async getRuns(limit = 10): Promise[]> {\n const result = await sqlite.execute(\n `SELECT * FROM ${this.tables.runs} ORDER BY id DESC LIMIT ?`,\n [limit],\n );\n return result.rows as Record[];\n }\n\n // Event logging\n async logEvent(runId: bigint | null, event: RunEvent): Promise {\n await sqlite.execute(\n `INSERT INTO ${this.tables.events} (run_id, ts, level, event, channel_id, message_id, details_json)\n VALUES (?, ?, ?, ?, ?, ?, ?)`,\n [\n runId ? runId.toString() : null,\n event.timestamp,\n event.level,\n event.event,\n event.channelId ?? null,\n event.messageId ?? null,\n event.details ? JSON.stringify(event.details) : null,\n ],\n );\n }\n\n async getRunEvents(runId: bigint): Promise[]> {\n const result = await sqlite.execute(\n `SELECT * FROM ${this.tables.events} WHERE run_id = ? ORDER BY id`,\n [runId.toString()],\n );\n return result.rows as Record[];\n }\n\n // Channel state\n async getLastMessageId(channelId: string): Promise {\n const result = await sqlite.execute(\n `SELECT last_message_id FROM ${this.tables.channels} WHERE channel_id = ?`,\n [channelId],\n );\n if (result.rows.length === 0) return null;\n const row = result.rows[0] as unknown as {\n last_message_id?: string | null;\n };\n return row.last_message_id ?? null;\n }\n\n async updateChannelState(\n channelId: string,\n name: string,\n topic: string | null,\n lastMessageId?: string,\n ): Promise {\n await sqlite.execute(\n `INSERT INTO ${this.tables.channels} (channel_id, name, topic, last_message_id, last_seen_at)\n VALUES (?, ?, ?, ?, CURRENT_TIMESTAMP)\n ON CONFLICT(channel_id) DO UPDATE SET\n name = excluded.name,\n topic = excluded.topic,\n last_message_id = COALESCE(excluded.last_message_id, last_message_id),\n last_seen_at = CURRENT_TIMESTAMP`,\n [channelId, name, topic, lastMessageId ?? null],\n );\n }\n\n async resetChannelCursor(\n channelId: string,\n lastMessageId: string | null,\n ): Promise {\n await sqlite.execute(\n `UPDATE ${this.tables.channels} SET last_message_id = ? WHERE channel_id = ?`,\n [lastMessageId, channelId],\n );\n }\n\n // Message processing\n async tryClaimMessage(\n channelId: string,\n messageId: string,\n status: \"dry_run\" | \"processing\" | \"skipped\" | \"planned\",\n ): Promise {\n try {\n await sqlite.execute(\n `INSERT INTO ${this.tables.processed} (channel_id, message_id, status)\n VALUES (?, ?, ?)`,\n [channelId, messageId, status],\n );\n return true;\n } catch (err) {\n if (\n err instanceof Error &&\n err.message.includes(\"UNIQUE constraint failed\")\n ) {\n return false;\n }\n throw err;\n }\n }\n\n async updateMessageStatus(\n channelId: string,\n messageId: string,\n status: \"created\" | \"error\",\n threadId?: string,\n error?: string,\n ): Promise {\n await sqlite.execute(\n `UPDATE ${this.tables.processed}\n SET status = ?, thread_id = ?, error = ?, processed_at = CURRENT_TIMESTAMP\n WHERE channel_id = ? AND message_id = ?`,\n [status, threadId ?? null, error ?? null, channelId, messageId],\n );\n }\n\n async isMessageProcessed(\n channelId: string,\n messageId: string,\n ): Promise {\n const result = await sqlite.execute(\n `SELECT 1 FROM ${this.tables.processed} WHERE channel_id = ? AND message_id = ?`,\n [channelId, messageId],\n );\n return result.rows.length > 0;\n }\n\n // Cooldown\n async isChannelOnCooldown(\n channelId: string,\n windowMs: number,\n maxThreads: number,\n ): Promise {\n const cutoff = toSqliteTimestamp(new Date(Date.now() - windowMs));\n const result = await sqlite.execute(\n `SELECT COUNT(*) as count FROM ${this.tables.processed}\n WHERE channel_id = ? AND status = 'created' AND processed_at > ?`,\n [channelId, cutoff],\n );\n const row = result.rows[0] as unknown as {\n count?: number | string | bigint;\n };\n const count = Number(row.count ?? 0);\n return count >= maxThreads;\n }\n\n // Stats\n async recordThreadCreated(channelId: string): Promise {\n const today = new Date().toISOString().slice(0, 10);\n await sqlite.execute(\n `INSERT INTO ${this.tables.stats} (channel_id, date, threads_created, last_thread_at)\n VALUES (?, ?, 1, CURRENT_TIMESTAMP)\n ON CONFLICT(channel_id, date) DO UPDATE SET\n threads_created = threads_created + 1,\n last_thread_at = CURRENT_TIMESTAMP`,\n [channelId, today],\n );\n }\n\n async getTodayStats(): Promise[]> {\n const today = new Date().toISOString().slice(0, 10);\n const result = await sqlite.execute(\n `SELECT channel_id, threads_created, last_thread_at\n FROM ${this.tables.stats} WHERE date = ?\n ORDER BY threads_created DESC`,\n [today],\n );\n return result.rows as Record[];\n }\n\n // Debug/reset operations\n async getState(): Promise<{\n channels: Record[];\n recentProcessed: Record[];\n todayStats: Record[];\n }> {\n const channels = await sqlite.execute(\n `SELECT * FROM ${this.tables.channels} ORDER BY last_seen_at DESC LIMIT 20`,\n );\n const processed = await sqlite.execute(\n `SELECT * FROM ${this.tables.processed} ORDER BY processed_at DESC LIMIT 50`,\n );\n const stats = await this.getTodayStats();\n return {\n channels: channels.rows as Record[],\n recentProcessed: processed.rows as Record[],\n todayStats: stats,\n };\n }\n\n async clearProcessed(\n channelId?: string,\n beforeDate?: string,\n status?: string,\n ): Promise {\n let sql = `DELETE FROM ${this.tables.processed} WHERE 1=1`;\n const args: (string | null)[] = [];\n\n if (channelId) {\n sql += ` AND channel_id = ?`;\n args.push(channelId);\n }\n if (beforeDate) {\n sql += ` AND processed_at < ?`;\n args.push(beforeDate);\n }\n if (status) {\n sql += ` AND status = ?`;\n args.push(status);\n }\n\n const result = await sqlite.execute(sql, args);\n return result.rowsAffected;\n }\n\n async resetAll(): Promise {\n await sqlite.execute(`DELETE FROM ${this.tables.processed}`);\n await sqlite.execute(`DELETE FROM ${this.tables.channels}`);\n await sqlite.execute(`DELETE FROM ${this.tables.stats}`);\n await sqlite.execute(`DELETE FROM ${this.tables.runs}`);\n await sqlite.execute(`DELETE FROM ${this.tables.events}`);\n }\n}\n","deleted","label",[178,179,160],"backend","autothread","permalink","https://www.val.town/x/colel/rust-nyc-talk-submissions/code/backend/autothread/store.ts","extension","actionData","errors"]