const { DiscordMessageListener, DiscordReactionListener, registerDiscordListener } =

await import("./monitor/listeners.js");

type MockWithCalls = { mock: { calls: unknown[][] } };

function firstMockCall(mock: MockWithCalls, label: string): unknown[] {

const call = mock.mock.calls.at(0);

if (!call) {

throw new Error(`expected ${label} call`);

}

return call;

}

function firstMockArg(mock: MockWithCalls, label: string) {

return firstMockCall(mock, label)[0];

}

function requireRecord(value: unknown, label: string): Record<string, unknown> {

if (typeof value !== "object" || value === null) {

throw new Error(`expected ${label} to be an object`);

}

return value as Record<string, unknown>;

}

function makeReactionEvent(overrides?: {

guildId?: string;

channelId?: string;

await listener.handle(data, client);

expect(enqueueSystemEventSpy, testCase.name).toHaveBeenCalledOnce();

const [text, opts] = enqueueSystemEventSpy.mock.calls[0];

const [text, opts] = firstMockCall(enqueueSystemEventSpy, "enqueueSystemEvent");

expect(text, testCase.name).toContain("Discord reaction added");

expect(text, testCase.name).toContain("👍");

expect(text, testCase.name).toContain("dm");

expect(text, testCase.name).not.toContain("undefined");

expect(opts.sessionKey, testCase.name).toBe("discord:acc-1:dm:user-1");

expect(requireRecord(opts, "system event options").sessionKey, testCase.name).toBe(

"discord:acc-1:dm:user-1",

);

}

});

expect(getReactionClientFetchChannelMock(client)).toHaveBeenCalled();

expect(enqueueSystemEventSpy).toHaveBeenCalledOnce();

const [text] = enqueueSystemEventSpy.mock.calls[0];

const text = firstMockArg(enqueueSystemEventSpy, "enqueueSystemEvent");

expect(text).toContain("Discord reaction added");

});

await listener.handle(data, client);

expect(resolveAgentRouteMock).toHaveBeenCalledOnce();

const routeArgs = (resolveAgentRouteMock.mock.calls[0]?.[0] ?? {}) as {

const routeArgs = firstMockArg(resolveAgentRouteMock, "resolveAgentRoute") as {

peer?: unknown;

};

if (!routeArgs) {

throw new Error("expected route arguments");

}

expect(routeArgs.peer).toEqual({ kind: "direct", id: "user-42" });

});

await listener.handle(data, client);

expect(resolveAgentRouteMock).toHaveBeenCalledOnce();

const routeArgs = (resolveAgentRouteMock.mock.calls[0]?.[0] ?? {}) as {

const routeArgs = firstMockArg(resolveAgentRouteMock, "resolveAgentRoute") as {

peer?: unknown;

};

if (!routeArgs) {

throw new Error("expected route arguments");

}

expect(routeArgs.peer).toEqual({ kind: "group", id: "channel-1" });

});

});