Method requestStreamsForAgent

app/src/utils/streamManager.ts:96–145

The primary method for acquiring streams, using a "blueprint" approach.

(agentId: string, requiredStreams: PseudoStreamType[])

  
  /** The primary method for acquiring streams, using a "blueprint" approach. */
  public async requestStreamsForAgent(agentId: string, requiredStreams: PseudoStreamType[]): Promise<void> {
    Logger.debug("StreamManager", `Processing stream blueprint for agent '${agentId}': [${requiredStreams.join(', ')}]`);

    // Get the appropriate capture implementation based on platform
    const captureImpl = isWeb() ? browserStreamCapture : tauriStreamCapture;

    // Let the platform-specific implementation map pseudo streams to master streams
    const requiredMasterStreams = new Set<MasterStreamType>();
    for (const type of requiredStreams) {
      const masterStreams = captureImpl.getMasterStreamsForPseudoStream(type);
      masterStreams.forEach(ms => requiredMasterStreams.add(ms));
    }

    const acquisitionPromises: Promise<void>[] = [];
    requiredMasterStreams.forEach(masterType => acquisitionPromises.push(this.ensureMasterStream(masterType, captureImpl)));

    try {
      await Promise.all(acquisitionPromises);

      for (const type of requiredStreams) {
        if (!this.isPseudoStreamAvailable(type)) {
          throw new Error(`Failed to acquire required stream component '${type}'. Permission may have been denied.`);
        }
      }

      // --- Centralized Transcription & Mixer Logic ---
      // Start transcription services and auto-subscribe the agent to each stream type.
      // This ensures the agent receives all transcribed text from the moment streams are acquired.
      if (requiredStreams.includes('allAudio')) {
        await this.initializeAudioMixer();
      }
      if (requiredStreams.includes('microphone') && this.microphoneStream) {
        await this.startTranscriptionForStream('microphone', this.microphoneStream);
        this.getOrCreateSubscriber(agentId, 'microphone');
      }
      if (requiredStreams.includes('screenAudio') && this.screenAudioStream) {
        await this.startTranscriptionForStream('screenAudio', this.screenAudioStream);
        this.getOrCreateSubscriber(agentId, 'screenAudio');
      }
      // Notify listeners after subscribers are created so hooks can detect them
      this.notifyListeners();
      // --- END ---

      requiredStreams.forEach(type => this.userSets.get(type)?.add(agentId));

    } catch (error) {
      Logger.error("StreamManager", `Failed to fulfill stream blueprint for agent '${agentId}'.`, error);
      throw error;
    }
  }

  /** Releases all streams used by a specific agent. */
  public releaseStreamsForAgent(agentId: string): void {