Function rewriteUploadDirectUrl

src/remote/daemon-proxy.ts:208–232

(upstreamUrl: string, req: IncomingMessage)

}

function rewriteUploadDirectUrl(upstreamUrl: string, req: IncomingMessage): string | null {
  let parsed: URL;
  try {
    parsed = new URL(upstreamUrl);
  } catch {
    return null;
  }

  if (!parsed.pathname.startsWith('/upload/')) {
    return null;
  }

  const host = typeof req.headers.host === 'string' ? req.headers.host : '';
  if (!host) return null;

  const requestPath = new URL(req.url ?? '/', 'http://127.0.0.1').pathname;
  const uploadIndex = requestPath.lastIndexOf('/upload/preflight');
  const uploadPrefix = uploadIndex >= 0 ? requestPath.slice(0, uploadIndex) : '';
  const forwardedProto = req.headers['x-forwarded-proto'];
  const proto = Array.isArray(forwardedProto) ? forwardedProto[0] : forwardedProto;
  const rewritten = new URL(`${proto || 'http'}://${host}`);
  rewritten.pathname = `${uploadPrefix}${parsed.pathname}`;
  rewritten.search = parsed.search;
  return rewritten.toString();
}

async function pipeProxyResponseBody(response: Response, res: ServerResponse): Promise<void> {
  if (!response.body) {