diff --git a/main.go b/main.go index ca799a0..a8e55a3 100644 --- a/main.go +++ b/main.go @@ -16,6 +16,8 @@ var weatherSource weathersource.WeatherSource var weatherAPI api.WeatherAPI func main() { + log.SetOutput(os.Stdout) + //setup new sensorRegistry -> MongodbSensorRegistry var err error if sensorRegistry, err = storage.NewMongodbSensorRegistry(config.MongoConfiguration); err != nil { @@ -44,6 +46,7 @@ func main() { defer weatherAPI.Close() weatherAPI.AddNewWeatherDataCallback(handleNewWeatherData) + log.Print("Application is running") err = weatherAPI.Start() if err != nil { log.Fatal(err) @@ -54,6 +57,7 @@ func main() { func handleNewWeatherData(wd storage.WeatherData) error { _, err := sensorRegistry.ResolveSensorById(wd.SensorId) if !config.AllowUnregisteredSensors && err != nil { + log.Print("discarded invalid weatherdata") return fmt.Errorf("could not resolve sensor") } weatherStorage.Save(wd) diff --git a/storage/influxdb-storage.go b/storage/influxdb-storage.go index 3ff53c6..b98b9b0 100644 --- a/storage/influxdb-storage.go +++ b/storage/influxdb-storage.go @@ -3,6 +3,7 @@ package storage import ( "context" "fmt" + "log" "time" "weather-data/config" @@ -23,6 +24,7 @@ func NewInfluxStorage(cfg config.InfluxConfig) (*influxStorage, error) { influx.config = cfg influx.client = influxdb2.NewClient(cfg.Host, cfg.Token) influx.measurement = "data" + log.Print("Successfully created influx-client") return influx, nil } @@ -44,6 +46,7 @@ func (storage *influxStorage) Save(data WeatherData) error { writeAPI := storage.client.WriteAPI(storage.config.Organization, storage.config.Bucket) writeAPI.WritePoint(datapoint) + log.Print("Written weather data point to influx-db") return nil } diff --git a/storage/mongodb-storage.go b/storage/mongodb-storage.go index 12eb481..ddc7869 100644 --- a/storage/mongodb-storage.go +++ b/storage/mongodb-storage.go @@ -48,6 +48,8 @@ func NewMongodbSensorRegistry(mongoCfg config.MongoConfig) (*mongodbSensorRegist weathersensorsDB := client.Database(mongoCfg.Database) sensorRegistry.sensorCollection = weathersensorsDB.Collection(mongoCfg.Collection) + log.Print("successfully created mongodb connection") + return sensorRegistry, nil } diff --git a/weathersource/mqtt-source.go b/weathersource/mqtt-source.go index 3c3c5a1..d669742 100644 --- a/weathersource/mqtt-source.go +++ b/weathersource/mqtt-source.go @@ -58,6 +58,7 @@ func NewMqttSource(cfg config.MqttConfig) (*mqttWeatherSource, error) { go source.publishDataValues() + log.Print("successfully connected to mqtt-broker") return source, nil }