Function startHTTPServer

tests/setup/server.js:20–109

(handlerOrOptions, options)

};

export const startHTTPServer = async (handlerOrOptions, options) => {
  const certificate = await certificatePromise;

  const {
    handler,
    useBuffering = false,
    rate = undefined,
    class="cm">// Default to 0 so the OS assigns a free ephemeral port. Tests that need
    class="cm">// a deterministic port can still pass one explicitly. Sharing a fixed
    class="cm">// port across many tests creates TIME_WAIT / pool-reuse races that
    class="cm">// surface as EPIPE on the client under CI runner load.
    port = 0,
    keepAlive = 1000,
    useHTTP2,
    key = certificate.private,
    cert = certificate.cert,
  } = Object.assign(
    typeof handlerOrOptions === class="st">'function'
      ? {
          handler: handlerOrOptions,
        }
      : handlerOrOptions || {},
    options
  );

  return new Promise((resolve, reject) => {
    const serverHandler =
      handler ||
      async function (req, res) {
        try {
          req.headers[class="st">'content-length'] &&
            res.setHeader(class="st">'content-length', req.headers[class="st">'content-length']);

          let dataStream = req;

          if (useBuffering) {
            dataStream = stream.Readable.from(await getStream(req));
          }

          const streams = [dataStream];

          if (rate) {
            streams.push(new Throttle({ rate }));
          }

          streams.push(res);

          stream.pipeline(streams, (err) => {
            err && console.log(class="st">'Server warning: ' + err.message);
          });
        } catch (err) {
          console.warn(class="st">'HTTP server error:', err);
        }
      };

    const server = useHTTP2
      ? http2.createSecureServer({ key, cert }, serverHandler)
      : http.createServer(serverHandler);