assets+loopdb: publish cooperative deposit withdrawal transaction

This commit implements the full cooperative deposit withdrawal
flow. The client first fetches keys for any pending withdrawals,
then publishes sweep transactions using the revealed key to sign
the deposit sweep. Once the sweep confirms, the deposit’s state
is updated in the deposit store.

Author: bhandras

assets/deposit/manager.go

@@ -163,6 +163,10 @@ func (m *Manager) Run(ctx context.Context, bestBlock uint32) error {
 		return err
 	}
 
+	// Wake the manager up very 10 seconds to check if there're any pending
+	// chores to do.
+	const wakeupInterval = time.Duration(10) * time.Second
+
 	for {
 		select {
 		case <-m.callEnter:
@@ -182,6 +186,15 @@ func (m *Manager) Run(ctx context.Context, bestBlock uint32) error {
 				return err
 			}
 
+		case <-time.After(wakeupInterval):
+			err := m.publishPendingWithdrawals(ctx)
+			if err != nil {
+				log.Errorf("Unable to publish pending "+
+					"withdrawals: %v", err)
+
+				return err
+			}
+
 		case err := <-blockErrChan:
 			log.Errorf("received error from block epoch "+
 				"notification: %v", err)
@@ -871,6 +884,8 @@ func (m *Manager) handleDepositSpend(ctx context.Context, d *Deposit,
 
 	switch d.State {
 	case StateTimeoutSweepPublished:
+		fallthrough
+	case StateCooperativeSweepPublished:
 		log.Infof("Deposit %s withdrawn in: %s", d.ID, outpoint)
 		d.State = StateSwept
 
@@ -1016,3 +1031,68 @@ func (m *Manager) WithdrawDeposits(ctx context.Context,
 
 	return nil
 }
+
+// publishPendingWithdrawals publishes any pending deposit withdrawals.
+func (m *Manager) publishPendingWithdrawals(ctx context.Context) error {
+	for _, d := range m.deposits {
+		// TODO(bhandras): republish on StateCooperativeSweepPublished.
+		if d.State != StateWithdrawn {
+			continue
+		}
+
+		// Start monitoring the sweep unless we're already doing so.
+		if _, ok := m.pendingSweeps[d.ID]; !ok {
+			err := m.waitForDepositSpend(ctx, d)
+			if err != nil {
+				log.Errorf("Unable to wait for deposit %v "+
+					"spend: %v", d.ID, err)
+
+				return err
+			}
+
+			m.pendingSweeps[d.ID] = struct{}{}
+		}
+
+		serverKey, err := m.store.GetAssetDepositServerKey(
+			ctx, d.ID,
+		)
+		if err != nil {
+			return err
+		}
+
+		lockID, err := d.lockID()
+		if err != nil {
+			return err
+		}
+
+		sweepAddr, err := address.DecodeAddress(
+			d.SweepAddr, &m.addressParams,
+		)
+		if err != nil {
+			return err
+		}
+
+		// TODO(bhandras): conf target should be dynamic/configrable.
+		const confTarget = 2
+		feeRateSatPerKw, err := m.walletKit.EstimateFeeRate(
+			ctx, confTarget,
+		)
+
+		funder := true
+		sendAssetResp, err := m.sweeper.PublishDepositSweepMuSig2(
+			ctx, d.Kit, funder, d.Proof, serverKey, sweepAddr,
+			feeRateSatPerKw.FeePerVByte(), lockID, lockExpiration,
+		)
+		if err != nil {
+			log.Errorf("Unable to publish deposit sweep for %v: %v",
+				d.ID, err)
+		} else {
+			log.Infof("Published sweep for deposit %v: %v", d.ID,
+				sendAssetResp.Transfer.AnchorTxHash)
+
+			d.State = StateCooperativeSweepPublished
+		}
+	}
+
+	return nil
+}

assets/deposit/sql_store.go

@@ -38,6 +38,9 @@ type Querier interface {
 
 	SetAssetDepositServerInternalKey(ctx context.Context,
 		arg sqlc.SetAssetDepositServerInternalKeyParams) error
+
+	GetAssetDepositServerInternalKey(ctx context.Context,
+		depositID string) ([]byte, error)
 }
 
 // DepositBaseDB is the interface that contains all the queries generated
@@ -314,3 +317,19 @@ func (s *SQLStore) SetAssetDepositServerKey(ctx context.Context,
 		},
 	)
 }
+
+func (s *SQLStore) GetAssetDepositServerKey(ctx context.Context,
+	depositID string) (*btcec.PrivateKey, error) {
+
+	keyBytes, err := s.db.GetAssetDepositServerInternalKey(ctx, depositID)
+	if err != nil {
+		return nil, err
+	}
+
+	key, _ := btcec.PrivKeyFromBytes(keyBytes)
+	if err != nil {
+		return nil, err
+	}
+
+	return key, nil
+}

go.mod

@@ -29,14 +29,14 @@ require (
 	github.com/lightningnetwork/lnd/clock v1.1.1
 	github.com/lightningnetwork/lnd/queue v1.1.1
 	github.com/lightningnetwork/lnd/ticker v1.1.1
-	github.com/lightningnetwork/lnd/tlv v1.3.1
+	github.com/lightningnetwork/lnd/tlv v1.3.2
 	github.com/lightningnetwork/lnd/tor v1.1.6
 	github.com/ory/dockertest/v3 v3.10.0
 	github.com/stretchr/testify v1.10.0
 	github.com/urfave/cli v1.22.14
 	go.etcd.io/bbolt v1.3.11
-	golang.org/x/net v0.38.0
-	golang.org/x/sync v0.12.0
+	golang.org/x/net v0.39.0
+	golang.org/x/sync v0.13.0
 	google.golang.org/grpc v1.64.1
 	google.golang.org/protobuf v1.34.2
 	gopkg.in/macaroon-bakery.v2 v2.3.0
@@ -73,8 +73,8 @@ require (
 	github.com/cpuguy83/go-md2man/v2 v2.0.2 // indirect
 	github.com/decred/dcrd/crypto/blake256 v1.0.1 // indirect
 	github.com/decred/dcrd/lru v1.1.2 // indirect
-	github.com/docker/cli v28.0.1+incompatible // indirect
-	github.com/docker/docker v28.0.1+incompatible // indirect
+	github.com/docker/cli v28.1.1+incompatible // indirect
+	github.com/docker/docker v28.1.1+incompatible // indirect
 	github.com/docker/go-connections v0.5.0 // indirect
 	github.com/docker/go-units v0.5.0 // indirect
 	github.com/dustin/go-humanize v1.0.1 // indirect
@@ -102,12 +102,12 @@ require (
 	github.com/jackc/pgio v1.0.0 // indirect
 	github.com/jackc/pgpassfile v1.0.0 // indirect
 	github.com/jackc/pgproto3/v2 v2.3.3 // indirect
-	github.com/jackc/pgservicefile v0.0.0-20221227161230-091c0ba34f0a // indirect
-	github.com/jackc/pgtype v1.14.0 // indirect
-	github.com/jackc/pgx/v4 v4.18.2 // indirect
-	github.com/jackc/pgx/v5 v5.6.0 // indirect
+	github.com/jackc/pgservicefile v0.0.0-20240606120523-5a60cdf6a761 // indirect
+	github.com/jackc/pgtype v1.14.4 // indirect
+	github.com/jackc/pgx/v4 v4.18.3 // indirect
+	github.com/jackc/pgx/v5 v5.7.4 // indirect
 	github.com/jackc/puddle v1.3.0 // indirect
-	github.com/jackc/puddle/v2 v2.2.1 // indirect
+	github.com/jackc/puddle/v2 v2.2.2 // indirect
 	github.com/jackpal/gateway v1.0.5 // indirect
 	github.com/jackpal/go-nat-pmp v0.0.0-20170405195558-28a68d0c24ad // indirect
 	github.com/jonboulle/clockwork v0.2.2 // indirect
@@ -121,11 +121,11 @@ require (
 	github.com/lightninglabs/lightning-node-connect/hashmailrpc v1.0.3 // indirect
 	github.com/lightninglabs/neutrino v0.16.1 // indirect
 	github.com/lightninglabs/neutrino/cache v1.1.2 // indirect
-	github.com/lightningnetwork/lightning-onion v1.2.1-0.20240712235311-98bd56499dfb // indirect
+	github.com/lightningnetwork/lightning-onion v1.2.1-0.20240815225420-8b40adf04ab9 // indirect
 	github.com/lightningnetwork/lnd/fn/v2 v2.0.8 // indirect
 	github.com/lightningnetwork/lnd/healthcheck v1.2.6 // indirect
 	github.com/lightningnetwork/lnd/kvdb v1.4.16 // indirect
-	github.com/lightningnetwork/lnd/sqldb v1.0.9 // indirect
+	github.com/lightningnetwork/lnd/sqldb v1.0.10 // indirect
 	github.com/ltcsuite/ltcd v0.0.0-20190101042124-f37f8bf35796 // indirect
 	github.com/mattn/go-isatty v0.0.20 // indirect
 	github.com/matttproud/golang_protobuf_extensions v1.0.2-0.20181231171920-c182affec369 // indirect
@@ -181,12 +181,12 @@ require (
 	go.uber.org/atomic v1.10.0 // indirect
 	go.uber.org/multierr v1.6.0 // indirect
 	go.uber.org/zap v1.23.0 // indirect
-	golang.org/x/crypto v0.36.0 // indirect
+	golang.org/x/crypto v0.37.0 // indirect
 	golang.org/x/exp v0.0.0-20240325151524-a685a6edb6d8 // indirect
 	golang.org/x/mod v0.21.0 // indirect
-	golang.org/x/sys v0.31.0 // indirect
-	golang.org/x/term v0.30.0 // indirect
-	golang.org/x/text v0.23.0 // indirect
+	golang.org/x/sys v0.32.0 // indirect
+	golang.org/x/term v0.31.0 // indirect
+	golang.org/x/text v0.24.0 // indirect
 	golang.org/x/time v0.5.0 // indirect
 	golang.org/x/tools v0.24.0 // indirect
 	google.golang.org/genproto v0.0.0-20240213162025-012b6fc9bca9 // indirect
@@ -215,4 +215,27 @@ replace github.com/lightninglabs/loop/swapserverrpc => ./swapserverrpc
 
 replace github.com/lightninglabs/loop/looprpc => ./looprpc
 
-go 1.23.9
+// Temporary replace to add SubmitPackage support (https://github.com/btcsuite/btcwallet/pull/1009).
+replace github.com/btcsuite/btcwallet => github.com/bhandras/btcwallet v0.11.1-0.20250507171803-0de1c46b1cfc
+
+// Temporary replace to add SubmitPackage support to btcd (https://github.com/btcsuite/btcd/pull/2366).
+replace github.com/btcsuite/btcd => github.com/bhandras/btcd v0.22.0-beta.0.20250507171227-f18160c86e92
+
+// Temporary replace to add SubmitPackage support to lnd (https://github.com/lightningnetwork/lnd/pull/9784).
+replace github.com/lightningnetwork/lnd => github.com/bhandras/lnd v0.8.0-beta-rc3.0.20250717123715-6cda96a60994
+
+// Temporary replace to make lnd compile with the SubmitPackage changes.
+replace github.com/lightningnetwork/lnd/sqldb => github.com/bhandras/lnd/sqldb v0.0.0-20250716041958-643fbb8af65b
+
+// Temporary replace to include client API for SubmitPackage in lndclient (https://github.com/lightninglabs/lndclient/pull/223)
+replace github.com/lightninglabs/lndclient => github.com/lightninglabs/lndclient v1.0.1-0.20250717123354-cf534c9968b9
+
+// Temporary replace to experimentally change all bitcoin transactions to use v3 (https://github.com/bhandras/taproot-assets/tree/v3-experimental)
+replace github.com/lightninglabs/taproot-assets => github.com/bhandras/taproot-assets v0.0.0-20250717122952-ca46f25f6c3b
+
+// Temporary replace to make taproot-assets compile with the v3 changes.
+replace github.com/lightninglabs/taproot-assets/taprpc => github.com/bhandras/taproot-assets/taprpc v0.0.0-20250605133854-360a25355248
+
+go 1.23.10
+
+toolchain go1.24.5