nyrn
/
openclaw
mirror of https://github.com/openclaw/openclaw.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

refactor: share abort target apply params

This commit is contained in:
Peter Steinberger 2026-03-13 22:19:25 +00:00
parent aaea0b2f28
commit bd758bb438
1 changed files with 19 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
src/auto-reply/reply/commands-session-abort.ts
View File

@ -86,6 +86,23 @@ async function applyAbortTarget(params: {
}
}
function buildAbortTargetApplyParams(
params: Parameters<CommandHandler>[0],
abortTarget: AbortTarget,
) {
return {
abortTarget,
sessionStore: params.sessionStore,
storePath: params.storePath,
abortKey: params.command.abortKey,
abortCutoff: resolveAbortCutoffForTarget({
ctx: params.ctx,
commandSessionKey: params.sessionKey,
targetSessionKey: abortTarget.key,
}),
};
}
export const handleStopCommand: CommandHandler = async (params, allowTextCommands) => {
if (!allowTextCommands) {
return null;
@ -109,17 +126,7 @@ export const handleStopCommand: CommandHandler = async (params, allowTextCommand
`stop: cleared followups=${cleared.followupCleared} lane=${cleared.laneCleared} keys=${cleared.keys.join(",")}`,
);
}
await applyAbortTarget({
abortTarget,
sessionStore: params.sessionStore,
storePath: params.storePath,
abortKey: params.command.abortKey,
abortCutoff: resolveAbortCutoffForTarget({
ctx: params.ctx,
commandSessionKey: params.sessionKey,
targetSessionKey: abortTarget.key,
}),
});
await applyAbortTarget(buildAbortTargetApplyParams(params, abortTarget));
// Trigger internal hook for stop command
const hookEvent = createInternalHookEvent(
@ -160,16 +167,6 @@ export const handleAbortTrigger: CommandHandler = async (params, allowTextComman
sessionEntry: params.sessionEntry,
sessionStore: params.sessionStore,
});
await applyAbortTarget({
abortTarget,
sessionStore: params.sessionStore,
storePath: params.storePath,
abortKey: params.command.abortKey,
abortCutoff: resolveAbortCutoffForTarget({
ctx: params.ctx,
commandSessionKey: params.sessionKey,
targetSessionKey: abortTarget.key,
}),
});
await applyAbortTarget(buildAbortTargetApplyParams(params, abortTarget));
return { shouldContinue: false, reply: { text: "⚙️ Agent was aborted." } };
};