Delete transformers

transformers/request-common.js

@@ -1,88 +0,0 @@
-import { logDebug } from '../logger.js';
-import { getSystemPrompt, getUserAgent } from '../config.js';
-
-export function transformToCommon(openaiRequest) {
-  logDebug('将 OpenAI 请求转换为通用格式');
-
-  // 基本保持 OpenAI 格式，只在 messages 前面插入 system 消息
-  const commonRequest = {
-    ...openaiRequest
-  };
-
-  const systemPrompt = getSystemPrompt();
-
-  if (systemPrompt) {
-    // 检查是否已有 system 消息
-    const hasSystemMessage = commonRequest.messages?.some(m => m.role === 'system');
-
-    if (hasSystemMessage) {
-      // 如果已有 system 消息，在第一个 system 消息前插入我们的 system prompt
-      commonRequest.messages = commonRequest.messages.map((msg, index) => {
-        if (msg.role === 'system' && index === commonRequest.messages.findIndex(m => m.role === 'system')) {
-          // 找到第一个 system 消息，前置我们的 prompt
-          return {
-            role: 'system',
-            content: systemPrompt + (typeof msg.content === 'string' ? msg.content?.replace("You are Claude Code, Anthropic's official CLI for Claude.", 'you are bot.') : '')
-          };
-        }
-        return msg;
-      });
-    } else {
-      // 如果没有 system 消息，在 messages 数组最前面插入
-      commonRequest.messages = [
-        {
-          role: 'system',
-          content: systemPrompt
-        },
-        ...(commonRequest.messages || [])
-      ];
-    }
-  }
-
-  logDebug('已转换的通用请求', commonRequest);
-  return commonRequest;
-}
-
-export function getCommonHeaders(authHeader, clientHeaders = {}) {
-  // 如果未提供则生成唯一 ID
-  const sessionId = clientHeaders['x-session-id'] || generateUUID();
-  const messageId = clientHeaders['x-assistant-message-id'] || generateUUID();
-  
-  const headers = {
-    'accept': 'application/json',
-    'content-type': 'application/json',
-    'authorization': authHeader || '',
-    'x-api-provider': 'baseten',
-    'x-factory-client': 'cli',
-    'x-session-id': sessionId,
-    'x-assistant-message-id': messageId,
-    'user-agent': getUserAgent(),
-    'connection': 'keep-alive'
-  };
-
-  // 使用默认值传递 Stainless SDK 头
-  const stainlessDefaults = {
-    'x-stainless-arch': 'x64',
-    'x-stainless-lang': 'js',
-    'x-stainless-os': 'MacOS',
-    'x-stainless-runtime': 'node',
-    'x-stainless-retry-count': '0',
-    'x-stainless-package-version': '5.23.2',
-    'x-stainless-runtime-version': 'v24.3.0'
-  };
-
-  // 从客户端复制 Stainless 头或使用默认值
-  Object.keys(stainlessDefaults).forEach(header => {
-    headers[header] = clientHeaders[header] || stainlessDefaults[header];
-  });
-
-  return headers;
-}
-
-function generateUUID() {
-  return 'xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx'.replace(/[xy]/g, function(c) {
-    const r = Math.random() * 16 | 0;
-    const v = c == 'x' ? r : (r & 0x3 | 0x8);
-    return v.toString(16);
-  });
-}

transformers/request-openai.js

