Function readUpstreamHealth

src/remote/daemon-proxy.ts:89–102

(options: Required<DaemonProxyOptions>)

}

async function readUpstreamHealth(options: Required<DaemonProxyOptions>): Promise<unknown> {
  const upstreamUrl = new URL(buildDaemonHttpUrl(options.upstreamBaseUrl, 'health'));
  const response = await options.fetchImpl(upstreamUrl, {
    method: 'GET',
    headers: buildUpstreamHeaders({ headers: {} }, options.upstreamToken, '/health'),
    signal: AbortSignal.timeout(options.upstreamTimeoutMs),
  });
  const text = await response.text();
  try {
    return text ? JSON.parse(text) : { ok: response.ok, status: response.status };
  } catch {
    return { ok: response.ok, status: response.status };
  }
}

async function forwardProxyRequest(params: {
  req: IncomingMessage;