@bearer/cli/lib/actions/startLocalServer.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const get_port_1 = require("get-port");
// We want to stop the server as fast possible and for that we need to have no connection opened
// here we manually register incoming connections and close them when destroy is called
async function startServer(port, app) {
    return new Promise(async (resolve, reject) => {
        const connections = {};
        try {
            const listenablePort = await get_port_1.default({ port });
            if (listenablePort !== port) {
                reject(new UnavailablePort(port));
            }
            else {
                const server = app.listen(port, () => {
                    resolve(server);
                });
                server.on('connection', (conn) => {
                    const key = [conn.remoteAddress, conn.remotePort].join(':');
                    connections[key] = conn;
                    conn.on('close', () => {
                        delete connections[key];
                    });
                });
                server.destroy = cb => {
                    server.close(cb);
                    // force closing all connections
                    for (const key in connections) {
                        connections[key].destroy();
                    }
                };
            }
        }
        catch (e) {
            reject(e);
        }
    });
}
exports.startServer = startServer;
class UnavailablePort extends Error {
    constructor(port) {
        super(`Can not start server on port ${port}`);
    }
}
exports.UnavailablePort = UnavailablePort;