@@ -1,177 +0,0 @@
-import { logDebug } from '../logger.js';
-import { getSystemPrompt, getModelReasoning, getUserAgent } from '../config.js';
-
-export function transformToOpenAI(openaiRequest) {
-  logDebug('将 OpenAI 请求转换为目标 OpenAI 格式');
-
-  const targetRequest = {
-    model: openaiRequest.model,
-    input: [],
-    store: false
-  };
-
-  // 仅在客户端明确提供时添加 stream 参数
-  if (openaiRequest.stream !== undefined) {
-    targetRequest.stream = openaiRequest.stream;
-  }
-
-  // 将 max_tokens 转换为 max_output_tokens
-  if (openaiRequest.max_tokens) {
-    targetRequest.max_output_tokens = openaiRequest.max_tokens;
-  } else if (openaiRequest.max_completion_tokens) {
-    targetRequest.max_output_tokens = openaiRequest.max_completion_tokens;
-  }
-
-  // Transform messages to input
-  if (openaiRequest.messages && Array.isArray(openaiRequest.messages)) {
-    for (const msg of openaiRequest.messages) {
-      const inputMsg = {
-        role: msg.role,
-        content: []
-      };
-
-      // Determine content type based on role
-      // user role uses 'input_text', assistant role uses 'output_text'
-      const textType = msg.role === 'assistant' ? 'output_text' : 'input_text';
-      const imageType = msg.role === 'assistant' ? 'output_image' : 'input_image';
-
-      if (typeof msg.content === 'string') {
-        inputMsg.content.push({
-          type: textType,
-          text: msg.content?.replace("You are Claude Code, Anthropic's official CLI for Claude.", 'you are bot.')
-        });
-      } else if (Array.isArray(msg.content)) {
-        for (const part of msg.content) {
-          if (part.type === 'text') {
-            inputMsg.content.push({
-              type: textType,
-              text: part.text?.replace("You are Claude Code, Anthropic's official CLI for Claude.", 'you are bot.')
-            });
-          } else if (part.type === 'image_url') {
-            inputMsg.content.push({
-              type: imageType,
-              image_url: part.image_url
-            });
-          } else {
-            // Pass through other types as-is
-            inputMsg.content.push(part);
-          }
-        }
-      }
-
-      targetRequest.input.push(inputMsg);
-    }
-  }
-
-  // Transform tools if present
-  if (openaiRequest.tools && Array.isArray(openaiRequest.tools)) {
-    targetRequest.tools = openaiRequest.tools.map(tool => ({
-      ...tool,
-      strict: false
-    }));
-  }
-
-  // Extract system message as instructions and prepend system prompt
-  const systemPrompt = getSystemPrompt();
-  const systemMessage = openaiRequest.messages?.find(m => m.role === 'system');
-  
-  if (systemMessage) {
-    let userInstructions = '';
-    if (typeof systemMessage.content === 'string') {
-      userInstructions = systemMessage.content;
-    } else if (Array.isArray(systemMessage.content)) {
-      userInstructions = systemMessage.content
-        .filter(p => p.type === 'text')
-        .map(p => p.text)
-        .join('\n');
-    }
-    targetRequest.instructions = systemPrompt + userInstructions;
-    targetRequest.input = targetRequest.input.filter(m => m.role !== 'system');
-  } else if (systemPrompt) {
-    // If no user-provided system message, just add the system prompt
-    targetRequest.instructions = systemPrompt;
-  }
-
-  // 根据模型配置处理 reasoning 字段
-  const reasoningLevel = getModelReasoning(openaiRequest.model);
-  if (reasoningLevel === 'auto') {
-    // 自动模式：完全保留原始请求的 reasoning 字段
-    if (openaiRequest.reasoning !== undefined) {
-      targetRequest.reasoning = openaiRequest.reasoning;
-    }
-    // 如果原始请求没有 reasoning 字段，则不添加
-  } else if (reasoningLevel && ['low', 'medium', 'high'].includes(reasoningLevel)) {
-    // 特定级别：使用模型配置覆盖
-    targetRequest.reasoning = {
-      effort: reasoningLevel,
-      summary: 'auto'
-    };
-  } else {
-    // 关闭或无效：显式删除 reasoning 字段
-    // 这确保删除原始请求中的任何 reasoning 字段
-    delete targetRequest.reasoning;
-  }
-
-  // Pass through other parameters
-  if (openaiRequest.temperature !== undefined) {
-    targetRequest.temperature = openaiRequest.temperature;
-  }
-  if (openaiRequest.top_p !== undefined) {
-    targetRequest.top_p = openaiRequest.top_p;
-  }
-  if (openaiRequest.presence_penalty !== undefined) {
-    targetRequest.presence_penalty = openaiRequest.presence_penalty;
-  }
-  if (openaiRequest.frequency_penalty !== undefined) {
-    targetRequest.frequency_penalty = openaiRequest.frequency_penalty;
-  }
-  if (openaiRequest.parallel_tool_calls !== undefined) {
-    targetRequest.parallel_tool_calls = openaiRequest.parallel_tool_calls;
-  }
-
-  logDebug('已转换的目标 OpenAI 请求', targetRequest);
-  return targetRequest;
-}
-
-export function getOpenAIHeaders(authHeader, clientHeaders = {}) {
-  // 如果未提供则生成唯一 ID
-  const sessionId = clientHeaders['x-session-id'] || generateUUID();
-  const messageId = clientHeaders['x-assistant-message-id'] || generateUUID();
-  
-  const headers = {
-    'content-type': 'application/json',
-    'authorization': authHeader || '',
-    'x-api-provider': 'azure_openai',
-    'x-factory-client': 'cli',
-    'x-session-id': sessionId,
-    'x-assistant-message-id': messageId,
-    'user-agent': getUserAgent(),
-    'connection': 'keep-alive'
-  };
-
-  // Pass through Stainless SDK headers with defaults
-  const stainlessDefaults = {
-    'x-stainless-arch': 'x64',
-    'x-stainless-lang': 'js',
-    'x-stainless-os': 'MacOS',
-    'x-stainless-runtime': 'node',
-    'x-stainless-retry-count': '0',
-    'x-stainless-package-version': '5.23.2',
-    'x-stainless-runtime-version': 'v24.3.0'
-  };
-
-  // Copy Stainless headers from client or use defaults
-  Object.keys(stainlessDefaults).forEach(header => {
-    headers[header] = clientHeaders[header] || stainlessDefaults[header];
-  });
-
-  return headers;
-}
-
-function generateUUID() {
-  return 'xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx'.replace(/[xy]/g, function(c) {
-    const r = Math.random() * 16 | 0;
-    const v = c == 'x' ? r : (r & 0x3 | 0x8);
-    return v.toString(16);
-  });
-}

