forked from an/flokati
		
	added modules/webhoook.go
This commit is contained in:
		
							parent
							
								
									327cb50aab
								
							
						
					
					
						commit
						8ef027800c
					
				
					 1 changed files with 39 additions and 0 deletions
				
			
		
							
								
								
									
										39
									
								
								modules/webhook.go
									
										
									
									
									
										Normal file
									
								
							
							
						
						
									
										39
									
								
								modules/webhook.go
									
										
									
									
									
										Normal file
									
								
							|  | @ -0,0 +1,39 @@ | |||
| // vi:ts=4:sts=4:sw=4:noet:tw=72 | ||||
| 
 | ||||
| package modules | ||||
| 
 | ||||
| import ( | ||||
| 	"encoding/json" | ||||
| 	"fmt" | ||||
| 	"log" | ||||
| 	"net/http" | ||||
| 
 | ||||
| 	"git.dnix.de/an/xlog" | ||||
| ) | ||||
| 
 | ||||
| func init() { | ||||
| 	MsgFuncs["webhook"] = webhookHandleMessage | ||||
| 	RunFuncs["webhook"] = webhookRun | ||||
| } | ||||
| 
 | ||||
| func webhookRun() { | ||||
| 	xlog.Info("webhook listener started") | ||||
| 	http.HandleFunc("/webhook", webhookHandleHTTP) | ||||
| 	log.Fatal(http.ListenAndServe(":8080", nil)) | ||||
| } | ||||
| 
 | ||||
| func webhookHandleHTTP(w http.ResponseWriter, r *http.Request) { | ||||
| 	data := make(map[string]interface{}) | ||||
| 	err := json.NewDecoder(r.Body).Decode(&data) | ||||
| 	if err != nil { | ||||
| 		http.Error(w, err.Error(), http.StatusInternalServerError) | ||||
| 		return | ||||
| 	} | ||||
| 	fmt.Println("got webhook payload: ") | ||||
| 	for k, v := range webhookData { | ||||
| 		fmt.Printf("%s : %v\n", k, v) | ||||
| 	} | ||||
| } | ||||
| 
 | ||||
| func webhookHandleMessage(m *Message) { | ||||
| } | ||||
		Loading…
	
	Add table
		Add a link
		
	
		Reference in a new issue