sikk
/
flokati
forked from an/flokati
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

make token a parameter

This commit is contained in:
an 2018-04-22 13:43:19 +02:00
parent 23f324ccad
commit df0303ebcf
1 changed files with 4 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
modules/webhook.go
View File

@ -7,7 +7,6 @@ import (
"flag" "flag"
"fmt" "fmt"
"net/http" "net/http"
"strings"
"git.dnix.de/an/xlog" "git.dnix.de/an/xlog"
) )
@ -15,6 +14,7 @@ import (
var ( var (
webhookPort = flag.String("webhook_port", "8080", "Webhook listener port") webhookPort = flag.String("webhook_port", "8080", "Webhook listener port")
webhookChan = flag.String("webhook_chan", "", "Channel to post into") webhookChan = flag.String("webhook_chan", "", "Channel to post into")
webhookToken = flag.String("webhook_token", "", "Token")
) )
func init() { func init() {
@ -24,24 +24,10 @@ func init() {
func webhookRun() { func webhookRun() {
xlog.Info("webhook listener started") xlog.Info("webhook listener started")
http.HandleFunc("/webhook", webhookHandleHTTP) http.HandleFunc("/webhook/"+*webhookToken, webhookHandleHTTP)
xlog.Fatal("%v", http.ListenAndServe(":"+*webhookPort, nil)) xlog.Fatal("%v", http.ListenAndServe(":"+*webhookPort, nil))
} }
func webhookHandleMessage(m *Message) {
tok := strings.Split(m.Text, " ")
if len(tok) < 1 {
return
}
switch tok[0] {
case "!webhook-add":
if len(tok) > 1 {
http.HandleFunc("/webhook/"+tok[1], webhookHandleHTTP)
}
default:
}
}
func webhookHandleHTTP(w http.ResponseWriter, r *http.Request) { func webhookHandleHTTP(w http.ResponseWriter, r *http.Request) {
data := make(map[string]interface{}) data := make(map[string]interface{})
err := json.NewDecoder(r.Body).Decode(&data) err := json.NewDecoder(r.Body).Decode(&data)