[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_190":191,"_192":193},"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",7,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","9769a2d4-3a72-45a5-bc30-a209d2b44a30","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","main.ts","latestPath","fileId","58926db8-8418-11f1-aac1-1607ee4eb77e","name","fileType","http","content","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 if (!body.model) {\n return c.json(\n toOpenAIError(\"model is required.\", \"invalid_request_error\", \"model\"),\n 400,\n );\n }\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 const status = yandexResp.status === 401 || yandexResp.status === 403\n ? 401\n : yandexResp.status >= 500\n ? 502\n : 400;\n\n return c.json(\n toOpenAIError(\n `Yandex GPT API error (${yandexResp.status}): ${errMessage}`,\n status === 401 ? \"authentication_error\" : \"api_error\",\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","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 const status = yandexResp.status === 401 || yandexResp.status === 403\n ? 401\n : yandexResp.status >= 500\n ? 502\n : 400;\n\n return c.json(\n toOpenAIError(\n `Yandex GPT API error (${yandexResp.status}): ${errMessage}`,\n status === 401 ? \"authentication_error\" : \"api_error\",\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","createdAt",["D",1784537719006],"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",1789571433983],"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":185,"_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":186,"_78":-5,"_79":80,"_81":80,"_82":83,"_84":83,"_85":83,"_86":80,"_87":80,"_88":187,"_90":188,"_92":189,"_94":33},"tree",[172,173,174],"files",[172,173,174],"counts",{"_162":69,"_163":151,"_164":69,"_165":166,"_167":168},"contents",[136,137,138],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_50":155,"_39":156,"_37":157,"_140":-5,"_48":49,"_47":158,"_141":33,"_45":159,"_13":69,"_40":26,"_42":160,"_30":33,"_144":-5,"_34":161},{"_50":146,"_39":147,"_37":148,"_140":-5,"_48":49,"_47":149,"_141":33,"_45":150,"_13":151,"_40":152,"_42":153,"_30":33,"_144":-5,"_34":154},{"_50":139,"_39":35,"_37":38,"_140":-5,"_48":49,"_47":14,"_141":33,"_45":142,"_13":143,"_40":41,"_42":44,"_30":33,"_144":-5,"_34":145},"54c2b834-5285-4496-8d71-f11855de3186","parentId","latest",["D",1784537719006],3,"label",[35],"35b7461b-16ad-44fc-bd67-dc09cc3bd8d5","convert.ts","7ffb52c0-8418-11f1-b5d0-1607ee4eb77e",5,["D",1784537712195],1,"script","// 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",[147],"a846ea0c-ade8-44c5-9ee4-830c1f676288","README.md","973ae392-8418-11f1-99d5-1607ee4eb77e",4,["D",1784537657640],"# OpenAI → Yandex GPT API Adapter\n\nDrop-in adapter that lets any OpenAI-compatible client (SDKs, libraries, tools) use **Yandex GPT** as the backend.\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\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\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**\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 instead of using env vars:\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\",\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\",\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\",\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## Supported models\n\n| Model name | Description |\n|------------|-------------|\n| `yandexgpt` | YandexGPT (full model) |\n| `yandexgpt-lite` | YandexGPT Lite (faster, cheaper) |\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-prefixed with folder ID |\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## Architecture\n\n```mermaid\ngraph LR\n A[OpenAI Client] -->|POST /v1/chat/completions| B[Adapter - Hono]\n B -->|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)\n- `convert.ts` — Type definitions and format conversion functions\n",[156],"pulls","branches","forks","envVars",{"_169":69,"_171":69},"connections",{"_169":69,"_170":69},"count","unfilledCount","emptyCount",{"_50":155,"_39":156,"_37":157,"_140":-5,"_48":49,"_47":158,"_141":33,"_45":182,"_13":69,"_40":26,"_42":160,"_30":33,"_144":-5,"_176":183,"_34":184},{"_50":146,"_39":147,"_37":148,"_140":-5,"_48":49,"_47":149,"_141":33,"_45":179,"_13":151,"_40":152,"_42":153,"_30":33,"_144":-5,"_176":180,"_34":181},{"_50":139,"_39":35,"_37":38,"_140":-5,"_48":49,"_47":14,"_141":33,"_45":175,"_13":143,"_40":41,"_42":44,"_30":33,"_144":-5,"_176":177,"_34":178},["D",1784537719006],"children",[],[35],["D",1784537712195],[],[147],["D",1784537657640],[],[156],["D",1784537552501],["D",1789571433983],{"_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":223,"_224":225,"_226":227,"_228":33,"_229":33,"_230":33,"_231":31,"_232":-5,"_233":-7,"_234":-7,"_235":69,"_236":33,"_237":33,"_238":-5,"_239":33,"_240":33,"_241":33,"_242":-5},"ENV",{"_194":195,"_196":197,"_198":96,"_199":200,"_201":202,"_203":204,"_205":206,"_207":208,"_209":210,"_211":212,"_213":214,"_215":216,"_217":218,"_219":220,"_221":222},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","5015b8df46402d8bba4f485ecc37aec202b0e06b","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 · v7