feat(mst2): complete native metadata installation and controlled initialization

src/callisto/mod.rs

@@ -66,6 +66,9 @@ pub mod mega_view_root_chain_scan;
 pub mod mega_webhook;
 pub mod mega_webhook_delivery;
 pub mod mega_webhook_event_type;
+pub mod mst2_metadata_payload;
+pub mod mst2_metadata_prepare;
+pub mod mst2_metadata_prepare_page;
 pub mod mst2_native_head;
 pub mod mst2_native_publication;
 pub mod mst2_publication;

src/callisto/mst2_metadata_payload.rs

@@ -0,0 +1,16 @@
+use sea_orm::entity::prelude::*;
+
+#[derive(Clone, Debug, PartialEq, DeriveEntityModel, Eq)]
+#[sea_orm(table_name = "mst2_metadata_payload")]
+pub struct Model {
+    #[sea_orm(primary_key, auto_increment = false)]
+    pub page_id: Vec<u8>,
+    pub metadata_codec: i16,
+    pub byte_size: i32,
+    pub payload: Vec<u8>,
+    pub created_at: DateTimeWithTimeZone,
+}
+
+#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
+pub enum Relation {}
+impl ActiveModelBehavior for ActiveModel {}

src/callisto/mst2_metadata_prepare.rs

@@ -0,0 +1,32 @@
+use sea_orm::entity::prelude::*;
+
+#[derive(Clone, Debug, PartialEq, DeriveEntityModel, Eq)]
+#[sea_orm(table_name = "mst2_metadata_prepare")]
+pub struct Model {
+    #[sea_orm(primary_key, auto_increment = false)]
+    pub prepare_id: String,
+    pub operation_id: String,
+    pub manifest_digest: Vec<u8>,
+    pub canonical_plan: Vec<u8>,
+    pub source_domain: String,
+    pub tagged_root_tree_oid: String,
+    pub scope: String,
+    pub schema_version: i16,
+    pub metadata_codec: i16,
+    pub materialization_policy: i16,
+    pub fs_semantics: i16,
+    pub access_projection: i16,
+    pub verification_revision: i32,
+    pub projection_revision: i16,
+    pub metadata_root: Vec<u8>,
+    pub node_count: i32,
+    pub edge_count: i32,
+    pub total_bytes: i64,
+    pub state: String,
+    pub created_at: DateTimeWithTimeZone,
+    pub committed_at: Option<DateTimeWithTimeZone>,
+}
+
+#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
+pub enum Relation {}
+impl ActiveModelBehavior for ActiveModel {}

src/callisto/mst2_metadata_prepare_page.rs

@@ -0,0 +1,15 @@
+use sea_orm::entity::prelude::*;
+
+#[derive(Clone, Debug, PartialEq, DeriveEntityModel, Eq)]
+#[sea_orm(table_name = "mst2_metadata_prepare_page")]
+pub struct Model {
+    #[sea_orm(primary_key, auto_increment = false)]
+    pub prepare_id: String,
+    #[sea_orm(primary_key, auto_increment = false)]
+    pub page_id: Vec<u8>,
+    pub expected_size: i32,
+}
+
+#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
+pub enum Relation {}
+impl ActiveModelBehavior for ActiveModel {}