feat: add time.Sleep when subscribing failed and update backOff duration

tokamak-network · Aug 10, 2024 · 3cd1b8d · 3cd1b8d
1 parent dda04ec
commit 3cd1b8d
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/internal/pkg/listener/service.go b/internal/pkg/listener/service.go
@@ -6,6 +6,7 @@ import (
 	"encoding/gob"
 	"fmt"
 	"math"
+	"time"
 
 	"github.com/ethereum/go-ethereum"
 	"github.com/ethereum/go-ethereum/common"
@@ -139,9 +140,10 @@ func (s *EventService) Start(ctx context.Context) error {
 		return err
 	}
 
-	s.sub = event.ResubscribeErr(10, func(ctx context.Context, err error) (event.Subscription, error) {
+	s.sub = event.ResubscribeErr(5*time.Second, func(ctx context.Context, err error) (event.Subscription, error) {
 		if err != nil {
 			s.l.Errorw("Failed to re-subscribe the event", "err", err)
+			time.Sleep(1 * time.Second)
 		}
 
 		return s.subscribeNewHead(ctx)