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

Cleanup more logging
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
Peter Stuifzand 2019-03-18 22:51:22 +01:00
parent df9bb9396c
commit 90cb4bc674
1 changed files with 14 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
cmd/hubserver/handler.go
View File

@ -174,13 +174,13 @@ func (handler *subscriptionHandler) handleSubscription(w http.ResponseWriter, r
log.Printf("subscribe: async validation with url %s\n", validationURL.String()) log.Printf("subscribe: async validation with url %s\n", validationURL.String())
if validateURL(validationURL.String(), ourChallenge) { if validateURL(validationURL.String(), ourChallenge) {
log.Printf("subscribe: validation valid\n") log.Println("subscribe: validation valid")
err = handler.store.Subscribe(topicURL.String(), storage.Subscriber{callbackURL.String(), leaseSeconds, secret, time.Now()}) err = handler.store.Subscribe(topicURL.String(), storage.Subscriber{callbackURL.String(), leaseSeconds, secret, time.Now()})
if err != nil { if err != nil {
log.Printf("saving suscriber failed: %v", err) log.Printf("saving subscribe failed: %v", err)
} }
} else { } else {
log.Printf("subscribe: validation failed\n") log.Println("subscribe: validation failed")
} }
}() }()
@ -227,17 +227,25 @@ func (handler *subscriptionHandler) ServeHTTP(w http.ResponseWriter, r *http.Req
mode := r.Form.Get("hub.mode") mode := r.Form.Get("hub.mode")
if mode == "subscribe" { if mode == "subscribe" {
log.Println("hub.mode=subscribe")
err = handler.handleSubscription(w, r) err = handler.handleSubscription(w, r)
log.Printf("saving subscribe failed: %v", err) if err != nil {
log.Printf("saving subscribe failed: %v", err)
}
return return
} else if mode == "unsubscribe" { } else if mode == "unsubscribe" {
log.Println("hub.mode=unsubscribe")
err = handler.handleUnsubscription(w, r) err = handler.handleUnsubscription(w, r)
log.Printf("saving unsubscribe failed: %v", err) if err != nil {
log.Printf("saving unsubscribe failed: %v", err)
}
return return
} else if mode == "publish" { } else if mode == "publish" {
log.Println("hub.mode=publish received") log.Println("hub.mode=publish received")
err = handler.handlePublish(w, r) err = handler.handlePublish(w, r)
log.Printf("handling publish failed: %v", err) if err != nil {
log.Printf("handling publish failed: %v", err)
}
return return
} else { } else {
http.Error(w, "Unknown hub.mode", 400) http.Error(w, "Unknown hub.mode", 400)