currentSessionId: params?.currentSessionId ?? null,

activeChatRunId: params?.activeChatRunId ?? null,

pendingOptimisticUserMessage: params?.pendingOptimisticUserMessage ?? false,

pendingChatRunId: null as string | null,

isConnected: params?.isConnected ?? true,

sessionInfo: {},

};

expect(state.pendingOptimisticUserMessage).toBe(true);

});

it("tracks the in-flight runId so escape can abort during the wait", async () => {

const sendChat = vi.fn().mockResolvedValue({ runId: "ignored" });

const { handleCommand, state } = createHarness({ sendChat });

await handleCommand("hello");

const sentRunId = (sendChat.mock.calls[0]?.[0] as { runId: string }).runId;

expect(typeof sentRunId).toBe("string");

expect(sentRunId.length).toBeGreaterThan(0);

expect(state.activeChatRunId).toBeNull();

expect(state.pendingChatRunId).toBe(sentRunId);

});

it("clears the pending runId if sendChat fails", async () => {

const sendChat = vi.fn().mockRejectedValue(new Error("boom"));

const { handleCommand, state } = createHarness({ sendChat });

await handleCommand("hello");

expect(state.pendingChatRunId).toBeNull();

expect(state.pendingOptimisticUserMessage).toBe(false);

});

it("sends /btw without hijacking the active main run", async () => {

const setActivityStatus = vi.fn();

const { handleCommand, sendChat, addUser, noteLocalRunId, noteLocalBtwRunId, state } =