Telegram Video Transcription Bot

Send a video URL (YouTube, TikTok, Instagram, X/Twitter, Facebook) to get a transcript.

`,\n { status: 200, headers: { \"content-type\": \"text/html\" } },\n );\n};\n",[198],"ba4ddd34-34f5-11f1-bf65-42b51c65c3df","delete-webhook.ts","ba4dde06-34f5-11f1-bf65-42b51c65c3df",27,["D",1775836542240],"const token = Deno.env.get(\"TELEGRAM_TOKEN\")!;\nconst res = await fetch(`https://api.telegram.org/bot${token}/deleteWebhook?drop_pending_updates=true`);\nconsole.log(await res.json());\n",[206],"07f6c0dc-34f6-11f1-97aa-42b51c65c3df","debug-poll.ts","07f6c190-34f6-11f1-97aa-42b51c65c3df",28,["D",1775836672529],"import { blob } from \"https://esm.town/v/std/blob\";\n\nconst TOKEN = Deno.env.get(\"TELEGRAM_TOKEN\")!;\nconst OFFSET_KEY = \"telegram_bot_offset\";\n\nconst offset: number = (await blob.getJSON(OFFSET_KEY)) ?? 0;\nconsole.log(\"Stored offset:\", offset);\n\n// Short timeout so this completes quickly\nconst params = new URLSearchParams({ timeout: \"5\", limit: \"10\" });\nif (offset > 0) params.set(\"offset\", String(offset));\n\nconsole.log(\"Calling getUpdates with params:\", params.toString());\nconst res = await fetch(`https://api.telegram.org/bot${TOKEN}/getUpdates?${params}`);\nconst data = await res.json();\nconsole.log(\"Response:\", JSON.stringify(data, null, 2));\n",[213],"6d11a686-3667-11f1-aee9-42b51c65c3df","claude.ts","12b8c2a0-34f0-11f1-a6be-42b51c65c3df",94,["D",1775995326448],16,"import { ChatAnthropic } from \"npm:@langchain/anthropic\";\nimport { createReactAgent } from \"npm:@langchain/langgraph/prebuilt\";\nimport { tool } from \"npm:@langchain/core/tools\";\nimport { HumanMessage } from \"npm:@langchain/core/messages\";\nimport { z } from \"npm:zod\";\nimport ValTown from \"npm:@valtown/sdk\";\nimport { CallbackHandler } from \"npm:langfuse-langchain\";\nimport { ValTownSqliteSaver } from \"./checkpointer.ts\";\n\nconst vt = new ValTown({ bearerToken: Deno.env.get(\"VALTOWN_API_KEY\")! });\n\n// ── Tools ──────────────────────────────────────────────────────────────────\n\nconst listValsTool = tool(\n async ({ limit, offset }) => {\n const result: unknown[] = [];\n for await (const val of vt.me.vals.list({ limit: limit || 20, offset: offset || 0 })) {\n result.push(val);\n }\n return JSON.stringify(result, null, 2);\n },\n {\n name: \"list_vals\",\n description: \"List the user's vals (projects). Returns name, id, privacy, description.\",\n schema: z.object({\n limit: z.number().optional().describe(\"Max vals to return (default 20)\"),\n offset: z.number().optional().describe(\"Pagination offset\"),\n }),\n },\n);\n\nconst getValTool = tool(\n async ({ username, val_name }) => {\n const val = await vt.alias.username.valName.retrieve(val_name, { username });\n return JSON.stringify(val, null, 2);\n },\n {\n name: \"get_val\",\n description: \"Get details about a val by handle/valName identifier.\",\n schema: z.object({\n username: z.string().describe(\"The user's handle (e.g. 'cricks_unmixed4u')\"),\n val_name: z.string().describe(\"The val name\"),\n }),\n },\n);\n\nconst listFilesTool = tool(\n async ({ val_id, path, branch_id, recursive }) => {\n const params: Record = {};\n if (path) params.path = path;\n if (branch_id) params.branch_id = branch_id;\n if (recursive) params.recursive = recursive;\n const result: unknown[] = [];\n for await (const file of vt.vals.files.retrieve(val_id, params as any)) {\n result.push(file);\n }\n return JSON.stringify(result, null, 2);\n },\n {\n name: \"list_files\",\n description: \"List files in a val. Requires val_id and optionally a branch_id and path.\",\n schema: z.object({\n val_id: z.string().describe(\"The val UUID\"),\n path: z.string().optional().describe(\"Directory path to list (optional)\"),\n branch_id: z.string().optional().describe(\"Branch UUID (optional, defaults to main)\"),\n recursive: z.boolean().optional().describe(\"List recursively (optional)\"),\n }),\n },\n);\n\nconst readFileTool = tool(\n async ({ val_id, path, branch_id }) => {\n const params: Record = { path };\n if (branch_id) params.branch_id = branch_id;\n const resp = await vt.vals.files.getContent(val_id, params as any);\n return await resp.text();\n },\n {\n name: \"read_file\",\n description: \"Read the content of a file in a val.\",\n schema: z.object({\n val_id: z.string().describe(\"The val UUID\"),\n path: z.string().describe(\"File path (e.g. 'index.ts')\"),\n branch_id: z.string().optional().describe(\"Branch UUID (optional)\"),\n }),\n },\n);\n\nconst updateFileTool = tool(\n async ({ val_id, path, content, branch_id }) => {\n const params: Record = {\n path,\n content,\n };\n if (branch_id) params.branch_id = branch_id;\n const result = await vt.vals.files.update(val_id, params as any);\n return JSON.stringify(result, null, 2);\n },\n {\n name: \"update_file\",\n description: \"Update (write) a file's content in a val.\",\n schema: z.object({\n val_id: z.string().describe(\"The val UUID\"),\n path: z.string().describe(\"File path\"),\n content: z.string().describe(\"New file content\"),\n branch_id: z.string().optional().describe(\"Branch UUID (optional)\"),\n }),\n },\n);\n\nconst createFileTool = tool(\n async ({ val_id, path, content, type, branch_id }) => {\n const params: Record = {\n path,\n };\n if (content) params.content = content;\n if (type) params.type = type;\n if (branch_id) params.branch_id = branch_id;\n const result = await vt.vals.files.create(val_id, params as any);\n return JSON.stringify(result, null, 2);\n },\n {\n name: \"create_file\",\n description: \"Create a new file in a val.\",\n schema: z.object({\n val_id: z.string().describe(\"The val UUID\"),\n path: z.string().describe(\"File path (e.g. 'utils/helper.ts')\"),\n content: z.string().optional().describe(\"File content\"),\n type: z.enum([\"script\", \"http\", \"interval\", \"email\", \"file\"]).optional().describe(\"File type (default: script)\"),\n branch_id: z.string().optional().describe(\"Branch UUID (optional)\"),\n }),\n },\n);\n\nconst sqliteExecuteTool = tool(\n async ({ sql, args }) => {\n const result = await vt.sqlite.execute({\n statement: { sql, args: args || [] },\n });\n return JSON.stringify(result, null, 2);\n },\n {\n name: \"sqlite_execute\",\n description: \"Execute a SQL query against the user's SQLite database.\",\n schema: z.object({\n sql: z.string().describe(\"SQL statement\"),\n args: z.array(z.union([z.string(), z.number(), z.boolean(), z.null()])).optional().describe(\"Positional arguments for the query\"),\n }),\n },\n);\n\nconst listBlobsTool = tool(\n async ({ prefix }) => {\n const result = await vt.blobs.list({ prefix: prefix || undefined });\n return JSON.stringify(result, null, 2);\n },\n {\n name: \"list_blobs\",\n description: \"List blobs in the user's blob storage. Optionally filter by prefix.\",\n schema: z.object({\n prefix: z.string().optional().describe(\"Key prefix filter (optional)\"),\n }),\n },\n);\n\nconst tools = [listValsTool, getValTool, listFilesTool, readFileTool, updateFileTool, createFileTool, sqliteExecuteTool, listBlobsTool];\n\n// ── Agent setup ────────────────────────────────────────────────────────────\n\nconst SYSTEM_PROMPT = `You are a helpful assistant with access to the user's Val Town account.\nYou can list their vals, read/write files, run SQL queries, and manage blobs.\nBe concise. When showing code, use markdown code blocks.\nThe user's handle is \"cricks_unmixed4u\".`;\n\nconst llm = new ChatAnthropic({\n model: \"claude-haiku-4-5-20251001\",\n apiKey: Deno.env.get(\"ANTHROPIC_API_KEY\")!,\n maxTokens: 4096,\n});\n\nexport const checkpointer = new ValTownSqliteSaver();\n\nconst agent = createReactAgent({\n llm,\n tools,\n checkpointer,\n stateModifier: SYSTEM_PROMPT,\n});\n\n// ── Public API ─────────────────────────────────────────────────────────────\n\nexport async function askClaude(chatId: number, userMessage: string): Promise {\n try {\n const langfuseHandler = new CallbackHandler({\n publicKey: Deno.env.get(\"LANGFUSE_PUBLIC_KEY\"),\n secretKey: Deno.env.get(\"LANGFUSE_SECRET_KEY\"),\n baseUrl: Deno.env.get(\"LANGFUSE_BASE_URL\"),\n userId: String(chatId),\n });\n\n const finalState = await agent.invoke(\n { messages: [new HumanMessage(userMessage)] },\n {\n configurable: { thread_id: String(chatId) },\n recursionLimit: 25,\n callbacks: [langfuseHandler],\n },\n );\n\n await langfuseHandler.shutdownAsync();\n\n const last = finalState.messages[finalState.messages.length - 1];\n const content = last.content;\n\n if (typeof content === \"string\") {\n return content || \"(No response from Claude)\";\n }\n\n // Handle content blocks\n return (content as Array<{ type: string; text?: string }>)\n .filter((b) => b.type === \"text\")\n .map((b) => b.text ?? \"\")\n .join(\"\\n\") || \"(No response from Claude)\";\n } catch (err) {\n throw new Error(`Claude invocation failed: ${(err as Error).message}`);\n }\n}\n\nexport async function resetClaudeThread(chatId: number): Promise {\n await checkpointer.deleteThread(String(chatId));\n}\n",[220],"3de15244-363a-11f1-b9fe-42b51c65c3df","checkpointer.ts","beaca7d0-3639-11f1-a852-42b51c65c3df",64,["D",1775975919926],3,"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport {\n BaseCheckpointSaver,\n type Checkpoint,\n type CheckpointMetadata,\n type CheckpointTuple,\n type CheckpointListOptions,\n type PendingWrite,\n type ChannelVersions,\n} from \"npm:@langchain/langgraph-checkpoint\";\nimport type { RunnableConfig } from \"npm:@langchain/core/runnables\";\n\nexport class ValTownSqliteSaver extends BaseCheckpointSaver {\n private initialized = false;\n\n private async ensureTables() {\n if (this.initialized) return;\n await sqlite.batch([\n `CREATE TABLE IF NOT EXISTS checkpoints (\n thread_id TEXT NOT NULL,\n checkpoint_ns TEXT NOT NULL DEFAULT '',\n checkpoint_id TEXT NOT NULL,\n parent_checkpoint_id TEXT,\n type TEXT,\n checkpoint BLOB,\n metadata BLOB,\n PRIMARY KEY (thread_id, checkpoint_ns, checkpoint_id)\n )`,\n `CREATE TABLE IF NOT EXISTS writes (\n thread_id TEXT NOT NULL,\n checkpoint_ns TEXT NOT NULL DEFAULT '',\n checkpoint_id TEXT NOT NULL,\n task_id TEXT NOT NULL,\n idx INTEGER NOT NULL,\n channel TEXT NOT NULL,\n type TEXT,\n value BLOB,\n PRIMARY KEY (thread_id, checkpoint_ns, checkpoint_id, task_id, idx)\n )`,\n ]);\n this.initialized = true;\n }\n\n async getTuple(config: RunnableConfig): Promise {\n await this.ensureTables();\n\n const threadId = config.configurable?.thread_id as string | undefined;\n const checkpointNs = config.configurable?.checkpoint_ns as string || \"\";\n const checkpointId = config.configurable?.checkpoint_id as string | undefined;\n\n if (!threadId) return undefined;\n\n let checkpointQuery = `\n SELECT thread_id, checkpoint_ns, checkpoint_id, parent_checkpoint_id, type, checkpoint, metadata\n FROM checkpoints\n WHERE thread_id = ? AND checkpoint_ns = ?\n `;\n const checkpointArgs: (string | number)[] = [threadId, checkpointNs];\n\n if (checkpointId) {\n checkpointQuery += ` AND checkpoint_id = ?`;\n checkpointArgs.push(checkpointId);\n } else {\n checkpointQuery += ` ORDER BY checkpoint_id DESC LIMIT 1`;\n }\n\n const { rows } = await sqlite.execute({\n sql: checkpointQuery,\n args: checkpointArgs,\n });\n\n if (!rows || rows.length === 0) return undefined;\n\n const row = rows[0] as any;\n const cpId = row.checkpoint_id as string;\n\n const { rows: writeRows } = await sqlite.execute({\n sql: `\n SELECT task_id, idx, channel, type, value\n FROM writes\n WHERE thread_id = ? AND checkpoint_ns = ? AND checkpoint_id = ?\n ORDER BY task_id, idx\n `,\n args: [threadId, checkpointNs, cpId],\n });\n\n // serde.loadsTyped is async\n const checkpoint = row.checkpoint\n ? await this.serde.loadsTyped(row.type as string, new Uint8Array(row.checkpoint as ArrayBuffer))\n : null;\n const metadata = row.metadata\n ? await this.serde.loadsTyped(row.type as string, new Uint8Array(row.metadata as ArrayBuffer))\n : {};\n\n const pendingWrites: PendingWrite[] = [];\n for (const writeRow of (writeRows ?? []) as any[]) {\n const value = writeRow.value\n ? await this.serde.loadsTyped(writeRow.type as string, new Uint8Array(writeRow.value as ArrayBuffer))\n : null;\n pendingWrites.push([writeRow.task_id, writeRow.channel, value] as unknown as PendingWrite);\n }\n\n return {\n config: {\n configurable: {\n thread_id: threadId,\n checkpoint_ns: checkpointNs,\n checkpoint_id: cpId,\n },\n },\n checkpoint: checkpoint as Checkpoint,\n metadata: metadata as CheckpointMetadata,\n parentConfig: row.parent_checkpoint_id\n ? {\n configurable: {\n thread_id: threadId,\n checkpoint_ns: checkpointNs,\n checkpoint_id: row.parent_checkpoint_id as string,\n },\n }\n : undefined,\n pendingWrites,\n };\n }\n\n async *list(\n config: RunnableConfig,\n options?: CheckpointListOptions,\n ): AsyncGenerator {\n await this.ensureTables();\n\n const threadId = config.configurable?.thread_id as string | undefined;\n const checkpointNs = config.configurable?.checkpoint_ns as string || \"\";\n const beforeId = options?.before?.configurable?.checkpoint_id as string | undefined;\n\n if (!threadId) return;\n\n let query = `\n SELECT thread_id, checkpoint_ns, checkpoint_id, parent_checkpoint_id, type, checkpoint, metadata\n FROM checkpoints\n WHERE thread_id = ? AND checkpoint_ns = ?\n `;\n const args: (string | number)[] = [threadId, checkpointNs];\n\n if (beforeId) {\n query += ` AND checkpoint_id < ?`;\n args.push(beforeId);\n }\n\n query += ` ORDER BY checkpoint_id DESC`;\n\n if (options?.limit) {\n query += ` LIMIT ?`;\n args.push(options.limit);\n }\n\n const { rows } = await sqlite.execute({ sql: query, args });\n\n if (!rows) return;\n\n for (const row of rows as any[]) {\n const cpId = row.checkpoint_id as string;\n\n const { rows: writeRows } = await sqlite.execute({\n sql: `\n SELECT task_id, idx, channel, type, value\n FROM writes\n WHERE thread_id = ? AND checkpoint_ns = ? AND checkpoint_id = ?\n ORDER BY task_id, idx\n `,\n args: [threadId, checkpointNs, cpId],\n });\n\n const checkpoint = row.checkpoint\n ? await this.serde.loadsTyped(row.type as string, new Uint8Array(row.checkpoint as ArrayBuffer))\n : null;\n const metadata = row.metadata\n ? await this.serde.loadsTyped(row.type as string, new Uint8Array(row.metadata as ArrayBuffer))\n : {};\n\n const pendingWrites: PendingWrite[] = [];\n for (const writeRow of (writeRows ?? []) as any[]) {\n const value = writeRow.value\n ? await this.serde.loadsTyped(writeRow.type as string, new Uint8Array(writeRow.value as ArrayBuffer))\n : null;\n pendingWrites.push([writeRow.channel, value] as unknown as PendingWrite);\n }\n\n yield {\n config: {\n configurable: {\n thread_id: threadId,\n checkpoint_ns: checkpointNs,\n checkpoint_id: cpId,\n },\n },\n checkpoint: checkpoint as Checkpoint,\n metadata: metadata as CheckpointMetadata,\n parentConfig: row.parent_checkpoint_id\n ? {\n configurable: {\n thread_id: threadId,\n checkpoint_ns: checkpointNs,\n checkpoint_id: row.parent_checkpoint_id as string,\n },\n }\n : undefined,\n pendingWrites,\n };\n }\n }\n\n async put(\n config: RunnableConfig,\n checkpoint: Checkpoint,\n metadata: CheckpointMetadata,\n _newVersions: ChannelVersions,\n ): Promise {\n await this.ensureTables();\n\n const threadId = config.configurable?.thread_id as string | undefined;\n const checkpointNs = config.configurable?.checkpoint_ns as string || \"\";\n // current config.configurable.checkpoint_id is the PARENT; checkpoint.id is the NEW id\n const parentId = config.configurable?.checkpoint_id as string | undefined;\n const newCheckpointId = checkpoint.id;\n\n if (!threadId) throw new Error(\"thread_id is required in config.configurable\");\n\n // serde.dumpsTyped is async\n const [cpType, cpData] = await this.serde.dumpsTyped(checkpoint);\n const [, metaData] = await this.serde.dumpsTyped(metadata);\n\n await sqlite.execute({\n sql: `\n INSERT OR REPLACE INTO checkpoints\n (thread_id, checkpoint_ns, checkpoint_id, parent_checkpoint_id, type, checkpoint, metadata)\n VALUES (?, ?, ?, ?, ?, ?, ?)\n `,\n args: [threadId, checkpointNs, newCheckpointId, parentId ?? null, cpType, cpData, metaData],\n });\n\n return {\n configurable: {\n thread_id: threadId,\n checkpoint_ns: checkpointNs,\n checkpoint_id: newCheckpointId,\n },\n };\n }\n\n async putWrites(\n config: RunnableConfig,\n writes: PendingWrite[],\n taskId: string,\n ): Promise {\n await this.ensureTables();\n\n const threadId = config.configurable?.thread_id as string | undefined;\n const checkpointNs = config.configurable?.checkpoint_ns as string || \"\";\n const checkpointId = config.configurable?.checkpoint_id as string | undefined;\n\n if (!threadId || !checkpointId) {\n throw new Error(\"thread_id and checkpoint_id are required in config.configurable\");\n }\n\n if (writes.length === 0) return;\n\n // Serialize all writes first (async, so can't use sync .map)\n const statements = [];\n for (let idx = 0; idx < writes.length; idx++) {\n const write = writes[idx] as unknown as [string, unknown];\n const channel = write[0];\n const value = write[1];\n const [valueType, valueData] = await this.serde.dumpsTyped(value);\n statements.push({\n sql: `\n INSERT OR REPLACE INTO writes\n (thread_id, checkpoint_ns, checkpoint_id, task_id, idx, channel, type, value)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)\n `,\n args: [threadId, checkpointNs, checkpointId, taskId, idx, channel, valueType, valueData],\n });\n }\n\n await sqlite.batch(statements);\n }\n\n async deleteThread(threadId: string): Promise {\n await this.ensureTables();\n\n await sqlite.batch([\n { sql: `DELETE FROM checkpoints WHERE thread_id = ?`, args: [threadId] },\n { sql: `DELETE FROM writes WHERE thread_id = ?`, args: [threadId] },\n ]);\n }\n}\n",[228],"5d87d4bc-34f3-11f1-81df-42b51c65c3df","check-webhook.ts","5d87d570-34f3-11f1-81df-42b51c65c3df",22,["D",1775835527597],"const token = Deno.env.get(\"TELEGRAM_TOKEN\")!;\nconst res = await fetch(`https://api.telegram.org/bot${token}/getWebhookInfo`);\nconst data = await res.json();\nconsole.log(JSON.stringify(data, null, 2));\n",[236],"beb4cff0-3639-11f1-ac85-42b51c65c3df","bot-poll.ts","5df2da80-34f5-11f1-881c-42b51c65c3df",58,["D",1775975706519],"import { blob } from \"https://esm.town/v/std/blob\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { askClaude } from \"./claude.ts\";\n\nconst TOKEN = Deno.env.get(\"TELEGRAM_TOKEN\")!;\nconst OWNER_ID = Number(Deno.env.get(\"TELEGRAM_USER_ID\")!);\nconst SUPADATA_API_KEY = Deno.env.get(\"SUPADATA_API_KEY\")!;\nconst OFFSET_KEY = \"telegram_bot_offset\";\nconst MAX_LEN = 4000;\n\nconst VIDEO_URL_REGEX =\n /https?:\\/\\/(www\\.)?(youtube\\.com\\/watch|youtu\\.be\\/|tiktok\\.com\\/|instagram\\.com\\/(reel|p)\\/|x\\.com\\/\\w+\\/status\\/|twitter\\.com\\/\\w+\\/status\\/|facebook\\.com\\/(reel|watch|video))[^\\s]*/i;\n\nasync function tg(method: string, body: object) {\n const res = await fetch(`https://api.telegram.org/bot${TOKEN}/${method}`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(body),\n });\n return res.json();\n}\n\nasync function sendMessage(chatId: number, text: string, extra: object = {}) {\n return tg(\"sendMessage\", { chat_id: chatId, text, ...extra });\n}\n\nasync function sendTranscript(chatId: number, transcript: string) {\n if (transcript.length <= MAX_LEN) {\n await sendMessage(chatId, `📝 *Transcript:*\\n\\n${transcript}`, { parse_mode: \"Markdown\" });\n return;\n }\n const chunks: string[] = [];\n for (let i = 0; i < transcript.length; i += MAX_LEN) {\n chunks.push(transcript.slice(i, i + MAX_LEN));\n }\n for (let i = 0; i < chunks.length; i++) {\n await sendMessage(chatId, `📝 *Transcript (part ${i + 1}/${chunks.length}):*\\n\\n${chunks[i]}`, {\n parse_mode: \"Markdown\",\n });\n }\n}\n\nexport default async function (_interval: Interval) {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS transcript_jobs (\n job_id TEXT PRIMARY KEY,\n chat_id INTEGER NOT NULL,\n url TEXT NOT NULL,\n created_at INTEGER NOT NULL\n )\n `);\n\n const offset: number = (await blob.getJSON(OFFSET_KEY)) ?? 0;\n console.log(`[poll] offset=${offset}, calling getUpdates...`);\n\n const params = new URLSearchParams({ timeout: \"25\", limit: \"100\" });\n if (offset > 0) params.set(\"offset\", String(offset));\n\n const res = await fetch(`https://api.telegram.org/bot${TOKEN}/getUpdates?${params}`);\n const data = await res.json();\n\n if (!data.ok) {\n console.error(\"[poll] getUpdates error:\", JSON.stringify(data));\n return;\n }\n\n console.log(`[poll] got ${data.result.length} update(s)`);\n if (!data.result.length) return;\n\n let newOffset = offset;\n\n for (const update of data.result) {\n newOffset = update.update_id + 1;\n\n const msg = update.message;\n if (!msg?.text) continue;\n\n const chatId: number = msg.chat.id;\n const fromId: number = msg.from?.id;\n const text: string = msg.text;\n\n console.log(`[poll] message from ${fromId}: ${text.slice(0, 50)}`);\n\n if (fromId !== OWNER_ID) {\n await sendMessage(chatId, \"⛔ Sorry, this bot is private.\");\n continue;\n }\n\n if (text === \"/start\" || text.startsWith(\"/start \")) {\n await sendMessage(\n chatId,\n \"👋 *Welcome!* Send me a video URL from YouTube, TikTok, Instagram, X/Twitter, or Facebook and I'll fetch the transcript for you!\\n\\nUse /claude to talk to Claude AI with access to your Val Town account. Use /reset to clear your conversation history.\",\n { parse_mode: \"Markdown\" },\n );\n continue;\n }\n\n if (text === \"/reset\") {\n try {\n await (await import(\"./claude.ts\")).resetClaudeThread(chatId);\n await sendMessage(chatId, \"🧹 Cleared your conversation history with Claude.\");\n } catch (err) {\n await sendMessage(chatId, `❌ Reset error: ${(err as Error).message}`);\n }\n continue;\n }\n\n if (text.startsWith(\"/claude\")) {\n const prompt = text.slice(7).trim();\n if (!prompt) {\n await sendMessage(chatId, \"Usage: `/claude `\\n\\nExample: `/claude list my vals`\", {\n parse_mode: \"Markdown\",\n });\n continue;\n }\n await sendMessage(chatId, \"🤖 Thinking…\");\n try {\n const response = await askClaude(chatId, prompt);\n for (let i = 0; i < response.length; i += MAX_LEN) {\n const chunk = response.slice(i, i + MAX_LEN);\n await sendMessage(chatId, chunk, { parse_mode: \"Markdown\" }).catch(() =>\n sendMessage(chatId, chunk)\n );\n }\n } catch (err) {\n await sendMessage(chatId, `❌ Claude error: ${(err as Error).message}`);\n }\n continue;\n }\n\n const match = text.match(VIDEO_URL_REGEX);\n if (!match) {\n await sendMessage(\n chatId,\n \"Please send a video URL (YouTube, TikTok, Instagram, X/Twitter, or Facebook) and I'll transcribe it for you!\",\n );\n continue;\n }\n\n const url = match[0];\n const transcriptRes = await fetch(\n `https://api.supadata.ai/v1/transcript?url=${encodeURIComponent(url)}&text=true`,\n { headers: { \"x-api-key\": SUPADATA_API_KEY } },\n );\n\n if (transcriptRes.status === 200) {\n const transcriptData = await transcriptRes.json();\n await sendTranscript(chatId, transcriptData.content as string);\n } else if (transcriptRes.status === 202) {\n const { jobId } = await transcriptRes.json();\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO transcript_jobs (job_id, chat_id, url, created_at) VALUES (?, ?, ?, ?)`,\n args: [jobId, chatId, url, Date.now()],\n });\n await sendMessage(\n chatId,\n \"⏳ This video is long — transcription is running in the background. I'll send you the result when it's ready (usually a few minutes).\",\n );\n } else {\n const errData = await transcriptRes.json().catch(() => ({}));\n await sendMessage(\n chatId,\n `❌ Could not start transcription: ${errData?.message ?? `HTTP ${transcriptRes.status}`}`,\n );\n }\n }\n\n await blob.setJSON(OFFSET_KEY, newOffset);\n console.log(`[poll] done, new offset=${newOffset}`);\n}\n",[243],"15d8e30a-35bf-11f1-8fde-42b51c65c3df","beeminder-hourly.ts","89cb415a-35be-11f1-bb09-42b51c65c3df",41,["D",1775923024608],"import { Bot } from \"https://deno.land/x/grammy@v1.35.0/mod.ts\";\nimport { getAllBeeminderGoals } from \"https://esm.town/v/cricks_unmixed4u/beeminder-api/main.tsx\";\n\nexport default async function (interval: Interval) {\n // Skip during sleep hours (22:00 – 06:00 Amsterdam time)\n const now = new Date();\n const hour = parseInt(\n new Intl.DateTimeFormat(\"en-US\", {\n timeZone: \"Europe/Amsterdam\",\n hour: \"numeric\",\n hour12: false,\n }).format(now)\n );\n if (hour >= 22 || hour < 6) return;\n\n const telegramToken = Deno.env.get(\"TELEGRAM_TOKEN\");\n const beeminderToken = Deno.env.get(\"BEEMINDER_TOKEN\");\n const userId = Deno.env.get(\"TELEGRAM_USER_ID\");\n\n if (!telegramToken || !beeminderToken || !userId) {\n throw new Error(\n \"Missing required environment variables: TELEGRAM_TOKEN, BEEMINDER_TOKEN, or TELEGRAM_USER_ID\"\n );\n }\n\n const bot = new Bot(telegramToken);\n const goals = await getAllBeeminderGoals(beeminderToken);\n\n // Filter for urgent issues: safe buffer < 1 day, not won or lost\n const urgentGoals = goals\n .filter((goal) => goal.safebuf < 1 && !goal.won && !goal.lost)\n .sort((a, b) => a.safebuf - b.safebuf);\n\n if (urgentGoals.length === 0) return;\n\n const goalLines = urgentGoals.map((goal: any) => {\n return `${goal.slug}: ${goal.limsum}`;\n });\n\n const message = `🚨 URGENT (${urgentGoals.length} goals)\\n\\n${goalLines.join(\"\\n\")}`;\n await bot.api.sendMessage(userId, message);\n\n console.log(`Sent urgent Beeminder update to user ${userId}. ${urgentGoals.length} goals at risk.`);\n}\n",[250],"0808d62a-34ef-11f1-bc56-42b51c65c3df","beeminder-daily.ts","2db0b024-34ee-11f1-af8f-42b51c65c3df",7,["D",1775833666167],5,"import { Bot } from \"https://deno.land/x/grammy@v1.35.0/mod.ts\";\nimport { getAllBeeminderGoals } from \"https://esm.town/v/cricks_unmixed4u/beeminder-api/main.tsx\";\n\nexport default async function (interval: Interval) {\n const telegramToken = Deno.env.get(\"TELEGRAM_TOKEN\");\n const beeminderToken = Deno.env.get(\"BEEMINDER_TOKEN\");\n const userId = Deno.env.get(\"TELEGRAM_USER_ID\");\n\n if (!telegramToken || !beeminderToken || !userId) {\n throw new Error(\n \"Missing required environment variables: TELEGRAM_TOKEN, BEEMINDER_TOKEN, or TELEGRAM_USER_ID\"\n );\n }\n\n const bot = new Bot(telegramToken);\n const goals = await getAllBeeminderGoals(beeminderToken);\n\n // Filter for urgent issues: safe buffer < 1 day, not won or lost\n const urgentGoals = goals\n .filter((goal) => goal.safebuf < 1 && !goal.won && !goal.lost)\n .sort((a, b) => a.safebuf - b.safebuf);\n\n if (urgentGoals.length === 0) {\n await bot.api.sendMessage(userId, \"✅ No urgent Beeminder issues today! All goals are safe.\");\n return;\n }\n\n const goalLines = urgentGoals.map((goal: any) => {\n return `${goal.slug}: ${goal.limsum}`;\n });\n\n const message = `🚨 URGENT TODAY (${urgentGoals.length} goals)\\n\\n${goalLines.join(\"\\n\")}`;\n await bot.api.sendMessage(userId, message);\n\n console.log(`Sent urgent Beeminder update to user ${userId}. ${urgentGoals.length} goals at risk.`);\n}\n",[257],"6e0ce29e-357c-11f1-b0f5-42b51c65c3df",".vscode","6e0ce35c-357c-11f1-b0f5-42b51c65c3df",31,["D",1775894396363],[265],"c5c5fd3a-3672-11f1-8cda-42b51c65c3df",".git","c5c5fe0c-3672-11f1-8cda-42b51c65c3df",97,["D",1776000199737],[271],"6ded3c6e-357c-11f1-b212-42b51c65c3df",".claude","6ded3d2c-357c-11f1-b212-42b51c65c3df",30,["D",1775894396155],[277],"pulls","branches","forks","envVars",{"_289":291,"_292":61},"connections",{"_289":61,"_290":61},"count","unfilledCount",9,"emptyCount",{"_41":276,"_31":277,"_29":278,"_164":-5,"_39":40,"_38":279,"_166":57,"_36":395,"_13":61,"_33":34,"_35":-5,"_23":24,"_171":-5,"_315":396,"_26":397},{"_41":386,"_31":387,"_29":388,"_164":278,"_39":40,"_38":389,"_166":24,"_36":390,"_13":391,"_33":20,"_35":392,"_23":24,"_171":-5,"_315":393,"_26":394},{"_41":270,"_31":271,"_29":272,"_164":-5,"_39":40,"_38":273,"_166":57,"_36":383,"_13":61,"_33":34,"_35":-5,"_23":24,"_171":-5,"_315":384,"_26":385},{"_41":376,"_31":377,"_29":378,"_164":272,"_39":40,"_38":379,"_166":57,"_36":380,"_13":61,"_33":34,"_35":-5,"_23":24,"_171":-5,"_315":381,"_26":382},{"_41":372,"_31":32,"_29":30,"_164":272,"_39":40,"_38":14,"_166":57,"_36":373,"_13":61,"_33":34,"_35":-5,"_23":24,"_171":-5,"_315":374,"_26":375},{"_41":365,"_31":366,"_29":367,"_164":272,"_39":40,"_38":368,"_166":57,"_36":369,"_13":61,"_33":34,"_35":-5,"_23":24,"_171":-5,"_315":370,"_26":371},{"_41":264,"_31":265,"_29":266,"_164":-5,"_39":40,"_38":267,"_166":57,"_36":362,"_13":61,"_33":34,"_35":-5,"_23":24,"_171":-5,"_315":363,"_26":364},{"_41":354,"_31":355,"_29":356,"_164":266,"_39":40,"_38":357,"_166":57,"_36":358,"_13":61,"_33":20,"_35":359,"_23":24,"_171":-5,"_315":360,"_26":361},{"_41":256,"_31":257,"_29":258,"_164":-5,"_39":40,"_38":259,"_166":57,"_36":351,"_13":261,"_33":194,"_35":262,"_23":24,"_171":-5,"_315":352,"_26":353},{"_41":249,"_31":250,"_29":251,"_164":-5,"_39":40,"_38":252,"_166":57,"_36":348,"_13":193,"_33":194,"_35":254,"_23":24,"_171":-5,"_315":349,"_26":350},{"_41":242,"_31":243,"_29":244,"_164":-5,"_39":40,"_38":245,"_166":57,"_36":345,"_13":168,"_33":194,"_35":247,"_23":24,"_171":-5,"_315":346,"_26":347},{"_41":235,"_31":236,"_29":237,"_164":-5,"_39":40,"_38":238,"_166":57,"_36":342,"_13":61,"_33":169,"_35":240,"_23":24,"_171":-5,"_315":343,"_26":344},{"_41":227,"_31":228,"_29":229,"_164":-5,"_39":40,"_38":230,"_166":57,"_36":339,"_13":232,"_33":169,"_35":233,"_23":24,"_171":-5,"_315":340,"_26":341},{"_41":219,"_31":220,"_29":221,"_164":-5,"_39":40,"_38":222,"_166":57,"_36":336,"_13":224,"_33":169,"_35":225,"_23":24,"_171":-5,"_315":337,"_26":338},{"_41":212,"_31":213,"_29":214,"_164":-5,"_39":40,"_38":215,"_166":57,"_36":333,"_13":61,"_33":169,"_35":217,"_23":24,"_171":-5,"_315":334,"_26":335},{"_41":205,"_31":206,"_29":207,"_164":-5,"_39":40,"_38":208,"_166":57,"_36":330,"_13":61,"_33":169,"_35":210,"_23":24,"_171":-5,"_315":331,"_26":332},{"_41":197,"_31":198,"_29":55,"_164":-5,"_39":40,"_38":199,"_166":57,"_36":327,"_13":201,"_33":202,"_35":203,"_23":24,"_171":-5,"_315":328,"_26":329},{"_41":188,"_31":189,"_29":190,"_164":-5,"_39":40,"_38":191,"_166":57,"_36":324,"_13":193,"_33":194,"_35":195,"_23":24,"_171":-5,"_315":325,"_26":326},{"_41":180,"_31":181,"_29":182,"_164":-5,"_39":40,"_38":183,"_166":24,"_36":321,"_13":185,"_33":169,"_35":186,"_23":24,"_171":-5,"_315":322,"_26":323},{"_41":173,"_31":174,"_29":175,"_164":-5,"_39":40,"_38":176,"_166":57,"_36":318,"_13":61,"_33":169,"_35":178,"_23":24,"_171":-5,"_315":319,"_26":320},{"_41":161,"_31":162,"_29":163,"_164":-5,"_39":40,"_38":165,"_166":57,"_36":314,"_13":168,"_33":169,"_35":170,"_23":24,"_171":-5,"_315":316,"_26":317},["D",1775922349279],"children",[],[162],["D",1775835486944],[],[174],["D",1775995332308],[],[181],["D",1775836530931],[],[189],["D",1775975706725],[],[198],["D",1775836542240],[],[206],["D",1775836672529],[],[213],["D",1775995326448],[],[220],["D",1775975919926],[],[228],["D",1775835527597],[],[236],["D",1775975706519],[],[243],["D",1775923024608],[],[250],["D",1775833666167],[],[257],"6e2bc4ca-357c-11f1-b212-42b51c65c3df","extensions.json","6e2bc59c-357c-11f1-b212-42b51c65c3df",32,["D",1775894396567],"{\n \"recommendations\": [\n \"denoland.vscode-deno\"\n ]\n}",[],[265,355],["D",1775894396363],[300],[265],"c5e2c852-3672-11f1-b35d-42b51c65c3df","objects","c5e2c956-3672-11f1-b35d-42b51c65c3df",98,["D",1776000199923],[],[271,366],"c61d55d0-3672-11f1-9386-42b51c65c3df",["D",1776000200311],[],[271,32],"c5fdec4a-3672-11f1-a28d-42b51c65c3df","info","c5fded30-3672-11f1-a28d-42b51c65c3df",99,["D",1776000200102],[],[271,377],["D",1776000199737],[296,297,298],[271],"fb152990-3666-11f1-a4bb-42b51c65c3df","settings.local.json","6e34be68-357c-11f1-8046-42b51c65c3df",92,["D",1775995135204],18,"{\n \"permissions\": {\n \"allow\": [\n \"mcp__val-town__list_vals\",\n \"mcp__val-town__list_files\",\n \"mcp__val-town__read_file\",\n \"mcp__val-town__create_file\",\n \"mcp__val-town__write_interval_settings\",\n \"Bash(grep -E '\\\\\\\\.\\\$ts|json|md\\\$$')\",\n \"Bash(xargs cat:*)\",\n \"WebFetch(domain:langchain-ai.github.io)\",\n \"WebSearch\",\n \"WebFetch(domain:reference.langchain.com)\",\n \"WebFetch(domain:raw.githubusercontent.com)\",\n \"WebFetch(domain:esm.town)\",\n \"Bash(deno check:*)\",\n \"mcp__val-town__add_env_var\",\n \"mcp__langfuse-docs__getLangfuseDocsPage\",\n \"mcp__langfuse-docs__searchLangfuseDocs\",\n \"Bash(grep -E '\\\\\\\\.\\\$ts|js|json\\\$$')\",\n \"mcp__val-town__get_logs\",\n \"mcp__val-town__list_env_vars\",\n \"mcp__val-town__get_traces\",\n \"mcp__val-town__get_val_history\"\n ]\n }\n}\n",[],[277,387],["D",1775894396155],[294],[277],["D",1775832701083],["D",1789504321592],{"_102":101,"_110":106},{"_102":101,"_103":104,"_105":106,"_18":53,"_107":108,"_109":24},{"_13":87,"_31":88,"_41":40,"_89":42,"_90":91,"_92":93,"_94":48,"_95":96,"_97":98,"_99":43,"_100":101},"ctx",{"_80":-5,"_132":436,"_437":438,"_439":440,"_441":24,"_442":24,"_443":24,"_444":57,"_445":-5,"_446":-7,"_447":-7,"_448":61,"_449":24,"_450":24,"_451":-5,"_452":24,"_453":24,"_454":24,"_455":-5},"ENV",{"_407":408,"_409":410,"_411":88,"_412":413,"_414":415,"_416":417,"_418":419,"_420":421,"_422":423,"_424":425,"_426":427,"_428":429,"_430":431,"_432":433,"_434":435},"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 · v100