tapcfg+rfq: add group lookup to rfq manager

This commit adds a new interface to the rfq manager which helps us look
up the group an asset ID may belong to. The reason we can't reuse the
same interface from tapsend is a circular import issue. We also
introduce an in memory look-up map to skip a roundtrip to the db, since
this information is static.

Author: GeorgeTsagk

rfq/manager.go

@@ -61,6 +61,14 @@ type (
 	SellAcceptMap map[SerialisedScid]rfqmsg.SellAccept
 )
 
+// GroupLookup is an interface that helps us look up a group of an asset based
+// on the asset ID.
+type GroupLookup interface {
+	// QueryAssetGroup fetches the group information of an asset, if it
+	// belongs in a group.
+	QueryAssetGroup(context.Context, asset.ID) (*asset.AssetGroup, error)
+}
+
 // ManagerCfg is a struct that holds the configuration parameters for the RFQ
 // manager.
 type ManagerCfg struct {
@@ -84,6 +92,10 @@ type ManagerCfg struct {
 	// determine the available channels for routing.
 	ChannelLister ChannelLister
 
+	// GroupLookup is an interface that helps us querry asset groups by
+	// asset IDs.
+	GroupLookup GroupLookup
+
 	// AliasManager is the SCID alias manager. This component is injected
 	// into the manager once lnd and tapd are hooked together.
 	AliasManager ScidAliasManager
@@ -165,6 +177,12 @@ type Manager struct {
 		SerialisedScid, rfqmsg.SellAccept,
 	]
 
+	// groupKeyLookupCache is a map that helps us quickly perform an
+	// in-memory look up of the group an asset belongs to. Since this
+	// information is static and generated during minting, it is not
+	// possible for an asset to change groups.
+	groupKeyLookupCache lnutils.SyncMap[asset.ID, *btcec.PublicKey]
+
 	// subscribers is a map of components that want to be notified on new
 	// events, keyed by their subscription ID.
 	subscribers lnutils.SyncMap[uint64, *fn.EventReceiver[fn.Event]]
@@ -917,6 +935,34 @@ func (m *Manager) RemoveSubscriber(
 	return nil
 }
 
+// getAssetGroupKey retrieves the group key of an asset based on its ID.
+func (m *Manager) getAssetGroupKey(ctx context.Context,
+	id asset.ID) (fn.Option[btcec.PublicKey], error) {
+
+	// First, see if we have already queried our DB for this ID.
+	v, ok := m.groupKeyLookupCache.Load(id)
+	if ok {
+		return fn.Some(*v), nil
+	}
+
+	// Perform the DB query.
+	group, err := m.cfg.GroupLookup.QueryAssetGroup(ctx, id)
+	if err != nil {
+		return fn.None[btcec.PublicKey](), err
+	}
+
+	// If the asset does not belong to a group, return early with no error
+	// or response.
+	if group == nil || group.GroupKey == nil {
+		return fn.None[btcec.PublicKey](), nil
+	}
+
+	// Store the result for future calls.
+	m.groupKeyLookupCache.Store(id, &group.GroupPubKey)
+
+	return fn.Some(group.GroupPubKey), nil
+}
+
 // publishSubscriberEvent publishes an event to all subscribers.
 func (m *Manager) publishSubscriberEvent(event fn.Event) {
 	// Iterate over the subscribers and deliver the event to each one.

tapcfg/server.go

@@ -405,6 +405,7 @@ func genServerConfig(cfg *Config, cfgLogger btclog.Logger,
 			HtlcSubscriber:  lndRouterClient,
 			PriceOracle:     priceOracle,
 			ChannelLister:   walletAnchor,
+			GroupLookup:     tapdbAddrBook,
 			AliasManager:    lndRouterClient,
 			// nolint: lll
 			AcceptPriceDeviationPpm: rfqCfg.AcceptPriceDeviationPpm,