Port connection info changes to v3 (#433) (#435)

* feat(nats): add compression config (#432)

In NATS client and server, if the connection uses websocket we can enable
compression by passing the Compression config - it needs to be enbaled on
both client and server conn setup. Thus creating a new config to enbale
on both sides - if not websocket, this config has no effect

* Port connection info changes to v2 (#433)

pkg/app.go

@@ -125,6 +125,8 @@ type Pitaya interface {
 	RegisterModuleAfter(module interfaces.Module, name string) error
 	RegisterModuleBefore(module interfaces.Module, name string) error
 	GetModule(name string) (interfaces.Module, error)
+
+	GetNumberOfConnectedClients() int64
 }
 
 // App is the base app struct
@@ -553,3 +555,8 @@ func (app *App) RegisterRPCJob(rpcJob worker.RPCJob) error {
 	err := app.worker.RegisterRPCJob(rpcJob)
 	return err
 }
+
+// GetNumberOfConnectedClients returns the number of connected clients
+func (app *App) GetNumberOfConnectedClients() int64 {
+	return app.sessionPool.GetSessionCount()
+}

pkg/session/session.go

@@ -64,6 +64,7 @@ type SessionPool interface {
 	OnSessionClose(f func(s Session))
 	CloseAll()
 	AddHandshakeValidator(name string, f func(data *HandshakeData) error)
+	GetNumberOfConnectedClients() int64
 }
 
 // HandshakeClientData represents information about the client sent on the handshake.
@@ -310,6 +311,11 @@ func (pool *sessionPoolImpl) AddHandshakeValidator(name string, f func(data *Han
 	pool.handshakeValidators[name] = f
 }
 
+// GetNumberOfConnectedClients returns the number of connected clients
+func (pool *sessionPoolImpl) GetNumberOfConnectedClients() int64 {
+	return pool.GetSessionCount()
+}
+
 func (s *sessionImpl) updateEncodedData() error {
 	var b []byte
 	b, err := json.Marshal(s.data)

pkg/session/session_test.go

@@ -1507,3 +1507,18 @@ func TestSessionValidateHandshake(t *testing.T) {
 		})
 	}
 }
+
+func TestGetNumberOfConnectedClients(t *testing.T) {
+	ctrl := gomock.NewController(t)
+	defer ctrl.Finish()
+
+	entity := mocks.NewMockNetworkEntity(ctrl)
+	sessionPool := NewSessionPool()
+	connections := sessionPool.GetNumberOfConnectedClients()
+	assert.Equal(t, int64(0), connections)
+
+	ss := sessionPool.NewSession(entity, true)
+	assert.NotNil(t, ss)
+	connections = sessionPool.GetNumberOfConnectedClients()
+	assert.Equal(t, int64(1), connections)
+}

pkg/session/static.go

@@ -36,3 +36,8 @@ func OnSessionClose(f func(s Session)) {
 func CloseAll() {
 	DefaultSessionPool.CloseAll()
 }
+
+// GetNumberOfConnectedClients returns the number of connected clients
+func GetNumberOfConnectedClients() int64 {
+	return DefaultSessionPool.GetNumberOfConnectedClients()
+}

pkg/session/test/static_test.go

@@ -1,6 +1,7 @@
 package test
 
 import (
+	"math"
 	"testing"
 
 	"github.com/golang/mock/gomock"
@@ -115,3 +116,15 @@ func TestStaticCloseAll(t *testing.T) {
 	session.DefaultSessionPool = sessionPool
 	session.CloseAll()
 }
+
+func TestGetNumberOfConnectedClients(t *testing.T) {
+	ctrl := gomock.NewController(t)
+
+	expected := int64(math.MaxInt64)
+	sessionPool := mocks.NewMockSessionPool(ctrl)
+	sessionPool.EXPECT().GetNumberOfConnectedClients().Return(expected)
+
+	session.DefaultSessionPool = sessionPool
+	numberOfConnections := session.GetNumberOfConnectedClients()
+	require.Equal(t, expected, numberOfConnections)
+}

pkg/static.go

@@ -225,3 +225,7 @@ func RegisterModuleBefore(module interfaces.Module, name string) error {
 func GetModule(name string) (interfaces.Module, error) {
 	return DefaultApp.GetModule(name)
 }
+
+func GetNumberOfConnectedClients() int64 {
+	return DefaultApp.GetNumberOfConnectedClients()
+}

pkg/static_test.go

@@ -23,10 +23,12 @@ package pitaya
 import (
 	"context"
 	"errors"
-	"github.com/topfreegames/pitaya/v3/pkg/constants"
+	"math"
 	"testing"
 	"time"
 
+	"github.com/topfreegames/pitaya/v3/pkg/constants"
+
 	"github.com/golang/mock/gomock"
 	"github.com/golang/protobuf/proto"
 	"github.com/google/uuid"
@@ -922,3 +924,15 @@ func TestStaticGetModule(t *testing.T) {
 		})
 	}
 }
+
+func TestGetNumberOfConnectedClients(t *testing.T) {
+	ctrl := gomock.NewController(t)
+
+	expected := int64(math.MaxInt64)
+
+	app := mocks.NewMockPitaya(ctrl)
+	app.EXPECT().GetNumberOfConnectedClients().Return(expected)
+
+	DefaultApp = app
+	require.Equal(t, expected, GetNumberOfConnectedClients())
+}