Method handler

src/shared/function.http.ts:59–95

(
    req: Request,
    res: ServerResponse,
    logger: Logger,
    browser: BrowserInstance,
  )

  path = [HTTPRoutes.chromiumFunction, HTTPRoutes.function];
  tags = [APITags.browserAPI];
  async handler(
    req: Request,
    res: ServerResponse,
    logger: Logger,
    browser: BrowserInstance,
  ): Promise<void> {
    const config = this.config();
    const timeout = req.parsed.searchParams.get('timeout');
    const handler = functionHandler(config, logger, {
      protocolTimeout: timeout ? +timeout : undefined,
    });
    const { contentType, payload, page } = await handler(req, browser);

    logger.debug(`Got function response of "${contentType}"`);
    page.removeAllListeners();
    page.close().catch(() => {});

    if (contentType === 'uint8array') {
      const response = new Uint8Array(payload as Buffer);
      const type = ((await fileTypeFromBuffer(response)) || { mime: undefined })
        .mime;

      if (!type) {
        throw new BadRequest(`Couldn't determine function's response type.`);
      } else {
        logger.debug(`Sending file-type response of "${type}"`);
        const readStream = new Stream.PassThrough();
        readStream.end(response);
        res.setHeader('Content-Type', type);
        return new Promise((r) => readStream.pipe(res).once('close', r));
      }
    } else {
      writeResponse(res, 200, payload as string, contentType as contentTypes);
    }

    return;
  }
}