ports

type CommunicationPort interface {
	Open() error
	Read(buffer []byte) (int, error)
	Write(payload []byte) (int, error)
	Close() error
}

type Database interface {
	InsertDiscoveryRecord(discovery string, prefix string, fields []DiscoveryField) error
	InsertRecord(measurement map[string]interface{}) error
}

type DatabaseWithListener interface {
	Database
	Subscribe(topic string, callback mqtt.MessageHandler)
}

type Device interface {
	Name() string
	GetDiscoveryFields() []DiscoveryField
	Query() (map[string]interface{}, error)
}

type DiscoveryField struct {
	Name   string
	Factor string
	Unit   string
}