Method execCommand

pkg/devspace/sync/upstream.go:334–431

(exec latest.SyncExec, changedFiles []string)

}

func (u *upstream) execCommand(exec latest.SyncExec, changedFiles []string) error {
	matched := ""
	if len(exec.OnChange) > 0 {
	Outer:
		for _, pattern := range exec.OnChange {
			pattern = path.Clean(pattern)
			for _, file := range changedFiles {
				if len(file) == 1 {
					continue
				}

				hasMatched, _ := doublestar.Match(pattern, file[1:])
				if hasMatched {
					matched = file[1:]
					break Outer
				}
			}
		}
		if matched == "" {
			return nil
		}
	}

	execCommand := exec.Command
	execArgs := exec.Args
	if u.sync.Options.ResolveCommand != nil {
		var err error
		execCommand, execArgs, err = u.sync.Options.ResolveCommand(execCommand, execArgs)
		if err != nil {
			return errors.Wrap(err, "resolve command")
		}
	}

	execCommandName := exec.Name
	if execCommandName == "" {
		execCommandName = command.FormatCommandName(execCommand, execArgs)
	}

	if exec.Local {
		if matched != "" {
			u.sync.log.Infof("Upstream - Execute command '%s' locally, because '%s' changed", execCommandName, matched)
		} else {
			u.sync.log.Infof("Upstream - Execute command '%s' locally", execCommandName)
		}

		// if args are nil we execute the command in a shell
		var (
			err error
			out = &bytes.Buffer{}
		)
		if exec.Args == nil {
			err = engine.ExecuteSimpleShellCommand(u.sync.ctx, u.sync.LocalPath, expand.ListEnviron(os.Environ()...), out, out, nil, execCommand)
		} else {
			err = command.Command(u.sync.ctx, u.sync.LocalPath, expand.ListEnviron(os.Environ()...), out, out, nil, execCommand, exec.Args...)
		}
		if err != nil {
			if exec.FailOnError {
				return fmt.Errorf("error executing command %s: %s %v", execCommandName, out.String(), err)