refactor: Rename file and translate payload/response in one file

Author: ericc-ch

…c/routes/messages/openai-to-anthropic.ts …messages/openai-anthropic-translation.tssrc/routes/messages/openai-to-anthropic.ts renamed to src/routes/messages/openai-anthropic-translation.ts src/routes/messages/openai-to-anthropic.ts renamed to src/routes/messages/openai-anthropic-translation.ts

@@ -91,74 +91,26 @@ interface AnthropicToolUseBlock {
   input: Record<string, unknown>
 }
 
-// Translation functions
+// Payload translation
 
-function getAnthropicTextBlocks(
-  messageContent: Message["content"],
-): Array<AnthropicTextBlock> {
-  if (typeof messageContent === "string") {
-    return [{ type: "text", text: messageContent }]
-  }
-
-  if (Array.isArray(messageContent)) {
-    return messageContent
-      .filter((part): part is TextPart => part.type === "text")
-      .map((part) => ({ type: "text", text: part.text }))
-  }
-
-  return []
-}
-
-function getAnthropicToolUseBlocks(
-  toolCalls: Array<ToolCall> | undefined,
-): Array<AnthropicToolUseBlock> {
-  if (!toolCalls) {
-    return []
-  }
-  return toolCalls.map((toolCall) => ({
-    type: "tool_use",
-    id: toolCall.id,
-    name: toolCall.function.name,
-    input: JSON.parse(toolCall.function.arguments) as Record<string, unknown>,
-  }))
-}
-
-function mapOpenAIStopReasonToAnthropic(
-  finishReason: ChatCompletionResponse["choices"][0]["finish_reason"],
-): AnthropicResponse["stop_reason"] {
-  const stopReasonMap = {
-    stop: "end_turn",
-    length: "max_tokens",
-    tool_calls: "tool_use",
-    content_filter: "end_turn",
-  } as const
-  return stopReasonMap[finishReason]
-}
-
-function mapContent(
-  content: string | Array<AnthropicContentBlock>,
-): string | Array<ContentPart> | null {
-  if (typeof content === "string") {
-    return content
-  }
-  if (!Array.isArray(content)) {
-    return null
-  }
-
-  const contentParts: Array<ContentPart> = []
-  for (const block of content) {
-    if (block.type === "text") {
-      contentParts.push({ type: "text", text: block.text })
-    } else if (block.type === "image") {
-      contentParts.push({
-        type: "image_url",
-        image_url: {
-          url: `data:${block.source.media_type};base64,${block.source.data}`,
-        },
-      })
-    }
+export function translateToOpenAI(
+  payload: AnthropicMessagesPayload,
+): ChatCompletionsPayload {
+  return {
+    model: payload.model,
+    messages: translateAnthropicMessagesToOpenAI(
+      payload.messages,
+      payload.system,
+    ),
+    max_tokens: payload.max_tokens,
+    stop: payload.stop_sequences,
+    stream: payload.stream,
+    temperature: payload.temperature,
+    top_p: payload.top_p,
+    user: payload.metadata?.user_id,
+    tools: translateAnthropicToolsToOpenAI(payload.tools),
+    tool_choice: translateAnthropicToolChoiceToOpenAI(payload.tool_choice),
   }
-  return contentParts
 }
 
 function translateAnthropicMessagesToOpenAI(
@@ -210,6 +162,32 @@ function translateAnthropicMessagesToOpenAI(
   return messages
 }
 
+function mapContent(
+  content: string | Array<AnthropicContentBlock>,
+): string | Array<ContentPart> | null {
+  if (typeof content === "string") {
+    return content
+  }
+  if (!Array.isArray(content)) {
+    return null
+  }
+
+  const contentParts: Array<ContentPart> = []
+  for (const block of content) {
+    if (block.type === "text") {
+      contentParts.push({ type: "text", text: block.text })
+    } else if (block.type === "image") {
+      contentParts.push({
+        type: "image_url",
+        image_url: {
+          url: `data:${block.source.media_type};base64,${block.source.data}`,
+        },
+      })
+    }
+  }
+  return contentParts
+}
+
 function translateAnthropicToolsToOpenAI(
   anthropicTools: Array<AnthropicTool> | undefined,
 ): Array<Tool> | undefined {
@@ -238,9 +216,6 @@ function translateAnthropicToolChoiceToOpenAI(
       return "auto"
     }
     case "any": {
-      // The type definition for tool_choice is missing "required", but it's a valid value.
-      // eslint-disable-next-line @typescript-eslint/ban-ts-comment
-      // @ts-expect-error
       return "required"
     }
     case "tool": {
@@ -258,25 +233,7 @@ function translateAnthropicToolChoiceToOpenAI(
   }
 }
 
-export function translateToOpenAI(
-  payload: AnthropicMessagesPayload,
-): ChatCompletionsPayload {
-  return {
-    model: payload.model,
-    messages: translateAnthropicMessagesToOpenAI(
-      payload.messages,
-      payload.system,
-    ),
-    max_tokens: payload.max_tokens,
-    stop: payload.stop_sequences,
-    stream: payload.stream,
-    temperature: payload.temperature,
-    top_p: payload.top_p,
-    user: payload.metadata?.user_id,
-    tools: translateAnthropicToolsToOpenAI(payload.tools),
-    tool_choice: translateAnthropicToolChoiceToOpenAI(payload.tool_choice),
-  }
-}
+// Response translation
 
 export function translateToAnthropic(
   response: ChatCompletionResponse,
@@ -299,3 +256,45 @@ export function translateToAnthropic(
     },
   }
 }
+
+function getAnthropicTextBlocks(
+  messageContent: Message["content"],
+): Array<AnthropicTextBlock> {
+  if (typeof messageContent === "string") {
+    return [{ type: "text", text: messageContent }]
+  }
+
+  if (Array.isArray(messageContent)) {
+    return messageContent
+      .filter((part): part is TextPart => part.type === "text")
+      .map((part) => ({ type: "text", text: part.text }))
+  }
+
+  return []
+}
+
+function getAnthropicToolUseBlocks(
+  toolCalls: Array<ToolCall> | undefined,
+): Array<AnthropicToolUseBlock> {
+  if (!toolCalls) {
+    return []
+  }
+  return toolCalls.map((toolCall) => ({
+    type: "tool_use",
+    id: toolCall.id,
+    name: toolCall.function.name,
+    input: JSON.parse(toolCall.function.arguments) as Record<string, unknown>,
+  }))
+}
+
+function mapOpenAIStopReasonToAnthropic(
+  finishReason: ChatCompletionResponse["choices"][0]["finish_reason"],
+): AnthropicResponse["stop_reason"] {
+  const stopReasonMap = {
+    stop: "end_turn",
+    length: "max_tokens",
+    tool_calls: "tool_use",
+    content_filter: "end_turn",
+  } as const
+  return stopReasonMap[finishReason]
+}

src/services/copilot/create-chat-completions.ts

@@ -9,15 +9,15 @@ export const createChatCompletions = async (
 ) => {
   if (!state.copilotToken) throw new Error("Copilot token not found")
 
-  const visionEnable = payload.messages.some(
+  const enableVision = payload.messages.some(
     (x) =>
       typeof x.content !== "string"
       && x.content?.some((x) => x.type === "image_url"),
   )
 
   const response = await fetch(`${copilotBaseUrl(state)}/chat/completions`, {
     method: "POST",
-    headers: copilotHeaders(state, visionEnable),
+    headers: copilotHeaders(state, enableVision),
     body: JSON.stringify(payload),
   })
 
@@ -60,7 +60,7 @@ interface Choice {
   index: number
   delta: Delta
   finish_reason: "stop" | "length" | "tool_calls" | "content_filter" | null
-  logprobs: null
+  logprobs: object | null
 }
 
 // Non-streaming types
@@ -82,7 +82,7 @@ export interface ChatCompletionResponse {
 interface ChoiceNonStreaming {
   index: number
   message: Message
-  logprobs: null
+  logprobs: object | null
   finish_reason: "stop" | "length" | "tool_calls" | "content_filter"
 }
 
@@ -108,6 +108,7 @@ export interface ChatCompletionsPayload {
   tool_choice?:
     | "none"
     | "auto"
+    | "required"
     | { type: "function"; function: { name: string } }
     | null
   user?: string | null