mqtt

type BytesPayload []byte

type ConnAck struct {
	Header
	SessionPresent bool
	ReturnCode     ReturnCode
}

type Connect struct {
	Header
	ProtocolName               string
	ProtocolVersion            uint8
	WillRetain                 bool
	WillFlag                   bool
	CleanSession               bool
	WillQos                    QosLevel
	KeepAliveTimer             uint16
	ClientId                   string
	WillTopic, WillMessage     string
	UsernameFlag, PasswordFlag bool
	Username, Password         string
}

type DecoderConfig interface {
	// MakePayload returns a Payload for the given Publish message. r is a Reader
	// that will read the payload data, and n is the number of bytes in the
	// payload. The Payload.ReadPayload method is called on the returned payload
	// by the decoding process.
	MakePayload(msg *Publish, r io.Reader, n int) (Payload, error)
}

type DefaultDecoderConfig struct{}

type Disconnect struct {
	Header
}

type Header struct {
	DupFlag, Retain bool
	QosLevel        QosLevel
}

type Message interface {
	// Encode writes the message to w.
	Encode(w io.Writer) error

	// Decode reads the message extended headers and payload from
	// r. Typically the values for hdr and packetRemaining will
	// be returned from Header.Decode.
	Decode(r io.Reader, hdr Header, packetRemaining int32, config DecoderConfig) error
}

type MessageType uint8

type Payload interface {
	// Size returns the number of bytes that WritePayload will write.
	Size() int

	// WritePayload writes the payload data to w. Implementations must write
	// Size() bytes of data, but it is *not* required to do so prior to
	// returning. Size() bytes must have been written to w prior to another
	// message being encoded to the underlying connection.
	WritePayload(w io.Writer) error

	// ReadPayload reads the payload data from r (r will EOF at the end of the
	// payload). It is *not* required for r to have been consumed prior to this
	// returning. r must have been consumed completely prior to another message
	// being decoded from the underlying connection.
	ReadPayload(r io.Reader) error
}

type PingReq struct {
	Header
}

type PingResp struct {
	Header
}

type PubAck struct {
	Header
	MessageId uint16
}

type PubComp struct {
	Header
	MessageId uint16
}

type PubRec struct {
	Header
	MessageId uint16
}

type PubRel struct {
	Header
	MessageId uint16
}

type Publish struct {
	Header
	TopicName string
	MessageId uint16
	Payload   Payload
}

type QosLevel uint8

type ReturnCode uint8

type StreamedPayload struct {
	// N indicates payload size to the encoder. This many bytes will be read from
	// the reader when encoding. The number of bytes in the payload will be
	// stored here when decoding.
	N int

	// EncodingSource is used to copy data from when encoding a Publish message
	// onto the wire. This can be
	EncodingSource io.Reader

	// DecodingSink is used to copy data to when decoding a Publish message from
	// the wire. This can be nil if the payload is only being used for encoding.
	DecodingSink io.Writer
}

type SubAck struct {
	Header
	MessageId uint16
	TopicsQos []QosLevel
}

type Subscribe struct {
	Header
	MessageId uint16
	Topics    []TopicQos
}

type TopicQos struct {
	Topic string
	Qos   QosLevel
}

type UnsubAck struct {
	Header
	MessageId uint16
}

type Unsubscribe struct {
	Header
	MessageId uint16
	Topics    []string
}

type ValueConfig struct {
	Payload Payload
}