smarthome

type Client interface {
	// Set publishes a set message with the value
	Set(toplevel, item string, value string) error
	// Get publishes a get request message.
	Get(toplevel, item string) (Value, error)
	// Command publishes a command to the toplevel topic.
	Command(toplevel string, cmd []byte) error

	// Subscribe to receive callbacks whenever a status message is received.
	Subscribe(toplevel, item string) *Subscription

	// Close disconnects the client.
	Close()
}

type ConnectionState int

type Device struct {
	Toplevel string
	Item     string
	Value    Value
}

type DeviceLookup interface {
	Device(toplevel, item string) (Device, bool)
	Find(toplevel string, itemMatch *regexp.Regexp) []Device
	Close()
}

type Handler interface {
	// Set handles a set request.
	Set(toplevel, item string, value interface{})
	// Get handles a get request.
	Get(toplevel, item string) (Value, bool)
	// Command handles a command request.
	Command(toplevel string, cmd []byte)
}

type Server interface {
	// Connect to the MQTT broker.
	Connect() error
	// Disconnect from the MQTT broker.
	Disconnect()

	// Publish the state of the hardware connection.
	PublishHWStatus(ConnectionState) error

	// Publish a status message.
	PublishStatus(item string, value Value) error
	// Publish a one-shot message.
	PublishOneShotStatus(item string, value Value) error

	// Client returns a client that shares the underlying MQTT connection.
	// The server must be connected before calling.
	// Closing the client is required but will not disconnect the underlying MQTT connection.
	Client() (Client, error)
}

type StatusMessage struct {
	Toplevel string
	Item     string
	Value    Value
}

type Subscription struct {
	C <-chan StatusMessage
	// contains filtered or unexported fields
}

type Value struct {
	Value       interface{}
	Time        time.Time
	LastChanged time.Time
}