Function requestRouter

api/src/controllers/mcp/oauth.test.ts:172–223

(
	router: Router,
	path: string,
	options: { method?: string; body?: Record<string, string> | string; headers?: Record<string, string> } = {},
)

}

async function requestRouter(
	router: Router,
	path: string,
	options: { method?: string; body?: Record<string, string> | string; headers?: Record<string, string> } = {},
) {
	const server = http.createServer(createAppForRouter(router));

	await new Promise<void>((resolve, reject) => {
		server.on('error', reject);
		server.listen(0, resolve);
	});

	const { port } = server.address() as AddressInfo;
	let encodedBody: string | undefined;

	if (typeof options.body === 'string') {
		encodedBody = options.body;
	} else if (options.body) {
		encodedBody = new URLSearchParams(options.body).toString();
	}

	try {
		const response = await fetch(`http://127.0.0.1:${port}${path}`, {
			method: options.method ?? 'GET',
			headers: {
				'User-Agent': 'test',
				...options.headers,
			},
			body: encodedBody,
		});

		const text = await response.text();
		let body;

		try {
			body = text ? JSON.parse(text) : undefined;
		} catch {
			body = undefined;
		}

		return {
			body,
			headers: response.headers,
			status: response.status,
			text,
		};
	} finally {
		await new Promise<void>((resolve, reject) => {
			server.close((error) => (error ? reject(error) : resolve()));
		});
	}
}

async function postForm(
	router: Router,