return { harness, bus, cleanup };

}

function mockCallArg(mock: ReturnType<typeof vi.fn>, callIndex = 0, argIndex = 0): unknown {

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

if (!call) {

throw new Error(`Expected mock call ${callIndex}`);

}

return call.at(argIndex);

}

describe("nostr inbound gateway path", () => {

afterEach(() => {

mocks.normalizePubkey.mockClear();

}),

});

const options = mocks.startNostrBus.mock.calls[0]?.[0] as {

const options = mockCallArg(mocks.startNostrBus) as {

authorizeSender: (params: {

senderPubkey: string;

reply: (text: string) => Promise<void>;

}),

).resolves.toBe("pairing");

expect(sendPairingReply).toHaveBeenCalledTimes(1);

expect(sendPairingReply.mock.calls[0]?.[0]).toContain("Pairing code:");

expect(mockCallArg(sendPairingReply)).toContain("Pairing code:");

cleanup.stop();

});

} as never,

});

const options = mocks.startNostrBus.mock.calls[0]?.[0] as {

const options = mockCallArg(mocks.startNostrBus) as {

onMessage: (

senderPubkey: string,

text: string,

expect(harness.recordInboundSession).toHaveBeenCalledTimes(1);

expect(harness.dispatchReplyWithBufferedBlockDispatcher).toHaveBeenCalledTimes(1);

const ctx = harness.dispatchReplyWithBufferedBlockDispatcher.mock.calls[0]?.[0]?.ctx;

const ctx = (

mockCallArg(harness.dispatchReplyWithBufferedBlockDispatcher) as {

ctx?: Record<string, unknown>;

}

).ctx;

expect(ctx?.BodyForAgent).toBe("hello from nostr");

expect(ctx?.SenderId).toBe("sender-pubkey");

expect(ctx?.MessageSid).toBe("event-123");