feat: add nip47 notifications endpoint

README.md

@@ -198,6 +198,61 @@ Notifies about new events matching the filter provided via webhooks.
 // Source: https://pkg.go.dev/github.com/nbd-wtf/[email protected]#Filter
 ```
 
+#### Response
+
+```json
+{
+  "subscription_id": "f370d1fc-x0x0-x0x0-x0x0-8f68fa12f32c",
+  "webhookUrl": "https://your.webhook.url"
+}
+```
+
+#### Response to Webhook URL
+
+```json
+{
+  "id": "a16ycf4a01bcxx........xxxxx",
+  "pubkey": "a16y69effexxxx........xxxxx",
+  "created_at": 1709033612,
+  "kind": 23195,
+  "tags": [
+      [
+          "p",
+          "f490f5xxxxx........xxxxx"
+      ],
+      [
+          "e",
+          "a41aefxxxxx........xxxxx"
+      ]
+  ],
+  "content": "<encrypted content>",
+  "sig": "<signature>"
+}
+```
+
+</details>
+
+------------------------------------------------------------------------------------------
+
+### Subscribe to NWC Events
+
+Notifies about new response events which are requested by the pubkey to the wallet service.
+
+<details>
+<summary>
+<code>POST</code> <code><b>/nip47/subscriptions</b></code>
+</summary>
+
+#### Request Body
+
+| name      |  type     | data type               | description                                                           |
+|-----------|-----------|-------------------------|-----------------------------------------------------------------------|
+| relayUrl  |  optional | string           | If no relay is provided, it uses the default relay  |
+| webhookUrl  |  required | string         | Webhook URL to publish events |
+| walletPubkey  |  required | string         | Pubkey of the NWC Wallet Provider |
+| connectionPubkey  |  required | string         | Public key of the user (derived from secret in NWC connection string) |
+
+
 #### Response
 
 ```json

cmd/server/main.go

@@ -33,6 +33,7 @@ func main() {
 
 	e.POST("/nip47/info", svc.InfoHandler)
 	e.POST("/nip47", svc.NIP47Handler)
+	e.POST("/nip47/notifications", svc.NIP47NotificationHandler)
 	e.POST("/publish", svc.PublishHandler)
 	e.POST("/subscriptions", svc.SubscriptionHandler)
 	e.DELETE("/subscriptions/:id", svc.StopSubscriptionHandler)

internal/nostr/models.go

@@ -158,6 +158,13 @@ type NIP47Request struct {
 	SignedEvent  *nostr.Event `json:"event"`
 }
 
+type NIP47NotificationRequest struct {
+	RelayUrl     string        `json:"relayUrl"`
+	WebhookUrl   string        `json:"webhookUrl"`
+	WalletPubkey string        `json:"walletPubkey"`
+	ConnPubkey   string        `json:"connectionPubkey"`
+}
+
 type NIP47Response struct {
 	Event  *nostr.Event `json:"event,omitempty"`
 	State  string       `json:"state"`

internal/nostr/nostr.go

@@ -395,6 +395,69 @@ func (svc *Service) NIP47Handler(c echo.Context) error {
 	})
 }
 
+func (svc *Service) NIP47NotificationHandler(c echo.Context) error {
+	var requestData NIP47NotificationRequest
+	// send in a pubkey and authenticate by signing
+	if err := c.Bind(&requestData); err != nil {
+		return c.JSON(http.StatusBadRequest, ErrorResponse{
+			Message: "Error decoding subscription request",
+			Error:   err.Error(),
+		})
+	}
+
+	if (requestData.WebhookUrl == "") {
+		return c.JSON(http.StatusBadRequest, ErrorResponse{
+			Message: "webhook url is empty",
+			Error:   "no webhook url in request data",
+		})
+	}
+
+	if (requestData.WalletPubkey == "") {
+		return c.JSON(http.StatusBadRequest, ErrorResponse{
+			Message: "Wallet pubkey is empty",
+			Error:   "no wallet pubkey in request data",
+		})
+	}
+
+	if (requestData.ConnPubkey == "") {
+		return c.JSON(http.StatusBadRequest, ErrorResponse{
+			Message: "Connection pubkey is empty",
+			Error:   "no connection pubkey in request data",
+		})
+	}
+
+	subscription := Subscription{
+		RelayUrl:   requestData.RelayUrl,
+		WebhookUrl: requestData.WebhookUrl,
+		Open:       true,
+		Authors:    &[]string{requestData.WalletPubkey},
+		Kinds:      &[]int{23196},
+	}
+
+	tags := new(nostr.TagMap)
+	*tags = make(nostr.TagMap)
+	(*tags)["p"] = []string{requestData.ConnPubkey}
+
+	subscription.Tags = tags
+
+
+	err := svc.db.Create(&subscription).Error
+
+	if err != nil {
+		return c.JSON(http.StatusBadRequest, ErrorResponse{
+			Message: "Failed to store subscription",
+			Error:   err.Error(),
+		})
+	}
+
+	go svc.startSubscription(svc.Ctx, &subscription)
+
+	return c.JSON(http.StatusOK, SubscriptionResponse{
+		SubscriptionId: subscription.Uuid,
+		WebhookUrl: requestData.WebhookUrl,
+	})
+}
+
 func (svc *Service) SubscriptionHandler(c echo.Context) error {
 	var requestData SubscriptionRequest
 	// send in a pubkey and authenticate by signing