implement webhook push handler

implement handler function to send
events to registered webhook

registered handle function will get
called when the events happen.
check origin UUID, if it is same as the peer ID
send events to the registered webhook

Signed-off-by: Madhu Rajanna <mrajanna@redhat.com>

Author: Madhu-1

glusterd2/events/eventhandler.go

@@ -1,6 +1,7 @@
 package events
 
 import (
+	"encoding/json"
 	"fmt"
 	"net/http"
 	"sort"
@@ -11,6 +12,7 @@ import (
 	"github.com/gluster/glusterd2/pkg/api"
 	eventsapi "github.com/gluster/glusterd2/plugins/events/api"
 
+	jwt "github.com/dgrijalva/jwt-go"
 	log "github.com/sirupsen/logrus"
 )
 
@@ -161,14 +163,34 @@ func (h *handler) Events() []string {
 	return h.events
 }
 
-func getJWTToken(url string, secret string) string {
-	//TODO generate the gwt token from the sceret
-	return ""
+func getJWTToken(eventtype, secret string) string {
+	claims := &jwt.StandardClaims{
+		IssuedAt:  time.Now().Unix(),
+		ExpiresAt: time.Now().Add(time.Second * 10).Unix(),
+		Subject:   eventtype,
+	}
+
+	token := jwt.NewWithClaims(jwt.SigningMethodHS256, claims)
+	ss, err := token.SignedString([]byte(secret))
+	if err != nil {
+		return ""
+	}
+	return ss
 }
 
-//SendWebhookMsg sends HTTP Post request to webhook URL
-func SendWebhookMsg(webhook *eventsapi.Webhook, message string) error {
-	body := strings.NewReader(message)
+//WebhookPublish sends event to registered webhooks
+func WebhookPublish(webhook *eventsapi.Webhook, e *api.Event) error {
+	message, err := json.Marshal(e)
+	if err != nil {
+		log.WithFields(log.Fields{
+			"name":  e.Name,
+			"error": err.Error(),
+		}).Error("failed to marshal event")
+		return err
+	}
+
+	body := strings.NewReader(string(message))
+
 	req, err := http.NewRequest("POST", webhook.URL, body)
 	if err != nil {
 		log.WithError(err).Error("error forming the request object")
@@ -180,7 +202,7 @@ func SendWebhookMsg(webhook *eventsapi.Webhook, message string) error {
 	}
 
 	if webhook.Secret != "" {
-		token := getJWTToken(webhook.URL, webhook.Secret)
+		token := getJWTToken(e.Name, webhook.Secret)
 		req.Header.Set("Authorization", "bearer "+token)
 	}
 

glusterd2/servers/eventlistener/handler.go

@@ -21,15 +21,6 @@ func getWebhooks() []*eventsapi.Webhook {
 	return webhooks
 }
 
-func webhookPublish(webhook *eventsapi.Webhook, message string) {
-	err := gd2events.SendWebhookMsg(webhook, message)
-	if err != nil {
-		log.WithError(err).Error("Error while publishing event to webhook")
-	}
-
-	return
-}
-
 func handleMessage(inMessage string, addr *net.UDPAddr) {
 	data := strings.SplitN(inMessage, " ", 3)
 	if len(data) != 3 {

plugins/events/hooks.go

@@ -0,0 +1,45 @@
+package events
+
+import (
+	gd2events "github.com/gluster/glusterd2/glusterd2/events"
+	"github.com/gluster/glusterd2/glusterd2/gdctx"
+	"github.com/gluster/glusterd2/pkg/api"
+	eventsapi "github.com/gluster/glusterd2/plugins/events/api"
+	"github.com/pborman/uuid"
+
+	log "github.com/sirupsen/logrus"
+)
+
+type webhooksNotifier struct{}
+
+func (w *webhooksNotifier) Handle(e *api.Event) {
+	//send events only from originator node
+	if !uuid.Equal(e.Origin, gdctx.MyUUID) {
+		return
+	}
+	// Get the list of registered Webhooks
+	webhooks, err := GetWebhookList()
+	if err != nil {
+		log.WithError(err).Error("error retriving webhook list from etcd")
+		return
+	}
+
+	for _, w := range webhooks {
+		go func(e *api.Event, w *eventsapi.Webhook) {
+			err = gd2events.WebhookPublish(w, e)
+			if err != nil {
+				log.WithError(err).Error("error in pushing data to webhook")
+			}
+		}(e, w)
+	}
+
+}
+
+func (w *webhooksNotifier) Events() []string {
+	return []string{}
+}
+
+func init() {
+	w := new(webhooksNotifier)
+	gd2events.Register(w)
+}

plugins/events/rest.go

@@ -128,10 +128,12 @@ func eventsListHandler(w http.ResponseWriter, r *http.Request) {
 
 func checkConnection(c transaction.TxnCtx) error {
 	var req eventsapi.Webhook
+
 	if err := c.Get("req", &req); err != nil {
 		return err
 	}
-	return gd2events.SendWebhookMsg(&req, "")
+	e := gd2events.New("TEST", map[string]string{}, false)
+	return gd2events.WebhookPublish(&req, e)
 }
 
 func registerWebhookTestStepFuncs() {