Upload 2 files

src/index.js

@@ -85,7 +85,7 @@ app.use(async (ctx, next) => {
 })
 
 const makeRequest = async (session_id, requestModel, messages) => {
-  console.log('开始请求 genspark.ai:', { session_id, requestModel })
+  console.log('开始请求:', { session_id: '***', model: requestModel })
   try {
     // 设置请求头
     const myHeaders = new Headers()
@@ -111,12 +111,6 @@ const makeRequest = async (session_id, requestModel, messages) => {
       }
     })
 
-    console.log('请求配置:', {
-      url: "https://www.genspark.ai/api/copilot/ask",
-      headers: Object.fromEntries(myHeaders.entries()),
-      body: JSON.parse(body)
-    })
-
     const requestConfig = {
       method: 'POST',
       headers: myHeaders,
@@ -125,11 +119,6 @@ const makeRequest = async (session_id, requestModel, messages) => {
     };
 
     const response = await fetch("https://www.genspark.ai/api/copilot/ask", requestConfig)
-    console.log('收到响应:', {
-      status: response.status,
-      statusText: response.statusText,
-      headers: Object.fromEntries(response.headers.entries())
-    })
     
     if (!response.ok) {
       throw new Error(`HTTP error! status: ${response.status}`)
@@ -147,12 +136,10 @@ const handleChatCompletions = async (ctx) => {
   const { messages, stream = false, model = 'claude-3-5-sonnet' } = ctx.request.body
   const session_id = ctx.get('Authorization')?.replace('Bearer ', '')
 
-  console.log('收到聊天请求:', {
+  console.log('收到请求:', {
     path: ctx.path,
-    method: ctx.method,
     model,
     stream,
-    session_id: session_id ? '***' : undefined,
     messages_count: messages?.length
   })
 
@@ -169,21 +156,15 @@ const handleChatCompletions = async (ctx) => {
       throw new Error('Response body is null')
     }
 
-    console.log('处理响应中...', {
-      status: response.status,
-      headers: Object.fromEntries(response.headers.entries()),
-      stream
-    })
-
     if (stream == "true" || stream == true) {
-      ctx.status = 200  // 明确设置状态码
+      ctx.status = 200
       ctx.set({
         'Content-Type': 'text/event-stream',
         'Cache-Control': 'no-cache',
         'Connection': 'keep-alive',
       })
     } else {
-      ctx.status = 200  // 明确设置状态码
+      ctx.status = 200
       ctx.set({
         'Content-Type': 'application/json',
       })
@@ -227,7 +208,6 @@ const handleChatCompletions = async (ctx) => {
         const { done, value } = await reader.read()
         if (done) {
           if (stream == "true" || stream == true) {
-            console.log('流式响应完成')
             ctx.res.write('data: [DONE]\n\n')
           }
           break
@@ -235,7 +215,6 @@ const handleChatCompletions = async (ctx) => {
 
         if (stream == "true" || stream == true) {
           const text = new TextDecoder().decode(value)
-          console.log('处理流式数据块:', text.length, '字节')
           const textContent = [...text.matchAll(/data:.*"}/g)]
 
           textContent.forEach(item => {
@@ -293,14 +272,12 @@ const handleChatCompletions = async (ctx) => {
         }
         ctx.body = resBody
       } else {
-        console.log('正常结束流式响应')
         ctx.res.end()
       }
     } catch (error) {
-      console.error('流式响应出错:', error)
+      console.error('响应处理出错:', error)
       if (stream == "true" || stream == true) {
         try {
-          console.log('发送错误信息到流')
           ctx.res.write(`data: ${JSON.stringify({
             "id": `chatcmpl-${messageId}`,
             "choices": [
@@ -322,8 +299,8 @@ const handleChatCompletions = async (ctx) => {
           ctx.res.end()
         }
       } else {
-      ctx.status = 500
-      ctx.body = { error: '流式响应处理失败', details: error.toString() }
+        ctx.status = 500
+        ctx.body = { error: '响应处理失败', details: error.toString() }
       }
     }
   } catch (error) {