From a622cf395be0ca099efc7210dd9a6913b3059df6 Mon Sep 17 00:00:00 2001
From: piraces <raul.piraces@gmail.com>
Date: Fri, 19 May 2023 22:14:54 +0200
Subject: [PATCH] chore: enhance connection closed scenario

---
 pkg/replayer/replayer.go | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/pkg/replayer/replayer.go b/pkg/replayer/replayer.go
index 36d688e..7b70d77 100644
--- a/pkg/replayer/replayer.go
+++ b/pkg/replayer/replayer.go
@@ -55,7 +55,11 @@ func ReplayEventsToRelays(parameters *ReplayParameters) {
 					continue
 				}
 
-				relay = connectToRelay(url)
+				err := relay.Connection.Ping()
+				if err != nil {
+					log.Printf("[DEBUG] ping to relay failed, reconnecting to %s because of error: %v\n", url, err)
+					relay = connectToRelay(url)
+				}
 				publishStatus, err := relay.Publish(context.Background(), ev.Event)
 				_ = relay.Close()
 				if err != nil {