Function TestSessionSuccess

internal/sshserver/Server_test.go:212–245

(t *testing.T)

}

func TestSessionSuccess(t *testing.T) {
	//t.Parallel()()
	port := test.GetNextPort(t, "SSH")
	server := newServerHelper(
		t,
		fmt.Sprintf("127.0.0.1:%d", port),
		map[string][]byte{
			"foo": []byte("bar"),
		},
		map[string]string{},
	)
	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.Password("bar"),
		hostKey,
		[]byte("Hi"),
		nil,
		nil,
	)
	assert.Equal(t, []byte("Hello world!"), reply)
	assert.Equal(t, 0, exitStatus)
	assert.Equal(t, nil, err)
}

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