fn: rename chanutils packge to fn

In this commit, we rename the chanutils package to be just `fn`. This is
shorter so means we'll run into the line limit less. The package also
now contains general generic functions, so this new name matches better.

Author: Roasbeef

address/book.go

@@ -11,8 +11,8 @@ import (
 	"github.com/btcsuite/btcd/wire"
 	"github.com/lightninglabs/lndclient"
 	"github.com/lightninglabs/taproot-assets/asset"
-	"github.com/lightninglabs/taproot-assets/chanutils"
 	"github.com/lightninglabs/taproot-assets/commitment"
+	"github.com/lightninglabs/taproot-assets/fn"
 	"github.com/lightningnetwork/lnd/keychain"
 )
 
@@ -150,23 +150,23 @@ type Book struct {
 
 	// subscribers is a map of components that want to be notified on new
 	// address events, keyed by their subscription ID.
-	subscribers map[uint64]*chanutils.EventReceiver[*AddrWithKeyInfo]
+	subscribers map[uint64]*fn.EventReceiver[*AddrWithKeyInfo]
 
 	// subscriberMtx guards the subscribers map and access to the
 	// subscriptionID.
 	subscriberMtx sync.Mutex
 }
 
 // A compile-time assertion to make sure Book satisfies the
-// chanutils.EventPublisher interface.
-var _ chanutils.EventPublisher[*AddrWithKeyInfo, QueryParams] = (*Book)(nil)
+// fn.EventPublisher interface.
+var _ fn.EventPublisher[*AddrWithKeyInfo, QueryParams] = (*Book)(nil)
 
 // NewBook creates a new Book instance from the config.
 func NewBook(cfg BookConfig) *Book {
 	return &Book{
 		cfg: cfg,
 		subscribers: make(
-			map[uint64]*chanutils.EventReceiver[*AddrWithKeyInfo],
+			map[uint64]*fn.EventReceiver[*AddrWithKeyInfo],
 		),
 	}
 }
