vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-06 06:50:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: share ui approval event handling

Browse Source
This commit is contained in:
Peter Steinberger
2026-04-20 22:36:09 +01:00
parent 1f951f36fd
commit 9dcbf911a0
1 changed files with 23 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

49
ui/src/ui/app-gateway.ts
View File

@@ -119,6 +119,25 @@ type GatewayHostWithSideResults = GatewayHost & {
chatSideResultTerminalRuns?: Set<string>;
};
function enqueueApprovalRequest(host: GatewayHost, entry: ExecApprovalRequest | null) {
if (!entry) {
return;
}
host.execApprovalQueue = addExecApproval(host.execApprovalQueue, entry);
host.execApprovalError = null;
const delay = Math.max(0, entry.expiresAtMs - Date.now() + 500);
window.setTimeout(() => {
host.execApprovalQueue = removeExecApproval(host.execApprovalQueue, entry.id);
}, delay);
}
function removeResolvedApprovalRequest(host: GatewayHost, payload: unknown) {
const resolved = parseExecApprovalResolved(payload);
if (resolved) {
host.execApprovalQueue = removeExecApproval(host.execApprovalQueue, resolved.id);
}
}
function isTerminalChatState(
state: ChatEventPayload["state"] | ReturnType<typeof handleChatEvent> | null | undefined,
): state is "final" | "aborted" | "error" {
@@ -542,44 +561,22 @@ function handleGatewayEventUnsafe(host: GatewayHost, evt: GatewayEventFrame) {
}
if (evt.event === "exec.approval.requested") {
const entry = parseExecApprovalRequested(evt.payload);
if (entry) {
host.execApprovalQueue = addExecApproval(host.execApprovalQueue, entry);
host.execApprovalError = null;
const delay = Math.max(0, entry.expiresAtMs - Date.now() + 500);
window.setTimeout(() => {
host.execApprovalQueue = removeExecApproval(host.execApprovalQueue, entry.id);
}, delay);
}
enqueueApprovalRequest(host, parseExecApprovalRequested(evt.payload));
return;
}
if (evt.event === "exec.approval.resolved") {
const resolved = parseExecApprovalResolved(evt.payload);
if (resolved) {
host.execApprovalQueue = removeExecApproval(host.execApprovalQueue, resolved.id);
}
removeResolvedApprovalRequest(host, evt.payload);
return;
}
if (evt.event === "plugin.approval.requested") {
const entry = parsePluginApprovalRequested(evt.payload);
if (entry) {
host.execApprovalQueue = addExecApproval(host.execApprovalQueue, entry);
host.execApprovalError = null;
const delay = Math.max(0, entry.expiresAtMs - Date.now() + 500);
window.setTimeout(() => {
host.execApprovalQueue = removeExecApproval(host.execApprovalQueue, entry.id);
}, delay);
}
enqueueApprovalRequest(host, parsePluginApprovalRequested(evt.payload));
return;
}
if (evt.event === "plugin.approval.resolved") {
const resolved = parseExecApprovalResolved(evt.payload);
if (resolved) {
host.execApprovalQueue = removeExecApproval(host.execApprovalQueue, resolved.id);
}
removeResolvedApprovalRequest(host, evt.payload);
return;
}