Implement account rewards

backend-rust/migrations/0001_initialize.up.sql

@@ -65,6 +65,25 @@ CREATE TYPE pool_open_status AS ENUM (
     'ClosedForAll'
 );
 
+CREATE TYPE account_statement_entry_type AS ENUM (
+    'TransferIn',
+    'TransferOut',
+    'AmountDecrypted',
+    'AmountEncrypted',
+    'TransactionFee',
+    'FinalizationReward',
+    'FoundationReward',
+    'BakerReward',
+    'TransactionFeeReward'
+);
+
+CREATE TYPE account_statement_reward_type AS ENUM (
+    'FinalizationReward',
+    'FoundationReward',
+    'BakerReward',
+    'TransactionFeeReward'
+);
+
 CREATE TYPE module_reference_contract_link_action AS ENUM (
     'Added',
     'Removed'
@@ -229,6 +248,7 @@ CREATE TABLE accounts(
 CREATE INDEX accounts_amount_idx ON accounts (amount);
 CREATE INDEX accounts_delegated_stake_idx ON accounts (delegated_stake);
 CREATE INDEX accounts_num_txs_idx ON accounts (num_txs);
+CREATE INDEX accounts_address_index ON accounts (address);
 
 -- Add foreign key constraint now that the account table is created.
 ALTER TABLE transactions
@@ -514,3 +534,21 @@ $trigger$ LANGUAGE plpgsql;
 CREATE TRIGGER account_updated_notify_trigger AFTER INSERT
 ON affected_accounts
 FOR EACH ROW EXECUTE PROCEDURE account_updated_notify_trigger_function();
+
+CREATE TABLE account_statements (
+    id              BIGINT                              GENERATED ALWAYS AS IDENTITY PRIMARY KEY,
+    account_index   BIGINT REFERENCES accounts(index)   NOT NULL,
+    timestamp       TIMESTAMPTZ                         NOT NULL,
+    entry_type      account_statement_entry_type        NOT NULL,
+    amount          BIGINT                              NOT NULL,
+    account_balance BIGINT                              NOT NULL,
+    block_height    BIGINT REFERENCES blocks(height)    NOT NULL,
+    transaction_id  BIGINT                              NULL
+);
+
+CREATE INDEX account_statements_entry_type_idx ON account_statements (entry_type);
+
+CREATE VIEW account_rewards AS
+SELECT id, account_index, timestamp, entry_type::TEXT::account_statement_reward_type AS reward_type, amount, block_height
+FROM account_statements
+WHERE entry_type::TEXT IN (SELECT unnest(enum_range(NULL::account_statement_reward_type))::TEXT);