import http from "http"; import { URL } from "url"; /** * Start a local HTTP server to receive OAuth callback * @param {Function} onCallback - Called with query params when callback received * @param {number} fixedPort - Optional fixed port number (default: random) * @returns {Promise<{server: http.Server, port: number, close: Function}>} */ export function startLocalServer( onCallback: (params: Record) => void, fixedPort: number | null = null ): Promise<{ server: any; port: number; close: () => void }> { return new Promise((resolve, reject) => { const server = http.createServer((req, res) => { const url = new URL(req.url || "/", `http://localhost`); if (url.pathname === "/callback" || url.pathname === "/auth/callback") { const params = Object.fromEntries(url.searchParams); // Send success response to browser with auto-close attempt res.writeHead(200, { "Content-Type": "text/html; charset=utf-8" }); res.end(` Authentication Successful

✓

Authentication Successful

Closing in 3 seconds...

`); // Call callback with params onCallback(params); } else { res.writeHead(404); res.end("Not found"); } }); // Listen on fixed port or find available port const portToUse = fixedPort || 0; server.listen(portToUse, "127.0.0.1", () => { const addr = server.address() as { port: number }; resolve({ server, port: addr.port, close: () => server.close(), }); }); server.on("error", (err: any) => { if (err.code === "EADDRINUSE" && fixedPort) { reject( new Error( `Port ${fixedPort} is already in use. Please close other applications using this port.` ) ); } else { reject(err); } }); }); } /** * Wait for callback with timeout * @param {number} timeoutMs - Timeout in milliseconds * @returns {Promise