approvalId: string;

decision: ExecApprovalReplyDecision;

};

export type IMessageApprovalReactionHandleResult =

| { handled: false; stopPolling: false }

| { handled: true; stopPolling: boolean };

type IMessageApprovalReactionTarget = ApprovalReactionTargetRecord;

};

}

export async function maybeResolveIMessageApprovalReaction(params: {

export async function handleIMessageApprovalReaction(params: {

cfg: OpenClawConfig;

accountId: string;

message: IMessagePayload;

bodyText: string;

gatewayUrl?: string;

logVerboseMessage?: (message: string) => void;

}): Promise<boolean> {

}): Promise<IMessageApprovalReactionHandleResult> {

const event = readApprovalReactionEvent(params.message, params.bodyText);

if (!event) {

return false;

return { handled: false, stopPolling: false };

}

// A removed tapback (user un-taps 👍 or switches to a different emoji) is

// intentionally NOT a fresh resolve. We only want to clear the binding so

// the next added-tapback resolves freshly. Falling through to `return false`

// would surface the un-tap as a noisy reaction system event; instead we

// own the event and stay quiet.

if (event.action === "removed") {

return false;

return { handled: false, stopPolling: false };

}

let target: IMessageApprovalReactionResolution | null = null;

let matchedMessageId: string | null = null;

}

}

if (!target) {

return false;

return { handled: false, stopPolling: false };

}

const approvalKind = target.approvalId.startsWith("plugin:") ? "plugin" : "exec";

params.logVerboseMessage?.(

`imessage: approval reaction denied id=${target.approvalId}; reactions require explicit approvers`,

);

return true;

return { handled: true, stopPolling: false };

}

const auth = imessageApprovalAuth.authorizeActorAction({

cfg: params.cfg,

params.logVerboseMessage?.(

`imessage: approval reaction denied id=${target.approvalId} sender=${event.actorHandle}`,

);

return true;

return { handled: true, stopPolling: false };

}

const { isApprovalNotFoundError, resolveIMessageApproval } = await loadApprovalResolver();

params.logVerboseMessage?.(

`imessage: approval reaction resolved id=${target.approvalId} sender=${event.actorHandle} decision=${target.decision} via messageId=${matchedMessageId ?? event.messageId}`,

);

return true;

return { handled: true, stopPolling: true };

} catch (error) {

if (isApprovalNotFoundError(error)) {

for (const candidate of event.messageIdCandidates) {

params.logVerboseMessage?.(

`imessage: approval reaction ignored for expired approval id=${target.approvalId} sender=${event.actorHandle}`,

);

return true;

return { handled: true, stopPolling: true };

}

// Surface non-NotFound errors at warn level so a gateway 5xx / network

// outage / auth failure is visible without OPENCLAW_LOG_LEVEL=debug.

params.logVerboseMessage?.(

`imessage: approval reaction failed id=${target.approvalId} sender=${event.actorHandle}: ${String(error)}`,

);

return true;

return { handled: true, stopPolling: true };

}

}

export async function maybeResolveIMessageApprovalReaction(params: {

cfg: OpenClawConfig;

accountId: string;

message: IMessagePayload;

bodyText: string;

gatewayUrl?: string;

logVerboseMessage?: (message: string) => void;

}): Promise<boolean> {

return (await handleIMessageApprovalReaction(params)).handled;

}

export function clearIMessageApprovalReactionTargetsForTest(): void {

imessageApprovalReactionTargets.clearForTest();

pendingReactionPollTargets.clear();