@@ -319,6 +319,10 @@ func (o *openaiClient) stream(ctx context.Context, messages []message.Message, t
319319 go func() {
320320 for {
321321 attempts++
322+ // Kujtim: fixes an issue with anthropig models on openrouter
323+ if len(params.Tools) == 0 {
324+ params.Tools = nil
325+ }
322326 openaiStream := o.client.Chat.Completions.NewStreaming(
323327 ctx,
324328 params,
@@ -484,31 +488,41 @@ func (o *openaiClient) stream(ctx context.Context, messages []message.Message, t
484488}
485489
486490func (o *openaiClient) shouldRetry(attempts int, err error) (bool, int64, error) {
487− var apiErr *openai.Error
488− if !errors.As(err, &apiErr) {
489− return false, 0, err
490− }
491−
492491 if attempts > maxRetries {
493492 return false, 0, fmt.Errorf("maximum retry attempts reached for rate limit: %d retries", maxRetries)
494493 }
494+ if errors.Is(err, context.Canceled) || errors.Is(err, context.DeadlineExceeded) {
495+ return false, 0, err
496+ }
497+ var apiErr *openai.Error
498+ retryMs := 0
499+ retryAfterValues := []string{}
500+ if errors.As(err, &apiErr) {
501+ // Check for token expiration (401 Unauthorized)
502+ if apiErr.StatusCode == 401 {
503+ o.providerOptions.apiKey, err = config.Get().Resolve(o.providerOptions.config.APIKey)
504+ if err != nil {
505+ return false, 0, fmt.Errorf("failed to resolve API key: %w", err)
506+ }
507+ o.client = createOpenAIClient(o.providerOptions)
508+ return true, 0, nil
509+ }
495510
496− // Check for token expiration (401 Unauthorized)
497− if apiErr.StatusCode == 401 {
498− o.providerOptions.apiKey, err = config.Get().Resolve(o.providerOptions.config.APIKey)
499− if err != nil {
500− return false, 0, fmt.Errorf("failed to resolve API key: %w", err)
511+ if apiErr.StatusCode != 429 && apiErr.StatusCode != 500 {
512+ return false, 0, err
501513 }
502− o.client = createOpenAIClient(o.providerOptions)
503− return true, 0, nil
504− }
505514
506− if apiErr.StatusCode != 429 && apiErr.StatusCode != 500 {
507− return false, 0, err
515+ retryAfterValues = apiErr.Response.Header.Values("Retry-After")
508516 }
509517
510− retryMs := 0
511− retryAfterValues := apiErr.Response.Header.Values("Retry-After")
518+ if apiErr != nil {
519+ slog.Warn("OpenAI API error", "status_code", apiErr.StatusCode, "message", apiErr.Message, "type", apiErr.Type)
520+ if len(retryAfterValues) > 0 {
521+ slog.Warn("Retry-After header", "values", retryAfterValues)
522+ }
523+ } else {
524+ slog.Warn("OpenAI API error", "error", err.Error())
525+ }
512526
513527 backoffMs := 2000 * (1 << (attempts - 1))
514528 jitterMs := int(float64(backoffMs) * 0.2)