Use clean eventbus for integration tests

pkg/eventbus/eventbus.go

@@ -46,6 +46,10 @@ func Service() *eventbus {
 	return gEventBus
 }
 
+func Set(eb *eventbus) {
+	gEventBus = eb
+}
+
 func New() *eventbus {
 	return &eventbus{
 		wg:       &sync.WaitGroup{},

tests/compose/main_test.go

@@ -2,6 +2,7 @@ package compose
 
 import (
 	"context"
+	"github.com/cortezaproject/corteza-server/pkg/eventbus"
 	"os"
 	"testing"
 
@@ -45,6 +46,8 @@ type (
 var (
 	testApp app.Runnable
 	r       chi.Router
+
+	eventBus = eventbus.New()
 )
 
 func init() {
@@ -58,6 +61,10 @@ func db() *factory.DB {
 func (app *TestApp) Initialize(ctx context.Context) (err error) {
 	service.DefaultPermissions = permissions.NewTestService(ctx, app.Log, db(), "compose_permission_rules")
 	service.DefaultStore, err = plain.NewWithAfero(afero.NewMemMapFs(), "test")
+
+	eventBus = eventbus.New()
+	eventbus.Set(eventBus)
+
 	return
 }