feat(SPV-1345): get webhooks

bitcoin-sv · Jan 2, 2025 · 00cce43 · 00cce43
1 parent 78e5200
commit 00cce43
Show file tree

Hide file tree

Showing 3 changed files with 29 additions and 3 deletions.
diff --git a/actions/admin/routes.go b/actions/admin/routes.go
@@ -36,7 +36,7 @@ func RegisterRoutes(handlersManager *handlers.Manager) {
 	adminGroupOld.POST("/xpubs/count", handlers.AsAdmin(xpubsCount))
 	adminGroupOld.POST("/webhooks/subscriptions", handlers.AsAdmin(subscribeWebhookOld))
 	adminGroupOld.DELETE("/webhooks/subscriptions", handlers.AsAdmin(unsubscribeWebhookOld))
-	adminGroupOld.GET("/webhooks/subscriptions", handlers.AsAdmin(getAllWebhooks))
+	adminGroupOld.GET("/webhooks/subscriptions", handlers.AsAdmin(getAllWebhooksOld))
 
 	adminGroupOld.GET("/transactions/:id", handlers.AsAdmin(getTxAdminByIDOld))
 	adminGroupOld.GET("/transactions", handlers.AsAdmin(getTransactionsOld))
@@ -71,6 +71,7 @@ func RegisterRoutes(handlersManager *handlers.Manager) {
 	adminGroup.GET("/utxos", handlers.AsAdmin(utxosSearch))
 
 	// webhooks
+	adminGroup.GET("/webhooks/subscriptions", handlers.AsAdmin(getAllWebhooks))
 	adminGroup.POST("/webhooks/subscriptions", handlers.AsAdmin(subscribeWebhook))
 	adminGroup.DELETE("/webhooks/subscriptions", handlers.AsAdmin(unsubscribeWebhook))
 

diff --git a/actions/admin/webhooks.go b/actions/admin/webhooks.go
@@ -4,6 +4,7 @@ import (
 	"net/http"
 
 	"github.com/bitcoin-sv/spv-wallet/engine/spverrors"
+	"github.com/bitcoin-sv/spv-wallet/mappings"
 	"github.com/bitcoin-sv/spv-wallet/models"
 	"github.com/bitcoin-sv/spv-wallet/server/reqctx"
 	"github.com/gin-gonic/gin"
@@ -61,3 +62,27 @@ func unsubscribeWebhook(c *gin.Context, _ *reqctx.AdminContext) {
 
 	c.Status(http.StatusOK)
 }
+
+// getAllWebhooks will return all the stored webhooks
+// @Summary		Get All Webhooks
+// @Description	Get All Webhooks currently subscribed to
+// @Tags		Admin
+// @Produce		json
+// @Success		200 {object} []models.Webhook "List of webhooks"
+// @Failure 	500	"Internal server error - Error while getting all webhooks"
+// @Router		/api/v1/admin/webhooks/subscriptions [get]
+// @Security	x-auth-xpub
+func getAllWebhooks(c *gin.Context, _ *reqctx.AdminContext) {
+	wh, err := reqctx.Engine(c).GetWebhooks(c.Request.Context())
+	if err != nil {
+		spverrors.ErrorResponse(c, err, reqctx.Logger(c))
+		return
+	}
+
+	webhookDTOs := make([]*models.Webhook, len(wh))
+	for i, w := range wh {
+		webhookDTOs[i] = mappings.MapToWebhookContract(w)
+	}
+
+	c.JSON(http.StatusOK, webhookDTOs)
+}
diff --git a/actions/admin/webhooks_old.go b/actions/admin/webhooks_old.go
@@ -64,7 +64,7 @@ func unsubscribeWebhookOld(c *gin.Context, _ *reqctx.AdminContext) {
 	c.JSON(http.StatusOK, true)
 }
 
-// getAllWebhooks will return all the stored webhooks
+// getAllWebhooksOld will return all the stored webhooks
 // @DeprecatedRouter /v1/admin/webhooks/subscriptions [get]
 // @Summary		Get All Webhooks
 // @Description	Get All Webhooks currently subscribed to
@@ -74,7 +74,7 @@ func unsubscribeWebhookOld(c *gin.Context, _ *reqctx.AdminContext) {
 // @Failure 	500	"Internal server error - Error while getting all webhooks"
 // @Router		/v1/admin/webhooks/subscriptions [get]
 // @Security	x-auth-xpub
-func getAllWebhooks(c *gin.Context, _ *reqctx.AdminContext) {
+func getAllWebhooksOld(c *gin.Context, _ *reqctx.AdminContext) {
 	wh, err := reqctx.Engine(c).GetWebhooks(c.Request.Context())
 	if err != nil {
 		spverrors.ErrorResponse(c, err, reqctx.Logger(c))