wip: phoenixd webhook

lightning/phoenixd/phoenixd.go

@@ -11,6 +11,7 @@ import (
 	"strings"
 
 	"github.com/ekzyis/zaply/lightning"
+	"github.com/labstack/echo/v4"
 )
 
 type Phoenixd struct {
@@ -96,3 +97,18 @@ func (p *Phoenixd) CreateInvoice(msats int64, description string) (lightning.Bol
 
 	return lightning.Bolt11(response.Serialized), nil
 }
+
+func WebhookHandler(c echo.Context) error {
+	var webhook struct {
+		Type        string `json:"type"`
+		AmountSat   int64  `json:"amountSat"`
+		PaymentHash string `json:"paymentHash"`
+	}
+	if err := c.Bind(&webhook); err != nil {
+		return err
+	}
+
+	log.Printf("webhook: %+v", webhook)
+
+	return c.NoContent(http.StatusOK)
+}

server/server.go

@@ -1,6 +1,9 @@
 package server
 
 import (
+	"log"
+	"net/url"
+
 	"github.com/ekzyis/zaply/env"
 	"github.com/ekzyis/zaply/lightning/phoenixd"
 	"github.com/ekzyis/zaply/lnurl"
@@ -17,16 +20,25 @@ func NewServer() *Server {
 		Echo: echo.New(),
 	}
 
-	p := phoenixd.NewPhoenixd(
-		phoenixd.WithPhoenixdURL(env.PhoenixdURL),
-		phoenixd.WithPhoenixdLimitedAccessToken(env.PhoenixdLimitedAccessToken),
-	)
-
 	s.Use(middleware.LoggerWithConfig(middleware.LoggerConfig{
 		Format:           "${time_custom} ${method} ${uri} ${status}\n",
 		CustomTimeFormat: "2006-01-02 15:04:05.00000-0700",
 	}))
 
+	webhookPath := "/overlay/webhook"
+	webhookUrl, err := url.JoinPath(env.PublicUrl, webhookPath)
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	p := phoenixd.NewPhoenixd(
+		phoenixd.WithPhoenixdURL(env.PhoenixdURL),
+		phoenixd.WithPhoenixdLimitedAccessToken(env.PhoenixdLimitedAccessToken),
+		phoenixd.WithPhoenixdWebhookUrl(webhookUrl),
+	)
+
+	s.POST(webhookPath, phoenixd.WebhookHandler)
+
 	lnurl.Router(s.Echo, p)
 
 	return s