new session in the active workspace\n/status active session status\n/last tail of the active session transcript\n/watch /unwatch forward the active session's replies here\n/notifyall on|off forward every cloud session's replies\n/model default model for /new (now: {model})\n/cancel cancel the running turn\n/sleep put the active workspace to sleep\n/link web link for the active workspace\n\nAnything without a leading slash is sent to the active session.\nReply to one of my messages to route your text to that session.`;\n\ntype Update = {\n update_id?: number;\n message?: {\n message_id: number;\n text?: string;\n from?: { id: number };\n chat: { id: number };\n reply_to_message?: { message_id: number };\n };\n};\n\nfunction allowed(userId: number): boolean {\n return env(\"TELEGRAM_ALLOWED_USER_ID\")\n .split(\",\")\n .map((s) => s.trim())\n .filter(Boolean)\n .includes(String(userId));\n}\n\nfunction labelFor(state: State, workspaceId?: string, sessionId?: string): string {\n const ws = workspaceId ? state.names[workspaceId] ?? workspaceId.slice(0, 8) : \"?\";\n const se = sessionId ? state.names[sessionId] ?? sessionId.slice(0, 8) : \"?\";\n return `${ws} › ${se}`;\n}\n\nfunction watch(state: State, chatId: number, sessionId: string): Watched {\n delete state.watched[sessionId]; // re-insert so the LRU trim treats it as fresh\n state.watched[sessionId] = { chatId, label: labelFor(state, state.activeWorkspaceId, sessionId) };\n return state.watched[sessionId];\n}\n\nasync function activateWorkspace(state: State, workspace: Workspace): Promise {\n state.activeWorkspaceId = workspace.id;\n state.names[workspace.id] = workspace.name;\n const sessions = await sessionsList(workspace.id);\n state.sessionIndex = sessions.map((s) => s.id);\n for (const s of sessions) if (s.name) state.names[s.id] = s.name;\n state.activeSessionId = sessions[0]?.id;\n const lines = sessions.map((s, i) => `${i + 1}. ${s.name ?? s.id.slice(0, 8)}${s.model ? ` (${s.model})` : \"\"}`);\n const active = state.activeSessionId ? state.names[state.activeSessionId] ?? state.activeSessionId.slice(0, 8) : \"none\";\n return `Active: ${workspace.name} [${workspace.state}]\\n${workspaceWebLink(workspace.id)}\\n\\nSessions:\\n${\n lines.join(\"\\n\") || \"(none)\"\n }\\n\\nActive session: ${active}`;\n}\n\nfunction requireActiveSession(state: State): string {\n if (!state.activeSessionId) throw new Error(\"No active session. Run /ws then /use , or /new .\");\n return state.activeSessionId;\n}\n\nasync function handleCommand(state: State, chatId: number, cmd: string, arg: string): Promise {\n switch (cmd) {\n case \"start\":\n case \"help\":\n return HELP.replace(\"{model}\", state.model);\n\n case \"ws\": {\n const rows = await workspacesList(state);\n state.wsIndex = rows.map((w) => w.id);\n for (const w of rows) state.names[w.id] = w.name;\n if (!rows.length) return \"No workspaces. Try /new .\";\n return rows\n .map((w, i) => {\n const active = w.id === state.activeWorkspaceId ? \" ←\" : \"\";\n const step = w.lifecycleStep ? `/${w.lifecycleStep}` : \"\";\n return `${i + 1}. ${w.name} [${w.state}${step}]${active}`;\n })\n .join(\"\\n\");\n }\n\n case \"use\": {\n const id = state.wsIndex[Number.parseInt(arg, 10) - 1];\n if (!id) return \"Usage: /use (run /ws first).\";\n return activateWorkspace(state, await conductor(`/v0/workspaces/${id}`));\n }\n\n case \"sessions\": {\n if (!state.activeWorkspaceId) return \"No active workspace. Run /ws then /use .\";\n return activateWorkspace(state, await conductor(`/v0/workspaces/${state.activeWorkspaceId}`));\n }\n\n case \"session\": {\n const id = state.sessionIndex[Number.parseInt(arg, 10) - 1];\n if (!id) return \"Usage: /session (run /sessions first).\";\n state.activeSessionId = id;\n return `Active session: ${labelFor(state, state.activeWorkspaceId, id)}`;\n }\n\n case \"new\": {\n if (!arg) return \"Usage: /new \";\n const projectId = env(\"CONDUCTOR_PROJECT_ID\");\n if (!projectId) return \"CONDUCTOR_PROJECT_ID is not set on the val.\";\n const created = await conductor<{ workspaceId: string; sessionId: string }>(\"/v0/workspaces\", {\n method: \"POST\",\n body: JSON.stringify({ projectId, agent: \"claude\", model: state.model, message: arg }),\n });\n state.activeWorkspaceId = created.workspaceId;\n state.activeSessionId = created.sessionId;\n state.names[created.workspaceId] = `new ${created.workspaceId.slice(0, 8)}`;\n watch(state, chatId, created.sessionId);\n return `Created and prompted.\\n${workspaceWebLink(created.workspaceId)}\\nReplies from this session will be forwarded here.`;\n }\n\n case \"newsession\": {\n if (!state.activeWorkspaceId) return \"No active workspace. Run /ws then /use .\";\n if (!arg) return \"Usage: /newsession \";\n const created = await conductor<{ id: string }>(\"/v0/sessions\", {\n method: \"POST\",\n body: JSON.stringify({ workspaceId: state.activeWorkspaceId, agent: \"claude\", model: state.model, message: arg }),\n });\n state.activeSessionId = created.id;\n watch(state, chatId, created.id);\n return `New session started in ${state.names[state.activeWorkspaceId] ?? \"workspace\"}; replies will be forwarded here.`;\n }\n\n case \"status\": {\n const id = requireActiveSession(state);\n const st = await conductor(`/v0/sessions/${id}/status`);\n const ws = state.activeWorkspaceId ? await conductor(`/v0/workspaces/${state.activeWorkspaceId}`) : undefined;\n return `${labelFor(state, state.activeWorkspaceId, id)}\\nsession: ${st.status}${st.errorMessage ? ` (${st.errorMessage})` : \"\"}${\n ws ? `\\nworkspace: ${ws.state}${ws.lifecycleStep ? `/${ws.lifecycleStep}` : \"\"}` : \"\"\n }`;\n }\n\n case \"last\":\n return (await transcriptTail(requireActiveSession(state))) || \"Transcript is empty so far.\";\n\n case \"watch\":\n return `Forwarding replies from ${watch(state, chatId, requireActiveSession(state)).label}.`;\n\n case \"unwatch\":\n delete state.watched[requireActiveSession(state)];\n return \"Stopped forwarding that session.\";\n\n case \"notifyall\": {\n if (arg === \"on\") {\n state.notifyAll = true;\n return \"Forwarding replies from every cloud session.\";\n }\n if (arg === \"off\") {\n state.notifyAll = false;\n return \"Only watched sessions are forwarded now.\";\n }\n return `notifyall is ${state.notifyAll ? \"on\" : \"off\"}. Usage: /notifyall on|off`;\n }\n\n case \"model\": {\n if (!arg) return `Default model: ${state.model}`;\n state.model = arg;\n return `Default model for /new is now ${arg}.`;\n }\n\n case \"cancel\":\n await conductor(`/v0/sessions/${requireActiveSession(state)}/cancel`, { method: \"POST\" });\n return \"Cancel requested.\";\n\n case \"sleep\": {\n if (!state.activeWorkspaceId) return \"No active workspace.\";\n await conductor(`/v0/workspaces/${state.activeWorkspaceId}/sleep`, { method: \"POST\" });\n return `Sleeping ${state.names[state.activeWorkspaceId] ?? \"workspace\"}.`;\n }\n\n case \"link\":\n return state.activeWorkspaceId ? workspaceWebLink(state.activeWorkspaceId) : \"No active workspace.\";\n\n default:\n return `Unknown command /${cmd}. Send /help.`;\n }\n}\n\nasync function handleTelegram(req: Request): Promise {\n // Both checks fail closed: an unset secret or an unset allowlist means nobody gets in.\n const secret = env(\"TELEGRAM_WEBHOOK_SECRET\");\n if (!secret || req.headers.get(\"x-telegram-bot-api-secret-token\") !== secret) {\n return new Response(\"forbidden\", { status: 403 });\n }\n if (!env(\"TELEGRAM_ALLOWED_USER_ID\")) return new Response(\"TELEGRAM_ALLOWED_USER_ID not configured\", { status: 503 });\n\n const update = (await req.json()) as Update;\n const message = update.message;\n if (!message?.text || !message.from) return new Response(\"ok\");\n\n const state = await stateLoad();\n // Telegram retries any update it did not get a 2xx for. Record the id before\n // doing work so a retry cannot run /new twice.\n if (update.update_id !== undefined) {\n if (state.seenUpdates.includes(update.update_id)) return new Response(\"ok\");\n state.seenUpdates.push(update.update_id);\n await stateSave(state);\n }\n\n const chatId = message.chat.id;\n if (!allowed(message.from.id)) {\n await sendText(chatId, `Not authorized (user id ${message.from.id}).`);\n return new Response(\"ok\");\n }\n state.chatId = chatId;\n\n let reply: string;\n let routeTo = state.activeSessionId;\n try {\n const text = message.text.trim();\n if (text.startsWith(\"/\")) {\n const [head, ...rest] = text.split(/\\s+/);\n reply = await handleCommand(state, chatId, head.slice(1).split(\"@\")[0].toLowerCase(), rest.join(\" \").trim());\n routeTo = state.activeSessionId;\n } else {\n const routed = message.reply_to_message ? state.msgToSession[String(message.reply_to_message.message_id)] : undefined;\n const sessionId = routed ?? requireActiveSession(state);\n await sessionSend(sessionId, text);\n reply = `→ ${(state.watched[sessionId] ?? watch(state, chatId, sessionId)).label}`;\n routeTo = sessionId;\n }\n } catch (error) {\n reply = `Error: ${(error as Error).message}`;\n }\n const sent = await sendText(chatId, reply, message.message_id);\n if (routeTo) for (const id of sent.ids) state.msgToSession[String(id)] = routeTo;\n await stateSave(state);\n return new Response(\"ok\");\n}\n\nfunction bearerMatches(req: Request, expected: string): boolean {\n const presented = (req.headers.get(\"authorization\") ?? \"\").replace(/^Bearer\\s+/i, \"\");\n if (!expected || presented.length !== expected.length) return false;\n let diff = 0;\n for (let i = 0; i < expected.length; i++) diff |= presented.charCodeAt(i) ^ expected.charCodeAt(i);\n return diff === 0;\n}\n\nasync function handleNotify(req: Request): Promise {\n if (!bearerMatches(req, env(\"CONDUCTOR_API_KEY\"))) return new Response(\"forbidden\", { status: 403 });\n const body = (await req.json()) as { sessionId?: string; workspaceId?: string; text?: string };\n if (!body.sessionId || !body.text) return new Response(\"bad request\", { status: 400 });\n\n const state = await stateLoad();\n const watched = state.watched[body.sessionId];\n const chatId = watched?.chatId ?? (state.notifyAll ? state.chatId : undefined);\n if (!chatId) return Response.json({ forwarded: false, reason: \"session not watched\" });\n\n const wsName = body.workspaceId ? state.names[body.workspaceId] : undefined;\n const label = watched?.label ?? (wsName ? `${wsName} › ${body.sessionId.slice(0, 8)}` : body.sessionId.slice(0, 8));\n const parts = chunk(body.text);\n const shown = parts.slice(0, MAX_CHUNKS_PER_NOTIFY);\n if (parts.length > shown.length) shown.push(`…(${parts.length - shown.length} more chunks truncated; use /last)`);\n const sent = await sendText(chatId, `[${label}]\\n${shown.join(\"\")}`);\n for (const id of sent.ids) state.msgToSession[String(id)] = body.sessionId;\n await stateSave(state);\n return Response.json({ forwarded: sent.ids.length > 0, delivered: sent.ids.length, error: sent.error });\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n if (req.method === \"POST\" && url.pathname === \"/telegram\") return handleTelegram(req);\n if (req.method === \"POST\" && url.pathname === \"/notify\") return handleNotify(req);\n if (req.method === \"POST\" && url.pathname === \"/setup\") {\n if (!bearerMatches(req, env(\"CONDUCTOR_API_KEY\"))) return new Response(\"forbidden\", { status: 403 });\n const state = await stateLoad();\n const result = await webhookRegister(state).catch((e: Error) => `webhook error: ${e.message}`);\n return Response.json({ result });\n }\n if (url.pathname === \"/health\") {\n // Read-only on purpose: registration is POST /setup behind the bearer.\n const state = await stateLoad();\n return Response.json({\n ok: true,\n webhookRegistered: state.webhookFor === webhookFingerprint() && Boolean(env(\"TELEGRAM_BOT_TOKEN\")),\n botTokenSet: Boolean(env(\"TELEGRAM_BOT_TOKEN\")),\n allowlistSet: Boolean(env(\"TELEGRAM_ALLOWED_USER_ID\")),\n conductorKeySet: Boolean(env(\"CONDUCTOR_API_KEY\")),\n watchedSessions: Object.keys(state.watched).length,\n notifyAll: state.notifyAll,\n });\n }\n return new Response(\"conductor-telegram-bridge: POST /telegram (webhook), POST /notify (Stop hook), POST /setup, GET /health\", {\n headers: { \"Content-Type\": \"text/plain\" },\n });\n}\n","deleted","label",[109],"pulls","branches","forks","envVars",{"_131":133,"_134":42},"connections",{"_131":42,"_132":42},"count","unfilledCount",5,"emptyCount",{"_18":108,"_20":109,"_110":36,"_111":-5,"_112":68,"_113":66,"_114":38,"_22":136,"_65":116,"_117":118,"_119":120,"_121":26,"_122":-5,"_137":138,"_85":139},["D",1788332128242],"children",[],[109],["D",1788331484791],{"_16":17,"_83":79},{"_16":17,"_77":-5,"_78":79,"_33":34,"_80":81,"_82":26},{"_65":66,"_20":67,"_18":68,"_69":19,"_70":-5,"_71":-5,"_72":-5,"_73":-5,"_74":-5,"_75":21,"_76":17},"ctx",{"_58":-5,"_104":177,"_178":179,"_180":181,"_182":26,"_183":26,"_184":26,"_185":38,"_186":-5,"_187":-7,"_188":-7,"_189":42,"_190":26,"_191":26,"_192":-5,"_193":26,"_194":26,"_195":26,"_196":-5},"ENV",{"_148":149,"_150":151,"_152":67,"_153":154,"_155":156,"_157":158,"_159":160,"_161":162,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","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"]

Search