Method wrapHTTPHandler

src/router.ts:186–239

(
    route: HTTPRoute | BrowserHTTPRoute,
    handler: HTTPRoute['handler'] | BrowserHTTPRoute['handler'],
  )

  }

  protected wrapHTTPHandler(
    route: HTTPRoute | BrowserHTTPRoute,
    handler: HTTPRoute['handler'] | BrowserHTTPRoute['handler'],
  ) {
    return async (req: Request, res: Response) => {
      if (!isConnected(res)) {
        this.log.warn(`HTTP Request has closed prior to running`);
        return ROUTE_DID_NOT_RUN;
      }
      const logger = new this.logger(route.name, req);
      if (
        Object.getPrototypeOf(route) instanceof BrowserHTTPRoute &&
        'browser' in route &&
        route.browser
      ) {
        const browser = await this.browserManager.getBrowserForRequest(
          req,
          route,
          logger,
        );

        if (!isConnected(res)) {
          this.log.warn(`HTTP Request has closed prior to running`);
          this.browserManager.complete(browser);
          return ROUTE_DID_NOT_RUN;
        }

        if (!browser) {
          return writeResponse(res, 500, `Error loading the browser`);
        }

        try {
          this.log.trace(`Running found HTTP handler.`);
          return await Promise.race([
            handler(req, res, logger, browser),
            new Promise((resolve, reject) => {
              res.once('close', () => {
                if (!res.writableEnded) {
                  reject(new Error(`Request closed prior to writing results`));
                }
                this.log.trace(`Response has been written, resolving`);
                resolve(null);
              });
            }),
          ]);
        } finally {
          this.log.trace(`HTTP Request handler has finished.`);
          this.browserManager.complete(browser);
        }
      }

      return (handler as HTTPRoute['handler'])(req, res, logger);
    };
  }

  protected wrapWebSocketHandler(
    route: WebSocketRoute | BrowserWebsocketRoute,