Method getCommand

pkg/devspace/services/proxycommands/server.go:126–197

(sess ssh.Session)

}

func (s *Server) getCommand(sess ssh.Session) (*exec.Cmd, *types.ProxyCommand, error) {
	var cmd *exec.Cmd
	rawCommand := sess.RawCommand()
	if len(rawCommand) == 0 {
		return nil, nil, fmt.Errorf("command required")
	}

	command := &types.ProxyCommand{}
	err := json.Unmarshal([]byte(rawCommand), &command)
	if err != nil {
		return nil, nil, fmt.Errorf("parse command: %v", err)
	} else if len(command.Args) == 0 {
		return nil, nil, fmt.Errorf("command is empty")
	}

	var reverseCommand *latest.ProxyCommand
	for _, r := range s.commands {
		if r.GitCredentials && command.Args[0] == "git-credentials" {
			reverseCommand = r
			break
		}
		if r.Command == command.Args[0] {
			reverseCommand = r
			break
		}
	}
	if reverseCommand == nil {
		return nil, nil, fmt.Errorf("command not allowed")
	}

	c := reverseCommand.Command
	if reverseCommand.LocalCommand != "" {
		c = reverseCommand.LocalCommand
	}
	if reverseCommand.GitCredentials {
		c = "git"
	}

	args := []string{}
	for _, arg := range command.Args[1:] {
		splitted := strings.Split(arg, "=")
		if len(splitted) == 1 {
			args = append(args, s.transformPath(arg))
			continue
		}

		args = append(args, splitted[0]+"="+s.transformPath(strings.Join(splitted[1:], "=")))
	}

	cmd = exec.Command(c, args...)
	cmd.Dir = s.transformPath(command.WorkingDir)

	// make sure working dir exists otherwise we get an error
	_, err = os.Stat(cmd.Dir)
	if err != nil {
		s.log.Debugf("unknown working dir: %s", cmd.Dir)
		cmd.Dir = os.TempDir()
	}