Function createMockRequest

test/server/sse.test.ts:22–55

({
    headers = {},
    body,
    url = '/messages'
}: { headers?: Record<string, string>; body?: string; url?: string } = {})

};

const createMockRequest = ({
    headers = {},
    body,
    url = '/messages'
}: { headers?: Record<string, string>; body?: string; url?: string } = {}) => {
    const mockReq = {
        headers,
        body: body ? body : undefined,
        url,
        auth: {
            token: 'test-token'
        },
        on: vi.fn<http.IncomingMessage['on']>().mockImplementation((event, listener) => {
            const mockListener = listener as unknown as (...args: unknown[]) => void;
            if (event === 'data') {
                mockListener(Buffer.from(body || '') as unknown as Error);
            }
            if (event === 'error') {
                mockListener(new Error('test'));
            }
            if (event === 'end') {
                mockListener();
            }
            if (event === 'close') {
                setTimeout(listener, 100);
            }
            return mockReq;
        }),
        listeners: vi.fn<http.IncomingMessage['listeners']>(),
        removeListener: vi.fn<http.IncomingMessage['removeListener']>()
    } as unknown as http.IncomingMessage;

    return mockReq;
};

async function readAllSSEEvents(response: Response): Promise<string[]> {
    const reader = response.body?.getReader();