chore: enhance connection closed scenario

piraces · May 19, 2023 · a622cf3 · a622cf3
1 parent b6dab31
commit a622cf3
Showing 1 changed file with 5 additions and 1 deletion.
diff --git 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 {