loopd: add asset client to swap config

Author: sputn1ck

client.go

@@ -14,6 +14,7 @@ import (
 	"github.com/btcsuite/btcd/btcutil"
 	"github.com/lightninglabs/aperture/l402"
 	"github.com/lightninglabs/lndclient"
+	"github.com/lightninglabs/loop/assets"
 	"github.com/lightninglabs/loop/loopdb"
 	"github.com/lightninglabs/loop/swap"
 	"github.com/lightninglabs/loop/sweep"
@@ -94,6 +95,7 @@ type Client struct {
 	lndServices *lndclient.LndServices
 	sweeper     *sweep.Sweeper
 	executor    *executor
+	assetClient *assets.TapdClient
 
 	resumeReady chan struct{}
 	wg          sync.WaitGroup
@@ -121,6 +123,9 @@ type ClientConfig struct {
 	// Lnd is an instance of the lnd proxy.
 	Lnd *lndclient.LndServices
 
+	// AssetClient is an instance of the assets client.
+	AssetClient *assets.TapdClient
+
 	// MaxL402Cost is the maximum price we are willing to pay to the server
 	// for the token.
 	MaxL402Cost btcutil.Amount
@@ -273,6 +278,7 @@ func NewClient(dbDir string, loopDB loopdb.SwapStore,
 		errChan:      make(chan error),
 		clientConfig: *config,
 		lndServices:  cfg.Lnd,
+		assetClient:  cfg.AssetClient,
 		sweeper:      sweeper,
 		executor:     executor,
 		resumeReady:  make(chan struct{}),
@@ -453,7 +459,7 @@ func (s *Client) Run(ctx context.Context, statusChan chan<- SwapInfo) error {
 func (s *Client) resumeSwaps(ctx context.Context,
 	loopOutSwaps []*loopdb.LoopOut, loopInSwaps []*loopdb.LoopIn) {
 
-	swapCfg := newSwapConfig(s.lndServices, s.Store, s.Server)
+	swapCfg := newSwapConfig(s.lndServices, s.Store, s.Server, s.assetClient)
 
 	for _, pend := range loopOutSwaps {
 		if pend.State().State.Type() != loopdb.StateTypePending {
@@ -523,7 +529,7 @@ func (s *Client) LoopOut(globalCtx context.Context,
 	}
 
 	// Create a new swap object for this swap.
-	swapCfg := newSwapConfig(s.lndServices, s.Store, s.Server)
+	swapCfg := newSwapConfig(s.lndServices, s.Store, s.Server, s.assetClient)
 	initResult, err := newLoopOutSwap(
 		globalCtx, swapCfg, initiationHeight, request,
 	)
@@ -682,7 +688,7 @@ func (s *Client) LoopIn(globalCtx context.Context,
 
 	// Create a new swap object for this swap.
 	initiationHeight := s.executor.height()
-	swapCfg := newSwapConfig(s.lndServices, s.Store, s.Server)
+	swapCfg := newSwapConfig(s.lndServices, s.Store, s.Server, s.assetClient)
 	initResult, err := newLoopInSwap(
 		globalCtx, swapCfg, initiationHeight, request,
 	)

loopd/config.go

@@ -11,6 +11,7 @@ import (
 
 	"github.com/btcsuite/btcd/btcutil"
 	"github.com/lightninglabs/aperture/l402"
+	"github.com/lightninglabs/loop/assets"
 	"github.com/lightninglabs/loop/loopdb"
 	"github.com/lightningnetwork/lnd/cert"
 	"github.com/lightningnetwork/lnd/lncfg"
@@ -196,6 +197,8 @@ type Config struct {
 
 	Server *loopServerConfig `group:"server" namespace:"server"`
 
+	Tapd *assets.TapdConfig `group:"tapd" namespace:"tapd"`
+
 	View viewParameters `command:"view" alias:"v" description:"View all swaps in the database. This command can only be executed when loopd is not running."`
 }
 
@@ -214,6 +217,7 @@ func DefaultConfig() Config {
 		Server: &loopServerConfig{
 			NoTLS: false,
 		},
+		Tapd:            assets.DefaultTapdConfig(),
 		LoopDir:         LoopDirBase,
 		ConfigFile:      defaultConfigFile,
 		DataDir:         LoopDirBase,

loopd/daemon.go

@@ -16,6 +16,7 @@ import (
 	proxy "github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
 	"github.com/lightninglabs/lndclient"
 	"github.com/lightninglabs/loop"
+	"github.com/lightninglabs/loop/assets"
 	"github.com/lightninglabs/loop/instantout"
 	"github.com/lightninglabs/loop/instantout/reservation"
 	"github.com/lightninglabs/loop/loopd/perms"
@@ -28,6 +29,7 @@ import (
 	"github.com/lightninglabs/loop/staticaddr/withdraw"
 	loop_swaprpc "github.com/lightninglabs/loop/swapserverrpc"
 	"github.com/lightninglabs/loop/sweepbatcher"
+	"github.com/lightninglabs/taproot-assets/taprpc"
 	"github.com/lightningnetwork/lnd/clock"
 	"github.com/lightningnetwork/lnd/lntypes"
 	"github.com/lightningnetwork/lnd/macaroons"
@@ -82,6 +84,7 @@ type Daemon struct {
 	internalErrChan chan error
 
 	lnd           *lndclient.GrpcLndServices
+	assetClient   *assets.TapdClient
 	clientCleanup func()
 
 	wg       sync.WaitGroup
@@ -138,6 +141,14 @@ func (d *Daemon) Start() error {
 		return err
 	}
 
+	// Initialize the assets client.
+	if d.cfg.Tapd.Host != "" {
+		d.assetClient, err = assets.NewTapdClient(d.cfg.Tapd)
+		if err != nil {
+			return err
+		}
+	}
+
 	// With lnd connected, initialize everything else, such as the swap
 	// server client, the swap client RPC server instance and our main swap
 	// and error handlers. If this fails, then nothing has been started yet,
@@ -435,9 +446,25 @@ func (d *Daemon) initialize(withMacaroonService bool) error {
 		chainParams,
 	)
 
+	// If we're running an asset client, we'll log something here.
+	if d.assetClient != nil {
+		getInfo, err := d.assetClient.GetInfo(
+			d.mainCtx, &taprpc.GetInfoRequest{},
+		)
+		if err != nil {
+			return fmt.Errorf("unable to get asset client info: %v", err)
+		}
+		if getInfo.LndIdentityPubkey != d.lnd.NodePubkey.String() {
+			return fmt.Errorf("asset client pubkey %v does not match "+
+				"lnd pubkey %v", getInfo.LndIdentityPubkey,
+				d.lnd.NodePubkey)
+		}
+		log.Infof("Using asset client with version %v", getInfo.Version)
+	}
+
 	// Create an instance of the loop client library.
 	swapClient, clientCleanup, err := getClient(
-		d.cfg, swapDb, sweeperDb, &d.lnd.LndServices,
+		d.cfg, swapDb, sweeperDb, &d.lnd.LndServices, d.assetClient,
 	)
 	if err != nil {
 		return err

loopd/utils.go

@@ -9,6 +9,7 @@ import (
 	"github.com/lightninglabs/aperture/l402"
 	"github.com/lightninglabs/lndclient"
 	"github.com/lightninglabs/loop"
+	"github.com/lightninglabs/loop/assets"
 	"github.com/lightninglabs/loop/liquidity"
 	"github.com/lightninglabs/loop/loopdb"
 	"github.com/lightninglabs/loop/swap"
@@ -19,8 +20,8 @@ import (
 
 // getClient returns an instance of the swap client.
 func getClient(cfg *Config, swapDb loopdb.SwapStore,
-	sweeperDb sweepbatcher.BatcherStore, lnd *lndclient.LndServices) (
-	*loop.Client, func(), error) {
+	sweeperDb sweepbatcher.BatcherStore, lnd *lndclient.LndServices,
+	assets *assets.TapdClient) (*loop.Client, func(), error) {
 
 	// Default is not set for MaxLSATCost and MaxLSATFee to distinguish
 	// it from user explicitly setting the option to default value.
@@ -45,6 +46,7 @@ func getClient(cfg *Config, swapDb loopdb.SwapStore,
 		SwapServerNoTLS:                      cfg.Server.NoTLS,
 		TLSPathServer:                        cfg.Server.TLSPath,
 		Lnd:                                  lnd,
+		AssetClient:                          assets,
 		MaxL402Cost:                          btcutil.Amount(cfg.MaxL402Cost),
 		MaxL402Fee:                           btcutil.Amount(cfg.MaxL402Fee),
 		LoopOutMaxParts:                      cfg.LoopOutMaxParts,

loopd/view.go

@@ -7,6 +7,7 @@ import (
 	"github.com/btcsuite/btcd/chaincfg"
 	"github.com/lightninglabs/lndclient"
 	"github.com/lightninglabs/loop"
+	"github.com/lightninglabs/loop/assets"
 	"github.com/lightninglabs/loop/loopdb"
 	"github.com/lightninglabs/loop/sweepbatcher"
 	"github.com/lightninglabs/loop/utils"
@@ -37,8 +38,16 @@ func view(config *Config, lisCfg *ListenerCfg) error {
 		chainParams,
 	)
 
+	var assetClient *assets.TapdClient
+	if config.Tapd.Host != "" {
+		assetClient, err = assets.NewTapdClient(config.Tapd)
+		if err != nil {
+			return err
+		}
+	}
+
 	swapClient, cleanup, err := getClient(
-		config, swapDb, sweeperDb, &lnd.LndServices,
+		config, swapDb, sweeperDb, &lnd.LndServices, assetClient,
 	)
 	if err != nil {
 		return err

loopin_test.go

@@ -47,7 +47,7 @@ func testLoopInSuccess(t *testing.T) {
 
 	height := int32(600)
 
-	cfg := newSwapConfig(&ctx.lnd.LndServices, ctx.store, ctx.server)
+	cfg := newSwapConfig(&ctx.lnd.LndServices, ctx.store, ctx.server, nil)
 
 	expectedLastHop := &route.Vertex{0x02}
 
@@ -200,7 +200,7 @@ func testLoopInTimeout(t *testing.T, externalValue int64) {
 
 	height := int32(600)
 
-	cfg := newSwapConfig(&ctx.lnd.LndServices, ctx.store, ctx.server)
+	cfg := newSwapConfig(&ctx.lnd.LndServices, ctx.store, ctx.server, nil)
 
 	req := testLoopInRequest
 	if externalValue != 0 {
@@ -414,7 +414,7 @@ func testLoopInResume(t *testing.T, state loopdb.SwapState, expired bool,
 	ctxb := context.Background()
 
 	ctx := newLoopInTestContext(t)
-	cfg := newSwapConfig(&ctx.lnd.LndServices, ctx.store, ctx.server)
+	cfg := newSwapConfig(&ctx.lnd.LndServices, ctx.store, ctx.server, nil)
 
 	// Create sender and receiver keys.
 	_, senderPubKey := test.CreateKey(1)
@@ -769,7 +769,7 @@ func advanceToPublishedHtlc(t *testing.T, ctx *loopInTestContext) SwapInfo {
 func startNewLoopIn(t *testing.T, ctx *loopInTestContext, height int32) (
 	*swapConfig, error, *loopInSwap) {
 
-	cfg := newSwapConfig(&ctx.lnd.LndServices, ctx.store, ctx.server)
+	cfg := newSwapConfig(&ctx.lnd.LndServices, ctx.store, ctx.server, nil)
 
 	req := &testLoopInRequest
 

loopout_test.go

@@ -181,7 +181,7 @@ func testLateHtlcPublish(t *testing.T) {
 
 	height := int32(600)
 
-	cfg := newSwapConfig(&lnd.LndServices, store, server)
+	cfg := newSwapConfig(&lnd.LndServices, store, server, nil)
 
 	testRequest.Expiry = height + testLoopOutMinOnChainCltvDelta
 
@@ -282,7 +282,7 @@ func testCustomSweepConfTarget(t *testing.T) {
 	ctx.Lnd.SetFeeEstimate(DefaultSweepConfTarget, 10000)
 
 	cfg := newSwapConfig(
-		&lnd.LndServices, loopdb.NewStoreMock(t), server,
+		&lnd.LndServices, loopdb.NewStoreMock(t), server, nil,
 	)
 
 	initResult, err := newLoopOutSwap(
@@ -522,7 +522,7 @@ func testPreimagePush(t *testing.T) {
 	)
 
 	cfg := newSwapConfig(
-		&lnd.LndServices, loopdb.NewStoreMock(t), server,
+		&lnd.LndServices, loopdb.NewStoreMock(t), server, nil,
 	)
 
 	initResult, err := newLoopOutSwap(
@@ -786,7 +786,7 @@ func testFailedOffChainCancelation(t *testing.T) {
 	testReq.Expiry = lnd.Height + 20
 
 	cfg := newSwapConfig(
-		&lnd.LndServices, loopdb.NewStoreMock(t), server,
+		&lnd.LndServices, loopdb.NewStoreMock(t), server, nil,
 	)
 
 	initResult, err := newLoopOutSwap(
@@ -940,7 +940,7 @@ func TestLoopOutMuSig2Sweep(t *testing.T) {
 	)
 
 	cfg := newSwapConfig(
-		&lnd.LndServices, loopdb.NewStoreMock(t), server,
+		&lnd.LndServices, loopdb.NewStoreMock(t), server, nil,
 	)
 
 	initResult, err := newLoopOutSwap(

swap.go

@@ -5,6 +5,7 @@ import (
 	"time"
 
 	"github.com/lightninglabs/lndclient"
+	"github.com/lightninglabs/loop/assets"
 	"github.com/lightninglabs/loop/loopdb"
 	"github.com/lightninglabs/loop/swap"
 	"github.com/lightninglabs/loop/utils"
@@ -79,14 +80,16 @@ type swapConfig struct {
 	lnd    *lndclient.LndServices
 	store  loopdb.SwapStore
 	server swapServerClient
+	assets *assets.TapdClient
 }
 
 func newSwapConfig(lnd *lndclient.LndServices, store loopdb.SwapStore,
-	server swapServerClient) *swapConfig {
+	server swapServerClient, assets *assets.TapdClient) *swapConfig {
 
 	return &swapConfig{
 		lnd:    lnd,
 		store:  store,
 		server: server,
+		assets: assets,
 	}
 }