rfqmsg+tapchannelmsg: add helper functions for asset ID detection

To easily find out if all asset IDs from a set are actually committed to
a channel, we add helper functions for the different channel messages
that we can encounter in our subsystems (depending on whether we get the
message from a blob in a hook or as JSON over the RPC interface).

Author: guggero

rfqmsg/custom_channel_data.go

@@ -1,5 +1,10 @@
 package rfqmsg
 
+import (
+	"github.com/lightninglabs/taproot-assets/asset"
+	"github.com/lightninglabs/taproot-assets/fn"
+)
+
 // JsonAssetBalance is a struct that represents the balance of a single asset ID
 // within a channel.
 type JsonAssetBalance struct {
@@ -43,6 +48,26 @@ type JsonAssetChannel struct {
 	IncomingHtlcBalance uint64             `json:"incoming_htlc_balance"`
 }
 
+// HasAllAssetIDs checks if the OpenChannel contains all asset IDs in the
+// provided set. It returns true if all asset IDs are present, false otherwise.
+func (c *JsonAssetChannel) HasAllAssetIDs(ids fn.Set[asset.ID]) bool {
+	for id := range ids {
+		found := false
+		for _, fundingAsset := range c.FundingAssets {
+			if fundingAsset.AssetGenesis.AssetID == id.String() {
+				found = true
+				break
+			}
+		}
+
+		if !found {
+			return false
+		}
+	}
+
+	return true
+}
+
 // JsonAssetChannelBalances is a struct that represents the balance information
 // of all assets within open and pending channels.
 type JsonAssetChannelBalances struct {

tapchannelmsg/records.go

@@ -157,6 +157,26 @@ func (o *OpenChannel) Bytes() []byte {
 	return buf.Bytes()
 }
 
+// HasAllAssetIDs checks if the OpenChannel contains all asset IDs in the
+// provided set. It returns true if all asset IDs are present, false otherwise.
+func (o *OpenChannel) HasAllAssetIDs(ids fn.Set[asset.ID]) bool {
+	for id := range ids {
+		found := false
+		for _, output := range o.Assets() {
+			if output.AssetID.Val == id {
+				found = true
+				break
+			}
+		}
+
+		if !found {
+			return false
+		}
+	}
+
+	return true
+}
+
 // DecodeOpenChannel deserializes an OpenChannel from the given blob.
 func DecodeOpenChannel(blob tlv.Blob) (*OpenChannel, error) {
 	var o OpenChannel
@@ -536,6 +556,42 @@ func (c *Commitment) Leaves() lnwallet.CommitAuxLeaves {
 	return leaves
 }
 
+// HasAllAssetIDs checks if the OpenChannel contains all asset IDs in the
+// provided set. It returns true if all asset IDs are present, false otherwise.
+func (c *Commitment) HasAllAssetIDs(assetIDs fn.Set[asset.ID]) bool {
+	// First, we collect all possible asset IDs from the local and remote
+	// outputs, including the HTLCs.
+	channelAssetIDs := fn.NewSet[asset.ID]()
+	for _, local := range c.LocalOutputs() {
+		channelAssetIDs.Add(local.AssetID.Val)
+	}
+	for _, remote := range c.RemoteOutputs() {
+		channelAssetIDs.Add(remote.AssetID.Val)
+	}
+	for _, incoming := range c.IncomingHtlcAssets.Val.Outputs() {
+		channelAssetIDs.Add(incoming.AssetID.Val)
+	}
+	for _, outgoing := range c.OutgoingHtlcAssets.Val.Outputs() {
+		channelAssetIDs.Add(outgoing.AssetID.Val)
+	}
+
+	for id := range assetIDs {
+		found := false
+		for channelAssetID := range channelAssetIDs {
+			if channelAssetID == id {
+				found = true
+				break
+			}
+		}
+
+		if !found {
+			return false
+		}
+	}
+
+	return true
+}
+
 // DecodeCommitment deserializes a Commitment from the given blob.
 func DecodeCommitment(blob tlv.Blob) (*Commitment, error) {
 	var c Commitment