使用统一httpclient，复用axios配置逻辑

src/api/client.js

@@ -1,4 +1,3 @@
-import axios from 'axios';
 import tokenManager from '../auth/token_manager.js';
 import config from '../config/config.js';
 import { generateToolCallId } from '../utils/idGenerator.js';
@@ -6,7 +5,7 @@ import AntigravityRequester from '../AntigravityRequester.js';
 import { saveBase64Image } from '../utils/imageStorage.js';
 import logger from '../utils/logger.js';
 import memoryManager, { MemoryPressure, registerMemoryPoolCleanup } from '../utils/memoryManager.js';
-import { buildAxiosRequestConfig } from '../utils/httpClient.js';
+import { buildAxiosRequestConfig, httpRequest, httpStreamRequest } from '../utils/httpClient.js';
 import { setReasoningSignature, setToolSignature } from '../utils/thoughtSignatureCache.js';
 import { getOriginalToolName } from '../utils/toolNameCache.js';
 
@@ -178,15 +177,6 @@ function buildHeaders(token) {
   };
 }
 
-function buildAxiosConfig(url, headers, body = null) {
-  return buildAxiosRequestConfig({
-    method: 'POST',
-    url,
-    headers,
-    data: body
-  });
-}
-
 function buildRequesterConfig(headers, body = null) {
   const reqConfig = {
     method: 'POST',
@@ -341,8 +331,12 @@ export async function generateAssistantResponse(requestBody, token, callback) {
   
   try {
     if (useAxios) {
-      const axiosConfig = { ...buildAxiosConfig(config.api.url, headers, requestBody), responseType: 'stream' };
-      const response = await axios(axiosConfig);
+      const response = await httpStreamRequest({
+        method: 'POST',
+        url: config.api.url,
+        headers,
+        data: requestBody
+      });
       
       // 使用 Buffer 直接处理，避免 toString 的内存分配
       response.data.on('data', chunk => {
@@ -392,7 +386,12 @@ export async function generateAssistantResponse(requestBody, token, callback) {
 async function fetchRawModels(headers, token) {
   try {
     if (useAxios) {
-      const response = await axios(buildAxiosConfig(config.api.modelsUrl, headers, {}));
+      const response = await httpRequest({
+        method: 'POST',
+        url: config.api.modelsUrl,
+        headers,
+        data: {}
+      });
       return response.data;
     }
     const response = await requester.antigravity_fetch(config.api.modelsUrl, buildRequesterConfig(headers, {}));
@@ -495,7 +494,12 @@ export async function generateAssistantResponseNoStream(requestBody, token) {
   
   try {
     if (useAxios) {
-      data = (await axios(buildAxiosConfig(config.api.noStreamUrl, headers, requestBody))).data;
+      data = (await httpRequest({
+        method: 'POST',
+        url: config.api.noStreamUrl,
+        headers,
+        data: requestBody
+      })).data;
     } else {
       const response = await requester.antigravity_fetch(config.api.noStreamUrl, buildRequesterConfig(headers, requestBody));
       if (response.status !== 200) {
@@ -577,7 +581,12 @@ export async function generateImageForSD(requestBody, token) {
   
   try {
     if (useAxios) {
-      data = (await axios(buildAxiosConfig(config.api.noStreamUrl, headers, requestBody))).data;
+      data = (await httpRequest({
+        method: 'POST',
+        url: config.api.noStreamUrl,
+        headers,
+        data: requestBody
+      })).data;
     } else {
       const response = await requester.antigravity_fetch(config.api.noStreamUrl, buildRequesterConfig(headers, requestBody));
       if (response.status !== 200) {

src/server/index.js

@@ -10,7 +10,7 @@ import config from '../config/config.js';
 import tokenManager from '../auth/token_manager.js';
 import adminRouter from '../routes/admin.js';
 import sdRouter from '../routes/sd.js';
-import memoryManager, { MemoryPressure, registerMemoryPoolCleanup } from '../utils/memoryManager.js';
+import memoryManager, { registerMemoryPoolCleanup } from '../utils/memoryManager.js';
 
 const __filename = fileURLToPath(import.meta.url);
 const __dirname = path.dirname(__filename);
@@ -153,10 +153,10 @@ const createStreamChunk = (id, created, model, delta, finish_reason = null) => {
 const writeStreamData = (res, data) => {
   const json = JSON.stringify(data);
   // 释放对象回池
-                const delta = { reasoning_content: data.reasoning_content };
-                if (data.thoughtSignature) {
-                  delta.thoughtSignature = data.thoughtSignature;
-                }
+  const delta = { reasoning_content: data.reasoning_content };
+  if (data.thoughtSignature) {
+    delta.thoughtSignature = data.thoughtSignature;
+  }
   res.write(SSE_PREFIX);
   res.write(json);
   res.write(SSE_SUFFIX);

src/utils/httpClient.js

@@ -68,3 +68,10 @@ export async function httpRequest(configOverrides) {
   const axiosConfig = buildAxiosRequestConfig(configOverrides);
   return axios(axiosConfig);
 }
+
+// 流式请求封装
+export async function httpStreamRequest(configOverrides) {
+  const axiosConfig = buildAxiosRequestConfig(configOverrides);
+  axiosConfig.responseType = 'stream';
+  return axios(axiosConfig);
+}