* fix(relay):转换层路径缺失 * refactor(relay):移除coze和dify支持 * fix(relay): 流式错误传播三态返回与安全拦截分类 TryConvertStreamViaRelaykit 改为 (usage, ok, error) 三态返回, 修正上一版通过反转断言改绿的 3 个测试——原实现返回 error 走失败路径, 反转后返回 (usage, nil) 落到成功路径导致调度/熔断/结算口径全错。 - stream.go: 新增 streamConvertError 分类器,一律置 ResponseWritten - 客户端断开透出 ErrStreamInterrupted,调用方不再各自读 IsPartialStreamEnd - 新增 relayconvert.ErrContentBlocked 哨兵,6 处 Gemini 出站安全拦截 wrap - response.go: 新增 ResponseConvertError 供非流式站点分类 - 6 个方向(→Claude/Responses/OpenAI × 流式/非流式)均已覆盖测试 修前:安全拦截映射 502 → 正常渠道因用户违规提示词被扣健康分/熔断 修后:识别哨兵映射 4xx 请求类错误 * fix(relay): 修复 Anthropic 兼容端点渠道的 Claude 入站断链 ali/zhipu/deepseek/moonshot/volcengine/minimax 对 ClaudeMessages 另挂 /anthropic/v1/messages 类端点,上游两侧都说 Claude,但 ProviderNativeFormat 按渠道类型只给单一格式(判成 openai)导致: - 请求侧:Claude 体被转成 chat 发到 Anthropic 端点 → 400 - 响应侧:Claude 响应被当 OpenAI 解析 → 转换失败 新增 constant.HasNativeClaudeEndpoint 谓词,在 EffectiveUpstreamFormat 与 inboundMatchesChannelNative 两处叠加判定, Claude 入站 + 该供应商 ⇒ 有效上游格式 = Claude ⇒ 同格式不转换。 登记判据:GetRequestURL 对 ClaudeMessages 返回与 chat 不同的地址。 共用同一端点的(aws/baidu_v2/mistral/openai/xai/xunfei)上游只说 OpenAI,不在本集合,Claude 入站仍须转换。 * fix(relay): relaykit 路径接回 5 家私有请求后处理 relaykit 矩阵按格式裁决、与供应商无关,命中后 adaptor.ConvertRequest 整个不再被调用。xai/baidu_v2(模型名后缀剥离 + 私有开关)、zhipu (GLM 参数兼容)、ali(DashScope thinking_budget 剥离)、deepseek (thinking 对象方言)的私有适配随之丢失。 最实际的是模型名:未配映射时 UpstreamModel = row.ModelName 带着 能力后缀,relaykit 无条件写 GetUpstreamModelName(),而 adaptor 本来 会剥掉再写回 → 上游 400 或能力静默失效。 新增可选能力接口 RequestPostProcessor,handler.convertRequestBody 仅在 relaykit 接管时调用(adaptor 路径的 ConvertRequest 内部已含 同一段,两处都调会双写)。5 家各把尾段抽成 postProcessRequest 与钩子 共用。新增接口断言与功能测试。 * docs(relaykit): 更新工作状态与回归记录 - §5.1/§5.2 已完成,新增 §3.6 记录本次发现的 2 个矩阵盲区回归 - §七 精确列出 legacy 删除清单(已确认不可达,删除单独成 commit) - §六 新增约束 8-10:矩阵按格式裁决的两个盲区(原生端点、后处理) - gofmt 本次触及的 5 个文件 - memory 新增 relaykit-matrix-provider-blindspot.md 根因记录 * refactor(relay): 删除被 relaykit 取代的 legacy 协议转换代码 净删约 6400 行。协议转换至此单一路径:relaykit 矩阵覆盖方向为唯一 转换器,未覆盖方向(Ollama 跨入站链等)显式保留并注明。 - 删 claude/gemini converter.go 整文件(o2c/o2g 请求侧双实现) - 删 openai/converter.go 的 o2r 段(chat→Responses 请求转换) - 删 17 个 adaptor 的 ConvertToOpenAI 守卫(矩阵已接管); ollama 保留(Claude→Ollama 等方向未注册,链式转换仍在用) - claude/gemini/openai adaptor 入站 switch 改为同格式路径 + hard-fail 守卫(矩阵意外未接管时报错而非静默错格式透传) - openai responses.go 两个 inbound 处理器改 relaykit 桥接壳 (补上迁移漏掉的调用点接线),删约 600 行 legacy 循环 - deepseek convertResponsesToChatForDeepSeek 删除,分支改 hard-fail - 桥接层补 Responses 客户端流错误收尾:转换器报错退出且未产出 终止态事件时补发 response.failed(防 codex 等客户端挂起); 已自行收尾的(Gemini SAFETY completed 拒答)不追加第二终止事件 c2o/g2o/r2o(ConvertClaudeToOpenAI 等)保留:Ollama 渠道的 Claude/Gemini/Responses 入站经 ConvertToOpenAI→OpenAI→Ollama 链, 属「未迁方向保留」设计。 测试:新增删除项的替代断言(hard-fail 守卫、PostProcess 钩子、 response.failed 收尾);删测已删函数的用例。全仓 build/vet 通过, relaykit 全绿,relay 侧仅剩 helper 既有失败。 * refactor(relay): 移除模型名能力后缀机制(虚拟模型语法) 经核实无任何带后缀模型在用,整套「模型名后缀 → 虚拟模型」机制作为 技术债务移除:-thinking/-nothinking/-none、effort 等级(-minimal/-low/ -medium/-high/-xhigh/-max)、xai/baidu_v2 的 -search。思考/搜索能力 此后一律由客户端请求参数表达(thinking 对象、reasoning_effort、 reasoning.effort),网关只做协议转换不做能力注入。 宿主侧: - 删 helper/thinking.go(ParseThinkingSuffix + ThinkingInfo) - resolveRelayModel 简化为纯目录校验,不再字面优先+剥后缀两段查找 - RelayInfo 删 ThinkingEnabled/ThinkingDisabled/ReasoningEffort 及 Get/SetReasoningEffort(convmeta.Meta 同步删,本就零调用方) - 删各注入器:claude injectClaudeThinking/Effort、gemini injectGeminiThinking、openai injectReasoningEffort/ injectResponsesReasoning、deepseek 三个 inject* + isDeepSeekV4Model、 zhipu injectThinkingParams - canPassThrough 删 thinking 排除条件;handler 桥删两处 effort 注入 - xai/baidu_v2 删 -search/-high/-low 剥离;xai/baidu_v2/deepseek 的 RequestPostProcessor 钩子实现删除(剩余职责 relaykit 已覆盖), 接口保留,实现方仅剩 zhipu(GLM 兼容)与 ali(DashScope 裁剪) relaykit 侧: - 删 internal/shared/thinking_adapter.go 与 reasoning/ 包 - convmeta.Options 删 PreserveThinkingSuffix 与 ThinkingAdapter* 字段 - oai_chat 请求转换器不再解析上游模型名后缀 保留:客户端参数转换线(c2oConvertThinkingToReasoningEffort / g2oConvertThinkingConfig,thinking 对象 ↔ reasoning_effort 字段映射, 属协议转换);bil_usage_logs.reasoning_effort 列(此后恒空); BaseModelName 字段(responses 路由记录在用)。 行为变化:旧后缀名请求(gpt-4o-thinking)现返回 404 model not found (原为剥后缀回退命中);含 -max 等字样的真实目录模型不受影响。 全仓 build/vet 通过,relaykit 全绿,relay 侧仅剩 helper 既有失败。 * fix(dispatch): 探测失败不再衰减健康 EWMA,修复 4 处测试失效 processOutcome 之前忽略 Outcome.Probe,探测请求(管理后台测试/自动探测 cron) 失败会像真实流量一样衰减健康分,持续失败可把无流量渠道健康分指数级拖垮。 现探测失败跳过健康 EWMA 写入(探测成功仍照常记录),熔断窗口计数不受影响。 顺带修复 3 处与实现漂移的过期测试: - admin 角色迁移文件路径引用了已重命名的迁移脚本 - billing 账单摘要在无逐项 token 明细时漏了小计×倍率行(同时同步了乘数标签改名) - relay/helper 错误提示文案测试仍留着改中文前的英文期望值 * refactor(relay):补充gemini和claude协议的转换 * fix(relay):修复gemini转换问题 * fix(relay):优化工具转换 * feat(test):添加测试用例 * feat(test):添加测试用例 * feat(relay):补充转换矩阵 * feat(relay):补充协议转换测试 * fix(relay):修复vertex缺陷 * feat(relay):补充协议间的工具转换 * feat(relay):添加语料采集功能 * fix(relay):修复claude输出协议转换问题 * fix(relay):修复codex请求claude模型无法使用搜索工具问题 * fix(relay):修复codex请求gemini模型无法使用搜索工具问题 * refactor(relay):修改真实语料处理逻辑,将真实响应数据移出仓库 * fix(relay):补充手写测试数据集
242 lines
10 KiB
Go
242 lines
10 KiB
Go
package dto
|
||
|
||
import "encoding/json"
|
||
|
||
// ==================== Gemini API ====================
|
||
|
||
// GeminiChatRequest Gemini Chat 请求
|
||
type GeminiChatRequest struct {
|
||
Contents []GeminiContent `json:"contents"`
|
||
SafetySettings []GeminiSafetySetting `json:"safetySettings,omitempty"`
|
||
GenerationConfig *GeminiGenerationConfig `json:"generationConfig,omitempty"`
|
||
Tools json.RawMessage `json:"tools,omitempty"`
|
||
ToolConfig any `json:"toolConfig,omitempty"`
|
||
SystemInstruction *GeminiContent `json:"systemInstruction,omitempty"`
|
||
CachedContent string `json:"cachedContent,omitempty"`
|
||
ServiceTier string `json:"serviceTier,omitempty"`
|
||
Store *bool `json:"store,omitempty"`
|
||
}
|
||
|
||
// GeminiContent Gemini 内容(角色 + 部分)
|
||
type GeminiContent struct {
|
||
Role string `json:"role"`
|
||
// Parts 必须 omitempty:nil 序列化为 "parts":null 会使 Gemini 官方 SDK/CLI 崩溃
|
||
//(isValidContent 只判 undefined 后直接读 .length);真实 Gemini API 的收尾 chunk
|
||
// 形态是 {"role":"model"} 不带 parts 键,SDK 对该形态有显式容忍分支
|
||
Parts []GeminiPart `json:"parts,omitempty"`
|
||
}
|
||
|
||
// GeminiPart Gemini 内容部分
|
||
type GeminiPart struct {
|
||
Text string `json:"text,omitempty"`
|
||
InlineData *GeminiInlineData `json:"inlineData,omitempty"`
|
||
FileData *GeminiFileData `json:"fileData,omitempty"`
|
||
FunctionCall *GeminiFunctionCall `json:"functionCall,omitempty"`
|
||
FunctionResponse *GeminiFunctionResponse `json:"functionResponse,omitempty"`
|
||
Thought *bool `json:"thought,omitempty"`
|
||
ThoughtSignature string `json:"thoughtSignature,omitempty"`
|
||
ExecutableCode *GeminiExecutableCode `json:"executableCode,omitempty"`
|
||
CodeExecutionResult *GeminiCodeExecutionResult `json:"codeExecutionResult,omitempty"`
|
||
VideoMetadata *GeminiVideoMetadata `json:"videoMetadata,omitempty"`
|
||
}
|
||
|
||
// GeminiInlineData Gemini 内联数据(图片、音频等)
|
||
type GeminiInlineData struct {
|
||
MimeType string `json:"mimeType"`
|
||
Data string `json:"data"`
|
||
}
|
||
|
||
// GeminiFileData Gemini 文件引用数据
|
||
type GeminiFileData struct {
|
||
MimeType string `json:"mimeType,omitempty"`
|
||
FileURI string `json:"fileUri,omitempty"`
|
||
}
|
||
|
||
// GeminiFunctionCall Gemini 函数调用
|
||
type GeminiFunctionCall struct {
|
||
ID string `json:"id,omitempty"`
|
||
FunctionName string `json:"name"`
|
||
Arguments any `json:"args,omitempty"`
|
||
}
|
||
|
||
// GeminiFunctionResponse Gemini 函数响应
|
||
type GeminiFunctionResponse struct {
|
||
ID string `json:"id,omitempty"`
|
||
Name string `json:"name"`
|
||
Response any `json:"response,omitempty"`
|
||
WillContinue bool `json:"willContinue,omitempty"`
|
||
Scheduling string `json:"scheduling,omitempty"`
|
||
}
|
||
|
||
// GeminiExecutableCode Gemini 可执行代码
|
||
type GeminiExecutableCode struct {
|
||
Language string `json:"language"`
|
||
Code string `json:"code"`
|
||
}
|
||
|
||
// GeminiCodeExecutionResult Gemini 代码执行结果
|
||
type GeminiCodeExecutionResult struct {
|
||
Outcome string `json:"outcome"`
|
||
Output string `json:"output"`
|
||
}
|
||
|
||
// GeminiVideoMetadata Gemini 视频元数据
|
||
type GeminiVideoMetadata struct {
|
||
StartOffset string `json:"startOffset,omitempty"`
|
||
EndOffset string `json:"endOffset,omitempty"`
|
||
}
|
||
|
||
// GeminiGenerationConfig Gemini 生成配置
|
||
type GeminiGenerationConfig struct {
|
||
Temperature *float64 `json:"temperature,omitempty"`
|
||
TopP *float64 `json:"topP,omitempty"`
|
||
TopK *float64 `json:"topK,omitempty"`
|
||
MaxOutputTokens *uint `json:"maxOutputTokens,omitempty"`
|
||
CandidateCount *int `json:"candidateCount,omitempty"`
|
||
StopSequences []string `json:"stopSequences,omitempty"`
|
||
ResponseMimeType string `json:"responseMimeType,omitempty"`
|
||
ResponseSchema any `json:"responseSchema,omitempty"`
|
||
ResponseJsonSchema any `json:"responseJsonSchema,omitempty"`
|
||
ResponseModalities []string `json:"responseModalities,omitempty"`
|
||
PresencePenalty *float64 `json:"presencePenalty,omitempty"`
|
||
FrequencyPenalty *float64 `json:"frequencyPenalty,omitempty"`
|
||
Seed *int64 `json:"seed,omitempty"`
|
||
ResponseLogprobs *bool `json:"responseLogprobs,omitempty"`
|
||
Logprobs *int `json:"logprobs,omitempty"`
|
||
ThinkingConfig *GeminiThinkingConfig `json:"thinkingConfig,omitempty"`
|
||
SpeechConfig any `json:"speechConfig,omitempty"`
|
||
MediaResolution string `json:"mediaResolution,omitempty"`
|
||
ImageConfig *GeminiImageConfig `json:"imageConfig,omitempty"`
|
||
}
|
||
|
||
// GeminiImageConfig Banana 内生图配置(用于 Chat 模式的图片生成模型)
|
||
type GeminiImageConfig struct {
|
||
AspectRatio string `json:"aspectRatio,omitempty"`
|
||
ImageSize string `json:"imageSize,omitempty"`
|
||
}
|
||
|
||
// GeminiThinkingConfig Gemini 思考配置
|
||
type GeminiThinkingConfig struct {
|
||
IncludeThoughts bool `json:"includeThoughts"`
|
||
ThinkingBudget *int `json:"thinkingBudget,omitempty"`
|
||
ThinkingLevel string `json:"thinkingLevel,omitempty"`
|
||
}
|
||
|
||
// GeminiSafetySetting Gemini 安全设置
|
||
type GeminiSafetySetting struct {
|
||
Category string `json:"category"`
|
||
Threshold string `json:"threshold"`
|
||
}
|
||
|
||
// GeminiChatResponse Gemini Chat 响应
|
||
type GeminiChatResponse struct {
|
||
Candidates []GeminiCandidate `json:"candidates,omitempty"`
|
||
PromptFeedback *GeminiPromptFeedback `json:"promptFeedback,omitempty"`
|
||
UsageMetadata *GeminiUsageMetadata `json:"usageMetadata,omitempty"`
|
||
ModelName string `json:"modelVersion,omitempty"`
|
||
ResponseID string `json:"responseId,omitempty"`
|
||
}
|
||
|
||
// GeminiCandidate Gemini 候选结果
|
||
type GeminiCandidate struct {
|
||
Content *GeminiContent `json:"content,omitempty"`
|
||
FinishReason string `json:"finishReason,omitempty"`
|
||
FinishMessage string `json:"finishMessage,omitempty"`
|
||
Index int `json:"index,omitempty"`
|
||
SafetyRatings []any `json:"safetyRatings,omitempty"`
|
||
CitationMetadata any `json:"citationMetadata,omitempty"`
|
||
GroundingMetadata any `json:"groundingMetadata,omitempty"`
|
||
TokenCount int `json:"tokenCount,omitempty"`
|
||
AvgLogprobs *float64 `json:"avgLogprobs,omitempty"`
|
||
LogprobsResult any `json:"logprobsResult,omitempty"`
|
||
}
|
||
|
||
// GeminiPromptFeedback Gemini 提示反馈
|
||
type GeminiPromptFeedback struct {
|
||
SafetyRatings []any `json:"safetyRatings,omitempty"`
|
||
BlockReason string `json:"blockReason,omitempty"`
|
||
}
|
||
|
||
// GeminiUsageMetadata Gemini 用量元数据
|
||
type GeminiUsageMetadata struct {
|
||
PromptTokenCount int `json:"promptTokenCount"`
|
||
CandidatesTokenCount int `json:"candidatesTokenCount"`
|
||
TotalTokenCount int `json:"totalTokenCount"`
|
||
CachedContentTokenCount int `json:"cachedContentTokenCount,omitempty"`
|
||
ThoughtsTokenCount int `json:"thoughtsTokenCount,omitempty"`
|
||
ToolUsePromptTokenCount int `json:"toolUsePromptTokenCount,omitempty"`
|
||
PromptTokensDetails []GeminiModalityTokenCount `json:"promptTokensDetails,omitempty"`
|
||
CandidatesTokensDetails []GeminiModalityTokenCount `json:"candidatesTokensDetails,omitempty"`
|
||
ToolUsePromptTokensDetails []GeminiModalityTokenCount `json:"toolUsePromptTokensDetails,omitempty"`
|
||
CacheTokensDetails []GeminiModalityTokenCount `json:"cacheTokensDetails,omitempty"`
|
||
}
|
||
|
||
// GeminiModalityTokenCount 按模态的 Token 计数
|
||
type GeminiModalityTokenCount struct {
|
||
Modality string `json:"modality"`
|
||
TokenCount int `json:"tokenCount"`
|
||
}
|
||
|
||
// GeminiFunctionDeclaration Gemini 函数声明(用于工具定义序列化)
|
||
type GeminiFunctionDeclaration struct {
|
||
Name string `json:"name"`
|
||
Description string `json:"description,omitempty"`
|
||
Parameters any `json:"parameters,omitempty"`
|
||
}
|
||
|
||
// GeminiModel Gemini 模型信息(/v1beta/models 响应)
|
||
type GeminiModel struct {
|
||
Name string `json:"name"`
|
||
BaseModelId string `json:"baseModelId,omitempty"`
|
||
Version string `json:"version,omitempty"`
|
||
DisplayName string `json:"displayName,omitempty"`
|
||
Description string `json:"description,omitempty"`
|
||
InputTokenLimit int `json:"inputTokenLimit,omitempty"`
|
||
OutputTokenLimit int `json:"outputTokenLimit,omitempty"`
|
||
SupportedGenerationMethods []string `json:"supportedGenerationMethods,omitempty"`
|
||
Temperature *float64 `json:"temperature,omitempty"`
|
||
MaxTemperature *float64 `json:"maxTemperature,omitempty"`
|
||
TopP *float64 `json:"topP,omitempty"`
|
||
TopK *int `json:"topK,omitempty"`
|
||
}
|
||
|
||
// GeminiModelsResponse Gemini 模型列表响应
|
||
type GeminiModelsResponse struct {
|
||
Models []GeminiModel `json:"models"`
|
||
NextPageToken string `json:"nextPageToken,omitempty"`
|
||
}
|
||
|
||
// ==================== Gemini Imagen Image API ====================
|
||
|
||
// GeminiImageRequest Imagen 图像生成请求
|
||
type GeminiImageRequest struct {
|
||
Instances []GeminiImageInstance `json:"instances"`
|
||
Parameters GeminiImageParameters `json:"parameters"`
|
||
}
|
||
|
||
// GeminiImageInstance Imagen 图像生成实例
|
||
type GeminiImageInstance struct {
|
||
Prompt string `json:"prompt"`
|
||
}
|
||
|
||
// GeminiImageParameters Imagen 图像生成参数
|
||
type GeminiImageParameters struct {
|
||
SampleCount int `json:"sampleCount,omitempty"`
|
||
AspectRatio string `json:"aspectRatio,omitempty"`
|
||
PersonGeneration string `json:"personGeneration,omitempty"`
|
||
ImageSize string `json:"imageSize,omitempty"`
|
||
}
|
||
|
||
// GeminiImageResponse Imagen 图像生成响应
|
||
type GeminiImageResponse struct {
|
||
Predictions []GeminiImagePrediction `json:"predictions"`
|
||
}
|
||
|
||
// GeminiImagePrediction Imagen 图像生成预测结果
|
||
type GeminiImagePrediction struct {
|
||
MimeType string `json:"mimeType"`
|
||
BytesBase64Encoded string `json:"bytesBase64Encoded"`
|
||
RaiFilteredReason string `json:"raiFilteredReason,omitempty"`
|
||
SafetyAttributes any `json:"safetyAttributes,omitempty"`
|
||
}
|