添加指纹请求器，添加真正的非流

config.json

@@ -6,6 +6,7 @@
   "api": {
     "url": "https://daily-cloudcode-pa.sandbox.googleapis.com/v1internal:streamGenerateContent?alt=sse",
     "modelsUrl": "https://daily-cloudcode-pa.sandbox.googleapis.com/v1internal:fetchAvailableModels",
+    "noStreamUrl": "https://daily-cloudcode-pa.sandbox.googleapis.com/v1internal:generateContent",
     "host": "daily-cloudcode-pa.sandbox.googleapis.com",
     "userAgent": "antigravity/1.11.3 windows/amd64"
   },

src/AntigravityRequester.js

@@ -22,14 +22,14 @@ class antigravityRequester {
         const arch = os.arch();
         
         let filename;
-        if (platform === 'win32' && arch === 'x64') {
+        if (platform === 'win32') {
             filename = 'antigravity_requester_windows_amd64.exe';
-        } else if (platform === 'android' && arch === 'arm64') {
+        } else if (platform === 'android') {
             filename = 'antigravity_requester_android_arm64';
-        } else if (platform === 'linux' && arch === 'x64') {
+        } else if (platform === 'linux') {
             filename = 'antigravity_requester_linux_amd64';
         } else {
-            throw new Error(`Unsupported platform/architecture: ${platform}/${arch}. Only supports: windows/x64, android/arm64, linux/x64`);
+            throw new Error(`Unsupported platform: ${platform}`);
         }
         
         const binPath = this.binPath || path.join(__dirname, 'bin');
@@ -57,35 +57,45 @@ class antigravityRequester {
             this.proc.stdin.setDefaultEncoding('utf8');
         }
 
+        // 增大 stdout 缓冲区以减少背压
+        if (this.proc.stdout.setEncoding) {
+            this.proc.stdout.setEncoding('utf8');
+        }
+        
+        // 使用 setImmediate 异步处理数据,避免阻塞
         this.proc.stdout.on('data', (data) => {
             this.buffer += data.toString();
-            const lines = this.buffer.split('\n');
-            this.buffer = lines.pop();
+            
+            // 使用 setImmediate 异步处理,避免阻塞 stdout 读取
+            setImmediate(() => {
+                const lines = this.buffer.split('\n');
+                this.buffer = lines.pop();
 
-            for (const line of lines) {
-                if (!line.trim()) continue;
-                try {
-                    const response = JSON.parse(line);
-                    const pending = this.pendingRequests.get(response.id);
-                    if (!pending) continue;
+                for (const line of lines) {
+                    if (!line.trim()) continue;
+                    try {
+                        const response = JSON.parse(line);
+                        const pending = this.pendingRequests.get(response.id);
+                        if (!pending) continue;
 
-                    if (pending.streamResponse) {
-                        pending.streamResponse._handleChunk(response);
-                        if (response.type === 'end' || response.type === 'error') {
-                            this.pendingRequests.delete(response.id);
-                        }
-                    } else {
-                        this.pendingRequests.delete(response.id);
-                        if (response.ok) {
-                            pending.resolve(new antigravityResponse(response));
+                        if (pending.streamResponse) {
+                            pending.streamResponse._handleChunk(response);
+                            if (response.type === 'end' || response.type === 'error') {
+                                this.pendingRequests.delete(response.id);
+                            }
                         } else {
-                            pending.reject(new Error(response.error || 'Request failed'));
+                            this.pendingRequests.delete(response.id);
+                            if (response.ok) {
+                                pending.resolve(new antigravityResponse(response));
+                            } else {
+                                pending.reject(new Error(response.error || 'Request failed'));
+                            }
                         }
+                    } catch (e) {
+                        console.error('Failed to parse response:', e, 'Line:', line);
                     }
-                } catch (e) {
-                    console.error('Failed to parse response:', e);
                 }
-            }
+            });
         });
 
         this.proc.stderr.on('data', (data) => {

src/api/client.js

@@ -17,6 +17,53 @@ if (config.useNativeFetch !== true) {
   useNativeFetch = true;
 }
 
+function processStreamLine(line, state, callback) {
+  if (!line.startsWith('data: ')) return;
+  
+  try {
+    const data = JSON.parse(line.slice(6));
+    const parts = data.response?.candidates?.[0]?.content?.parts;
+    
+    if (parts) {
+      for (const part of parts) {
+        if (part.thought === true) {
+          if (!state.thinkingStarted) {
+            callback({ type: 'thinking', content: '<think>\n' });
+            state.thinkingStarted = true;
+          }
+          callback({ type: 'thinking', content: part.text || '' });
+        } else if (part.text !== undefined) {
+          if (state.thinkingStarted) {
+            callback({ type: 'thinking', content: '\n</think>\n' });
+            state.thinkingStarted = false;
+          }
+          callback({ type: 'text', content: part.text });
+        } else if (part.functionCall) {
+          state.toolCalls.push({
+            id: part.functionCall.id || generateToolCallId(),
+            type: 'function',
+            function: {
+              name: part.functionCall.name,
+              arguments: JSON.stringify(part.functionCall.args)
+            }
+          });
+        }
+      }
+    }
+    
+    if (data.response?.candidates?.[0]?.finishReason && state.toolCalls.length > 0) {
+      if (state.thinkingStarted) {
+        callback({ type: 'thinking', content: '\n</think>\n' });
+        state.thinkingStarted = false;
+      }
+      callback({ type: 'tool_calls', tool_calls: state.toolCalls });
+      state.toolCalls = [];
+    }
+  } catch (e) {
+    // 忽略解析错误
+  }
+}
+
 export async function generateAssistantResponse(requestBody, callback) {
   const token = await tokenManager.getToken();
   
@@ -43,8 +90,7 @@ export async function generateAssistantResponse(requestBody, callback) {
     body: JSON.stringify(requestBody)
   });
 
-  let thinkingStarted = false;
-  let toolCalls = [];
+  const state = { thinkingStarted: false, toolCalls: [] };
   let buffer = '';
   let errorBody = '';
   let statusCode = null;
@@ -53,9 +99,7 @@ export async function generateAssistantResponse(requestBody, callback) {
     streamResponse
       .onStart(({ status }) => {
         statusCode = status;
-        if (status === 403) {
-          tokenManager.disableCurrentToken(token);
-        }
+        if (status === 403) tokenManager.disableCurrentToken(token);
       })
       .onData((chunk) => {
         if (statusCode !== 200) {
@@ -67,50 +111,7 @@ export async function generateAssistantResponse(requestBody, callback) {
         const lines = buffer.split('\n');
         buffer = lines.pop();
         
-        for (const line of lines.filter(l => l.startsWith('data: '))) {
-          const jsonStr = line.slice(6);
-          try {
-            const data = JSON.parse(jsonStr);
-            const parts = data.response?.candidates?.[0]?.content?.parts;
-            if (parts) {
-              for (const part of parts) {
-                if (part.thought === true) {
-                  if (!thinkingStarted) {
-                    callback({ type: 'thinking', content: '<think>\n' });
-                    thinkingStarted = true;
-                  }
-                  callback({ type: 'thinking', content: part.text || '' });
-                } else if (part.text !== undefined) {
-                  if (thinkingStarted) {
-                    callback({ type: 'thinking', content: '\n</think>\n' });
-                    thinkingStarted = false;
-                  }
-                  callback({ type: 'text', content: part.text });
-                } else if (part.functionCall) {
-                  toolCalls.push({
-                    id: part.functionCall.id || generateToolCallId(),
-                    type: 'function',
-                    function: {
-                      name: part.functionCall.name,
-                      arguments: JSON.stringify(part.functionCall.args)
-                    }
-                  });
-                }
-              }
-            }
-            
-            if (data.response?.candidates?.[0]?.finishReason && toolCalls.length > 0) {
-              if (thinkingStarted) {
-                callback({ type: 'thinking', content: '\n</think>\n' });
-                thinkingStarted = false;
-              }
-              callback({ type: 'tool_calls', tool_calls: toolCalls });
-              toolCalls = [];
-            }
-          } catch (e) {
-            // 忽略解析错误
-          }
-        }
+        lines.forEach(line => processStreamLine(line, state, callback));
       })
       .onEnd(() => {
         if (statusCode === 403) {
@@ -164,17 +165,16 @@ async function generateWithNativeFetch(url, headers, requestBody, callback, toke
     body: JSON.stringify(requestBody)
   });
 
-  if (response.status === 403) {
-    tokenManager.disableCurrentToken(token);
-    throw new Error('该账号没有使用权限，已自动禁用');
-  }
-
   if (!response.ok) {
-    throw new Error(`API请求失败 (${response.status})`);
+    const errorBody = await response.text();
+    if (response.status === 403) {
+      tokenManager.disableCurrentToken(token);
+      throw new Error(`该账号没有使用权限，已自动禁用。错误详情: ${errorBody}`);
+    }
+    throw new Error(`API请求失败 (${response.status}): ${errorBody}`);
   }
 
-  let thinkingStarted = false;
-  let toolCalls = [];
+  const state = { thinkingStarted: false, toolCalls: [] };
   const reader = response.body.getReader();
   const decoder = new TextDecoder();
   let buffer = '';
@@ -187,51 +187,68 @@ async function generateWithNativeFetch(url, headers, requestBody, callback, toke
     const lines = buffer.split('\n');
     buffer = lines.pop();
 
-    for (const line of lines.filter(l => l.startsWith('data: '))) {
-      const jsonStr = line.slice(6);
-      try {
-        const data = JSON.parse(jsonStr);
-        const parts = data.response?.candidates?.[0]?.content?.parts;
-        if (parts) {
-          for (const part of parts) {
-            if (part.thought === true) {
-              if (!thinkingStarted) {
-                callback({ type: 'thinking', content: '<think>\n' });
-                thinkingStarted = true;
-              }
-              callback({ type: 'thinking', content: part.text || '' });
-            } else if (part.text !== undefined) {
-              if (thinkingStarted) {
-                callback({ type: 'thinking', content: '\n</think>\n' });
-                thinkingStarted = false;
-              }
-              callback({ type: 'text', content: part.text });
-            } else if (part.functionCall) {
-              toolCalls.push({
-                id: part.functionCall.id || generateToolCallId(),
-                type: 'function',
-                function: {
-                  name: part.functionCall.name,
-                  arguments: JSON.stringify(part.functionCall.args)
-                }
-              });
-            }
-          }
-        }
+    lines.forEach(line => processStreamLine(line, state, callback));
+  }
+}
 
-        if (data.response?.candidates?.[0]?.finishReason && toolCalls.length > 0) {
-          if (thinkingStarted) {
-            callback({ type: 'thinking', content: '\n</think>\n' });
-            thinkingStarted = false;
-          }
-          callback({ type: 'tool_calls', tool_calls: toolCalls });
-          toolCalls = [];
+export async function generateAssistantResponseNoStream(requestBody) {
+  const token = await tokenManager.getToken();
+  
+  if (!token) {
+    throw new Error('没有可用的token，请运行 npm run login 获取token');
+  }
+  
+  const response = await fetch(config.api.noStreamUrl, {
+    method: 'POST',
+    headers: {
+      'Host': config.api.host,
+      'User-Agent': config.api.userAgent,
+      'Authorization': `Bearer ${token.access_token}`,
+      'Content-Type': 'application/json',
+      'Accept-Encoding': 'gzip'
+    },
+    body: JSON.stringify(requestBody)
+  });
+
+  if (!response.ok) {
+    const errorBody = await response.text();
+    if (response.status === 403) {
+      tokenManager.disableCurrentToken(token);
+      throw new Error(`该账号没有使用权限，已自动禁用。错误详情: ${errorBody}`);
+    }
+    throw new Error(`API请求失败 (${response.status}): ${errorBody}`);
+  }
+
+  const data = await response.json();
+  //console.log(JSON.stringify(data,null,2))
+  const parts = data.response?.candidates?.[0]?.content?.parts || [];
+  
+  let content = '';
+  let thinkingContent = '';
+  const toolCalls = [];
+  
+  for (const part of parts) {
+    if (part.thought === true) {
+      thinkingContent += part.text || '';
+    } else if (part.text !== undefined) {
+      content += part.text;
+    } else if (part.functionCall) {
+      toolCalls.push({
+        id: part.functionCall.id || generateToolCallId(),
+        type: 'function',
+        function: {
+          name: part.functionCall.name,
+          arguments: JSON.stringify(part.functionCall.args)
         }
-      } catch (e) {
-        // 忽略解析错误
-      }
+      });
     }
   }
+  
+  if (thinkingContent) {
+    content = `<think>\n${thinkingContent}\n</think>\n${content}`;
+  }
+  
+  return { content, toolCalls };
 }
 
 export function closeRequester() {

src/bin/antigravity_requester_android_arm64

@@ -1,3 +1,3 @@
 version https://git-lfs.github.com/spec/v1
-oid sha256:39d953841d55d4673f77fb2a225d76bc202569a3726ed476a7daaa218e3d4bd6
+oid sha256:198c940794a575933d68803f15280658a3674eafb45c90e76b6c8f7cf360da94
 size 8192353

src/bin/antigravity_requester_linux_amd64

@@ -1,3 +1,3 @@
 version https://git-lfs.github.com/spec/v1
-oid sha256:9f362ec3859dc5d189f67de7d7426ab88e9c84819697dca2e3e7ac3d6b1a0846
+oid sha256:1375c1b833468b4b04998753f76697412920b1d32aeddfc8ba6daaf98723d63f
 size 7930040

src/bin/antigravity_requester_windows_amd64.exe

@@ -1,3 +1,3 @@
 version https://git-lfs.github.com/spec/v1
-oid sha256:a755b4a7cb2bdadd278c5701c13e3d9bcd03d0051df66f6b5a4745e81f229a77
-size 8096768
+oid sha256:e957f08b72e519e470641ab327dcd59514d6fe5005b238379e501672fa67bb41
+size 8097792

src/config/config.js

@@ -6,6 +6,7 @@ const defaultConfig = {
   api: {
     url: 'https://daily-cloudcode-pa.sandbox.googleapis.com/v1internal:streamGenerateContent?alt=sse',
     modelsUrl: 'https://daily-cloudcode-pa.sandbox.googleapis.com/v1internal:fetchAvailableModels',
+    noStreamUrl: "https://daily-cloudcode-pa.sandbox.googleapis.com/v1internal:generateContent",
     host: 'daily-cloudcode-pa.sandbox.googleapis.com',
     userAgent: 'antigravity/1.11.3 windows/amd64'
   },

src/server/index.js

@@ -1,5 +1,5 @@
 import express from 'express';
-import { generateAssistantResponse, getAvailableModels, closeRequester } from '../api/client.js';
+import { generateAssistantResponse, generateAssistantResponseNoStream, getAvailableModels, closeRequester } from '../api/client.js';
 import { generateRequestBody } from '../utils/utils.js';
 import logger from '../utils/logger.js';
 import config from '../config/config.js';
@@ -99,17 +99,9 @@ app.post('/v1/chat/completions', async (req, res) => {
       res.write('data: [DONE]\n\n');
       res.end();
     } else {
-      let fullContent = '';
-      let toolCalls = [];
-      await generateAssistantResponse(requestBody, (data) => {
-        if (data.type === 'tool_calls') {
-          toolCalls = data.tool_calls;
-        } else {
-          fullContent += data.content;
-        }
-      });
+      const { content, toolCalls } = await generateAssistantResponseNoStream(requestBody);
       
-      const message = { role: 'assistant', content: fullContent };
+      const message = { role: 'assistant', content };
       if (toolCalls.length > 0) {
         message.tool_calls = toolCalls;
       }
@@ -152,7 +144,17 @@ app.post('/v1/chat/completions', async (req, res) => {
         res.write('data: [DONE]\n\n');
         res.end();
       } else {
-        res.status(500).json({ error: error.message });
+        res.json({
+          id: `chatcmpl-${Date.now()}`,
+          object: 'chat.completion',
+          created: Math.floor(Date.now() / 1000),
+          model,
+          choices: [{
+            index: 0,
+            message: { role: 'assistant', content: `错误: ${error.message}` },
+            finish_reason: 'stop'
+          }]
+        });
       }
     }
   }

test/test-request.js

@@ -0,0 +1,51 @@
+import { generateRequestBody } from '../src/utils/utils.js';
+import tokenManager from '../src/auth/token_manager.js';
+import config from '../src/config/config.js';
+
+async function testRequest() {
+  try {
+    const token = await tokenManager.getToken();
+    
+    const tools = [{
+      type: 'function',
+      function: {
+        name: 'get_weather',
+        description: '获取天气信息',
+        parameters: {
+          type: 'object',
+          properties: {
+            location: { type: 'string', description: '城市名称' }
+          },
+          required: ['location']
+        }
+      }
+    }];
+    
+    const requestBody = await generateRequestBody(
+      [{ role: 'user', content: '你是谁？' }],
+      'gemini-3-pro-high',
+      {},
+      []
+      //tools
+    );
+    
+    const response = await fetch('https://daily-cloudcode-pa.sandbox.googleapis.com/v1internal:generateContent', {
+      method: 'POST',
+      headers: {
+        'Host': config.api.host,
+        'User-Agent': config.api.userAgent,
+        'Authorization': `Bearer ${token.access_token}`,
+        'Content-Type': 'application/json',
+        'Accept-Encoding': 'gzip'
+      },
+      body: JSON.stringify(requestBody)
+    });
+    
+    const result = await response.json();
+    console.log(JSON.stringify(result, null, 2));
+  } catch (error) {
+    console.error('Error:', error.message);
+  }
+}
+
+testRequest();