Function sendHttpRequest

src/daemon/client/daemon-client-transport.ts:362–454

(
  info: DaemonInfo,
  req: DaemonRequest,
  statePaths: DaemonPaths,
  timeoutMs: number | undefined,
  options: SendRequestOptions,
)

}

async function sendHttpRequest(
  info: DaemonInfo,
  req: DaemonRequest,
  statePaths: DaemonPaths,
  timeoutMs: number | undefined,
  options: SendRequestOptions,
): Promise<DaemonResponse> {
  const rpcUrl = info.baseUrl
    ? new URL(buildDaemonHttpUrl(info.baseUrl, 'rpc'))
    : info.httpPort
      ? new URL(`http://127.0.0.1:${info.httpPort}/rpc`)
      : null;
  if (!rpcUrl) throw new AppError('COMMAND_FAILED', DAEMON_HTTP_ENDPOINT_UNAVAILABLE_MESSAGE);
  const rpcPayload = JSON.stringify(buildHttpRpcPayload(req, { includeTokenParam: !info.baseUrl }));
  const headers: Record<string, string | number> = {
    'content-type': 'application/json',
    'content-length': Buffer.byteLength(rpcPayload),
  };
  if (info.baseUrl) {
    Object.assign(headers, buildDaemonHttpAuthHeaders(info.token));
  }

  return await new Promise((resolve, reject) => {
    const transport = rpcUrl.protocol === 'https:' ? https : http;
    const request = transport.request(
      {
        protocol: rpcUrl.protocol,
        host: rpcUrl.hostname,
        port: rpcUrl.port,
        method: 'POST',
        path: rpcUrl.pathname + rpcUrl.search,
        headers,
      },
      (res) => {
        if (shouldReadDaemonProgressStream(req, res.headers?.['content-type'])) {
          readDaemonHttpProgressResponse(res, {
            req,
            onProgress: options.onProgress,
            reject,
            clearTimeout: () => {
              if (timeoutHandle) clearTimeout(timeoutHandle);
            },
            handleResponseBody: (body) =>
              handleDaemonHttpResponseBody(body, { info, req, resolve, reject }),
          });
          return;
        }
        void readNodeHttpResponseBody(res)
          .then((body) => {
            if (timeoutHandle) clearTimeout(timeoutHandle);
            handleDaemonHttpResponseBody(body, { info, req, resolve, reject });
          })
          .catch((err: unknown) => {
            if (timeoutHandle) clearTimeout(timeoutHandle);
            reject(
              new AppError(
                'COMMAND_FAILED',
                'Failed to read daemon response',