@@ -392,7 +392,7 @@ func (b *Book) CompleteEvent(ctx context.Context, event *Event,
 // marker onward existing items should be delivered on startup. If deliverFrom
 // is nil/zero/empty then all existing items will be delivered.
 func (b *Book) RegisterSubscriber(
-	receiver *chanutils.EventReceiver[*AddrWithKeyInfo],
+	receiver *fn.EventReceiver[*AddrWithKeyInfo],
 	deliverExisting bool, deliverFrom QueryParams) error {
 
 	b.subscriberMtx.Lock()
@@ -427,7 +427,7 @@ func (b *Book) RegisterSubscriber(
 // RemoveSubscriber removes the given subscriber and also stops it from
 // processing events.
 func (b *Book) RemoveSubscriber(
-	subscriber *chanutils.EventReceiver[*AddrWithKeyInfo]) error {
+	subscriber *fn.EventReceiver[*AddrWithKeyInfo]) error {
 
 	b.subscriberMtx.Lock()
 	defer b.subscriberMtx.Unlock()

cmd/tapd/main.go

@@ -7,7 +7,7 @@ import (
 	"runtime/pprof"
 
 	"github.com/jessevdk/go-flags"
-	"github.com/lightninglabs/taproot-assets/chanutils"
+	"github.com/lightninglabs/taproot-assets/fn"
 	"github.com/lightninglabs/taproot-assets/tapcfg"
 	"github.com/lightningnetwork/lnd/signal"
 )
@@ -62,9 +62,7 @@ func main() {
 	// This concurrent error queue can be used by every component that can
 	// raise runtime errors. Using a queue will prevent us from blocking on
 	// sending errors to it, as long as the queue is running.
-	errQueue := chanutils.NewConcurrentQueue[error](
-		chanutils.DefaultQueueSize,
-	)
+	errQueue := fn.NewConcurrentQueue[error](fn.DefaultQueueSize)
 	errQueue.Start()
 	defer errQueue.Stop()
 

commitment/asset.go

@@ -10,7 +10,7 @@ import (
 
 	"github.com/btcsuite/btcd/btcec/v2/schnorr"
 	"github.com/lightninglabs/taproot-assets/asset"
-	"github.com/lightninglabs/taproot-assets/chanutils"
+	"github.com/lightninglabs/taproot-assets/fn"
 	"github.com/lightninglabs/taproot-assets/mssmt"
 	"golang.org/x/exp/maps"
 )
@@ -404,7 +404,7 @@ func (c *AssetCommitment) Copy() (*AssetCommitment, error) {
 
 	// First, we'll perform a deep copy of all the assets that this existing
 	// commitment is committing to.
-	newAssets := chanutils.CopyAll(maps.Values(c.Assets()))
+	newAssets := fn.CopyAll(maps.Values(c.Assets()))
 
 	// Now that we have a deep copy of all the assets, we can just create a
 	// brand-new commitment from the set of assets.

commitment/proof.go

@@ -5,7 +5,7 @@ import (
 	"io"
 
 	"github.com/lightninglabs/taproot-assets/asset"
-	"github.com/lightninglabs/taproot-assets/chanutils"
+	"github.com/lightninglabs/taproot-assets/fn"
 	"github.com/lightninglabs/taproot-assets/mssmt"
 	"github.com/lightningnetwork/lnd/tlv"
 )
@@ -129,7 +129,7 @@ func (p Proof) DeriveByAssetInclusion(asset *asset.Asset) (*TapCommitment,
 	)
 	log.Tracef("Derived asset inclusion proof for asset_id=%v, "+
 		"asset_commitment_key=%x, asset_commitment_leaf=%s",
-		asset.ID(), chanutils.ByteSlice(asset.AssetCommitmentKey()),
+		asset.ID(), fn.ByteSlice(asset.AssetCommitmentKey()),
 		assetCommitmentLeaf.NodeHash())
 
 	return NewTapCommitmentWithRoot(

commitment/tap.go

@@ -11,7 +11,7 @@ import (
 	"github.com/btcsuite/btcd/chaincfg/chainhash"
 	"github.com/btcsuite/btcd/txscript"
 	"github.com/lightninglabs/taproot-assets/asset"
-	"github.com/lightninglabs/taproot-assets/chanutils"
+	"github.com/lightninglabs/taproot-assets/fn"
 	"github.com/lightninglabs/taproot-assets/mssmt"
 	"golang.org/x/exp/maps"
 )
@@ -378,7 +378,7 @@ func (c *TapCommitment) Copy() (*TapCommitment, error) {
 	}
 
 	// Otherwise, we'll copy all the internal asset commitments.
-	newAssetCommitments, err := chanutils.CopyAllErr(
+	newAssetCommitments, err := fn.CopyAllErr(
 		maps.Values(c.assetCommitments),
 	)
 	if err != nil {

chanutils/concurrency.go renamed to fn/concurrency.go

@@ -1,4 +1,4 @@
-package chanutils
+package fn
 
 import (
 	"context"

chanutils/concurrency_test.go renamed to fn/concurrency_test.go

@@ -1,4 +1,4 @@
-package chanutils
+package fn
 
 import (
 	"context"

chanutils/context_guard.go renamed to fn/context_guard.go

@@ -1,4 +1,4 @@
-package chanutils
+package fn
 
 import (
 	"context"

chanutils/errors.go renamed to fn/errors.go

@@ -1,4 +1,4 @@
-package chanutils
+package fn
 
 import (
 	"context"

chanutils/errors_test.go renamed to fn/errors_test.go

@@ -1,4 +1,4 @@
-package chanutils
+package fn
 
 import (
 	"context"

chanutils/events.go renamed to fn/events.go

@@ -1,4 +1,4 @@
-package chanutils
+package fn
 
 import (
 	"fmt"

chanutils/func.go renamed to fn/func.go

@@ -1,4 +1,4 @@
-package chanutils
+package fn
 
 import "fmt"
 

chanutils/iter.go renamed to fn/iter.go

@@ -1,4 +1,4 @@
-package chanutils
+package fn
 
 // ForEachErr will iterate through all items in the passed slice, calling the
 // function f on each slice. If a call to f fails, then the function returns an

chanutils/memory.go renamed to fn/memory.go

@@ -1,4 +1,4 @@
-package chanutils
+package fn
 
 // Ptr returns the pointer of the given value. This is useful in instances
 // where a function returns the value, but a pointer is wanted. Without this,

chanutils/queue.go renamed to fn/queue.go

@@ -1,4 +1,4 @@
-package chanutils
+package fn
 
 import (
 	"container/list"

chanutils/recv.go renamed to fn/recv.go

@@ -1,4 +1,4 @@
-package chanutils
+package fn
 
 import (
 	"fmt"

chanutils/send.go renamed to fn/send.go

@@ -1,4 +1,4 @@
-package chanutils
+package fn
 
 // SendOrQuit attempts to and a message through channel c. If this succeeds,
 // then bool is returned. Otherwise if a quit signal is received first, then

chanutils/set.go renamed to fn/set.go

@@ -1,4 +1,4 @@
-package chanutils
+package fn
 
 import "golang.org/x/exp/maps"
 

itest/assertions.go

@@ -12,7 +12,7 @@ import (
 	"github.com/btcsuite/btcd/txscript"
 	"github.com/btcsuite/btcd/wire"
 	"github.com/lightninglabs/taproot-assets/asset"
-	"github.com/lightninglabs/taproot-assets/chanutils"
+	"github.com/lightninglabs/taproot-assets/fn"
 	"github.com/lightninglabs/taproot-assets/proof"
 	"github.com/lightninglabs/taproot-assets/taprpc"
 	unirpc "github.com/lightninglabs/taproot-assets/taprpc/universerpc"
@@ -688,7 +688,7 @@ func assertUniverseRootsEqual(t *testing.T, a, b *unirpc.AssetRootResponse) {
 	// same set of asset IDs are being tracked.
 	uniKeys := maps.Keys(a.UniverseRoots)
 	require.Equal(t, len(a.UniverseRoots), len(b.UniverseRoots))
-	require.True(t, chanutils.All(uniKeys, func(key string) bool {
+	require.True(t, fn.All(uniKeys, func(key string) bool {
 		_, ok := b.UniverseRoots[key]
 		return ok
 	}))
@@ -805,7 +805,7 @@ func assertUniverseAssetStats(t *testing.T, node *tapdHarness,
 	require.Len(t, assetStats.AssetStats, len(assetIDs))
 
 	for _, assetStat := range assetStats.AssetStats {
-		found := chanutils.Any(assetIDs, func(id []byte) bool {
+		found := fn.Any(assetIDs, func(id []byte) bool {
 			return bytes.Equal(assetStat.AssetId, id)
 		})
 		require.True(t, found)

itest/assets_test.go

@@ -9,7 +9,7 @@ import (
 	"time"
 
 	"github.com/btcsuite/btcd/chaincfg/chainhash"
-	"github.com/lightninglabs/taproot-assets/chanutils"
+	"github.com/lightninglabs/taproot-assets/fn"
 	"github.com/lightninglabs/taproot-assets/proof"
 	"github.com/lightninglabs/taproot-assets/taprpc"
 	"github.com/lightninglabs/taproot-assets/taprpc/mintrpc"
@@ -469,7 +469,7 @@ func testMintAssetNameCollisionError(t *harnessTest) {
 
 		return batch.Assets[0].AssetType == taprpc.AssetType_COLLECTIBLE
 	}
-	batchCollide, err := chanutils.First(allBatches, isCollidingBatch)
+	batchCollide, err := fn.First(allBatches, isCollidingBatch)
 	require.NoError(t.t, err)
 
 	require.Len(t.t, batchCollide.Assets, 1)

itest/multi_asset_group_test.go

@@ -7,7 +7,7 @@ import (
 	"testing"
 
 	"github.com/lightninglabs/taproot-assets/asset"
-	"github.com/lightninglabs/taproot-assets/chanutils"
+	"github.com/lightninglabs/taproot-assets/fn"
 	"github.com/lightninglabs/taproot-assets/taprpc"
 	"github.com/lightninglabs/taproot-assets/taprpc/mintrpc"
 	"github.com/stretchr/testify/require"
@@ -91,7 +91,7 @@ func testMintMultiAssetGroups(t *harnessTest) {
 
 	// We need to fetch the minted group anchor asset, which includes the
 	// genesis information used to compute the tweak for the group key.
-	normalAnchor, err := chanutils.First(
+	normalAnchor, err := fn.First(
 		mintedBatch, func(asset *taprpc.Asset) bool {
 			return matchingName(asset, issuableAssets[0].Asset.Name)
 		},
@@ -104,7 +104,7 @@ func testMintMultiAssetGroups(t *harnessTest) {
 		normalAnchor.AssetGroup.TweakedGroupKey,
 	)
 
-	collectAnchor, err := chanutils.First(
+	collectAnchor, err := fn.First(
 		mintedBatch, func(asset *taprpc.Asset) bool {
 			return matchingName(asset, issuableAssets[1].Asset.Name)
 		},
@@ -130,7 +130,7 @@ func testMintMultiAssetGroups(t *harnessTest) {
 		require.NoError(t.t, secondTapd.stop(true))
 	}()
 
-	normalMember, err := chanutils.First(
+	normalMember, err := fn.First(
 		mintedBatch, func(asset *taprpc.Asset) bool {
 			return asset.Amount == normalAnchor.Amount/2
 		},
@@ -175,7 +175,7 @@ func testMintMultiAssetGroups(t *harnessTest) {
 		)
 		return isNotAnchor && isGrouped
 	}
-	collectMember, err := chanutils.First(mintedBatch, isCollectGroupMember)
+	collectMember, err := fn.First(mintedBatch, isCollectGroupMember)
 	require.NoError(t.t, err)
 
 	collectMemberGenInfo := collectMember.AssetGenesis

itest/universe_test.go

@@ -8,7 +8,7 @@ import (
 	"io"
 
 	"github.com/btcsuite/btcd/btcec/v2/schnorr"
-	"github.com/lightninglabs/taproot-assets/chanutils"
+	"github.com/lightninglabs/taproot-assets/fn"
 	"github.com/lightninglabs/taproot-assets/taprpc"
 	unirpc "github.com/lightninglabs/taproot-assets/taprpc/universerpc"
 	"github.com/lightningnetwork/lnd/lntest/wait"
@@ -116,10 +116,9 @@ func testUniverseSync(t *harnessTest) {
 	// Finally, we'll ensure that the universe keys and leaves matches for
 	// both parties.
 	uniRoots := maps.Values(universeRoots.UniverseRoots)
-	uniIDs := chanutils.Map(uniRoots,
-		func(root *unirpc.UniverseRoot) *unirpc.ID {
-			return root.Id
-		},
+	uniIDs := fn.Map(uniRoots, func(root *unirpc.UniverseRoot) *unirpc.ID {
+		return root.Id
+	},
 	)
 	assertUniverseKeysEqual(t.t, uniIDs, t.tapd, bob)
 	assertUniverseLeavesEqual(t.t, uniIDs, t.tapd, bob)

mssmt/proof.go

@@ -4,7 +4,7 @@ import (
 	"errors"
 	"fmt"
 
-	"github.com/lightninglabs/taproot-assets/chanutils"
+	"github.com/lightninglabs/taproot-assets/fn"
 )
 
 var (
@@ -89,7 +89,7 @@ func (p *CompressedProof) Decompress() (*Proof, error) {
 	nodes := make([]Node, len(p.Bits))
 
 	// The number of 0 bits should match the number of pre-populated nodes.
-	numExpectedNodes := chanutils.Reduce(p.Bits, func(count int, bit bool) int {
+	numExpectedNodes := fn.Reduce(p.Bits, func(count int, bit bool) int {
 		if !bit {
 			return count + 1
 		}