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

post to irc

This commit is contained in:
an 2018-04-22 11:39:52 +02:00
parent 80f2f13aee
commit 41be481497
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
modules/webhook.go
View File

@ -4,13 +4,18 @@ package modules
import ( import (
"encoding/json" "encoding/json"
"flag"
"fmt" "fmt"
"log"
"net/http" "net/http"
"git.dnix.de/an/xlog" "git.dnix.de/an/xlog"
) )
var (
webhookPort = flag.String("webhook_port", "8080", "Webhook listener port")
webhookChan = flag.String("webhook_chan", "", "Channel to post into")
)
func init() { func init() {
MsgFuncs["webhook"] = webhookHandleMessage MsgFuncs["webhook"] = webhookHandleMessage
RunFuncs["webhook"] = webhookRun RunFuncs["webhook"] = webhookRun
@ -19,7 +24,7 @@ func init() {
func webhookRun() { func webhookRun() {
xlog.Info("webhook listener started") xlog.Info("webhook listener started")
http.HandleFunc("/webhook", webhookHandleHTTP) http.HandleFunc("/webhook", webhookHandleHTTP)
log.Fatal(http.ListenAndServe(":8080", nil)) xlog.Fatal(http.ListenAndServe(":"+*webhookPort, nil))
} }
func webhookHandleHTTP(w http.ResponseWriter, r *http.Request) { func webhookHandleHTTP(w http.ResponseWriter, r *http.Request) {
@ -32,6 +37,9 @@ func webhookHandleHTTP(w http.ResponseWriter, r *http.Request) {
fmt.Println("got webhook payload: ") fmt.Println("got webhook payload: ")
for k, v := range data { for k, v := range data {
fmt.Printf("%s : %v\n", k, v) fmt.Printf("%s : %v\n", k, v)
if k == "text" {
sayCh <- *webhookChan + "\n" + v
}
} }
} }