Method start

internal/sshserver/Server_test.go:534–579

(t *testing.T)

}

func (h *serverHelper) start(t *testing.T) (hostKey []byte, err error) {
	if h.server != nil {
		return nil, fmt.Errorf("server already running")
	}
	cfg := config.SSHConfig{}
	structutils.Defaults(&cfg)
	cfg.Listen = h.listen
	if err := cfg.GenerateHostKey(); err != nil {
		return nil, err
	}
	private, err := ssh.ParsePrivateKey([]byte(cfg.HostKeys[0]))
	if err != nil {
		return nil, err
	}
	hostKey = private.PublicKey().Marshal()
	logger := log.NewTestLogger(t)
	readyChannel := make(chan struct{}, 1)
	h.shutdownChannel = make(chan struct{}, 1)
	errChannel := make(chan error, 1)
	handler := newFullHandler(
		readyChannel,
		h.shutdownChannel,
		h.passwords,
		h.pubKeys,
	)
	server, err := sshserver.New(cfg, handler, logger)
	if err != nil {
		return hostKey, err
	}
	lifecycle := service.NewLifecycle(server)
	h.lifecycle = lifecycle
	go func() {
		err = lifecycle.Run()
		if err != nil {
			errChannel <- err
		}
	}()
	//Wait for the server to be ready
	select {
	case err := <-errChannel:
		return hostKey, err
	case <-readyChannel:
	}
	h.server = server
	return hostKey, nil
}

func (h *serverHelper) stop() {
	if h.lifecycle != nil {