mqtt

type Client interface {
	// Connect connect with MQTT broker and send CONNECT MQTT request
	Connect(ctx context.Context) (*ConnAck, error)

	// Disconnect disconnect from MQTT broker
	Disconnect(ctx context.Context, reasonCode DisconnectReasonCode, props *DisconnectProperties) error

	// Subscribe send MQTT Subscribe request to the broker with the given Subscription parameter and it's
	// properties, and a message channel through which the published messages are returned for the given
	// subscribed topics.
	// The function waits for the the MQTT SUBSCRIBE response, SubAck, or a packet timeout
	// configured as part of the Client options
	// Note: the subscriptions input may contain more than one topic, the associated
	// MessageReceiver is valid for all the topics present in the given subscriptions.
	Subscribe(ctx context.Context, subscriptions []*Subscription, props *SubscribeProperties, recvr *MessageReceiver) (*SubAck, error)

	// CallbackSubscribe send MQTT Subscribe request to the broker with the given Subscription parameter and it's
	// properties, and a callback handler through which the published messages are returned for the given subscribed topics.
	// The function waits for the the MQTT SUBSCRIBE response, SubAck, or a packet timeout
	// configured as part of the Client options
	// Note: the input Subscribe parameter can contain more than one topic, the associated
	// Callback handler is valid for all the topics present in the given Subscribe.
	CallbackSubscribe(ctx context.Context, subscriptions []*Subscription, props *SubscribeProperties, cb MessageHandler) (*SubAck, error)

	// Unsubscribe send MQTT UNSUBSCRIBE request to the broker with the given topic filters and it's properties.
	// The function waits for the the MQTT SUBSCRIBE response, SubAck, or for a packet timeout
	Unsubscribe(ctx context.Context, topicFilters []string, props *UnsubscribeProperties) (*UnsubAck, error)

	// Publish send MQTT PUBLISH packet to the MQTT broker. When the QoS is 1 or 2
	// the function waits for a response from the broker and for QoS 0 the function
	// complets immediately after the PUBLISH message is scheduled to send.
	Publish(ctx context.Context, topic string, qosLevel byte, retain bool, payload []byte, props *PublishProperties) error

	// On map the callback argument with the event name, more than one
	// callback can be added for a particular event name
	On(eventName string, callback interface{}) error

	// Off remove the callback associated with the event name
	Off(eventName string, callback interface{}) error
}

type ClientOption func(*clientOptions) error

type ConnAck struct {
	SessionPresent bool
	ReasonCode     ConnAckReasonCode
	Properties     *ConnAckProperties
}

type ConnAckProperties struct {
	SessionExpiryInterval           *uint32
	ReceiveMaximum                  *uint16
	MaximumQoS                      *byte
	RetainAvailable                 *bool
	MaximumPacketSize               *uint32
	AssignedClientIdentifier        string
	TopicAliasMaximum               *uint16
	ReasonString                    string
	UserProperty                    map[string]string
	WildcardSubscriptionAvailable   *bool
	SubscriptionIdentifierAvailable *bool
	SharedSubscriptionAvailable     *bool
	ServerKeepAlive                 *uint16
	ResponseInformation             string
	ServerReference                 string
	AuthenticationMethod            string
	AuthenticationData              []byte
}

type ConnAckReasonCode byte

type Connect struct {
	CleanStart     bool
	KeepAlive      uint16
	WillFlag       bool
	WillQoS        byte
	WillRetain     bool
	WillTopic      string
	WillPayload    []byte
	WillProperties *WillProperties
	Properties     *ConnectProperties
	ClientID       string
	UserName       string
	Password       []byte
	// contains filtered or unexported fields
}

type ConnectProperties struct {
	SessionExpiryInterval *uint32
	ReceiveMaximum        *uint16
	MaximumPacketSize     *uint32
	TopicAliasMaximum     *uint16
	RequestProblemInfo    *bool
	RequestResponseInfo   *bool
	UserProperty          map[string]string
	AuthenticationMethod  string
	AuthenticationData    []byte
}

