[{"_1":2,"_171":-5,"_172":-5},"loaderData",{"_3":4,"_92":93},"root",{"_5":6,"_35":36,"_65":66},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20,"_34":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_37":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":48,"_49":50,"_51":52,"_53":54,"_55":56,"_57":58,"_59":60,"_61":62,"_63":64},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","96591c8dbfc078fdbadefbda462961392fdd9880","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","clerkState",{"_67":68},"__internal_clerk_state",{"_69":70,"_71":46,"_72":73,"_74":73,"_75":20,"_76":73,"_77":73,"_78":73,"_79":73,"_80":81,"_90":20,"_91":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_82":20,"_19":20,"_83":73,"_84":85,"_86":73,"_87":46,"_88":20,"_89":73},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_94":95,"_96":97,"_98":99,"_100":101,"_148":149,"_168":169,"_170":-5},"handle","eray","name","stockai","path","main.ts","project",{"_102":103,"_96":97,"_104":105,"_106":-5,"_107":20,"_108":109,"_110":-5,"_111":-5,"_12":112,"_113":-5,"_114":20,"_115":-5,"_116":-5,"_117":32,"_14":118,"_119":120,"_121":120,"_122":123,"_124":123,"_125":123,"_126":120,"_127":120,"_23":128,"_131":132,"_134":135,"_147":20},"id","2693c7d2-e46b-11f0-b29f-42dde27851f2","createdAt",["D",1766980930830],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","019b6841-ac69-77de-9e63-4223363873fa","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","019b6841-ac69-77de-9e63-474462dba6aa","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_94":95,"_129":130},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzM3Vkc4Y1JIQXptMENXUUVFbllpclNjM2xmSCJ9","org",{"_94":95,"_133":130,"_12":112},"avatar","branch",{"_136":137,"_96":44,"_102":138,"_139":103,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":97,"_146":95},"version",13,"26940dfa-e46b-11f0-b29f-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_102":150,"_96":99,"_151":152,"_153":-5,"_154":138,"_155":156,"_157":158,"_104":159,"_136":160,"_161":162,"_163":164,"_165":20,"_166":97,"_98":167},"9fde8f4e-e46d-11f0-a0c8-42dde27851f2","fileId","fd96f7e0-e46b-11f0-ad9b-42dde27851f2","parentId","branchId","branchVersion",12,"latest",true,["D",1766981993240],5,"fileType","http","content","// Deno Deploy Script for StockAI API Proxy\n// 部署到 Deno Deploy 边缘网络\n\n// ==================== 配置变量 ====================\n\n// 环境变量\nconst AUTH_KEYS = (Deno.env.get(\"AUTH_KEYS\") || \"sk-default,sk-false\").split(\",\").map(k => k.trim());\nconst DEBUG = (Deno.env.get(\"DEBUG\") || \"true\") === \"true\";\n\n// 目标地址\nconst BASE_URL = \"https://free.stockai.trade\";\n\n// User-Agent 列表\nconst USER_AGENTS = [\n \"Mozilla/5.0 (Linux; Android 13; Pixel 7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/116.0.0.0 Mobile Safari/537.36\",\n \"Mozilla/5.0 (Linux; Android 14; SM-S918B) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/131.0.0.0 Mobile Safari/537.36\",\n \"Mozilla/5.0 (iPhone; CPU iPhone OS 18_1 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/18.1 Mobile/15E148 Safari/604.1\",\n \"Mozilla/5.0 (Linux; Android 13; SM-G991B) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/130.0.0.0 Mobile Safari/537.36\",\n \"Mozilla/5.0 (iPhone; CPU iPhone OS 17_6 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/17.6 Mobile/15E148 Safari/604.1\",\n \"Mozilla/5.0 (Linux; Android 14; Pixel 8 Pro) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/131.0.0.0 Mobile Safari/537.36\",\n];\n\n// 固定的 AI SDK User-Agent\nconst AI_SDK_UA = \"ai-sdk/5.0.49 runtime/browser\";\n\n// 模型列表\nconst MODELS = [\n { name: \"mistral-devstral-2\", value: \"mistral/devstral-2\" },\n { name: \"glm-4.6v-flash\", value: \"zai/glm-4.6v-flash\" },\n { name: \"News新闻模型\", value: \"stockai/news\" },\n { name: \"gpt-4o-mini\", value: \"arcee-ai/trinity-mini\" },\n { name: \"deepseek-v3\", value: \"deepcogito/cogito-v2.1-671b\" },\n { name: \"gemini-2.5-flash\", value: \"google/gemini-2.0-flash\" },\n { name: \"glm-4.5-air\", value: \"z-ai/glm-4.5-air\" },\n { name: \"glm-4.6\", value: \"z-ai/glm-4.6\" },\n { name: \"kimi-k2\", value: \"moonshotai/kimi-k2\" },\n { name: \"kimi-k2-thinking\", value: \"moonshotai/kimi-k2-thinking\" },\n { name: \"llama-4-scout\", value: \"meta/llama-4-scout\" },\n { name: \"longcat-flash-chat\", value: \"meituan/longcat-flash-chat\" },\n { name: \"longcat-flash-chat-search\", value: \"meituan/longcat-flash-chat-search\" },\n { name: \"gpt-oss-20b\", value: \"openai/gpt-oss-20b\" },\n { name: \"qwen3-coder\", value: \"qwen/qwen3-coder\" },\n { name: \"deepseek-r1\", value: \"alibaba/tongyi-deepresearch-30b-a3b\" },\n];\n\n// ==================== 工具函数 ====================\n\nfunction log(...args: unknown[]) {\n if (DEBUG) {\n console.log(`[${new Date().toISOString()}]`, ...args);\n }\n}\n\nfunction logError(...args: unknown[]) {\n if (DEBUG) {\n console.error(`[${new Date().toISOString()}] [ERROR]`, ...args);\n }\n}\n\nfunction getRandomUserAgent(): string {\n return USER_AGENTS[Math.floor(Math.random() * USER_AGENTS.length)];\n}\n\nfunction generateUUID(): string {\n return crypto.randomUUID();\n}\n\nfunction generateRandomId(length: number = 16): string {\n const chars = \"ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz\";\n let result = \"\";\n for (let i = 0; i < length; i++) {\n result += chars.charAt(Math.floor(Math.random() * chars.length));\n }\n return result;\n}\n\n// ==================== API 鉴权 ====================\n\nfunction authenticateRequest(request: Request): { success: boolean; error?: string } {\n const authHeader = request.headers.get(\"Authorization\");\n \n if (!authHeader) {\n return { success: false, error: \"Missing Authorization header\" };\n }\n \n const parts = authHeader.split(\" \");\n if (parts.length !== 2 || parts[0] !== \"Bearer\") {\n return { success: false, error: \"Invalid Authorization header format. Expected: Bearer \" };\n }\n \n const token = parts[1];\n if (!AUTH_KEYS.includes(token)) {\n return { success: false, error: \"Invalid API key\" };\n }\n \n return { success: true };\n}\n\nfunction createErrorResponse(status: number, message: string, type: string = \"invalid_request_error\"): Response {\n return new Response(JSON.stringify({\n error: {\n message,\n type,\n param: null,\n code: null\n }\n }), {\n status,\n headers: {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n }\n });\n}\n\n// ==================== 模型列表处理 ====================\n\nfunction handleModelsRequest(): Response {\n const timestamp = Math.floor(Date.now() / 1000);\n \n const models: Array<{ id: string; object: string; created: number; owned_by: string }> = [];\n \n for (const model of MODELS) {\n models.push({\n id: model.name,\n object: \"model\",\n created: timestamp,\n owned_by: \"stockai\"\n });\n }\n \n return new Response(JSON.stringify({\n object: \"list\",\n data: models\n }), {\n status: 200,\n headers: {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n }\n });\n}\n\n// ==================== 模型名称映射 ====================\n\nfunction getModelValue(modelName: string): string | null {\n const model = MODELS.find(m => m.name === modelName);\n return model ? model.value : null;\n}\n\nfunction isSearchModel(modelValue: string): boolean {\n return modelValue.includes(\"-search\");\n}\n\n// ==================== 消息格式化 ====================\n\ninterface Message {\n role: string;\n content: string | Array<{ type: string; text?: string; image_url?: { url: string } }>;\n}\n\nfunction formatMessagesToSingleText(messages: Message[]): string {\n return messages.map(msg => {\n let content: string;\n if (typeof msg.content === \"string\") {\n content = msg.content;\n } else if (Array.isArray(msg.content)) {\n content = msg.content\n .filter(item => item.type === \"text\" && item.text)\n .map(item => item.text)\n .join(\" \");\n } else {\n content = \"\";\n }\n return `${msg.role}: ${content}`;\n }).join(\"\\n\");\n}\n\n// ==================== SSE 解析器 ====================\n\ninterface SSEEvent {\n type: string;\n id?: string;\n delta?: string;\n data?: string;\n messageId?: string;\n toolCallId?: string;\n toolName?: string;\n input?: unknown;\n output?: unknown;\n inputTextDelta?: string;\n}\n\nfunction parseSSELine(line: string): SSEEvent | null {\n if (!line.startsWith(\"data: \")) {\n return null;\n }\n \n const data = line.slice(6);\n if (data === \"[DONE]\") {\n return { type: \"done\" };\n }\n \n try {\n return JSON.parse(data) as SSEEvent;\n } catch {\n return null;\n }\n}\n\n// ==================== 工具调用格式化 ====================\n\nfunction formatToolCall(toolName: string, input: unknown): string {\n let markdown = `\\n\\n---\\n**🔧 工具调用: ${toolName}**\\n\\n`;\n \n if (input && typeof input === \"object\") {\n const inputObj = input as Record;\n markdown += \"**参数:**\\n\";\n for (const [key, value] of Object.entries(inputObj)) {\n markdown += `- \\`${key}\\`: ${JSON.stringify(value)}\\n`;\n }\n }\n \n return markdown;\n}\n\nfunction formatToolOutput(toolName: string, output: unknown): string {\n let markdown = `\\n**📋 ${toolName} 结果:**\\n\\n`;\n \n if (output && typeof output === \"object\") {\n const outputObj = output as { content?: Array<{ type: string; text?: string }>, isError?: boolean };\n \n if (outputObj.isError) {\n markdown += \"⚠️ 工具执行出错\\n\";\n }\n \n if (outputObj.content && Array.isArray(outputObj.content)) {\n for (const item of outputObj.content) {\n if (item.type === \"text\" && item.text) {\n // 提取关键信息，格式化输出\n const text = item.text;\n // 尝试解析标题和URL\n const titleMatch = text.match(/Title: (.+?)(?:\\n|$)/);\n const urlMatch = text.match(/URL: (.+?)(?:\\n|$)/);\n \n if (titleMatch && urlMatch) {\n markdown += `- [${titleMatch[1]}](${urlMatch[1]})\\n`;\n } else {\n // 截取前200字符避免过长\n markdown += text.substring(0, 200) + (text.length > 200 ? \"...\" : \"\") + \"\\n\\n\";\n }\n }\n }\n }\n }\n \n markdown += \"\\n---\\n\\n\";\n return markdown;\n}\n\n// ==================== 聊天请求处理 ====================\n\ninterface ChatRequest {\n model: string;\n messages: Message[];\n stream?: boolean;\n temperature?: number;\n max_tokens?: number;\n}\n\nasync function handleChatCompletions(request: Request): Promise {\n let requestBody: ChatRequest;\n \n try {\n requestBody = await request.json();\n } catch {\n return createErrorResponse(400, \"Invalid JSON in request body\");\n }\n \n const { model, messages, stream = false } = requestBody;\n \n if (!model) {\n return createErrorResponse(400, \"Missing 'model' field\");\n }\n \n if (!messages || !Array.isArray(messages) || messages.length === 0) {\n return createErrorResponse(400, \"Missing or invalid 'messages' field\");\n }\n \n // 获取模型对应的 value\n const modelValue = getModelValue(model);\n if (!modelValue) {\n return createErrorResponse(400, `Unknown model: ${model}. Please use model name from /v1/models`);\n }\n \n const webSearch = isSearchModel(modelValue);\n \n log(`Model: ${model}, Value: ${modelValue}, WebSearch: ${webSearch}, Stream: ${stream}`);\n \n // 格式化消息为单条文本\n const formattedMessage = formatMessagesToSingleText(messages);\n log(\"Formatted message:\", formattedMessage.substring(0, 100) + \"...\");\n \n // 获取随机 UA\n const userAgent = getRandomUserAgent();\n log(\"Using User-Agent:\", userAgent);\n \n try {\n // 构造请求体\n const requestId = generateRandomId(16);\n const messageId = generateRandomId(16);\n \n const stockaiRequest = {\n model: modelValue,\n webSearch: webSearch,\n id: requestId,\n messages: [{\n parts: [{\n type: \"text\",\n text: formattedMessage\n }],\n id: messageId,\n role: \"user\"\n }],\n trigger: \"submit-message\"\n };\n \n log(\"Sending request to StockAI...\");\n log(\"Request body:\", JSON.stringify(stockaiRequest));\n \n // 发送请求\n const chatResponse = await fetch(`${BASE_URL}/api/chat`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"user-agent\": AI_SDK_UA,\n \"User-Agent\": userAgent,\n \"Referer\": `${BASE_URL}/`,\n },\n body: JSON.stringify(stockaiRequest)\n });\n \n if (!chatResponse.ok) {\n const errorText = await chatResponse.text();\n logError(\"StockAI API error:\", chatResponse.status, errorText);\n return createErrorResponse(502, `Upstream API error: ${chatResponse.status}`);\n }\n \n // 处理 SSE 响应\n if (stream) {\n return await handleStreamResponse(chatResponse, model);\n } else {\n return await handleNonStreamResponse(chatResponse, model);\n }\n \n } catch (error) {\n logError(\"Error processing chat request:\", error);\n return createErrorResponse(500, `Internal server error: ${error instanceof Error ? error.message : \"Unknown error\"}`);\n }\n}\n\n// ==================== 流式响应处理 ====================\n\nasync function handleStreamResponse(response: Response, model: string): Promise {\n const responseId = `chatcmpl-${generateUUID()}`;\n const timestamp = Math.floor(Date.now() / 1000);\n \n const encoder = new TextEncoder();\n const decoder = new TextDecoder();\n \n const reader = response.body?.getReader();\n if (!reader) {\n return createErrorResponse(500, \"Failed to read response stream\");\n }\n \n let buffer = \"\";\n let reasoningContent = \"\";\n let textContent = \"\";\n let toolCallInfo = \"\";\n let isReasoningPhase = false;\n let isTextPhase = false;\n let sentRoleChunk = false;\n let currentToolName = \"\";\n let currentToolInput = \"\";\n \n const stream = new ReadableStream({\n async start(controller) {\n try {\n // 发送首个块\n const firstChunk = {\n id: responseId,\n object: \"chat.completion.chunk\",\n created: timestamp,\n model: model,\n choices: [{\n index: 0,\n delta: {\n role: \"assistant\",\n content: \"\"\n },\n logprobs: null,\n finish_reason: null\n }]\n };\n controller.enqueue(encoder.encode(`data: ${JSON.stringify(firstChunk)}\\n\\n`));\n sentRoleChunk = true;\n \n while (true) {\n const { done, value } = await reader.read();\n if (done) break;\n \n buffer += decoder.decode(value, { stream: true });\n const lines = buffer.split(\"\\n\");\n buffer = lines.pop() || \"\";\n \n for (const line of lines) {\n if (!line.trim()) continue;\n \n const event = parseSSELine(line);\n if (!event) continue;\n \n log(\"SSE Event:\", event.type, event);\n \n switch (event.type) {\n case \"reasoning-start\":\n isReasoningPhase = true;\n break;\n \n case \"reasoning-delta\":\n if (event.delta) {\n reasoningContent += event.delta;\n // 发送思考内容\n const reasoningChunk = {\n id: responseId,\n object: \"chat.completion.chunk\",\n created: timestamp,\n model: model,\n choices: [{\n index: 0,\n delta: {\n content: null,\n reasoning_content: event.delta\n },\n logprobs: null,\n finish_reason: null\n }]\n };\n controller.enqueue(encoder.encode(`data: ${JSON.stringify(reasoningChunk)}\\n\\n`));\n }\n break;\n \n case \"reasoning-end\":\n isReasoningPhase = false;\n break;\n \n case \"text-start\":\n isTextPhase = true;\n // 如果有工具调用信息，先发送\n if (toolCallInfo) {\n const toolChunk = {\n id: responseId,\n object: \"chat.completion.chunk\",\n created: timestamp,\n model: model,\n choices: [{\n index: 0,\n delta: {\n content: toolCallInfo\n },\n logprobs: null,\n finish_reason: null\n }]\n };\n controller.enqueue(encoder.encode(`data: ${JSON.stringify(toolChunk)}\\n\\n`));\n toolCallInfo = \"\";\n }\n break;\n \n case \"text-delta\":\n if (event.delta) {\n textContent += event.delta;\n const textChunk = {\n id: responseId,\n object: \"chat.completion.chunk\",\n created: timestamp,\n model: model,\n choices: [{\n index: 0,\n delta: {\n content: event.delta\n },\n logprobs: null,\n finish_reason: null\n }]\n };\n controller.enqueue(encoder.encode(`data: ${JSON.stringify(textChunk)}\\n\\n`));\n }\n break;\n \n case \"text-end\":\n isTextPhase = false;\n break;\n \n case \"tool-input-start\":\n currentToolName = event.toolName || \"\";\n currentToolInput = \"\";\n break;\n \n case \"tool-input-delta\":\n if (event.inputTextDelta) {\n currentToolInput += event.inputTextDelta;\n }\n break;\n \n case \"tool-input-available\":\n if (event.toolName && event.input) {\n toolCallInfo += formatToolCall(event.toolName, event.input);\n }\n break;\n \n case \"tool-output-available\":\n if (event.toolName && event.output) {\n toolCallInfo += formatToolOutput(event.toolName, event.output);\n }\n break;\n \n case \"data-text\":\n // 处理 stockai/news 等模型的特殊响应格式\n if (event.data && event.data !== \"Loading...\") {\n const dataChunk = {\n id: responseId,\n object: \"chat.completion.chunk\",\n created: timestamp,\n model: model,\n choices: [{\n index: 0,\n delta: {\n content: event.data\n },\n logprobs: null,\n finish_reason: null\n }]\n };\n controller.enqueue(encoder.encode(`data: ${JSON.stringify(dataChunk)}\\n\\n`));\n }\n break;\n \n case \"done\":\n case \"finish\":\n // 发送结束块\n const finishChunk = {\n id: responseId,\n object: \"chat.completion.chunk\",\n created: timestamp,\n model: model,\n choices: [{\n index: 0,\n delta: {},\n logprobs: null,\n finish_reason: \"stop\"\n }],\n usage: {\n prompt_tokens: 0,\n completion_tokens: textContent.length + reasoningContent.length,\n total_tokens: textContent.length + reasoningContent.length,\n completion_tokens_details: {\n reasoning_tokens: reasoningContent.length\n }\n }\n };\n controller.enqueue(encoder.encode(`data: ${JSON.stringify(finishChunk)}\\n\\n`));\n controller.enqueue(encoder.encode(\"data: [DONE]\\n\\n\"));\n break;\n }\n }\n }\n \n controller.close();\n } catch (error) {\n logError(\"Stream error:\", error);\n controller.error(error);\n }\n }\n });\n \n return new Response(stream, {\n status: 200,\n headers: {\n \"Content-Type\": \"text/event-stream\",\n \"Cache-Control\": \"no-cache\",\n \"Connection\": \"keep-alive\",\n \"Access-Control-Allow-Origin\": \"*\",\n }\n });\n}\n\n// ==================== 非流式响应处理 ====================\n\nasync function handleNonStreamResponse(response: Response, model: string): Promise {\n const responseId = `chatcmpl-${generateUUID()}`;\n const timestamp = Math.floor(Date.now() / 1000);\n \n const decoder = new TextDecoder();\n const reader = response.body?.getReader();\n \n if (!reader) {\n return createErrorResponse(500, \"Failed to read response stream\");\n }\n \n let buffer = \"\";\n let reasoningContent = \"\";\n let textContent = \"\";\n let toolCallInfo = \"\";\n let currentToolName = \"\";\n let currentToolInput = \"\";\n \n // 读取所有 SSE 事件\n while (true) {\n const { done, value } = await reader.read();\n if (done) break;\n \n buffer += decoder.decode(value, { stream: true });\n const lines = buffer.split(\"\\n\");\n buffer = lines.pop() || \"\";\n \n for (const line of lines) {\n if (!line.trim()) continue;\n \n const event = parseSSELine(line);\n if (!event) continue;\n \n log(\"SSE Event (non-stream):\", event.type);\n \n switch (event.type) {\n case \"reasoning-delta\":\n if (event.delta) {\n reasoningContent += event.delta;\n }\n break;\n \n case \"text-delta\":\n if (event.delta) {\n textContent += event.delta;\n }\n break;\n \n case \"tool-input-available\":\n if (event.toolName && event.input) {\n toolCallInfo += formatToolCall(event.toolName, event.input);\n }\n break;\n \n case \"tool-output-available\":\n if (event.toolName && event.output) {\n toolCallInfo += formatToolOutput(event.toolName, event.output);\n }\n break;\n \n case \"data-text\":\n // 处理 stockai/news 等模型的特殊响应格式\n if (event.data && event.data !== \"Loading...\") {\n textContent += event.data;\n }\n break;\n }\n }\n }\n \n // 组合最终内容：工具调用信息 + 正式回复\n const finalContent = toolCallInfo + textContent;\n \n const responseBody = {\n id: responseId,\n object: \"chat.completion\",\n created: timestamp,\n model: model,\n choices: [{\n index: 0,\n message: {\n role: \"assistant\",\n content: finalContent,\n ...(reasoningContent ? { reasoning_content: reasoningContent } : {})\n },\n logprobs: null,\n finish_reason: \"stop\"\n }],\n usage: {\n prompt_tokens: 0,\n completion_tokens: finalContent.length + reasoningContent.length,\n total_tokens: finalContent.length + reasoningContent.length,\n ...(reasoningContent ? {\n completion_tokens_details: {\n reasoning_tokens: reasoningContent.length\n }\n } : {})\n }\n };\n \n return new Response(JSON.stringify(responseBody), {\n status: 200,\n headers: {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n }\n });\n}\n\n// ==================== CORS 预检处理 ====================\n\nfunction handleCORS(): Response {\n return new Response(null, {\n status: 204,\n headers: {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Authorization, X-Requested-With\",\n \"Access-Control-Max-Age\": \"86400\",\n }\n });\n}\n\n// ==================== 主路由处理 ====================\nexport default async function (request: Request): Promise {\n const url = new URL(request.url);\n const path = url.pathname;\n const method = request.method;\n \n log(`${method} ${path}`);\n \n // 处理 CORS 预检请求\n if (method === \"OPTIONS\") {\n return handleCORS();\n }\n \n // 根路径 - 返回服务信息\n if (path === \"/\" || path === \"\") {\n return new Response(JSON.stringify({\n service: \"StockAI OpenAI Compatible API Proxy\",\n version: \"1.0.0\",\n endpoints: {\n models: \"/v1/models\",\n chat: \"/v1/chat/completions\"\n },\n debug: DEBUG,\n availableModels: MODELS.map(m => m.name)\n }), {\n status: 200,\n headers: {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n }\n });\n }\n \n // 健康检查\n if (path === \"/health\") {\n return new Response(JSON.stringify({ status: \"ok\" }), {\n status: 200,\n headers: {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n }\n });\n }\n \n // API 路由 - 需要鉴权\n if (path === \"/v1/models\" && method === \"GET\") {\n const auth = authenticateRequest(request);\n if (!auth.success) {\n return createErrorResponse(401, auth.error!, \"authentication_error\");\n }\n return handleModelsRequest();\n }\n \n if (path === \"/v1/chat/completions\" && method === \"POST\") {\n const auth = authenticateRequest(request);\n if (!auth.success) {\n return createErrorResponse(401, auth.error!, \"authentication_error\");\n }\n return await handleChatCompletions(request);\n }\n \n // 404 - 路由不存在\n return createErrorResponse(404, `Endpoint not found: ${method} ${path}`, \"not_found\");\n}","deleted","label",[99],"permalink","https://www.val.town/x/eray/stockai/code/main.ts","extension","actionData","errors"]