[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_203":204,"_205":206},"routes/_app.x.$handle.$name",{"_106":105,"_39":52,"_114":96,"_34":115,"_13":14,"_116":-5,"_11":117,"_118":119,"_120":121,"_122":123,"_124":125,"_26":-5,"_126":-5,"_127":-5,"_128":33,"_129":130,"_131":31,"_132":-5,"_133":-5,"_134":135},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_50":51,"_39":52,"_45":53,"_54":-5,"_55":33,"_56":57,"_58":57,"_59":60,"_61":-5,"_19":62,"_63":64,"_65":31,"_66":-5,"_67":-5,"_68":69,"_70":71,"_72":73,"_74":75,"_76":77,"_78":-5,"_79":80,"_81":80,"_82":83,"_84":83,"_85":83,"_86":80,"_87":80,"_88":89,"_90":91,"_92":93,"_94":33},"version",16,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","4f252adc-9e65-426f-9eb1-64f13ac56340","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":29,"_30":31,"_32":33,"_34":35,"_36":35},"file",{"_37":38,"_39":35,"_40":41,"_42":44,"_45":46,"_47":14,"_48":49,"_30":33},"previous",{"_37":38,"_39":35,"_40":41,"_42":43},"deleted",true,"deletedHere",false,"path","probe.ts","latestPath","fileId","04cc448c-8419-11f1-9348-1607ee4eb77e","name","fileType","script","content","// Test both WebSocket and HTTP approaches for Alice API\nimport { generateRandomId } from \"./convert.ts\"; // we'll just inline\n\nfunction genId() {\n return Array.from(crypto.getRandomValues(new Uint8Array(16)), (b) =>\n b.toString(16).padStart(2, \"0\")\n ).join(\"\");\n}\n\n// Step 1: Get session data from alice.yandex.ru\nconsole.log(\"=== Fetching alice.yandex.ru for session ===\");\nconst pageResp = await fetch(\"https://alice.yandex.ru/\", {\n headers: {\n \"User-Agent\": \"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\nconst pageText = await pageResp.text();\nconst sk = pageText.match(/\"sk\":\"([^\"]+)\"/)?.[1] ?? \"\";\nconst yandexuid = pageText.match(/\"yandexuid\":\"([^\"]+)\"/)?.[1] ?? \"\";\nconst uuid = pageText.match(/\"uuid\":\"([^\"]+)\"/)?.[1] ?? \"\";\nconst setCookies = pageResp.headers.getSetCookie?.() ?? [];\nconst cookieHeader = setCookies.map((c) => c.split(\";\")[0]).join(\"; \");\n\nconsole.log(\"sk:\", sk);\nconsole.log(\"yandexuid:\", yandexuid);\nconsole.log(\"uuid:\", uuid);\nconsole.log(\"cookies:\", cookieHeader.substring(0, 200));\n\n// Build ARPC headers\nconst appId = \"ru.yandex.webstandalone.desktop\";\nconst supportedFeatures = [\n \"supports_streaming_response\",\n \"supports_markdown_response\",\n \"supports_rich_json_cards\",\n \"supports_default_dialog_as_dedicated\",\n \"supports_unlimited_dialogs_creation\",\n \"supports_multi_model_dialogs\",\n \"print_text_in_message_view\",\n \"show_loader_directive\",\n \"whisper\",\n].join(\",\");\n\nconst arpcHeaders: Record = {\n \"X-Ya-App-Id\": appId,\n \"X-Ya-Uuid\": uuid,\n \"X-Ya-Device-Id\": uuid,\n \"X-Ya-Language\": \"ru\",\n \"Content-Type\": \"application/json\",\n \"X-Ya-Supported-Features\": supportedFeatures,\n \"X-Ya-Application\": JSON.stringify({\n app_id: appId,\n uuid,\n device_id: uuid,\n lang: \"ru\",\n timezone: \"Europe/Moscow\",\n }),\n \"Accept\": \"application/json\",\n \"Origin\": \"https://alice.yandex.ru\",\n \"Referer\": \"https://alice.yandex.ru/\",\n \"Cookie\": cookieHeader,\n};\n\n// Step 2: Try HTTP ARPC - create dialog with messages\nconsole.log(\"\\n=== HTTP ARPC: create_dialog_with_messages ===\");\nconst dialogId = genId();\nconst requestId = genId();\nconst basePath = \"https://alice.yandex.ru/rpc\";\n\nconst body = {\n dialog_id: dialogId,\n request_ids: [requestId],\n messages: [{\n request_id: requestId,\n text: \"Привет\",\n type: \"text\",\n }],\n};\n\ntry {\n const resp = await fetch(`${basePath}/dialog/create_dialog_with_messages`, {\n method: \"POST\",\n headers: arpcHeaders,\n body: JSON.stringify(body),\n });\n const text = await resp.text();\n console.log(\"Status:\", resp.status, resp.statusText);\n console.log(\"Content-Type:\", resp.headers.get(\"content-type\"));\n console.log(\"Body:\", text.substring(0, 500));\n} catch (err) {\n console.log(\"Error:\", err);\n}\n\n// Step 3: Try read_dialog\nconsole.log(\"\\n=== HTTP ARPC: read_dialog ===\");\ntry {\n const resp = await fetch(`${basePath}/dialog/read_dialog`, {\n method: \"POST\",\n headers: arpcHeaders,\n body: JSON.stringify({ dialog_id: dialogId }),\n });\n const text = await resp.text();\n console.log(\"Status:\", resp.status, resp.statusText);\n console.log(\"Body:\", text.substring(0, 500));\n} catch (err) {\n console.log(\"Error:\", err);\n}\n\n// Step 4: Try dialog/list\nconsole.log(\"\\n=== HTTP ARPC: dialog/list ===\");\ntry {\n const resp = await fetch(`${basePath}/dialog/list`, {\n method: \"POST\",\n headers: arpcHeaders,\n body: JSON.stringify({}),\n });\n const text = await resp.text();\n console.log(\"Status:\", resp.status, resp.statusText);\n console.log(\"Body:\", text.substring(0, 500));\n} catch (err) {\n console.log(\"Error:\", err);\n}\n\n// Step 5: Try WebSocket connection\nconsole.log(\"\\n=== WebSocket: connecting to uniproxy ===\");\ntry {\n const ws = new WebSocket(\"wss://uniproxy.alice.yandex.ru/uni.ws\");\n \n const wsResult = new Promise((resolve) => {\n const timeout = setTimeout(() => {\n console.log(\"WebSocket timeout (5s)\");\n try { ws.close(); } catch {}\n resolve(null);\n }, 5000);\n\n ws.onopen = () => {\n console.log(\"WebSocket connected!\");\n // Try sending a TextInput message\n const messageId = genId();\n const reqId = genId();\n const msg = {\n header: {\n namespace: \"Vins\",\n name: \"TextInput\",\n messageId,\n seqNumber: 0,\n dialogId: genId(),\n uuid,\n appId,\n },\n payload: {\n request_id: reqId,\n text: \"Привет\",\n lang: \"ru\",\n },\n };\n console.log(\"Sending:\", JSON.stringify(msg).substring(0, 300));\n ws.send(JSON.stringify(msg));\n };\n\n ws.onmessage = (event) => {\n console.log(\"WebSocket message:\", typeof event.data, String(event.data).substring(0, 500));\n };\n\n ws.onerror = (event) => {\n console.log(\"WebSocket error:\", event);\n clearTimeout(timeout);\n resolve(null);\n };\n\n ws.onclose = (event) => {\n console.log(\"WebSocket closed:\", event.code, event.reason);\n clearTimeout(timeout);\n resolve(null);\n };\n });\n\n await wsResult;\n} catch (err) {\n console.log(\"WebSocket error:\", err);\n}\n","// Test corrected WebSocket message format for Alice\nfunction genId() {\n return Array.from(crypto.getRandomValues(new Uint8Array(16)), (b) =>\n b.toString(16).padStart(2, \"0\")\n ).join(\"\");\n}\n\n// Step 1: Get session data\nconsole.log(\"=== Fetching alice.yandex.ru ===\");\nconst pageResp = await fetch(\"https://alice.yandex.ru/\", {\n headers: {\n \"User-Agent\": \"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\nconst pageText = await pageResp.text();\nconst yandexuid = pageText.match(/\"yandexuid\":\"([^\"]+)\"/)?.[1] ?? \"\";\nconst uuid = pageText.match(/\"uuid\":\"([^\"]+)\"/)?.[1] ?? \"\";\nconst setCookies = pageResp.headers.getSetCookie?.() ?? [];\nconst cookieHeader = setCookies.map((c) => c.split(\";\")[0]).join(\"; \");\nconsole.log(\"uuid:\", uuid, \"yandexuid:\", yandexuid);\n\nconst appId = \"ru.yandex.webstandalone.desktop\";\n\n// Step 2: Get dialog list to find existing dialog\nconsole.log(\"\\n=== dialog/list ===\");\nconst arpcHeaders: Record = {\n \"X-Ya-App-Id\": appId,\n \"X-Ya-Uuid\": uuid,\n \"X-Ya-Device-Id\": uuid,\n \"X-Ya-Language\": \"ru\",\n \"Content-Type\": \"application/json\",\n \"X-Ya-Application\": JSON.stringify({ app_id: appId, uuid, device_id: uuid, lang: \"ru\", timezone: \"Europe/Moscow\" }),\n \"Accept\": \"application/json\",\n \"Origin\": \"https://alice.yandex.ru\",\n \"Referer\": \"https://alice.yandex.ru/\",\n \"Cookie\": cookieHeader,\n};\n\nconst listResp = await fetch(\"https://alice.yandex.ru/rpc/dialog/list\", {\n method: \"POST\",\n headers: arpcHeaders,\n body: JSON.stringify({}),\n});\nconst listData = await listResp.json();\nconsole.log(\"Dialog list:\", JSON.stringify(listData).substring(0, 600));\n\n// Step 3: Try WebSocket with corrected format\nconsole.log(\"\\n=== WebSocket (corrected format) ===\");\nconst ws = new WebSocket(\"wss://uniproxy.alice.yandex.ru/uni.ws\");\n\nawait new Promise((resolve) => {\n let msgCount = 0;\n const timeout = setTimeout(() => {\n console.log(`Timeout. Received ${msgCount} messages.`);\n try { ws.close(); } catch {}\n resolve(null);\n }, 15000);\n\n ws.onopen = () => {\n console.log(\"WS connected!\");\n \n const messageId = genId();\n const requestId = genId();\n \n // Try format: {event: {header: {...}, payload: {...}}}\n const msg = {\n event: {\n header: {\n namespace: \"Vins\",\n name: \"TextInput\",\n messageId,\n seqNumber: 0,\n },\n payload: {\n request_id: requestId,\n text: \"Привет! Скажи пару слов.\",\n dialog_id: null,\n dialog_type: \"DEDICATED_CHAT\",\n lang: \"ru\",\n app_id: appId,\n uuid,\n device_id: uuid,\n platform: \"desktop\",\n application: JSON.stringify({ app_id: appId, uuid, device_id: uuid, lang: \"ru\", timezone: \"Europe/Moscow\" }),\n },\n },\n };\n \n console.log(\"Sending:\", JSON.stringify(msg).substring(0, 400));\n ws.send(JSON.stringify(msg));\n };\n\n ws.onmessage = (event) => {\n msgCount++;\n const data = String(event.data);\n console.log(`\\nWS msg #${msgCount}:`, data.substring(0, 800));\n \n if (msgCount >= 10) {\n clearTimeout(timeout);\n try { ws.close(); } catch {}\n resolve(null);\n }\n };\n\n ws.onerror = (e) => {\n console.log(\"WS error:\", e);\n clearTimeout(timeout);\n resolve(null);\n };\n\n ws.onclose = (e) => {\n console.log(\"WS closed:\", e.code, e.reason);\n clearTimeout(timeout);\n resolve(null);\n };\n});\n","createdAt",["D",1784538068684],"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","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",{"_106":105,"_113":109},"org",{"_106":105,"_107":105,"_108":109,"_19":62,"_110":111,"_112":33},"branch",{"_13":95,"_39":96,"_50":49,"_97":51,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":-5,"_103":52,"_104":105},"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",{"_50":51,"_39":52,"_45":198,"_54":-5,"_55":33,"_56":57,"_58":57,"_59":60,"_61":-5,"_19":62,"_63":64,"_65":31,"_66":-5,"_67":-5,"_68":69,"_70":71,"_72":73,"_74":75,"_76":199,"_78":-5,"_79":80,"_81":80,"_82":83,"_84":83,"_85":83,"_86":80,"_87":80,"_88":200,"_90":201,"_92":202,"_94":33},"tree",[181,182,183,184],"files",[181,182,183,184],"counts",{"_171":69,"_172":161,"_173":69,"_174":175,"_176":177},"contents",[136,137,138,139],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_50":164,"_39":165,"_37":166,"_141":-5,"_48":49,"_47":167,"_142":33,"_45":168,"_13":161,"_40":26,"_42":169,"_30":33,"_145":-5,"_34":170},{"_50":156,"_39":157,"_37":158,"_141":-5,"_48":49,"_47":159,"_142":33,"_45":160,"_13":161,"_40":41,"_42":162,"_30":33,"_145":-5,"_34":163},{"_50":147,"_39":148,"_37":149,"_141":-5,"_48":49,"_47":150,"_142":33,"_45":151,"_13":152,"_40":153,"_42":154,"_30":33,"_145":-5,"_34":155},{"_50":140,"_39":35,"_37":38,"_141":-5,"_48":49,"_47":14,"_142":33,"_45":143,"_13":144,"_40":41,"_42":44,"_30":33,"_145":-5,"_34":146},"040d5f6c-f68d-4efd-aa4b-6ffe5b08b538","parentId","latest",["D",1784538068684],6,"label",[35],"a47519b7-1353-4785-aa41-428d84f09fdc","main.ts","58926db8-8418-11f1-aac1-1607ee4eb77e",8,["D",1784537724082],4,"http","import { Hono } from \"npm:hono\";\nimport {\n buildChunk,\n DEFAULT_MODEL,\n resolveModel,\n toOpenAIError,\n toOpenAIModels,\n toOpenAIResponse,\n toYandexRequest,\n YANDEX_ENDPOINT,\n} from \"./convert.ts\";\nimport type { OpenAIChatRequest } from \"./convert.ts\";\n\nconst app = new Hono();\n\n// Surface full stack traces on errors\napp.onError((err) => Promise.reject(err));\n\n// ── Auth helpers ──────────────────────────────────────────────\n\nfunction getApiKey(c: Parameters[1]>[0]): string | null {\n // Prefer per-request Bearer token, then fall back to env var\n const auth = c.req.header(\"authorization\");\n if (auth?.startsWith(\"Bearer \")) {\n return auth.slice(7);\n }\n return Deno.env.get(\"YANDEX_API_KEY\") ?? null;\n}\n\nfunction getFolderId(\n c: Parameters[1]>[0],\n): string | null {\n // Prefer header, then fall back to env var\n return c.req.header(\"x-folder-id\") ?? Deno.env.get(\"YANDEX_FOLDER_ID\") ??\n null;\n}\n\nfunction authHeaders(apiKey: string, folderId: string): Record {\n return {\n \"Api-Key\": apiKey,\n \"x-folder-id\": folderId,\n \"Content-Type\": \"application/json\",\n };\n}\n\n// ── Routes ────────────────────────────────────────────────────\n\n// Health check\napp.get(\"/\", (c) => c.json({ status: \"ok\", service: \"openai-yandex-adapter\" }));\n\n// List models (OpenAI-compatible)\napp.get(\"/v1/models\", (c) => c.json(toOpenAIModels()));\n\n// Chat completions (the main endpoint)\napp.post(\"/v1/chat/completions\", async (c) => {\n const apiKey = getApiKey(c);\n const folderId = getFolderId(c);\n\n if (!apiKey) {\n return c.json(\n toOpenAIError(\n \"No API key provided. Set YANDEX_API_KEY env var or pass Authorization: Bearer .\",\n \"authentication_error\",\n ),\n 401,\n );\n }\n\n if (!folderId) {\n return c.json(\n toOpenAIError(\n \"No folder ID provided. Set YANDEX_FOLDER_ID env var or pass x-folder-id header.\",\n \"authentication_error\",\n ),\n 401,\n );\n }\n\n let body: OpenAIChatRequest;\n try {\n body = await c.req.json();\n } catch {\n return c.json(\n toOpenAIError(\"Invalid JSON in request body.\"),\n 400,\n );\n }\n\n if (!body.messages?.length) {\n return c.json(\n toOpenAIError(\"messages is required and must not be empty.\", \"invalid_request_error\", \"messages\"),\n 400,\n );\n }\n\n // Default to yandexgpt-lite (free tier) if model is missing\n const requestedModel = body.model || DEFAULT_MODEL;\n const yandexModel = resolveModel(requestedModel);\n body.model = yandexModel;\n\n const yandexReq = toYandexRequest(body, folderId);\n const isStream = body.stream ?? false;\n\n // ── Call Yandex GPT ───────────────────────────────────────\n let yandexResp: Response;\n try {\n yandexResp = await fetch(YANDEX_ENDPOINT, {\n method: \"POST\",\n headers: authHeaders(apiKey, folderId),\n body: JSON.stringify(yandexReq),\n });\n } catch (err) {\n return c.json(\n toOpenAIError(\n `Failed to reach Yandex GPT API: ${err instanceof Error ? err.message : String(err)}`,\n \"api_error\",\n ),\n 502,\n );\n }\n\n if (!yandexResp.ok) {\n const errText = await yandexResp.text().catch(() => \"Unknown error\");\n let errMessage = errText;\n try {\n const errJson = JSON.parse(errText);\n errMessage = errJson.error?.message ?? errJson.message ?? errText;\n } catch { /* keep raw text */ }\n\n // Map Yandex status codes to OpenAI-compatible statuses\n let status: number;\n let errorType: string;\n let errorCode: string | null = null;\n\n if (yandexResp.status === 401 || yandexResp.status === 403) {\n status = 401;\n errorType = \"authentication_error\";\n } else if (yandexResp.status === 429) {\n status = 429;\n errorType = \"rate_limit_error\";\n errorCode = \"rate_limit_exceeded\";\n errMessage = `Rate limit exceeded (free tier). ${errMessage}`;\n } else if (yandexResp.status >= 500) {\n status = 502;\n errorType = \"api_error\";\n } else {\n status = 400;\n errorType = \"api_error\";\n }\n\n return c.json(\n toOpenAIError(\n `Yandex GPT API error (${yandexResp.status}): ${errMessage}`,\n errorType,\n errorCode,\n ),\n status,\n );\n }\n\n // ── Non-streaming response ────────────────────────────────\n if (!isStream) {\n const data = await yandexResp.json();\n return c.json(toOpenAIResponse(data, body.model));\n }\n\n // ── Streaming response (SSE) ──────────────────────────────\n // Yandex streams cumulative text in each SSE event.\n // We diff against previous text to produce OpenAI-style deltas.\n const id = `chatcmpl-${crypto.randomUUID()}`;\n const created = Math.floor(Date.now() / 1000);\n const encoder = new TextEncoder();\n let previousText = \"\";\n let sentRole = false;\n\n const stream = new ReadableStream({\n async start(controller) {\n const reader = yandexResp.body!.getReader();\n const decoder = new TextDecoder();\n let buffer = \"\";\n\n try {\n while (true) {\n const { done, value } = await reader.read();\n if (done) break;\n\n buffer += decoder.decode(value, { stream: true });\n\n // Process complete lines\n while (true) {\n const idx = buffer.indexOf(\"\\n\");\n if (idx === -1) break;\n\n const line = buffer.slice(0, idx).trim();\n buffer = buffer.slice(idx + 1);\n\n if (!line.startsWith(\"data: \")) continue;\n const data = line.slice(6).trim();\n if (!data || data === \"[DONE]\") continue;\n\n try {\n const chunk = JSON.parse(data);\n const alt = chunk.alternatives?.[0];\n if (!alt) continue;\n\n const currentText = alt.message?.text ?? \"\";\n const delta = currentText.slice(previousText.length);\n previousText = currentText;\n\n // First chunk: send the role\n if (!sentRole) {\n controller.enqueue(\n encoder.encode(\n buildChunk(id, created, body.model, { role: \"assistant\" }, null),\n ),\n );\n sentRole = true;\n }\n\n // Send content delta if there's new text\n if (delta) {\n controller.enqueue(\n encoder.encode(\n buildChunk(id, created, body.model, { content: delta }, null),\n ),\n );\n }\n\n // Final chunk: send finish_reason\n if (\n alt.status === \"ALTERNATIVE_STATUS_FINAL\" ||\n alt.status === \"ALTERNATIVE_STATUS_TRUNCATED_FINAL\"\n ) {\n const finishReason = alt.status === \"ALTERNATIVE_STATUS_TRUNCATED_FINAL\"\n ? \"length\"\n : \"stop\";\n controller.enqueue(\n encoder.encode(\n buildChunk(id, created, body.model, {}, finishReason),\n ),\n );\n }\n } catch {\n // Skip malformed JSON lines\n }\n }\n }\n\n // If we never sent a role (empty response), send a minimal one\n if (!sentRole) {\n controller.enqueue(\n encoder.encode(\n buildChunk(id, created, body.model, { role: \"assistant\" }, null),\n ),\n );\n controller.enqueue(\n encoder.encode(\n buildChunk(id, created, body.model, {}, \"stop\"),\n ),\n );\n }\n\n controller.enqueue(encoder.encode(\"data: [DONE]\\n\\n\"));\n controller.close();\n } catch (err) {\n controller.error(err);\n }\n },\n });\n\n return new Response(stream, {\n headers: {\n \"Content-Type\": \"text/event-stream\",\n \"Cache-Control\": \"no-cache\",\n \"Connection\": \"keep-alive\",\n },\n });\n});\n\nexport default app.fetch;\n",[148],"35b7461b-16ad-44fc-bd67-dc09cc3bd8d5","convert.ts","7ffb52c0-8418-11f1-b5d0-1607ee4eb77e",5,["D",1784537712195],1,"// Type definitions and conversion functions between OpenAI and Yandex GPT formats\n\n// ── OpenAI types ──────────────────────────────────────────────\n\nexport interface OpenAIMessage {\n role: \"system\" | \"user\" | \"assistant\";\n content: 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 frequency_penalty?: number;\n presence_penalty?: number;\n n?: number;\n stop?: string | string[];\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 interface OpenAIModelsResponse {\n object: \"list\";\n data: Array<{\n id: string;\n object: \"model\";\n created: number;\n owned_by: string;\n }>;\n}\n\n// ── Yandex GPT types ──────────────────────────────────────────\n\ninterface YandexMessage {\n role: \"system\" | \"user\" | \"assistant\";\n text: string;\n}\n\ninterface YandexCompletionOptions {\n stream: boolean;\n temperature?: number;\n maxTokens?: string;\n topP?: number;\n}\n\nexport interface YandexChatRequest {\n modelUri: string;\n completionOptions: YandexCompletionOptions;\n messages: YandexMessage[];\n}\n\ninterface YandexAlternative {\n message: { role: string; text: string };\n status: string;\n}\n\ninterface YandexResponse {\n alternatives: YandexAlternative[];\n usage?: {\n inputTokens?: string;\n completionTokens?: string;\n totalTokens?: string;\n };\n modelVersion?: string;\n}\n\n// ── Constants ─────────────────────────────────────────────────\n\nexport const YANDEX_ENDPOINT =\n \"https://llm.api.cloud.yandex.net/llm/v1/chat/completions\";\n\nexport const YANDEX_MODELS = [\n { id: \"yandexgpt\", label: \"YandexGPT\" },\n { id: \"yandexgpt-lite\", label: \"YandexGPT Lite\" },\n];\n\n/** Default model when client doesn't specify one. */\nexport const DEFAULT_MODEL = \"yandexgpt-lite\";\n\n/**\n * Map OpenAI model names to Yandex model names.\n * Lets you point any OpenAI SDK directly at this adapter without changing model names.\n */\nconst MODEL_ALIASES: Record = {\n // OpenAI → Yandex\n \"gpt-4\": \"yandexgpt\",\n \"gpt-4o\": \"yandexgpt\",\n \"gpt-4-turbo\": \"yandexgpt\",\n \"gpt-3.5-turbo\": \"yandexgpt-lite\",\n \"gpt-3.5\": \"yandexgpt-lite\",\n // Short aliases\n \"lite\": \"yandexgpt-lite\",\n \"pro\": \"yandexgpt\",\n};\n\n/** Resolve a model name through the alias table. */\nexport function resolveModel(model: string): string {\n return MODEL_ALIASES[model] ?? model;\n}\n\n// ── Conversion functions ──────────────────────────────────────\n\n/** Build a Yandex modelUri from an OpenAI-style model name. */\nexport function buildModelUri(model: string, folderId: string): string {\n // Allow full URIs to pass through directly\n if (model.startsWith(\"gpt://\") || model.startsWith(\"cls://\")) {\n return model;\n }\n return `gpt://${folderId}/${model}/latest`;\n}\n\n/** Convert an OpenAI chat request to Yandex GPT format. */\nexport function toYandexRequest(\n req: OpenAIChatRequest,\n folderId: string,\n): YandexChatRequest {\n const completionOptions: YandexCompletionOptions = {\n stream: req.stream ?? false,\n };\n\n if (req.temperature !== undefined) {\n completionOptions.temperature = req.temperature;\n }\n if (req.max_tokens !== undefined) {\n completionOptions.maxTokens = String(req.max_tokens);\n }\n if (req.top_p !== undefined) {\n completionOptions.topP = req.top_p;\n }\n\n return {\n modelUri: buildModelUri(req.model, folderId),\n completionOptions,\n messages: req.messages.map((m) => ({\n role: m.role,\n text: m.content,\n })),\n };\n}\n\n/** Map Yandex alternative status to OpenAI finish_reason. */\nfunction toFinishReason(status: string): string {\n switch (status) {\n case \"ALTERNATIVE_STATUS_TRUNCATED_FINAL\":\n return \"length\";\n case \"ALTERNATIVE_STATUS_CONTENT_FILTER\":\n return \"content_filter\";\n default:\n return \"stop\";\n }\n}\n\n/** Convert a Yandex GPT response to OpenAI chat completion format. */\nexport function toOpenAIResponse(\n yandexResp: YandexResponse,\n model: string,\n): OpenAIChatResponse {\n const alt = yandexResp.alternatives?.[0];\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: alt ? toFinishReason(alt.status) : \"stop\",\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\n/** Build an OpenAI-format SSE chunk for streaming. */\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\n/** Convert a Yandex error response body to OpenAI error format. */\nexport function toOpenAIError(\n message: string,\n type = \"invalid_request_error\",\n code: string | null = null,\n): OpenAIError {\n return {\n error: { message, type, param: null, code },\n };\n}\n\n/** List available models in OpenAI /v1/models format. */\nexport function toOpenAIModels(): OpenAIModelsResponse {\n const created = Math.floor(Date.now() / 1000);\n return {\n object: \"list\",\n data: YANDEX_MODELS.map((m) => ({\n id: m.id,\n object: \"model\" as const,\n created,\n owned_by: \"yandex\",\n })),\n };\n}\n",[157],"b6750cef-ca51-42f9-b035-9183f7431888","README.md","973ae392-8418-11f1-99d5-1607ee4eb77e",9,["D",1784537745735],"# OpenAI → Yandex GPT API Adapter\n\nDrop-in adapter that lets any OpenAI-compatible client (SDKs, libraries, tools) use **Yandex GPT** as the backend. Works with the Yandex Cloud free tier.\n\n## How it works\n\n```\nClient (OpenAI SDK) ──→ This adapter ──→ Yandex GPT API\n OpenAI format ↕ translate Yandex format\n```\n\nThe adapter translates:\n- **Requests**: OpenAI `POST /v1/chat/completions` → Yandex `llm/v1/chat/completions`\n- **Responses**: Yandex format → OpenAI format\n- **Streaming**: Yandex SSE (cumulative text) → OpenAI SSE (deltas)\n- **Model names**: OpenAI model names auto-mapped to Yandex models\n\n## Endpoints\n\n| Method | Path | Description |\n|--------|------|-------------|\n| `GET` | `/` | Health check |\n| `GET` | `/v1/models` | List available Yandex models |\n| `POST` | `/v1/chat/completions` | Chat completions (streaming + non-streaming) |\n\n## Setup\n\n### 1. Get Yandex Cloud credentials (free tier)\n\nYou need a **folder ID** and an **API key** from Yandex Cloud:\n\n1. Go to [Yandex Cloud Console](https://console.yandex.cloud/)\n2. Create or select a folder, copy its **Folder ID**\n3. Create a **Service Account** → generate an **API Key**\n4. No payment method required for the free tier\n\n### 2. Set environment variables\n\n- `YANDEX_FOLDER_ID` — your Yandex Cloud folder ID\n- `YANDEX_API_KEY` — your Yandex Cloud API key\n\n👉 Add YANDEX_FOLDER_ID here: https://www.val.town/x/dmkrj/openai-yandex-adapter/environment-variables?key=YANDEX_FOLDER_ID\n\n👉 Add YANDEX_API_KEY here: https://www.val.town/x/dmkrj/openai-yandex-adapter/environment-variables?key=YANDEX_API_KEY\n\nYou can also pass credentials per-request:\n- `Authorization: Bearer ` header\n- `x-folder-id: ` header\n\n### 3. Use with any OpenAI client\n\n```python\nfrom openai import OpenAI\n\nclient = OpenAI(\n base_url=\"https://dmkrj--58926db8841811f1aac11607ee4eb77e.web.val.run/v1\",\n api_key=\"\",\n)\n\nresponse = client.chat.completions.create(\n model=\"yandexgpt-lite\", # or \"gpt-3.5-turbo\" — auto-mapped!\n messages=[\n {\"role\": \"system\", \"content\": \"You are a helpful assistant.\"},\n {\"role\": \"user\", \"content\": \"Hello!\"},\n ],\n)\nprint(response.choices[0].message.content)\n```\n\n```javascript\nimport OpenAI from \"openai\";\n\nconst client = new OpenAI({\n baseURL: \"https://dmkrj--58926db8841811f1aac11607ee4eb77e.web.val.run/v1\",\n apiKey: \"\",\n});\n\nconst response = await client.chat.completions.create({\n model: \"yandexgpt-lite\",\n messages: [{ role: \"user\", content: \"Hello!\" }],\n});\nconsole.log(response.choices[0].message.content);\n```\n\n**Streaming** works too — just set `stream: true`:\n\n```python\nstream = client.chat.completions.create(\n model=\"yandexgpt-lite\",\n messages=[{\"role\": \"user\", \"content\": \"Write a haiku about coding.\"}],\n stream=True,\n)\nfor chunk in stream:\n print(chunk.choices[0].delta.content or \"\", end=\"\", flush=True)\n```\n\n## Model aliases\n\nThe adapter automatically maps OpenAI model names to Yandex models, so you can use existing OpenAI SDK code without changes:\n\n| OpenAI model name | Yandex model |\n|-------------------|-------------|\n| `gpt-4` | `yandexgpt` |\n| `gpt-4o` | `yandexgpt` |\n| `gpt-4-turbo` | `yandexgpt` |\n| `gpt-3.5-turbo` | `yandexgpt-lite` |\n| `gpt-3.5` | `yandexgpt-lite` |\n| `yandexgpt` | `yandexgpt` |\n| `yandexgpt-lite` | `yandexgpt-lite` |\n| *(omitted)* | `yandexgpt-lite` (default) |\n\nYou can also pass a full Yandex model URI directly (e.g. `gpt:///yandexgpt/rc1`).\n\n## Supported parameters\n\n| OpenAI param | Yandex equivalent | Notes |\n|--------------|-------------------|-------|\n| `model` | `modelUri` | Auto-mapped via aliases, defaults to `yandexgpt-lite` |\n| `messages` | `messages` | `content` → `text` |\n| `temperature` | `temperature` | Passed through |\n| `max_tokens` | `maxTokens` | Converted to string |\n| `top_p` | `topP` | Passed through |\n| `stream` | `stream` | SSE delta conversion |\n\n## Error handling\n\nThe adapter maps Yandex errors to OpenAI-compatible error format:\n\n| Yandex status | Adapter status | Error type |\n|---------------|---------------|------------|\n| 401 / 403 | 401 | `authentication_error` |\n| 429 | 429 | `rate_limit_error` |\n| 5xx | 502 | `api_error` |\n| 4xx | 400 | `api_error` |\n\n## Architecture\n\n```mermaid\ngraph LR\n A[OpenAI Client] -->|POST /v1/chat/completions| B[Adapter - Hono]\n B -->|resolveModel + toYandexRequest| C[Convert]\n C -->|fetch| D[Yandex GPT API]\n D -->|Response / SSE| B\n B -->|toOpenAIResponse| E[OpenAI-format JSON / SSE]\n E --> A\n```\n\n## Files\n\n- `main.ts` — HTTP handler (Hono routes, auth, streaming, rate-limit handling)\n- `convert.ts` — Type definitions, model aliases, and format conversion functions\n",[165],"pulls","branches","forks","envVars",{"_178":69,"_180":69},"connections",{"_178":69,"_179":69},"count","unfilledCount","emptyCount",{"_50":164,"_39":165,"_37":166,"_141":-5,"_48":49,"_47":167,"_142":33,"_45":195,"_13":161,"_40":26,"_42":169,"_30":33,"_145":-5,"_186":196,"_34":197},{"_50":156,"_39":157,"_37":158,"_141":-5,"_48":49,"_47":159,"_142":33,"_45":192,"_13":161,"_40":41,"_42":162,"_30":33,"_145":-5,"_186":193,"_34":194},{"_50":147,"_39":148,"_37":149,"_141":-5,"_48":49,"_47":150,"_142":33,"_45":189,"_13":152,"_40":153,"_42":154,"_30":33,"_145":-5,"_186":190,"_34":191},{"_50":140,"_39":35,"_37":38,"_141":-5,"_48":49,"_47":14,"_142":33,"_45":185,"_13":144,"_40":41,"_42":44,"_30":33,"_145":-5,"_186":187,"_34":188},["D",1784538068684],"children",[],[35],["D",1784537724082],[],[148],["D",1784537712195],[],[157],["D",1784537745735],[],[165],["D",1784537552501],["D",1789484509295],{"_106":105,"_113":109},{"_106":105,"_107":105,"_108":109,"_19":62,"_110":111,"_112":33},{"_13":95,"_39":96,"_50":49,"_97":51,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":-5,"_103":52,"_104":105},"ctx",{"_88":-5,"_133":236,"_237":238,"_239":240,"_241":33,"_242":33,"_243":33,"_244":31,"_245":-5,"_246":-7,"_247":-7,"_248":69,"_249":33,"_250":33,"_251":-5,"_252":33,"_253":33,"_254":33,"_255":-5},"ENV",{"_207":208,"_209":210,"_211":96,"_212":213,"_214":215,"_216":217,"_218":219,"_220":221,"_222":223,"_224":225,"_226":227,"_228":229,"_230":231,"_232":233,"_234":235},"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 · v16