mqtt

type Acl interface {
	AllowConnect(packet *ConnectPacket) error
	AllowPublish(session *Session, packet *PublishPacket) error
	AllowSubscribe(session *Session, packet *SubscribePacket) error
}

type AuthPacket struct {
}

type ConnackPacket struct {
	// contains filtered or unexported fields
}

type ConnectPacket struct {
	UsernameFlag bool
	PasswordFlag bool
	WillFlag     bool
	WillQoS      byte
	WillRetain   bool
	CleanSession bool
	KeepAlive    uint16
	ClientId     string
	WillTopic    string
	WillMessage  string
	Username     string
	Password     string
}

type DisconnectPacket struct {
}

type PingreqPacket struct {
}

type PingrespPacket struct {
}

type PubackPacket struct {
	// contains filtered or unexported fields
}

type PubcompPacket struct {
	// contains filtered or unexported fields
}

type PublishPacket struct {
	Duplicate bool
	Qos       byte
	Retain    bool
	Topic     string
	PacketId  uint16
	Payload   string
}

type PubrecPacket struct {
	// contains filtered or unexported fields
}

type PubrelPacket struct {
	// contains filtered or unexported fields
}

type Session struct {
	Conn   net.Conn
	Reader *bufio.Reader
	Writer io.Writer

	Handler       handler
	Acl           Acl
	Subscriptions []*topicLevel

	SendQueue    any
	ReceiveQueue any

	CleanSession bool
	WillFlag     bool
	WillRetained bool
	ClientId     string
	Username     string
	Password     string
	WillTopic    string
	WillMsg      string
	WillQos      byte
	KeepAlive    uint16
}

type SubackPacket struct {
	// contains filtered or unexported fields
}

type SubscribePacket struct {
	PacketId uint16
	Topics   []string
	Qos      []byte
}

type UnsubackPacket struct {
	// contains filtered or unexported fields
}

type UnsubscribePacket struct {
	// contains filtered or unexported fields
}