sckio

type AppSocket interface {
	CurrentUser() sdkcm.Requester
	Socket
}

type Config struct {
	Name          string
	MaxConnection int
}

type ObserverProvider interface {
	AddObservers(server *socketio.Server, sc goservice.ServiceContext, l logger.Logger) func(socketio.Conn) error
}

type Socket interface {
	ID() string
	Close() error
	URL() url.URL
	LocalAddr() net.Addr
	RemoteAddr() net.Addr
	RemoteHeader() http.Header

	Context() interface{}
	SetContext(v interface{})
	Namespace() string
	Emit(msg string, v ...interface{})

	Join(room string)
	Leave(room string)
	LeaveAll()
	Rooms() []string
}

type SocketServer interface {
	UserSockets(userId int) []AppSocket
	EmitToRoom(room string, key string, data interface{}) error
	EmitToUser(userId int, key string, data interface{}) error
	StartRealtimeServer(engine *gin.Engine, sc goservice.ServiceContext, op ObserverProvider)
	GetSocketServer() *socketio.Server
	SaveAppSocket(userId int, appSck AppSocket)
}