()
| 173 | } |
| 174 | |
| 175 | func GetGlobalRateLimit() *uctypes.RateLimitInfo { |
| 176 | rateLimitLock.Lock() |
| 177 | defer rateLimitLock.Unlock() |
| 178 | return globalRateLimitInfo |
| 179 | } |
| 180 | |
| 181 | func runAIChatStep(ctx context.Context, sseHandler *sse.SSEHandlerCh, backend UseChatBackend, chatOpts uctypes.WaveChatOpts, cont *uctypes.WaveContinueResponse) (*uctypes.WaveStopReason, []uctypes.GenAIMessage, error) { |
| 182 | if chatOpts.Config.APIType == uctypes.APIType_OpenAIResponses && shouldUseChatCompletionsAPI(chatOpts.Config.Model) { |
no outgoing calls
no test coverage detected