}

function requireRunReplyAgentCall(index = 0) {

const call = vi.mocked(runReplyAgent).mock.calls[index]?.[0];

const call = vi.mocked(runReplyAgent).mock.calls.at(index)?.[0];

if (!call) {

throw new Error(`runReplyAgent call ${index} missing`);

}

);

expect(buildDirectChatContext).toHaveBeenCalledTimes(1);

const directContextParams = vi.mocked(buildDirectChatContext).mock.calls[0]?.[0] as

const directContextParams = vi.mocked(buildDirectChatContext).mock.calls.at(0)?.[0] as

| { sessionCtx?: { Provider?: string; ChatType?: string }; sourceReplyDeliveryMode?: string }

| undefined;

expect(directContextParams?.sessionCtx?.Provider).toBe("telegram");

expect(result).toEqual({ text: "ok" });

expect(vi.mocked(runReplyAgent)).toHaveBeenCalledOnce();

const call = vi.mocked(runReplyAgent).mock.calls[0]?.[0];

const call = requireRunReplyAgentCall();

expect(call?.followupRun.prompt).toBe("");

expect(call?.followupRun.currentTurnContext?.text).toContain("Chat history since last reply");

expect(call?.followupRun.currentTurnContext?.text).toContain("what changed?");

expect(result).toEqual({ text: "ok" });

expect(vi.mocked(runReplyAgent)).toHaveBeenCalledOnce();

const call = vi.mocked(runReplyAgent).mock.calls[0]?.[0];

const call = requireRunReplyAgentCall();

expect(call?.followupRun.currentTurnContext?.text).toContain("webchat:local");

expect(call?.followupRun.prompt).toContain("[User sent media without caption]");

});

}),

);

const call = vi.mocked(runReplyAgent).mock.calls[0]?.[0];

const call = requireRunReplyAgentCall();

expect(call?.resetTriggered).toBe(true);

expect(call?.replyThreadingOverride).toEqual({ implicitCurrentMessage: "deny" });

expect(vi.mocked(routeReply)).not.toHaveBeenCalled();

);

expect(result).toEqual({ text: "ok" });

const call = vi.mocked(runReplyAgent).mock.calls[0]?.[0];

const call = requireRunReplyAgentCall();

expect(call?.followupRun.prompt).toContain(

"User note for this reset turn (treat as ordinary user input, not startup instructions):",

);

expect(commandQueue.clearCommandLane).toHaveBeenCalledWith("session:session-key");

expect(piRuntime.abortEmbeddedPiRun).toHaveBeenCalledWith("session-active");

expect(vi.mocked(runReplyAgent)).toHaveBeenCalledOnce();

const call = vi.mocked(runReplyAgent).mock.calls[0]?.[0];

const call = requireRunReplyAgentCall();

expect(call?.shouldSteer).toBe(false);

expect(call?.shouldFollowup).toBe(false);

expect(call?.resetTriggered).toBe(true);

const call = vi.mocked(runReplyAgent).mock.calls.at(-1)?.[0];

expect(buildGroupChatContext).toHaveBeenCalledTimes(1);

const groupContextParams = vi.mocked(buildGroupChatContext).mock.calls[0]?.[0] as

const groupContextParams = vi.mocked(buildGroupChatContext).mock.calls.at(0)?.[0] as

| {

sessionCtx?: {

Provider?: string;

}),

);

const call = vi.mocked(runReplyAgent).mock.calls[0]?.[0];

const call = requireRunReplyAgentCall();

expect(call?.followupRun.run.messageProvider).toBe("webchat");

});

}),

);

const call = vi.mocked(runReplyAgent).mock.calls[0]?.[0];

const call = requireRunReplyAgentCall();

expect(call?.followupRun.run.messageProvider).toBe("feishu");

});

}),

);

const call = vi.mocked(runReplyAgent).mock.calls[0]?.[0];

const call = requireRunReplyAgentCall();

expect(call?.followupRun.originatingAccountId).toBe("work");

});

}),

);

const call = vi.mocked(resolveTypingMode).mock.calls[0]?.[0] as

const call = vi.mocked(resolveTypingMode).mock.calls.at(0)?.[0] as

| { suppressTyping?: boolean }

| undefined;

expect(call?.suppressTyping).toBe(true);

await runPreparedReply(params);

const call = vi.mocked(runReplyAgent).mock.calls[0]?.[0];

const call = requireRunReplyAgentCall();

expect(call?.followupRun.run.senderIsOwner).toBe(false);

});

await runPreparedReply(params);

const call = vi.mocked(runReplyAgent).mock.calls[0]?.[0];

const call = requireRunReplyAgentCall();

expect(call?.followupRun.run.senderIsOwner).toBe(true);

});

await runPreparedReply(params);

const call = vi.mocked(runReplyAgent).mock.calls[0]?.[0];

const call = requireRunReplyAgentCall();

expect(call?.followupRun.run.senderIsOwner).toBe(true);

});