[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_152":153,"_154":155},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":-7,"_18":19,"_17":-7,"_115":-5,"_20":116,"_22":117,"_118":119,"_120":121,"_26":122,"_24":123,"_124":-5,"_125":-5,"_126":52,"_127":128,"_129":43,"_130":-5,"_131":-5,"_132":133},"routes/_app.x.$handle.$name.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":25,"_26":27,"_28":-5,"_29":-5,"_30":-5,"_31":-5,"_32":-5},"handle","dhruvareddy","name","conductor-telegram-bridge","branchName","main","version","path","main.ts","project",{"_33":60,"_13":14,"_44":61,"_62":-5,"_63":52,"_64":65,"_66":65,"_67":68,"_69":-5,"_70":71,"_72":36,"_73":43,"_74":-5,"_75":-5,"_76":77,"_78":79,"_80":-5,"_81":-5,"_82":-5,"_83":-5,"_84":85,"_86":85,"_87":88,"_89":88,"_90":88,"_91":85,"_92":85,"_93":94,"_95":96,"_97":98,"_99":52},"tree",[55],"file",{"_33":34,"_13":19,"_35":36,"_37":-5,"_38":39,"_40":41,"_42":43,"_44":45,"_17":46,"_47":48,"_49":50,"_51":52,"_53":-5,"_18":54},"contents",[],"upstream","pull","ahead","behind","envVars","id","d0e9b3d7-2b91-4f6e-b833-5ce4c6bdbf13","fileId","f0e5dbb0-a699-11f1-8771-1607ee4eb77e","parentId","branchId","326a3659-7663-41b5-a5eb-41ceb847cd1f","branchVersion",2,"latest",true,"createdAt",["D",1788332128242],1,"fileType","http","content","// Telegram <-> Conductor bridge. Runs as a Val Town HTTP val.\n//\n// Inbound: Telegram webhook -> POST /telegram -> Conductor REST API\n// Outbound: Claude Code Stop hook in a Conductor workspace -> POST /notify -> Telegram\n//\n// No secrets live in this file. Environment variables (set on the val):\n// TELEGRAM_BOT_TOKEN from @BotFather\n// TELEGRAM_WEBHOOK_SECRET required; Telegram echoes it in a header on every webhook call\n// TELEGRAM_WEBHOOK_URL this val's public endpoint, used once by POST /setup\n// TELEGRAM_ALLOWED_USER_ID required; numeric Telegram user id(s), comma separated\n// CONDUCTOR_API_KEY Conductor API key. Also the bearer for POST /notify and POST /setup.\n// CONDUCTOR_PROJECT_ID default project for /new\n// CONDUCTOR_DEFAULT_MODEL default model for /new (e.g. fable-5-1)\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst CONDUCTOR_API = Deno.env.get(\"CONDUCTOR_API_URL\") ?? \"https://api.conductor.build\";\nconst TELEGRAM_API = \"https://api.telegram.org\";\nconst STATE_KEY = \"conductor-telegram-bridge/state.v2.json\";\nconst TELEGRAM_TEXT_LIMIT = 4000;\nconst MAX_CHUNKS_PER_NOTIFY = 3;\nconst CHUNK_SPACING_MS = 350;\nconst RETRY_AFTER_CAP_MS = 5000;\n// Insertion-ordered maps are trimmed to these sizes on every save so the blob\n// cannot grow without bound.\nconst CAPS = { msgToSession: 300, names: 200, watched: 50, seenUpdates: 100 };\n\ntype Watched = { chatId: number; label: string };\ntype State = {\n chatId?: number;\n conductorUserId?: string;\n activeWorkspaceId?: string;\n activeSessionId?: string;\n wsIndex: string[];\n sessionIndex: string[];\n watched: Record;\n notifyAll: boolean;\n model: string;\n msgToSession: Record;\n names: Record;\n seenUpdates: number[];\n webhookFor?: string;\n};\ntype SendResult = { ids: number[]; error?: string };\n\nconst env = (key: string): string => Deno.env.get(key) ?? \"\";\n\nasync function stateLoad(): Promise {\n const saved = await blob.getJSON(STATE_KEY).catch(() => null);\n return {\n wsIndex: [],\n sessionIndex: [],\n watched: {},\n notifyAll: false,\n model: env(\"CONDUCTOR_DEFAULT_MODEL\") || \"fable-5-1\",\n msgToSession: {},\n names: {},\n seenUpdates: [],\n ...(saved ?? {}),\n };\n}\n\nfunction trimMap(map: Record, cap: number): void {\n const keys = Object.keys(map);\n for (const key of keys.slice(0, Math.max(0, keys.length - cap))) delete map[key];\n}\n\nasync function stateSave(state: State): Promise {\n trimMap(state.msgToSession, CAPS.msgToSession);\n trimMap(state.names, CAPS.names);\n trimMap(state.watched, CAPS.watched);\n state.seenUpdates = state.seenUpdates.slice(-CAPS.seenUpdates);\n await blob.setJSON(STATE_KEY, state);\n}\n\n// ---------- Conductor ----------\n\nasync function conductor(path: string, init: RequestInit = {}): Promise {\n const res = await fetch(`${CONDUCTOR_API}${path}`, {\n ...init,\n headers: {\n Authorization: `Bearer ${env(\"CONDUCTOR_API_KEY\")}`,\n \"Content-Type\": \"application/json\",\n ...(init.headers ?? {}),\n },\n });\n const text = await res.text();\n if (!res.ok) throw new Error(`Conductor ${init.method ?? \"GET\"} ${path} -> ${res.status}: ${text.slice(0, 300)}`);\n return text ? (JSON.parse(text) as T) : (undefined as T);\n}\n\ntype Workspace = {\n id: string;\n name: string;\n state: string;\n lifecycleStep?: string;\n lastActivityAt?: string;\n createdAt?: string;\n};\ntype Session = { id: string; name?: string; model?: string; archivedAt?: string };\ntype SessionStatus = { status: string; errorMessage?: string };\n\nasync function conductorUserId(state: State): Promise {\n if (state.conductorUserId) return state.conductorUserId;\n const me = await conductor<{ userId?: string }>(\"/me\");\n if (!me.userId) throw new Error(\"could not resolve Conductor user id from /me\");\n state.conductorUserId = me.userId;\n return me.userId;\n}\n\nasync function workspacesList(state: State, limit = 10): Promise {\n const creator = await conductorUserId(state);\n const res = await conductor<{ data: Workspace[] }>(\n `/v0/workspaces?creator=${encodeURIComponent(creator)}&limit=${limit}`,\n );\n const rows = (res.data ?? []).filter((w) => w.state !== \"archived\" && w.state !== \"deleted\");\n rows.sort((a, b) => (b.lastActivityAt ?? b.createdAt ?? \"\").localeCompare(a.lastActivityAt ?? a.createdAt ?? \"\"));\n return rows;\n}\n\nasync function sessionsList(workspaceId: string, limit = 10): Promise {\n const res = await conductor<{ data: Session[] }>(`/v0/workspaces/${workspaceId}/sessions?limit=${limit}`);\n return (res.data ?? []).filter((s) => !s.archivedAt);\n}\n\nasync function sessionSend(sessionId: string, message: string): Promise {\n await conductor(`/v0/sessions/${sessionId}/messages`, { method: \"POST\", body: JSON.stringify({ message }) });\n}\n\nasync function transcriptTail(sessionId: string, chars = 3000): Promise {\n const safeId = sessionId.replace(/[^0-9a-f-]/gi, \"\");\n const query = `SELECT transcript FROM session_transcripts_view WHERE session_id = '${safeId}' LIMIT 1`;\n const res = await conductor<{ rows: Array<{ transcript?: string }> }>(\"/v0/sql\", {\n method: \"POST\",\n body: JSON.stringify({ query }),\n });\n const transcript = res.rows?.[0]?.transcript ?? \"\";\n return transcript.length > chars ? `…${transcript.slice(-chars)}` : transcript;\n}\n\nconst workspaceWebLink = (workspaceId: string): string => `https://app.conductor.build/workspace/${workspaceId}`;\n\n// ---------- Telegram ----------\n\nconst sleep = (ms: number): Promise => new Promise((resolve) => setTimeout(resolve, ms));\n\nasync function telegram(method: string, body: Record, retried = false): Promise {\n const res = await fetch(`${TELEGRAM_API}/bot${env(\"TELEGRAM_BOT_TOKEN\")}/${method}`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(body),\n });\n const json = (await res.json()) as {\n ok: boolean;\n result?: T;\n description?: string;\n parameters?: { retry_after?: number };\n };\n if (json.ok) return json.result as T;\n const retryAfter = json.parameters?.retry_after;\n if (res.status === 429 && retryAfter && !retried) {\n await sleep(Math.min(retryAfter * 1000, RETRY_AFTER_CAP_MS));\n return telegram(method, body, true);\n }\n throw new Error(`Telegram ${method}: ${json.description ?? res.status}`);\n}\n\nfunction chunk(text: string, size = TELEGRAM_TEXT_LIMIT): string[] {\n const out: string[] = [];\n let rest = text;\n while (rest.length > size) {\n let cut = rest.lastIndexOf(\"\\n\", size);\n if (cut < size / 2) cut = size;\n out.push(rest.slice(0, cut));\n rest = rest.slice(cut);\n }\n if (rest) out.push(rest);\n return out;\n}\n\n// Never throws: returns the ids that were delivered plus the first error, so\n// callers can persist reply-routing for what did land.\nasync function sendText(chatId: number, text: string, replyTo?: number): Promise {\n const ids: number[] = [];\n const parts = chunk(text);\n for (const [i, part] of parts.entries()) {\n if (i > 0) await sleep(CHUNK_SPACING_MS);\n try {\n const msg = await telegram<{ message_id: number }>(\"sendMessage\", {\n chat_id: chatId,\n text: part,\n disable_web_page_preview: true,\n ...(i === 0 && replyTo ? { reply_to_message_id: replyTo, allow_sending_without_reply: true } : {}),\n });\n ids.push(msg.message_id);\n } catch (error) {\n return { ids, error: (error as Error).message };\n }\n }\n return { ids };\n}\n\nfunction webhookFingerprint(): string {\n return `${env(\"TELEGRAM_BOT_TOKEN\").slice(0, 12)}|${env(\"TELEGRAM_WEBHOOK_URL\")}|${env(\"TELEGRAM_WEBHOOK_SECRET\").slice(0, 6)}`;\n}\n\nasync function webhookRegister(state: State): Promise {\n for (const key of [\"TELEGRAM_BOT_TOKEN\", \"TELEGRAM_WEBHOOK_SECRET\", \"TELEGRAM_WEBHOOK_URL\", \"TELEGRAM_ALLOWED_USER_ID\"]) {\n if (!env(key)) return `${key} not set`;\n }\n await telegram(\"setWebhook\", {\n url: `${env(\"TELEGRAM_WEBHOOK_URL\").replace(/\\/$/, \"\")}/telegram`,\n secret_token: env(\"TELEGRAM_WEBHOOK_SECRET\"),\n allowed_updates: [\"message\"],\n drop_pending_updates: false,\n });\n await telegram(\"setMyCommands\", {\n commands: [\n { command: \"ws\", description: \"List my workspaces\" },\n { command: \"use\", description: \"use : make workspace n active\" },\n { command: \"sessions\", description: \"List sessions in the active workspace\" },\n { command: \"session\", description: \"session : make session n active\" },\n { command: \"new\", description: \"new : create a workspace and start on it\" },\n { command: \"newsession\", description: \"newsession : new session in active workspace\" },\n { command: \"status\", description: \"Active session status\" },\n { command: \"last\", description: \"Tail of the active session transcript\" },\n { command: \"watch\", description: \"Forward replies from the active session here\" },\n { command: \"unwatch\", description: \"Stop forwarding the active session\" },\n { command: \"notifyall\", description: \"notifyall on|off: forward every cloud session\" },\n { command: \"model\", description: \"model : default model for /new\" },\n { command: \"cancel\", description: \"Cancel the running turn\" },\n { command: \"sleep\", description: \"Put the active workspace to sleep\" },\n { command: \"link\", description: \"Web link for the active workspace\" },\n { command: \"help\", description: \"Show help\" },\n ],\n });\n state.webhookFor = webhookFingerprint();\n await stateSave(state);\n return \"webhook registered\";\n}\n\n// ---------- command handling ----------\n\nconst HELP = `Conductor bridge\n\n/ws list my workspaces\n/use make workspace n active (picks its latest session)\n/sessions list sessions in the active workspace\n/session make session n active\n/new create a workspace and send the prompt\n/newsession

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",false,"label",[19],{"_33":34,"_13":19,"_35":36,"_37":-5,"_38":39,"_40":41,"_42":43,"_44":56,"_17":46,"_47":48,"_49":50,"_51":52,"_53":-5,"_57":58,"_18":59},["D",1788332128242],"children",[],[19],"02c327a7-2d97-4eaa-94e7-937ab4f420c9",["D",1788331484791],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Telegram <-> Conductor cloud workspaces bridge","imageUrl","userId","019d4071-030b-75d1-a5a0-0f76530bae14","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019d4071-030b-75d1-a5a0-110dc0761f71","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_114":110},"org",{"_11":12,"_108":-5,"_109":110,"_70":71,"_111":112,"_113":52},"branch",{"_17":41,"_13":16,"_33":39,"_100":60,"_101":-5,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":14,"_107":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzNCZ0Y2dERUcUUxeVpyMUFQQ1VaS3pKNXRBYSJ9","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_33":60,"_13":14,"_44":148,"_62":-5,"_63":52,"_64":65,"_66":65,"_67":68,"_69":-5,"_70":71,"_72":36,"_73":43,"_74":-5,"_75":-5,"_76":77,"_78":79,"_80":-5,"_81":-5,"_82":-5,"_83":-5,"_84":85,"_86":85,"_87":88,"_89":88,"_90":88,"_91":85,"_92":85,"_93":149,"_95":150,"_97":151,"_99":52},[145],"files",[145],"counts",{"_135":77,"_136":46,"_137":77,"_32":138,"_139":140},[],{"_33":34,"_13":19,"_35":36,"_37":-5,"_38":39,"_40":41,"_42":43,"_44":45,"_17":46,"_47":48,"_49":50,"_51":52,"_53":-5,"_18":134},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},[19],"pulls","branches","forks",{"_141":143,"_144":77},"connections",{"_141":77,"_142":77},"count","unfilledCount",5,"emptyCount",{"_33":34,"_13":19,"_35":36,"_37":-5,"_38":39,"_40":41,"_42":43,"_44":56,"_17":46,"_47":48,"_49":50,"_51":52,"_53":-5,"_57":146,"_18":147},[],[19],["D",1788331484791],{"_11":12,"_114":110},{"_11":12,"_108":-5,"_109":110,"_70":71,"_111":112,"_113":52},{"_17":41,"_13":16,"_33":39,"_100":60,"_101":-5,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":14,"_107":12},"ctx",{"_93":-5,"_131":185,"_186":187,"_188":189,"_190":52,"_191":52,"_192":52,"_193":43,"_194":-5,"_195":-7,"_196":-7,"_197":77,"_198":52,"_199":52,"_200":-5,"_201":52,"_202":52,"_203":52,"_204":-5},"ENV",{"_156":157,"_158":159,"_160":16,"_161":162,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184},"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"]