mirror of
https://github.com/router-for-me/CLIProxyAPI.git
synced 2026-02-03 04:50:52 +08:00
317 lines
11 KiB
Go
317 lines
11 KiB
Go
// Package openai provides request translation functionality for OpenAI to Claude Code API compatibility.
|
|
// It handles parsing and transforming OpenAI Chat Completions API requests into Claude Code API format,
|
|
// extracting model information, system instructions, message contents, and tool declarations.
|
|
// The package performs JSON data transformation to ensure compatibility
|
|
// between OpenAI API format and Claude Code API's expected format.
|
|
package chat_completions
|
|
|
|
import (
|
|
"bytes"
|
|
"crypto/rand"
|
|
"crypto/sha256"
|
|
"encoding/hex"
|
|
"fmt"
|
|
"math/big"
|
|
"strings"
|
|
|
|
"github.com/google/uuid"
|
|
"github.com/router-for-me/CLIProxyAPI/v6/internal/thinking"
|
|
"github.com/tidwall/gjson"
|
|
"github.com/tidwall/sjson"
|
|
)
|
|
|
|
var (
|
|
user = ""
|
|
account = ""
|
|
session = ""
|
|
)
|
|
|
|
// ConvertOpenAIRequestToClaude parses and transforms an OpenAI Chat Completions API request into Claude Code API format.
|
|
// It extracts the model name, system instruction, message contents, and tool declarations
|
|
// from the raw JSON request and returns them in the format expected by the Claude Code API.
|
|
// The function performs comprehensive transformation including:
|
|
// 1. Model name mapping and parameter extraction (max_tokens, temperature, top_p, etc.)
|
|
// 2. Message content conversion from OpenAI to Claude Code format
|
|
// 3. Tool call and tool result handling with proper ID mapping
|
|
// 4. Image data conversion from OpenAI data URLs to Claude Code base64 format
|
|
// 5. Stop sequence and streaming configuration handling
|
|
//
|
|
// Parameters:
|
|
// - modelName: The name of the model to use for the request
|
|
// - rawJSON: The raw JSON request data from the OpenAI API
|
|
// - stream: A boolean indicating if the request is for a streaming response
|
|
//
|
|
// Returns:
|
|
// - []byte: The transformed request data in Claude Code API format
|
|
func ConvertOpenAIRequestToClaude(modelName string, inputRawJSON []byte, stream bool) []byte {
|
|
rawJSON := bytes.Clone(inputRawJSON)
|
|
|
|
if account == "" {
|
|
u, _ := uuid.NewRandom()
|
|
account = u.String()
|
|
}
|
|
if session == "" {
|
|
u, _ := uuid.NewRandom()
|
|
session = u.String()
|
|
}
|
|
if user == "" {
|
|
sum := sha256.Sum256([]byte(account + session))
|
|
user = hex.EncodeToString(sum[:])
|
|
}
|
|
userID := fmt.Sprintf("user_%s_account_%s_session_%s", user, account, session)
|
|
|
|
// Base Claude Code API template with default max_tokens value
|
|
out := fmt.Sprintf(`{"model":"","max_tokens":32000,"messages":[],"metadata":{"user_id":"%s"}}`, userID)
|
|
|
|
root := gjson.ParseBytes(rawJSON)
|
|
|
|
// Convert OpenAI reasoning_effort to Claude thinking config.
|
|
if v := root.Get("reasoning_effort"); v.Exists() {
|
|
effort := strings.ToLower(strings.TrimSpace(v.String()))
|
|
if effort != "" {
|
|
budget, ok := thinking.ConvertLevelToBudget(effort)
|
|
if ok {
|
|
switch budget {
|
|
case 0:
|
|
out, _ = sjson.Set(out, "thinking.type", "disabled")
|
|
case -1:
|
|
out, _ = sjson.Set(out, "thinking.type", "enabled")
|
|
default:
|
|
if budget > 0 {
|
|
out, _ = sjson.Set(out, "thinking.type", "enabled")
|
|
out, _ = sjson.Set(out, "thinking.budget_tokens", budget)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
// Helper for generating tool call IDs in the form: toolu_<alphanum>
|
|
// This ensures unique identifiers for tool calls in the Claude Code format
|
|
genToolCallID := func() string {
|
|
const letters = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789"
|
|
var b strings.Builder
|
|
// 24 chars random suffix for uniqueness
|
|
for i := 0; i < 24; i++ {
|
|
n, _ := rand.Int(rand.Reader, big.NewInt(int64(len(letters))))
|
|
b.WriteByte(letters[n.Int64()])
|
|
}
|
|
return "toolu_" + b.String()
|
|
}
|
|
|
|
// Model mapping to specify which Claude Code model to use
|
|
out, _ = sjson.Set(out, "model", modelName)
|
|
|
|
// Max tokens configuration with fallback to default value
|
|
if maxTokens := root.Get("max_tokens"); maxTokens.Exists() {
|
|
out, _ = sjson.Set(out, "max_tokens", maxTokens.Int())
|
|
}
|
|
|
|
// Temperature setting for controlling response randomness
|
|
if temp := root.Get("temperature"); temp.Exists() {
|
|
out, _ = sjson.Set(out, "temperature", temp.Float())
|
|
} else if topP := root.Get("top_p"); topP.Exists() {
|
|
out, _ = sjson.Set(out, "top_p", topP.Float())
|
|
}
|
|
|
|
// Stop sequences configuration for custom termination conditions
|
|
if stop := root.Get("stop"); stop.Exists() {
|
|
if stop.IsArray() {
|
|
var stopSequences []string
|
|
stop.ForEach(func(_, value gjson.Result) bool {
|
|
stopSequences = append(stopSequences, value.String())
|
|
return true
|
|
})
|
|
if len(stopSequences) > 0 {
|
|
out, _ = sjson.Set(out, "stop_sequences", stopSequences)
|
|
}
|
|
} else {
|
|
out, _ = sjson.Set(out, "stop_sequences", []string{stop.String()})
|
|
}
|
|
}
|
|
|
|
// Stream configuration to enable or disable streaming responses
|
|
out, _ = sjson.Set(out, "stream", stream)
|
|
|
|
// Process messages and transform them to Claude Code format
|
|
if messages := root.Get("messages"); messages.Exists() && messages.IsArray() {
|
|
messageIndex := 0
|
|
systemMessageIndex := -1
|
|
messages.ForEach(func(_, message gjson.Result) bool {
|
|
role := message.Get("role").String()
|
|
contentResult := message.Get("content")
|
|
|
|
switch role {
|
|
case "system":
|
|
if systemMessageIndex == -1 {
|
|
systemMsg := `{"role":"user","content":[]}`
|
|
out, _ = sjson.SetRaw(out, "messages.-1", systemMsg)
|
|
systemMessageIndex = messageIndex
|
|
messageIndex++
|
|
}
|
|
if contentResult.Exists() && contentResult.Type == gjson.String && contentResult.String() != "" {
|
|
textPart := `{"type":"text","text":""}`
|
|
textPart, _ = sjson.Set(textPart, "text", contentResult.String())
|
|
out, _ = sjson.SetRaw(out, fmt.Sprintf("messages.%d.content.-1", systemMessageIndex), textPart)
|
|
} else if contentResult.Exists() && contentResult.IsArray() {
|
|
contentResult.ForEach(func(_, part gjson.Result) bool {
|
|
if part.Get("type").String() == "text" {
|
|
textPart := `{"type":"text","text":""}`
|
|
textPart, _ = sjson.Set(textPart, "text", part.Get("text").String())
|
|
out, _ = sjson.SetRaw(out, fmt.Sprintf("messages.%d.content.-1", systemMessageIndex), textPart)
|
|
}
|
|
return true
|
|
})
|
|
}
|
|
case "user", "assistant":
|
|
msg := `{"role":"","content":[]}`
|
|
msg, _ = sjson.Set(msg, "role", role)
|
|
|
|
// Handle content based on its type (string or array)
|
|
if contentResult.Exists() && contentResult.Type == gjson.String && contentResult.String() != "" {
|
|
part := `{"type":"text","text":""}`
|
|
part, _ = sjson.Set(part, "text", contentResult.String())
|
|
msg, _ = sjson.SetRaw(msg, "content.-1", part)
|
|
} else if contentResult.Exists() && contentResult.IsArray() {
|
|
contentResult.ForEach(func(_, part gjson.Result) bool {
|
|
partType := part.Get("type").String()
|
|
|
|
switch partType {
|
|
case "text":
|
|
textPart := `{"type":"text","text":""}`
|
|
textPart, _ = sjson.Set(textPart, "text", part.Get("text").String())
|
|
msg, _ = sjson.SetRaw(msg, "content.-1", textPart)
|
|
|
|
case "image_url":
|
|
// Convert OpenAI image format to Claude Code format
|
|
imageURL := part.Get("image_url.url").String()
|
|
if strings.HasPrefix(imageURL, "data:") {
|
|
// Extract base64 data and media type from data URL
|
|
parts := strings.Split(imageURL, ",")
|
|
if len(parts) == 2 {
|
|
mediaTypePart := strings.Split(parts[0], ";")[0]
|
|
mediaType := strings.TrimPrefix(mediaTypePart, "data:")
|
|
data := parts[1]
|
|
|
|
imagePart := `{"type":"image","source":{"type":"base64","media_type":"","data":""}}`
|
|
imagePart, _ = sjson.Set(imagePart, "source.media_type", mediaType)
|
|
imagePart, _ = sjson.Set(imagePart, "source.data", data)
|
|
msg, _ = sjson.SetRaw(msg, "content.-1", imagePart)
|
|
}
|
|
}
|
|
}
|
|
return true
|
|
})
|
|
}
|
|
|
|
// Handle tool calls (for assistant messages)
|
|
if toolCalls := message.Get("tool_calls"); toolCalls.Exists() && toolCalls.IsArray() && role == "assistant" {
|
|
toolCalls.ForEach(func(_, toolCall gjson.Result) bool {
|
|
if toolCall.Get("type").String() == "function" {
|
|
toolCallID := toolCall.Get("id").String()
|
|
if toolCallID == "" {
|
|
toolCallID = genToolCallID()
|
|
}
|
|
|
|
function := toolCall.Get("function")
|
|
toolUse := `{"type":"tool_use","id":"","name":"","input":{}}`
|
|
toolUse, _ = sjson.Set(toolUse, "id", toolCallID)
|
|
toolUse, _ = sjson.Set(toolUse, "name", function.Get("name").String())
|
|
|
|
// Parse arguments for the tool call
|
|
if args := function.Get("arguments"); args.Exists() {
|
|
argsStr := args.String()
|
|
if argsStr != "" && gjson.Valid(argsStr) {
|
|
argsJSON := gjson.Parse(argsStr)
|
|
if argsJSON.IsObject() {
|
|
toolUse, _ = sjson.SetRaw(toolUse, "input", argsJSON.Raw)
|
|
} else {
|
|
toolUse, _ = sjson.SetRaw(toolUse, "input", "{}")
|
|
}
|
|
} else {
|
|
toolUse, _ = sjson.SetRaw(toolUse, "input", "{}")
|
|
}
|
|
} else {
|
|
toolUse, _ = sjson.SetRaw(toolUse, "input", "{}")
|
|
}
|
|
|
|
msg, _ = sjson.SetRaw(msg, "content.-1", toolUse)
|
|
}
|
|
return true
|
|
})
|
|
}
|
|
|
|
out, _ = sjson.SetRaw(out, "messages.-1", msg)
|
|
messageIndex++
|
|
|
|
case "tool":
|
|
// Handle tool result messages conversion
|
|
toolCallID := message.Get("tool_call_id").String()
|
|
content := message.Get("content").String()
|
|
|
|
msg := `{"role":"user","content":[{"type":"tool_result","tool_use_id":"","content":""}]}`
|
|
msg, _ = sjson.Set(msg, "content.0.tool_use_id", toolCallID)
|
|
msg, _ = sjson.Set(msg, "content.0.content", content)
|
|
out, _ = sjson.SetRaw(out, "messages.-1", msg)
|
|
messageIndex++
|
|
}
|
|
return true
|
|
})
|
|
}
|
|
|
|
// Tools mapping: OpenAI tools -> Claude Code tools
|
|
if tools := root.Get("tools"); tools.Exists() && tools.IsArray() && len(tools.Array()) > 0 {
|
|
hasAnthropicTools := false
|
|
tools.ForEach(func(_, tool gjson.Result) bool {
|
|
if tool.Get("type").String() == "function" {
|
|
function := tool.Get("function")
|
|
anthropicTool := `{"name":"","description":""}`
|
|
anthropicTool, _ = sjson.Set(anthropicTool, "name", function.Get("name").String())
|
|
anthropicTool, _ = sjson.Set(anthropicTool, "description", function.Get("description").String())
|
|
|
|
// Convert parameters schema for the tool
|
|
if parameters := function.Get("parameters"); parameters.Exists() {
|
|
anthropicTool, _ = sjson.SetRaw(anthropicTool, "input_schema", parameters.Raw)
|
|
} else if parameters := function.Get("parametersJsonSchema"); parameters.Exists() {
|
|
anthropicTool, _ = sjson.SetRaw(anthropicTool, "input_schema", parameters.Raw)
|
|
}
|
|
|
|
out, _ = sjson.SetRaw(out, "tools.-1", anthropicTool)
|
|
hasAnthropicTools = true
|
|
}
|
|
return true
|
|
})
|
|
|
|
if !hasAnthropicTools {
|
|
out, _ = sjson.Delete(out, "tools")
|
|
}
|
|
}
|
|
|
|
// Tool choice mapping from OpenAI format to Claude Code format
|
|
if toolChoice := root.Get("tool_choice"); toolChoice.Exists() {
|
|
switch toolChoice.Type {
|
|
case gjson.String:
|
|
choice := toolChoice.String()
|
|
switch choice {
|
|
case "none":
|
|
// Don't set tool_choice, Claude Code will not use tools
|
|
case "auto":
|
|
out, _ = sjson.SetRaw(out, "tool_choice", `{"type":"auto"}`)
|
|
case "required":
|
|
out, _ = sjson.SetRaw(out, "tool_choice", `{"type":"any"}`)
|
|
}
|
|
case gjson.JSON:
|
|
// Specific tool choice mapping
|
|
if toolChoice.Get("type").String() == "function" {
|
|
functionName := toolChoice.Get("function.name").String()
|
|
toolChoiceJSON := `{"type":"tool","name":""}`
|
|
toolChoiceJSON, _ = sjson.Set(toolChoiceJSON, "name", functionName)
|
|
out, _ = sjson.SetRaw(out, "tool_choice", toolChoiceJSON)
|
|
}
|
|
default:
|
|
}
|
|
}
|
|
|
|
return []byte(out)
|
|
}
|