loopd: instantiate static address open channel manager

Author: hieblmi

loopd/daemon.go

@@ -24,6 +24,7 @@ import (
 	"github.com/lightninglabs/loop/staticaddr/address"
 	"github.com/lightninglabs/loop/staticaddr/deposit"
 	"github.com/lightninglabs/loop/staticaddr/loopin"
+	"github.com/lightninglabs/loop/staticaddr/openchannel"
 	"github.com/lightninglabs/loop/staticaddr/withdraw"
 	loop_swaprpc "github.com/lightninglabs/loop/swapserverrpc"
 	"github.com/lightninglabs/loop/sweepbatcher"
@@ -573,6 +574,7 @@ func (d *Daemon) initialize(withMacaroonService bool) error {
 		staticAddressManager *address.Manager
 		depositManager       *deposit.Manager
 		withdrawalManager    *withdraw.Manager
+		openChannelManager   *openchannel.Manager
 		staticLoopInManager  *loopin.Manager
 	)
 
@@ -619,6 +621,19 @@ func (d *Daemon) initialize(withMacaroonService bool) error {
 	}
 	withdrawalManager = withdraw.NewManager(withdrawalCfg, blockHeight)
 
+	// Static address deposit open channel manager setup.
+	openChannelCfg := &openchannel.Config{
+		Server:          staticAddressClient,
+		AddressManager:  staticAddressManager,
+		DepositManager:  depositManager,
+		WalletKit:       d.lnd.WalletKit,
+		ChainParams:     d.lnd.ChainParams,
+		ChainNotifier:   d.lnd.ChainNotifier,
+		Signer:          d.lnd.Signer,
+		LightningClient: d.lnd.Client,
+	}
+	openChannelManager = openchannel.NewManager(openChannelCfg)
+
 	// Static address loop-in manager setup.
 	staticAddressLoopInStore := loopin.NewSqlStore(
 		loopdb.NewTypedStore[loopin.Querier](baseDb),
@@ -726,6 +741,7 @@ func (d *Daemon) initialize(withMacaroonService bool) error {
 		depositManager:       depositManager,
 		withdrawalManager:    withdrawalManager,
 		staticLoopInManager:  staticLoopInManager,
+		openChannelManager:   openChannelManager,
 		assetClient:          d.assetClient,
 	}
 
@@ -961,6 +977,20 @@ func (d *Daemon) initialize(withMacaroonService bool) error {
 			cancel()
 		}
 	}
+	// Start the static address open channel manager.
+	if openChannelManager != nil {
+		d.wg.Add(1)
+		go func() {
+			defer d.wg.Done()
+
+			infof("Starting static address open channel manager")
+			err := openChannelManager.Run(d.mainCtx)
+			if err != nil && !errors.Is(context.Canceled, err) {
+				d.internalErrChan <- err
+			}
+			infof("Static address open channel manager stopped")
+		}()
+	}
 
 	// Start the static address loop-in manager.
 	if staticLoopInManager != nil {

loopd/swapclient_server.go

@@ -32,6 +32,7 @@ import (
 	"github.com/lightninglabs/loop/staticaddr/address"
 	"github.com/lightninglabs/loop/staticaddr/deposit"
 	"github.com/lightninglabs/loop/staticaddr/loopin"
+	"github.com/lightninglabs/loop/staticaddr/openchannel"
 	"github.com/lightninglabs/loop/staticaddr/withdraw"
 	"github.com/lightninglabs/loop/swap"
 	"github.com/lightninglabs/loop/swapserverrpc"
@@ -97,6 +98,7 @@ type swapClientServer struct {
 	depositManager       *deposit.Manager
 	withdrawalManager    *withdraw.Manager
 	staticLoopInManager  *loopin.Manager
+	openChannelManager   *openchannel.Manager
 	assetClient          *assets.TapdClient
 	swaps                map[lntypes.Hash]loop.SwapInfo
 	subscribers          map[int]chan<- interface{}
@@ -1978,13 +1980,14 @@ func (s *swapClientServer) GetStaticAddressSummary(ctx context.Context,
 	}
 
 	var (
-		totalNumDeposits = len(allDeposits)
-		valueUnconfirmed int64
-		valueDeposited   int64
-		valueExpired     int64
-		valueWithdrawn   int64
-		valueLoopedIn    int64
-		htlcTimeoutSwept int64
+		totalNumDeposits    = len(allDeposits)
+		valueUnconfirmed    int64
+		valueDeposited      int64
+		valueExpired        int64
+		valueWithdrawn      int64
+		valueLoopedIn       int64
+		valueChannelsOpened int64
+		htlcTimeoutSwept    int64
 	)
 
 	// Value unconfirmed.
@@ -2016,6 +2019,9 @@ func (s *swapClientServer) GetStaticAddressSummary(ctx context.Context,
 
 		case deposit.HtlcTimeoutSwept:
 			htlcTimeoutSwept += value
+
+		case deposit.ChannelPublished:
+			valueChannelsOpened += value
 		}
 	}
 
@@ -2040,6 +2046,7 @@ func (s *swapClientServer) GetStaticAddressSummary(ctx context.Context,
 		ValueExpiredSatoshis:           valueExpired,
 		ValueWithdrawnSatoshis:         valueWithdrawn,
 		ValueLoopedInSatoshis:          valueLoopedIn,
+		ValueChannelsOpened:            valueChannelsOpened,
 		ValueHtlcTimeoutSweepsSatoshis: htlcTimeoutSwept,
 	}, nil
 }
@@ -2149,6 +2156,35 @@ func (s *swapClientServer) populateBlocksUntilExpiry(ctx context.Context,
 	return nil
 }
 
+// StaticOpenChannel initiates an open channel request using static address
+// deposits.
+func (s *swapClientServer) StaticOpenChannel(ctx context.Context,
+	req *looprpc.OpenChannelRequest) (*looprpc.StaticOpenChannelResponse,
+	error) {
+
+	infof("Static open channel request received")
+
+	chanOpenTxHash, err := s.openChannelManager.DeliverOpenChannelRequest(
+		ctx, req,
+	)
+
+	var (
+		txHash string
+		errMsg string
+	)
+	if chanOpenTxHash != nil {
+		txHash = chanOpenTxHash.String()
+	}
+	if err != nil {
+		errMsg = err.Error()
+	}
+
+	return &looprpc.StaticOpenChannelResponse{
+		ChannelOpenTxHash: txHash,
+		Error:             errMsg,
+	}, nil
+}
+
 type filterFunc func(deposits *deposit.Deposit) bool
 
 func filter(deposits []*deposit.Deposit, f filterFunc) []*looprpc.Deposit {
@@ -2202,6 +2238,12 @@ func toClientDepositState(state fsm.StateType) looprpc.DepositState {
 	case deposit.LoopedIn:
 		return looprpc.DepositState_LOOPED_IN
 
+	case deposit.OpeningChannel:
+		return looprpc.DepositState_OPENING_CHANNEL
+
+	case deposit.ChannelPublished:
+		return looprpc.DepositState_CHANNEL_PUBLISHED
+
 	case deposit.SweepHtlcTimeout:
 		return looprpc.DepositState_SWEEP_HTLC_TIMEOUT
 
@@ -2281,6 +2323,12 @@ func toServerState(state looprpc.DepositState) fsm.StateType {
 	case looprpc.DepositState_LOOPED_IN:
 		return deposit.LoopedIn
 
+	case looprpc.DepositState_OPENING_CHANNEL:
+		return deposit.OpeningChannel
+
+	case looprpc.DepositState_CHANNEL_PUBLISHED:
+		return deposit.ChannelPublished
+
 	case looprpc.DepositState_SWEEP_HTLC_TIMEOUT:
 		return deposit.SweepHtlcTimeout