const scheduleFollowupDrainMock = vi.fn();

const refreshQueuedFollowupSessionMock = vi.fn();

const resolveOutboundAttachmentFromUrlMock = vi.fn();

const createReplyMediaPathNormalizerRuntimeMock = vi.fn();

const createReplyMediaContextRuntimeMock = vi.fn();

vi.mock("../../agents/model-fallback.js", () => ({

runWithModelFallback: (params: {

}));

// Spy on the .runtime import path used by agent-runner-execution.ts so we can assert

// that the fix prevents a second normalizer from being created inside runAgentTurnWithFallback.

// that the fix prevents a second media context from being created inside runAgentTurnWithFallback.

vi.mock("./reply-media-paths.runtime.js", async (importOriginal) => {

const mod = await importOriginal<typeof import("./reply-media-paths.runtime.js")>();

return {

createReplyMediaPathNormalizer: (...args: Parameters<typeof mod.createReplyMediaPathNormalizer>) => {

createReplyMediaPathNormalizerRuntimeMock(...args);

return mod.createReplyMediaPathNormalizer(...args);

createReplyMediaContext: (...args: Parameters<typeof mod.createReplyMediaContext>) => {

createReplyMediaContextRuntimeMock(...args);

return mod.createReplyMediaContext(...args);

},

createReplyMediaPathNormalizer: mod.createReplyMediaPathNormalizer,

};

});

scheduleFollowupDrainMock.mockReset();

refreshQueuedFollowupSessionMock.mockReset();

resolveOutboundAttachmentFromUrlMock.mockReset();

createReplyMediaPathNormalizerRuntimeMock.mockReset();

createReplyMediaContextRuntimeMock.mockReset();

vi.stubEnv("OPENCLAW_TEST_FAST", "1");

resolveOutboundAttachmentFromUrlMock.mockImplementation(async (mediaUrl: string) => ({

path: path.join("/tmp/outbound-media", path.basename(mediaUrl)),

);

});

it("does not create a second normalizer inside runAgentTurnWithFallback when onBlockReply is provided", async () => {

it("shares one media cache between direct block media and final payload filtering", async () => {

let stagedIndex = 0;

resolveOutboundAttachmentFromUrlMock.mockImplementation(async (mediaUrl: string) => {

stagedIndex += 1;

return {

path: path.join("/tmp/outbound-media", `${stagedIndex}-${path.basename(mediaUrl)}`),

};

});

const onBlockReply = vi.fn();

runEmbeddedPiAgentMock.mockImplementation(

async (params: {

onBlockReply?: (payload: { text?: string; mediaUrls?: string[] }) => Promise<void>;

}) => {

await params.onBlockReply?.({

text: "here is the chart\nMEDIA:./out/chart.png",

});

return {

payloads: [{ text: "here is the chart\nMEDIA:./out/chart.png" }],

meta: {

agentMeta: {

sessionId: "session",

provider: "anthropic",

model: "claude",

},

},

};

},

);

const result = await runReplyAgent({

commandBody: "generate chart",

followupRun: createMockFollowupRun({

prompt: "generate chart",

run: {

agentId: "main",

agentDir: "/tmp/agent",

messageProvider: "whatsapp",

workspaceDir: "/tmp/workspace",

},

}) as unknown as FollowupRun,

queueKey: "main",

resolvedQueue: { mode: "interrupt" } as QueueSettings,

shouldSteer: false,

shouldFollowup: false,

isActive: false,

isStreaming: false,

typing: createMockTypingController(),

sessionCtx: {

Provider: "whatsapp",

Surface: "whatsapp",

To: "chat-1",

OriginatingTo: "chat-1",

AccountId: "default",

MessageSid: "msg-1",

} as unknown as TemplateContext,

defaultModel: "anthropic/claude",

resolvedVerboseLevel: "off",

isNewSession: false,

blockStreamingEnabled: false,

resolvedBlockStreamingBreak: "message_end",

shouldInjectGroupIntro: false,

typingMode: "instant",

opts: {

onBlockReply,

},

});

expect(result).toBeUndefined();

expect(resolveOutboundAttachmentFromUrlMock).toHaveBeenCalledTimes(1);

expect(onBlockReply).toHaveBeenCalledTimes(1);

expect(onBlockReply).toHaveBeenCalledWith({

text: undefined,

mediaUrl: "/tmp/outbound-media/1-chart.png",

mediaUrls: ["/tmp/outbound-media/1-chart.png"],

replyToCurrent: false,

replyToId: "msg-1",

replyToTag: false,

audioAsVoice: false,

});

});

it("does not create a second media context inside runAgentTurnWithFallback when onBlockReply is provided", async () => {

// Regression test for openclaw/openclaw#68056.

// Before the fix, runAgentTurnWithFallback always called createReplyMediaPathNormalizer

// from reply-media-paths.runtime.js to build its own normalizer instance — separate from

// the one agent-runner.ts created and passed to buildReplyPayloads. Two separate

// persistedMediaBySource caches meant the same source could be persisted twice (two UUID

// outbound files, two WhatsApp sends).

// Before the fix, runAgentTurnWithFallback created its own media context, separate from

// the one agent-runner.ts created and passed to buildReplyPayloads. Two separate caches

// meant the same source could be persisted twice (two UUID outbound files, two sends).

//

// After the fix, agent-runner.ts passes its normalizer into runAgentTurnWithFallback, so

// After the fix, agent-runner.ts passes its media context into runAgentTurnWithFallback, so

// the .runtime import path is never called from inside that function.

runEmbeddedPiAgentMock.mockResolvedValue({

payloads: [],

},

});

// The .runtime import is only used by agent-runner-execution.ts. After the fix,

// runAgentTurnWithFallback receives the normalizer from the caller and never

// calls createReplyMediaPathNormalizer itself.

expect(createReplyMediaPathNormalizerRuntimeMock).not.toHaveBeenCalled();

// The .runtime import is only used by agent-runner-execution.ts. After the fix,

// runAgentTurnWithFallback receives the context from the caller and never

// creates its own.

expect(createReplyMediaContextRuntimeMock).not.toHaveBeenCalled();

});

});