Added mutex to avoid concurrency errors on SubscriptionManager (#2316)

* Added mutex to avoid concurrency errors on SubscriptionManager

* Fix CI dependencies

* Adding mutex to the event emitting

.github/workflows/pull-request.yaml

@@ -88,6 +88,7 @@ jobs:
 
   build-go:
     name: Build go binaries (API Server and CLI)
+    needs: [unit-test-cli, test-server]
     runs-on: ubuntu-latest
     steps:
     - uses: actions/checkout@v3

server/executor/eventemitter.go

@@ -2,6 +2,7 @@ package executor
 
 import (
 	"context"
+	"sync"
 
 	"github.com/kubeshop/tracetest/server/model"
 )
@@ -17,6 +18,7 @@ type publisher interface {
 type internalEventEmitter struct {
 	repository model.TestRunEventRepository
 	publisher  publisher
+	mutex      sync.Mutex
 }
 
 func NewEventEmitter(repository model.TestRunEventRepository, publisher publisher) EventEmitter {
@@ -32,6 +34,9 @@ func (em *internalEventEmitter) Emit(ctx context.Context, event model.TestRunEve
 		return err
 	}
 
+	em.mutex.Lock()
+	defer em.mutex.Unlock()
+
 	em.publisher.Publish(event.ResourceID(), event)
 
 	return nil