[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_178":179,"_180":181},"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",5,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","311efff2-d18e-4c82-bd9f-72876f3f8609","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","01a089ac-3dfc-75de-a2d4-931ecbb1de7a","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// Chat with NVIDIA's API, keeping recent conversation context\nexport async function aiReply(chatId: string, prompt: string): Promise {\n const apiKey = Deno.env.get(\"NVIDIA_API_KEY\");\n if (!apiKey) throw new Error(\"NVIDIA_API_KEY is not set\");\n const model = Deno.env.get(\"NVIDIA_MODEL\") ?? \"meta/llama-3.3-70b-instruct\";\n\n const client = new OpenAI({\n baseURL: \"https://integrate.api.nvidia.com/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,\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// Fetch the bot's identity up front (required when handling updates manually)\nawait bot.init();\n\n// Handle the /start command.\nbot.command(\"start\", (ctx) => ctx.reply(\"Welcome! Up and running.\"));\n// Handle other messages by sending them to NVIDIA's model.\nbot.on(\"message\", async (ctx) => {\n try {\n await ctx.reply(await aiReply(String(ctx.chat.id), ctx.message.text));\n } catch (err) {\n console.error(err);\n await ctx.reply(\"Sorry, something went wrong talking to NVIDIA.\");\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 const { pathname } = new URL(req.url);\n\n if (pathname.endsWith(\"/process\")) {\n // Long-running path: called by ourselves (must carry the secret token)\n if (req.headers.get(\"x-telegram-bot-api-secret-token\") !== SECRET_TOKEN) {\n return new Response(\"unauthorized\", { status: 401 });\n }\n const update = await req.json();\n await bot.handleUpdate(update); // can take as long as it needs\n return new Response(\"done\");\n }\n\n // Webhook path: acknowledge Telegram immediately, then kick off the\n // processing as an unawaited request to ourselves (keeps a process\n // alive until the AI reply is sent).\n const body = await req.text();\n const origin = new URL(req.url).origin;\n fetch(`${origin}/process`, {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n \"x-telegram-bot-api-secret-token\": SECRET_TOKEN,\n },\n body,\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};","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// Chat with NVIDIA's API, keeping recent conversation context\nexport async function aiReply(chatId: string, prompt: string): Promise {\n const apiKey = Deno.env.get(\"NVIDIA_API_KEY\");\n if (!apiKey) throw new Error(\"NVIDIA_API_KEY is not set\");\n const model = Deno.env.get(\"NVIDIA_MODEL\") ?? \"moonshotai/kimi-k2-instruct\";\n\n const client = new OpenAI({\n baseURL: \"https://integrate.api.nvidia.com/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,\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// Fetch the bot's identity up front (required when handling updates manually)\nawait bot.init();\n\n// Handle the /start command.\nbot.command(\"start\", (ctx) => ctx.reply(\"Welcome! Up and running.\"));\n// Handle other messages by sending them to NVIDIA's model.\nbot.on(\"message\", async (ctx) => {\n try {\n await ctx.reply(await aiReply(String(ctx.chat.id), ctx.message.text));\n } catch (err) {\n console.error(err);\n await ctx.reply(\"Sorry, something went wrong talking to NVIDIA.\");\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 const { pathname } = new URL(req.url);\n\n if (pathname.endsWith(\"/process\")) {\n // Long-running path: called by ourselves (must carry the secret token)\n if (req.headers.get(\"x-telegram-bot-api-secret-token\") !== SECRET_TOKEN) {\n return new Response(\"unauthorized\", { status: 401 });\n }\n const update = await req.json();\n await bot.handleUpdate(update); // can take as long as it needs\n return new Response(\"done\");\n }\n\n // Webhook path: acknowledge Telegram immediately, then kick off the\n // processing as an unawaited request to ourselves (keeps a process\n // alive until the AI reply is sent).\n const body = await req.text();\n const origin = new URL(req.url).origin;\n fetch(`${origin}/process`, {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n \"x-telegram-bot-api-secret-token\": SECRET_TOKEN,\n },\n body,\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",1789016736246],"branchVersion","branchId","a87d3b21-4278-488d-87ca-d50aff41c3da","id","250af3fc-be1e-4420-a814-9425bb113783","telegram-chat-bot",["D",1789016145246],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Telegram AI chatbot powered by OrcaRouter's free Qwen model","imageUrl","e0907b47-12d5-478d-8ac2-8888b4aa3a81","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a04b43-8df8-7150-be87-42143954bfd1","tursoName","250af3fcbe1e4420a8149425bb113783","tursoHostname","250af3fcbe1e4420a8149425bb113783-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789536664699],"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",7,"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":173,"_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":174,"_77":-5,"_78":79,"_80":79,"_81":82,"_83":82,"_84":82,"_85":79,"_86":79,"_87":175,"_89":176,"_91":177,"_93":31},"tree",[164,165],"files",[164,165],"counts",{"_153":68,"_154":142,"_155":68,"_156":157,"_158":159},"contents",[136,137],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_49":149,"_38":34,"_36":37,"_141":-5,"_47":48,"_46":14,"_143":31,"_44":150,"_13":151,"_39":40,"_41":43,"_30":31,"_147":-5,"_33":152},{"_49":138,"_38":139,"_36":140,"_141":-5,"_47":48,"_46":142,"_143":64,"_44":144,"_13":68,"_39":145,"_41":146,"_30":31,"_147":-5,"_33":148},"010f3b91-3e49-4253-b7f3-f10d11184397","memory.ts","01a089ac-3dfd-73df-ba9b-3995ee7c2ad9","parentId",1,"latest",["D",1789016161793],"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",[139],"b281b8ba-6521-40a2-884c-bdccc6e5b944",["D",1789016736246],4,[34],"pulls","branches","forks","envVars",{"_160":162,"_163":68},"connections",{"_160":68,"_161":68},"count","unfilledCount",3,"emptyCount",{"_49":149,"_38":34,"_36":37,"_141":-5,"_47":48,"_46":14,"_143":31,"_44":170,"_13":151,"_39":40,"_41":43,"_30":31,"_147":-5,"_167":171,"_33":172},{"_49":138,"_38":139,"_36":140,"_141":-5,"_47":48,"_46":142,"_143":64,"_44":166,"_13":68,"_39":145,"_41":146,"_30":31,"_147":-5,"_167":168,"_33":169},["D",1789016161793],"children",[],[139],["D",1789016736246],[],[34],["D",1789016145246],["D",1789536664699],{"_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":211,"_212":213,"_214":215,"_216":31,"_217":31,"_218":31,"_219":64,"_220":-5,"_221":-7,"_222":-7,"_223":68,"_224":31,"_225":31,"_226":-5,"_227":31,"_228":31,"_229":31,"_230":-5},"ENV",{"_182":183,"_184":185,"_186":95,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202,"_203":204,"_205":206,"_207":208,"_209":210},"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 · v5