transformers/response-anthropic.js

@@ -1,138 +0,0 @@
-import { logDebug } from '../logger.js';
-
-export class AnthropicResponseTransformer {
-  constructor(model, requestId) {
-    this.model = model;
-    this.requestId = requestId || `chatcmpl-${Date.now()}`;
-    this.created = Math.floor(Date.now() / 1000);
-    this.messageId = null;
-    this.currentIndex = 0;
-  }
-
-  parseSSELine(line) {
-    if (line.startsWith('event:')) {
-      return { type: 'event', value: line.slice(6).trim() };
-    }
-    if (line.startsWith('data:')) {
-      const dataStr = line.slice(5).trim();
-      try {
-        return { type: 'data', value: JSON.parse(dataStr) };
-      } catch (e) {
-        return { type: 'data', value: dataStr };
-      }
-    }
-    return null;
-  }
-
-  transformEvent(eventType, eventData) {
-    logDebug(`Anthropic 事件: ${eventType}`);
-
-    if (eventType === 'message_start') {
-      this.messageId = eventData.message?.id || this.requestId;
-      return this.createOpenAIChunk('', 'assistant', false);
-    }
-
-    if (eventType === 'content_block_start') {
-      return null;
-    }
-
-    if (eventType === 'content_block_delta') {
-      const text = eventData.delta?.text || '';
-      return this.createOpenAIChunk(text, null, false);
-    }
-
-    if (eventType === 'content_block_stop') {
-      return null;
-    }
-
-    if (eventType === 'message_delta') {
-      const stopReason = eventData.delta?.stop_reason;
-      if (stopReason) {
-        return this.createOpenAIChunk('', null, true, this.mapStopReason(stopReason));
-      }
-      return null;
-    }
-
-    if (eventType === 'message_stop') {
-      return this.createDoneSignal();
-    }
-
-    if (eventType === 'ping') {
-      return null;
-    }
-
-    return null;
-  }
-
-  createOpenAIChunk(content, role = null, finish = false, finishReason = null) {
-    const chunk = {
-      id: this.requestId,
-      object: 'chat.completion.chunk',
-      created: this.created,
-      model: this.model,
-      choices: [
-        {
-          index: 0,
-          delta: {},
-          finish_reason: finish ? finishReason : null
-        }
-      ]
-    };
-
-    if (role) {
-      chunk.choices[0].delta.role = role;
-    }
-    if (content) {
-      chunk.choices[0].delta.content = content;
-    }
-
-    return `data: ${JSON.stringify(chunk)}\n\n`;
-  }
-
-  createDoneSignal() {
-    return 'data: [DONE]\n\n';
-  }
-
-  mapStopReason(anthropicReason) {
-    const mapping = {
-      'end_turn': 'stop',
-      'max_tokens': 'length',
-      'stop_sequence': 'stop',
-      'tool_use': 'tool_calls'
-    };
-    return mapping[anthropicReason] || 'stop';
-  }
-
-  async *transformStream(sourceStream) {
-    let buffer = '';
-    let currentEvent = null;
-
-    try {
-      for await (const chunk of sourceStream) {
-        buffer += chunk.toString();
-        const lines = buffer.split('\n');
-        buffer = lines.pop() || '';
-
-        for (const line of lines) {
-          if (!line.trim()) continue;
-
-          const parsed = this.parseSSELine(line);
-          if (!parsed) continue;
-
-          if (parsed.type === 'event') {
-            currentEvent = parsed.value;
-          } else if (parsed.type === 'data' && currentEvent) {
-            const transformed = this.transformEvent(currentEvent, parsed.value);
-            if (transformed) {
-              yield transformed;
-            }
-            currentEvent = null;
-          }
-        }
-      }
-    } catch (error) {
-      logDebug('Anthropic 流转换错误', error);
-      throw error;
-    }
-  }
-}

