feat: add payment_sent notification

events/models.go

@@ -24,6 +24,13 @@ type PaymentReceivedEventProperties struct {
 	NodeType    string `json:"node_type"`
 }
 
+type PaymentSentEventProperties struct {
+	PaymentId   string `json:"payment_id"`
+	PaymentHash string `json:"payment_hash"`
+	Amount      uint64 `json:"amount"`
+	NodeType    string `json:"node_type"`
+}
+
 type ChannelBackupEvent struct {
 	Channels []ChannelBackupInfo `json:"channels"`
 }

lnclient/ldk/ldk.go

@@ -1229,6 +1229,16 @@ func (ls *LDKService) handleLdkEvent(event *ldk_node.Event) {
 				NodeType:    config.LDKBackendType,
 			},
 		})
+	case ldk_node.EventPaymentSuccessful:
+		ls.eventPublisher.Publish(&events.Event{
+			Event: "nwc_payment_sent",
+			Properties: &events.PaymentSentEventProperties{
+				PaymentId:   *eventType.PaymentId,
+				PaymentHash: eventType.PaymentHash,
+				Amount:      *eventType.FeePaidMsat / 1000,
+				NodeType:    config.LDKBackendType,
+			},
+		})
 	}
 }
 

nip47/notifications/models.go

@@ -8,8 +8,9 @@ type Notification struct {
 }
 
 const (
-	NOTIFICATION_TYPES            = "payment_received" // e.g. "payment_received payment_sent balance_updated payment_sent channel_opened channel_closed ..."
+	NOTIFICATION_TYPES            = "payment_received payment_sent" // e.g. "payment_received payment_sent balance_updated payment_sent channel_opened channel_closed ..."
 	PAYMENT_RECEIVED_NOTIFICATION = "payment_received"
+	PAYMENT_SENT_NOTIFICATION     = "payment_sent"
 )
 
 type PaymentReceivedNotification struct {

nip47/notifications/nip47_notifier.go

@@ -44,28 +44,54 @@ func NewNip47Notifier(relay Relay, db *gorm.DB, cfg config.Config, keys keys.Key
 }
 
 func (notifier *Nip47Notifier) ConsumeEvent(ctx context.Context, event *events.Event) error {
-	if event.Event != "nwc_payment_received" {
+	if event.Event != "nwc_payment_received" && event.Event != "nwc_payment_sent" {
 		return nil
 	}
 
-	paymentReceivedEventProperties, ok := event.Properties.(*events.PaymentReceivedEventProperties)
-	if !ok {
-		logger.Logger.WithField("event", event).Error("Failed to cast event")
-		return errors.New("failed to cast event")
-	}
+	var transaction interface{}
+	var notificationType string
+	switch event.Event {
+	case "nwc_payment_received":
+		paymentReceivedEventProperties, ok := event.Properties.(*events.PaymentReceivedEventProperties)
+		if !ok {
+			logger.Logger.WithField("event", event).Error("Failed to cast event")
+			return errors.New("failed to cast event")
+		}
 
-	transaction, err := notifier.lnClient.LookupInvoice(ctx, paymentReceivedEventProperties.PaymentHash)
-	if err != nil {
-		logger.Logger.
-			WithField("paymentHash", paymentReceivedEventProperties.PaymentHash).
-			WithError(err).
-			Error("Failed to lookup invoice by payment hash")
-		return err
+		var err error
+		transaction, err = notifier.lnClient.LookupInvoice(ctx, paymentReceivedEventProperties.PaymentHash)
+		if err != nil {
+			logger.Logger.
+				WithField("paymentHash", paymentReceivedEventProperties.PaymentHash).
+				WithError(err).
+				Error("Failed to lookup invoice by payment hash")
+			return err
+		}
+		notificationType = PAYMENT_RECEIVED_NOTIFICATION
+	case "nwc_payment_sent":
+		paymentSentEventProperties, ok := event.Properties.(*events.PaymentSentEventProperties)
+		if !ok {
+			logger.Logger.WithField("event", event).Error("Failed to cast event")
+			return errors.New("failed to cast event")
+		}
+
+		var err error
+		transaction, err = notifier.lnClient.LookupInvoice(ctx, paymentSentEventProperties.PaymentHash)
+		if err != nil {
+			logger.Logger.
+				WithField("paymentHash", paymentSentEventProperties.PaymentHash).
+				WithError(err).
+				Error("Failed to lookup invoice by payment hash")
+			return err
+		}
+		notificationType = PAYMENT_SENT_NOTIFICATION
+	default:
+		logger.Logger.Fatalf("Unsupported notification type: %v", event.Event)
 	}
 
 	notifier.notifySubscribers(ctx, &Notification{
 		Notification:     transaction,
-		NotificationType: PAYMENT_RECEIVED_NOTIFICATION,
+		NotificationType: notificationType,
 	}, nostr.Tags{})
 	return nil
 }

nip47/notifications/nip47_notifier_test.go

@@ -84,6 +84,26 @@ func TestSendNotification(t *testing.T) {
 	assert.Equal(t, tests.MockTransaction.Amount, transaction.Amount)
 	assert.Equal(t, tests.MockTransaction.FeesPaid, transaction.FeesPaid)
 	assert.Equal(t, tests.MockTransaction.SettledAt, transaction.SettledAt)
+
+	testEvent = &events.Event{
+		Event: "nwc_payment_sent",
+		Properties: &events.PaymentSentEventProperties{
+			PaymentId:   tests.MockPaymentId,
+			PaymentHash: tests.MockPaymentHash,
+			Amount:      uint64(tests.MockTransaction.Amount),
+			NodeType:    "LDK",
+		},
+	}
+
+	svc.EventPublisher.Publish(testEvent)
+
+	receivedEvent = <-nip47NotificationQueue.Channel()
+	assert.Equal(t, testEvent, receivedEvent)
+
+	notifier.ConsumeEvent(ctx, receivedEvent)
+
+	assert.NotNil(t, relay.publishedEvent)
+	assert.NotEmpty(t, relay.publishedEvent.Content)
 }
 
 func TestSendNotificationNoPermission(t *testing.T) {

tests/mock_ln_client.go

@@ -13,6 +13,7 @@ const MockPaymentHash500 = "be8ad5d0b82071d538dcd160e3a3af444bd890de68388a4d771b
 
 const MockInvoice = "lntb1230n1pjypux0pp5xgxzcks5jtx06k784f9dndjh664wc08ucrganpqn52d0ftrh9n8sdqyw3jscqzpgxqyz5vqsp5rkx7cq252p3frx8ytjpzc55rkgyx2mfkzzraa272dqvr2j6leurs9qyyssqhutxa24r5hqxstchz5fxlslawprqjnarjujp5sm3xj7ex73s32sn54fthv2aqlhp76qmvrlvxppx9skd3r5ut5xutgrup8zuc6ay73gqmra29m"
 const MockPaymentHash = "320c2c5a1492ccfd5bc7aa4ad9b657d6aaec3cfcc0d1d98413a29af4ac772ccf" // for the above invoice
+const MockPaymentId = "paymentId123"
 
 var MockNodeInfo = lnclient.NodeInfo{
 	Alias:       "bob",