Method readSSEStream

model/opencode.go:238–400

(ctx context.Context, sessionID string, question string, writer io.Writer, flusher http.Flusher, ready chan<- struct{})

}

func (p *OpenCodeProvider) readSSEStream(ctx context.Context, sessionID string, question string, writer io.Writer, flusher http.Flusher, ready chan<- struct{}) (*ModelResult, error) {
	// OpenCode only exposes global SSE endpoints (/event and /global/event).
	// There is no session-scoped SSE endpoint, so we filter by sessionID
	// client-side. This is the intended design — events include a sessionID
	// field for this purpose.
	req, err := http.NewRequest("GET", p.serverUrl+"/event", nil)
	if err != nil {
		return nil, err
	}

	p.setAuth(req)
	req.Header.Set("Accept", "text/event-stream")
	req.Header.Set("Cache-Control", "no-cache")

	sseCtx, cancel := context.WithTimeout(ctx, 1200*time.Second)
	defer cancel()
	req = req.WithContext(sseCtx)

	resp, err := p.client.Do(req)
	if err != nil {
		close(ready) // unblock caller even on failure
		return nil, fmt.Errorf("OpenCode: failed to connect to SSE stream: %v", err)
	}
	defer resp.Body.Close()

	// Signal caller that SSE connection is established
	close(ready)

	if resp.StatusCode != http.StatusOK {
		body, _ := io.ReadAll(resp.Body)
		return nil, fmt.Errorf("OpenCode: SSE HTTP %d: %s", resp.StatusCode, string(body))
	}

	var fullText strings.Builder
	var promptTokens, completionTokens int
	done := false
	partTypes := make(map[string]string) // partID -> type ("reasoning" or "text")

	scanner := bufio.NewScanner(resp.Body)
	scanner.Buffer(make([]byte, 0, 64*1024), 1024*1024)

	for scanner.Scan() {
		line := scanner.Text()

		if !strings.HasPrefix(line, "data: ") {
			continue
		}

		data := strings.TrimPrefix(line, "data: ")
		if data == "" || data == "[DONE]" {
			continue
		}

		event := p.parseSSEEvent(data)

		if event.Properties == nil {
			continue
		}