Function forwardProxyRequest

src/remote/daemon-proxy.ts:104–124

(params: {
  req: IncomingMessage;
  res: ServerResponse;
  route: string;
  options: Required<DaemonProxyOptions>;
  rpcBody?: string;
})

}

async function forwardProxyRequest(params: {
  req: IncomingMessage;
  res: ServerResponse;
  route: string;
  options: Required<DaemonProxyOptions>;
  rpcBody?: string;
}): Promise<void> {
  const { req, res, route, options, rpcBody } = params;
  const upstreamUrl = buildUpstreamUrl(options.upstreamBaseUrl, route, req.url ?? '/');
  const method = req.method ?? 'GET';
  const headers = buildUpstreamHeaders(req, options.upstreamToken, route);
  const body = resolveUpstreamBody(req, route, rpcBody, options.upstreamToken);
  const response = await options.fetchImpl(upstreamUrl, {
    method,
    headers,
    signal: AbortSignal.timeout(options.upstreamTimeoutMs),
    ...(body ? { body, duplex: 'half' as const } : {}),
  });

  await sendProxyResponse({ req, res, route, response, clientToken: options.clientToken });
}

async function sendProxyResponse(params: {
  req: IncomingMessage;