Function uploadPack

packages/plugins/apps/src/git-client/transport.ts:158–226

(
  url: string,
  sha: string,
  opts: UploadPackOptions = {},
)

// POST /git-upload-pack, parse side-band, extract raw packfile bytes.
// Handles side-band-64k: band 1 = pack data, band 2 = progress, band 3 = error.
export async function uploadPack(
  url: string,
  sha: string,
  opts: UploadPackOptions = {},
): Promise<UploadPackResult> {
  const fetchImpl = opts.fetchImpl ?? fetch;
  const repo = normalizeRepoUrl(url);
  const upUrl = `${repo}/git-upload-pack`;
  const body = buildV1Request(sha);
  const t0 = Date.now();
  const res = await fetchGit(
    upUrl,
    {
      method: "POST",
      headers: {
        ...baseHeaders(opts.auth ?? {}),
        "content-type": "application/x-git-upload-pack-request",
        accept: "application/x-git-upload-pack-result",
        "git-protocol": "version=1",
      },
      body: new Uint8Array(body).buffer,
    },
    fetchImpl,
    { allowPrivateHosts: opts.allowPrivateHosts },
  );
  if (!res.ok) {
    const errText = await res.text();
    throw new Error(`upload-pack ${res.status}: ${errText.slice(0, 200)}`);
  }

  // Stream + demux side-band pkt-lines, with a byte cap on total downloaded.
  const reader = res.body!.getReader();
  const maxBytes = opts.maxBytes ?? Infinity;
  let downloaded = 0;
  let truncated = false;

  // Accumulate raw bytes, then demux pkt-lines. We buffer because pkt-lines can
  // straddle chunk boundaries; we cap the RAW download.
  const chunks: Uint8Array[] = [];
  while (true) {
    const { done, value } = await reader.read();
    if (done) break;
    if (value) {
      downloaded += value.length;
      chunks.push(value);
      if (downloaded >= maxBytes) {
        truncated = true;
        await reader.cancel();
        break;
      }
    }
  }
  const wallMs = Date.now() - t0;

  // concat
  const raw = new Uint8Array(downloaded);
  {
    let off = 0;