projects/weather-api
6
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

resolve sensor

Browse source
This commit is contained in:
Joel Schmid 2021-03-20 16:23:17 +01:00
parent 4b6d8e6c6b
commit 395e4530af
3 changed files with 6 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
main.go
View file

@ -55,7 +55,8 @@ func main() {
} }
func handleNewWeatherData(wd storage.WeatherData) error { func handleNewWeatherData(wd storage.WeatherData) error {
if !config.AllowUnregisteredSensors() && !sensorRegistry.ExistSensorId(wd.SensorId) { _, couldResolve := sensorRegistry.ResolveSensorById(wd.SensorId)
if !config.AllowUnregisteredSensors() && !couldResolve {
return errors.New("sensor have to be registered") return errors.New("sensor have to be registered")
} }
weatherStorage.Save(wd) weatherStorage.Save(wd)

6
storage/inmemory-storage.go
View file

@ -35,13 +35,13 @@ func (registry *inmemorySensorRegistry) ExistSensorName(name string) bool {
return false return false
} }
func (registry *inmemorySensorRegistry) ExistSensorId(sensorId uuid.UUID) bool { func (registry *inmemorySensorRegistry) ResolveSensorById(sensorId uuid.UUID) (*WeatherSensor, bool) {
for _, s := range registry.weatherSensors { for _, s := range registry.weatherSensors {
if s.Id == sensorId { if s.Id == sensorId {
return true return s, true
} }
} }
return false return nil, false
} }
func (registry *inmemorySensorRegistry) ExistSensor(sensor *WeatherSensor) bool { func (registry *inmemorySensorRegistry) ExistSensor(sensor *WeatherSensor) bool {

2
storage/weather-data.go
View file

@ -17,7 +17,7 @@ type WeatherStorage interface {
type SensorRegistry interface { type SensorRegistry interface {
RegisterSensorByName(string) (*WeatherSensor, error) RegisterSensorByName(string) (*WeatherSensor, error)
ExistSensor(*WeatherSensor) bool ExistSensor(*WeatherSensor) bool
ExistSensorId(uuid.UUID) bool ResolveSensorById(uuid.UUID) (*WeatherSensor, bool)
GetSensors() []*WeatherSensor GetSensors() []*WeatherSensor
Close() error Close() error
} }