import { hasOutboundReplyContent } from "openclaw/plugin-sdk/reply-payload";

import { DEFAULT_HEARTBEAT_ACK_MAX_CHARS } from "../../auto-reply/heartbeat.js";

import { getReplyPayloadMetadata } from "../../auto-reply/reply-payload.js";

import type { ReplyPayload } from "../../auto-reply/reply-payload.js";

import { normalizeOptionalString } from "../../shared/string-coerce.js";

import { truncateUtf16Safe } from "../../utils.js";

}

}

for (let i = payloads.length - 1; i >= 0; i--) {

if (isNonTerminalToolErrorWarning(payloads[i])) {

continue;

}

const summary = pickSummaryFromOutput(payloads[i]?.text);

if (summary) {

return summary;

}

}

for (let i = payloads.length - 1; i >= 0; i--) {

if (isNonTerminalToolErrorWarning(payloads[i])) {

continue;

}

const clean = (payloads[i]?.text ?? "").trim();

if (clean) {

return clean;

);

}

function isNonTerminalToolErrorWarning(payload: object | undefined): boolean {

return Boolean(payload && getReplyPayloadMetadata(payload)?.nonTerminalToolErrorWarning);

}

function isSuccessfulCronPayload(payload: DeliveryPayload | undefined): boolean {

return (

payload?.isError !== true &&

(isDeliverablePayload(payload) || payloadHasStructuredDeliveryContent(payload))

);

}

export function resolveCronPayloadOutcome(params: {

payloads: DeliveryPayload[];

runLevelError?: unknown;

failureSignal?: CronFailureSignal | undefined;

finalAssistantVisibleText?: string | undefined;

preferFinalAssistantVisibleText?: boolean;

}): CronPayloadOutcome {

const firstText = params.payloads[0]?.text ?? "";

const firstText =

params.payloads.find((payload) => !isNonTerminalToolErrorWarning(payload))?.text ?? "";

const fallbackSummary =

pickSummaryFromPayloads(params.payloads) ?? pickSummaryFromOutput(firstText);

const fallbackOutputText = pickLastNonEmptyTextFromPayloads(params.payloads);

const hasSuccessfulPayloadAfterLastError =

!params.runLevelError &&

lastErrorPayloadIndex >= 0 &&

params.payloads

.slice(lastErrorPayloadIndex + 1)

.some((payload) => payload?.isError !== true && Boolean(payload?.text?.trim()));

params.payloads.slice(lastErrorPayloadIndex + 1).some(isSuccessfulCronPayload);

const hasSuccessfulPayloadBeforeLastError =

!params.runLevelError &&

lastErrorPayloadIndex > 0 &&

params.payloads

.slice(0, lastErrorPayloadIndex)

.some((payload) => payload?.isError !== true && Boolean(payload?.text?.trim()));

params.payloads.slice(0, lastErrorPayloadIndex).some(isSuccessfulCronPayload);

const lastErrorPayload =

lastErrorPayloadIndex >= 0 ? params.payloads[lastErrorPayloadIndex] : undefined;

const hasRecoveringTerminalOutput =

normalizedFinalAssistantVisibleText !== undefined ||

hasSuccessfulPayloadAfterLastError ||

hasSuccessfulPayloadBeforeLastError;

const hasNonTerminalToolErrorWarning =

!params.runLevelError &&

params.failureSignal?.fatalForCron !== true &&

hasRecoveringTerminalOutput &&

isNonTerminalToolErrorWarning(lastErrorPayload);

const hasPendingPresentationWarning =

!params.runLevelError &&

params.failureSignal?.fatalForCron !== true &&

lastErrorPayloadIndex >= 0 &&

isCronMessagePresentationWarning(lastErrorPayloadText) &&

(normalizedFinalAssistantVisibleText !== undefined || hasSuccessfulPayloadBeforeLastError);

const hasFatalStructuredErrorPayload =

hasErrorPayload && !hasSuccessfulPayloadAfterLastError && !hasPendingPresentationWarning;

hasErrorPayload &&

!hasSuccessfulPayloadAfterLastError &&

!hasPendingPresentationWarning &&

!hasNonTerminalToolErrorWarning;

const hasStructuredDeliveryPayloads = selectedDeliveryPayloads.some((payload) =>

payloadHasStructuredDeliveryContent(payload),

);