From 20169926062e15ceb471d09b0fc382e4523f9402 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Louis=20G=C3=A9rard?= Date: Thu, 23 Jan 2025 06:25:54 +0100 Subject: [PATCH] fix(server): remove retry logic MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Louis Gérard --- internal/firehose/stream.go | 24 ++++++++---------------- 1 file changed, 8 insertions(+), 16 deletions(-) diff --git a/internal/firehose/stream.go b/internal/firehose/stream.go index 9cfda74..7ae5b8d 100644 --- a/internal/firehose/stream.go +++ b/internal/firehose/stream.go @@ -139,22 +139,14 @@ func (fh *FirehoseListener) SubscribeFirehose() { }, } scheduler := sequential.NewScheduler("stream", rsc.EventHandler) - maxRetries := 5 - delay := 10 * time.Second - currentRetry := 0 - for currentRetry < maxRetries { - fh.logger.Info("trying to connect", "try", currentRetry, "maxRetries", maxRetries) - con, _, err := websocket.DefaultDialer.Dial(uri, http.Header{}) - if err != nil { - fh.logger.Info("failed to establish connection", "err", err.Error()) - time.Sleep(delay * time.Duration(currentRetry)) - continue - } - err = events.HandleRepoStream(ctx, con, scheduler, fh.logger) - if err != nil { - fh.logger.Error("handling repo stream", "err", err.Error()) - time.Sleep(delay * time.Duration(currentRetry)) - } + con, _, err := websocket.DefaultDialer.Dial(uri, http.Header{}) + if err != nil { + fh.logger.Info("failed to establish connection", "err", err.Error()) + return + } + err = events.HandleRepoStream(ctx, con, scheduler, fh.logger) + if err != nil { + fh.logger.Error("handling repo stream", "err", err.Error()) } } -- 2.54.0