loopdb: static address deposit queries

Author: hieblmi

loopdb/sqlc/migrations/000008_static_address_deposits.down.sql

@@ -0,0 +1 @@
+DROP TABLE IF EXISTS deposits;

loopdb/sqlc/migrations/000008_static_address_deposits.up.sql

@@ -0,0 +1,17 @@
+-- deposits stores historic and unspent static address outputs.
+CREATE TABLE IF NOT EXISTS deposits (
+    -- id is the auto-incrementing primary key for a static address.
+    id INTEGER PRIMARY KEY,
+
+    tx_hash BYTEA NOT NULL,
+
+    tx_index INT NOT NULL,
+
+    amount BIGINT NOT NULL,
+
+    confirmation_height BIGINT NOT NULL,
+
+    time_out_sweep_pk_script BYTEA NOT NULL,
+
+    spent BOOLEAN NOT NULL
+);

loopdb/sqlc/models.go

@@ -34,4 +34,24 @@ INSERT INTO static_addresses (
 
 -- name: DeleteStaticAddress :exec
 DELETE FROM static_addresses
-WHERE address_id=$1;
+WHERE address_id=$1;
+
+-- name: AllDeposits :many
+SELECT * FROM deposits;
+
+-- name: CreateDeposit :exec
+INSERT INTO deposits (
+    tx_hash,
+    tx_index,
+    amount,
+    confirmation_height,
+    time_out_sweep_pk_script,
+    spent
+) VALUES (
+             $1,
+             $2,
+             $3,
+             $4,
+             $5,
+             $6
+         );

loopdb/sqlc/querier.go

@@ -6,6 +6,8 @@ import (
 
 	"github.com/btcsuite/btcd/btcec/v2"
 	"github.com/btcsuite/btcd/btcutil"
+	"github.com/btcsuite/btcd/chaincfg/chainhash"
+	"github.com/btcsuite/btcd/wire"
 	"github.com/jackc/pgx/v4"
 	"github.com/lightninglabs/loop/loopdb"
 	"github.com/lightninglabs/loop/loopdb/sqlc"
@@ -128,6 +130,61 @@ func (s *SqlStore) GetAllStaticAddresses(ctx context.Context) (
 	return result, nil
 }
 
+// CreateDeposit creates a static address record in the database.
+func (s *SqlStore) CreateDeposit(ctx context.Context, deposit *Deposit) error {
+	createArgs := sqlc.CreateDepositParams{
+		TxHash:               deposit.Hash[:],
+		TxIndex:              int32(deposit.Index),
+		Amount:               int64(deposit.Value),
+		ConfirmationHeight:   deposit.ConfirmationHeight,
+		TimeOutSweepPkScript: deposit.TimeOutSweepPkScript,
+		Spent:                deposit.Spent,
+	}
+
+	return s.baseDB.Queries.CreateDeposit(ctx, createArgs)
+}
+
+// AllDeposits retrieves all known deposits to our static address.
+func (s *SqlStore) AllDeposits(ctx context.Context) ([]Deposit, error) {
+	deposits, err := s.baseDB.Queries.AllDeposits(ctx)
+	if err != nil {
+		return nil, err
+	}
+
+	return s.toDeposits(deposits)
+}
+
+func (s *SqlStore) toDeposits(rows []sqlc.Deposit) ([]Deposit, error) {
+	var result []Deposit
+	for _, row := range rows {
+		deposit, err := s.toDeposit(row)
+		if err != nil {
+			return nil, err
+		}
+
+		result = append(result, *deposit)
+	}
+
+	return result, nil
+}
+
+func (s *SqlStore) toDeposit(row sqlc.Deposit) (*Deposit, error) {
+	hash, err := chainhash.NewHash(row.TxHash)
+	if err != nil {
+		return nil, err
+	}
+
+	return &Deposit{
+		OutPoint: wire.OutPoint{
+			Hash:  *hash,
+			Index: uint32(row.TxIndex),
+		},
+		Value:              btcutil.Amount(row.Amount),
+		ConfirmationHeight: row.ConfirmationHeight,
+		Spent:              row.Spent,
+	}, nil
+}
+
 // Close closes the database connection.
 func (s *SqlStore) Close() {
 	s.baseDB.DB.Close()