Function convertAnthropicMessagesToOpenAI

api/client.go:1124–1225

(messages []map[string]any)

		defer close(results)
		scanner := bufio.NewScanner(body)
		scanner.Buffer(make([]byte, 0, 64*1024), 10*1024*1024)
		for scanner.Scan() {
			line := scanner.Text()
			if !strings.HasPrefix(line, "data:") {
				continue
			}
			dataStr := strings.TrimSpace(line[len("data:"):])
			if dataStr == "" {
				continue
			}
			select {
			case results <- sseScanResult{data: dataStr}:
			case <-scanCtx.Done():
				return
			}
		}
		if err := scanner.Err(); err != nil {
			select {
			case results <- sseScanResult{err: err}:
			case <-scanCtx.Done():
			}
		}
	}()

	timer := time.NewTimer(idleTimeout)
	defer timer.Stop()
	for {
		select {
		case <-ctx.Done():
			_ = body.Close()
			return ctx.Err()
		case item, ok := <-results:
			if !ok {
				return nil
			}
			if !timer.Stop() {
				select {
				case <-timer.C:
				default:
				}
			}
			timer.Reset(idleTimeout)
			if item.err != nil {
				return item.err
			}
			if !handle(item.data) {
				return nil
			}
		case <-timer.C:
			_ = body.Close()
			return StreamIdleTimeoutError{Timeout: idleTimeout}
		}
	}
}

func singleErrorEvent(err error) <-chan EventResult {
	ch := make(chan EventResult, 1)
	ch <- EventResult{Err: err}