eio

type Config struct {
	PingInterval  time.Duration `yaml:"ping_interval" env-default:"30s" env:"EIO_PING_INTERVAL"`
	PingTimeout   time.Duration `yaml:"ping_timeout" env-default:"1m" env:"EIO_PING_TIMEOUT"`
	InitialPacket *eiop.Packet  `yaml:"initial_packet"`
}

type Emitter interface {
	Use(pattern string, middlewares ...func(event *emitter.Event))
	On(topic string, middlewares ...func(event *emitter.Event)) <-chan emitter.Event
	Once(topic string, middlewares ...func(event *emitter.Event)) <-chan emitter.Event
	Off(topic string, channels ...<-chan emitter.Event)
	Listeners(topic string) []<-chan emitter.Event
	Topics() []string
	Emit(topic string, args ...any) chan struct{}
	Fire(topic string, args ...any)
}

type HandshakeInterceptor func(query url.Values, headers map[string]string) bool

type Server interface {
	Emitter

	Cfg() Config
	Shutdown()
	HandleWebSocket(ws WebSocket) error
}

type Socket interface {
	io.Closer
	Emitter

	SID() string
	State() State
	Query() url.Values
	Headers() map[string]string
	Send(packet eiop.Packet)
}

type State byte

type WebSocket interface {
	io.Closer
	Emitter

	Query() url.Values
	Headers() map[string]string
	Write(packet eiop.Packet)
}