Method Cleaned

core/git_local.go:82–202

(ctx context.Context)

}

func (repo *LocalGitRepository) Cleaned(ctx context.Context) (inst dagql.ObjectResult[*Directory], rerr error) {
	srv := dagql.CurrentDagqlServer(ctx)
	query, err := CurrentQuery(ctx)
	if err != nil {
		return inst, err
	}
	cache := query.SnapshotManager()

	parent, err := repo.Directory.Self().Snapshot.GetOrEval(ctx, repo.Directory.Result)
	if err != nil {
		return inst, fmt.Errorf("get git directory snapshot: %w", err)
	}
	repoDirPath, err := repo.Directory.Self().Dir.GetOrEval(ctx, repo.Directory.Result)
	if err != nil {
		return inst, fmt.Errorf("get git directory path: %w", err)
	}

	bkref, err := cache.New(ctx, parent,
		bkcache.WithRecordType(bkclient.UsageRecordTypeRegular),
		bkcache.WithDescription("git cleaned worktree"))

	if err != nil {
		return inst, err
	}
	defer func() {
		if rerr != nil && bkref != nil {
			bkref.Release(context.WithoutCancel(ctx))
		}
	}()
	skip := false
	err = MountRef(ctx, bkref, func(parentRoot string, _ *mount.Mount) error {
		src, err := fs.RootPath(parentRoot, repoDirPath)
		if err != nil {
			return err
		}

		git := gitutil.NewGitCLI(gitutil.WithDir(src))
		worktree, err := git.WorkTree(ctx)
		if err != nil {
			return err
		}
		if worktree == "" {
			skip = true // no worktree, no changes
			return nil
		}
		gitDir, err := git.GitDir(ctx)
		if err != nil {
			return err
		}

		idx, err := os.Open(filepath.Join(gitDir, "index"))
		if err != nil {
			return err
		}
		defer idx.Close()

		// NOTE: apply the index to a temp file because "git restore --staged"
		// re-writes the index which we don't want to show up as a changed file