[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_224":225,"_226":227},"routes/_app.x.$handle.$name",{"_100":99,"_32":45,"_108":90,"_27":109,"_13":14,"_110":-5,"_11":111,"_112":113,"_114":115,"_116":117,"_118":119,"_20":-5,"_120":-5,"_121":-5,"_122":25,"_123":124,"_125":59,"_126":-5,"_127":-5,"_128":129},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":25},"version",118,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","alice.ts","latestPath","fileId","99cbc6c4-841f-11f1-b96e-1607ee4eb77e","name","fileType","script","content","// Alice WebSocket client — alice.yandex.ru via uniproxy\n// Session pool + dialog continuity + retries\n\nconst UNIPROXY_URL = \"wss://uniproxy.alice.yandex.ru/uni.ws\";\r\nconst ALICE_PAGE_URL = \"https://alice.yandex.ru/\";\r\nconst APP_ID = \"ru.yandex.webstandalone.desktop\";\r\n\r\nconst SESSION_TTL_MS = 4 * 60_000;\r\nconst DIALOG_TTL_MS = 15 * 60_000;\r\nconst MAX_RETRIES = 2;\r\n\r\n// From alice.yandex.ru bootstrap (anon web)\r\n// Base = \"YandexGPT 5 Lite без Поиска\" — dumb for facts\r\n// Pro = more capable; still may need our tools\r\n// Pro = better model; Base = \"без Поиска\" (avoid)\r\nconst ALICE_MODE = { mode: \"Pro\", preset: \"\" };\r\n\r\nconst SUPPORTED_FEATURES = [\r\n \"background_response_streaming\",\r\n \"background_response_streaming_anon\",\r\n \"supports_bso_answer\",\r\n \"open_link\",\r\n \"server_action\",\r\n \"supports_streaming_response\",\r\n \"supports_rich_json_cards\",\r\n \"supports_new_sources_cards\",\r\n \"supports_markdown_response\",\r\n \"supports_unlimited_dialogs_creation\",\r\n \"supports_multi_model_dialogs\",\r\n \"print_text_in_message_view\",\r\n \"show_loader_directive\",\r\n \"supports_default_dialog_as_dedicated\",\r\n \"supports_origin_in_separate_card\",\r\n \"div2_cards\",\r\n];\r\n\r\nconst EXPERIMENTS = [\r\n \"mm_allow_anonymous_request\",\r\n \"read_dialogs_for_unauthorized_users\",\r\n \"standalone_alice_2_0\",\r\n \"enable_find_poi_standalone\",\r\n \"exp_flag_chat_dialog_history\",\r\n \"mm_enable_protocol_scenario=WebAliceControls\",\r\n];\r\n\r\n// Saint Petersburg default (not US DC / not Chelyabinsk)\r\nconst DEFAULT_LOCATION = {\r\n lat: 59.9311,\r\n lon: 30.3609,\r\n accuracy: 10000,\r\n};\r\nconst DEFAULT_TZ = \"Europe/Moscow\"; // MSK = SPb\n\nexport interface AliceSession {\n sk: string;\n uuid: string;\n cookies: string;\n createdAt: number;\n}\n\nexport interface AliceResponseChunk {\n text: string;\n done: boolean;\n dialogId?: string;\n raw: unknown;\n}\n\nexport interface SendOptions {\n dialogId?: string;\n resetSession?: boolean;\n timeoutMs?: number;\n}\n\n// ── Pools (warm isolate memory) ─────────────────────────────\n\nlet cachedSession: AliceSession | null = null;\n\nconst dialogStore = new Map<\n string,\n { dialogId: string; updatedAt: number }\n>();\n\nfunction sleep(ms: number): Promise {\n return new Promise((r) => setTimeout(r, ms));\n}\n\nfunction genId(): string {\n return Array.from(crypto.getRandomValues(new Uint8Array(16)), (b) =>\n b.toString(16).padStart(2, \"0\"),\n ).join(\"\");\n}\n\nfunction purgeDialogs() {\n const now = Date.now();\n for (const [k, v] of dialogStore) {\n if (now - v.updatedAt > DIALOG_TTL_MS) dialogStore.delete(k);\n }\n}\n\nexport function rememberDialog(key: string, dialogId: string) {\n if (!key || !dialogId) return;\n purgeDialogs();\n dialogStore.set(key, { dialogId, updatedAt: Date.now() });\n}\n\nexport function recallDialog(key: string): string | undefined {\n if (!key) return undefined;\n purgeDialogs();\n const hit = dialogStore.get(key);\n if (!hit) return undefined;\n hit.updatedAt = Date.now();\n return hit.dialogId;\n}\n\n/** Conversation fingerprint for dialog continuity without client header. */\nexport function conversationKey(messages: Array<{ role: string; content: string }>): string {\n // hash user turns only (ignore huge system dumps from OpenCode)\n const seed = messages\n .filter((m) => m.role === \"user\")\n .slice(0, 4)\n .map((m) => m.content.slice(0, 120))\n .join(\"|\");\n let h = 0x811c9dc5;\n for (let i = 0; i < seed.length; i++) {\n h ^= seed.charCodeAt(i);\n h = Math.imul(h, 0x01000193);\n }\n return (h >>> 0).toString(16);\n}\n\n// ── Session ─────────────────────────────────────────────────\n\nasync function fetchFreshSession(): Promise {\n const resp = await fetch(ALICE_PAGE_URL, {\n headers: {\n \"User-Agent\":\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36\",\n Accept: \"text/html,application/xhtml+xml\",\n \"Accept-Language\": \"ru-RU,ru;q=0.9,en;q=0.8\",\n },\n });\n\n if (!resp.ok) {\n throw new Error(`Alice page HTTP ${resp.status}`);\n }\n\n const html = await resp.text();\n const sk = html.match(/\"sk\":\"([^\"]+)\"/)?.[1] ?? \"\";\n const uuid = html.match(/\"uuid\":\"([^\"]+)\"/)?.[1] ?? \"\";\n const setCookies = resp.headers.getSetCookie?.() ?? [];\n const cookies = setCookies.map((c) => c.split(\";\")[0]).join(\"; \");\n\n if (!sk || !uuid) {\n throw new Error(\"Failed to extract sk/uuid from alice.yandex.ru\");\n }\n\n return { sk, uuid, cookies, createdAt: Date.now() };\n}\n\nexport async function getSession(force = false): Promise {\n if (\n !force &&\n cachedSession &&\n Date.now() - cachedSession.createdAt < SESSION_TTL_MS\n ) {\n return cachedSession;\n }\n cachedSession = await fetchFreshSession();\n return cachedSession;\n}\n\nexport function invalidateSession() {\n cachedSession = null;\n}\n\n// ── Response parse ──────────────────────────────────────────\n\n// deno-lint-ignore no-explicit-any\nfunction extractResponseText(response: any): string {\n if (!response) return \"\";\n return (\n response.card?.text ??\n response.cards?.[0]?.text ??\n response.text ??\n response.output_speech?.text ??\n response.json_response?.text ??\n response.json_response?.card?.text ??\n \"\"\n );\n}\n\n// deno-lint-ignore no-explicit-any\nfunction extractDialogId(parsed: any, payload: any): string | undefined {\n const candidates = [\n payload?.response?.dialog_id,\n payload?.response?.dialogId,\n payload?.dialog_id,\n payload?.dialogId,\n parsed?.directive?.payload?.response?.card?.dialog_id,\n payload?.header?.dialog_id,\n payload?.response?.header?.dialog_id,\n ];\n for (const c of candidates) {\n if (typeof c === \"string\" && c.length > 0) return c;\n }\n // deep-ish scan for dialog_id key (capped)\n const raw = JSON.stringify(payload ?? {}).slice(0, 50_000);\n const m = raw.match(/\"dialog_id\"\\s*:\\s*\"([^\"]+)\"/);\n if (m?.[1]) return m[1];\n const m2 = raw.match(/\"dialogId\"\\s*:\\s*\"([^\"]+)\"/);\n if (m2?.[1]) return m2[1];\n const m3 = raw.match(/\"DialogId\"\\s*:\\s*\"([^\"]+)\"/);\n if (m3?.[1]) return m3[1];\n return undefined;\n}\n\n// ── Core WS turn ────────────────────────────────────────────\n\nasync function* sendToAliceOnce(\n text: string,\n session: AliceSession,\n opts: SendOptions = {},\n): AsyncGenerator {\n const { sk, uuid } = session;\n const dialogId = opts.dialogId ?? \"\";\n const resetSession = opts.resetSession ?? !dialogId;\n const timeoutMs = opts.timeoutMs ?? 45_000;\n let seqNum = 0;\n\n const messageQueue: string[] = [];\n let wsClosed = false;\n let wsError: Error | null = null;\n\n const ws = new WebSocket(UNIPROXY_URL);\n\n ws.onmessage = (event) => {\n messageQueue.push(String(event.data));\n };\n ws.onerror = () => {\n wsError = new Error(\"WebSocket error\");\n };\n ws.onclose = () => {\n wsClosed = true;\n };\n\n await new Promise((resolve, reject) => {\n const t = setTimeout(() => reject(new Error(\"WS connect timeout\")), 12_000);\n ws.onopen = () => {\n clearTimeout(t);\n resolve();\n };\n ws.onerror = () => {\n clearTimeout(t);\n reject(new Error(\"WS connection failed\"));\n };\n });\n\n ws.onerror = () => {\n wsError = new Error(\"WebSocket error\");\n };\n\n ws.send(\n JSON.stringify({\n event: {\n header: {\n namespace: \"System\",\n name: \"SynchronizeState\",\n messageId: genId(),\n seqNumber: seqNum++,\n },\n payload: {\n accept_invalid_auth: true,\n auth_token: sk,\n uuid,\n vins: {\n application: {\n app_id: APP_ID,\n platform: \"desktop\",\n device_id: uuid,\n device_model: \"desktop\",\n },\n },\n supported_features: SUPPORTED_FEATURES,\r\n request: { experiments: EXPERIMENTS },\r\n speechkitVersion: \"4.16.7\",\r\n },\r\n },\r\n }),\r\n );\n\n let authenticated = false;\n const authDeadline = Date.now() + 8_000;\n while (!authenticated && Date.now() < authDeadline && !wsClosed) {\n if (wsError) throw wsError;\n if (messageQueue.length > 0) {\n const msg = messageQueue.shift()!;\n if (msg.includes(\"SynchronizeStateResponse\")) authenticated = true;\n if (msg.includes(\"InvalidAuth\")) {\n throw new Error(\"Alice InvalidAuth\");\n }\n } else {\n await sleep(30);\n }\n }\n\n if (!authenticated) {\n try {\n ws.close();\n } catch {\n /* */\n }\n throw new Error(\"Authentication failed\");\n }\n\n const requestId = genId();\n const messageId = genId();\n const now = new Date();\n const clientTime = now.toISOString().slice(0, 19).replace(/[:+-]/g, \"\");\n const timestamp = String(Date.now()).slice(0, -3);\n\n ws.send(\n JSON.stringify({\n event: {\n header: {\n namespace: \"Vins\",\n name: \"TextInput\",\n messageId,\n seqNumber: seqNum++,\n },\n payload: {\n application: {\n app_id: APP_ID,\n app_version: \"1.114.1\",\n platform: \"desktop\",\n os_version: \"linux\",\n uuid,\n device_id: uuid,\n lang: \"ru-RU\",\n client_time: clientTime,\n timezone: DEFAULT_TZ,\r\n timestamp,\r\n device_model: \"desktop\",\r\n },\r\n header: {\r\n prev_req_id: null,\r\n request_id: requestId,\r\n dialog_id: dialogId,\r\n dialog_type: \"DEDICATED_CHAT\",\r\n },\r\n // CRITICAL: alice_2_settings — without this Alice defaults to Base (no search)\r\n alice_2_settings: ALICE_MODE,\n request: {\r\n event: {\r\n type: \"text_input\",\r\n text,\r\n },\r\n voice_session: false,\r\n experiments: EXPERIMENTS,\r\n uniproxy_options: {\r\n background_response_streaming_options: {\r\n request_with_shown_new_dialog: resetSession ? {} : undefined,\r\n },\r\n },\r\n additional_options: {\r\n origin_domain: \"yandex.ru\",\r\n supported_features: SUPPORTED_FEATURES,\r\n unsupported_features: [],\r\n },\r\n location: DEFAULT_LOCATION,\r\n reset_session: resetSession,\r\n },\r\n },\r\n },\r\n }),\r\n );\n\n let fullText = \"\";\n let responseDone = false;\n let lastDialogId: string | undefined = dialogId || undefined;\n const responseDeadline = Date.now() + timeoutMs;\n\n while (!responseDone && Date.now() < responseDeadline && !wsClosed) {\n if (wsError) {\n try {\n ws.close();\n } catch {\n /* */\n }\n throw wsError;\n }\n\n if (messageQueue.length === 0) {\n await sleep(25);\n continue;\n }\n\n const rawMsg = messageQueue.shift()!;\n if (rawMsg.includes(\"InputStartAck\")) continue;\n if (rawMsg.includes(\"SynchronizeStateResponse\")) continue;\n\n // deno-lint-ignore no-explicit-any\n let parsed: any;\n try {\n parsed = JSON.parse(rawMsg);\n } catch {\n continue;\n }\n\n const directive = parsed.directive;\n if (!directive) {\n // some streaming frames nest differently\n if (parsed.streaming && parsed.directive === undefined) continue;\n continue;\n }\n\n const headerName = directive.header?.name as string | undefined;\n const payload = directive.payload;\n\n if (headerName === \"EventException\") {\n const errMsg = payload?.error?.message ?? \"Alice API error\";\n try {\n ws.close();\n } catch {\n /* */\n }\n throw new Error(errMsg);\n }\n\n if (headerName === \"VinsResponse\" || headerName === \"DeferredAliceResponse\") {\n const response = payload?.response;\n const foundDialog = extractDialogId(parsed, payload);\n if (foundDialog) lastDialogId = foundDialog;\n\n const replyText = extractResponseText(response);\n if (replyText && replyText !== fullText) {\n const delta = replyText.startsWith(fullText)\n ? replyText.slice(fullText.length)\n : replyText;\n fullText = replyText;\n if (delta) {\n yield {\n text: delta,\n done: false,\n dialogId: lastDialogId,\n raw: parsed,\n };\n }\n }\n\n if (headerName === \"VinsResponse\" && !response?.is_streaming) {\n responseDone = true;\n yield {\n text: \"\",\n done: true,\n dialogId: lastDialogId,\n raw: parsed,\n };\n }\n continue;\n }\n\n if (headerName === \"DialogControl\") {\n const foundDialog = extractDialogId(parsed, payload);\n if (foundDialog) lastDialogId = foundDialog;\n if (payload?.is_final || payload?.finished) {\n responseDone = true;\n yield {\n text: \"\",\n done: true,\n dialogId: lastDialogId,\n raw: parsed,\n };\n }\n }\n }\n\n if (!responseDone && fullText) {\n yield { text: \"\", done: true, dialogId: lastDialogId, raw: null };\n }\n\n if (!fullText && !responseDone) {\n try {\n ws.close();\n } catch {\n /* */\n }\n throw new Error(\"Alice timeout — empty response\");\n }\n\n try {\n ws.close();\n } catch {\n /* */\n }\n}\n\nfunction isRetryable(err: unknown): boolean {\n const msg = err instanceof Error ? err.message : String(err);\n return /timeout|WebSocket|Authentication|InvalidAuth|failed|429|502|503|EOF|network/i\n .test(msg);\n}\n\n/** Stream Alice reply with retries + session refresh. */\nexport async function* sendToAlice(\n text: string,\n session?: AliceSession,\n dialogIdOrOpts: string | SendOptions = \"\",\n): AsyncGenerator {\n const opts: SendOptions =\n typeof dialogIdOrOpts === \"string\"\n ? { dialogId: dialogIdOrOpts }\n : dialogIdOrOpts;\n\n const maxTry = (opts.timeoutMs ?? 45_000) <= 12_000 ? 1 : MAX_RETRIES;\r\n let lastErr: unknown;\r\n for (let attempt = 1; attempt <= maxTry; attempt++) {\r\n try {\r\n const sess = session && attempt === 1\r\n ? session\r\n : await getSession(attempt > 1);\r\n let finalDialog = opts.dialogId;\r\n for await (const chunk of sendToAliceOnce(text, sess, {\r\n ...opts,\r\n dialogId: finalDialog ?? opts.dialogId,\r\n })) {\r\n if (chunk.dialogId) finalDialog = chunk.dialogId;\r\n yield chunk;\r\n }\r\n return;\r\n } catch (err) {\r\n lastErr = err;\r\n console.log(\r\n JSON.stringify({\r\n level: \"warn\",\r\n event: \"alice_retry\",\r\n attempt,\r\n maxTry,\r\n error: err instanceof Error ? err.message : String(err),\r\n }),\r\n );\r\n invalidateSession();\r\n if (!isRetryable(err) || attempt === maxTry) break;\r\n await sleep(250 * attempt * attempt);\r\n }\r\n }\n throw lastErr instanceof Error\n ? lastErr\n : new Error(String(lastErr));\n}\n\nexport async function askAlice(\n text: string,\n session?: AliceSession,\n opts: SendOptions = {},\n): Promise<{ text: string; dialogId?: string }> {\n let full = \"\";\n let dialogId = opts.dialogId;\n for await (const chunk of sendToAlice(text, session, opts)) {\n full += chunk.text;\n if (chunk.dialogId) dialogId = chunk.dialogId;\n }\n return { text: full, dialogId };\n}\n\n/** Cheap readiness: reuse pool or fetch session. */\nexport async function pingAlice(): Promise<{ ok: boolean; ms: number; cached: boolean }> {\n const t0 = Date.now();\n const cached = !!(\n cachedSession && Date.now() - cachedSession.createdAt < SESSION_TTL_MS\n );\n try {\n await getSession();\n return { ok: true, ms: Date.now() - t0, cached };\n } catch {\n return { ok: false, ms: Date.now() - t0, cached: false };\n }\n}\n\n// bust 2026-07-20T15:09:37.0161522+05:00\r\n","// Alice WebSocket client — alice.yandex.ru via uniproxy\n// Session pool + dialog continuity + retries\n\nconst UNIPROXY_URL = \"wss://uniproxy.alice.yandex.ru/uni.ws\";\r\nconst ALICE_PAGE_URL = \"https://alice.yandex.ru/\";\r\nconst APP_ID = \"ru.yandex.webstandalone.desktop\";\r\n\r\nconst SESSION_TTL_MS = 4 * 60_000;\r\nconst DIALOG_TTL_MS = 15 * 60_000;\r\nconst MAX_RETRIES = 2;\r\n\r\n// From alice.yandex.ru bootstrap (anon web)\r\n// Base = \"YandexGPT 5 Lite без Поиска\" — dumb for facts\r\n// Pro = more capable; still may need our tools\r\n// Pro = better model; Base = \"без Поиска\" (avoid)\r\nconst ALICE_MODE = { mode: \"Pro\", preset: \"\" };\r\n\r\nconst SUPPORTED_FEATURES = [\r\n \"background_response_streaming\",\r\n \"background_response_streaming_anon\",\r\n \"supports_bso_answer\",\r\n \"open_link\",\r\n \"server_action\",\r\n \"supports_streaming_response\",\r\n \"supports_rich_json_cards\",\r\n \"supports_new_sources_cards\",\r\n \"supports_markdown_response\",\r\n \"supports_unlimited_dialogs_creation\",\r\n \"supports_multi_model_dialogs\",\r\n \"print_text_in_message_view\",\r\n \"show_loader_directive\",\r\n \"supports_default_dialog_as_dedicated\",\r\n \"supports_origin_in_separate_card\",\r\n \"div2_cards\",\r\n];\r\n\r\nconst EXPERIMENTS = [\r\n \"mm_allow_anonymous_request\",\r\n \"read_dialogs_for_unauthorized_users\",\r\n \"standalone_alice_2_0\",\r\n \"enable_find_poi_standalone\",\r\n \"exp_flag_chat_dialog_history\",\r\n \"mm_enable_protocol_scenario=WebAliceControls\",\r\n];\r\n\r\n// Saint Petersburg default (not US DC / not Chelyabinsk)\r\nconst DEFAULT_LOCATION = {\r\n lat: 59.9311,\r\n lon: 30.3609,\r\n accuracy: 10000,\r\n};\r\nconst DEFAULT_TZ = \"Europe/Moscow\"; // MSK = SPb\n\nexport interface AliceSession {\n sk: string;\n uuid: string;\n cookies: string;\n createdAt: number;\n}\n\nexport interface AliceResponseChunk {\n text: string;\n done: boolean;\n dialogId?: string;\n raw: unknown;\n}\n\nexport interface SendOptions {\n dialogId?: string;\n resetSession?: boolean;\n timeoutMs?: number;\n}\n\n// ── Pools (warm isolate memory) ─────────────────────────────\n\nlet cachedSession: AliceSession | null = null;\n\nconst dialogStore = new Map<\n string,\n { dialogId: string; updatedAt: number }\n>();\n\nfunction sleep(ms: number): Promise {\n return new Promise((r) => setTimeout(r, ms));\n}\n\nfunction genId(): string {\n return Array.from(crypto.getRandomValues(new Uint8Array(16)), (b) =>\n b.toString(16).padStart(2, \"0\"),\n ).join(\"\");\n}\n\nfunction purgeDialogs() {\n const now = Date.now();\n for (const [k, v] of dialogStore) {\n if (now - v.updatedAt > DIALOG_TTL_MS) dialogStore.delete(k);\n }\n}\n\nexport function rememberDialog(key: string, dialogId: string) {\n if (!key || !dialogId) return;\n purgeDialogs();\n dialogStore.set(key, { dialogId, updatedAt: Date.now() });\n}\n\nexport function recallDialog(key: string): string | undefined {\n if (!key) return undefined;\n purgeDialogs();\n const hit = dialogStore.get(key);\n if (!hit) return undefined;\n hit.updatedAt = Date.now();\n return hit.dialogId;\n}\n\n/** Conversation fingerprint for dialog continuity without client header. */\nexport function conversationKey(messages: Array<{ role: string; content: string }>): string {\n // hash user turns only (ignore huge system dumps from OpenCode)\n const seed = messages\n .filter((m) => m.role === \"user\")\n .slice(0, 4)\n .map((m) => m.content.slice(0, 120))\n .join(\"|\");\n let h = 0x811c9dc5;\n for (let i = 0; i < seed.length; i++) {\n h ^= seed.charCodeAt(i);\n h = Math.imul(h, 0x01000193);\n }\n return (h >>> 0).toString(16);\n}\n\n// ── Session ─────────────────────────────────────────────────\n\nasync function fetchFreshSession(): Promise {\n const resp = await fetch(ALICE_PAGE_URL, {\n headers: {\n \"User-Agent\":\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36\",\n Accept: \"text/html,application/xhtml+xml\",\n \"Accept-Language\": \"ru-RU,ru;q=0.9,en;q=0.8\",\n },\n });\n\n if (!resp.ok) {\n throw new Error(`Alice page HTTP ${resp.status}`);\n }\n\n const html = await resp.text();\n const sk = html.match(/\"sk\":\"([^\"]+)\"/)?.[1] ?? \"\";\n const uuid = html.match(/\"uuid\":\"([^\"]+)\"/)?.[1] ?? \"\";\n const setCookies = resp.headers.getSetCookie?.() ?? [];\n const cookies = setCookies.map((c) => c.split(\";\")[0]).join(\"; \");\n\n if (!sk || !uuid) {\n throw new Error(\"Failed to extract sk/uuid from alice.yandex.ru\");\n }\n\n return { sk, uuid, cookies, createdAt: Date.now() };\n}\n\nexport async function getSession(force = false): Promise {\n if (\n !force &&\n cachedSession &&\n Date.now() - cachedSession.createdAt < SESSION_TTL_MS\n ) {\n return cachedSession;\n }\n cachedSession = await fetchFreshSession();\n return cachedSession;\n}\n\nexport function invalidateSession() {\n cachedSession = null;\n}\n\n// ── Response parse ──────────────────────────────────────────\n\n// deno-lint-ignore no-explicit-any\r\nfunction extractResponseText(response: any): string {\r\n if (!response) return \"\";\r\n const direct = [\r\n response.card?.text,\r\n response.cards?.[0]?.text,\r\n response.text,\r\n response.output_speech?.text,\r\n response.json_response?.text,\r\n response.json_response?.card?.text,\r\n response.markdown,\r\n response.card?.markdown,\r\n response.message?.text,\r\n response.answer,\r\n ];\r\n for (const d of direct) {\r\n if (typeof d === \"string\" && d.trim()) return d.trim();\r\n }\r\n // cards array deep\r\n if (Array.isArray(response.cards)) {\r\n for (const c of response.cards) {\r\n const t = c?.text ?? c?.markdown ?? c?.content?.text;\r\n if (typeof t === \"string\" && t.trim()) return t.trim();\r\n }\r\n }\r\n // last resort: first longish \"text\" field in JSON (capped)\r\n try {\r\n const raw = JSON.stringify(response).slice(0, 80_000);\r\n const re = /\"(?:text|markdown|message)\"\\s*:\\s*\"((?:\\\\.|[^\"\\\\]){12,})\"/g;\r\n let best = \"\";\r\n let m: RegExpExecArray | null;\r\n while ((m = re.exec(raw)) !== null) {\r\n const s = m[1]\r\n .replace(/\\\\n/g, \"\\n\")\r\n .replace(/\\\\\"/g, '\"')\r\n .replace(/\\\\\\\\/g, \"\\\\\")\r\n .trim();\r\n if (s.length > best.length && !/dialog_id|request_id/i.test(s)) {\r\n best = s;\r\n }\r\n }\r\n if (best) return best;\r\n } catch {\r\n /* */\r\n }\r\n return \"\";\r\n}\n\n// deno-lint-ignore no-explicit-any\nfunction extractDialogId(parsed: any, payload: any): string | undefined {\n const candidates = [\n payload?.response?.dialog_id,\n payload?.response?.dialogId,\n payload?.dialog_id,\n payload?.dialogId,\n parsed?.directive?.payload?.response?.card?.dialog_id,\n payload?.header?.dialog_id,\n payload?.response?.header?.dialog_id,\n ];\n for (const c of candidates) {\n if (typeof c === \"string\" && c.length > 0) return c;\n }\n // deep-ish scan for dialog_id key (capped)\n const raw = JSON.stringify(payload ?? {}).slice(0, 50_000);\n const m = raw.match(/\"dialog_id\"\\s*:\\s*\"([^\"]+)\"/);\n if (m?.[1]) return m[1];\n const m2 = raw.match(/\"dialogId\"\\s*:\\s*\"([^\"]+)\"/);\n if (m2?.[1]) return m2[1];\n const m3 = raw.match(/\"DialogId\"\\s*:\\s*\"([^\"]+)\"/);\n if (m3?.[1]) return m3[1];\n return undefined;\n}\n\n// ── Core WS turn ────────────────────────────────────────────\n\nasync function* sendToAliceOnce(\n text: string,\n session: AliceSession,\n opts: SendOptions = {},\n): AsyncGenerator {\n const { sk, uuid } = session;\n const dialogId = opts.dialogId ?? \"\";\n const resetSession = opts.resetSession ?? !dialogId;\n const timeoutMs = opts.timeoutMs ?? 22_000;\n let seqNum = 0;\n\n const messageQueue: string[] = [];\n let wsClosed = false;\n let wsError: Error | null = null;\n\n const ws = new WebSocket(UNIPROXY_URL);\n\n ws.onmessage = (event) => {\n messageQueue.push(String(event.data));\n };\n ws.onerror = () => {\n wsError = new Error(\"WebSocket error\");\n };\n ws.onclose = () => {\n wsClosed = true;\n };\n\n await new Promise((resolve, reject) => {\n const t = setTimeout(() => reject(new Error(\"WS connect timeout\")), 12_000);\n ws.onopen = () => {\n clearTimeout(t);\n resolve();\n };\n ws.onerror = () => {\n clearTimeout(t);\n reject(new Error(\"WS connection failed\"));\n };\n });\n\n ws.onerror = () => {\n wsError = new Error(\"WebSocket error\");\n };\n\n ws.send(\n JSON.stringify({\n event: {\n header: {\n namespace: \"System\",\n name: \"SynchronizeState\",\n messageId: genId(),\n seqNumber: seqNum++,\n },\n payload: {\n accept_invalid_auth: true,\n auth_token: sk,\n uuid,\n vins: {\n application: {\n app_id: APP_ID,\n platform: \"desktop\",\n device_id: uuid,\n device_model: \"desktop\",\n },\n },\n supported_features: SUPPORTED_FEATURES,\r\n request: { experiments: EXPERIMENTS },\r\n speechkitVersion: \"4.16.7\",\r\n },\r\n },\r\n }),\r\n );\n\n let authenticated = false;\n const authDeadline = Date.now() + 8_000;\n while (!authenticated && Date.now() < authDeadline && !wsClosed) {\n if (wsError) throw wsError;\n if (messageQueue.length > 0) {\n const msg = messageQueue.shift()!;\n if (msg.includes(\"SynchronizeStateResponse\")) authenticated = true;\n if (msg.includes(\"InvalidAuth\")) {\n throw new Error(\"Alice InvalidAuth\");\n }\n } else {\n await sleep(30);\n }\n }\n\n if (!authenticated) {\n try {\n ws.close();\n } catch {\n /* */\n }\n throw new Error(\"Authentication failed\");\n }\n\n const requestId = genId();\n const messageId = genId();\n const now = new Date();\n const clientTime = now.toISOString().slice(0, 19).replace(/[:+-]/g, \"\");\n const timestamp = String(Date.now()).slice(0, -3);\n\n ws.send(\n JSON.stringify({\n event: {\n header: {\n namespace: \"Vins\",\n name: \"TextInput\",\n messageId,\n seqNumber: seqNum++,\n },\n payload: {\n application: {\n app_id: APP_ID,\n app_version: \"1.114.1\",\n platform: \"desktop\",\n os_version: \"linux\",\n uuid,\n device_id: uuid,\n lang: \"ru-RU\",\n client_time: clientTime,\n timezone: DEFAULT_TZ,\r\n timestamp,\r\n device_model: \"desktop\",\r\n },\r\n header: {\r\n prev_req_id: null,\r\n request_id: requestId,\r\n dialog_id: dialogId,\r\n dialog_type: \"DEDICATED_CHAT\",\r\n },\r\n // CRITICAL: alice_2_settings — without this Alice defaults to Base (no search)\r\n alice_2_settings: ALICE_MODE,\n request: {\r\n event: {\r\n type: \"text_input\",\r\n text,\r\n },\r\n voice_session: false,\r\n experiments: EXPERIMENTS,\r\n uniproxy_options: {\r\n background_response_streaming_options: {\r\n request_with_shown_new_dialog: resetSession ? {} : undefined,\r\n },\r\n },\r\n additional_options: {\r\n origin_domain: \"yandex.ru\",\r\n supported_features: SUPPORTED_FEATURES,\r\n unsupported_features: [],\r\n },\r\n location: DEFAULT_LOCATION,\r\n reset_session: resetSession,\r\n },\r\n },\r\n },\r\n }),\r\n );\n\n let fullText = \"\";\n let responseDone = false;\n let lastDialogId: string | undefined = dialogId || undefined;\n const responseDeadline = Date.now() + timeoutMs;\n\n while (!responseDone && Date.now() < responseDeadline && !wsClosed) {\n if (wsError) {\n try {\n ws.close();\n } catch {\n /* */\n }\n throw wsError;\n }\n\n if (messageQueue.length === 0) {\n await sleep(25);\n continue;\n }\n\n const rawMsg = messageQueue.shift()!;\n if (rawMsg.includes(\"InputStartAck\")) continue;\n if (rawMsg.includes(\"SynchronizeStateResponse\")) continue;\n\n // deno-lint-ignore no-explicit-any\n let parsed: any;\n try {\n parsed = JSON.parse(rawMsg);\n } catch {\n continue;\n }\n\n const directive = parsed.directive;\n if (!directive) {\n // some streaming frames nest differently\n if (parsed.streaming && parsed.directive === undefined) continue;\n continue;\n }\n\n const headerName = directive.header?.name as string | undefined;\n const payload = directive.payload;\n\n if (headerName === \"EventException\") {\n const errMsg = payload?.error?.message ?? \"Alice API error\";\n try {\n ws.close();\n } catch {\n /* */\n }\n throw new Error(errMsg);\n }\n\n if (headerName === \"VinsResponse\" || headerName === \"DeferredAliceResponse\") {\n const response = payload?.response;\n const foundDialog = extractDialogId(parsed, payload);\n if (foundDialog) lastDialogId = foundDialog;\n\n const replyText = extractResponseText(response);\n if (replyText && replyText !== fullText) {\n const delta = replyText.startsWith(fullText)\n ? replyText.slice(fullText.length)\n : replyText;\n fullText = replyText;\n if (delta) {\n yield {\n text: delta,\n done: false,\n dialogId: lastDialogId,\n raw: parsed,\n };\n }\n }\n\n if (headerName === \"VinsResponse\" && !response?.is_streaming) {\n responseDone = true;\n yield {\n text: \"\",\n done: true,\n dialogId: lastDialogId,\n raw: parsed,\n };\n }\n continue;\n }\n\n if (headerName === \"DialogControl\") {\n const foundDialog = extractDialogId(parsed, payload);\n if (foundDialog) lastDialogId = foundDialog;\n if (payload?.is_final || payload?.finished) {\n responseDone = true;\n yield {\n text: \"\",\n done: true,\n dialogId: lastDialogId,\n raw: parsed,\n };\n }\n }\n }\n\n if (!responseDone && fullText) {\n yield { text: \"\", done: true, dialogId: lastDialogId, raw: null };\n }\n\n if (!fullText && !responseDone) {\n try {\n ws.close();\n } catch {\n /* */\n }\n throw new Error(\"Alice timeout — empty response\");\n }\n\n try {\n ws.close();\n } catch {\n /* */\n }\n}\n\nfunction isRetryable(err: unknown): boolean {\n const msg = err instanceof Error ? err.message : String(err);\n return /timeout|WebSocket|Authentication|InvalidAuth|failed|429|502|503|EOF|network/i\n .test(msg);\n}\n\n/** Stream Alice reply with retries + session refresh. */\nexport async function* sendToAlice(\n text: string,\n session?: AliceSession,\n dialogIdOrOpts: string | SendOptions = \"\",\n): AsyncGenerator {\n const opts: SendOptions =\n typeof dialogIdOrOpts === \"string\"\n ? { dialogId: dialogIdOrOpts }\n : dialogIdOrOpts;\n\n const maxTry = (opts.timeoutMs ?? 22_000) <= 14_000 ? 1 : MAX_RETRIES;\r\n let lastErr: unknown;\r\n for (let attempt = 1; attempt <= maxTry; attempt++) {\r\n try {\r\n const sess = session && attempt === 1\r\n ? session\r\n : await getSession(attempt > 1);\r\n let finalDialog = opts.dialogId;\r\n for await (const chunk of sendToAliceOnce(text, sess, {\r\n ...opts,\r\n dialogId: finalDialog ?? opts.dialogId,\r\n })) {\r\n if (chunk.dialogId) finalDialog = chunk.dialogId;\r\n yield chunk;\r\n }\r\n return;\r\n } catch (err) {\r\n lastErr = err;\r\n console.log(\r\n JSON.stringify({\r\n level: \"warn\",\r\n event: \"alice_retry\",\r\n attempt,\r\n maxTry,\r\n error: err instanceof Error ? err.message : String(err),\r\n }),\r\n );\r\n invalidateSession();\r\n if (!isRetryable(err) || attempt === maxTry) break;\r\n await sleep(250 * attempt * attempt);\r\n }\r\n }\n throw lastErr instanceof Error\n ? lastErr\n : new Error(String(lastErr));\n}\n\nexport async function askAlice(\n text: string,\n session?: AliceSession,\n opts: SendOptions = {},\n): Promise<{ text: string; dialogId?: string }> {\n let full = \"\";\n let dialogId = opts.dialogId;\n for await (const chunk of sendToAlice(text, session, opts)) {\n full += chunk.text;\n if (chunk.dialogId) dialogId = chunk.dialogId;\n }\n return { text: full, dialogId };\n}\n\n/** Cheap readiness: reuse pool or fetch session. */\nexport async function pingAlice(): Promise<{ ok: boolean; ms: number; cached: boolean }> {\n const t0 = Date.now();\n const cached = !!(\n cachedSession && Date.now() - cachedSession.createdAt < SESSION_TTL_MS\n );\n try {\n await getSession();\n return { ok: true, ms: Date.now() - t0, cached };\n } catch {\n return { ok: false, ms: Date.now() - t0, cached: false };\n }\n}\n\n// bust 2026-07-20T15:09:37.0161522+05:00\r\n","createdAt",["D",1784545285446],"branchVersion","branchId","c0d1bd45-cfa4-4439-a58d-8b2dd40d5344","id","b14b03ef-0b5a-41c2-8f35-784598396b5f","openai-yandex-adapter",["D",1784537552501],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","OpenAI-compatible API adapter for Yandex GPT (free tier)","imageUrl","27af7c01-80a6-42d0-8a42-18f99ce8bb03","pinnedFileId","a536781a-841f-11f1-8ecd-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019f7ba5-7ad8-732a-82a4-e6072669dcc2","tursoName","b14b03ef0b5a41c28f35784598396b5f","tursoHostname","b14b03ef0b5a41c28f35784598396b5f-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789484509295],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_100":99,"_107":103},"org",{"_100":99,"_101":99,"_102":103,"_18":55,"_104":105,"_106":25},"branch",{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"isOwned",136,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","dmkrj","handle","displayName","avatar","https://lh3.googleusercontent.com/a/ACg8ocKVGzvzjbF7__cpkyYO7FVbjNDQ3JVNm0gId3KrMdC7DKByr4M=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":219,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":220,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":221,"_84":222,"_86":223,"_88":25},"tree",[194,195,196,197,198,199],"files",[194,195,196,197,198,199],"counts",{"_183":63,"_184":185,"_186":63,"_187":188,"_189":190},"contents",[130,131,132,133,134,135],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":175,"_32":176,"_30":177,"_139":-5,"_41":42,"_40":178,"_141":59,"_38":179,"_13":180,"_33":20,"_35":181,"_24":25,"_145":-5,"_27":182},{"_43":167,"_32":168,"_30":169,"_139":-5,"_41":42,"_40":170,"_141":25,"_38":171,"_13":172,"_33":34,"_35":173,"_24":25,"_145":-5,"_27":174},{"_43":163,"_32":28,"_30":31,"_139":-5,"_41":42,"_40":14,"_141":25,"_38":164,"_13":165,"_33":34,"_35":37,"_24":25,"_145":-5,"_27":166},{"_43":155,"_32":156,"_30":157,"_139":-5,"_41":42,"_40":158,"_141":59,"_38":159,"_13":160,"_33":34,"_35":161,"_24":25,"_145":-5,"_27":162},{"_43":147,"_32":148,"_30":57,"_139":-5,"_41":42,"_40":149,"_141":25,"_38":150,"_13":151,"_33":152,"_35":153,"_24":25,"_145":-5,"_27":154},{"_43":136,"_32":137,"_30":138,"_139":-5,"_41":42,"_40":140,"_141":25,"_38":142,"_13":143,"_33":34,"_35":144,"_24":25,"_145":-5,"_27":146},"aff57bd4-cba6-464f-a086-ae815f5b3cc9","search.ts","50e43b68-8423-11f1-959b-1607ee4eb77e","parentId",115,"latest",["D",1784545085162],6,"// Full web toolkit — no API keys\n// weather (Open-Meteo) | wiki | FX | DDG | spell-ish city fix\n\nconst UA =\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36\";\n\nconst WEATHER_RE =\n /погод|температур|осадк|forecast|weather|градус|дожд|снег|ветер/i;\nconst SEARCH_RE =\n /погод|новост|курс|доллар|евро|bitcoin|btc|кто так|что так|когда|где |сколько стоит|сегодня|сейчас|актуаль|weather|news|price|who is|what is|вики|wiki|найди|погугли/i;\nconst FX_RE = /курс|доллар|евро|usd|eur|btc|bitcoin|рубл/i;\nconst WIKI_RE = /кто так|что так|кто эт|что эт|вики|wiki|расскажи про|who is|what is/i;\n\nexport function needsWeb(query: string): boolean {\n return SEARCH_RE.test(query) || WEATHER_RE.test(query) || FX_RE.test(query);\n}\n\n/** Common RU city typos / informal — longest first, whole-word only */\nconst CITY_FIX_LIST: Array<[string, string]> = [\n [\"чеблябинск\", \"Челябинск\"],\n [\"челябинск\", \"Челябинск\"],\n [\"санкт-петербург\", \"Санкт-Петербург\"],\n [\"нижний новгород\", \"Нижний Новгород\"],\n [\"ростов-на-дону\", \"Ростов-на-Дону\"],\n [\"екатеринбург\", \"Екатеринбург\"],\n [\"новосибирск\", \"Новосибирск\"],\n [\"челяба\", \"Челябинск\"],\n [\"питер\", \"Санкт-Петербург\"],\n [\"ебург\", \"Екатеринбург\"],\n [\"спб\", \"Санкт-Петербург\"],\n [\"мск\", \"Москва\"],\n [\"екб\", \"Екатеринбург\"],\n [\"нск\", \"Новосибирск\"],\n [\"нн\", \"Нижний Новгород\"],\n];\n\nexport function fixQuery(q: string): string {\n let out = q.trim();\n for (const [bad, good] of CITY_FIX_LIST) {\n // whole token + optional RU case ending (чеблябинске → Челябинск)\n // avoid нск inside ЧелябиНСК via left boundary\n const re = new RegExp(\n `(^|[^а-яёa-z0-9])(${bad}[аеуы]?)(?=[^а-яёa-z0-9]|$)`,\n \"gi\",\n );\n out = out.replace(re, `$1${good}`);\n }\n return out;\n}\n\nconst CITY_FIX: Record = Object.fromEntries(CITY_FIX_LIST);\n\n/** Rough RU → nominative for geocoding (Москве→Москва, Питере→Питер handled via fix) */\nfunction toNominative(city: string): string {\n let c = city.trim();\n // known full forms\n const known: Record = {\n москве: \"Москва\",\n москвы: \"Москва\",\n москву: \"Москва\",\n \"санкт-петербурге\": \"Санкт-Петербург\",\n петербурге: \"Санкт-Петербург\",\n питере: \"Санкт-Петербург\",\n екатеринбурге: \"Екатеринбург\",\n челябинске: \"Челябинск\",\n новосибирске: \"Новосибирск\",\n казани: \"Казань\",\n сочи: \"Сочи\",\n };\n const low = c.toLowerCase();\n if (known[low]) return known[low];\n // -е / -и locative\n if (/[бвгджзклмнпрстфхцчшщ]е$/i.test(c) && c.length > 4) {\n c = c.slice(0, -1); // Москве → Москв → need а\n if (!/[аяь]$/i.test(c)) c = c + \"а\"; // Москв + а\n // Челябинске → Челябинск (consonant stem): if ends with ск/цк keep\n }\n if (/ске$/i.test(city)) return city.slice(0, -1); // Челябинске → Челябинск\n if (/бурге$/i.test(city)) return city.slice(0, -1);\n if (c === c.toLowerCase()) {\n c = c.charAt(0).toUpperCase() + c.slice(1);\n }\n return c;\n}\n\nexport function extractCity(query: string): string | null {\n const q = fixQuery(query);\n\n // only look for city in weather / \"в \" geo context — not \"в одно предложение\"\n const geoCtx = /погод|weather|температур|градус|город/i.test(q);\n\n // known aliases\n for (const [bad, good] of CITY_FIX_LIST) {\n if (\n new RegExp(`(?:^|[^а-яё])${bad}[аеуы]?(?:[^а-яё]|$)`, \"i\").test(query) ||\n new RegExp(good, \"i\").test(q)\n ) {\n return good;\n }\n }\n\n if (!geoCtx) return null;\n\n const m =\n q.match(/погод[аеы]?\\s+(?:в|во)\\s+([а-яёa-z0-9\\-\\s]{2,40})/i) ||\n q.match(/weather\\s+(?:in|for)\\s+([a-z\\-\\s]{2,40})/i) ||\n q.match(\n /(?:в|во)\\s+([а-яёa-z][а-яёa-z\\-]{1,30}(?:[-\\s][а-яёa-z]+)?)/i,\n );\n if (!m) return null;\n let city = m[1].replace(/[?!.]+$/g, \"\").trim();\n const low = city.toLowerCase();\n if (CITY_FIX[low]) return CITY_FIX[low];\n // skip non-cities\n if (\n /предложен|слово|раз|час|день|год|вопрос|ответ|режим/i.test(city)\n ) {\n return null;\n }\n return toNominative(city);\n}\n\nasync function geocode(city: string) {\n const url =\n `https://geocoding-api.open-meteo.com/v1/search?name=${\n encodeURIComponent(city)\n }&count=1&language=ru&format=json`;\n const res = await fetch(url, { headers: { \"User-Agent\": UA } });\n if (!res.ok) return null;\n const data = await res.json();\n const r = data?.results?.[0];\n if (!r) return null;\n return {\n name: [r.name, r.admin1, r.country].filter(Boolean).join(\", \"),\n lat: r.latitude as number,\n lon: r.longitude as number,\n };\n}\n\nfunction weatherCodeRu(code: number): string {\n const map: Record = {\n 0: \"ясно\",\n 1: \"преимущественно ясно\",\n 2: \"переменная облачность\",\n 3: \"пасмурно\",\n 45: \"туман\",\n 48: \"изморозь\",\n 51: \"лёгкая морось\",\n 61: \"небольшой дождь\",\n 63: \"дождь\",\n 65: \"сильный дождь\",\n 71: \"небольшой снег\",\n 73: \"снег\",\n 75: \"сильный снег\",\n 80: \"ливень\",\n 95: \"гроза\",\n };\n return map[code] ?? `код ${code}`;\n}\n\nexport async function weatherFor(city: string): Promise {\n const g = await geocode(fixQuery(city));\n if (!g) return null;\n const url =\n `https://api.open-meteo.com/v1/forecast?latitude=${g.lat}&longitude=${g.lon}` +\n `¤t=temperature_2m,relative_humidity_2m,apparent_temperature,weather_code,wind_speed_10m,precipitation` +\n `&daily=temperature_2m_max,temperature_2m_min,precipitation_sum&timezone=auto&forecast_days=3`;\n const res = await fetch(url, { headers: { \"User-Agent\": UA } });\n if (!res.ok) return null;\n const data = await res.json();\n const c = data.current;\n if (!c) return null;\n const d = data.daily;\n let daily = \"\";\n if (d?.time?.[0]) {\n daily =\n `\\nСегодня: max ${d.temperature_2m_max[0]}° / min ${d.temperature_2m_min[0]}°, осадки ${d.precipitation_sum[0]} мм`;\n if (d.time[1]) {\n daily +=\n `\\nЗавтра: max ${d.temperature_2m_max[1]}° / min ${d.temperature_2m_min[1]}°`;\n }\n }\n return (\n `🌤 Погода — ${g.name}\\n` +\n `Сейчас: ${c.temperature_2m}°C (ощущается ${c.apparent_temperature}°C), ${\n weatherCodeRu(c.weather_code)\n }, влажность ${c.relative_humidity_2m}%, ветер ${c.wind_speed_10m} км/ч, осадки ${c.precipitation} мм.` +\n daily\n );\n}\n\nexport async function wikiSummary(query: string): Promise {\n try {\n // strip question words\n let q = fixQuery(query)\n .replace(/кто такой|кто такая|кто это|что такое|что это|расскажи про|вики|wiki/gi, \"\")\n .replace(/[?!.]/g, \"\")\n .trim();\n if (q.length < 2) q = fixQuery(query);\n const url =\n `https://ru.wikipedia.org/api/rest_v1/page/summary/${\n encodeURIComponent(q)\n }`;\n const res = await fetch(url, {\n headers: { \"User-Agent\": UA, Accept: \"application/json\" },\n });\n if (!res.ok) {\n // try EN\n const res2 = await fetch(\n `https://en.wikipedia.org/api/rest_v1/page/summary/${\n encodeURIComponent(q)\n }`,\n { headers: { \"User-Agent\": UA } },\n );\n if (!res2.ok) return null;\n const d2 = await res2.json();\n if (d2.extract) return `📖 ${d2.title}: ${d2.extract}`;\n return null;\n }\n const d = await res.json();\n if (d.extract) return `📖 ${d.title}: ${d.extract}`;\n return null;\n } catch {\n return null;\n }\n}\n\nasync function btcUsd(): Promise {\n const urls = [\n \"https://api.coinbase.com/v2/prices/BTC-USD/spot\",\n \"https://api.binance.com/api/v3/ticker/price?symbol=BTCUSDT\",\n \"https://api.coingecko.com/api/v3/simple/price?ids=bitcoin&vs_currencies=usd\",\n ];\n for (const url of urls) {\n try {\n const res = await fetch(url, {\n headers: { \"User-Agent\": UA, Accept: \"application/json\" },\n });\n if (!res.ok) continue;\n const j = await res.json();\n if (j?.data?.amount) return parseFloat(j.data.amount);\n if (j?.price) return parseFloat(j.price);\n if (j?.bitcoin?.usd) return Number(j.bitcoin.usd);\n } catch {\n /* try next */\n }\n }\n return null;\n}\n\nexport async function fxRates(query: string): Promise {\n try {\n let usdRub: number | null = null;\n let eurRub: number | null = null;\n let stamp = \"now\";\n\n try {\n const res = await fetch(\"https://open.er-api.com/v6/latest/USD\", {\n headers: { \"User-Agent\": UA },\n });\n if (res.ok) {\n const data = await res.json();\n usdRub = data?.rates?.RUB ?? null;\n const eur = data?.rates?.EUR;\n if (usdRub && eur) eurRub = usdRub / eur;\n stamp = data.time_last_update_utc || stamp;\n }\n } catch {\n /* */\n }\n\n // fallback FX\n if (!usdRub) {\n try {\n const res = await fetch(\n \"https://api.exchangerate.host/latest?base=USD&symbols=RUB,EUR\",\n { headers: { \"User-Agent\": UA } },\n );\n if (res.ok) {\n const data = await res.json();\n usdRub = data?.rates?.RUB ?? null;\n if (usdRub && data?.rates?.EUR) eurRub = usdRub / data.rates.EUR;\n }\n } catch {\n /* */\n }\n }\n\n if (!usdRub) return null;\n\n let line =\n `💱 Курсы (${stamp}):\\n` +\n `1 USD = ${usdRub.toFixed(2)} RUB`;\n if (eurRub) line += `\\n1 EUR ≈ ${eurRub.toFixed(2)} RUB`;\n\n if (/btc|bitcoin|битк/i.test(query)) {\n const btc = await btcUsd();\n if (btc) {\n line +=\n `\\n1 BTC ≈ ${btc.toLocaleString(\"en-US\", { maximumFractionDigits: 0 })} USD ≈ ${\n (btc * usdRub).toLocaleString(\"ru-RU\", { maximumFractionDigits: 0 })\n } RUB`;\n } else {\n line += `\\nBTC: не удалось получить котировку`;\n }\n }\n return line;\n } catch {\n return null;\n }\n}\n\nasync function ddgHtml(query: string): Promise {\n try {\n const url =\n `https://html.duckduckgo.com/html/?q=${encodeURIComponent(fixQuery(query))}`;\n const res = await fetch(url, {\n headers: { \"User-Agent\": UA, Accept: \"text/html\" },\n });\n if (!res.ok) return null;\n const html = await res.text();\n const snippets: string[] = [];\n const re = /class=\"result__snippet\"[^>]*>([\\s\\S]*?)<\\/(?:a|td)>/gi;\n let m;\n while ((m = re.exec(html)) !== null && snippets.length < 6) {\n const text = m[1]\n .replace(/<[^>]+>/g, \" \")\n .replace(/"/g, '\"')\n .replace(/'/g, \"'\")\n .replace(/&/g, \"&\")\n .replace(/\\s+/g, \" \")\n .trim();\n // filter SEO junk\n if (\n text.length > 50 &&\n text.length < 400 &&\n !/прогноз погоды на \\d+ дн|cookie|javascript/i.test(text)\n ) {\n snippets.push(text);\n }\n }\n if (!snippets.length) return null;\n // best = first with digits or cyrillic density\n snippets.sort((a, b) => scoreSnippet(b) - scoreSnippet(a));\n return snippets.slice(0, 3).map((s, i) => `${i + 1}. ${s}`).join(\"\\n\");\n } catch {\n return null;\n }\n}\n\nfunction scoreSnippet(s: string): number {\n let sc = 0;\n if (/\\d/.test(s)) sc += 3;\n if (/[а-яё]{4,}/i.test(s)) sc += 2;\n if (s.length > 80 && s.length < 280) sc += 2;\n if (/подробн|на сегодня|режим реального/i.test(s)) sc -= 2;\n return sc;\n}\n\nasync function ddgInstant(query: string): Promise {\n try {\n const url =\n `https://api.duckduckgo.com/?q=${\n encodeURIComponent(fixQuery(query))\n }&format=json&no_html=1&skip_disambig=1`;\n const res = await fetch(url, {\n headers: { \"User-Agent\": UA, Accept: \"application/json\" },\n });\n if (!res.ok) return null;\n const data = await res.json();\n const bits: string[] = [];\n if (data.AbstractText) bits.push(data.AbstractText);\n if (data.Answer) bits.push(String(data.Answer));\n if (Array.isArray(data.RelatedTopics)) {\n for (const t of data.RelatedTopics.slice(0, 3)) {\n if (t?.Text) bits.push(t.Text);\n }\n }\n return bits.length ? bits.join(\"\\n\") : null;\n } catch {\n return null;\n }\n}\n\n/** Rich multi-source context */\nexport async function buildWebContext(query: string): Promise {\n const q = fixQuery(query);\n if (!needsWeb(q) && !WIKI_RE.test(q) && !FX_RE.test(q)) return null;\n\n const chunks: string[] = [];\n const jobs: Promise[] = [];\n\n if (WEATHER_RE.test(q)) {\n jobs.push(\n (async () => {\n const city = extractCity(q) ?? \"Челябинск\";\n const w = await weatherFor(city);\n if (w) chunks.push(w);\n })(),\n );\n }\n\n if (FX_RE.test(q)) {\n jobs.push(\n (async () => {\n const fx = await fxRates(q);\n if (fx) chunks.push(fx);\n })(),\n );\n }\n\n if (WIKI_RE.test(q) || /кто |что такое/i.test(q)) {\n jobs.push(\n (async () => {\n const w = await wikiSummary(q);\n if (w) chunks.push(w);\n })(),\n );\n }\n\n // always general search for searchy queries\n jobs.push(\n (async () => {\n const instant = await ddgInstant(q);\n if (instant) chunks.push(instant);\n else {\n const html = await ddgHtml(q);\n if (html) chunks.push(html);\n }\n })(),\n );\n\n await Promise.all(jobs);\n if (!chunks.length) return null;\n return chunks.join(\"\\n\\n\");\n}\n\nexport async function withWebSearch(userText: string): Promise {\n const q = fixQuery(userText.trim());\n if (!q) return q;\n try {\n const ctx = await buildWebContext(q);\n if (!ctx) return q;\n return `${ctx}\\n\\nВопрос: ${q}`;\n } catch {\n return q;\n }\n}\n","label",[137],"26fbee13-f963-41d6-9338-8d51e1dd0ad0","main.ts",117,["D",1784545086172],16,"http","// Val Town HTTP — Alice agent adapter (full farsh)\n// deploy-stamp: 2026-07-20-holes-closed\nimport { Hono } from \"npm:hono\";\nimport { runAgent, runAgentStream } from \"./agent.ts\";\nimport {\n conversationKey,\n getSession,\n pingAlice,\n rememberDialog,\n} from \"./alice.ts\";\nimport {\n buildChunk,\n lastUserText,\n messagesToPrompt,\n normalizeMessages,\n resolveModel,\n toOpenAIError,\n toOpenAIModels,\n toOpenAIResponse,\n type OpenAIChatRequest,\n} from \"./convert.ts\";\n\nconst app = new Hono();\napp.onError((err) => Promise.reject(err));\n\nfunction reqId(): string {\n return crypto.randomUUID().slice(0, 8);\n}\n\nfunction log(obj: Record) {\n console.log(JSON.stringify({ ts: new Date().toISOString(), ...obj }));\n}\n\napp.get(\"/\", (c) =>\n c.json({\n status: \"ok\",\n service: \"openai-yandex-adapter\",\n backend: \"alice.yandex.ru\",\n free: true,\n streaming: true,\n features: [\n \"agent-full\",\n \"tools-first\",\n \"weather\",\n \"web-search\",\n \"wikipedia\",\n \"fx-rates\",\n \"btc\",\n \"math\",\n \"datetime\",\n \"spellfix\",\n \"local-chat-fallback\",\n \"alice-pro-mode\",\n \"default-spb-msk\",\n \"session-pool\",\n \"retries\",\n \"ready\",\n \"request-logs\",\n \"no-alice-hang\",\n ],\n defaults: { tz: \"Europe/Moscow\", city: \"Санкт-Петербург\" },\n }),\n);\n\napp.get(\"/ready\", async (c) => {\n const id = reqId();\n const t0 = Date.now();\n const ping = await pingAlice();\n log({\n req: id,\n route: \"/ready\",\n ok: ping.ok,\n ms: Date.now() - t0,\n alice_ms: ping.ms,\n cached: ping.cached,\n });\n if (!ping.ok) return c.json({ status: \"not_ready\", ...ping }, 503);\n return c.json({ status: \"ready\", ...ping });\n});\n\napp.get(\"/health\", (c) => c.redirect(\"/ready\"));\napp.get(\"/v1/models\", (c) => c.json(toOpenAIModels()));\n\napp.post(\"/v1/chat/completions\", async (c) => {\n const id = reqId();\n const t0 = Date.now();\n\n let body: OpenAIChatRequest;\n try {\n body = await c.req.json();\n } catch {\n return c.json(toOpenAIError(\"Invalid JSON in request body.\"), 400);\n }\n\n if (!body.messages?.length) {\n return c.json(\n toOpenAIError(\n \"messages is required and must not be empty.\",\n \"invalid_request_error\",\n \"messages\",\n ),\n 400,\n );\n }\n\n const messages = normalizeMessages(body.messages);\n const model = resolveModel(body.model);\n const isStream = body.stream ?? false;\n\n const headerDialog =\n c.req.header(\"x-dialog-id\") ??\n c.req.header(\"x-alice-dialog-id\") ??\n undefined;\n const convKey = conversationKey(messages);\n const dialogId = headerDialog || \"\";\n const continuing = Boolean(headerDialog);\n\n // user question (strip OpenCode junk via messagesToPrompt / lastUser)\n const userQ = continuing\n ? lastUserText(messages)\n : lastUserText(messages) || messagesToPrompt(messages);\n\n if (!userQ.trim()) {\n return c.json(\n toOpenAIError(\n \"messages content is empty.\",\n \"invalid_request_error\",\n \"messages\",\n ),\n 400,\n );\n }\n\n let session;\n try {\n session = await getSession();\n } catch (err) {\n log({\n req: id,\n route: \"chat\",\n error: \"session\",\n ms: Date.now() - t0,\n msg: err instanceof Error ? err.message : String(err),\n });\n return c.json(\n toOpenAIError(\n `Failed to get Alice session: ${\n err instanceof Error ? err.message : String(err)\n }`,\n \"api_error\",\n ),\n 502,\n );\n }\n\n const sendOpts = {\n dialogId,\n resetSession: !continuing,\n };\n\n // ── Non-stream agent ──────────────────────────────────────\n if (!isStream) {\n try {\n const result = await runAgent(userQ, session, sendOpts);\n if (result.dialogId) rememberDialog(convKey, result.dialogId);\n\n c.header(\"X-Request-Id\", id);\n c.header(\"X-Agent-Tools\", result.tools.join(\",\"));\n c.header(\"X-Agent-Retries\", String(result.retries));\n c.header(\"X-Agent-Source\", result.source);\n if (result.dialogId || dialogId) {\n c.header(\"X-Dialog-Id\", result.dialogId || dialogId);\n }\n\n log({\n req: id,\n route: \"chat\",\n stream: false,\n ms: Date.now() - t0,\n tools: result.tools,\n steps: result.steps,\n retries: result.retries,\n source: result.source,\n out_len: result.text.length,\n });\n\n return c.json(toOpenAIResponse(result.text, model));\n } catch (err) {\n log({\n req: id,\n route: \"chat\",\n error: err instanceof Error ? err.message : String(err),\n ms: Date.now() - t0,\n });\n return c.json(\n toOpenAIError(\n `Agent error: ${err instanceof Error ? err.message : String(err)}`,\n \"api_error\",\n ),\n 502,\n );\n }\n }\n\n // ── Stream agent ──────────────────────────────────────────\n const chatId = `chatcmpl-${crypto.randomUUID()}`;\n const created = Math.floor(Date.now() / 1000);\n const encoder = new TextEncoder();\n let outDialog = dialogId;\n let toolsHdr = \"\";\n let retries = 0;\n\n const stream = new ReadableStream({\n async start(controller) {\n const push = (s: string) => controller.enqueue(encoder.encode(s));\n try {\n push(buildChunk(chatId, created, model, { role: \"assistant\" }, null));\n\n for await (const ev of runAgentStream(userQ, session, sendOpts)) {\n if (ev.type === \"meta\") {\n toolsHdr = ev.tools.join(\",\");\n continue;\n }\n if (ev.type === \"text\") {\n if (ev.dialogId) outDialog = ev.dialogId;\n if (ev.text) {\n push(\n buildChunk(chatId, created, model, { content: ev.text }, null),\n );\n }\n }\n if (ev.type === \"done\") {\n if (ev.dialogId) outDialog = ev.dialogId;\n retries = ev.retries;\n if (outDialog) rememberDialog(convKey, outDialog);\n log({\n req: id,\n route: \"chat\",\n stream: true,\n ms: Date.now() - t0,\n tools: toolsHdr,\n steps: ev.steps,\n retries,\n });\n }\n }\n\n push(buildChunk(chatId, created, model, {}, \"stop\"));\n push(\"data: [DONE]\\n\\n\");\n controller.close();\n } catch (err) {\n const msg = err instanceof Error ? err.message : String(err);\n push(\n buildChunk(\n chatId,\n created,\n model,\n { content: `[Error: ${msg}]` },\n \"stop\",\n ),\n );\n push(\"data: [DONE]\\n\\n\");\n controller.close();\n log({ req: id, route: \"chat\", stream: true, error: msg });\n }\n },\n });\n\n const headers: Record = {\n \"Content-Type\": \"text/event-stream\",\n \"Cache-Control\": \"no-cache\",\n Connection: \"keep-alive\",\n \"X-Request-Id\": id,\n \"X-Agent\": \"1\",\n };\n if (outDialog) headers[\"X-Dialog-Id\"] = outDialog;\n\n return new Response(stream, { headers });\n});\n\nexport default app.fetch;\n\n// 2026-07-20T15:17:43.9323801+05:00",[148],"c1a3c298-4644-4ce2-952a-496c212060c7","convert.ts","854ed196-841f-11f1-b9c6-1607ee4eb77e",88,["D",1784542177923],7,"// OpenAI format helpers\n\nexport interface OpenAIMessage {\n role: \"system\" | \"user\" | \"assistant\" | string;\n content: string | Array<{ type: string; text?: string }>;\n}\n\nexport interface OpenAIChatRequest {\n model?: string;\n messages: OpenAIMessage[];\n temperature?: number;\n max_tokens?: number;\n stream?: boolean;\n top_p?: number;\n user?: string;\n}\n\nexport interface OpenAIChatResponse {\n id: string;\n object: \"chat.completion\";\n created: number;\n model: string;\n choices: Array<{\n index: number;\n message: { role: string; content: string };\n finish_reason: string;\n }>;\n usage: {\n prompt_tokens: number;\n completion_tokens: number;\n total_tokens: number;\n };\n}\n\nexport interface OpenAIError {\n error: {\n message: string;\n type: string;\n param: string | null;\n code: string | null;\n };\n}\n\nexport const DEFAULT_MODEL = \"alice\";\n\nexport const MODELS = [{ id: \"alice\", label: \"Alice free web\" }];\n\nexport function resolveModel(model?: string): string {\n return model?.trim() || DEFAULT_MODEL;\n}\n\nexport function messageContent(m: OpenAIMessage): string {\n if (typeof m.content === \"string\") return m.content;\n if (Array.isArray(m.content)) {\n return m.content\n .filter((p) => p.type === \"text\" && p.text)\n .map((p) => p.text!)\n .join(\"\\n\");\n }\n return \"\";\n}\n\nexport function normalizeMessages(\n messages: OpenAIMessage[],\n): Array<{ role: string; content: string }> {\n return messages.map((m) => ({\n role: m.role,\n content: messageContent(m),\n }));\n}\n\nconst MAX_SYSTEM_CHARS = 280;\nconst MAX_HISTORY_TURNS = 6;\nconst MAX_TOTAL_CHARS = 3500;\n\n/** Last user utterance. */\nexport function lastUserText(\n messages: Array<{ role: string; content: string }>,\n): string {\n for (let i = messages.length - 1; i >= 0; i--) {\n if (messages[i].role === \"user\" && messages[i].content.trim()) {\n return messages[i].content.trim();\n }\n }\n return \"\";\n}\n\n/**\n * Alice-friendly prompt.\n * OpenCode dumps huge system/AGENTS text — that makes Alice reply \"запуталась\".\n * Rules:\n * - drop long system messages (tools/agents junk)\n * - keep short system as soft hint\n * - keep last few user/assistant turns as plain dialogue\n * - if still huge → last user only\n */\nexport function messagesToPrompt(\n messages: Array<{ role: string; content: string }>,\n): string {\n const userOnly = lastUserText(messages);\n if (!userOnly) return \"\";\n\n const parts: string[] = [];\n\n // short system only\n for (const m of messages) {\n if (m.role !== \"system\") continue;\n const t = m.content.trim();\n if (!t) continue;\n // skip OpenCode / agent dumps\n if (\n t.length > MAX_SYSTEM_CHARS ||\n /AGENTS\\.md|opencode|You are |tool|guideline|XML|jailbreak/i.test(t)\n ) {\n continue;\n }\n parts.push(t);\n }\n\n // recent chat turns (no labels Alice hates)\n const chat = messages.filter(\n (m) =>\n (m.role === \"user\" || m.role === \"assistant\") && m.content.trim(),\n );\n const recent = chat.slice(-MAX_HISTORY_TURNS);\n\n if (recent.length <= 1) {\n // single shot — just the question\n const out = parts.length ? `${parts.join(\" \")}\\n\\n${userOnly}` : userOnly;\n return out.slice(0, MAX_TOTAL_CHARS);\n }\n\n for (const m of recent) {\n if (m.role === \"user\") parts.push(`Пользователь: ${m.content.trim()}`);\n else parts.push(`Алиса: ${m.content.trim()}`);\n }\n\n // nudge reply to last user\n if (!parts[parts.length - 1]?.startsWith(\"Пользователь:\")) {\n parts.push(`Пользователь: ${userOnly}`);\n }\n parts.push(\"Ответь на последнее сообщение пользователя коротко и по делу.\");\n\n const joined = parts.join(\"\\n\");\n if (joined.length > MAX_TOTAL_CHARS) {\n // fallback: clean user question only (best for weather etc.)\n return userOnly;\n }\n return joined;\n}\n\nexport function toOpenAIResponse(\n content: string,\n model: string,\n): OpenAIChatResponse {\n return {\n id: `chatcmpl-${crypto.randomUUID()}`,\n object: \"chat.completion\",\n created: Math.floor(Date.now() / 1000),\n model,\n choices: [\n {\n index: 0,\n message: { role: \"assistant\", content },\n finish_reason: \"stop\",\n },\n ],\n usage: {\n prompt_tokens: 0,\n completion_tokens: 0,\n total_tokens: 0,\n },\n };\n}\n\n/** Yandex-shaped wrapper (compat with older main). */\nexport function toOpenAIResponseFromYandexShape(\n yandexResp: {\n alternatives?: Array<{\n message?: { role?: string; text?: string };\n status?: string;\n }>;\n usage?: {\n inputTokens?: string;\n completionTokens?: string;\n totalTokens?: string;\n };\n },\n model: string,\n): OpenAIChatResponse {\n const alt = yandexResp.alternatives?.[0];\n const finish =\n alt?.status === \"ALTERNATIVE_STATUS_TRUNCATED_FINAL\"\n ? \"length\"\n : alt?.status === \"ALTERNATIVE_STATUS_CONTENT_FILTER\"\n ? \"content_filter\"\n : \"stop\";\n\n return {\n id: `chatcmpl-${crypto.randomUUID()}`,\n object: \"chat.completion\",\n created: Math.floor(Date.now() / 1000),\n model,\n choices: [\n {\n index: 0,\n message: {\n role: alt?.message?.role ?? \"assistant\",\n content: alt?.message?.text ?? \"\",\n },\n finish_reason: finish,\n },\n ],\n usage: {\n prompt_tokens: parseInt(yandexResp.usage?.inputTokens ?? \"0\", 10),\n completion_tokens: parseInt(\n yandexResp.usage?.completionTokens ?? \"0\",\n 10,\n ),\n total_tokens: parseInt(yandexResp.usage?.totalTokens ?? \"0\", 10),\n },\n };\n}\n\nexport function buildChunk(\n id: string,\n created: number,\n model: string,\n delta: Record,\n finishReason: string | null,\n): string {\n const chunk = {\n id,\n object: \"chat.completion.chunk\" as const,\n created,\n model,\n choices: [\n {\n index: 0,\n delta,\n finish_reason: finishReason,\n },\n ],\n };\n return `data: ${JSON.stringify(chunk)}\\n\\n`;\n}\n\nexport function toOpenAIError(\n message: string,\n type = \"invalid_request_error\",\n code: string | null = null,\n): OpenAIError {\n return { error: { message, type, param: null, code } };\n}\n\nexport function toOpenAIModels() {\n const created = Math.floor(Date.now() / 1000);\n return {\n object: \"list\" as const,\n data: MODELS.map((m) => ({\n id: m.id,\n object: \"model\" as const,\n created,\n owned_by: \"yandex-alice\",\n })),\n };\n}\n\n// bust 2026-07-20T15:09:36.9751567+05:00\r\n",[156],"9d1d80a8-6dae-483e-8b11-63f7de23c1ee",["D",1784545285446],14,[28],"5d3bac43-6d41-4b27-953d-115d9d2672cb","agent.ts","e6378666-8423-11f1-90de-1607ee4eb77e",116,["D",1784545085796],9,"// FULL agent: all tools, tools-first, spellfix, wiki/fx/weather/math/time\n// Alice only for open chat polish\n\nimport {\n askAlice,\n type AliceSession,\n type SendOptions,\n} from \"./alice.ts\";\nimport {\n buildWebContext,\n extractCity,\n fixQuery,\n fxRates,\n needsWeb,\n weatherFor,\n wikiSummary,\n} from \"./search.ts\";\n\nexport type ToolName =\n | \"weather\"\n | \"web\"\n | \"wiki\"\n | \"fx\"\n | \"datetime\"\n | \"math\"\n | \"none\";\n\nexport interface AgentResult {\n text: string;\n dialogId?: string;\n tools: ToolName[];\n steps: string[];\n retries: number;\n source: \"tools\" | \"alice\" | \"hybrid\" | \"fallback\";\n}\n\nconst DUMB_RE =\n /запутал|попроще|не понимаю|не могу помочь|уточни|неясно|перефразир|не совсем понял|сложн(ый|ое) вопрос|^хз$/i;\n\nconst MATH_RE =\n /посчит|вычисл|сколько будет|процент|\\d+\\s*%\\s*от|[\\d\\s\\.\\,]+\\s*[\\+\\-\\*\\/x×÷]\\s*[\\d]/i;\nconst TIME_RE =\n /который час|сколько времени|какая дата|сегодня какая дата|день недели|time now|what time|какое сегодня/i;\nconst CHAT_RE =\n /придумай|напиши стих|анекдот|поздрав|расскажи сказк|ролевая|как дела|привет(?!\\s*мир)/i;\nconst WEATHER_RE = /погод|температур|weather|градус|осадк/i;\nconst FX_RE = /курс|доллар|евро|usd|eur|btc|bitcoin|рубл/i;\nconst WIKI_RE = /кто такой|кто такая|что такое|вики|wiki|who is|what is/i;\nconst FACT_RE =\n /новост|найди|погугли|search|где |когда |сколько стоит|актуаль/i;\n\nfunction isDumb(t: string): boolean {\n if (!t || t.trim().length < 6) return true;\n return DUMB_RE.test(t);\n}\n\nexport function planTools(query: string): ToolName[] {\n const q = fixQuery(query);\n const tools: ToolName[] = [];\n if (MATH_RE.test(q)) tools.push(\"math\");\n if (TIME_RE.test(q)) tools.push(\"datetime\");\n if (WEATHER_RE.test(q)) tools.push(\"weather\");\n if (FX_RE.test(q)) tools.push(\"fx\");\n if (WIKI_RE.test(q)) tools.push(\"wiki\");\n // web only when useful — not for pure math/time/chat\n if (\n !MATH_RE.test(q) &&\n !CHAT_RE.test(q) &&\n (needsWeb(q) || FACT_RE.test(q) || WEATHER_RE.test(q) || FX_RE.test(q) ||\n WIKI_RE.test(q))\n ) {\n tools.push(\"web\");\n }\n if (\n tools.length === 0 &&\n !CHAT_RE.test(q) &&\n q.length > 8 &&\n /[?？]|как |где |когда |почему |какой |what |how |why /i.test(q)\n ) {\n tools.push(\"web\");\n }\n if (tools.length === 0) tools.push(\"none\");\n return [...new Set(tools)];\n}\n\nfunction runMath(query: string): string | null {\n try {\n const pct = query.match(/([\\d.,]+)\\s*%\\s*от\\s*([\\d.,]+)/i);\n if (pct) {\n const a = parseFloat(pct[1].replace(\",\", \".\"));\n const b = parseFloat(pct[2].replace(\",\", \".\"));\n return `${a}% от ${b} = ${(a / 100) * b}`;\n }\n const q = query\n .toLowerCase()\n .replace(/,/g, \".\")\n .replace(/×|х/gi, \"*\")\n .replace(/÷/g, \"/\");\n const m = q.match(/(\\d+(?:\\.\\d+)?)\\s*([\\+\\-\\*\\/x])\\s*(\\d+(?:\\.\\d+)?)/i);\n if (!m) return null;\n const op = m[2] === \"x\" ? \"*\" : m[2];\n const e = `${m[1]}${op}${m[3]}`;\n const val = Function(`\"use strict\"; return (${e})`)();\n if (typeof val !== \"number\" || !Number.isFinite(val)) return null;\n return `${m[1]} ${op} ${m[3]} = ${val}`;\n } catch {\n return null;\n }\n}\n\nfunction runDatetime(): string {\n return new Date().toLocaleString(\"ru-RU\", {\n timeZone: \"Europe/Moscow\",\n weekday: \"long\",\n year: \"numeric\",\n month: \"long\",\n day: \"numeric\",\n hour: \"2-digit\",\n minute: \"2-digit\",\n }) + \" (Санкт-Петербург / Москва, UTC+3)\";\n}\n\nfunction cityFromQuery(q: string): string {\n return extractCity(q) ?? extractCity(fixQuery(q)) ?? \"Санкт-Петербург\";\n}\n\ninterface Bag {\n name: ToolName;\n text: string;\n}\n\nasync function runTools(\n query: string,\n tools: ToolName[],\n steps: string[],\n): Promise {\n const q = fixQuery(query);\n const out: Bag[] = [];\n const jobs: Promise[] = [];\n\n for (const t of tools) {\n if (t === \"none\") continue;\n steps.push(`tool:${t}`);\n jobs.push(\n (async () => {\n try {\n if (t === \"math\") {\n const m = runMath(q);\n if (m) out.push({ name: t, text: m });\n } else if (t === \"datetime\") {\n out.push({ name: t, text: runDatetime() });\n } else if (t === \"weather\") {\n const city = cityFromQuery(q);\n steps.push(`city:${city}`);\n const w = await weatherFor(city);\n if (w) out.push({ name: t, text: w });\n else {\n steps.push(`weather_fail:${city}`);\n out.push({\n name: t,\n text: `Не удалось получить погоду для «${city}». Проверь название города.`,\n });\n }\n } else if (t === \"fx\") {\n const fx = await fxRates(q);\n if (fx) out.push({ name: t, text: fx });\n } else if (t === \"wiki\") {\n const w = await wikiSummary(q);\n if (w) out.push({ name: t, text: w });\n } else if (t === \"web\") {\n const ctx = await buildWebContext(q);\n if (ctx) out.push({ name: t, text: ctx });\n }\n } catch (e) {\n steps.push(\n `fail:${t}:${e instanceof Error ? e.message : String(e)}`,\n );\n }\n })(),\n );\n }\n await Promise.all(jobs);\n return out;\n}\n\nfunction synthesize(userQ: string, bags: Bag[]): string {\n if (!bags.length) return \"\";\n const pick = (n: ToolName) => bags.find((b) => b.name === n)?.text;\n const wantWeather = WEATHER_RE.test(userQ);\n const wantTime = TIME_RE.test(userQ);\n\n // priority: math > weather > fx > wiki > time > web\n if (pick(\"math\")) return `Результат: ${pick(\"math\")}`;\n if (pick(\"weather\")) return pick(\"weather\")!;\n if (wantWeather) {\n const web = pick(\"web\");\n if (web) {\n const lines = web\n .split(\"\\n\")\n .map((l) => l.replace(/^\\d+\\.\\s*/, \"\").trim())\n .filter((l) => /°|температур|погод|облач|дожд|ясн/i.test(l))\n .slice(0, 3);\n if (lines.length) return lines.join(\"\\n\");\n }\n return `Не нашёл погоду по запросу «${userQ}». Уточни город.`;\n }\n if (pick(\"fx\")) return pick(\"fx\")!;\n if (pick(\"wiki\")) return pick(\"wiki\")!;\n // date/time BEFORE generic web (web SEO junk was winning)\n if (pick(\"datetime\") && wantTime) {\n return `Сейчас: ${pick(\"datetime\")}`;\n }\n if (pick(\"web\")) {\n const lines = pick(\"web\")!\n .split(\"\\n\")\n .map((l) => l.replace(/^\\d+\\.\\s*/, \"\").trim())\n .filter(\n (l) =>\n l.length > 40 &&\n l.length < 350 &&\n !/прогноз погоды на \\d+|cookie|javascript|именинник|фаза Луны/i\n .test(l),\n )\n .slice(0, 3);\n if (lines.length) return lines.join(\"\\n\\n\");\n return pick(\"web\")!.slice(0, 900);\n }\n if (pick(\"datetime\")) return `Сейчас: ${pick(\"datetime\")}`;\n return bags.map((b) => b.text).join(\"\\n\\n\");\n}\n\nfunction needsAlice(userQ: string, bags: Bag[], draft: string): boolean {\n // strong tool hit → never Alice\n if (bags.some((b) => [\"weather\", \"math\", \"fx\", \"datetime\"].includes(b.name))) {\n return false;\n }\n if (bags.some((b) => b.name === \"wiki\" && b.text.length > 60)) return false;\n if (draft.length > 100 && (FACT_RE.test(userQ) || needsWeb(userQ))) {\n return false;\n }\n // creative / chat — Alice optional; we have local fallback if she dies\n return CHAT_RE.test(userQ) || bags.every((b) => b.name === \"none\" || !b);\n}\n\nfunction localChatFallback(userQ: string): string {\n const q = userQ.toLowerCase().trim();\n if (/^привет|^здравств|^hey|^hi\\b/i.test(q)) {\n return \"Привет! Могу погоду, курсы, вики, посчитать — спрашивай.\";\n }\n if (/придумай.*приветств|коротк.*приветств/i.test(q)) {\n return \"Привет! Рад тебя видеть — давай сделаем день чуть проще.\";\n }\n if (/анекдот/i.test(q)) {\n return \"Баг заходит в бар. Бармен: «Ты что-то празднуешь?» Баг: «Меня наконец воспроизвели».\";\n }\n if (/как дела/i.test(q)) {\n return \"Норм, на связи. Погода, курсы, факты, счёт — что нужно?\";\n }\n if (/стих|poem/i.test(q)) {\n return \"Дождь стучит по крыше кода,\\nдеплой зелёный — вот и мода.\\nСпроси факт — отвечу прямо,\\nбез «запуталась» упрямо.\";\n }\n if (/поздрав/i.test(q)) {\n return \"Поздравляю! Пусть всё взлетает с первого деплоя и без unexpected EOF.\";\n }\n if (/^(\\?+|х+з+|а+|e+|test)$/i.test(q)) {\n return \"Напиши нормальный вопрос: «погода в СПБ», «курс доллара», «кто такой …», «25*4».\";\n }\n // generic creative — still answer something useful\n if (q.length > 15) {\n return (\n `Ок, запрос: «${userQ.slice(0, 200)}».\\n` +\n `Я лучше в фактах и tools. Уточни задачу одной фразой — или спроси погоду/курс/вики.`\n );\n }\n return (\n `Понял: «${userQ}».\\n` +\n `Для фактов: «погода в СПБ», «курс доллара», «кто такой …», «25*4».`\n );\n}\n\nexport async function runAgent(\n userQ: string,\n session: AliceSession,\n opts: SendOptions = {},\n): Promise {\n const q = fixQuery(userQ);\n const steps: string[] = [];\n if (q !== userQ) steps.push(`spell:${userQ.slice(0, 40)}→${q.slice(0, 40)}`);\n\n const tools = planTools(q);\n steps.push(`plan:${tools.join(\"+\")}`);\n\n const bags = await runTools(q, tools, steps);\n steps.push(`bags:${bags.length}`);\n\n let text = synthesize(q, bags);\n let dialogId = opts.dialogId;\n let retries = 0;\n let source: AgentResult[\"source\"] = text ? \"tools\" : \"fallback\";\n\n if (!needsAlice(q, bags, text) && text) {\n steps.push(\"answer:tools_full\");\n return { text, dialogId, tools, steps, retries, source: \"tools\" };\n }\n\n // open chat: free Alice WS often empty — default FAST local, optional Alice race\n if (needsAlice(q, bags, text) && !text) {\n // skip Alice by default (timeout hell). Set tryAlice for rare polish.\n const tryAlice = false;\n if (!tryAlice || CHAT_RE.test(q) || q.length < 8) {\n text = localChatFallback(q);\n source = \"fallback\";\n steps.push(\"answer:local_fast\");\n } else {\n try {\n const r = await askAlice(\n `Ответь кратко по-русски.\\n\\nВопрос: ${q}\\n\\nОтвет:`,\n session,\n { dialogId: \"\", resetSession: true, timeoutMs: 8_000 },\n );\n steps.push(\"alice:call\");\n if (!isDumb(r.text)) {\n text = r.text.trim();\n dialogId = r.dialogId ?? dialogId;\n source = \"alice\";\n steps.push(\"alice:ok\");\n } else {\n retries++;\n text = localChatFallback(q);\n source = \"fallback\";\n }\n } catch (e) {\n retries++;\n steps.push(\n `alice:err:${e instanceof Error ? e.message : String(e)}`,\n );\n text = localChatFallback(q);\n source = \"fallback\";\n }\n }\n }\n\n if (!text.trim()) {\n text = localChatFallback(q);\n source = \"fallback\";\n }\n\n return { text, dialogId, tools, steps, retries, source };\n}\n\nexport async function* runAgentStream(\n userQ: string,\n session: AliceSession,\n opts: SendOptions = {},\n): AsyncGenerator<\n | { type: \"meta\"; tools: ToolName[]; steps: string[] }\n | { type: \"text\"; text: string; dialogId?: string }\n | {\n type: \"done\";\n dialogId?: string;\n retries: number;\n steps: string[];\n source: string;\n }\n> {\n const result = await runAgent(userQ, session, opts);\n yield { type: \"meta\", tools: result.tools, steps: result.steps };\n const t = result.text || \"\";\n for (let i = 0; i < t.length; i += 56) {\n yield {\n type: \"text\",\n text: t.slice(i, i + 56),\n dialogId: result.dialogId,\n };\n }\n yield {\n type: \"done\",\n dialogId: result.dialogId,\n retries: result.retries,\n steps: result.steps,\n source: result.source,\n };\n}\n",[168],"0441a2f2-12f2-457f-b877-4cc17a6c6555","README.md","59c0db16-841d-11f1-a987-1607ee4eb77e",56,["D",1784539749787],4,"# Val Town deploy — Alice OpenAI adapter\n\n## Upload (3 files)\n\nCreate public val, e.g. `alice-openai-adapter`:\n\n| File | Type on Val Town |\n|------|------------------|\n| `main.ts` | **HTTP** |\n| `alice.ts` | Script |\n| `convert.ts` | Script |\n\n## Steps\n\n1. https://www.val.town → New Val → HTTP\n2. Paste `main.ts` into `main.ts` (HTTP)\n3. Add file `alice.ts` (script) — paste contents\n4. Add file `convert.ts` (script) — paste contents\n5. Save → copy endpoint URL from HTTP file\n\nEndpoint looks like:\n```\nhttps://YOURHANDLE--XXXXXXXX.web.val.run\n```\n\n## Use\n\n```\nbase_url = https://YOURHANDLE--....web.val.run/v1\napi_key = anything (ignored)\nmodel = alice\n```\n\n```bash\ncurl https://YOURHANDLE--....web.val.run/v1/chat/completions \\\n -H \"Content-Type: application/json\" \\\n -d '{\"model\":\"alice\",\"messages\":[{\"role\":\"user\",\"content\":\"Привет\"}]}'\n```\n\nNo env vars. Free Alice web, no Yandex Cloud key.\n\n## Notes\n\n- Do **not** upload Node `src/` files (`ws`, `@hono/node-server`)\n- These Val Town files use Deno `WebSocket` + `npm:hono`\n- Val Town free credit / rate limits apply to the HTTP val itself",[176],"pulls","branches",1,"forks","envVars",{"_191":63,"_193":63},"connections",{"_191":63,"_192":63},"count","unfilledCount","emptyCount",{"_43":175,"_32":176,"_30":177,"_139":-5,"_41":42,"_40":178,"_141":59,"_38":216,"_13":180,"_33":20,"_35":181,"_24":25,"_145":-5,"_201":217,"_27":218},{"_43":167,"_32":168,"_30":169,"_139":-5,"_41":42,"_40":170,"_141":25,"_38":213,"_13":172,"_33":34,"_35":173,"_24":25,"_145":-5,"_201":214,"_27":215},{"_43":163,"_32":28,"_30":31,"_139":-5,"_41":42,"_40":14,"_141":25,"_38":210,"_13":165,"_33":34,"_35":37,"_24":25,"_145":-5,"_201":211,"_27":212},{"_43":155,"_32":156,"_30":157,"_139":-5,"_41":42,"_40":158,"_141":59,"_38":207,"_13":160,"_33":34,"_35":161,"_24":25,"_145":-5,"_201":208,"_27":209},{"_43":147,"_32":148,"_30":57,"_139":-5,"_41":42,"_40":149,"_141":25,"_38":204,"_13":151,"_33":152,"_35":153,"_24":25,"_145":-5,"_201":205,"_27":206},{"_43":136,"_32":137,"_30":138,"_139":-5,"_41":42,"_40":140,"_141":25,"_38":200,"_13":143,"_33":34,"_35":144,"_24":25,"_145":-5,"_201":202,"_27":203},["D",1784545085162],"children",[],[137],["D",1784545086172],[],[148],["D",1784542177923],[],[156],["D",1784545285446],[],[28],["D",1784545085796],[],[168],["D",1784539749787],[],[176],["D",1784537552501],["D",1789484509295],{"_100":99,"_107":103},{"_100":99,"_101":99,"_102":103,"_18":55,"_104":105,"_106":25},{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"ctx",{"_82":-5,"_127":257,"_258":259,"_260":261,"_262":25,"_263":25,"_264":25,"_265":59,"_266":-5,"_267":-7,"_268":-7,"_269":63,"_270":25,"_271":25,"_272":-5,"_273":25,"_274":25,"_275":25,"_276":-5},"ENV",{"_228":229,"_230":231,"_232":90,"_233":234,"_235":236,"_237":238,"_239":240,"_241":242,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256},"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 · v118