mirror of
https://github.com/router-for-me/CLIProxyAPI.git
synced 2026-02-18 04:10:51 +08:00
0a47b452e9
- Ensured `functionDeclarations` key renaming only occurs if the key exists in Gemini tools processing. - Prevented unnecessary JSON reassignment when the target key is absent.
97 lines
3.5 KiB
Go
97 lines
3.5 KiB
Go
// Package gemini provides in-provider request normalization for Gemini API.
|
|
// It ensures incoming v1beta requests meet minimal schema requirements
|
|
// expected by Google's Generative Language API.
|
|
package gemini
|
|
|
|
import (
|
|
"bytes"
|
|
"fmt"
|
|
|
|
"github.com/router-for-me/CLIProxyAPI/v6/internal/translator/gemini/common"
|
|
"github.com/router-for-me/CLIProxyAPI/v6/internal/util"
|
|
"github.com/tidwall/gjson"
|
|
"github.com/tidwall/sjson"
|
|
)
|
|
|
|
// ConvertGeminiRequestToGemini normalizes Gemini v1beta requests.
|
|
// - Adds a default role for each content if missing or invalid.
|
|
// The first message defaults to "user", then alternates user/model when needed.
|
|
//
|
|
// It keeps the payload otherwise unchanged.
|
|
func ConvertGeminiRequestToGemini(_ string, inputRawJSON []byte, _ bool) []byte {
|
|
rawJSON := bytes.Clone(inputRawJSON)
|
|
// Fast path: if no contents field, only attach safety settings
|
|
contents := gjson.GetBytes(rawJSON, "contents")
|
|
if !contents.Exists() {
|
|
return common.AttachDefaultSafetySettings(rawJSON, "safetySettings")
|
|
}
|
|
|
|
toolsResult := gjson.GetBytes(rawJSON, "tools")
|
|
if toolsResult.Exists() && toolsResult.IsArray() {
|
|
toolResults := toolsResult.Array()
|
|
for i := 0; i < len(toolResults); i++ {
|
|
if gjson.GetBytes(rawJSON, fmt.Sprintf("tools.%d.functionDeclarations", i)).Exists() {
|
|
strJson, _ := util.RenameKey(string(rawJSON), fmt.Sprintf("tools.%d.functionDeclarations", i), fmt.Sprintf("tools.%d.function_declarations", i))
|
|
rawJSON = []byte(strJson)
|
|
}
|
|
|
|
functionDeclarationsResult := gjson.GetBytes(rawJSON, fmt.Sprintf("tools.%d.function_declarations", i))
|
|
if functionDeclarationsResult.Exists() && functionDeclarationsResult.IsArray() {
|
|
functionDeclarationsResults := functionDeclarationsResult.Array()
|
|
for j := 0; j < len(functionDeclarationsResults); j++ {
|
|
parametersResult := gjson.GetBytes(rawJSON, fmt.Sprintf("tools.%d.function_declarations.%d.parameters", i, j))
|
|
if parametersResult.Exists() {
|
|
strJson, _ := util.RenameKey(string(rawJSON), fmt.Sprintf("tools.%d.function_declarations.%d.parameters", i, j), fmt.Sprintf("tools.%d.function_declarations.%d.parametersJsonSchema", i, j))
|
|
rawJSON = []byte(strJson)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
// Walk contents and fix roles
|
|
out := rawJSON
|
|
prevRole := ""
|
|
idx := 0
|
|
contents.ForEach(func(_ gjson.Result, value gjson.Result) bool {
|
|
role := value.Get("role").String()
|
|
|
|
// Only user/model are valid for Gemini v1beta requests
|
|
valid := role == "user" || role == "model"
|
|
if role == "" || !valid {
|
|
var newRole string
|
|
if prevRole == "" {
|
|
newRole = "user"
|
|
} else if prevRole == "user" {
|
|
newRole = "model"
|
|
} else {
|
|
newRole = "user"
|
|
}
|
|
path := fmt.Sprintf("contents.%d.role", idx)
|
|
out, _ = sjson.SetBytes(out, path, newRole)
|
|
role = newRole
|
|
}
|
|
|
|
prevRole = role
|
|
idx++
|
|
return true
|
|
})
|
|
|
|
gjson.GetBytes(out, "contents").ForEach(func(key, content gjson.Result) bool {
|
|
if content.Get("role").String() == "model" {
|
|
content.Get("parts").ForEach(func(partKey, part gjson.Result) bool {
|
|
if part.Get("functionCall").Exists() {
|
|
out, _ = sjson.SetBytes(out, fmt.Sprintf("contents.%d.parts.%d.thoughtSignature", key.Int(), partKey.Int()), "skip_thought_signature_validator")
|
|
} else if part.Get("thoughtSignature").Exists() {
|
|
out, _ = sjson.SetBytes(out, fmt.Sprintf("contents.%d.parts.%d.thoughtSignature", key.Int(), partKey.Int()), "skip_thought_signature_validator")
|
|
}
|
|
return true
|
|
})
|
|
}
|
|
return true
|
|
})
|
|
|
|
out = common.AttachDefaultSafetySettings(out, "safetySettings")
|
|
return out
|
|
}
|