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

Add some logging
Some checks failed
continuous-integration/drone/push Build is failing
Details

Browse Source
This commit is contained in:
Peter Stuifzand 2019-03-18 22:11:28 +01:00
parent d75e55ec49
commit d58d21d491
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
cmd/hubserver/handler.go
View File

@ -175,7 +175,8 @@ func (handler *subscriptionHandler) handleSubscription(w http.ResponseWriter, r
if validateURL(validationURL.String(), ourChallenge) { if validateURL(validationURL.String(), ourChallenge) {
log.Printf("subscribe: validation valid\n") log.Printf("subscribe: validation valid\n")
_ = 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()})
log.Println("saving suscriber failed: %v", err)
} else { } else {
log.Printf("subscribe: validation failed\n") log.Printf("subscribe: validation failed\n")
} }
@ -224,13 +225,16 @@ func (handler *subscriptionHandler) ServeHTTP(w http.ResponseWriter, r *http.Req
if mode == "subscribe" { if mode == "subscribe" {
err = handler.handleSubscription(w, r) err = handler.handleSubscription(w, r)
log.Println("saving subscribe failed: %v", err)
return return
} else if mode == "unsubscribe" { } else if mode == "unsubscribe" {
err = handler.handleUnsubscription(w, r) err = handler.handleUnsubscription(w, r)
log.Println("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.Println("handling publish failed: %v", err)
return return
} else { } else {
http.Error(w, "Unknown hub.mode", 400) http.Error(w, "Unknown hub.mode", 400)