Mirroristas/planetmint-go
2
0
Fork 0
mirror of https://github.com/planetmint/planetmint-go.git synced 2025-11-26 15:35:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat(mqtt): start monitor after api server

Browse Source 
closes #435

Signed-off-by: Julian Strobl <jmastr@mailbox.org>
This commit is contained in:
Julian Strobl 2024-11-15 11:10:38 +01:00
parent 6ec84d9395
commit 853ad35cd9
No known key found for this signature in database
GPG Key ID: E0A8F9AD733499A7
2 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
app/app.go
View File

@ -955,6 +955,12 @@ func (app *App) RegisterTendermintService(clientCtx client.Context) {
// RegisterNodeService implements the Application.RegisterNodeService method.
func (app *App) RegisterNodeService(clientCtx client.Context) {
nodeservice.RegisterNodeService(clientCtx, app.GRPCQueryRouter())
// HACK: start mqtt monitor as late as possible (hint: look in vendor directory for startup order)
mqttMonitorInstance := monitor.GetMqttMonitorInstance()
err := mqttMonitorInstance.Start()
if err != nil {
panic(err)
}
}
// initParamsKeeper init params keeper and its subspaces

10
monitor/interface.go
View File

@ -25,6 +25,12 @@ func SetMqttMonitorInstance(monitorInstance MQTTMonitorClientI) {
monitorMutex.Unlock()
}
func GetMqttMonitorInstance() (monitorInstance MQTTMonitorClientI) {
monitorMutex.Lock()
defer monitorMutex.Unlock()
return mqttMonitorInstance
}
func LazyMqttMonitorLoader(logger log.Logger, homeDir string) {
monitorMutex.RLock()
tmpInstance := mqttMonitorInstance
@ -44,10 +50,6 @@ func LazyMqttMonitorLoader(logger log.Logger, homeDir string) {
}
SetMqttMonitorInstance(NewMqttMonitorService(aciveActorsDB, *config.GetConfig()))
err = mqttMonitorInstance.Start()
if err != nil {
panic(err)
}
}
func SelectPoPParticipantsOutOfActiveActors() (challenger string, challengee string, err error) {