Method emitStreamStart

src/node/services/streamManager.ts:1886–1917

(
    workspaceId: WorkspaceId,
    streamInfo: WorkspaceStreamInfo,
    historySequence: number,
    options?: { replay?: boolean }
  )

  }

  private emitStreamStart(
    workspaceId: WorkspaceId,
    streamInfo: WorkspaceStreamInfo,
    historySequence: number,
    options?: { replay?: boolean }
  ): void {
    const streamStartAgentId = streamInfo.initialMetadata?.agentId;
    const streamStartMode = this.getStreamMode(streamInfo.initialMetadata);
    const canonicalModel = normalizeToCanonical(streamInfo.model);
    const routedThroughGateway =
      streamInfo.initialMetadata?.routedThroughGateway ??
      streamInfo.model.startsWith("mux-gateway:");
    const routeProvider = streamInfo.initialMetadata?.routeProvider;

    this.emit("stream-start", {
      type: "stream-start",
      workspaceId: workspaceId as string,
      messageId: streamInfo.messageId,
      ...(options?.replay && { replay: true }),
      model: canonicalModel,
      routedThroughGateway,
      ...(routeProvider != null && { routeProvider }),
      historySequence,
      startTime: streamInfo.startTime,
      ...(streamStartAgentId && { agentId: streamStartAgentId }),
      ...(streamStartMode && { mode: streamStartMode }),
      ...(streamInfo.thinkingLevel && { thinkingLevel: streamInfo.thinkingLevel }),
      ...(streamInfo.initialMetadata?.acpPromptId != null
        ? { acpPromptId: streamInfo.initialMetadata.acpPromptId }
        : {}),
    } as StreamStartEvent);
  }

  private emitStreamAbort(
    workspaceId: WorkspaceId,