From 1eac7d05c525d565c45ad8e0aed2b0c667838465 Mon Sep 17 00:00:00 2001
From: Ingo Oppermann <ingo@datarhei.com>
Date: Tue, 21 Oct 2025 15:44:13 +0200
Subject: [PATCH] Add retry after failed connect to event source

---
 cluster/node/core.go | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/cluster/node/core.go b/cluster/node/core.go
index 600a9b1e..79cc5c2f 100644
--- a/cluster/node/core.go
+++ b/cluster/node/core.go
@@ -96,7 +96,7 @@ type Core struct {
 	hasSRT      bool
 	srtAddress  *url.URL
 
-	media     map[string]*Media // map[storage]map[path]lastchange
+	media     map[string]*Media
 	mediaLock sync.RWMutex
 
 	logger log.Logger
@@ -333,15 +333,15 @@ func (n *Core) mediaEvents(ctx context.Context, storage string) {
 		ch, err := n.client.MediaEvents(ctx, storage, "/**")
 		if err != nil {
 			m.available = false
-			m.media = nil
+			m.media = map[string]int64{}
 
 			n.mediaLock.Lock()
 			n.media[storage] = m
 			n.mediaLock.Unlock()
 
 			n.logger.Error().WithField("storage", storage).WithError(err).Log("Failed to connect to event source")
-
-			return
+			time.Sleep(5 * time.Second)
+			continue
 		}
 
 		n.logger.Info().WithField("storage", storage).Log("Connected to event source")