mqtt

type BrokerConfig struct {
	URL      string
	ClientID string
	Username string
	Password string
}

type Call struct {
	Topic     string
	Request   any
	Response  any
	QoS       int
	MaxWait   time.Duration
	Retain    bool
	Unmarshal func(payload []byte, resp any) error
}

type Config struct {
	Logger          *zerolog.Logger
	Broker          BrokerConfig
	MessageHandlers map[string]MessageHandler
	RequestHandlers map[string]RequestHandler
	HandlerTimeout  time.Duration
	Subscriptions   []string
	AutoSubscribe   bool
}

type Endpoint interface {
	Connect(ctx context.Context) error
	Disconnect(ctx context.Context) error
	Call(ctx context.Context, c *Call) error
	Publish(ctx context.Context, msg *Message) error
	Subscribe(ctx context.Context, topic string) error
	Unsubscribe(ctx context.Context, topic string) error
	RegisterMessageHandler(topic string, h MessageHandler)
	RegisterRequestHandler(topic string, h RequestHandler)
	UnregisterHandler(topic string)
}

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

type HTTPDoerConfig struct {
	Topic    string
	Endpoint Endpoint
	MaxWait  time.Duration
	QoS      int
	Retain   bool
}

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

type HTTPServerConfig struct {
	Topic          string
	Broker         BrokerConfig
	HandlerTimeout time.Duration
	Handler        http.Handler
	Logger         *zerolog.Logger
}

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

type Message struct {
	Topic   string
	QoS     int
	Payload []byte
	Retain  bool
	Expiry  time.Duration
}

type MessageHandler func(ctx context.Context, msg *Message)

type PublishFunc func(ctx context.Context, msg *Message) error

type RequestHandler func(ctx context.Context, msg *Message) (any, error)