type Connection interface {
	BrokerURL() string
	// Connect MQTT client calls Connect when it needs a io read writer.
	// If the Connect returns an error during reconenct then the MQTT client will
	// attempt a reconnect again. The reconnect interval depends on backoff delay
	Connect(ctx context.Context) (io.ReadWriter, error)
	// Closes the network connection
	Close()
}

type Disconnect struct {
	ReasonCode DisconnectReasonCode
	Properties *DisconnectProperties
}

type DisconnectProperties struct {
	SessionExpiryInterval *uint32
	ReasonString          string
	UserProperty          map[string]string
	ServerReference       string
}

type DisconnectReasonCode byte

type DisconnectedEventFn = func(err error)

type EventEmitter interface {
	On(eventName string, callback interface{}) error
	Off(eventName string, callback interface{}) error
}

type MessageHandler func(*Publish)

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

type PubAck struct {
	ReasonCode PubAckReasonCode
	Properties *PublishResponseProperties
	// contains filtered or unexported fields
}

type PubAckReasonCode byte

type PubComp struct {
	ReasonCode PubCompReasonCode
	Properties *PublishResponseProperties
	// contains filtered or unexported fields
}

type PubCompReasonCode byte

type PubRec struct {
	ReasonCode PubRecReasonCode
	Properties *PublishResponseProperties
	// contains filtered or unexported fields
}

type PubRecReasonCode byte

type PubRel struct {
	ReasonCode PubRelReasonCode
	Properties *PublishResponseProperties
	// contains filtered or unexported fields
}

type PubRelReasonCode byte

type Publish struct {
	QoSLevel  byte
	DUPFlag   bool
	Retain    bool
	TopicName string

	Properties *PublishProperties
	Payload    []byte
	// contains filtered or unexported fields
}

type PublishProperties struct {
	PayloadFormatIndicator  *bool
	MessageExpiryInterval   *uint32
	TopicAlias              *uint16
	ResponseTopic           string
	CorrelationData         []byte
	UserProperty            map[string]string
	SubscriptionIdentifiers []uint32
	ContentType             string
}

type PublishResponseProperties struct {
	ReasonString string
	UserProperty map[string]string
}

type ReconnectedEventFn = func(connack *ConnAck)

type ReconnectingEventFn = func(str string)

type ResubscribeEventFn = func(resubscribeResult ResubscribeResult)

type ResubscribeResult struct {
	Subscribe *Subscribe
	SubAck    *SubAck
	Error     error
}

type SubAck struct {
	Properties  *SubAckProperties
	ReasonCodes []SubAckReasonCode
	// contains filtered or unexported fields
}

type SubAckProperties struct {
	ReasonString string
	UserProperty map[string]string
}

type SubAckReasonCode byte

type Subscribe struct {
	Subscriptions []*Subscription
	Properties    *SubscribeProperties
	// contains filtered or unexported fields
}

type SubscribeProperties struct {
	SubscriptionIdentifier *uint32
	UserProperty           map[string]string
}

type Subscription struct {
	TopicFilter       string
	QoSLevel          byte
	NoLocal           bool
	RetainAsPublished bool
	RetainHandling    byte
}

type TCPConn struct {
	Host      string
	TLSConfig *tls.Config
	// contains filtered or unexported fields
}

type UnsubAck struct {
	Properties  *UnsubAckProperties
	ReasonCodes []UnsubAckReasonCode
	// contains filtered or unexported fields
}

type UnsubAckProperties struct {
	ReasonString string
	UserProperty map[string]string
}

type UnsubAckReasonCode byte

type Unsubscribe struct {
	Properties   *UnsubscribeProperties
	TopicFilters []string
	// contains filtered or unexported fields
}

type UnsubscribeProperties struct {
	UserProperty map[string]string
}

type WebsocketConn struct {
	Host      string
	TLSConfig *tls.Config
	// contains filtered or unexported fields
}

type WillMessage struct {
	QoS        byte
	Retain     bool
	Topic      string
	Payload    []byte
	Properties *WillProperties
}

type WillProperties struct {
	WillDelayInterval      *uint32
	PayloadFormatIndicator *bool
	MessageExpiryInterval  *uint32
	ContentType            string
	ResponseTopic          string
	CorrelationData        []byte
	UserProperty           map[string]string
}