loopdb: add asset params to store

Author: sputn1ck

loopdb/sql_store.go

@@ -499,6 +499,8 @@ func loopOutToInsertArgs(hash lntypes.Hash,
 		MaxPrepayRoutingFee: int64(loopOut.MaxPrepayRoutingFee),
 		PublicationDeadline: loopOut.SwapPublicationDeadline.UTC(),
 		PaymentTimeout:      int32(loopOut.PaymentTimeout.Seconds()),
+		AssetID:             loopOut.AssetId,
+		AssetEdgeNode:       loopOut.AssetEdgeNode,
 	}
 }
 
@@ -595,6 +597,8 @@ func ConvertLoopOutRow(network *chaincfg.Params, row sqlc.GetLoopOutSwapRow,
 			PaymentTimeout: time.Duration(
 				row.PaymentTimeout,
 			) * time.Second,
+			AssetId:       row.AssetID,
+			AssetEdgeNode: row.AssetEdgeNode,
 		},
 		Loop: Loop{
 			Hash: swapHash,

loopdb/sql_test.go

@@ -22,6 +22,15 @@ const (
 	testLabel = "test label"
 )
 
+var (
+	testAssetId = []byte{
+		1, 1, 1, 1, 2, 2, 2, 2,
+		3, 3, 3, 3, 4, 4, 4, 4,
+		1, 1, 1, 1, 2, 2, 2, 2,
+		3, 3, 3, 3, 4, 4, 4, 4,
+	}
+)
+
 // TestSqliteLoopOutStore tests all the basic functionality of the current
 // sqlite swap store.
 func TestSqliteLoopOutStore(t *testing.T) {
@@ -80,6 +89,13 @@ func TestSqliteLoopOutStore(t *testing.T) {
 	t.Run("labelled swap", func(t *testing.T) {
 		testSqliteLoopOutStore(t, &labelledSwap)
 	})
+
+	assetSwap := unrestrictedSwap
+	assetSwap.AssetId = testAssetId
+
+	t.Run("asset swap", func(t *testing.T) {
+		testSqliteLoopOutStore(t, &assetSwap)
+	})
 }
 
 // testSqliteLoopOutStore tests the basic functionality of the current sqlite

loopdb/sqlc/migrations/000012_loop_out_asset_params.down.sql

@@ -0,0 +1,2 @@
+ALTER TABLE loopout_swaps DROP COLUMN asset_id;
+ALTER TABLE loopout_swaps DROP COLUMN asset_edge_node;

loopdb/sqlc/migrations/000012_loop_out_asset_params.up.sql

@@ -0,0 +1,7 @@
+-- asset_id is an optional field that can be used to specify the asset id that
+-- will be used to pay the swap invoice using a taproot assets channel.
+ALTER TABLE loopout_swaps ADD asset_id BYTEA;
+
+-- asset_edge_node is an optional field that can be used to specify the node
+-- that will be used to route the asset payment through.
+ALTER TABLE loopout_swaps ADD asset_edge_node BYTEA;

loopdb/sqlc/models.go

@@ -106,9 +106,11 @@ INSERT INTO loopout_swaps (
     max_prepay_routing_fee,
     publication_deadline,
     single_sweep,
-    payment_timeout
+    payment_timeout,
+    asset_id,
+    asset_edge_node
 ) VALUES (
-    $1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12
+    $1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14
 );
 
 -- name: InsertLoopIn :exec