fix(eventsub): retry deadline subscribe

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

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/apps/eventsub/internal/manager/manager.go b/apps/eventsub/internal/manager/manager.go
@@ -136,7 +136,6 @@ func NewManager(opts Opts) (*Manager, error) {
 					}
 
 					startDistributedLock.Lock()
-					defer startDistributedLock.Unlock()
 
 					channelsWg := sync.WaitGroup{}
 
@@ -176,6 +175,7 @@ func NewManager(opts Opts) (*Manager, error) {
 					)
 
 					channelsWg.Wait()
+					startDistributedLock.Unlock()
 				}()
 
 				return nil

diff --git a/apps/eventsub/internal/manager/subscribe.go b/apps/eventsub/internal/manager/subscribe.go
@@ -30,6 +30,10 @@ func (c *Manager) SubscribeWithLimits(
 					return true
 				}
 
+				if errors.Is(err, context.DeadlineExceeded) {
+					return true
+				}
+
 				return false
 			},
 		),