From c5de41f183122d106fb56134fddc6f8a6b7fdda4 Mon Sep 17 00:00:00 2001
From: kolaente <k@knt.li>
Date: Wed, 13 Sep 2023 21:36:00 +0200
Subject: [PATCH] feat(webhooks): add event listener to send webhook payload

---
 pkg/models/listeners.go | 52 +++++++++++++++++++++++++++++++++++++----
 pkg/models/webhooks.go  |  3 +++
 2 files changed, 51 insertions(+), 4 deletions(-)

diff --git a/pkg/models/listeners.go b/pkg/models/listeners.go
index f0d41f703f1..b443b22a098 100644
--- a/pkg/models/listeners.go
+++ b/pkg/models/listeners.go
@@ -17,8 +17,11 @@
 package models
 
 import (
+	"bytes"
 	"encoding/json"
+	"net/http"
 	"strconv"
+	"time"
 
 	"code.vikunja.io/api/pkg/config"
 
@@ -627,22 +630,63 @@ func (s *SendProjectCreatedNotification) Handle(msg *message.Message) (err error
 
 // WebhookListener represents a listener
 type WebhookListener struct {
+	EventName string
 }
 
 // Name defines the name for the WebhookListener listener
-func (s *WebhookListener) Name() string {
+func (wl *WebhookListener) Name() string {
 	return "webhook.listener"
 }
 
+type WebhookPayload struct {
+	EventName string       `json:"event_name"`
+	Time      time.Time    `json:"time"`
+	Data      WebhookEvent `json:"data"`
+}
+
 // Handle is executed when the event WebhookListener listens on is fired
-func (s *WebhookListener) Handle(msg *message.Message) (err error) {
-	event := &ProjectUpdatedEvent{}
+func (wl *WebhookListener) Handle(msg *message.Message) (err error) {
+	var event WebhookEvent
 	err = json.Unmarshal(msg.Payload, event)
 	if err != nil {
 		return err
 	}
 
-	return nil
+	s := db.NewSession()
+	defer s.Close()
+
+	ws := []*Webhook{}
+	err = s.Where("project_id = ?", event.ProjectID()).
+		Find(&ws)
+	if err != nil {
+		return err
+	}
+
+	var webhook *Webhook
+	for _, w := range ws {
+		for _, e := range w.Events {
+			if e == wl.EventName {
+				webhook = w
+				break
+			}
+		}
+
+	}
+
+	if webhook == nil {
+		return nil
+	}
+
+	payload, err := json.Marshal(WebhookPayload{
+		EventName: wl.EventName,
+		Time:      time.Now(),
+		Data:      event,
+	})
+	if err != nil {
+		return err
+	}
+	_, err = http.NewRequest(http.MethodPost, webhook.TargetURL, bytes.NewReader(payload))
+	return
 }
 
 ///////
diff --git a/pkg/models/webhooks.go b/pkg/models/webhooks.go
index 38db349a51c..f3a99e4c7b4 100644
--- a/pkg/models/webhooks.go
+++ b/pkg/models/webhooks.go
@@ -66,6 +66,9 @@ func RegisterEventForWebhook(event WebhookEvent) {
 	defer availableWebhookEventsLock.Unlock()
 
 	availableWebhookEvents[event.Name()] = true
+	events.RegisterListener(event.Name(), &WebhookListener{
+		EventName: event.Name(),
+	})
 }
 
 func (w *Webhook) Create(s *xorm.Session, a web.Auth) (err error) {