refactor: extract a separate repository to publish events

1 files changed, 3 insertions, 22 deletions

diff --git a/app/db/in_memory_repository_test.go b/app/db/in_memory_repository_test.go
index 5bb220e..b89f16a 100644
--- a/app/db/in_memory_repository_test.go
+++ b/app/db/in_memory_repository_test.go
@@ -7,14 +7,12 @@ import (
 
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
-	"github.com/xlgmokha/x/pkg/event"
 	"github.com/xlgmokha/x/pkg/x"
 	"gitlab.com/gitlab-org/software-supply-chain-security/authorization/sparkled/app/domain"
 )
 
 func TestInMemoryRepository(t *testing.T) {
-	aggregator := event.New[*domain.Sparkle]()
-	storage := NewRepository[*domain.Sparkle](aggregator)
+	storage := NewRepository[*domain.Sparkle]()
 
 	t.Run("Save", func(t *testing.T) {
 		t.Run("an invalid Sparkle", func(t *testing.T) {
@@ -33,25 +31,8 @@ func TestInMemoryRepository(t *testing.T) {
 			assert.Equal(t, "because", sparkles[0].Reason)
 		})
 
-		t.Run("publishes an event", func(t *testing.T) {
-			called := false
-			var payload *domain.Sparkle
-
-			aggregator.SubscribeTo("after.create", func(item *domain.Sparkle) {
-				called = true
-				payload = item
-			})
-
-			sparkle := &domain.Sparkle{Sparklee: "@tanuki", Reason: "because"}
-			require.NoError(t, storage.Save(t.Context(), sparkle))
-
-			require.True(t, called)
-			require.NotNil(t, payload)
-			assert.Equal(t, sparkle, payload)
-		})
-
 		t.Run("prevents race conditions", func(t *testing.T) {
-			repository := NewRepository[*domain.Sparkle](aggregator)
+			repository := NewRepository[*domain.Sparkle]()
 			ctx := context.Background()
 
 			numGoroutines := 100
@@ -112,7 +93,7 @@ func TestInMemoryRepository(t *testing.T) {
 	})
 
 	t.Run("All", func(t *testing.T) {
-		repository := NewRepository[*domain.Sparkle](aggregator)
+		repository := NewRepository[*domain.Sparkle]()
 		require.NoError(t, repository.Save(t.Context(), &domain.Sparkle{
 			Sparklee: "@tanuki",
 			Reason:   "because",