Method publish

lib/services/stream.ts:58–85

* Send event to all clients of a project

(projectId: string, event: RealtimeEvent)

   * Send event to all clients of a project
   */
  public publish(projectId: string, event: RealtimeEvent): void {
    websocketManager.broadcast(projectId, event);

    const projectStreams = this.streams.get(projectId);
    if (!projectStreams || projectStreams.size === 0) {
      return;
    }
    const message = `data: ${JSON.stringify(event)}\n\n`;
    const encoder = new TextEncoder();
    const encodedMessage = encoder.encode(message);

    const deadControllers: ReadableStreamDefaultController[] = [];

    projectStreams.forEach((controller) => {
      try {
        controller.enqueue(encodedMessage);
      } catch (error) {
        console.error(`[StreamManager] Failed to send message:`, error);
        // Mark for removal after iteration
        deadControllers.push(controller);
      }
    });

    // Remove dead connections after iteration
    deadControllers.forEach((controller) => {
      this.removeStream(projectId, controller);
    });
  }

  /**
   * Return number of connected streams for a project