looprpc: add autoloop parameters to rpc server

Author: carlaKC

liquidity/liquidity.go

@@ -362,6 +362,8 @@ type Manager struct {
 }
 
 // Run periodically checks whether we should automatically dispatch a loop out.
+// We run this loop even if automated swaps are not currently enabled rather
+// than managing starting and stopping the ticker as our parameters are updated.
 func (m *Manager) Run(ctx context.Context) error {
 	m.cfg.AutoOutTicker.Resume()
 	defer m.cfg.AutoOutTicker.Stop()

loopd/swapclient_server.go

@@ -578,11 +578,22 @@ func (s *swapClientServer) GetLiquidityParams(_ context.Context,
 		SweepFeeRateSatPerVbyte: uint64(satPerByte),
 		SweepConfTarget:         cfg.SweepConfTarget,
 		FailureBackoffSec:       uint64(cfg.FailureBackOff.Seconds()),
+		AutoLoopOut:             cfg.AutoOut,
+		AutoOutBudgetSat:        uint64(cfg.AutoFeeBudget),
+		AutoMaxInFlight:         uint64(cfg.MaxAutoInFlight),
 		Rules: make(
 			[]*looprpc.LiquidityRule, 0, len(cfg.ChannelRules),
 		),
 	}
 
+	// Zero golang time is different to a zero unix time, so we only set
+	// our start date if it is non-zero.
+	if !cfg.AutoFeeStartDate.IsZero() {
+		rpcCfg.AutoOutBudgetStartSec = uint64(
+			cfg.AutoFeeStartDate.Unix(),
+		)
+	}
+
 	for channel, rule := range cfg.ChannelRules {
 		rpcRule := &looprpc.LiquidityRule{
 			ChannelId:         channel.ToUint64(),
@@ -617,12 +628,22 @@ func (s *swapClientServer) SetLiquidityParams(_ context.Context,
 		SweepConfTarget:            in.Parameters.SweepConfTarget,
 		FailureBackOff: time.Duration(in.Parameters.FailureBackoffSec) *
 			time.Second,
+		AutoOut:         in.Parameters.AutoLoopOut,
+		AutoFeeBudget:   btcutil.Amount(in.Parameters.AutoOutBudgetSat),
+		MaxAutoInFlight: int(in.Parameters.AutoMaxInFlight),
 		ChannelRules: make(
 			map[lnwire.ShortChannelID]*liquidity.ThresholdRule,
 			len(in.Parameters.Rules),
 		),
 	}
 
+	// Zero unix time is different to zero golang time.
+	if in.Parameters.AutoOutBudgetStartSec != 0 {
+		params.AutoFeeStartDate = time.Unix(
+			int64(in.Parameters.AutoOutBudgetStartSec), 0,
+		)
+	}
+
 	for _, rule := range in.Parameters.Rules {
 		var (
 			shortID = lnwire.NewShortChanIDFromInt(rule.ChannelId)