onAgentRunStart?: (runId: string) => void;

userTurnTranscriptRecorder?: {

message?: unknown;

resolveMessage?: () => Promise<unknown>;

markRuntimePersisted: (message: { role: "user"; content: string }) => void;

markRuntimePersistencePending: (pending: Promise<void>) => void;

};

mockState.lastDispatchCtx = params.ctx;

mockState.lastDispatchImages = params.replyOptions?.images;

mockState.lastDispatchImageOrder = params.replyOptions?.imageOrder;

mockState.lastDispatchUserTurnInput =

params.replyOptions?.userTurnTranscriptRecorder?.message;

const recorder = params.replyOptions?.userTurnTranscriptRecorder;

mockState.lastDispatchUserTurnInput = recorder?.resolveMessage

? await recorder.resolveMessage()

: recorder?.message;

if (mockState.dispatchError) {

throw mockState.dispatchError;

}

ctx.MediaWorkspaceDir = mediaPathOffloadWorkspaceDir;

ctx.MediaStaged = true;

}

const mediaPathOffloadsIncludeImages = mediaPathOffloadTypes.some((type) =>

type.startsWith("image/"),

);

const replyOptionImages = mediaPathOffloadsIncludeImages

? undefined

: parsedImages.length > 0

? parsedImages

: undefined;

const { onModelSelected, ...replyPipeline } = createChannelMessageReplyPipeline({

cfg,

replyOptions: {

runId: clientRunId,

abortSignal: activeRunAbort.controller.signal,

images: parsedImages.length > 0 ? parsedImages : undefined,

images: replyOptionImages,

imageOrder: imageOrder.length > 0 ? imageOrder : undefined,

thinkingLevelOverride: p.thinking,

fastModeOverride: p.fastMode,

expect(captured?.ctx?.MediaType).toBe("image/png");

expect(captured?.ctx?.MediaTypes).toEqual(["image/png"]);

expect(captured?.ctx?.MediaStaged).toBe(true);

await vi.waitFor(() => expect(context.removeChatRun).toHaveBeenCalledTimes(1));

} finally {

dispatchInboundMessageMock.mockReset();

testState.agentConfig = undefined;