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

Disable incStat
All checks were successful
the build was successful
Details

Browse Source
This commit is contained in:
Peter Stuifzand 2018-08-05 18:00:15 +02:00
parent aa257744f0
commit 68d84bdaa3
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
cmd/hubserver/main.go
View File

@ -66,12 +66,12 @@ func (handler *subscriptionHandler) handlePublish(w http.ResponseWriter, r *http
return err return err
} }
handler.incStat(fmt.Sprintf("publish.%s", topic)) // handler.incStat(fmt.Sprintf("publish.%s", topic))
if subs, e := handler.Subscribers[topic]; e { if subs, e := handler.Subscribers[topic]; e {
for _, sub := range subs { for _, sub := range subs {
handler.incStat(fmt.Sprintf("publish.post.%s.%s", topic, sub.Callback)) // handler.incStat(fmt.Sprintf("publish.post.%s.%s", topic, sub.Callback))
log.Printf("publish: creating post to %s\n", sub.Callback) log.Printf("publish: creating post to %s\n", sub.Callback)
postReq, err := http.NewRequest("POST", sub.Callback, strings.NewReader(string(feedContent))) postReq, err := http.NewRequest("POST", sub.Callback, strings.NewReader(string(feedContent)))
if err != nil { if err != nil {
@ -264,7 +264,7 @@ func (handler *subscriptionHandler) ServeHTTP(w http.ResponseWriter, r *http.Req
if r.Method == http.MethodGet { if r.Method == http.MethodGet {
fmt.Fprintln(w, "WebSub hub") fmt.Fprintln(w, "WebSub hub")
if r.URL.Query().Get("debug") == "1" { if r.URL.Query().Get("debug") == "1" {
handler.incStat("http.index.debug") // handler.incStat("http.index.debug")
enc := json.NewEncoder(w) enc := json.NewEncoder(w)
enc.SetIndent("", " ") enc.SetIndent("", " ")
enc.Encode(handler.Subscribers) enc.Encode(handler.Subscribers)