model

type Client struct {
	ID           int64
	ClientId     string
	Username     string
	Password     []byte
	SubscribeAcl string
	PublishAcl   string
	CreatedAt    int64
}

type Connections interface {
	Add(clientId string, conn TagyouConn)
	Exists(clientId string) (TagyouConn, bool)
	Close(clientId string) error
	Remove(clientId string)
}

type Engine interface {
	OnConnect(session *RunningSession)
	OnPing(session *RunningSession)
	OnSubscribe(session *RunningSession, p Packet)
	OnUnsubscribe(session *RunningSession, p Packet)
	OnPublish(session *RunningSession, p Packet)
	OnClientPuback(session *RunningSession, p Packet)
	OnClientPubrec(session *RunningSession, p Packet)
	OnClientPubrel(session *RunningSession, p Packet)
	OnClientPubcomp(clientId string, packetIdentifier int, reasonCode uint8)
	OnClientDisconnect(session *RunningSession, clientId string)
	// connection status
	OnSocketUpButSilent(session *RunningSession) bool
	OnSocketDownClosed(session *RunningSession) bool
}

type Message struct {
	Topic       string
	Qos         byte
	Retained    bool
	Payload     string
	PayloadType byte
}

type Packet interface {
	QoS() byte
	Retain() bool
	ApplicationMessage() []byte
	PacketIdentifier() int
	Dup() bool
	GetPublishTopic() string
	GetReasonCode() uint8
	GetSubscriptions() []Subscription
	PacketType() byte
}

type Retain struct {
	ClientID           string
	Topic              string
	ApplicationMessage []byte
	CreatedAt          int64
}

type Retry struct {
	ID                 int64
	ClientId           string
	ApplicationMessage []byte
	PacketIdentifier   int
	Qos                uint8
	Dup                bool
	Retries            uint8
	AckStatus          uint8
	CreatedAt          int64
	SessionID          int64
	ReasonCode         uint8
}

type Router interface {
	Send(clientId string, payload []byte)
	Forward(senderId string, topic string, packet Packet)
	SendRetain(protocolVersion uint8, subscription Subscription)
	AddDestination(clientId string, conn TagyouConn)
	RemoveDestination(clientId string)
	DestinationExists(clientId string) bool
	GetConns() Connections
}

type RunningSession struct {
	ID              int64
	SessionID       int64
	ClientId        string
	ProtocolVersion uint8
	LastSeen        int64
	LastConnect     int64
	Connected       bool
	ExpiryInterval  int64
	ConnectFlags    uint8
	KeepAlive       int
	WillTopic       string
	WillDelay       int64
	WillMessage     []byte
	Username        string
	Password        string
	SubscribeAcl    string
	PublishAcl      string
	Router          Router
	Engine          Engine
	Conn            TagyouConn
	Mu              sync.RWMutex
}

type Session struct {
	ID              int64
	LastSeen        int64
	LastConnect     int64
	ExpiryInterval  int64
	ClientId        string
	Connected       bool
	ProtocolVersion uint8
}

type SimpleConnections struct {
	Conns map[string]TagyouConn
	Mu    sync.RWMutex
}

type Subscription struct {
	ClientId          string
	Topic             string
	RetainHandling    uint8
	RetainAsPublished uint8
	NoLocal           uint8
	Qos               uint8
	ProtocolVersion   uint8
	Enabled           bool
	CreatedAt         int64
	SessionID         int64
	Shared            bool
	ShareName         string
}

type SubscriptionGroup map[string][]Subscription

type TagyouConn interface {
	Write(b []byte) (n int, err error)
	Close() error
	RemoteAddr() net.Addr
}

type User struct {
	ID        int64
	Username  string
	Password  []byte
	CreatedAt int64
}

type WebsocketConnection struct {
	Conn *websocket.Conn
}