staticaddr: fast-flag

Author: hieblmi

client.go

@@ -843,6 +843,7 @@ func (s *Client) LoopInQuote(ctx context.Context,
 	quote, err := s.Server.GetLoopInQuote(
 		ctx, request.Amount, s.lndServices.NodePubkey, request.LastHop,
 		request.RouteHints, request.Initiator, request.NumDeposits,
+		request.Fast,
 	)
 	if err != nil {
 		return nil, err

cmd/loop/staticaddr.go

@@ -485,6 +485,12 @@ var staticAddressLoopInCommand = cli.Command{
 				"is change it is sent back to the static " +
 				"address.",
 		},
+		cli.BoolFlag{
+			Name: "fast",
+			Usage: "expedited publishing of the change output if " +
+				"the swap creates one. This results in a " +
+				"higher swap fee.",
+		},
 		lastHopFlag,
 		labelFlag,
 		routeHintsFlag,
@@ -573,7 +579,8 @@ func staticAddressLoopIn(ctx *cli.Context) error {
 		depositOutpoints = ctx.StringSlice("utxo")
 
 	case selectedAmount > 0:
-		// If only an amount is selected we will trigger coin selection.
+		// If only an amount is selected, we will trigger coin
+		// selection.
 
 	default:
 		return fmt.Errorf("unknown quote request")
@@ -594,6 +601,7 @@ func staticAddressLoopIn(ctx *cli.Context) error {
 		Private:            ctx.Bool(privateFlag.Name),
 		DepositOutpoints:   depositOutpoints,
 		AutoSelectDeposits: autoSelectDepositsForQuote,
+		Fast:               ctx.Bool("fast"),
 	}
 	quote, err := client.GetLoopInQuote(ctxb, quoteReq)
 	if err != nil {
@@ -623,6 +631,7 @@ func staticAddressLoopIn(ctx *cli.Context) error {
 		RouteHints:            hints,
 		Private:               ctx.Bool("private"),
 		PaymentTimeoutSeconds: paymentTimeoutSeconds,
+		Fast:                  ctx.Bool("fast"),
 	}
 
 	resp, err := client.StaticAddressLoopIn(ctxb, req)

interface.go

@@ -343,6 +343,11 @@ type StaticAddressLoopInRequest struct {
 	// the user did not select an amount, the amount of the selected
 	// deposits is used.
 	SelectedAmount btcutil.Amount
+
+	// Fast indicates whether the user requested a fast static loop-in. If
+	// set, the flag is passed to the server which may alter its behavior
+	// (for example, publish sooner) and is stored in the database.
+	Fast bool
 }
 
 // LoopInTerms are the server terms on which it executes loop in swaps.
@@ -405,6 +410,12 @@ type LoopInQuoteRequest struct {
 	// per-input service fee. This is to cover for the increased on-chain
 	// fee the server has to pay when the sweeping transaction is broadcast.
 	NumDeposits uint32
+
+	// Fast indicates whether the user requested a fast static loop-in
+	// publication on-chain. This is helpful if swap change needs to get
+	// confirmed fast. This comes at a higher swap cost since the server has
+	// to pay more on-chain fees.
+	Fast bool
 }
 
 // LoopInQuote contains estimates for the fees making up the total swap cost

loopd/swapclient_server.go

@@ -1025,6 +1025,7 @@ func (s *swapClientServer) GetLoopInQuote(ctx context.Context,
 		Private:        req.Private,
 		Initiator:      defaultLoopdInitiator,
 		NumDeposits:    uint32(numDeposits),
+		Fast:           req.Fast,
 	})
 	if err != nil {
 		return nil, err
@@ -2052,6 +2053,7 @@ func (s *swapClientServer) StaticAddressLoopIn(ctx context.Context,
 		Private:               in.Private,
 		RouteHints:            routeHints,
 		PaymentTimeoutSeconds: in.PaymentTimeoutSeconds,
+		Fast:                  in.GetFast(),
 	}
 
 	if in.LastHop != nil {

loopdb/sqlc/migrations/000020_static_address_fast_flag.down.sql

@@ -0,0 +1,2 @@
+-- Drop 'fast' flag from static_address_swaps
+ALTER TABLE static_address_swaps DROP COLUMN fast;

loopdb/sqlc/migrations/000020_static_address_fast_flag.up.sql

@@ -0,0 +1,2 @@
+-- Add 'fast' flag to static_address_swaps, default false
+ALTER TABLE static_address_swaps ADD COLUMN fast BOOLEAN NOT NULL DEFAULT false;

loopdb/sqlc/models.go

@@ -9,7 +9,8 @@ INSERT INTO static_address_swaps (
     selected_amount,
     htlc_tx_fee_rate_sat_kw,
     htlc_timeout_sweep_tx_id,
-    htlc_timeout_sweep_address
+    htlc_timeout_sweep_address,
+    fast
 ) VALUES (
     $1,
     $2,
@@ -20,7 +21,8 @@ INSERT INTO static_address_swaps (
     $7,
     $8,
     $9,
-    $10
+    $10,
+    $11
 );
 
 -- name: UpdateStaticAddressLoopIn :exec

loopdb/sqlc/queries/static_address_loopin.sql

@@ -130,9 +130,11 @@ func newLoopInSwap(globalCtx context.Context, cfg *swapConfig,
 	// channels is an LND side black box feature. Advanced users will quote
 	// directly anyway and there they have the option to add specific route
 	// hints.
+	numDeposits := uint32(0)
+	fast := false
 	quote, err := cfg.server.GetLoopInQuote(
 		globalCtx, request.Amount, cfg.lnd.NodePubkey, request.LastHop,
-		request.RouteHints, request.Initiator, 0,
+		request.RouteHints, request.Initiator, numDeposits, fast,
 	)
 	if err != nil {
 		return nil, wrapGrpcError("loop in terms", err)