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],"directory",[265],"c5c5fd3a-3672-11f1-8cda-42b51c65c3df",".git","c5c5fe0c-3672-11f1-8cda-42b51c65c3df",97,["D",1776000199737],[272],"6ded3c6e-357c-11f1-b212-42b51c65c3df",".claude","6ded3d2c-357c-11f1-b212-42b51c65c3df",30,["D",1775894396155],[278],"pulls","branches","forks","envVars",{"_290":292,"_293":61},"connections",{"_290":61,"_291":61},"count","unfilledCount",9,"emptyCount",{"_41":277,"_31":278,"_29":279,"_164":-5,"_39":40,"_38":280,"_166":57,"_36":635,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":636,"_26":637},{"_41":626,"_31":627,"_29":628,"_164":279,"_39":40,"_38":629,"_166":24,"_36":630,"_13":631,"_33":20,"_34":632,"_23":24,"_171":-5,"_346":633,"_26":634},{"_41":271,"_31":272,"_29":273,"_164":-5,"_39":40,"_38":274,"_166":57,"_36":623,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":624,"_26":625},{"_41":616,"_31":617,"_29":618,"_164":273,"_39":40,"_38":619,"_166":57,"_36":620,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":621,"_26":622},{"_41":610,"_31":435,"_29":611,"_164":273,"_39":40,"_38":612,"_166":57,"_36":613,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":614,"_26":615},{"_41":605,"_31":598,"_29":600,"_164":273,"_39":40,"_38":606,"_166":57,"_36":607,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":608,"_26":609},{"_41":599,"_31":412,"_29":593,"_164":600,"_39":40,"_38":601,"_166":57,"_36":602,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":603,"_26":604},{"_41":591,"_31":414,"_29":592,"_164":593,"_39":40,"_38":594,"_166":57,"_36":595,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":596,"_26":597},{"_41":586,"_31":433,"_29":428,"_164":273,"_39":40,"_38":587,"_166":57,"_36":588,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":589,"_26":590},{"_41":579,"_31":580,"_29":581,"_164":428,"_39":40,"_38":582,"_166":57,"_36":583,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":584,"_26":585},{"_41":572,"_31":573,"_29":574,"_164":428,"_39":40,"_38":575,"_166":57,"_36":576,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":577,"_26":578},{"_41":565,"_31":566,"_29":567,"_164":428,"_39":40,"_38":568,"_166":57,"_36":569,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":570,"_26":571},{"_41":558,"_31":559,"_29":560,"_164":428,"_39":40,"_38":561,"_166":57,"_36":562,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":563,"_26":564},{"_41":551,"_31":552,"_29":553,"_164":428,"_39":40,"_38":554,"_166":57,"_36":555,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":556,"_26":557},{"_41":544,"_31":545,"_29":546,"_164":428,"_39":40,"_38":547,"_166":57,"_36":548,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":549,"_26":550},{"_41":537,"_31":538,"_29":539,"_164":428,"_39":40,"_38":540,"_166":57,"_36":541,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":542,"_26":543},{"_41":530,"_31":531,"_29":532,"_164":428,"_39":40,"_38":533,"_166":57,"_36":534,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":535,"_26":536},{"_41":523,"_31":524,"_29":525,"_164":428,"_39":40,"_38":526,"_166":57,"_36":527,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":528,"_26":529},{"_41":518,"_31":517,"_29":513,"_164":428,"_39":40,"_38":519,"_166":57,"_36":520,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":521,"_26":522},{"_41":512,"_31":32,"_29":30,"_164":513,"_39":40,"_38":14,"_166":57,"_36":514,"_13":61,"_33":20,"_34":35,"_23":24,"_171":-5,"_346":515,"_26":516},{"_41":505,"_31":506,"_29":507,"_164":428,"_39":40,"_38":508,"_166":57,"_36":509,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":510,"_26":511},{"_41":498,"_31":499,"_29":500,"_164":428,"_39":40,"_38":501,"_166":57,"_36":502,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":503,"_26":504},{"_41":491,"_31":492,"_29":493,"_164":428,"_39":40,"_38":494,"_166":57,"_36":495,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":496,"_26":497},{"_41":484,"_31":485,"_29":486,"_164":428,"_39":40,"_38":487,"_166":57,"_36":488,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":489,"_26":490},{"_41":477,"_31":478,"_29":479,"_164":428,"_39":40,"_38":480,"_166":57,"_36":481,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":482,"_26":483},{"_41":470,"_31":471,"_29":472,"_164":428,"_39":40,"_38":473,"_166":57,"_36":474,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":475,"_26":476},{"_41":465,"_31":464,"_29":458,"_164":428,"_39":40,"_38":466,"_166":57,"_36":467,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":468,"_26":469},{"_41":455,"_31":456,"_29":457,"_164":458,"_39":40,"_38":459,"_166":57,"_36":460,"_13":61,"_33":20,"_34":461,"_23":24,"_171":-5,"_346":462,"_26":463},{"_41":448,"_31":449,"_29":450,"_164":428,"_39":40,"_38":451,"_166":57,"_36":452,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":453,"_26":454},{"_41":441,"_31":442,"_29":443,"_164":428,"_39":40,"_38":444,"_166":57,"_36":445,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":446,"_26":447},{"_41":434,"_31":435,"_29":436,"_164":428,"_39":40,"_38":437,"_166":57,"_36":438,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":439,"_26":440},{"_41":425,"_31":426,"_29":427,"_164":428,"_39":40,"_38":429,"_166":57,"_36":430,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":431,"_26":432},{"_41":420,"_31":412,"_29":407,"_164":273,"_39":40,"_38":421,"_166":57,"_36":422,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":423,"_26":424},{"_41":413,"_31":414,"_29":415,"_164":407,"_39":40,"_38":416,"_166":57,"_36":417,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":418,"_26":419},{"_41":404,"_31":405,"_29":406,"_164":407,"_39":40,"_38":408,"_166":57,"_36":409,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":410,"_26":411},{"_41":396,"_31":397,"_29":398,"_164":273,"_39":40,"_38":399,"_166":57,"_36":400,"_13":61,"_33":20,"_34":401,"_23":24,"_171":-5,"_346":402,"_26":403},{"_41":264,"_31":265,"_29":266,"_164":-5,"_39":40,"_38":267,"_166":57,"_36":393,"_13":61,"_33":269,"_34":-5,"_23":24,"_171":-5,"_346":394,"_26":395},{"_41":385,"_31":386,"_29":387,"_164":266,"_39":40,"_38":388,"_166":57,"_36":389,"_13":61,"_33":20,"_34":390,"_23":24,"_171":-5,"_346":391,"_26":392},{"_41":256,"_31":257,"_29":258,"_164":-5,"_39":40,"_38":259,"_166":57,"_36":382,"_13":261,"_33":194,"_34":262,"_23":24,"_171":-5,"_346":383,"_26":384},{"_41":249,"_31":250,"_29":251,"_164":-5,"_39":40,"_38":252,"_166":57,"_36":379,"_13":193,"_33":194,"_34":254,"_23":24,"_171":-5,"_346":380,"_26":381},{"_41":242,"_31":243,"_29":244,"_164":-5,"_39":40,"_38":245,"_166":57,"_36":376,"_13":168,"_33":194,"_34":247,"_23":24,"_171":-5,"_346":377,"_26":378},{"_41":235,"_31":236,"_29":237,"_164":-5,"_39":40,"_38":238,"_166":57,"_36":373,"_13":61,"_33":169,"_34":240,"_23":24,"_171":-5,"_346":374,"_26":375},{"_41":227,"_31":228,"_29":229,"_164":-5,"_39":40,"_38":230,"_166":57,"_36":370,"_13":232,"_33":169,"_34":233,"_23":24,"_171":-5,"_346":371,"_26":372},{"_41":219,"_31":220,"_29":221,"_164":-5,"_39":40,"_38":222,"_166":57,"_36":367,"_13":224,"_33":169,"_34":225,"_23":24,"_171":-5,"_346":368,"_26":369},{"_41":212,"_31":213,"_29":214,"_164":-5,"_39":40,"_38":215,"_166":57,"_36":364,"_13":61,"_33":169,"_34":217,"_23":24,"_171":-5,"_346":365,"_26":366},{"_41":205,"_31":206,"_29":207,"_164":-5,"_39":40,"_38":208,"_166":57,"_36":361,"_13":61,"_33":169,"_34":210,"_23":24,"_171":-5,"_346":362,"_26":363},{"_41":197,"_31":198,"_29":55,"_164":-5,"_39":40,"_38":199,"_166":57,"_36":358,"_13":201,"_33":202,"_34":203,"_23":24,"_171":-5,"_346":359,"_26":360},{"_41":188,"_31":189,"_29":190,"_164":-5,"_39":40,"_38":191,"_166":57,"_36":355,"_13":193,"_33":194,"_34":195,"_23":24,"_171":-5,"_346":356,"_26":357},{"_41":180,"_31":181,"_29":182,"_164":-5,"_39":40,"_38":183,"_166":24,"_36":352,"_13":185,"_33":169,"_34":186,"_23":24,"_171":-5,"_346":353,"_26":354},{"_41":173,"_31":174,"_29":175,"_164":-5,"_39":40,"_38":176,"_166":57,"_36":349,"_13":61,"_33":169,"_34":178,"_23":24,"_171":-5,"_346":350,"_26":351},{"_41":161,"_31":162,"_29":163,"_164":-5,"_39":40,"_38":165,"_166":57,"_36":345,"_13":168,"_33":169,"_34":170,"_23":24,"_171":-5,"_346":347,"_26":348},["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,386],["D",1775894396363],[331],[265],"c977d822-3672-11f1-a47b-42b51c65c3df","config","c977d8c2-3672-11f1-a47b-42b51c65c3df",129,["D",1776000205905],"[core]\n\trepositoryformatversion = 0\n\tfilemode = true\n\tbare = false\n\tlogallrefupdates = true\n\tignorecase = true\n\tprecomposeunicode = true\n",[],[272,397],"c93412b8-3672-11f1-8804-42b51c65c3df","tags","c93413da-3672-11f1-8804-42b51c65c3df","c6545cb0-3672-11f1-a47b-42b51c65c3df",126,["D",1776000205492],[],[272,412,405],"refs","c91af224-3672-11f1-8e7c-42b51c65c3df","heads","c91af2d8-3672-11f1-8e7c-42b51c65c3df",125,["D",1776000205327],[],[272,412,414],"c6545bf2-3672-11f1-a47b-42b51c65c3df",102,["D",1776000200669],[327,328],[272,412],"c7b858b8-3672-11f1-8354-42b51c65c3df","pack","c7b859a8-3672-11f1-8354-42b51c65c3df","c5e2c956-3672-11f1-b35d-42b51c65c3df",112,["D",1776000203003],[],[272,433,426],"objects","c8428650-3672-11f1-b110-42b51c65c3df","info","c84286e6-3672-11f1-b110-42b51c65c3df",117,["D",1776000203907],[],[272,433,435],"c8943590-3672-11f1-86a8-42b51c65c3df","e8","c8943658-3672-11f1-86a8-42b51c65c3df",120,["D",1776000204442],[],[272,433,442],"c77b5a12-3672-11f1-b3fc-42b51c65c3df","e3","c77b5b52-3672-11f1-b3fc-42b51c65c3df",110,["D",1776000202595],[],[272,433,449],"c97295f6-3672-11f1-ba29-42b51c65c3df","b821550dd60b530466e57d09df71de431831d0","c97296be-3672-11f1-ba29-42b51c65c3df","c73a84a6-3672-11f1-8cda-42b51c65c3df",128,["D",1776000205902],"x\u0001}��\u000e�0\u0010��y\n�ٚ޵��c\u0018'��@$A �.�w�P\u0007\u001c��]��|��\u001c%?��<\u0016y��<��є1��K0PH�E\u0015(@\rT\u001b��@_@�E�eM6�rL ?�.�~��+Y��qj�.��:Ѻi>?��w؄\u0015h�w��W�\u001f�PR&(�\u0005�2��'��-o��

Diff · v130