Method snapshotSingleSource

cli/command_snapshot_create.go:284–390

nolint:gocyclo,funlen

(
	ctx context.Context,
	fsEntry fs.Entry,
	setManual bool,
	rep repo.RepositoryWriter,
	u *upload.Uploader,
	sourceInfo snapshot.SourceInfo,
	tags map[string]string,
	st *notifydata.MultiSnapshotStatus,
)

//nolint:gocyclo,funlen
func (c *commandSnapshotCreate) snapshotSingleSource(
	ctx context.Context,
	fsEntry fs.Entry,
	setManual bool,
	rep repo.RepositoryWriter,
	u *upload.Uploader,
	sourceInfo snapshot.SourceInfo,
	tags map[string]string,
	st *notifydata.MultiSnapshotStatus,
) (finalErr error) {
	log(ctx).Infof("Snapshotting %v ...", sourceInfo)

	var mwe notifydata.ManifestWithError

	mwe.Manifest.Source = sourceInfo

	st.Snapshots = append(st.Snapshots, &mwe)

	defer func() {
		if finalErr != nil {
			mwe.Error = finalErr.Error()
		}
	}()

	var previous []*snapshot.Manifest

	previous, finalErr = snapshot.FindPreviousManifests(ctx, rep, sourceInfo, nil)
	if finalErr != nil {
		return errors.Wrap(finalErr, "unable to find previous manifests")
	}

	if len(previous) > 0 {
		mwe.Previous = previous[0]
	}

	policyTree, finalErr := policy.TreeForSource(ctx, rep, sourceInfo)
	if finalErr != nil {
		return errors.Wrap(finalErr, "unable to get policy tree")
	}

	manifest, finalErr := u.Upload(ctx, fsEntry, policyTree, sourceInfo, previous...)
	if finalErr != nil {
		// fail-fast uploads will fail here without recording a manifest, other uploads will
		// possibly fail later.
		return errors.Wrap(finalErr, "upload error")
	}

	manifest.Description = c.snapshotCreateDescription
	manifest.Tags = tags
	manifest.UpdatePins(c.pins, nil)

	startTimeOverride, _ := parseTimestamp(c.snapshotCreateStartTime)
	endTimeOverride, _ := parseTimestamp(c.snapshotCreateEndTime)

	if !startTimeOverride.IsZero() {
		if endTimeOverride.IsZero() {
			// Calculate the correct end time based on current duration if they're not specified
			duration := manifest.EndTime.Sub(manifest.StartTime)