Function rewriteUploadPreflightResponse

src/remote/daemon-proxy.ts:171–206

(
  body: string,
  req: IncomingMessage,
  clientToken: string,
)

}

function rewriteUploadPreflightResponse(
  body: string,
  req: IncomingMessage,
  clientToken: string,
): string {
  let parsed: unknown;
  try {
    parsed = JSON.parse(body) as unknown;
  } catch {
    return body;
  }

  if (!parsed || typeof parsed !== 'object') return body;
  const record = parsed as { upload?: { url?: unknown; headers?: unknown } };
  if (!record.upload || typeof record.upload.url !== 'string') {
    return body;
  }

  const rewrittenUrl = rewriteUploadDirectUrl(record.upload.url, req);
  if (!rewrittenUrl) return body;

  const headers =
    record.upload.headers && typeof record.upload.headers === 'object'
      ? { ...(record.upload.headers as Record<string, unknown>) }
      : {};
  Object.assign(headers, buildDaemonHttpAuthHeaders(clientToken));

  return JSON.stringify({
    ...(parsed as Record<string, unknown>),
    upload: {
      ...record.upload,
      url: rewrittenUrl,
      headers,
    },
  });
}

function rewriteUploadDirectUrl(upstreamUrl: string, req: IncomingMessage): string | null {
  let parsed: URL;