Method makeVerifyWalkerFunc

cli/command_snapshot_verify.go:101–174

(ctx context.Context, rep repo.Repository, v *snapshotfs.Verifier)

}

func (c *commandSnapshotVerify) makeVerifyWalkerFunc(ctx context.Context, rep repo.Repository, v *snapshotfs.Verifier) func(tw *snapshotfs.TreeWalker) error {
	return func(tw *snapshotfs.TreeWalker) error {
		manifests, err := c.loadSourceManifests(ctx, rep)
		if err != nil {
			return err
		}

		snapIDManifests, err := c.loadSnapIDManifests(ctx, rep)
		if err != nil {
			return err
		}

		manifests = append(manifests, snapIDManifests...)

		type twEntry struct {
			root     fs.Entry
			rootPath string
		}

		var treeWalkerEntries []twEntry

		for _, man := range manifests {
			rootPath := fmt.Sprintf("%v@%v", man.Source, formatTimestamp(man.StartTime.ToTime()))

			if man.RootEntry == nil {
				continue
			}

			root, err := snapshotfs.SnapshotRoot(rep, man)
			if err != nil {
				return errors.Wrapf(err, "unable to get snapshot root: %q", rootPath)
			}

			treeWalkerEntries = append(treeWalkerEntries, twEntry{
				root:     root,
				rootPath: rootPath,
			})

			if err := addExpectedWorkFromDirSummaryToVerifier(ctx, v, root); err != nil {
				return errors.Wrapf(err, "unable to set stat totals from summary")
			}
		}

		for _, twEntry := range treeWalkerEntries {
			// ignore error now, return aggregate error at a higher level.
			//nolint:errcheck
			tw.Process(ctx, twEntry.root, twEntry.rootPath)
		}

		for _, oidStr := range c.verifyCommandDirObjectIDs {
			oid, err := snapshotfs.ParseObjectIDWithPath(ctx, rep, oidStr)
			if err != nil {
				return errors.Wrapf(err, "unable to parse: %q", oidStr)
			}

			// ignore error now, return aggregate error at a higher level.
			//nolint:errcheck
			tw.Process(ctx, snapshotfs.DirectoryEntry(rep, oid, nil), oidStr)