Store tx_pointer in db

Author: jannikluhn

rolling-shutter/keyperimpl/gnosis/database/gnosiskeyper.sqlc.gen.go

@@ -18,4 +18,22 @@ ON CONFLICT (enforce_one_row) DO UPDATE
 SET block_number = $1;
 
 -- name: GetTransactionSubmittedEventsSyncedUntil :one
-SELECT block_number FROM transaction_submitted_events_synced_until LIMIT 1;
+SELECT block_number FROM transaction_submitted_events_synced_until LIMIT 1;
+
+-- name: GetLocalTxPointer :one
+SELECT local, local_block FROM tx_pointer LIMIT 1;
+
+-- name: GetConsensusTxPointer :one
+SELECT consensus, consensus_block FROM tx_pointer LIMIT 1;
+
+-- name: UpdateLocalTxPointer :exec
+INSERT INTO tx_pointer (local, local_block)
+VALUES ($1, $2)
+ON CONFLICT (enforce_one_row) DO UPDATE
+SET local = $1, local_block = $2;
+
+-- name: UpdateConsensusTxPointer :exec
+INSERT INTO tx_pointer (consensus, consensus_block)
+VALUES ($1, $2)
+ON CONFLICT (enforce_one_row) DO UPDATE
+SET consensus = $1, consensus_block = $2;

rolling-shutter/keyperimpl/gnosis/database/models.sqlc.gen.go

@@ -14,7 +14,22 @@ CREATE TABLE transaction_submitted_event (
     PRIMARY KEY (block_number, block_hash, tx_index, log_index)
 );
 
-create table transaction_submitted_events_synced_until(
-       enforce_one_row bool primary key default true,
-       block_number bigint not null CHECK (block_number > 0)
+CREATE TABLE transaction_submitted_events_synced_until(
+    enforce_one_row bool PRIMARY KEY DEFAULT true,
+    block_number bigint NOT NULL CHECK (block_number > 0)
+);
+
+-- tx_pointer stores what we know about the current value of the tx pointer. There are two
+-- sources that are stored independently: The keyper itself (local) and the other keypers
+-- (consensus). The local value is updated whenever the keyper sends decryption key shares for some
+-- transactions. The consensus value is updated when decryption keys are received from other
+-- keypers. The values can be NULL if the keyper has lost track (e.g. after a restart or if no
+-- messages have been received recently). Each value is annotated with the number of the block at
+-- whose end the tx_pointer is valid.
+CREATE TABLE tx_pointer(
+    enforce_one_row bool PRIMARY KEY DEFAULT true,
+    local bigint DEFAULT NULL,
+    local_block bigint NOT NULL DEFAULT 0,
+    consensus bigint DEFAULT NULL,
+    consensus_block bigint NOT NULL DEFAULT 0
 );