更智能的提醒

package-lock.json

@@ -1,11 +1,18 @@
 {
-  "name": "googleIde",
+  "name": "antigravity-to-openai",
+  "version": "1.0.0",
   "lockfileVersion": 3,
   "requires": true,
   "packages": {
     "": {
+      "name": "antigravity-to-openai",
+      "version": "1.0.0",
+      "license": "MIT",
       "dependencies": {
         "express": "^5.1.0"
+      },
+      "engines": {
+        "node": ">=18.0.0"
       }
     },
     "node_modules/accepts": {

src/api/client.js

@@ -3,6 +3,11 @@ import config from '../config/config.js';
 
 export async function generateAssistantResponse(requestBody, callback) {
   const token = await tokenManager.getToken();
+  
+  if (!token) {
+    throw new Error('没有可用的token，请运行 npm run login 获取token');
+  }
+  
   const url = config.api.url;
   
   const response = await fetch(url, {
@@ -10,7 +15,7 @@ export async function generateAssistantResponse(requestBody, callback) {
     headers: {
       'Host': config.api.host,
       'User-Agent': config.api.userAgent,
-      'Authorization': `Bearer ${token}`,
+      'Authorization': `Bearer ${token.access_token}`,
       'Content-Type': 'application/json',
       'Accept-Encoding': 'gzip'
     },
@@ -19,6 +24,10 @@ export async function generateAssistantResponse(requestBody, callback) {
 
   if (!response.ok) {
     const errorText = await response.text();
+    if (response.status === 403) {
+      tokenManager.disableCurrentToken(token);
+      throw new Error(`该账号没有使用权限，已自动禁用。错误详情: ${errorText}`);
+    }
     throw new Error(`API请求失败 (${response.status}): ${errorText}`);
   }
 
@@ -85,12 +94,16 @@ export async function generateAssistantResponse(requestBody, callback) {
 export async function getAvailableModels() {
   const token = await tokenManager.getToken();
   
+  if (!token) {
+    throw new Error('没有可用的token，请运行 npm run login 获取token');
+  }
+  
   const response = await fetch(config.api.modelsUrl, {
     method: 'POST',
     headers: {
       'Host': config.api.host,
       'User-Agent': config.api.userAgent,
-      'Authorization': `Bearer ${token}`,
+      'Authorization': `Bearer ${token.access_token}`,
       'Content-Type': 'application/json',
       'Accept-Encoding': 'gzip'
     },

src/auth/token_manager.js

@@ -87,6 +87,7 @@ class TokenManager {
   }
 
   disableToken(token) {
+    log.warn(`禁用token`)
     token.enable = false;
     this.saveToFile();
     this.loadTokens();
@@ -102,9 +103,8 @@ class TokenManager {
         if (this.isExpired(token)) {
           await this.refreshToken(token);
         }
-        const accessToken = token.access_token;
         this.currentIndex = (this.currentIndex + 1) % this.tokens.length;
-        return accessToken;
+        return token;
       } catch (error) {
         if (error.statusCode === 403) {
           log.warn(`Token ${this.currentIndex} 刷新失败(403)，禁用并尝试下一个`);
@@ -120,6 +120,13 @@ class TokenManager {
     return null;
   }
 
+  disableCurrentToken(token) {
+    const found = this.tokens.find(t => t.access_token === token.access_token);
+    if (found) {
+      this.disableToken(found);
+    }
+  }
+
   async handleRequestError(error, currentAccessToken) {
     if (error.statusCode === 403) {
       log.warn('请求遇到403错误，尝试刷新token');
@@ -128,7 +135,7 @@ class TokenManager {
         try {
           await this.refreshToken(currentToken);
           log.info('Token刷新成功，返回新token');
-          return currentToken.access_token;
+          return currentToken;
         } catch (refreshError) {
           if (refreshError.statusCode === 403) {
             log.warn('刷新token也遇到403，禁用并切换到下一个');

src/server/index.js

@@ -49,8 +49,8 @@ app.get('/v1/models', async (req, res) => {
 });
 
 app.post('/v1/chat/completions', async (req, res) => {
+  const { messages, model, stream = true, tools, ...params} = req.body;
   try {
-    const { messages, model, stream = true, tools, ...params} = req.body;
     
     if (!messages) {
       return res.status(400).json({ error: 'messages is required' });
@@ -129,7 +129,31 @@ app.post('/v1/chat/completions', async (req, res) => {
   } catch (error) {
     logger.error('生成响应失败:', error.message);
     if (!res.headersSent) {
-      res.status(500).json({ error: error.message });
+      if (stream) {
+        res.setHeader('Content-Type', 'text/event-stream');
+        res.setHeader('Cache-Control', 'no-cache');
+        res.setHeader('Connection', 'keep-alive');
+        const id = `chatcmpl-${Date.now()}`;
+        const created = Math.floor(Date.now() / 1000);
+        res.write(`data: ${JSON.stringify({
+          id,
+          object: 'chat.completion.chunk',
+          created,
+          model,
+          choices: [{ index: 0, delta: { content: `错误: ${error.message}` }, finish_reason: null }]
+        })}\n\n`);
+        res.write(`data: ${JSON.stringify({
+          id,
+          object: 'chat.completion.chunk',
+          created,
+          model,
+          choices: [{ index: 0, delta: {}, finish_reason: 'stop' }]
+        })}\n\n`);
+        res.write('data: [DONE]\n\n');
+        res.end();
+      } else {
+        res.status(500).json({ error: error.message });
+      }
     }
   }
 });