Merge pull request #838 from input-output-hk/jpraynaud/828-adapt-signer-regsitration-store

Create/Migrate `signer_registration` store

Author: jpraynaud

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "mithril-aggregator"
-version = "0.2.43"
+version = "0.2.44"
 description = "A Mithril Aggregator server"
 authors = { workspace = true }
 edition = { workspace = true }

mithril-aggregator/Cargo.toml

@@ -146,6 +146,47 @@ create table open_message (
     foreign key (epoch_setting_id)     references epoch_setting (epoch_setting_id),
     foreign key (signed_entity_type_id) references signed_entity_type (signed_entity_type_id)
 );
+"#,
+        ),
+        // Migration 6
+        // Add the `signer_registration` table and migration data from the previous
+        // `verification_key` JSON format.
+        // TODO: activate FK w/ signer table exists `foreign key (signer_id) references signer(signer_id)`
+        SqlMigration::new(
+            6,
+            r#"
+create table signer_registration (
+    signer_id                   text        not null,
+    epoch_setting_id            integer     not null,
+    verification_key            text        not null,
+    verification_key_signature  text,
+    operational_certificate     text,
+    kes_period                  integer,
+    stake                       integer,
+    created_at                  text        not null default current_timestamp,
+    primary key (epoch_setting_id, signer_id)
+    foreign key (epoch_setting_id) references epoch_setting(epoch_setting_id)
+);
+create table if not exists verification_key (key_hash text primary key, key json not null, value json not null);
+insert into signer_registration (signer_id, 
+                                epoch_setting_id, 
+                                verification_key, 
+                                verification_key_signature,
+                                operational_certificate, 
+                                kes_period,
+                                stake) 
+    select 
+        verification_key_signer.key as signer_id,
+        verification_key.key as epoch_setting_id, 
+        json_extract(verification_key_signer.value, '$.verification_key') as verification_key,
+        json_extract(verification_key_signer.value, '$.verification_key_signature') as verification_key_signature,
+        json_extract(verification_key_signer.value, '$.operational_certificate') as operational_certificate,
+        json_extract(verification_key_signer.value, '$.kes_period') as kes_period,
+        stake_pool.stake as stake
+    from verification_key, json_each(verification_key.value) as verification_key_signer 
+    left join stake_pool on stake_pool.stake_pool_id = verification_key_signer.key and stake_pool.epoch = verification_key.key
+    order by verification_key.key, verification_key_signer.key asc;
+drop table verification_key;
 "#,
         ),
     ]

mithril-aggregator/src/database/migration.rs

@@ -190,7 +190,7 @@ impl<'conn> Provider<'conn> for UpdateEpochSettingProvider<'conn> {
     }
 }
 
-/// Provider to remove old data from theepoch_setting table
+/// Provider to remove old data from the epoch_setting table
 pub struct DeleteEpochSettingProvider<'conn> {
     connection: &'conn Connection,
 }
@@ -249,6 +249,7 @@ impl<'conn> DeleteEpochSettingProvider<'conn> {
         self.find(filters)
     }
 }
+
 /// Service to deal with epoch settings (read & write).
 pub struct EpochSettingStore {
     connection: Arc<Mutex<Connection>>,

mithril-aggregator/src/database/provider/epoch_setting.rs

@@ -2,9 +2,11 @@
 mod certificate;
 mod epoch_setting;
 mod open_message;
+mod signer_registration;
 mod stake_pool;
 
 pub use certificate::*;
 pub use epoch_setting::*;
 pub use open_message::*;
+pub use signer_registration::*;
 pub use stake_pool::*;