sio

type Adapter interface {
	Broadcast(packet siop.Packet, rooms []string, excluded ...string)
	Add(room string, sck Socket)
	Remove(room string, sck Socket)
	Clients(room string) []Socket
	Rooms(client Socket) []string
}

type AdapterFactory func(nsp Namespace) Adapter

type Client interface {
	SID() string
	Query() url.Values
	Headers() map[string]string
	Conn() eio.Socket
	Send(packet siop.Packet)
	Remove(sck Socket)
	Disconnect()
}

type Config struct {
	ConnectionTimeout time.Duration `yaml:"connection_timeout" env-default:"90s" env:"SIO_CONNECTION_TIMEOUT"`
}

type Namespace interface {
	eio.Emitter

	NextAckID() uint64
	Name() string
	Server() Server
	Adapter() Adapter
	Add(client Client, data any) Socket
	Remove(sck Socket)
	AddConnected(sck Socket)
	RemoveConnected(sck Socket)
	ConnectedSockets() map[string]Socket
	Broadcast(rooms []string, event string, args ...any)
}

type ReceivedByLocalAck func(args ...any)

type ReceivedByRemoteAck func(args ...any)

type Server interface {
	Cfg() Config
	Shutdown()
	AdapterFactory() AdapterFactory
	HasNamespace(nsp string) bool
	Namespace(nsp string) Namespace
}

type Socket interface {
	eio.Emitter

	SID() string
	Namespace() Namespace
	ConnectData() any
	Query() url.Values
	Headers() map[string]string
	Disconnect(close bool)
	Broadcast(rooms []string, event string, args ...any)
	Send(remoteAck ReceivedByRemoteAck, event string, args ...any)
	JoinRooms(rooms ...string)
	LeaveRooms(rooms ...string)
	LeaveAllRooms()
	OnEvent(packet siop.Packet)
	OnAck(packet siop.Packet)
	OnPacket(packet siop.Packet)
	OnConnect()
	OnDisconnect()
	OnError(msg string, err error)
	OnClose(reason, description string)
	SendPacket(packet siop.Packet)
}