diff options
Diffstat (limited to 'ntfy')
| -rw-r--r-- | ntfy/publisher.go | 16 | ||||
| -rw-r--r-- | ntfy/watcher.go | 6 |
2 files changed, 19 insertions, 3 deletions
diff --git a/ntfy/publisher.go b/ntfy/publisher.go new file mode 100644 index 0000000..68f8e49 --- /dev/null +++ b/ntfy/publisher.go @@ -0,0 +1,16 @@ +package ntfy + +import ( + "net/http" + "strings" +) + +func SendMessage(message string, endpoint string, topics []string) error { + for _, topic := range topics { + _, err := http.Post(endpoint+"/"+topic, "text/plain", strings.NewReader(message)) + if err != nil { + return err + } + } + return nil +} 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() } } }() |