sqlc: deposit queries, models and migrations

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,40 @@
+-- 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,
+
+    -- deposit_id is the unique identifier for the deposit.
+    deposit_id BLOB NOT NULL UNIQUE,
+
+    -- tx_hash is the transaction hash of the deposit.
+    tx_hash BYTEA NOT NULL,
+
+    -- output_index is the index of the output in the transaction.
+    out_index INT NOT NULL,
+
+    -- amount is the amount of the deposit.
+    amount BIGINT NOT NULL,
+
+    -- confirmation_height is the absolute height at which the deposit was
+    -- confirmed.
+    confirmation_height BIGINT NOT NULL,
+
+    -- timeout_sweep_pk_script is the public key script that will be used to
+    -- sweep the deposit after has expired.
+    timeout_sweep_pk_script BYTEA NOT NULL
+);
+
+-- deposit_updates contains all the updates to a deposit.
+CREATE TABLE IF NOT EXISTS deposit_updates (
+    -- id is the auto incrementing primary key.
+    id INTEGER PRIMARY KEY,
+
+    -- deposit_id is the unique identifier for the deposit.
+    deposit_id BLOB NOT NULL REFERENCES deposits(deposit_id),
+
+    -- update_state is the state of the deposit at the time of the update.
+    update_state TEXT NOT NULL,
+
+    -- update_timestamp is the timestamp of the update.
+    update_timestamp TIMESTAMP NOT NULL
+);

loopdb/sqlc/models.go

@@ -0,0 +1,63 @@
+-- name: CreateDeposit :exec
+INSERT INTO deposits (
+    deposit_id,
+    tx_hash,
+    out_index,
+    amount,
+    confirmation_height,
+    timeout_sweep_pk_script
+) VALUES (
+             $1,
+             $2,
+             $3,
+             $4,
+             $5,
+             $6
+         );
+
+-- name: UpdateDeposit :exec
+UPDATE deposits
+SET
+    tx_hash = $2,
+    out_index = $3,
+    confirmation_height = $4
+WHERE
+    deposits.deposit_id = $1;
+
+-- name: InsertDepositUpdate :exec
+INSERT INTO deposit_updates (
+    deposit_id,
+    update_state,
+    update_timestamp
+) VALUES (
+             $1,
+             $2,
+             $3
+         );
+
+-- name: GetDeposit :one
+SELECT
+    *
+FROM
+    deposits
+WHERE
+    deposit_id = $1;
+
+-- name: AllDeposits :many
+SELECT
+    *
+FROM
+    deposits
+ORDER BY
+    id ASC;
+
+-- name: GetLatestDepositUpdate :one
+SELECT
+    *
+FROM
+    deposit_updates
+WHERE
+    deposit_id = $1
+ORDER BY
+    update_timestamp DESC
+LIMIT 1;