Merge pull request #858 from input-output-hk/jpraynaud/816-adapt-signed-entity-stores

Create/Migrate `signed_entity` store

Author: jpraynaud

Cargo.lock

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

mithril-aggregator/Cargo.toml

@@ -187,6 +187,40 @@ insert into signer_registration (signer_id,
     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;
+"#,
+        ),
+        // Migration 7
+        // Add the `signed_entity` table and migration data from the previous
+        // `snapshot` JSON format.
+        SqlMigration::new(
+            7,
+            r#"
+create table signed_entity (
+    signed_entity_id            text        not null,
+    signed_entity_type_id       integer     not null,
+    certificate_id              text        not null,
+    beacon                      json        not null,
+    entity                      json        not null,
+    created_at                  text        not null default current_timestamp,
+    primary key (signed_entity_id)
+    foreign key (signed_entity_type_id) references signed_entity_type(signed_entity_type_id)
+    foreign key (certificate_id) references certificate(certificate_id)
+);
+create table if not exists snapshot (key_hash text primary key, key json not null, value json not null);
+insert into signed_entity (signed_entity_id, 
+                                signed_entity_type_id, 
+                                certificate_id,
+                                beacon,
+                                entity) 
+    select 
+        json_extract(snapshot.value, '$.digest') as signed_entity_id,
+        2 as signed_entity_type_id,
+        json_extract(snapshot.value, '$.certificate_hash') as certificate_id,
+        json_extract(snapshot.value, '$.beacon') as beacon,
+        snapshot.value as entity
+    from snapshot 
+    order by ROWID asc;
+drop table snapshot;
 "#,
         ),
     ]

mithril-aggregator/src/database/migration.rs

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