fix: re-enqueue failed info publish request (#1300)

Author: rolznz

nip47/nip47_service.go

@@ -2,6 +2,7 @@ package nip47
 
 import (
 	"context"
+	"time"
 
 	"github.com/getAlby/hub/alby"
 	"github.com/getAlby/hub/apps"
@@ -99,6 +100,9 @@ func (svc *nip47Service) StartNip47InfoPublisher(relay *nostr.Relay, lnClient ln
 				_, err := svc.PublishNip47Info(relay.Context(), relay, req.AppWalletPubKey, req.AppWalletPrivKey, lnClient)
 				if err != nil {
 					logger.Logger.WithError(err).WithField("wallet_pubkey", req.AppWalletPubKey).Error("Failed to publish NIP47 info from queue")
+					// wait and then re-add the item to the queue
+					time.Sleep(5 * time.Second)
+					svc.EnqueueNip47InfoPublishRequest(req.AppWalletPubKey, req.AppWalletPrivKey)
 				}
 			}
 		}

service/create_app_consumer.go

@@ -56,12 +56,9 @@ func (s *createAppConsumer) ConsumeEvent(ctx context.Context, event *events.Even
 		logger.Logger.WithError(err).Error("Failed to calculate app wallet pub key")
 		return
 	}
+	s.svc.nip47Service.EnqueueNip47InfoPublishRequest(walletPubKey, walletPrivKey)
 
 	go func() {
-		_, err := s.svc.GetNip47Service().PublishNip47Info(ctx, s.relay, walletPubKey, walletPrivKey, s.svc.lnClient)
-		if err != nil {
-			logger.Logger.WithError(err).Error("Could not publish NIP47 info")
-		}
 		err = s.svc.startAppWalletSubscription(ctx, s.relay, walletPubKey)
 		if err != nil && !errors.Is(err, context.Canceled) {
 			logger.Logger.WithError(err).WithFields(logrus.Fields{

service/update_app_consumer.go

@@ -43,11 +43,6 @@ func (s *updateAppConsumer) ConsumeEvent(ctx context.Context, event *events.Even
 
 	if s.svc.keys.GetNostrPublicKey() != walletPubKey {
 		// only need to re-publish the nip47 event info if it is not a legacy wallet
-
-		_, err = s.svc.GetNip47Service().PublishNip47Info(ctx, s.relay, walletPubKey, walletPrivKey, s.svc.lnClient)
-		if err != nil {
-			logger.Logger.WithError(err).Error("Could not re-publish NIP47 info")
-		}
-
+		s.svc.nip47Service.EnqueueNip47InfoPublishRequest(walletPubKey, walletPrivKey)
 	}
 }