testing webhooks
This commit is contained in:
parent
df0303ebcf
commit
f603c503f6
|
@ -14,7 +14,6 @@ import (
|
|||
var (
|
||||
webhookPort = flag.String("webhook_port", "8080", "Webhook listener port")
|
||||
webhookChan = flag.String("webhook_chan", "", "Channel to post into")
|
||||
webhookToken = flag.String("webhook_token", "", "Token")
|
||||
)
|
||||
|
||||
func init() {
|
||||
|
@ -24,10 +23,24 @@ func init() {
|
|||
|
||||
func webhookRun() {
|
||||
xlog.Info("webhook listener started")
|
||||
http.HandleFunc("/webhook/"+*webhookToken, webhookHandleHTTP)
|
||||
http.HandleFunc("/webhook", webhookHandleHTTP)
|
||||
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) {
|
||||
data := make(map[string]interface{})
|
||||
err := json.NewDecoder(r.Body).Decode(&data)
|
||||
|
|
Loading…
Reference in New Issue