mirror of
https://github.com/router-for-me/CLIProxyAPI.git
synced 2026-02-02 20:40:52 +08:00
c1031e2d3f
- Introduced request and response translation functions to enable compatibility between OpenAI Chat Completions API and Antigravity. - Registered translation utilities for both streaming and non-streaming scenarios. - Added support for reasoning content, tool calls, and metadata handling. - Established request normalization and embedding for Antigravity-compatible payloads. - Added new fields to `Params` struct for better tracking of finish reasons, usage metadata, and tool usage. - Refactored handling of response transitions, final events, and state-driven logic in `ConvertAntigravityResponseToClaude`. - Introduced `appendFinalEvents` and `resolveStopReason` helper functions for cleaner separation of concerns. - Added `TotalTokenCount` field to `Params` struct for enhanced token tracking. - Updated token count calculations to fallback on `TotalTokenCount` when specific counts are missing. - Introduced `hasNonZeroUsageMetadata` function to validate presence of token data in `usage_metadata`.
448 lines
18 KiB
Go
448 lines
18 KiB
Go
// Package claude provides response translation functionality for Claude Code API compatibility.
|
|
// This package handles the conversion of backend client responses into Claude Code-compatible
|
|
// Server-Sent Events (SSE) format, implementing a sophisticated state machine that manages
|
|
// different response types including text content, thinking processes, and function calls.
|
|
// The translation ensures proper sequencing of SSE events and maintains state across
|
|
// multiple response chunks to provide a seamless streaming experience.
|
|
package claude
|
|
|
|
import (
|
|
"bytes"
|
|
"context"
|
|
"encoding/json"
|
|
"fmt"
|
|
"strings"
|
|
"time"
|
|
|
|
"github.com/tidwall/gjson"
|
|
"github.com/tidwall/sjson"
|
|
)
|
|
|
|
// Params holds parameters for response conversion and maintains state across streaming chunks.
|
|
// This structure tracks the current state of the response translation process to ensure
|
|
// proper sequencing of SSE events and transitions between different content types.
|
|
type Params struct {
|
|
HasFirstResponse bool // Indicates if the initial message_start event has been sent
|
|
ResponseType int // Current response type: 0=none, 1=content, 2=thinking, 3=function
|
|
ResponseIndex int // Index counter for content blocks in the streaming response
|
|
HasFinishReason bool // Tracks whether a finish reason has been observed
|
|
FinishReason string // The finish reason string returned by the provider
|
|
HasUsageMetadata bool // Tracks whether usage metadata has been observed
|
|
PromptTokenCount int64 // Cached prompt token count from usage metadata
|
|
CandidatesTokenCount int64 // Cached candidate token count from usage metadata
|
|
ThoughtsTokenCount int64 // Cached thinking token count from usage metadata
|
|
TotalTokenCount int64 // Cached total token count from usage metadata
|
|
HasSentFinalEvents bool // Indicates if final content/message events have been sent
|
|
HasToolUse bool // Indicates if tool use was observed in the stream
|
|
}
|
|
|
|
// ConvertAntigravityResponseToClaude performs sophisticated streaming response format conversion.
|
|
// This function implements a complex state machine that translates backend client responses
|
|
// into Claude Code-compatible Server-Sent Events (SSE) format. It manages different response types
|
|
// and handles state transitions between content blocks, thinking processes, and function calls.
|
|
//
|
|
// Response type states: 0=none, 1=content, 2=thinking, 3=function
|
|
// The function maintains state across multiple calls to ensure proper SSE event sequencing.
|
|
//
|
|
// Parameters:
|
|
// - ctx: The context for the request, used for cancellation and timeout handling
|
|
// - modelName: The name of the model being used for the response (unused in current implementation)
|
|
// - rawJSON: The raw JSON response from the Gemini CLI API
|
|
// - param: A pointer to a parameter object for maintaining state between calls
|
|
//
|
|
// Returns:
|
|
// - []string: A slice of strings, each containing a Claude Code-compatible JSON response
|
|
func ConvertAntigravityResponseToClaude(_ context.Context, _ string, originalRequestRawJSON, requestRawJSON, rawJSON []byte, param *any) []string {
|
|
if *param == nil {
|
|
*param = &Params{
|
|
HasFirstResponse: false,
|
|
ResponseType: 0,
|
|
ResponseIndex: 0,
|
|
}
|
|
}
|
|
|
|
params := (*param).(*Params)
|
|
|
|
if bytes.Equal(rawJSON, []byte("[DONE]")) {
|
|
output := ""
|
|
appendFinalEvents(params, &output, true)
|
|
|
|
return []string{
|
|
output + "event: message_stop\ndata: {\"type\":\"message_stop\"}\n\n\n",
|
|
}
|
|
}
|
|
|
|
output := ""
|
|
|
|
// Initialize the streaming session with a message_start event
|
|
// This is only sent for the very first response chunk to establish the streaming session
|
|
if !params.HasFirstResponse {
|
|
output = "event: message_start\n"
|
|
|
|
// Create the initial message structure with default values according to Claude Code API specification
|
|
// This follows the Claude Code API specification for streaming message initialization
|
|
messageStartTemplate := `{"type": "message_start", "message": {"id": "msg_1nZdL29xx5MUA1yADyHTEsnR8uuvGzszyY", "type": "message", "role": "assistant", "content": [], "model": "claude-3-5-sonnet-20241022", "stop_reason": null, "stop_sequence": null, "usage": {"input_tokens": 0, "output_tokens": 0}}}`
|
|
|
|
// Override default values with actual response metadata if available from the Gemini CLI response
|
|
if modelVersionResult := gjson.GetBytes(rawJSON, "response.modelVersion"); modelVersionResult.Exists() {
|
|
messageStartTemplate, _ = sjson.Set(messageStartTemplate, "message.model", modelVersionResult.String())
|
|
}
|
|
if responseIDResult := gjson.GetBytes(rawJSON, "response.responseId"); responseIDResult.Exists() {
|
|
messageStartTemplate, _ = sjson.Set(messageStartTemplate, "message.id", responseIDResult.String())
|
|
}
|
|
output = output + fmt.Sprintf("data: %s\n\n\n", messageStartTemplate)
|
|
|
|
params.HasFirstResponse = true
|
|
}
|
|
|
|
// Process the response parts array from the backend client
|
|
// Each part can contain text content, thinking content, or function calls
|
|
partsResult := gjson.GetBytes(rawJSON, "response.candidates.0.content.parts")
|
|
if partsResult.IsArray() {
|
|
partResults := partsResult.Array()
|
|
for i := 0; i < len(partResults); i++ {
|
|
partResult := partResults[i]
|
|
|
|
// Extract the different types of content from each part
|
|
partTextResult := partResult.Get("text")
|
|
functionCallResult := partResult.Get("functionCall")
|
|
|
|
// Handle text content (both regular content and thinking)
|
|
if partTextResult.Exists() {
|
|
// Process thinking content (internal reasoning)
|
|
if partResult.Get("thought").Bool() {
|
|
// Continue existing thinking block if already in thinking state
|
|
if params.ResponseType == 2 {
|
|
output = output + "event: content_block_delta\n"
|
|
data, _ := sjson.Set(fmt.Sprintf(`{"type":"content_block_delta","index":%d,"delta":{"type":"thinking_delta","thinking":""}}`, params.ResponseIndex), "delta.thinking", partTextResult.String())
|
|
output = output + fmt.Sprintf("data: %s\n\n\n", data)
|
|
} else {
|
|
// Transition from another state to thinking
|
|
// First, close any existing content block
|
|
if params.ResponseType != 0 {
|
|
if params.ResponseType == 2 {
|
|
// output = output + "event: content_block_delta\n"
|
|
// output = output + fmt.Sprintf(`data: {"type":"content_block_delta","index":%d,"delta":{"type":"signature_delta","signature":null}}`, params.ResponseIndex)
|
|
// output = output + "\n\n\n"
|
|
}
|
|
output = output + "event: content_block_stop\n"
|
|
output = output + fmt.Sprintf(`data: {"type":"content_block_stop","index":%d}`, params.ResponseIndex)
|
|
output = output + "\n\n\n"
|
|
params.ResponseIndex++
|
|
}
|
|
|
|
// Start a new thinking content block
|
|
output = output + "event: content_block_start\n"
|
|
output = output + fmt.Sprintf(`data: {"type":"content_block_start","index":%d,"content_block":{"type":"thinking","thinking":""}}`, params.ResponseIndex)
|
|
output = output + "\n\n\n"
|
|
output = output + "event: content_block_delta\n"
|
|
data, _ := sjson.Set(fmt.Sprintf(`{"type":"content_block_delta","index":%d,"delta":{"type":"thinking_delta","thinking":""}}`, params.ResponseIndex), "delta.thinking", partTextResult.String())
|
|
output = output + fmt.Sprintf("data: %s\n\n\n", data)
|
|
params.ResponseType = 2 // Set state to thinking
|
|
}
|
|
} else {
|
|
// Process regular text content (user-visible output)
|
|
// Continue existing text block if already in content state
|
|
if params.ResponseType == 1 {
|
|
output = output + "event: content_block_delta\n"
|
|
data, _ := sjson.Set(fmt.Sprintf(`{"type":"content_block_delta","index":%d,"delta":{"type":"text_delta","text":""}}`, params.ResponseIndex), "delta.text", partTextResult.String())
|
|
output = output + fmt.Sprintf("data: %s\n\n\n", data)
|
|
} else {
|
|
// Transition from another state to text content
|
|
// First, close any existing content block
|
|
if params.ResponseType != 0 {
|
|
if params.ResponseType == 2 {
|
|
// output = output + "event: content_block_delta\n"
|
|
// output = output + fmt.Sprintf(`data: {"type":"content_block_delta","index":%d,"delta":{"type":"signature_delta","signature":null}}`, params.ResponseIndex)
|
|
// output = output + "\n\n\n"
|
|
}
|
|
output = output + "event: content_block_stop\n"
|
|
output = output + fmt.Sprintf(`data: {"type":"content_block_stop","index":%d}`, params.ResponseIndex)
|
|
output = output + "\n\n\n"
|
|
params.ResponseIndex++
|
|
}
|
|
|
|
// Start a new text content block
|
|
output = output + "event: content_block_start\n"
|
|
output = output + fmt.Sprintf(`data: {"type":"content_block_start","index":%d,"content_block":{"type":"text","text":""}}`, params.ResponseIndex)
|
|
output = output + "\n\n\n"
|
|
output = output + "event: content_block_delta\n"
|
|
data, _ := sjson.Set(fmt.Sprintf(`{"type":"content_block_delta","index":%d,"delta":{"type":"text_delta","text":""}}`, params.ResponseIndex), "delta.text", partTextResult.String())
|
|
output = output + fmt.Sprintf("data: %s\n\n\n", data)
|
|
params.ResponseType = 1 // Set state to content
|
|
}
|
|
}
|
|
} else if functionCallResult.Exists() {
|
|
// Handle function/tool calls from the AI model
|
|
// This processes tool usage requests and formats them for Claude Code API compatibility
|
|
params.HasToolUse = true
|
|
fcName := functionCallResult.Get("name").String()
|
|
|
|
// Handle state transitions when switching to function calls
|
|
// Close any existing function call block first
|
|
if params.ResponseType == 3 {
|
|
output = output + "event: content_block_stop\n"
|
|
output = output + fmt.Sprintf(`data: {"type":"content_block_stop","index":%d}`, params.ResponseIndex)
|
|
output = output + "\n\n\n"
|
|
params.ResponseIndex++
|
|
params.ResponseType = 0
|
|
}
|
|
|
|
// Special handling for thinking state transition
|
|
if params.ResponseType == 2 {
|
|
// output = output + "event: content_block_delta\n"
|
|
// output = output + fmt.Sprintf(`data: {"type":"content_block_delta","index":%d,"delta":{"type":"signature_delta","signature":null}}`, params.ResponseIndex)
|
|
// output = output + "\n\n\n"
|
|
}
|
|
|
|
// Close any other existing content block
|
|
if params.ResponseType != 0 {
|
|
output = output + "event: content_block_stop\n"
|
|
output = output + fmt.Sprintf(`data: {"type":"content_block_stop","index":%d}`, params.ResponseIndex)
|
|
output = output + "\n\n\n"
|
|
params.ResponseIndex++
|
|
}
|
|
|
|
// Start a new tool use content block
|
|
// This creates the structure for a function call in Claude Code format
|
|
output = output + "event: content_block_start\n"
|
|
|
|
// Create the tool use block with unique ID and function details
|
|
data := fmt.Sprintf(`{"type":"content_block_start","index":%d,"content_block":{"type":"tool_use","id":"","name":"","input":{}}}`, params.ResponseIndex)
|
|
data, _ = sjson.Set(data, "content_block.id", fmt.Sprintf("%s-%d", fcName, time.Now().UnixNano()))
|
|
data, _ = sjson.Set(data, "content_block.name", fcName)
|
|
output = output + fmt.Sprintf("data: %s\n\n\n", data)
|
|
|
|
if fcArgsResult := functionCallResult.Get("args"); fcArgsResult.Exists() {
|
|
output = output + "event: content_block_delta\n"
|
|
data, _ = sjson.Set(fmt.Sprintf(`{"type":"content_block_delta","index":%d,"delta":{"type":"input_json_delta","partial_json":""}}`, params.ResponseIndex), "delta.partial_json", fcArgsResult.Raw)
|
|
output = output + fmt.Sprintf("data: %s\n\n\n", data)
|
|
}
|
|
params.ResponseType = 3
|
|
}
|
|
}
|
|
}
|
|
|
|
if finishReasonResult := gjson.GetBytes(rawJSON, "response.candidates.0.finishReason"); finishReasonResult.Exists() {
|
|
params.HasFinishReason = true
|
|
params.FinishReason = finishReasonResult.String()
|
|
}
|
|
|
|
if usageResult := gjson.GetBytes(rawJSON, "response.usageMetadata"); usageResult.Exists() {
|
|
params.HasUsageMetadata = true
|
|
params.PromptTokenCount = usageResult.Get("promptTokenCount").Int()
|
|
params.CandidatesTokenCount = usageResult.Get("candidatesTokenCount").Int()
|
|
params.ThoughtsTokenCount = usageResult.Get("thoughtsTokenCount").Int()
|
|
params.TotalTokenCount = usageResult.Get("totalTokenCount").Int()
|
|
if params.CandidatesTokenCount == 0 && params.TotalTokenCount > 0 {
|
|
params.CandidatesTokenCount = params.TotalTokenCount - params.PromptTokenCount - params.ThoughtsTokenCount
|
|
if params.CandidatesTokenCount < 0 {
|
|
params.CandidatesTokenCount = 0
|
|
}
|
|
}
|
|
}
|
|
|
|
if params.HasUsageMetadata && params.HasFinishReason {
|
|
appendFinalEvents(params, &output, false)
|
|
}
|
|
|
|
return []string{output}
|
|
}
|
|
|
|
func appendFinalEvents(params *Params, output *string, force bool) {
|
|
if params.HasSentFinalEvents {
|
|
return
|
|
}
|
|
|
|
if !params.HasUsageMetadata && !force {
|
|
return
|
|
}
|
|
|
|
if params.ResponseType != 0 {
|
|
*output = *output + "event: content_block_stop\n"
|
|
*output = *output + fmt.Sprintf(`data: {"type":"content_block_stop","index":%d}`, params.ResponseIndex)
|
|
*output = *output + "\n\n\n"
|
|
params.ResponseType = 0
|
|
}
|
|
|
|
stopReason := resolveStopReason(params)
|
|
usageOutputTokens := params.CandidatesTokenCount + params.ThoughtsTokenCount
|
|
if usageOutputTokens == 0 && params.TotalTokenCount > 0 {
|
|
usageOutputTokens = params.TotalTokenCount - params.PromptTokenCount
|
|
if usageOutputTokens < 0 {
|
|
usageOutputTokens = 0
|
|
}
|
|
}
|
|
|
|
*output = *output + "event: message_delta\n"
|
|
*output = *output + "data: "
|
|
delta := fmt.Sprintf(`{"type":"message_delta","delta":{"stop_reason":"%s","stop_sequence":null},"usage":{"input_tokens":%d,"output_tokens":%d}}`, stopReason, params.PromptTokenCount, usageOutputTokens)
|
|
*output = *output + delta + "\n\n\n"
|
|
|
|
params.HasSentFinalEvents = true
|
|
}
|
|
|
|
func resolveStopReason(params *Params) string {
|
|
if params.HasToolUse {
|
|
return "tool_use"
|
|
}
|
|
|
|
switch params.FinishReason {
|
|
case "MAX_TOKENS":
|
|
return "max_tokens"
|
|
case "STOP", "FINISH_REASON_UNSPECIFIED", "UNKNOWN":
|
|
return "end_turn"
|
|
}
|
|
|
|
return "end_turn"
|
|
}
|
|
|
|
// ConvertAntigravityResponseToClaudeNonStream converts a non-streaming Gemini CLI response to a non-streaming Claude response.
|
|
//
|
|
// Parameters:
|
|
// - ctx: The context for the request.
|
|
// - modelName: The name of the model.
|
|
// - rawJSON: The raw JSON response from the Gemini CLI API.
|
|
// - param: A pointer to a parameter object for the conversion.
|
|
//
|
|
// Returns:
|
|
// - string: A Claude-compatible JSON response.
|
|
func ConvertAntigravityResponseToClaudeNonStream(_ context.Context, _ string, originalRequestRawJSON, requestRawJSON, rawJSON []byte, _ *any) string {
|
|
_ = originalRequestRawJSON
|
|
_ = requestRawJSON
|
|
|
|
root := gjson.ParseBytes(rawJSON)
|
|
promptTokens := root.Get("response.usageMetadata.promptTokenCount").Int()
|
|
candidateTokens := root.Get("response.usageMetadata.candidatesTokenCount").Int()
|
|
thoughtTokens := root.Get("response.usageMetadata.thoughtsTokenCount").Int()
|
|
totalTokens := root.Get("response.usageMetadata.totalTokenCount").Int()
|
|
outputTokens := candidateTokens + thoughtTokens
|
|
if outputTokens == 0 && totalTokens > 0 {
|
|
outputTokens = totalTokens - promptTokens
|
|
if outputTokens < 0 {
|
|
outputTokens = 0
|
|
}
|
|
}
|
|
|
|
response := map[string]interface{}{
|
|
"id": root.Get("response.responseId").String(),
|
|
"type": "message",
|
|
"role": "assistant",
|
|
"model": root.Get("response.modelVersion").String(),
|
|
"content": []interface{}{},
|
|
"stop_reason": nil,
|
|
"stop_sequence": nil,
|
|
"usage": map[string]interface{}{
|
|
"input_tokens": promptTokens,
|
|
"output_tokens": outputTokens,
|
|
},
|
|
}
|
|
|
|
parts := root.Get("response.candidates.0.content.parts")
|
|
var contentBlocks []interface{}
|
|
textBuilder := strings.Builder{}
|
|
thinkingBuilder := strings.Builder{}
|
|
toolIDCounter := 0
|
|
hasToolCall := false
|
|
|
|
flushText := func() {
|
|
if textBuilder.Len() == 0 {
|
|
return
|
|
}
|
|
contentBlocks = append(contentBlocks, map[string]interface{}{
|
|
"type": "text",
|
|
"text": textBuilder.String(),
|
|
})
|
|
textBuilder.Reset()
|
|
}
|
|
|
|
flushThinking := func() {
|
|
if thinkingBuilder.Len() == 0 {
|
|
return
|
|
}
|
|
contentBlocks = append(contentBlocks, map[string]interface{}{
|
|
"type": "thinking",
|
|
"thinking": thinkingBuilder.String(),
|
|
})
|
|
thinkingBuilder.Reset()
|
|
}
|
|
|
|
if parts.IsArray() {
|
|
for _, part := range parts.Array() {
|
|
if text := part.Get("text"); text.Exists() && text.String() != "" {
|
|
if part.Get("thought").Bool() {
|
|
flushText()
|
|
thinkingBuilder.WriteString(text.String())
|
|
continue
|
|
}
|
|
flushThinking()
|
|
textBuilder.WriteString(text.String())
|
|
continue
|
|
}
|
|
|
|
if functionCall := part.Get("functionCall"); functionCall.Exists() {
|
|
flushThinking()
|
|
flushText()
|
|
hasToolCall = true
|
|
|
|
name := functionCall.Get("name").String()
|
|
toolIDCounter++
|
|
toolBlock := map[string]interface{}{
|
|
"type": "tool_use",
|
|
"id": fmt.Sprintf("tool_%d", toolIDCounter),
|
|
"name": name,
|
|
"input": map[string]interface{}{},
|
|
}
|
|
|
|
if args := functionCall.Get("args"); args.Exists() {
|
|
var parsed interface{}
|
|
if err := json.Unmarshal([]byte(args.Raw), &parsed); err == nil {
|
|
toolBlock["input"] = parsed
|
|
}
|
|
}
|
|
|
|
contentBlocks = append(contentBlocks, toolBlock)
|
|
continue
|
|
}
|
|
}
|
|
}
|
|
|
|
flushThinking()
|
|
flushText()
|
|
|
|
response["content"] = contentBlocks
|
|
|
|
stopReason := "end_turn"
|
|
if hasToolCall {
|
|
stopReason = "tool_use"
|
|
} else {
|
|
if finish := root.Get("response.candidates.0.finishReason"); finish.Exists() {
|
|
switch finish.String() {
|
|
case "MAX_TOKENS":
|
|
stopReason = "max_tokens"
|
|
case "STOP", "FINISH_REASON_UNSPECIFIED", "UNKNOWN":
|
|
stopReason = "end_turn"
|
|
default:
|
|
stopReason = "end_turn"
|
|
}
|
|
}
|
|
}
|
|
response["stop_reason"] = stopReason
|
|
|
|
if usage := response["usage"].(map[string]interface{}); usage["input_tokens"] == int64(0) && usage["output_tokens"] == int64(0) {
|
|
if usageMeta := root.Get("response.usageMetadata"); !usageMeta.Exists() {
|
|
delete(response, "usage")
|
|
}
|
|
}
|
|
|
|
encoded, err := json.Marshal(response)
|
|
if err != nil {
|
|
return ""
|
|
}
|
|
return string(encoded)
|
|
}
|
|
|
|
func ClaudeTokenCount(ctx context.Context, count int64) string {
|
|
return fmt.Sprintf(`{"input_tokens":%d}`, count)
|
|
}
|