Method continue

packages/core/src/agent.test.ts:242–285

()

      this.emit({ type: 'agent_end', messages: this.state.messages });
    }
    async continue(): Promise<void> {
      this.call.continues += 1;
      const callIndex = agentCalls.indexOf(this.call);
      const script =
        scriptedAgent.overrideScriptForCallIndex !== undefined &&
        callIndex >= scriptedAgent.overrideScriptForCallIndex &&
        scriptedAgent.overrideScript
          ? { ...scriptedAgent, ...scriptedAgent.overrideScript }
          : scriptedAgent;

      this.emit({ type: 'agent_start' });
      this.emit({ type: 'turn_start' });
      const assistantMsg: AgentMessage = {
        role: 'assistant',
        // biome-ignore lint/suspicious/noExplicitAny: matches pi-ai Api/Provider literal unions in mocks.
        api: 'anthropic-messages' as any,
        // biome-ignore lint/suspicious/noExplicitAny: same.
        provider: 'anthropic' as any,
        model: 'mock-model',
        content: [{ type: 'text', text: script.assistantText }],
        usage: script.usage ?? {
          input: 0,
          output: 0,
          cacheRead: 0,
          cacheWrite: 0,
          totalTokens: 0,
          cost: { input: 0, output: 0, cacheRead: 0, cacheWrite: 0, total: 0 },
        },
        stopReason: script.stopReason ?? 'stop',
        ...(script.errorMessage ? { errorMessage: script.errorMessage } : {}),
        timestamp: Date.now(),
      };
      this.state.messages.push(assistantMsg);
      for (const e of script.events ?? []) this.emit(e);
      this.emit({
        type: 'message_update',
        message: assistantMsg,
        // biome-ignore lint/suspicious/noExplicitAny: AssistantMessageEvent shape not re-exported.
        assistantMessageEvent: { type: 'text_delta', delta: script.assistantText } as any,
      });
      this.emit({ type: 'message_end', message: assistantMsg });
      this.emit({ type: 'turn_end', message: assistantMsg, toolResults: [] });
      this.emit({ type: 'agent_end', messages: this.state.messages });
    }
    async waitForIdle(): Promise<void> {
      // no-op in mock
    }