Function TestPubKey

internal/sshserver/Server_test.go:282–324

(t *testing.T)

}

func TestPubKey(t *testing.T) {
	//t.Parallel()()
	port := test.GetNextPort(t, "SSH")
	rsaKey, err := rsa.GenerateKey(
		rand.Reader,
		4096,
	)
	assert.Nil(t, err, "failed to generate RSA key (%v)", err)
	signer, err := ssh.NewSignerFromKey(rsaKey)
	assert.Nil(t, err, "failed to create signer (%v)", err)
	publicKey := signer.PublicKey()
	authorizedKey := strings.TrimSpace(string(ssh.MarshalAuthorizedKey(publicKey)))
	server := newServerHelper(
		t,
		fmt.Sprintf("127.0.0.1:%d", port),
		map[string][]byte{},
		map[string]string{
			"foo": authorizedKey,
		},
	)
	hostKey, err := server.start(t)
	if err != nil {
		assert.Fail(t, "failed to start ssh server", err)
		return
	}
	defer func() {
		server.stop()
		<-server.shutdownChannel
	}()

	reply, exitStatus, err := shellRequestReply(
		fmt.Sprintf("127.0.0.1:%d", port),
		"foo",
		ssh.PublicKeys(signer),
		hostKey,
		[]byte("Hi"),
		nil,
		nil,
	)
	assert.Nil(t, err, "failed to send shell request (%v)", err)
	assert.Equal(t, 0, exitStatus)
	assert.Equal(t, []byte("Hello world!"), reply)
}

func TestKeepAlive(t *testing.T) {
	//t.Parallel()()