fix: ensure Close can be called multiple times safely

services/antivirus/pkg/service/service.go

@@ -160,8 +160,9 @@ EventLoop:
 }
 
 func (av Antivirus) Close() {
-	av.stopped.Store(true)
-	close(av.stopCh)
+	if av.stopped.CompareAndSwap(false, true) {
+		close(av.stopCh)
+	}
 }
 
 func (av Antivirus) processEvent(e events.Event, s events.Publisher) error {

services/clientlog/pkg/service/service.go

@@ -98,8 +98,9 @@ EventLoop:
 }
 
 func (cl *ClientlogService) Close() {
-	cl.stopped.Store(true)
-	close(cl.stopCh)
+	if cl.stopped.CompareAndSwap(false, true) {
+		close(cl.stopCh)
+	}
 }
 
 func (cl *ClientlogService) processEvent(event events.Event) {

services/notifications/pkg/service/service.go

@@ -121,8 +121,9 @@ EventLoop:
 }
 
 func (s eventsNotifier) Close() {
-	s.stopped.Store(true)
-	close(s.stopCh)
+	if s.stopped.CompareAndSwap(false, true) {
+		close(s.stopCh)
+	}
 }
 
 func (s eventsNotifier) render(ctx context.Context, template email.MessageTemplate,

services/policies/pkg/service/event/service.go

@@ -76,8 +76,9 @@ EventLoop:
 // from, so resources won't be freed and there will be memory leaks. For now,
 // if the service is stopped, you should close the app soon after.
 func (s Service) Close() {
-	s.stopped.Store(true)
-	close(s.stopCh)
+	if s.stopped.CompareAndSwap(false, true) {
+		close(s.stopCh)
+	}
 }
 
 func (s Service) processEvent(e events.Event) error {

services/postprocessing/pkg/service/service.go

@@ -115,8 +115,9 @@ EventLoop:
 // from, so resources won't be freed and there will be memory leaks. For now,
 // if the service is stopped, you should close the app soon after.
 func (pps *PostprocessingService) Close() {
-	pps.stopped.Store(true)
-	close(pps.stopCh)
+	if pps.stopped.CompareAndSwap(false, true) {
+		close(pps.stopCh)
+	}
 }
 
 func (pps *PostprocessingService) processEvent(e events.Event) error {