From 36e5ae804e4bf0c96a0ce6cca90029e88c2da9b3 Mon Sep 17 00:00:00 2001
From: adamdottv <2363879+adamdottv@users.noreply.github.com>
Date: Mon, 12 May 2025 14:32:27 -0500
Subject: chore: rename coder -> primary

---
 internal/pubsub/broker_test.go | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

(limited to 'internal/pubsub')

diff --git a/internal/pubsub/broker_test.go b/internal/pubsub/broker_test.go
index 1a82011fc..b4caa98f3 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("created", "test message")
+	broker.Publish(EventTypeCreated, "test message")
 
 	// Verify message is received
 	select {
 	case event := <-ch:
-		assert.Equal(t, "created", event.Type)
+		assert.Equal(t, EventTypeCreated, 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("created", i)
+		broker.Publish(EventTypeCreated, i)
 	}
 
 	// Wait for all subscribers to finish
-- 
cgit v1.2.3