ports

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

type Database interface {
	InsertRecord(measurement map[string]interface{}) error
	InsertRecordStation(measurement map[string]interface{}) error
}

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

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