tapdb: read and write database asset transfer label

Author: ffranr

tapdb/assets_store.go

@@ -2442,6 +2442,7 @@ func (a *AssetStore) LogPendingParcel(ctx context.Context,
 			HeightHint:       int32(spend.AnchorTxHeightHint),
 			AnchorTxid:       newAnchorTXID[:],
 			TransferTimeUnix: spend.TransferTime,
+			Label:            sqlStr(spend.Label),
 		})
 		if err != nil {
 			return fmt.Errorf("unable to insert asset transfer: "+
@@ -3562,6 +3563,7 @@ func (a *AssetStore) QueryParcels(ctx context.Context,
 				ChainFees:          dbAnchorTx.ChainFees,
 				Inputs:             inputs,
 				Outputs:            outputs,
+				Label:              dbT.Label.String,
 			}
 
 			// Set the block height if the anchor is marked as

tapdb/migrations.go

@@ -22,7 +22,7 @@ const (
 	// daemon.
 	//
 	// NOTE: This MUST be updated when a new migration is added.
-	LatestMigrationVersion = 31
+	LatestMigrationVersion = 32
 )
 
 // MigrationTarget is a functional option that can be passed to applyMigrations

tapdb/sqlc/migrations/000032_asset_transfer_label.down.sql

@@ -0,0 +1,2 @@
+-- Remove `label` column from table `asset_transfer`.
+ALTER TABLE asset_transfers DROP COLUMN label;

tapdb/sqlc/migrations/000032_asset_transfer_label.up.sql

@@ -0,0 +1,2 @@
+-- Add a column `label` to table `asset_transfer`.
+ALTER TABLE asset_transfers ADD COLUMN label VARCHAR DEFAULT NULL;

tapdb/sqlc/models.go

@@ -5,9 +5,9 @@ WITH target_txn(txn_id) AS (
     WHERE txid = @anchor_txid
 )
 INSERT INTO asset_transfers (
-    height_hint, anchor_txn_id, transfer_time_unix
+    height_hint, anchor_txn_id, transfer_time_unix, label
 ) VALUES (
-    @height_hint, (SELECT txn_id FROM target_txn), @transfer_time_unix
+    @height_hint, (SELECT txn_id FROM target_txn), @transfer_time_unix, @label
 ) RETURNING id;
 
 -- name: InsertAssetTransferInput :exec
@@ -44,7 +44,7 @@ WHERE output_id = (SELECT output_id FROM target);
 -- name: QueryAssetTransfers :many
 SELECT
     id, height_hint, txns.txid, txns.block_hash AS anchor_tx_block_hash,
-    transfer_time_unix
+    transfer_time_unix, transfers.label
 FROM asset_transfers transfers
 JOIN chain_txns txns
     ON txns.txn_id = transfers.anchor_txn_id

tapdb/sqlc/queries/transfers.sql

@@ -265,7 +265,7 @@ CREATE TABLE asset_transfers (
     anchor_txn_id BIGINT NOT NULL REFERENCES chain_txns(txn_id),
 
     transfer_time_unix TIMESTAMP NOT NULL
-);
+, label VARCHAR DEFAULT NULL);
 
 CREATE TABLE asset_witnesses (
     witness_id INTEGER PRIMARY KEY,