Merge pull request #840 from input-output-hk/greg/827/open_message

open message provider & repository

Author: ghubertpalo

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "mithril-aggregator"
-version = "0.2.42"
+version = "0.2.43"
 description = "A Mithril Aggregator server"
 authors = { workspace = true }
 edition = { workspace = true }
@@ -32,6 +32,7 @@ tar = "0.4.38"
 thiserror = "1.0.31"
 tokio = { version = "1.17.0", features = ["full"] }
 tokio-util = { version = "0.7.1", features = ["codec"] }
+uuid = { version = "1.3.0", features = ["v4", "fast-rng", "macro-diagnostics"] }
 warp = "0.3"
 
 [dev-dependencies]

mithril-aggregator/Cargo.toml

@@ -128,6 +128,24 @@ insert into certificate (certificate_id,
     from certificate_temp as c;
 create index epoch_index ON certificate(epoch);
 drop table certificate_temp;
+"#,
+        ),
+        // Migration 5
+        // Add the `open_message` table
+        SqlMigration::new(
+            5,
+            r#"
+create table open_message (
+	open_message_id         text    not null,
+    epoch_setting_id        int     not null,
+    beacon                  json    not null,
+    signed_entity_type_id   int     not null,
+    message                 text    not null,
+    created_at              text    not null default current_timestamp,
+    primary key (open_message_id),
+    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)
+);
 "#,
         ),
     ]

mithril-aggregator/src/database/migration.rs

@@ -76,7 +76,7 @@ impl SqLiteEntity for EpochSettingRecord {
     }
 }
 
-/// Simple [EpochSetting] provider.
+/// Simple [EpochSettingRecord] provider.
 pub struct EpochSettingProvider<'client> {
     client: &'client Connection,
 }

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

@@ -1,8 +1,10 @@
 //! Aggregator related database providers
 mod certificate;
 mod epoch_setting;
+mod open_message;
 mod stake_pool;
 
 pub use certificate::*;
 pub use epoch_setting::*;
+pub use open_message::*;
 pub use stake_pool::*;