Method getOrCreateSubscriber

app/src/utils/streamManager.ts:171–190

* Get or create a subscriber for an agent and stream type. * The subscriber accumulates transcripts independently for each agent.

(agentId: string, type: AudioStreamType)

   * The subscriber accumulates transcripts independently for each agent.
   */
  public getOrCreateSubscriber(agentId: string, type: AudioStreamType): TranscriptionSubscriber {
    const key = this.subscriberKey(agentId, type);

    if (!this.subscribers.has(key)) {
      const subscriber = new TranscriptionSubscriberImpl(agentId, type);
      this.subscribers.set(key, subscriber);

      // Register with transcription service to receive pushes
      const router = TranscriptionRouter.getInstance();
      const service = router.getActiveService(type);
      if (service) {
        service.addSubscriber(subscriber);
        Logger.debug("StreamManager", `Registered subscriber ${key} with transcription service for ${type}`);
      } else {
        Logger.warn("StreamManager", `No transcription service found for ${type} when creating subscriber ${key}`);
      }
    }

    return this.subscribers.get(key)!;
  }

  /**
   * Get an existing subscriber for an agent and stream type.