fix(eventsub): correct names for nats subscriptions

twirapp · May 31, 2024 · d7c7714 · d7c7714
1 parent bd2e39d
commit d7c7714
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 4 deletions.
diff --git a/apps/eventsub/internal/bus-listener/bus-listener.go b/apps/eventsub/internal/bus-listener/bus-listener.go
@@ -41,14 +41,14 @@ func New(opts Opts) (*BusListener, error) {
 		fx.Hook{
 			OnStart: func(ctx context.Context) error {
 				if err := impl.bus.EventSub.SubscribeToAllEvents.SubscribeGroup(
-					"eventsub.subscribeAll",
+					"eventsub",
 					impl.subscribeToAllEvents,
 				); err != nil {
 					return err
 				}
 
 				if err := impl.bus.EventSub.Subscribe.SubscribeGroup(
-					"eventsub.subscribe",
+					"eventsub",
 					impl.subscribe,
 				); err != nil {
 					return err

diff --git a/libs/bus-core/bus.go b/libs/bus-core/bus.go
@@ -167,7 +167,7 @@ func NewNatsBus(nc *nats.Conn) *Bus {
 		EventSub: &eventSubBus{
 			SubscribeToAllEvents: NewNatsQueue[eventsub.EventsubSubscribeToAllEventsRequest, struct{}](
 				nc,
-				eventsub.EventsubSubscribeSubject,
+				eventsub.EventsubSubscribeAllSubject,
 				1*time.Minute,
 				nats.GOB_ENCODER,
 			),

diff --git a/libs/bus-core/eventsub/eventsub.go b/libs/bus-core/eventsub/eventsub.go
@@ -1,7 +1,8 @@
 package eventsub
 
 const (
-	EventsubSubscribeSubject = "eventsub.subscribe"
+	EventsubSubscribeAllSubject = "eventsub.subscribeAll"
+	EventsubSubscribeSubject    = "eventsub.subscribe"
 )
 
 type EventsubSubscribeToAllEventsRequest struct {