From 2f9f57107d720550d704f94af23b7f5f355e5741 Mon Sep 17 00:00:00 2001 From: Peter Stuifzand Date: Tue, 30 Jan 2018 20:48:34 +0100 Subject: [PATCH] Add POST to callback --- cmd/hubserver/main.go | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) diff --git a/cmd/hubserver/main.go b/cmd/hubserver/main.go index 1656605..44ea349 100644 --- a/cmd/hubserver/main.go +++ b/cmd/hubserver/main.go @@ -36,6 +36,22 @@ func (handler *subscriptionHandler) handlePublish(w http.ResponseWriter, r *http topic := r.Form.Get("hub.topic") log.Printf("Topic = %s\n", topic) + client := &http.Client{} + res, err := client.Get(topic) + if err != nil { + return err + } + + if subs, e := handler.Subscribers[topic]; e { + for _, sub := range subs { + res, err = http.Post(sub.Callback, res.Header.Get("Content-Type"), res.Body) + if err != nil { + log.Printf("While POSTing to %s: %s", sub.Callback, err) + continue + } + } + } + return nil }