diff options
| -rw-r--r-- | go.mod | 6 | ||||
| -rw-r--r-- | internal/pubsub/broker_test.go | 6 |
2 files changed, 3 insertions, 9 deletions
@@ -31,12 +31,6 @@ require ( github.com/spf13/cobra v1.9.1 github.com/spf13/viper v1.20.0 github.com/stretchr/testify v1.10.0 - google.golang.org/api v0.215.0 -) - -require ( - cloud.google.com/go/auth/oauth2adapt v0.2.6 // indirect - golang.org/x/oauth2 v0.25.0 // indirect ) require ( diff --git a/internal/pubsub/broker_test.go b/internal/pubsub/broker_test.go index 581a513a3..1a82011fc 100644 --- a/internal/pubsub/broker_test.go +++ b/internal/pubsub/broker_test.go @@ -51,12 +51,12 @@ func TestBrokerPublish(t *testing.T) { ch := broker.Subscribe(ctx) // Publish a message - broker.Publish(CreatedEvent, "test message") + broker.Publish("created", "test message") // Verify message is received select { case event := <-ch: - assert.Equal(t, CreatedEvent, event.Type) + assert.Equal(t, "created", event.Type) assert.Equal(t, "test message", event.Payload) case <-time.After(100 * time.Millisecond): t.Fatal("timeout waiting for message") @@ -122,7 +122,7 @@ func TestBrokerConcurrency(t *testing.T) { // Publish messages to all subscribers for i := range numSubscribers { - broker.Publish(CreatedEvent, i) + broker.Publish("created", i) } // Wait for all subscribers to finish |