peter/websub-hub
1
0
Fork 0
Code Issues 1 Pull Requests Releases Activity

Also send hub.mode

Browse Source
This commit is contained in:
Peter Stuifzand 2018-01-30 21:51:51 +01:00
parent 7448b0f878
commit 418a997fbf
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
cmd/hubserver/main.go
View File

@ -83,6 +83,7 @@ func (handler *subscriptionHandler) handleUnsubscription(w http.ResponseWriter,
log.Println(r.Form.Encode()) log.Println(r.Form.Encode())
callback := r.Form.Get("hub.callback") callback := r.Form.Get("hub.callback")
topic := r.Form.Get("hub.topic") topic := r.Form.Get("hub.topic")
mode := r.Form.Get("hub.mode")
if subs, e := handler.Subscribers[topic]; e { if subs, e := handler.Subscribers[topic]; e {
for i, sub := range subs { for i, sub := range subs {
@ -90,6 +91,17 @@ func (handler *subscriptionHandler) handleUnsubscription(w http.ResponseWriter,
continue continue
} }
ourChallenge := randStringBytes(12) ourChallenge := randStringBytes(12)
validationURL, err := url.Parse(callback)
if err != nil {
log.Println(err)
return err
}
q := validationURL.Query()
q.Add("hub.mode", mode)
q.Add("hub.topic", topic)
q.Add("hub.challenge", ourChallenge)
validationURL.RawQuery = q.Encode()
if validateURL(sub.Callback, ourChallenge) { if validateURL(sub.Callback, ourChallenge) {
subs = append(subs[:i], subs[i+1:]...) subs = append(subs[:i], subs[i+1:]...)
break break