Function syncProjectViaGitBundle

src/node/runtime/gitBundleSync.ts:95–237

(params: GitBundleSyncParams)

}

export async function syncProjectViaGitBundle(params: GitBundleSyncParams): Promise<void> {
  const {
    projectPath,
    workspacePath,
    remoteTmpDir,
    remoteBundlePath,
    exec,
    quoteRemotePath,
    initLogger,
    logOriginErrors,
    abortSignal,
    createRemoteBundle,
    cloneStep,
  } = params;

  if (abortSignal?.aborted) {
    throw new Error("Sync operation aborted before starting");
  }

  const { originUrl } = await getOriginUrlForBundle(
    projectPath,
    initLogger,
    logOriginErrors ?? false
  );

  // Ensure the bundle exists on the remote runtime.
  initLogger.logStep("Creating git bundle...");
  let createResult: Awaited<ReturnType<GitBundleSyncParams["createRemoteBundle"]>>;
  try {
    createResult = await createRemoteBundle({ remoteBundlePath, initLogger, abortSignal });
  } catch (error) {
    // Best-effort cleanup (remote bundle may have been partially written).
    try {
      const rmStream = await exec(`rm -f ${quoteRemotePath(remoteBundlePath)}`, {
        cwd: remoteTmpDir,
        timeout: 10,
        abortSignal,
      });
      await rmStream.exitCode;
    } catch {
      // Ignore cleanup errors.
    }

    throw error;
  }

  try {
    // Clone from the bundle on the remote runtime.
    initLogger.logStep(cloneStep);
    const cloneStream = await exec(
      `${gitNoHooksPrefix(params.trusted)}git clone --quiet ${quoteRemotePath(remoteBundlePath)} ${quoteRemotePath(workspacePath)}`,
      {
        cwd: remoteTmpDir,
        timeout: 300,
        abortSignal,
      }
    );