relay_info.go 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769
  1. package common
  2. import (
  3. "encoding/json"
  4. "errors"
  5. "fmt"
  6. "strings"
  7. "time"
  8. "github.com/QuantumNous/new-api/common"
  9. "github.com/QuantumNous/new-api/constant"
  10. "github.com/QuantumNous/new-api/dto"
  11. relayconstant "github.com/QuantumNous/new-api/relay/constant"
  12. "github.com/QuantumNous/new-api/setting/model_setting"
  13. "github.com/QuantumNous/new-api/types"
  14. "github.com/gin-gonic/gin"
  15. "github.com/gorilla/websocket"
  16. )
  17. type ThinkingContentInfo struct {
  18. IsFirstThinkingContent bool
  19. SendLastThinkingContent bool
  20. HasSentThinkingContent bool
  21. }
  22. const (
  23. LastMessageTypeNone = "none"
  24. LastMessageTypeText = "text"
  25. LastMessageTypeTools = "tools"
  26. LastMessageTypeThinking = "thinking"
  27. )
  28. type ClaudeConvertInfo struct {
  29. LastMessagesType string
  30. Index int
  31. Usage *dto.Usage
  32. FinishReason string
  33. Done bool
  34. }
  35. type RerankerInfo struct {
  36. Documents []any
  37. ReturnDocuments bool
  38. }
  39. type BuildInToolInfo struct {
  40. ToolName string
  41. CallCount int
  42. SearchContextSize string
  43. }
  44. type ResponsesUsageInfo struct {
  45. BuiltInTools map[string]*BuildInToolInfo
  46. }
  47. type ChannelMeta struct {
  48. ChannelType int
  49. ChannelId int
  50. ChannelIsMultiKey bool
  51. ChannelMultiKeyIndex int
  52. ChannelBaseUrl string
  53. ApiType int
  54. ApiVersion string
  55. ApiKey string
  56. Organization string
  57. ChannelCreateTime int64
  58. ParamOverride map[string]interface{}
  59. HeadersOverride map[string]interface{}
  60. ChannelSetting dto.ChannelSettings
  61. ChannelOtherSettings dto.ChannelOtherSettings
  62. UpstreamModelName string
  63. IsModelMapped bool
  64. SupportStreamOptions bool // 是否支持流式选项
  65. }
  66. type TokenCountMeta struct {
  67. //promptTokens int
  68. estimatePromptTokens int
  69. }
  70. type RelayInfo struct {
  71. TokenId int
  72. TokenKey string
  73. TokenGroup string
  74. UserId int
  75. UsingGroup string // 使用的分组,当auto跨分组重试时,会变动
  76. UserGroup string // 用户所在分组
  77. TokenUnlimited bool
  78. StartTime time.Time
  79. FirstResponseTime time.Time
  80. isFirstResponse bool
  81. //SendLastReasoningResponse bool
  82. IsStream bool
  83. IsGeminiBatchEmbedding bool
  84. IsPlayground bool
  85. UsePrice bool
  86. RelayMode int
  87. OriginModelName string
  88. RequestURLPath string
  89. ShouldIncludeUsage bool
  90. DisablePing bool // 是否禁止向下游发送自定义 Ping
  91. ClientWs *websocket.Conn
  92. TargetWs *websocket.Conn
  93. InputAudioFormat string
  94. OutputAudioFormat string
  95. RealtimeTools []dto.RealTimeTool
  96. IsFirstRequest bool
  97. AudioUsage bool
  98. ReasoningEffort string
  99. UserSetting dto.UserSetting
  100. UserEmail string
  101. UserQuota int
  102. RelayFormat types.RelayFormat
  103. SendResponseCount int
  104. ReceivedResponseCount int
  105. FinalPreConsumedQuota int // 最终预消耗的配额
  106. // BillingSource indicates whether this request is billed from wallet quota or subscription.
  107. // "" or "wallet" => wallet; "subscription" => subscription
  108. BillingSource string
  109. // SubscriptionId is the user_subscriptions.id used when BillingSource == "subscription"
  110. SubscriptionId int
  111. // SubscriptionPreConsumed is the amount pre-consumed on subscription item (quota units or 1)
  112. SubscriptionPreConsumed int64
  113. // SubscriptionPostDelta is the post-consume delta applied to amount_used (quota units; can be negative).
  114. SubscriptionPostDelta int64
  115. // SubscriptionPlanId / SubscriptionPlanTitle are used for logging/UI display.
  116. SubscriptionPlanId int
  117. SubscriptionPlanTitle string
  118. // RequestId is used for idempotent pre-consume/refund
  119. RequestId string
  120. // SubscriptionAmountTotal / SubscriptionAmountUsedAfterPreConsume are used to compute remaining in logs.
  121. SubscriptionAmountTotal int64
  122. SubscriptionAmountUsedAfterPreConsume int64
  123. IsClaudeBetaQuery bool // /v1/messages?beta=true
  124. IsChannelTest bool // channel test request
  125. PriceData types.PriceData
  126. Request dto.Request
  127. // RequestConversionChain records request format conversions in order, e.g.
  128. // ["openai", "openai_responses"] or ["openai", "claude"].
  129. RequestConversionChain []types.RelayFormat
  130. ThinkingContentInfo
  131. TokenCountMeta
  132. *ClaudeConvertInfo
  133. *RerankerInfo
  134. *ResponsesUsageInfo
  135. *ChannelMeta
  136. *TaskRelayInfo
  137. }
  138. func (info *RelayInfo) InitChannelMeta(c *gin.Context) {
  139. channelType := common.GetContextKeyInt(c, constant.ContextKeyChannelType)
  140. paramOverride := common.GetContextKeyStringMap(c, constant.ContextKeyChannelParamOverride)
  141. headerOverride := common.GetContextKeyStringMap(c, constant.ContextKeyChannelHeaderOverride)
  142. apiType, _ := common.ChannelType2APIType(channelType)
  143. channelMeta := &ChannelMeta{
  144. ChannelType: channelType,
  145. ChannelId: common.GetContextKeyInt(c, constant.ContextKeyChannelId),
  146. ChannelIsMultiKey: common.GetContextKeyBool(c, constant.ContextKeyChannelIsMultiKey),
  147. ChannelMultiKeyIndex: common.GetContextKeyInt(c, constant.ContextKeyChannelMultiKeyIndex),
  148. ChannelBaseUrl: common.GetContextKeyString(c, constant.ContextKeyChannelBaseUrl),
  149. ApiType: apiType,
  150. ApiVersion: c.GetString("api_version"),
  151. ApiKey: common.GetContextKeyString(c, constant.ContextKeyChannelKey),
  152. Organization: c.GetString("channel_organization"),
  153. ChannelCreateTime: c.GetInt64("channel_create_time"),
  154. ParamOverride: paramOverride,
  155. HeadersOverride: headerOverride,
  156. UpstreamModelName: common.GetContextKeyString(c, constant.ContextKeyOriginalModel),
  157. IsModelMapped: false,
  158. SupportStreamOptions: false,
  159. }
  160. if channelType == constant.ChannelTypeAzure {
  161. channelMeta.ApiVersion = GetAPIVersion(c)
  162. }
  163. if channelType == constant.ChannelTypeVertexAi {
  164. channelMeta.ApiVersion = c.GetString("region")
  165. }
  166. channelSetting, ok := common.GetContextKeyType[dto.ChannelSettings](c, constant.ContextKeyChannelSetting)
  167. if ok {
  168. channelMeta.ChannelSetting = channelSetting
  169. }
  170. channelOtherSettings, ok := common.GetContextKeyType[dto.ChannelOtherSettings](c, constant.ContextKeyChannelOtherSetting)
  171. if ok {
  172. channelMeta.ChannelOtherSettings = channelOtherSettings
  173. }
  174. if streamSupportedChannels[channelMeta.ChannelType] {
  175. channelMeta.SupportStreamOptions = true
  176. }
  177. info.ChannelMeta = channelMeta
  178. // reset some fields based on channel meta
  179. // 重置某些字段,例如模型名称等
  180. if info.Request != nil {
  181. info.Request.SetModelName(info.OriginModelName)
  182. }
  183. }
  184. func (info *RelayInfo) ToString() string {
  185. if info == nil {
  186. return "RelayInfo<nil>"
  187. }
  188. // Basic info
  189. b := &strings.Builder{}
  190. fmt.Fprintf(b, "RelayInfo{ ")
  191. fmt.Fprintf(b, "RelayFormat: %s, ", info.RelayFormat)
  192. fmt.Fprintf(b, "RelayMode: %d, ", info.RelayMode)
  193. fmt.Fprintf(b, "IsStream: %t, ", info.IsStream)
  194. fmt.Fprintf(b, "IsPlayground: %t, ", info.IsPlayground)
  195. fmt.Fprintf(b, "RequestURLPath: %q, ", info.RequestURLPath)
  196. fmt.Fprintf(b, "OriginModelName: %q, ", info.OriginModelName)
  197. fmt.Fprintf(b, "EstimatePromptTokens: %d, ", info.estimatePromptTokens)
  198. fmt.Fprintf(b, "ShouldIncludeUsage: %t, ", info.ShouldIncludeUsage)
  199. fmt.Fprintf(b, "DisablePing: %t, ", info.DisablePing)
  200. fmt.Fprintf(b, "SendResponseCount: %d, ", info.SendResponseCount)
  201. fmt.Fprintf(b, "FinalPreConsumedQuota: %d, ", info.FinalPreConsumedQuota)
  202. // User & token info (mask secrets)
  203. fmt.Fprintf(b, "User{ Id: %d, Email: %q, Group: %q, UsingGroup: %q, Quota: %d }, ",
  204. info.UserId, common.MaskEmail(info.UserEmail), info.UserGroup, info.UsingGroup, info.UserQuota)
  205. fmt.Fprintf(b, "Token{ Id: %d, Unlimited: %t, Key: ***masked*** }, ", info.TokenId, info.TokenUnlimited)
  206. // Time info
  207. latencyMs := info.FirstResponseTime.Sub(info.StartTime).Milliseconds()
  208. fmt.Fprintf(b, "Timing{ Start: %s, FirstResponse: %s, LatencyMs: %d }, ",
  209. info.StartTime.Format(time.RFC3339Nano), info.FirstResponseTime.Format(time.RFC3339Nano), latencyMs)
  210. // Audio / realtime
  211. if info.InputAudioFormat != "" || info.OutputAudioFormat != "" || len(info.RealtimeTools) > 0 || info.AudioUsage {
  212. fmt.Fprintf(b, "Realtime{ AudioUsage: %t, InFmt: %q, OutFmt: %q, Tools: %d }, ",
  213. info.AudioUsage, info.InputAudioFormat, info.OutputAudioFormat, len(info.RealtimeTools))
  214. }
  215. // Reasoning
  216. if info.ReasoningEffort != "" {
  217. fmt.Fprintf(b, "ReasoningEffort: %q, ", info.ReasoningEffort)
  218. }
  219. // Price data (non-sensitive)
  220. if info.PriceData.UsePrice {
  221. fmt.Fprintf(b, "PriceData{ %s }, ", info.PriceData.ToSetting())
  222. }
  223. // Channel metadata (mask ApiKey)
  224. if info.ChannelMeta != nil {
  225. cm := info.ChannelMeta
  226. fmt.Fprintf(b, "ChannelMeta{ Type: %d, Id: %d, IsMultiKey: %t, MultiKeyIndex: %d, BaseURL: %q, ApiType: %d, ApiVersion: %q, Organization: %q, CreateTime: %d, UpstreamModelName: %q, IsModelMapped: %t, SupportStreamOptions: %t, ApiKey: ***masked*** }, ",
  227. cm.ChannelType, cm.ChannelId, cm.ChannelIsMultiKey, cm.ChannelMultiKeyIndex, cm.ChannelBaseUrl, cm.ApiType, cm.ApiVersion, cm.Organization, cm.ChannelCreateTime, cm.UpstreamModelName, cm.IsModelMapped, cm.SupportStreamOptions)
  228. }
  229. // Responses usage info (non-sensitive)
  230. if info.ResponsesUsageInfo != nil && len(info.ResponsesUsageInfo.BuiltInTools) > 0 {
  231. fmt.Fprintf(b, "ResponsesTools{ ")
  232. first := true
  233. for name, tool := range info.ResponsesUsageInfo.BuiltInTools {
  234. if !first {
  235. fmt.Fprintf(b, ", ")
  236. }
  237. first = false
  238. if tool != nil {
  239. fmt.Fprintf(b, "%s: calls=%d", name, tool.CallCount)
  240. } else {
  241. fmt.Fprintf(b, "%s: calls=0", name)
  242. }
  243. }
  244. fmt.Fprintf(b, " }, ")
  245. }
  246. fmt.Fprintf(b, "}")
  247. return b.String()
  248. }
  249. // 定义支持流式选项的通道类型
  250. var streamSupportedChannels = map[int]bool{
  251. constant.ChannelTypeOpenAI: true,
  252. constant.ChannelTypeAnthropic: true,
  253. constant.ChannelTypeAws: true,
  254. constant.ChannelTypeGemini: true,
  255. constant.ChannelCloudflare: true,
  256. constant.ChannelTypeAzure: true,
  257. constant.ChannelTypeVolcEngine: true,
  258. constant.ChannelTypeOllama: true,
  259. constant.ChannelTypeXai: true,
  260. constant.ChannelTypeDeepSeek: true,
  261. constant.ChannelTypeBaiduV2: true,
  262. constant.ChannelTypeZhipu_v4: true,
  263. constant.ChannelTypeAli: true,
  264. constant.ChannelTypeSubmodel: true,
  265. constant.ChannelTypeCodex: true,
  266. }
  267. func GenRelayInfoWs(c *gin.Context, ws *websocket.Conn) *RelayInfo {
  268. info := genBaseRelayInfo(c, nil)
  269. info.RelayFormat = types.RelayFormatOpenAIRealtime
  270. info.ClientWs = ws
  271. info.InputAudioFormat = "pcm16"
  272. info.OutputAudioFormat = "pcm16"
  273. info.IsFirstRequest = true
  274. return info
  275. }
  276. func GenRelayInfoClaude(c *gin.Context, request dto.Request) *RelayInfo {
  277. info := genBaseRelayInfo(c, request)
  278. info.RelayFormat = types.RelayFormatClaude
  279. info.ShouldIncludeUsage = false
  280. info.ClaudeConvertInfo = &ClaudeConvertInfo{
  281. LastMessagesType: LastMessageTypeNone,
  282. }
  283. if c.Query("beta") == "true" {
  284. info.IsClaudeBetaQuery = true
  285. }
  286. return info
  287. }
  288. func GenRelayInfoRerank(c *gin.Context, request *dto.RerankRequest) *RelayInfo {
  289. info := genBaseRelayInfo(c, request)
  290. info.RelayMode = relayconstant.RelayModeRerank
  291. info.RelayFormat = types.RelayFormatRerank
  292. info.RerankerInfo = &RerankerInfo{
  293. Documents: request.Documents,
  294. ReturnDocuments: request.GetReturnDocuments(),
  295. }
  296. return info
  297. }
  298. func GenRelayInfoOpenAIAudio(c *gin.Context, request dto.Request) *RelayInfo {
  299. info := genBaseRelayInfo(c, request)
  300. info.RelayFormat = types.RelayFormatOpenAIAudio
  301. return info
  302. }
  303. func GenRelayInfoEmbedding(c *gin.Context, request dto.Request) *RelayInfo {
  304. info := genBaseRelayInfo(c, request)
  305. info.RelayFormat = types.RelayFormatEmbedding
  306. return info
  307. }
  308. func GenRelayInfoResponses(c *gin.Context, request *dto.OpenAIResponsesRequest) *RelayInfo {
  309. info := genBaseRelayInfo(c, request)
  310. info.RelayMode = relayconstant.RelayModeResponses
  311. info.RelayFormat = types.RelayFormatOpenAIResponses
  312. info.ResponsesUsageInfo = &ResponsesUsageInfo{
  313. BuiltInTools: make(map[string]*BuildInToolInfo),
  314. }
  315. if len(request.Tools) > 0 {
  316. for _, tool := range request.GetToolsMap() {
  317. toolType := common.Interface2String(tool["type"])
  318. info.ResponsesUsageInfo.BuiltInTools[toolType] = &BuildInToolInfo{
  319. ToolName: toolType,
  320. CallCount: 0,
  321. }
  322. switch toolType {
  323. case dto.BuildInToolWebSearchPreview:
  324. searchContextSize := common.Interface2String(tool["search_context_size"])
  325. if searchContextSize == "" {
  326. searchContextSize = "medium"
  327. }
  328. info.ResponsesUsageInfo.BuiltInTools[toolType].SearchContextSize = searchContextSize
  329. }
  330. }
  331. }
  332. return info
  333. }
  334. func GenRelayInfoGemini(c *gin.Context, request dto.Request) *RelayInfo {
  335. info := genBaseRelayInfo(c, request)
  336. info.RelayFormat = types.RelayFormatGemini
  337. info.ShouldIncludeUsage = false
  338. return info
  339. }
  340. func GenRelayInfoImage(c *gin.Context, request dto.Request) *RelayInfo {
  341. info := genBaseRelayInfo(c, request)
  342. info.RelayFormat = types.RelayFormatOpenAIImage
  343. return info
  344. }
  345. func GenRelayInfoOpenAI(c *gin.Context, request dto.Request) *RelayInfo {
  346. info := genBaseRelayInfo(c, request)
  347. info.RelayFormat = types.RelayFormatOpenAI
  348. return info
  349. }
  350. func genBaseRelayInfo(c *gin.Context, request dto.Request) *RelayInfo {
  351. //channelType := common.GetContextKeyInt(c, constant.ContextKeyChannelType)
  352. //channelId := common.GetContextKeyInt(c, constant.ContextKeyChannelId)
  353. //paramOverride := common.GetContextKeyStringMap(c, constant.ContextKeyChannelParamOverride)
  354. tokenGroup := common.GetContextKeyString(c, constant.ContextKeyTokenGroup)
  355. // 当令牌分组为空时,表示使用用户分组
  356. if tokenGroup == "" {
  357. tokenGroup = common.GetContextKeyString(c, constant.ContextKeyUserGroup)
  358. }
  359. startTime := common.GetContextKeyTime(c, constant.ContextKeyRequestStartTime)
  360. if startTime.IsZero() {
  361. startTime = time.Now()
  362. }
  363. isStream := false
  364. if request != nil {
  365. isStream = request.IsStream(c)
  366. }
  367. // firstResponseTime = time.Now() - 1 second
  368. reqId := common.GetContextKeyString(c, common.RequestIdKey)
  369. if reqId == "" {
  370. reqId = common.GetTimeString() + common.GetRandomString(8)
  371. }
  372. info := &RelayInfo{
  373. Request: request,
  374. RequestId: reqId,
  375. UserId: common.GetContextKeyInt(c, constant.ContextKeyUserId),
  376. UsingGroup: common.GetContextKeyString(c, constant.ContextKeyUsingGroup),
  377. UserGroup: common.GetContextKeyString(c, constant.ContextKeyUserGroup),
  378. UserQuota: common.GetContextKeyInt(c, constant.ContextKeyUserQuota),
  379. UserEmail: common.GetContextKeyString(c, constant.ContextKeyUserEmail),
  380. OriginModelName: common.GetContextKeyString(c, constant.ContextKeyOriginalModel),
  381. TokenId: common.GetContextKeyInt(c, constant.ContextKeyTokenId),
  382. TokenKey: common.GetContextKeyString(c, constant.ContextKeyTokenKey),
  383. TokenUnlimited: common.GetContextKeyBool(c, constant.ContextKeyTokenUnlimited),
  384. TokenGroup: tokenGroup,
  385. isFirstResponse: true,
  386. RelayMode: relayconstant.Path2RelayMode(c.Request.URL.Path),
  387. RequestURLPath: c.Request.URL.String(),
  388. IsStream: isStream,
  389. StartTime: startTime,
  390. FirstResponseTime: startTime.Add(-time.Second),
  391. ThinkingContentInfo: ThinkingContentInfo{
  392. IsFirstThinkingContent: true,
  393. SendLastThinkingContent: false,
  394. },
  395. TokenCountMeta: TokenCountMeta{
  396. //promptTokens: common.GetContextKeyInt(c, constant.ContextKeyPromptTokens),
  397. estimatePromptTokens: common.GetContextKeyInt(c, constant.ContextKeyEstimatedTokens),
  398. },
  399. }
  400. if info.RelayMode == relayconstant.RelayModeUnknown {
  401. info.RelayMode = c.GetInt("relay_mode")
  402. }
  403. if strings.HasPrefix(c.Request.URL.Path, "/pg") {
  404. info.IsPlayground = true
  405. info.RequestURLPath = strings.TrimPrefix(info.RequestURLPath, "/pg")
  406. info.RequestURLPath = "/v1" + info.RequestURLPath
  407. }
  408. userSetting, ok := common.GetContextKeyType[dto.UserSetting](c, constant.ContextKeyUserSetting)
  409. if ok {
  410. info.UserSetting = userSetting
  411. }
  412. return info
  413. }
  414. func GenRelayInfo(c *gin.Context, relayFormat types.RelayFormat, request dto.Request, ws *websocket.Conn) (*RelayInfo, error) {
  415. var info *RelayInfo
  416. var err error
  417. switch relayFormat {
  418. case types.RelayFormatOpenAI:
  419. info = GenRelayInfoOpenAI(c, request)
  420. case types.RelayFormatOpenAIAudio:
  421. info = GenRelayInfoOpenAIAudio(c, request)
  422. case types.RelayFormatOpenAIImage:
  423. info = GenRelayInfoImage(c, request)
  424. case types.RelayFormatOpenAIRealtime:
  425. info = GenRelayInfoWs(c, ws)
  426. case types.RelayFormatClaude:
  427. info = GenRelayInfoClaude(c, request)
  428. case types.RelayFormatRerank:
  429. if request, ok := request.(*dto.RerankRequest); ok {
  430. info = GenRelayInfoRerank(c, request)
  431. break
  432. }
  433. err = errors.New("request is not a RerankRequest")
  434. case types.RelayFormatGemini:
  435. info = GenRelayInfoGemini(c, request)
  436. case types.RelayFormatEmbedding:
  437. info = GenRelayInfoEmbedding(c, request)
  438. case types.RelayFormatOpenAIResponses:
  439. if request, ok := request.(*dto.OpenAIResponsesRequest); ok {
  440. info = GenRelayInfoResponses(c, request)
  441. break
  442. }
  443. err = errors.New("request is not a OpenAIResponsesRequest")
  444. case types.RelayFormatOpenAIResponsesCompaction:
  445. if request, ok := request.(*dto.OpenAIResponsesCompactionRequest); ok {
  446. return GenRelayInfoResponsesCompaction(c, request), nil
  447. }
  448. return nil, errors.New("request is not a OpenAIResponsesCompactionRequest")
  449. case types.RelayFormatTask:
  450. info = genBaseRelayInfo(c, nil)
  451. case types.RelayFormatMjProxy:
  452. info = genBaseRelayInfo(c, nil)
  453. default:
  454. err = errors.New("invalid relay format")
  455. }
  456. if err != nil {
  457. return nil, err
  458. }
  459. if info == nil {
  460. return nil, errors.New("failed to build relay info")
  461. }
  462. info.InitRequestConversionChain()
  463. return info, nil
  464. }
  465. func (info *RelayInfo) InitRequestConversionChain() {
  466. if info == nil {
  467. return
  468. }
  469. if len(info.RequestConversionChain) > 0 {
  470. return
  471. }
  472. if info.RelayFormat == "" {
  473. return
  474. }
  475. info.RequestConversionChain = []types.RelayFormat{info.RelayFormat}
  476. }
  477. func (info *RelayInfo) AppendRequestConversion(format types.RelayFormat) {
  478. if info == nil {
  479. return
  480. }
  481. if format == "" {
  482. return
  483. }
  484. if len(info.RequestConversionChain) == 0 {
  485. info.RequestConversionChain = []types.RelayFormat{format}
  486. return
  487. }
  488. last := info.RequestConversionChain[len(info.RequestConversionChain)-1]
  489. if last == format {
  490. return
  491. }
  492. info.RequestConversionChain = append(info.RequestConversionChain, format)
  493. }
  494. func GenRelayInfoResponsesCompaction(c *gin.Context, request *dto.OpenAIResponsesCompactionRequest) *RelayInfo {
  495. info := genBaseRelayInfo(c, request)
  496. if info.RelayMode == relayconstant.RelayModeUnknown {
  497. info.RelayMode = relayconstant.RelayModeResponsesCompact
  498. }
  499. info.RelayFormat = types.RelayFormatOpenAIResponsesCompaction
  500. return info
  501. }
  502. //func (info *RelayInfo) SetPromptTokens(promptTokens int) {
  503. // info.promptTokens = promptTokens
  504. //}
  505. func (info *RelayInfo) SetEstimatePromptTokens(promptTokens int) {
  506. info.estimatePromptTokens = promptTokens
  507. }
  508. func (info *RelayInfo) GetEstimatePromptTokens() int {
  509. return info.estimatePromptTokens
  510. }
  511. func (info *RelayInfo) SetFirstResponseTime() {
  512. if info.isFirstResponse {
  513. info.FirstResponseTime = time.Now()
  514. info.isFirstResponse = false
  515. }
  516. }
  517. func (info *RelayInfo) HasSendResponse() bool {
  518. return info.FirstResponseTime.After(info.StartTime)
  519. }
  520. type TaskRelayInfo struct {
  521. Action string
  522. OriginTaskID string
  523. ConsumeQuota bool
  524. }
  525. type TaskSubmitReq struct {
  526. Prompt string `json:"prompt"`
  527. Model string `json:"model,omitempty"`
  528. Mode string `json:"mode,omitempty"`
  529. Image string `json:"image,omitempty"`
  530. Images []string `json:"images,omitempty"`
  531. Size string `json:"size,omitempty"`
  532. Duration int `json:"duration,omitempty"`
  533. Seconds string `json:"seconds,omitempty"`
  534. InputReference string `json:"input_reference,omitempty"`
  535. Metadata map[string]interface{} `json:"metadata,omitempty"`
  536. }
  537. func (t *TaskSubmitReq) GetPrompt() string {
  538. return t.Prompt
  539. }
  540. func (t *TaskSubmitReq) HasImage() bool {
  541. return len(t.Images) > 0
  542. }
  543. func (t *TaskSubmitReq) UnmarshalJSON(data []byte) error {
  544. type Alias TaskSubmitReq
  545. aux := &struct {
  546. Metadata json.RawMessage `json:"metadata,omitempty"`
  547. *Alias
  548. }{
  549. Alias: (*Alias)(t),
  550. }
  551. if err := common.Unmarshal(data, &aux); err != nil {
  552. return err
  553. }
  554. if len(aux.Metadata) > 0 {
  555. var metadataStr string
  556. if err := common.Unmarshal(aux.Metadata, &metadataStr); err == nil && metadataStr != "" {
  557. var metadataObj map[string]interface{}
  558. if err := common.Unmarshal([]byte(metadataStr), &metadataObj); err == nil {
  559. t.Metadata = metadataObj
  560. return nil
  561. }
  562. }
  563. var metadataObj map[string]interface{}
  564. if err := common.Unmarshal(aux.Metadata, &metadataObj); err == nil {
  565. t.Metadata = metadataObj
  566. }
  567. }
  568. return nil
  569. }
  570. func (t *TaskSubmitReq) UnmarshalMetadata(v any) error {
  571. metadata := t.Metadata
  572. if metadata != nil {
  573. metadataBytes, err := json.Marshal(metadata)
  574. if err != nil {
  575. return fmt.Errorf("marshal metadata failed: %w", err)
  576. }
  577. err = json.Unmarshal(metadataBytes, v)
  578. if err != nil {
  579. return fmt.Errorf("unmarshal metadata to target failed: %w", err)
  580. }
  581. }
  582. return nil
  583. }
  584. type TaskInfo struct {
  585. Code int `json:"code"`
  586. TaskID string `json:"task_id"`
  587. Status string `json:"status"`
  588. Reason string `json:"reason,omitempty"`
  589. Url string `json:"url,omitempty"`
  590. RemoteUrl string `json:"remote_url,omitempty"`
  591. Progress string `json:"progress,omitempty"`
  592. CompletionTokens int `json:"completion_tokens,omitempty"` // 用于按倍率计费
  593. TotalTokens int `json:"total_tokens,omitempty"` // 用于按倍率计费
  594. }
  595. func FailTaskInfo(reason string) *TaskInfo {
  596. return &TaskInfo{
  597. Status: "FAILURE",
  598. Reason: reason,
  599. }
  600. }
  601. // RemoveDisabledFields 从请求 JSON 数据中移除渠道设置中禁用的字段
  602. // service_tier: 服务层级字段,可能导致额外计费(OpenAI、Claude、Responses API 支持)
  603. // store: 数据存储授权字段,涉及用户隐私(仅 OpenAI、Responses API 支持,默认允许透传,禁用后可能导致 Codex 无法使用)
  604. // safety_identifier: 安全标识符,用于向 OpenAI 报告违规用户(仅 OpenAI 支持,涉及用户隐私)
  605. func RemoveDisabledFields(jsonData []byte, channelOtherSettings dto.ChannelOtherSettings) ([]byte, error) {
  606. var data map[string]interface{}
  607. if err := common.Unmarshal(jsonData, &data); err != nil {
  608. common.SysError("RemoveDisabledFields Unmarshal error :" + err.Error())
  609. return jsonData, nil
  610. }
  611. // 默认移除 service_tier,除非明确允许(避免额外计费风险)
  612. if !channelOtherSettings.AllowServiceTier {
  613. if _, exists := data["service_tier"]; exists {
  614. delete(data, "service_tier")
  615. }
  616. }
  617. // 默认允许 store 透传,除非明确禁用(禁用可能影响 Codex 使用)
  618. if channelOtherSettings.DisableStore {
  619. if _, exists := data["store"]; exists {
  620. delete(data, "store")
  621. }
  622. }
  623. // 默认移除 safety_identifier,除非明确允许(保护用户隐私,避免向 OpenAI 报告用户信息)
  624. if !channelOtherSettings.AllowSafetyIdentifier {
  625. if _, exists := data["safety_identifier"]; exists {
  626. delete(data, "safety_identifier")
  627. }
  628. }
  629. jsonDataAfter, err := common.Marshal(data)
  630. if err != nil {
  631. common.SysError("RemoveDisabledFields Marshal error :" + err.Error())
  632. return jsonData, nil
  633. }
  634. return jsonDataAfter, nil
  635. }
  636. // RemoveGeminiDisabledFields removes disabled fields from Gemini request JSON data
  637. // Currently supports removing functionResponse.id field which Vertex AI does not support
  638. func RemoveGeminiDisabledFields(jsonData []byte) ([]byte, error) {
  639. if !model_setting.GetGeminiSettings().RemoveFunctionResponseIdEnabled {
  640. return jsonData, nil
  641. }
  642. var data map[string]interface{}
  643. if err := common.Unmarshal(jsonData, &data); err != nil {
  644. common.SysError("RemoveGeminiDisabledFields Unmarshal error: " + err.Error())
  645. return jsonData, nil
  646. }
  647. // Process contents array
  648. // Handle both camelCase (functionResponse) and snake_case (function_response)
  649. if contents, ok := data["contents"].([]interface{}); ok {
  650. for _, content := range contents {
  651. if contentMap, ok := content.(map[string]interface{}); ok {
  652. if parts, ok := contentMap["parts"].([]interface{}); ok {
  653. for _, part := range parts {
  654. if partMap, ok := part.(map[string]interface{}); ok {
  655. // Check functionResponse (camelCase)
  656. if funcResp, ok := partMap["functionResponse"].(map[string]interface{}); ok {
  657. delete(funcResp, "id")
  658. }
  659. // Check function_response (snake_case)
  660. if funcResp, ok := partMap["function_response"].(map[string]interface{}); ok {
  661. delete(funcResp, "id")
  662. }
  663. }
  664. }
  665. }
  666. }
  667. }
  668. }
  669. jsonDataAfter, err := common.Marshal(data)
  670. if err != nil {
  671. common.SysError("RemoveGeminiDisabledFields Marshal error: " + err.Error())
  672. return jsonData, nil
  673. }
  674. return jsonDataAfter, nil
  675. }