Method Apply

pkg/engine/apply.go:97–133

Side effects are running/applying changes concurrently and on success moving old "current" tag

(
	ctx context.Context,
	mo *SingleMethodObj,
	currentState plumbing.Hash,
	desiredState plumbing.Hash,
	targetPath string,
	tags *[]string,
)

// Side effects are running/applying changes concurrently and on success moving old "current" tag
func (fc *FetchitConfig) Apply(
	ctx context.Context,
	mo *SingleMethodObj,
	currentState plumbing.Hash,
	desiredState plumbing.Hash,
	targetPath string,
	tags *[]string,
) error {
	if desiredState.IsZero() {
		return errors.New("Cannot run Apply if desired state is empty")
	}
	directory := filepath.Base(mo.Target.Url)

	currentTree, err := getTreeFromHash(directory, currentState)
	if err != nil {
		return utils.WrapErr(err, "Error getting tree from hash %s", currentState)
	}

	desiredTree, err := getTreeFromHash(directory, desiredState)
	if err != nil {
		return utils.WrapErr(err, "Error getting tree from hash %s", desiredState)
	}

	changeMap, err := getFilteredChangeMap(directory, targetPath, currentTree, desiredTree, tags)
	if err != nil {
		return utils.WrapErr(err, "Error getting filtered change map from %s to %s", currentState, desiredState)
	}

	err = fc.runChangesConcurrent(ctx, mo, changeMap)
	if err != nil {
		return utils.WrapErr(err, "Error applying change from %s to %s for path %s in %s",
			currentState, desiredState, targetPath, directory,
		)
	}

	return nil
}

func getTreeFromHash(directory string, hash plumbing.Hash) (*object.Tree, error) {
	if hash.IsZero() {