diff options
| author | adamdottv <[email protected]> | 2025-05-12 11:22:19 -0500 |
|---|---|---|
| committer | adamdottv <[email protected]> | 2025-05-12 11:22:19 -0500 |
| commit | d20d0c5a95e19250a7d83b4eb30f9d7b460104da (patch) | |
| tree | a0ce46f8aabd6ade3936145e81a94291f51a30f3 | |
| parent | 5af3c05d41f80615716f085d6d8eda859bf54ad4 (diff) | |
| download | opencode-d20d0c5a95e19250a7d83b4eb30f9d7b460104da.tar.gz opencode-d20d0c5a95e19250a7d83b4eb30f9d7b460104da.zip | |
chore: cleanup
| -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 |