expect(account?.lastError).toContain("channel stop timed out");

});

it("resumes startup on the second recovery pass while the stale task is still pending", async () => {

const startAccount = vi.fn(async ({ abortSignal }: { abortSignal: AbortSignal }) => {

abortSignal.addEventListener("abort", () => {}, { once: true });

await new Promise<void>(() => {});

});

installTestRegistry(

createTestPlugin({

startAccount,

}),

);

const manager = createManager();

await manager.startChannels();

const recoveryStopTask = manager.stopChannel("discord", DEFAULT_ACCOUNT_ID, {

manual: false,

});

await vi.advanceTimersByTimeAsync(5_000);

await recoveryStopTask;

await manager.startChannel("discord", DEFAULT_ACCOUNT_ID);

let account = manager.getRuntimeSnapshot().channelAccounts.discord?.[DEFAULT_ACCOUNT_ID];

expect(startAccount).toHaveBeenCalledTimes(1);

expect(account?.running).toBe(false);

expect(account?.restartPending).toBe(true);

await manager.startChannel("discord", DEFAULT_ACCOUNT_ID);

account = manager.getRuntimeSnapshot().channelAccounts.discord?.[DEFAULT_ACCOUNT_ID];

expect(startAccount).toHaveBeenCalledTimes(2);

expect(account?.running).toBe(true);

expect(account?.restartPending).toBe(false);

expect(account?.reconnectAttempts).toBe(0);

expect(account?.lastError).toBeNull();

});

it("restarts immediately when recovery stop timeout settles with an error", async () => {

const rejectFirstTask = createDeferred();

let startCount = 0;