import { loadChannels, waitWhatsAppLogin, type ChannelsState } from "./channels.ts";

function createDeferred<T>() {

let resolve!: (value: T) => void;

let reject!: (reason?: unknown) => void;

let resolve: ((value: T) => void) | undefined;

let reject: ((reason?: unknown) => void) | undefined;

const promise = new Promise<T>((res, rej) => {

resolve = res;

reject = rej;

});

if (!resolve || !reject) {

throw new Error("Expected deferred callbacks to be initialized");

}

return { promise, resolve, reject };

}

};

}

function requireClientRequest(state: ChannelsState) {

const request = state.client?.request;

if (!request) {

throw new Error("Expected channels controller client request");

}

return vi.mocked(request);

}

describe("channels controller WhatsApp wait", () => {

beforeEach(() => {

vi.clearAllMocks();

});

it("passes the currently displayed QR and replaces it when the login QR rotates", async () => {

const state = createState();

const request = vi.mocked(state.client!.request);

const request = requireClientRequest(state);

request.mockResolvedValueOnce({

connected: false,

message: "QR refreshed. Scan the latest code in WhatsApp → Linked Devices.",

ts: 2,

};

const deferred = createDeferred<ChannelsStatusSnapshot | null>();

const request = vi.mocked(state.client!.request);

const request = requireClientRequest(state);

request.mockReturnValueOnce(deferred.promise);

state.channelsSnapshot = previous;

state.channelsLastSuccess = 10;