transformers/response-openai.js

@@ -1,127 +0,0 @@
-import { logDebug } from '../logger.js';
-
-export class OpenAIResponseTransformer {
-  constructor(model, requestId) {
-    this.model = model;
-    this.requestId = requestId || `chatcmpl-${Date.now()}`;
-    this.created = Math.floor(Date.now() / 1000);
-  }
-
-  parseSSELine(line) {
-    if (line.startsWith('event:')) {
-      return { type: 'event', value: line.slice(6).trim() };
-    }
-    if (line.startsWith('data:')) {
-      const dataStr = line.slice(5).trim();
-      try {
-        return { type: 'data', value: JSON.parse(dataStr) };
-      } catch (e) {
-        return { type: 'data', value: dataStr };
-      }
-    }
-    return null;
-  }
-
-  transformEvent(eventType, eventData) {
-    logDebug(`目标 OpenAI 事件: ${eventType}`);
-
-    if (eventType === 'response.created') {
-      return this.createOpenAIChunk('', 'assistant', false);
-    }
-
-    if (eventType === 'response.in_progress') {
-      return null;
-    }
-
-    if (eventType === 'response.output_text.delta') {
-      const text = eventData.delta || eventData.text || '';
-      return this.createOpenAIChunk(text, null, false);
-    }
-
-    if (eventType === 'response.output_text.done') {
-      return null;
-    }
-
-    if (eventType === 'response.done') {
-      const status = eventData.response?.status;
-      let finishReason = 'stop';
-      
-      if (status === 'completed') {
-        finishReason = 'stop';
-      } else if (status === 'incomplete') {
-        finishReason = 'length';
-      }
-
-      const finalChunk = this.createOpenAIChunk('', null, true, finishReason);
-      const done = this.createDoneSignal();
-      return finalChunk + done;
-    }
-
-    return null;
-  }
-
-  createOpenAIChunk(content, role = null, finish = false, finishReason = null) {
-    const chunk = {
-      id: this.requestId,
-      object: 'chat.completion.chunk',
-      created: this.created,
-      model: this.model,
-      choices: [
-        {
-          index: 0,
-          delta: {},
-          finish_reason: finish ? finishReason : null
-        }
-      ]
-    };
-
-    if (role) {
-      chunk.choices[0].delta.role = role;
-    }
-    if (content) {
-      chunk.choices[0].delta.content = content;
-    }
-
-    return `data: ${JSON.stringify(chunk)}\n\n`;
-  }
-
-  createDoneSignal() {
-    return 'data: [DONE]\n\n';
-  }
-
-  async *transformStream(sourceStream) {
-    let buffer = '';
-    let currentEvent = null;
-
-    try {
-      for await (const chunk of sourceStream) {
-        buffer += chunk.toString();
-        const lines = buffer.split('\n');
-        buffer = lines.pop() || '';
-
-        for (const line of lines) {
-          if (!line.trim()) continue;
-
-          const parsed = this.parseSSELine(line);
-          if (!parsed) continue;
-
-          if (parsed.type === 'event') {
-            currentEvent = parsed.value;
-          } else if (parsed.type === 'data' && currentEvent) {
-            const transformed = this.transformEvent(currentEvent, parsed.value);
-            if (transformed) {
-              yield transformed;
-            }
-          }
-        }
-      }
-
-      if (currentEvent === 'response.done' || currentEvent === 'response.completed') {
-        yield this.createDoneSignal();
-      }
-    } catch (error) {
-      logDebug('OpenAI 流转换错误', error);
-      throw error;
-    }
-  }
-}