From 2ae7b384e5eb451fc9159267bc4531aa2a57981b Mon Sep 17 00:00:00 2001 From: sarthakjdev Date: Wed, 29 May 2024 00:40:05 +0530 Subject: [PATCH] chore: Wip Signed-off-by: sarthakjdev --- internal/manager/webhook_manager.go | 10 ++++------ pkg/client/client.go | 9 +++++++++ 2 files changed, 13 insertions(+), 6 deletions(-) diff --git a/internal/manager/webhook_manager.go b/internal/manager/webhook_manager.go index b8ca1e9..5d15ffc 100644 --- a/internal/manager/webhook_manager.go +++ b/internal/manager/webhook_manager.go @@ -47,16 +47,14 @@ func (wh *WebhookManager) createEchoHttpServer() *echo.Echo { } -func (wh *WebhookManager) getRequestHandler(c echo.Context) { - +func (wh *WebhookManager) GetRequestHandler(c echo.Context) { // this endpoint is used to verify the webhook - request := c.Request() fmt.Println(request) } -func (wh *WebhookManager) postRequestHandler(c echo.Context) { +func (wh *WebhookManager) PostRequestHandler(c echo.Context) { // emits events based on the payload of the request request := c.Request() @@ -82,12 +80,12 @@ func (wh *WebhookManager) ListenToEvents() { server := wh.createEchoHttpServer() server.GET(wh.path, func(c echo.Context) error { - wh.getRequestHandler(c) + wh.GetRequestHandler(c) return c.String(200, "ok") }) server.POST(wh.path, func(c echo.Context) error { - wh.postRequestHandler(c) + wh.PostRequestHandler(c) return c.String(200, "ok") }) diff --git a/pkg/client/client.go b/pkg/client/client.go index d3f9fb0..e90a2da 100644 --- a/pkg/client/client.go +++ b/pkg/client/client.go @@ -3,6 +3,7 @@ package wapi import ( "fmt" + "github.com/labstack/echo/v4" "github.com/sarthakjdev/wapi.go/internal/manager" requestclient "github.com/sarthakjdev/wapi.go/internal/request_client" "github.com/sarthakjdev/wapi.go/pkg/events" @@ -67,6 +68,14 @@ func (client *Client) InitiateClient() bool { return true } +func (client *Client) GetWebhookGetRequestHandler() func(c echo.Context) { + return client.webhook.GetRequestHandler +} + +func (client *Client) GetWebhookPostRequestHandler() func(c echo.Context) { + return client.webhook.PostRequestHandler +} + // OnMessage registers a handler for a specific event type. func (client *Client) On(eventType manager.EventType, handler func(events.BaseEvent)) { client.webhook.EventManager.On(eventType, handler)