});

}

// Commit messaging tool text on success, discard on error.

// Commit messaging tool evidence on success, discard on error.

const pendingText = ctx.state.pendingMessagingTexts.get(toolCallId);

const pendingTarget = ctx.state.pendingMessagingTargets.get(toolCallId);

const pendingMediaUrls = ctx.state.pendingMessagingMediaUrls.get(toolCallId) ?? [];

const startArgs =

startData?.args && typeof startData.args === "object"

? (startData.args as Record<string, unknown>)

: {};

const isMessagingSend =

pendingMediaUrls.length > 0 ||

(isMessagingTool(toolName) && isMessagingToolSendAction(toolName, startArgs));

const committedMediaUrls =

!isToolError && isMessagingSend

? [...pendingMediaUrls, ...collectMessagingMediaUrlsFromToolResult(result)]

: [];

if (pendingText) {

ctx.state.pendingMessagingTexts.delete(toolCallId);

if (!isToolError) {

if (pendingTarget) {

ctx.state.pendingMessagingTargets.delete(toolCallId);

if (!isToolError) {

ctx.state.messagingToolSentTargets.push(pendingTarget);

ctx.state.messagingToolSentTargets.push({

...pendingTarget,

...(pendingText ? { text: pendingText } : {}),

...(committedMediaUrls.length > 0 ? { mediaUrls: committedMediaUrls.slice() } : {}),

});

ctx.trimMessagingToolSent();

}

}

const pendingMediaUrls = ctx.state.pendingMessagingMediaUrls.get(toolCallId) ?? [];

ctx.state.pendingMessagingMediaUrls.delete(toolCallId);

const startArgs =

startData?.args && typeof startData.args === "object"

? (startData.args as Record<string, unknown>)

: {};

const isMessagingSend =

pendingMediaUrls.length > 0 ||

(isMessagingTool(toolName) && isMessagingToolSendAction(toolName, startArgs));

if (!isToolError && isMessagingSend) {

const committedMediaUrls = [

...pendingMediaUrls,

...collectMessagingMediaUrlsFromToolResult(result),

];

if (committedMediaUrls.length > 0) {

ctx.state.messagingToolSentMediaUrls.push(...committedMediaUrls);

ctx.trimMessagingToolSent();