snr/fermentord
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Use reloaded configuration in mainloop

Browse source
This commit is contained in:
Søren Rasmussen 2022-08-02 16:08:49 +02:00
parent 52b1108798
commit 5ecc4ba27a
1 changed files with 6 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
cmd/fermentord/loop.go
View file

@ -35,10 +35,13 @@ func mainLoop(ctx context.Context, wg *sync.WaitGroup, js nats.JetStream) {
// Controller // Controller
config := configuration.Global() config := configuration.Global()
ctrl := controllers.NewChamberController(config) ctrl := controllers.NewChamberController(config)
chConfigChange := make(chan configuration.Configuration, 1)
chn := configuration.NewChangeNotifier() chn := configuration.NewChangeNotifier()
viper.OnConfigChange(chn.OnConfigChange) viper.OnConfigChange(chn.OnConfigChange)
// Configuration updates // Configuration updates
chn.Subscribe(chConfigChange)
chn.Subscribe(temperature.ConfigUpdate) chn.Subscribe(temperature.ConfigUpdate)
chn.Subscribe(ctrl.ConfigUpdates) chn.Subscribe(ctrl.ConfigUpdates)
//chn.Subscribe(display.ConfiguUpdate) //chn.Subscribe(display.ConfiguUpdate)
@ -129,6 +132,9 @@ func mainLoop(ctx context.Context, wg *sync.WaitGroup, js nats.JetStream) {
ingest.AddState(state) ingest.AddState(state)
//display.SetState(state) //display.SetState(state)
case c := <-chConfigChange:
config = c
case <-ctx.Done(): case <-ctx.Done():
return return
} }