Method Run

internal/util/update/update.go:140–197

Run runs the Command.

()

// Run runs the Command.
func (u Command) Run() error {
	if u.Output == nil {
		u.Output = os.Stdout
	}

	kptfile, err := kptfileutil.ReadFileStrict(u.Path)
	if err != nil {
		return errors.Errorf("unable to read package Kptfile: %v", err)
	}

	// default arguments
	if u.Repo == "" {
		u.Repo = kptfile.Upstream.Git.Repo
	}
	if u.Ref == "" {
		u.Ref = kptfile.Upstream.Git.Ref
	}

	// require package is checked into git before trying to update it
	g := gitutil.NewLocalGitRunner("./")
	if err := g.Run("status", "-s", u.Path); err != nil {
		return errors.Errorf(
			"kpt packages must be checked into a git repo before they are updated: %v", err)
	}
	if strings.TrimSpace(g.Stdout.String()) != "" {
		return errors.Errorf("must commit package %q to git before attempting to update",
			u.Path)
	}

	// update
	updater, found := strategies[u.Strategy]
	if !found {
		return errors.Errorf("unrecognized update strategy %q", u.Strategy)
	}
	err = updater().Update(UpdateOptions{
		KptFile:        kptfile,
		ToRef:          u.Ref,
		ToRepo:         u.Repo,
		PackagePath:    u.Path,
		AbsPackagePath: u.FullPackagePath,
		DryRun:         u.DryRun,
		Verbose:        u.Verbose,
		SimpleMessage:  u.SimpleMessage,
		Output:         u.Output,
		AutoSet:        u.AutoSet,
	})

	if err != nil {
		return err
	}

	// perform auto-setters after the package is updated
	a := setters.AutoSet{
		Writer:      u.Output,
		PackagePath: u.Path,
	}
	return a.PerformAutoSetters()
}