Method handler

pkg/devspace/services/proxycommands/server.go:81–124

(sess ssh.Session)

}

func (s *Server) handler(sess ssh.Session) {
	cmd, payload, err := s.getCommand(sess)
	if err != nil {
		s.exitWithError(sess, errors.Wrap(err, "construct command"))
		return
	}

	if ssh.AgentRequested(sess) {
		l, err := ssh.NewAgentListener()
		if err != nil {
			s.exitWithError(sess, errors.Wrap(err, "start agent"))
			return
		}

		defer l.Close()
		go ssh.ForwardAgentConnections(l, sess)
		cmd.Env = append(cmd.Env, fmt.Sprintf("%s=%s", "SSH_AUTH_SOCK", l.Addr().String()))
	}

	// start shell session
	if payload.TTY && runtime.GOOS != "windows" {
		winSizeChan := make(chan ssh.Window, 1)
		winSizeChan <- ssh.Window{
			Width:  payload.Width,
			Height: payload.Height,
		}
		err = sshhelper.HandlePTY(sess, ssh.Pty{
			Term: "xterm",
			Window: ssh.Window{
				Width:  payload.Width,
				Height: payload.Height,
			},
		}, winSizeChan, cmd, func(reader io.Reader) io.Reader {
			return reader
		})
	} else {
		err = sshhelper.HandleNonPTY(sess, cmd, func(reader io.Reader) io.Reader {
			return NewRewriter(reader, s.rewriteMappings)
		})
	}

	// exit session
	s.exitWithError(sess, err)
}

func (s *Server) getCommand(sess ssh.Session) (*exec.Cmd, *types.ProxyCommand, error) {
	var cmd *exec.Cmd