Method run

src/runtime/agent.ts:670–887

()

  ): Promise<HandleResult> {
    const cs = await this.getOrCreateSession(adapter, channelId);
    const run = async (): Promise<HandleResult> => {
      cs.running = true;

      let turnHadVisibleOutput = false;
      let sawAgentStart = false;
      let sawAgentEnd = false;
      const runId = randomUUID();
      let unsubscribe = () => undefined;
      const waitForQueuedAgentEvents = async (): Promise<void> => {
        const maybeQueue = (cs.session as { _agentEventQueue?: unknown })
          ._agentEventQueue;
        if (
          !maybeQueue ||
          typeof (maybeQueue as Promise<unknown>).then !== "function"
        ) {
          return;
        }

        try {
          await maybeQueue;
        } catch (error) {
          log("[PackAgent] Waiting for queued agent events failed:", error);
        }
      };

      try {
        if (this.pendingAbortChannels.delete(channelId)) {
          return { stopReason: "aborted" };
        }

        const forwardAgentEvent = (event: AgentEvent): void => {
          if (event.type === "agent_start") {
            sawAgentStart = true;
          } else if (event.type === "agent_end") {
            if (sawAgentEnd) {
              return;
            }
            sawAgentEnd = true;
          }

          onEvent(event);
        };

        // Wire up file output callback for this run
        cs.fileOutputCallbackRef.current = (event) => {
          forwardAgentEvent(event);
        };
        cs.delegatedToolRunContextRef.current = {
          runId,
          channelId,
          adapter,
        };

        // Subscribe to agent events and forward to adapter
        unsubscribe = cs.session.subscribe((event: any) => {
          switch (event.type) {
            case "agent_start":
              log("\n=== [AGENT SESSION START] ===");