diff --git a/monitor/mqtt_monitor_test.go b/monitor/mqtt_monitor_test.go index c3398de..ff868ed 100644 --- a/monitor/mqtt_monitor_test.go +++ b/monitor/mqtt_monitor_test.go @@ -25,9 +25,9 @@ func TestGMonitorActiveParticipants(t *testing.T) { monitor.LazyLoadMonitorMQTTClient() cfg := config.GetConfig() db, err := leveldb.OpenFile("./activeActors.db", nil) + assert.NoError(t, err) defer db.Close() - assert.NoError(t, err) mqttMonitor := monitor.NewMqttMonitorService(db, *cfg) err = mqttMonitor.Start() assert.NoError(t, err) @@ -44,7 +44,6 @@ func TestGMonitorActiveParticipants(t *testing.T) { assert.NoError(t, err) assert.Contains(t, challenger, "plmnt") assert.Contains(t, challengee, "plmnt") - } func TestCleanupRemoval(t *testing.T) { @@ -52,8 +51,9 @@ func TestCleanupRemoval(t *testing.T) { cfg := config.GetConfig() db, err := leveldb.OpenFile("./activeActors.db", nil) - defer db.Close() assert.NoError(t, err) + defer db.Close() + mqttMonitor := monitor.NewMqttMonitorService(db, *cfg) err = mqttMonitor.Start() assert.NoError(t, err) @@ -78,8 +78,9 @@ func TestCleanupPrecisionTest(t *testing.T) { cfg := config.GetConfig() db, err := leveldb.OpenFile("./activeActors.db", nil) - defer db.Close() assert.NoError(t, err) + defer db.Close() + mqttMonitor := monitor.NewMqttMonitorService(db, *cfg) err = mqttMonitor.Start() assert.NoError(t, err)