Function handleProxyRequest

src/remote/daemon-proxy.ts:46–80

(
  req: IncomingMessage,
  res: ServerResponse,
  options: Required<DaemonProxyOptions>,
)

}

async function handleProxyRequest(
  req: IncomingMessage,
  res: ServerResponse,
  options: Required<DaemonProxyOptions>,
): Promise<void> {
  const route = resolveProxyRoute(req.url ?? '/');
  if (req.method === 'GET' && route === '/health') {
    await sendProxyHealth(res, options);
    return;
  }

  if (!isSupportedDaemonRoute(route, req.method)) {
    res.statusCode = 404;
    res.end('Not found');
    return;
  }

  let rpcBody: string | undefined;
  if (route === '/rpc') {
    rpcBody = (
      await readNodeHttpRequestBody(
        req,
        options.maxRpcBodyBytes,
        'Proxy request body is too large.',
      )
    ).toString('utf8');
  }

  if (!isAuthorized(req, options.clientToken, rpcBody)) {
    sendUnauthorized(res, route, readJsonRpcId(rpcBody));
    return;
  }

  await forwardProxyRequest({ req, res, route, options, rpcBody });
}

async function sendProxyHealth(res: ServerResponse, options: Required<DaemonProxyOptions>) {
  const upstream = await readUpstreamHealth(options);