Trigger key generation according to tx pointer

Author: jannikluhn

rolling-shutter/keyperimpl/gnosis/config.go

@@ -38,7 +38,9 @@ type Config struct {
 	Shuttermint *kprconfig.ShuttermintConfig
 	Metrics     *metricsserver.MetricsConfig
 
-	GnosisContracts *GnosisContracts `shconfig:",required"`
+	GnosisContracts      *GnosisContracts `shconfig:",required"`
+	EncryptedGasLimit    uint64           `shconfig:",required"`
+	MinGasPerTransaction uint64           `shconfig:",required"`
 }
 
 type GnosisContracts struct {
@@ -63,6 +65,8 @@ func (c *Config) SetDefaultValues() error {
 		KeyBroadcastContract: common.Address{},
 		Sequencer:            common.Address{},
 	}
+	c.EncryptedGasLimit = 1_000_000
+	c.MinGasPerTransaction = 21_000
 	return nil
 }
 

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

@@ -13,6 +13,12 @@ INSERT INTO transaction_submitted_event (
 VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9)
 ON CONFLICT DO NOTHING;
 
+-- name: GetTransactionSubmittedEvents :many
+SELECT * FROM transaction_submitted_event
+WHERE eon = $1 AND index >= $2
+ORDER BY index ASC
+LIMIT $3;
+
 -- name: SetTransactionSubmittedEventsSyncedUntil :exec
 INSERT INTO transaction_submitted_events_synced_until (block_number) VALUES ($1)
 ON CONFLICT (enforce_one_row) DO UPDATE
@@ -32,20 +38,17 @@ SELECT event_count FROM transaction_submitted_event_count
 WHERE eon = $1
 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: GetTxPointer :one
+SELECT * FROM tx_pointer
+WHERE eon = $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: InitTxPointer :exec
+INSERT INTO tx_pointer (eon, block, value)
+VALUES ($1, $2, 0)
+ON CONFLICT DO NOTHING;
 
--- 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;
+-- name: SetTxPointer :exec
+INSERT INTO tx_pointer (eon, block, value)
+VALUES ($1, $2, $3)
+ON CONFLICT (eon) DO UPDATE
+SET block = $2, value = $3;

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

@@ -3,15 +3,16 @@
 -- the schema. We'll use this to check we're using the right schema.
 
 CREATE TABLE transaction_submitted_event (
-    index bigint PRIMARY KEY CHECK (index >= 0),
+    index bigint CHECK (index >= 0),
     block_number bigint NOT NULL CHECK (block_number >= 0),
     block_hash bytea NOT NULL,
     tx_index bigint NOT NULL CHECK (tx_index >= 0),
     log_index bigint NOT NULL CHECK (log_index >= 0),
     eon bigint NOT NULL CHECK (eon >= 0),
     identity_prefix bytea NOT NULL,
     sender text NOT NULL,
-    gas_limit bigint NOT NULL CHECK (gas_limit >= 0)
+    gas_limit bigint NOT NULL CHECK (gas_limit >= 0),
+    PRIMARY KEY (index, eon)
 );
 
 CREATE TABLE transaction_submitted_events_synced_until(
@@ -24,17 +25,8 @@ CREATE TABLE transaction_submitted_event_count(
     event_count bigint NOT NULL DEFAULT 0 CHECK (event_count >= 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
+    eon bigint PRIMARY KEY,
+    block bigint NOT NULL DEFAULT 0,
+    value bigint NOT NULL DEFAULT 0
 );