Event-based webhook

* code cleanup

@@ -103,6 +104,7 @@ func FullInit() {
 	go func() {
 		models.RegisterListeners()
 		user.RegisterListeners()
+		webhooks.RegisterListeners()

@@ -322,0 +325,4 @@
+  # If set to true, HTTP POST is executed
+  enabled: true
+  # URL for webhook
+  url: "http://127.0.0.1/test/"

@@ -161,2 +161,4 @@
 	MetricsUsername Key = `metrics.username`
 	MetricsPassword Key = `metrics.password`
+
+	WebhookConf      Key = `webhooks`

@@ -372,0 +380,4 @@
+
+	WebhookConf.setDefault( []int{} )
+	// WebhookEnabled.setDefault(false)
+	// WebhookURL.setDefault("")

@@ -72,7 +74,10 @@ func InitEvents() (err error) {
 		return nil
 	})
 
+	whMiddleware := webhooks.GenerateMiddleware()

@@ -75,1 +77,4 @@
+	whMiddleware := webhooks.GenerateMiddleware()
+
 	router.AddMiddleware(
+		whMiddleware, //webhooks.WebhookMiddleware, 

@@ -88,1 +93,4 @@
 
+	router.AddMiddleware(
+
+	)

@@ -0,0 +1,91 @@
+package webhooks

@@ -0,0 +8,4 @@
+	"github.com/ThreeDotsLabs/watermill/message"
+)
+
+// type middlwareFunc func(message.HandlerFunc) message.HandlerFunc

@@ -0,0 +28,4 @@
+
+
+
+func TheGreatWebhookHandler(cfg []WebhookRuntimeConfig, topic string, msg *message.Message) {

@@ -0,0 +34,4 @@
+		log.Debugf("Checking webhook config [%d]", i)
+		if entry.FilterFunc(topic) {
+			log.Debugf("Executing webhook [%d]", i)
+			entry.ExecuteFunc(topic, msg)

@@ -0,0 +42,4 @@
+
+/*
+
+func OldWebhookMiddleware(h message.HandlerFunc) message.HandlerFunc {

@@ -0,0 +1,142 @@
+

@@ -0,0 +19,4 @@
+)
+
+const (
+	timeoutVal = 5 * time.Second

@@ -0,0 +21,4 @@
+const (
+	timeoutVal = 5 * time.Second
+	ctHeader = "Content-Type"
+	ctValue = "application/json"

@@ -0,0 +22,4 @@
+	timeoutVal = 5 * time.Second
+	ctHeader = "Content-Type"
+	ctValue = "application/json"
+	hmacHeader = "X-signature"

@@ -0,0 +44,4 @@
+
+
+
+func GetWebhookFilterFunc(cfg SingleConfEntry) FilteringFunction {

@@ -0,0 +45,4 @@
+
+
+func GetWebhookFilterFunc(cfg SingleConfEntry) FilteringFunction {
+	return func(topic string) (iteresting bool) {

@@ -0,0 +48,4 @@
+	return func(topic string) (iteresting bool) {
+		for _, filter := range cfg.Events {
+			log.Debugf("Match pattern:'%s' agains:'%s'", filter, topic)
+			if filter == "*" {

@@ -0,0 +53,4 @@
+				return true
+			} else {
+				if strings.HasPrefix(topic, filter) {
+					log.Debugf(" Positive match ")

@@ -0,0 +62,4 @@
+	}
+}
+
+func GetWebhookCallFunc(cfg SingleConfEntry) WebhookCallFunction {

@@ -0,0 +70,4 @@
+		log.Debugf("Webhook Call : %s (%s)", endpointURL, hmacKey)
+		webhookUrl := fmt.Sprintf("%s%s", endpointURL, topic)
+		
+		rawData := msg.Payload

@@ -0,0 +72,4 @@
+		
+		rawData := msg.Payload
+
+		req, err1 := http.NewRequest( http.MethodPost, webhookUrl,  bytes.NewBuffer(rawData))

@@ -0,0 +89,4 @@
+			req.Header.Set(hmacHeader, signature)
+		}
+
+		_, err2 := client.Do(req)

@@ -0,0 +91,4 @@
+
+		_, err2 := client.Do(req)
+
+		//_, err := http.Post(webhook_url, "application/json",data) "x-vikunja-signature"

@@ -0,0 +97,4 @@
+			return err2
+		}
+
+		log.Debugf("Webhook success : %s ", webhookUrl )

@@ -0,0 +117,4 @@
+	
+	var items []SingleConfEntry
+
+	config.WebhookConf.GetUnmarshaled(&items)

@@ -0,0 +121,4 @@
+
+	runtime := make([]WebhookRuntimeConfig, len(items))
+
+	fmt.Printf("RAW: %+v\n", items)

@@ -322,0 +326,4 @@
+    # URL for webhook
+    url: "http://127.0.0.1/test/test1/?q="
+    secret : "abc123"
+    timeout : 3