Method cloneWithProgress

src/node/services/projectService.ts:569–917

(
    input: CloneProjectParams,
    signal?: AbortSignal
  )

  }

  async *cloneWithProgress(
    input: CloneProjectParams,
    signal?: AbortSignal
  ): AsyncGenerator<CloneEvent> {
    const prepared = this.validateAndPrepareClone(input);
    if (!prepared.success) {
      yield { type: "error", code: "clone_failed", error: prepared.error };
      return;
    }

    const { cloneUrl, normalizedPath, cloneParentDir } = prepared.data;
    const cloneWorkPath = `${normalizedPath}.mux-clone-${randomBytes(6).toString("hex")}`;
    let cloneSucceeded = false;
    // Preserve full stderr so failed clones can surface git's fatal message instead of only exit code 128.
    let collectedStderr = "";
    let askpass: Awaited<ReturnType<typeof createMediatedAskpassSession>> | undefined;

    const cleanupPartialClone = async () => {
      if (cloneSucceeded) {
        return;
      }

      try {
        // Only clean up the temp clone path we created so we never delete
        // a destination directory that another process created concurrently.
        await fsPromises.rm(cloneWorkPath, { recursive: true, force: true });
      } catch {
        // Ignore cleanup errors — the original error is more important.
      }
    };

    try {
      if (signal?.aborted) {
        yield { type: "error", code: "clone_failed", error: "Clone cancelled" };
        return;
      }

      let cloneParentStat: Stats | null = null;
      try {
        cloneParentStat = await fsPromises.stat(cloneParentDir);
      } catch (error) {
        const err = error as NodeJS.ErrnoException;
        if (err.code !== "ENOENT") {
          throw error;
        }
      }

      if (cloneParentStat && !cloneParentStat.isDirectory()) {
        yield {
          type: "error",
          code: "clone_failed",
          error: "Clone destination parent directory is not a directory",
        };
        return;
      }

      let destinationStat: Stats | null = null;
      try {