From 9d96d1a9422b30dd6caa42cca2a561970735f160 Mon Sep 17 00:00:00 2001 From: Elizabeth Hunt Date: Sun, 21 Apr 2024 21:14:58 -0700 Subject: notify when we don't receive a thing in the last 24 hours --- ntfy/watcher.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'ntfy/watcher.go') diff --git a/ntfy/watcher.go b/ntfy/watcher.go index af4dd55..759c35b 100644 --- a/ntfy/watcher.go +++ b/ntfy/watcher.go @@ -30,7 +30,7 @@ func (w *NtfyWatcher) Watch() chan Message { retryTime := 5 * time.Second retries := retryCount - retry := func() { + sleepAndDecrementRetry := func() { log.Println("waiting 5 seconds before reconnecting. retries left:", retries, "topic:", topic, "endpoint:", w.Endpoint) time.Sleep(retryTime) retries-- @@ -45,7 +45,7 @@ func (w *NtfyWatcher) Watch() chan Message { resp, err := http.Get(endpoint) if err != nil { log.Println("error connecting to endpoint:", err) - retry() + sleepAndDecrementRetry() continue } @@ -60,7 +60,7 @@ func (w *NtfyWatcher) Watch() chan Message { if err := scanner.Err(); err != nil { log.Println("error reading response body:", err) - retry() + sleepAndDecrementRetry() } } }() -- cgit v1.2.3-70-g09d2