rfq+lndservices: remove scid alias of expired quotes

We use the new LND RPC endpoint that looks up the base scid for an
alias, in order to use it to delete the mapping shortly after. In
addition we break the order handler main loop into it's go routine,
which was previously never really running as it followed the HTLC
interceptor setup which was a blocking call.

Author: GeorgeTsagk

lndservices/router_client.go

@@ -45,6 +45,13 @@ func (l *LndRouterClient) DeleteLocalAlias(ctx context.Context, alias,
 	return l.lnd.Router.XDeleteLocalChanAlias(ctx, alias, baseScid)
 }
 
+// FindBaseAlias finds the base channel ID for a given alias.
+func (l *LndRouterClient) FindBaseAlias(ctx context.Context,
+	alias lnwire.ShortChannelID) (lnwire.ShortChannelID, error) {
+
+	return l.lnd.Router.XFindBaseLocalChanAlias(ctx, alias)
+}
+
 // SubscribeHtlcEvents subscribes to a stream of events related to
 // HTLC updates.
 func (l *LndRouterClient) SubscribeHtlcEvents(

rfq/manager.go

@@ -62,6 +62,10 @@ type ScidAliasManager interface {
 	// Manager's maps.
 	DeleteLocalAlias(ctx context.Context, alias,
 		baseScid lnwire.ShortChannelID) error
+
+	// FindBaseAlias finds the base channel ID for a given alias.
+	FindBaseAlias(ctx context.Context,
+		alias lnwire.ShortChannelID) (lnwire.ShortChannelID, error)
 }
 
 type (
@@ -241,6 +245,7 @@ func (m *Manager) startSubsystems(ctx context.Context) error {
 		CleanupInterval:  CacheCleanupInterval,
 		HtlcInterceptor:  m.cfg.HtlcInterceptor,
 		HtlcSubscriber:   m.cfg.HtlcSubscriber,
+		AliasManager:     m.cfg.AliasManager,
 		AcceptHtlcEvents: m.acceptHtlcEvents,
 		SpecifierChecker: m.AssetMatchesSpecifier,
 	})

rfq/order.go

@@ -659,6 +659,10 @@ type OrderHandlerCfg struct {
 	// intercept and accept/reject HTLCs.
 	HtlcInterceptor HtlcInterceptor
 
+	// AliasManager is the SCID alias manager. This component is used to add
+	// and remove SCID aliases.
+	AliasManager ScidAliasManager
+
 	// AcceptHtlcEvents is a channel that receives accepted HTLCs.
 	AcceptHtlcEvents chan<- *AcceptHtlcEvent
 
@@ -866,7 +870,7 @@ func (h *OrderHandler) subscribeHtlcs(ctx context.Context) error {
 func (h *OrderHandler) Start() error {
 	var startErr error
 	h.startOnce.Do(func() {
-		// Start the main event loop in a separate goroutine.
+		// Start the HTLC interceptor in a separate go routine.
 		h.Wg.Add(1)
 		go func() {
 			defer h.Wg.Done()
@@ -880,6 +884,12 @@ func (h *OrderHandler) Start() error {
 					"interception: %v", startErr)
 				return
 			}
+		}()
+
+		// Start the main event loop in a separate go routine.
+		h.Wg.Add(1)
+		go func() {
+			defer h.Wg.Done()
 
 			h.mainEventLoop()
 		}()
@@ -913,8 +923,8 @@ func (h *OrderHandler) RegisterAssetSalePolicy(buyAccept rfqmsg.BuyAccept) {
 	h.policies.Store(policy.AcceptedQuoteId.Scid(), policy)
 }
 
-// RegisterAssetPurchasePolicy generates and registers an asset buy policy with the
-// order handler. This function takes an incoming sell accept message as an
+// RegisterAssetPurchasePolicy generates and registers an asset buy policy with
+// the order handler. This function takes an incoming sell accept message as an
 // argument.
 func (h *OrderHandler) RegisterAssetPurchasePolicy(
 	sellAccept rfqmsg.SellAccept) {
@@ -1057,9 +1067,41 @@ func (h *OrderHandler) cleanupStalePolicies() {
 
 	h.policies.ForEach(
 		func(scid SerialisedScid, policy Policy) error {
-			if policy.HasExpired() {
-				staleCounter++
-				h.policies.Delete(scid)
+			if !policy.HasExpired() {
+				return nil
+			}
+
+			staleCounter++
+
+			// Delete the local entry of this policy.
+			h.policies.Delete(scid)
+
+			ctx, cancel := h.WithCtxQuitCustomTimeout(
+				h.DefaultTimeout,
+			)
+			defer cancel()
+
+			aliasScid := lnwire.NewShortChanIDFromInt(
+				uint64(scid),
+			)
+
+			// Find the base SCID for the alias.
+			baseScid, err := h.cfg.AliasManager.FindBaseAlias(
+				ctx, aliasScid,
+			)
+			if err != nil {
+				log.Warnf("Error finding base SCID for alias "+
+					"%d: %v", scid, err)
+				return nil
+			}
+
+			// Delete the alias scid mapping on LND.
+			err = h.cfg.AliasManager.DeleteLocalAlias(
+				ctx, aliasScid, baseScid,
+			)
+			if err != nil {
+				log.Warnf("Error deleting SCID alias %d: %v",
+					scid, err)
 			}
 
 			return nil