Method connect

frontend/src/utils/sse-client.ts:114–221

(headers?: Record<string, string>)

  }

  private async connect(headers?: Record<string, string>): Promise<void> {
    if (this.readyState === EventSource.CLOSED) {
      return;
    }

    this.controller = new AbortController();
    this.readyState = FetchEventSource.CONNECTING;

    try {
      const response = await fetch(this.url, {
        method: 'GET',
        headers: {
          Accept: 'text/event-stream',
          // Don't send Cache-Control header - backend sets it on response
          // Including it causes CORS issues
          ...headers,
        },
        signal: this.controller.signal,
        credentials: this.withCredentials ? 'include' : 'same-origin',
      });

      if (!response.ok) {
        throw new Error(`SSE connection failed: ${response.status} ${response.statusText}`);
      }

      if (!response.body) {
        throw new Error('Response body is null');
      }

      this.readyState = FetchEventSource.OPEN;

      // Fire onopen event
      if (this.onopenHandler) {
        this.onopenHandler(new Event('open'));
      }
      this.fireEvent('open', new Event('open'));

      // Read the stream
      this.reader = response.body.getReader();
      const decoder = new TextDecoder();
      let buffer = '';

      while (this.readyState === FetchEventSource.OPEN) {
        const { done, value } = await this.reader.read();

        if (done) {
          break;
        }

        buffer += decoder.decode(value, { stream: true });
        const lines = buffer.split('\n');
        buffer = lines.pop() || ''; // Keep incomplete line in buffer

        let eventType = 'message';
        let eventData = '';
        let eventId = '';

        for (const line of lines) {