fix(eventsub): correct loop for channels

twirapp · May 31, 2024 · 0ca65b9 · 0ca65b9
1 parent d00540a
commit 0ca65b9
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/apps/eventsub/internal/manager/manager.go b/apps/eventsub/internal/manager/manager.go
@@ -61,7 +61,7 @@ func NewManager(opts Opts) (*Manager, error) {
 	}
 
 	locker := redsync.New(redsyncredis.NewPool(opts.Redis))
-	startDistributedLock := locker.NewMutex("eventsub:startDistrubitedLock")
+	startDistributedLock := locker.NewMutex("eventsub:startDistributedLock")
 
 	opts.Lc.Append(
 		fx.Hook{
@@ -143,6 +143,8 @@ func NewManager(opts Opts) (*Manager, error) {
 					for _, channel := range channels {
 						channelsWg.Add(1)
 
+						channel := channel
+
 						go func() {
 							defer channelsWg.Done()
 							err = manager.SubscribeToNeededEvents(

diff --git a/apps/eventsub/internal/manager/subscribe.go b/apps/eventsub/internal/manager/subscribe.go
@@ -19,9 +19,7 @@ func (c *Manager) SubscribeWithLimits(
 ) {
 	data, err := retry.DoWithData(
 		func() (*esb.RequestStatus, error) {
-			data, subscribeErr := c.Subscribe(ctx, srq)
-
-			return data, subscribeErr
+			return c.Subscribe(ctx, srq)
 		},
 		retry.Attempts(0),
 		retry.Delay(1*time.Second),