From 084888880b7833972d84216061bfbe0fa73a1fb5 Mon Sep 17 00:00:00 2001 From: Peter Stuifzand Date: Tue, 18 Dec 2018 20:14:59 +0100 Subject: [PATCH] Don't resubscribe at feeds without Hub --- cmd/eksterd/hubbackend.go | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/cmd/eksterd/hubbackend.go b/cmd/eksterd/hubbackend.go index 9a3fb57..3018a41 100644 --- a/cmd/eksterd/hubbackend.go +++ b/cmd/eksterd/hubbackend.go @@ -181,8 +181,12 @@ func (h *hubIncomingBackend) GetFeeds() []Feed { } } - log.Printf("Websub feed: %#v\n", feed) + // Skip feeds without a Hub + if feed.Hub == "" { + continue + } + log.Printf("Websub feed: %#v\n", feed) feeds = append(feeds, feed) } @@ -210,7 +214,7 @@ func (h *hubIncomingBackend) run() error { if feed.Callback == "" { feed.Callback = fmt.Sprintf("%s/incoming/%d", h.baseURL, feed.ID) } - log.Printf("Send resubscribe for %s\n", feed.URL) + log.Printf("Send resubscribe for %q on %q\n", feed.URL, feed.Hub) err := h.Subscribe(&feed) if err != nil { log.Printf("Error while subscribing: %s", err)