[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_192":193,"_194":195},"routes/_app.x.$handle.$name",{"_105":104,"_38":51,"_114":95,"_33":115,"_13":14,"_116":-5,"_11":117,"_118":119,"_120":121,"_122":123,"_124":125,"_26":-5,"_126":-5,"_127":-5,"_128":31,"_129":130,"_131":64,"_132":-5,"_133":-5,"_134":135},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_49":50,"_38":51,"_44":52,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":37,"_63":64,"_65":-5,"_66":-5,"_67":68,"_69":70,"_71":72,"_73":74,"_75":76,"_77":-5,"_78":79,"_80":79,"_81":82,"_83":82,"_84":82,"_85":79,"_86":79,"_87":88,"_89":90,"_91":92,"_93":31},"version",11,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","7a9704ae-de6b-4448-b58c-2f73b043940e","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":29,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":34,"_39":40,"_41":43,"_44":45,"_46":14,"_47":48,"_30":31},"previous",{"_36":37,"_38":34,"_39":40,"_41":42},"deleted",false,"deletedHere","path","index.ts","latestPath","fileId","01a056a9-2aaa-718a-aa21-ebb36c0d7f82","name","fileType","http","content","import { Bot, webhookCallback } from \"https://deno.land/x/grammy@v1.35.0/mod.ts\";\nimport OpenAI from \"npm:openai\";\nimport { addMessage, getHistory } from \"./memory.ts\";\n\n// Ask OrcaRouter's free Qwen model with recent conversation context\nexport async function orcaReply(chatId: string, prompt: string): Promise {\n const apiKey = Deno.env.get(\"ORCAROUTER_API_KEY\");\n if (!apiKey) throw new Error(\"ORCAROUTER_API_KEY is not set\");\n\n const client = new OpenAI({\n baseURL: \"https://api.orcarouter.ai/v1\",\n apiKey,\n });\n\n // Build the message list: recent history + the new user message\n const history = await getHistory(chatId);\n await addMessage(chatId, \"user\", prompt);\n const messages = [\n ...history.map((m) => ({ role: m.role as \"user\" | \"assistant\", content: m.content })),\n { role: \"user\" as const, content: prompt },\n ];\n\n const response = await client.chat.completions.create({\n model: \"qwen/qwen3.8-27b-free\",\n messages,\n });\n\n const reply = response.choices[0].message.content ?? \"(empty response)\";\n await addMessage(chatId, \"assistant\", reply);\n return reply;\n}\n\nif (!Deno.env.get(\"TELEGRAM_TOKEN\")) {\n throw new Error(\"TELEGRAM_TOKEN is not set\");\n}\n\nconst bot = new Bot(Deno.env.get(\"TELEGRAM_TOKEN\")!);\n\n// Handle the /start command.\nbot.command(\"start\", (ctx) => ctx.reply(\"Welcome! Up and running.\"));\n// Handle other messages by sending them to OrcaRouter's Qwen model.\nbot.on(\"message\", async (ctx) => {\n try {\n await ctx.reply(await orcaReply(String(ctx.chat.id), ctx.message.text));\n } catch (err) {\n console.error(err);\n await ctx.reply(\"Sorry, something went wrong talking to OrcaRouter.\");\n }\n});\n\n// Use part of the TELEGRAM_TOKEN itself as the secret_token\n// to authorize webhook requests.\nconst SECRET_TOKEN = Deno.env.get(\"TELEGRAM_TOKEN\")!.split(\":\")[1];\n\nconst handleUpdate = webhookCallback(\n bot,\n \"std/http\",\n undefined,\n undefined,\n SECRET_TOKEN,\n);\n\nlet isEndpointSet = false;\nexport default async (req: Request): Promise => {\n // Set webhook if it is not set yet\n // Do this in the HTTP handler so we get the endpoint url from req.url\n // This is a no-op if nothing's changed\n if (!isEndpointSet) {\n await bot.api.setWebhook(req.url, {\n secret_token: SECRET_TOKEN,\n });\n isEndpointSet = true;\n }\n if (req.method === \"POST\") {\n return await handleUpdate(req);\n }\n return new Response(\n `

Telegram Bot Starter

Learn more at \n \n https://docs.val.town/integrations/telegram/

`,\n { status: 200, headers: { \"content-type\": \"text/html\" } },\n );\n};","import { Bot, webhookCallback } from \"https://deno.land/x/grammy@v1.35.0/mod.ts\";\nimport OpenAI from \"npm:openai\";\nimport { addMessage, getHistory } from \"./memory.ts\";\n\n// Ask OrcaRouter's free Qwen model with recent conversation context\nexport async function orcaReply(chatId: string, prompt: string): Promise {\n const apiKey = Deno.env.get(\"ORCAROUTER_API_KEY\");\n if (!apiKey) throw new Error(\"ORCAROUTER_API_KEY is not set\");\n\n const client = new OpenAI({\n baseURL: \"https://api.orcarouter.ai/v1\",\n apiKey,\n });\n\n // Build the message list: recent history + the new user message\n const history = await getHistory(chatId);\n await addMessage(chatId, \"user\", prompt);\n const messages = [\n ...history.map((m) => ({ role: m.role as \"user\" | \"assistant\", content: m.content })),\n { role: \"user\" as const, content: prompt },\n ];\n\n const response = await client.chat.completions.create({\n model: \"qwen/qwen3.8-27b-free\",\n messages,\n });\n\n const reply = response.choices[0].message.content ?? \"(empty response)\";\n await addMessage(chatId, \"assistant\", reply);\n return reply;\n}\n\nif (!Deno.env.get(\"TELEGRAM_TOKEN\")) {\n throw new Error(\"TELEGRAM_TOKEN is not set\");\n}\n\nconst bot = new Bot(Deno.env.get(\"TELEGRAM_TOKEN\")!);\n\n// Handle the /start command.\nbot.command(\"start\", (ctx) => ctx.reply(\"Welcome! Up and running.\"));\n// Handle other messages by sending them to OrcaRouter's Qwen model.\nbot.on(\"message\", async (ctx) => {\n try {\n await ctx.reply(await orcaReply(String(ctx.chat.id), ctx.message.text));\n } catch (err) {\n console.error(err);\n await ctx.reply(\"Sorry, something went wrong talking to OrcaRouter.\");\n }\n});\n\n// Use part of the TELEGRAM_TOKEN itself as the secret_token\n// to authorize webhook requests.\nconst SECRET_TOKEN = Deno.env.get(\"TELEGRAM_TOKEN\")!.split(\":\")[1];\n\nconst handleUpdate = webhookCallback(\n bot,\n \"std/http\",\n undefined,\n undefined,\n SECRET_TOKEN,\n);\n\nlet isEndpointSet = false;\nexport default async (req: Request): Promise => {\n // Set webhook if it is not set yet\n // Do this in the HTTP handler so we get the endpoint url from req.url\n // This is a no-op if nothing's changed\n if (!isEndpointSet) {\n await bot.api.setWebhook(req.url, {\n secret_token: SECRET_TOKEN,\n });\n isEndpointSet = true;\n }\n if (req.method === \"POST\") {\n // Acknowledge Telegram immediately so it doesn't retry the delivery,\n // then process the update in the background (the AI call can be slow).\n const update = await req.json();\n (async () => {\n try {\n await bot.handleUpdate(update);\n } catch (err) {\n console.error(err);\n }\n })();\n return new Response(\"OK\");\n }\n return new Response(\n `

Telegram Bot Starter

Learn more at \n \n https://docs.val.town/integrations/telegram/

`,\n { status: 200, headers: { \"content-type\": \"text/html\" } },\n );\n};","createdAt",["D",1788176723698],"branchVersion","branchId","3abfa93a-5ed9-4d09-aeeb-5288859edb65","id","e75b601f-dc35-4667-9acb-6701ee1cdeb0","telegram-orca-bot",["D",1788160322122],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Telegram bot that replies using OrcaRouter's Qwen model","imageUrl","e0907b47-12d5-478d-8ac2-8888b4aa3a81","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a04b43-8df8-7150-be87-42143954bfd1","tursoName","e75b601fdc3546679acb6701ee1cdeb0","tursoHostname","e75b601fdc3546679acb6701ee1cdeb0-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789463450699],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_105":104,"_113":109},"org",{"_105":104,"_106":107,"_108":109,"_19":61,"_110":111,"_112":31},"branch",{"_13":94,"_38":95,"_49":48,"_96":50,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":51,"_103":104},"isOwned",13,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","krism","handle","displayName","K M","avatar","https://lh3.googleusercontent.com/a/ACg8ocK4cD5iwamskafY_AWYsr98sEyaIkxPC-qG5AU66L4pyM-sQXgF=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_49":50,"_38":51,"_44":187,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":37,"_63":64,"_65":-5,"_66":-5,"_67":68,"_69":70,"_71":72,"_73":74,"_75":188,"_77":-5,"_78":79,"_80":79,"_81":82,"_83":82,"_84":82,"_85":79,"_86":79,"_87":189,"_89":190,"_91":191,"_93":31},"tree",[174,175,176],"files",[174,175,176],"counts",{"_163":68,"_164":146,"_165":68,"_166":167,"_168":169},"contents",[136,137,138],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_49":155,"_38":156,"_36":157,"_142":-5,"_47":48,"_46":158,"_144":64,"_44":159,"_13":68,"_39":160,"_41":161,"_30":31,"_149":-5,"_33":162},{"_49":151,"_38":34,"_36":37,"_142":-5,"_47":48,"_46":14,"_144":31,"_44":152,"_13":153,"_39":40,"_41":43,"_30":31,"_149":-5,"_33":154},{"_49":139,"_38":140,"_36":141,"_142":-5,"_47":48,"_46":143,"_144":64,"_44":145,"_13":146,"_39":147,"_41":148,"_30":31,"_149":-5,"_33":150},"6c43f1a5-d12d-4186-ab29-556482bd7548","memory.ts","e6ef9b06-a50d-11f1-86be-1607ee4eb77e","parentId",9,"latest",["D",1788161757858],1,"script","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport const HISTORY_LIMIT = 500; // messages of context per chat\n\n// Create the table once\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS messages (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n chat_id TEXT NOT NULL,\n role TEXT NOT NULL, -- 'user' or 'assistant'\n content TEXT NOT NULL,\n created_at INTEGER NOT NULL\n )\n`);\n\nexport async function addMessage(chatId: string, role: string, content: string) {\n await sqlite.execute({\n sql: \"INSERT INTO messages (chat_id, role, content, created_at) VALUES (?, ?, ?, ?)\",\n args: [chatId, role, content, Date.now()],\n });\n // Keep the DB tidy: drop anything older than the limit\n await sqlite.execute({\n sql: `DELETE FROM messages WHERE chat_id = ? AND id NOT IN (\n SELECT id FROM messages WHERE chat_id = ? ORDER BY id DESC LIMIT ${HISTORY_LIMIT}\n )`,\n args: [chatId, chatId],\n });\n}\n\nexport async function getHistory(chatId: string) {\n const result = await sqlite.execute({\n sql: \"SELECT role, content FROM messages WHERE chat_id = ? ORDER BY id DESC LIMIT ?\",\n args: [chatId, HISTORY_LIMIT],\n });\n return result.rows\n .map((r) => ({ role: r.role as string, content: r.content as string }))\n .reverse();\n}\n","label",[140],"aaa136f2-5139-456e-a0ba-d77cca47d469",["D",1788176723698],7,[34],"965fbb95-c394-418d-bce9-ecf064369f2e","daily-digest.ts","adf0a8e6-a511-11f1-83ae-1607ee4eb77e",10,["D",1788163077634],"interval","import { email } from \"https://esm.town/v/std/email\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// Daily digest of your Telegram bot conversation, emailed to you.\n// (No `to` needed — std/email defaults to the val owner's address.)\n\nexport default async function (interval: Interval) {\n // Only messages since the last run (or the last 24h on first run)\n const since = (interval.lastRunAt ?? new Date(Date.now() - 24 * 60 * 60 * 1000)).getTime();\n\n const result = await sqlite.execute({\n sql: \"SELECT role, content, created_at FROM messages WHERE created_at > ? ORDER BY id\",\n args: [since],\n });\n\n if (result.rows.length === 0) {\n console.log(\"No new messages — skipping digest.\");\n return;\n }\n\n const lines = result.rows.map((r) => {\n const time = new Date(r.created_at as number).toLocaleString(\"en-GB\", {\n timeZone: \"UTC\",\n });\n const who = r.role === \"user\" ? \"You\" : \"Bot\";\n return `[${time}] ${who}: ${r.content}`;\n });\n\n await email({\n subject: `Telegram bot digest — ${result.rows.length} new messages`,\n text: lines.join(\"\\n\\n\"),\n });\n\n console.log(`Emailed digest with ${result.rows.length} messages.`);\n}\n",[156],"pulls","branches","forks","envVars",{"_170":172,"_173":68},"connections",{"_170":68,"_171":68},"count","unfilledCount",2,"emptyCount",{"_49":155,"_38":156,"_36":157,"_142":-5,"_47":48,"_46":158,"_144":64,"_44":184,"_13":68,"_39":160,"_41":161,"_30":31,"_149":-5,"_178":185,"_33":186},{"_49":151,"_38":34,"_36":37,"_142":-5,"_47":48,"_46":14,"_144":31,"_44":181,"_13":153,"_39":40,"_41":43,"_30":31,"_149":-5,"_178":182,"_33":183},{"_49":139,"_38":140,"_36":141,"_142":-5,"_47":48,"_46":143,"_144":64,"_44":177,"_13":146,"_39":147,"_41":148,"_30":31,"_149":-5,"_178":179,"_33":180},["D",1788161757858],"children",[],[140],["D",1788176723698],[],[34],["D",1788163077634],[],[156],["D",1788160322122],["D",1789463450699],{"_105":104,"_113":109},{"_105":104,"_106":107,"_108":109,"_19":61,"_110":111,"_112":31},{"_13":94,"_38":95,"_49":48,"_96":50,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":51,"_103":104},"ctx",{"_87":-5,"_133":225,"_226":227,"_228":229,"_230":31,"_231":31,"_232":31,"_233":64,"_234":-5,"_235":-7,"_236":-7,"_237":68,"_238":31,"_239":31,"_240":-5,"_241":31,"_242":31,"_243":31,"_244":-5},"ENV",{"_196":197,"_198":199,"_200":95,"_201":202,"_203":204,"_205":206,"_207":208,"_209":210,"_211":212,"_213":214,"_215":216,"_217":218,"_219":220,"_221":222,"_223":224},"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 · v11