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

Add verification start

Browse Source
This commit is contained in:
Peter Stuifzand 2018-01-29 22:36:59 +01:00
parent 9333c94ef2
commit 79a959f3b9
1 changed files with 24 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
cmd/hubserver/main.go
View File

@ -3,12 +3,23 @@ package main
import ( import (
"fmt" "fmt"
"log" "log"
"strings" //"strings"
//import "strconv" //import "strconv"
"math/rand"
"net/http" "net/http"
"net/url" "net/url"
) )
const letterBytes = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ"
func RandStringBytes(n int) string {
b := make([]byte, n)
for i := range b {
b[i] = letterBytes[rand.Intn(len(letterBytes))]
}
return string(b)
}
type subscriptionHandler struct { type subscriptionHandler struct {
} }
@ -53,10 +64,19 @@ func (handler *subscriptionHandler) ServeHTTP(w http.ResponseWriter, r *http.Req
go func() { go func() {
client := http.Client{} client := http.Client{}
req, err := http.NewRequest("POST", callbackURL.String(), strings.NewReader("TEST"))
req.Header.Add("Content-Type", "text/plain") validationURL := callbackURL
req.Header.Add("Link", fmt.Sprintf("<https://hub.stuifzandapp.com/>; rel=hub, <%s>; rel=self", topicURL.String())) validationURL.Query().Add("hub.mode", "subscribe")
validationURL.Query().Add("hub.topic", topicURL.String())
validationURL.Query().Add("hub.challenge", RandStringBytes(12))
req, err := http.NewRequest(http.MethodGet, callbackURL.String(), nil)
res, err := client.Do(req) res, err := client.Do(req)
// req, err := http.NewRequest("POST", callbackURL.String(), strings.NewReader("TEST"))
// req.Header.Add("Content-Type", "text/plain")
// req.Header.Add("Link", fmt.Sprintf("<https://hub.stuifzandapp.com/>; rel=hub, <%s>; rel=self", topicURL.String()))
// res, err := client.Do(req)
log.Println(res, err) log.Println(res, err)
}() }()