Increase swap deadline offset (#34)

Increase swap deadline offset (#34)

feat(flags.go): add swapPublicationOffset flag to set swap publication deadline offset
feat(loop_provider.go): use swapPublicationOffset value from config to calculate SwapPublicationDeadline, allowing for more flexible swap deadlines

flags.go

@@ -96,6 +96,10 @@ func init() {
 	rootCmd.Flags().String("nodeguardHost", "", "Hostname:port to connect to nodeguard")
 	viper.BindPFlag("nodeguardHost", rootCmd.Flags().Lookup("nodeguardHost"))
 
+	//Swap Publication Offset in minutes
+	rootCmd.Flags().String("swapPublicationOffset", "30m", "Swap publication deadline offset (Maximum time for the swap provider to publish the swap)")
+	viper.BindPFlag("swapPublicationOffset", rootCmd.Flags().Lookup("swapPublicationOffset"))
+
 	//Now we set the global vars
 
 	pollingInterval = viper.GetDuration("pollingInterval")

provider/loop_provider.go

@@ -12,6 +12,7 @@ import (
 	"github.com/lightninglabs/loop/looprpc"
 	"github.com/lightningnetwork/lnd/routing/route"
 	log "github.com/sirupsen/logrus"
+	"github.com/spf13/viper"
 )
 
 type LoopProvider struct {
@@ -243,7 +244,8 @@ func (l *LoopProvider) RequestReverseSubmarineSwap(ctx context.Context, request
 		OutgoingChanSet:         request.ChannelSet,
 		SweepConfTarget:         2, //TODO Make this configurable
 		HtlcConfirmations:       2,
-		SwapPublicationDeadline: uint64(time.Now().Unix()),
+		//The publication deadline is maximum the offset of the swap deadline conf plus the current time
+		SwapPublicationDeadline: uint64(time.Now().Add(viper.GetDuration("swapPublicationOffset") * time.Minute).Unix()),
 		Label:                   fmt.Sprintf("Reverse submarine swap %d sats on date %s", request.SatsAmount, time.Now().Format(time.RFC3339)),
 		Initiator:               "Liquidator",
 	})