fix(eventsub): correct names for nats subscriptions

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

Hide file tree

Showing 3 changed files with 13 additions and 43 deletions.
diff --git a/apps/api-gql/internal/gql/resolvers/admin-actions.resolver.go b/apps/api-gql/internal/gql/resolvers/admin-actions.resolver.go
diff --git a/apps/api-gql/internal/gql/resolvers/user.resolver.go b/apps/api-gql/internal/gql/resolvers/user.resolver.go
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",
+					"eventsub.subscribeAll",
 					impl.subscribeToAllEvents,
 				); err != nil {
 					return err
 				}
 
 				if err := impl.bus.EventSub.Subscribe.SubscribeGroup(
-					"eventsub",
+					"eventsub.subscribe",
 					impl.subscribe,
 				); err != nil {
 					return err