Markus Pesch
3a090d190e
changes: - fix: read temperature values without daemon Add subcommand to read temperature values without starting the daemon - fix: implement measured value types Replace measured value types with constants - fix: add sensor pipelines Add functions which returns a channel with measured values - fix: filter measured values from a channel Add functions to filter measured values by sensor id or measured value types.
217 lines
6.5 KiB
Go
217 lines
6.5 KiB
Go
package repository
|
|
|
|
import (
|
|
"context"
|
|
"net/url"
|
|
"strings"
|
|
|
|
"git.cryptic.systems/volker.raschek/flucky/pkg/repository/db"
|
|
"git.cryptic.systems/volker.raschek/flucky/pkg/types"
|
|
"git.cryptic.systems/volker.raschek/go-logger"
|
|
)
|
|
|
|
// Repository represent a repository where all devices, sensors and measured
|
|
// values are stored.
|
|
type Repository struct {
|
|
database db.Database
|
|
}
|
|
|
|
// AddDevices to the repository
|
|
func (repo *Repository) AddDevices(devices ...*types.Device) error {
|
|
return repo.database.InsertDevices(context.Background(), devices...)
|
|
}
|
|
|
|
// AddMeasuredValues to the repository
|
|
func (repo *Repository) AddMeasuredValues(measuredValues ...*types.MeasuredValue) error {
|
|
return repo.database.InsertMeasuredValues(context.Background(), measuredValues...)
|
|
}
|
|
|
|
// AddSensors to the repository
|
|
func (repo *Repository) AddSensors(sensors ...*types.Sensor) error {
|
|
return repo.database.InsertSensors(context.Background(), sensors...)
|
|
}
|
|
|
|
// Close closes the repository and prevents new queries from starting. Close
|
|
// then waits for all queries that have started processing on the server to
|
|
// finish.
|
|
func (repo *Repository) Close() error {
|
|
return repo.database.Close()
|
|
}
|
|
|
|
// DisableSensorsByNames disable all sensors which match bei their name
|
|
func (repo *Repository) DisableSensorsByNames(sensorNames ...string) error {
|
|
sensors, err := repo.GetSensors()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
matchedSensors := make([]*types.Sensor, 0)
|
|
for _, sensor := range sensors {
|
|
for _, sensorName := range sensorNames {
|
|
if strings.Compare(sensor.Name, sensorName) == 0 {
|
|
sensor.Enabled = false
|
|
matchedSensors = append(matchedSensors, sensor)
|
|
}
|
|
}
|
|
}
|
|
|
|
return repo.UpdateSensors(matchedSensors...)
|
|
}
|
|
|
|
// EnableSensorsByNames enable all sensors which match bei their name
|
|
func (repo *Repository) EnableSensorsByNames(sensorNames ...string) error {
|
|
sensors, err := repo.GetSensors()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
matchedSensors := make([]*types.Sensor, 0)
|
|
for _, sensor := range sensors {
|
|
for _, sensorName := range sensorNames {
|
|
if strings.Compare(sensor.Name, sensorName) == 0 {
|
|
sensor.Enabled = true
|
|
matchedSensors = append(matchedSensors, sensor)
|
|
}
|
|
}
|
|
}
|
|
|
|
return repo.UpdateSensors(matchedSensors...)
|
|
}
|
|
|
|
// GetDevice returns a device by his id. If no device has been found, the
|
|
// function returns nil.
|
|
func (repo *Repository) GetDevice(deviceID string) (*types.Device, error) {
|
|
return repo.database.SelectDevice(context.Background(), deviceID)
|
|
}
|
|
|
|
// GetDevices returns all devices. If no devices has been found, the function
|
|
// returns nil.
|
|
func (repo *Repository) GetDevices() ([]*types.Device, error) {
|
|
return repo.database.SelectDevices(context.Background())
|
|
}
|
|
|
|
// GetSensor returns a sensor by his id. If no sensor has been found, the
|
|
// function returns nil.
|
|
func (repo *Repository) GetSensor(sensorID string) (*types.Sensor, error) {
|
|
return repo.database.SelectSensor(context.Background(), sensorID)
|
|
}
|
|
|
|
// GetSensors returns all sensors. If no sensors has been found, the function
|
|
// returns nil.
|
|
func (repo *Repository) GetSensors(models ...string) ([]*types.Sensor, error) {
|
|
sensors, err := repo.database.SelectSensors(context.Background())
|
|
switch {
|
|
case err != nil:
|
|
return nil, err
|
|
case len(models) > 0:
|
|
cachedSensors := make([]*types.Sensor, 0)
|
|
LOOP:
|
|
for i := range sensors {
|
|
for j := range models {
|
|
if strings.ToLower(sensors[i].Model) == strings.ToLower(models[j]) {
|
|
cachedSensors = append(cachedSensors, sensors[i])
|
|
continue LOOP
|
|
}
|
|
}
|
|
}
|
|
return cachedSensors, nil
|
|
case len(models) <= 0:
|
|
fallthrough
|
|
default:
|
|
return sensors, err
|
|
}
|
|
}
|
|
|
|
// GetSensorsByDeviceID returns all sensors by a device id. If no sensor has
|
|
// been found by the id, the function returns nil.
|
|
func (repo *Repository) GetSensorsByDeviceID(deviceID string) ([]*types.Sensor, error) {
|
|
cachedSensors := make([]*types.Sensor, 0)
|
|
sensors, err := repo.GetSensors()
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
for _, sensor := range sensors {
|
|
if strings.Compare(sensor.DeviceID, deviceID) == 0 {
|
|
cachedSensors = append(cachedSensors, sensor)
|
|
}
|
|
}
|
|
|
|
return cachedSensors, nil
|
|
}
|
|
|
|
// RemoveDevices removes devices by their ids from the repository. Additional
|
|
// all sensors and measured values, which are in relation with the device
|
|
// respectively the sensors will also be deleted.
|
|
func (repo *Repository) RemoveDevices(deviceIDs ...string) error {
|
|
return repo.database.DeleteDevices(context.Background(), deviceIDs...)
|
|
}
|
|
|
|
// RenameSensors all sensors which match by their current name to the new name
|
|
func (repo *Repository) RenameSensors(oldName string, newName string) error {
|
|
sensors, err := repo.GetSensors()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
matchedSensors := make([]*types.Sensor, 0)
|
|
for _, sensor := range sensors {
|
|
if strings.Compare(sensor.Name, oldName) == 0 {
|
|
sensor.Name = newName
|
|
matchedSensors = append(matchedSensors, sensor)
|
|
}
|
|
}
|
|
|
|
return repo.UpdateSensors(matchedSensors...)
|
|
}
|
|
|
|
// RemoveSensors removes sensors by their ids from the repository. Additional
|
|
// all measured values, which are in relation with the sensor will also be
|
|
// deleted.
|
|
func (repo *Repository) RemoveSensors(sensorIDs ...string) error {
|
|
return repo.database.DeleteSensors(context.Background(), sensorIDs...)
|
|
}
|
|
|
|
// RemoveSensorsByNames removes all sensors which match bei their name
|
|
func (repo *Repository) RemoveSensorsByNames(sensorNames ...string) error {
|
|
sensors, err := repo.GetSensors()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
matchedSensorIDs := make([]string, 0)
|
|
for _, sensor := range sensors {
|
|
for _, sensorName := range sensorNames {
|
|
if strings.Compare(sensor.Name, sensorName) == 0 {
|
|
matchedSensorIDs = append(matchedSensorIDs, sensor.ID)
|
|
}
|
|
}
|
|
}
|
|
|
|
return repo.RemoveSensors(matchedSensorIDs...)
|
|
}
|
|
|
|
// UpdateDevices update devices which are stored into the repository by their
|
|
// id. The id of the device can not be updated.
|
|
func (repo *Repository) UpdateDevices(devices ...*types.Device) error {
|
|
return repo.database.UpdateDevices(context.Background(), devices...)
|
|
}
|
|
|
|
// UpdateSensors update sensors which are stored into the repository by their
|
|
// id. The id of the sensor can not be updated.
|
|
func (repo *Repository) UpdateSensors(sensors ...*types.Sensor) error {
|
|
return repo.database.UpdateSensors(context.Background(), sensors...)
|
|
}
|
|
|
|
// New returns a new repository based on the data source name (dsn)
|
|
func New(dsnURL *url.URL, flogger logger.Logger) (*Repository, error) {
|
|
database, err := db.New(dsnURL, flogger)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return &Repository{
|
|
database: database,
|
|
}, nil
|
|
}
|