pedro/nats-app
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add create sensor data repo

Browse Source
This commit is contained in:
Pedro Pérez 2025-10-09 18:35:36 +02:00
parent 6d3408f34c
commit 9d86fd394c
1 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
internal/domains/sensors/repository.go
View File

@ -11,6 +11,7 @@ import (
type Repository interface { type Repository interface {
CreateSensor(s Sensor) error CreateSensor(s Sensor) error
CreateSensorData(data SensorData) error
UpdateSensor(s Sensor) error UpdateSensor(s Sensor) error
ReadSensor(sensorID string) (Sensor, error) ReadSensor(sensorID string) (Sensor, error)
ReadSensorValues(sensorID string, from, to time.Time) ([]SensorData, error) ReadSensorValues(sensorID string, from, to time.Time) ([]SensorData, error)
@ -34,6 +35,10 @@ func (p *pgxRepo) CreateSensor(s Sensor) error {
return err return err
} }
func (p *pgxRepo) CreateSensorData(s SensorData) error {
return nil
}
func (p *pgxRepo) UpdateSensor(s Sensor) error { func (p *pgxRepo) UpdateSensor(s Sensor) error {
panic("unimplemented") panic("unimplemented")
} }
@ -101,6 +106,10 @@ func (i *inMemory) CreateSensor(s Sensor) error {
return nil return nil
} }
func (p *inMemory) CreateSensorData(s SensorData) error {
return nil
}
func (i *inMemory) UpdateSensor(s Sensor) error { func (i *inMemory) UpdateSensor(s Sensor) error {
panic("unimplemented") panic("unimplemented")
} }
@ -160,6 +169,10 @@ func (d *DecoratorRepo) CreateSensor(s Sensor) error {
return nil return nil
} }
func (p *DecoratorRepo) CreateSensorData(s SensorData) error {
return nil
}
func (d *DecoratorRepo) UpdateSensor(s Sensor) error { func (d *DecoratorRepo) UpdateSensor(s Sensor) error {
if err := d.db.UpdateSensor(s); err != nil { if err := d.db.UpdateSensor(s); err != nil {
return err return err