},

);

await maybeHandleResetCommand(params);

const result = await maybeHandleResetCommand(params);

expect(routeReplyMock).toHaveBeenCalledWith(

expect.objectContaining({

threadId: "thread-1",

}),

);

expect(result).toEqual({ shouldContinue: false });

});

it("prefers the target session entry when emitting reset hooks", async () => {

sessionEntry?: HandleCommandsParams["sessionEntry"];

previousSessionEntry?: HandleCommandsParams["previousSessionEntry"];

workspaceDir: string;

}): Promise<void> {

}): Promise<{ routedReply: boolean }> {

const hookEvent = createInternalHookEvent("command", params.action, params.sessionKey ?? "", {

sessionEntry: params.sessionEntry,

previousSessionEntry: params.previousSessionEntry,

await triggerInternalHook(hookEvent);

params.command.resetHookTriggered = true;

let routedReply = false;

if (hookEvent.messages.length > 0) {

const channel = params.ctx.OriginatingChannel || params.command.channel;

const to = params.ctx.OriginatingTo || params.command.from || params.command.to;

threadId: params.ctx.MessageThreadId,

cfg: params.cfg,

});

routedReply = true;

}

}

}

})();

}

return { routedReply };

}

const targetSessionEntry = params.sessionStore?.[params.sessionKey] ?? params.sessionEntry;

await emitResetCommandHooks({

const hookResult = await emitResetCommandHooks({

action: commandAction,

ctx: params.ctx,

cfg: params.cfg,

if (!resetTail) {

return {

shouldContinue: false,

reply: {

text: commandAction === "reset" ? "✅ Session reset." : "✅ New session started.",

},

...(hookResult.routedReply

? {}

: {

reply: {

text: commandAction === "reset" ? "✅ Session reset." : "✅ New session started.",

},

}),

};

}

return null;