Add versioning to mainnet update 2.5

Cargo.toml

@@ -111,9 +111,8 @@ massa_event_cache = { path = "./massa-event-cache" }
 # Massa projects dependencies
 # massa-proto-rs = { git = "https://github.com/massalabs/massa-proto-rs", branch = "deferred_calls" }
 # massa-sc-runtime = { git = "https://github.com/massalabs/massa-sc-runtime", "branch" = "deferred_calls" }
-massa-proto-rs = { git = "https://github.com/massalabs/massa-proto-rs", "rev" = "b5267178eaf266ec724691d7de163e4c34343416" }
-massa-sc-runtime = { git = "https://github.com/massalabs/massa-sc-runtime", "rev" = "f5a584b9f8050f332c9ed332bd0a40f8e0372807" }
-
+massa-proto-rs = { git = "https://github.com/massalabs/massa-proto-rs", "rev" = "c9a7c55914f3d308996113df0936f15d96490313" }
+massa-sc-runtime = { git = "https://github.com/massalabs/massa-sc-runtime", "rev" = "cd14c775aff31b8c0f49064613118f428f9dd45f" }
 
 peernet = { git = "https://github.com/massalabs/PeerNet", "rev" = "04b05ddd320fbe76cc858115af7b5fc28bdb8310" }
 # Dev only - use local dependencies

massa-api-exports/src/node.rs

@@ -46,6 +46,8 @@ pub struct NodeStatus {
     pub chain_id: u64,
     /// minimal fees to include an operation in a block
     pub minimal_fees: Amount,
+    /// current mip version
+    pub current_mip_version: u32,
 }
 
 impl std::fmt::Display for NodeStatus {

massa-api/src/public.rs

@@ -458,6 +458,12 @@ impl MassaRpcServer for API<Public> {
         let config = CompactConfig::default();
         let now = MassaTime::now();
 
+        let current_mip_version = self
+            .0
+            .keypair_factory
+            .mip_store
+            .get_network_version_current();
+
         let last_slot_result = get_latest_block_slot_at_timestamp(
             api_settings.thread_count,
             api_settings.t0,
@@ -555,6 +561,7 @@ impl MassaRpcServer for API<Public> {
             current_cycle,
             chain_id: self.0.api_settings.chain_id,
             minimal_fees: self.0.api_settings.minimal_fees,
+            current_mip_version,
         })
     }
 
@@ -1160,6 +1167,16 @@ impl MassaRpcServer for API<Public> {
         &self,
         req: Vec<DeferredCallsQuoteRequest>,
     ) -> RpcResult<Vec<DeferredCallsQuoteResponse>> {
+        let current_network_version = self
+            .0
+            .keypair_factory
+            .mip_store
+            .get_network_version_current();
+
+        if current_network_version < 1 {
+            return Err(ApiError::NotFound.into());
+        }
+
         if req.len() as u64 > self.0.api_settings.max_arguments {
             return Err(ApiError::BadRequest("too many arguments".into()).into());
         }
@@ -1205,6 +1222,16 @@ impl MassaRpcServer for API<Public> {
         &self,
         arg: Vec<String>,
     ) -> RpcResult<Vec<DeferredCallResponse>> {
+        let current_network_version = self
+            .0
+            .keypair_factory
+            .mip_store
+            .get_network_version_current();
+
+        if current_network_version < 1 {
+            return Err(ApiError::NotFound.into());
+        }
+
         if arg.len() as u64 > self.0.api_settings.max_arguments {
             return Err(ApiError::BadRequest("too many arguments".into()).into());
         }
@@ -1245,6 +1272,16 @@ impl MassaRpcServer for API<Public> {
         &self,
         slots: Vec<Slot>,
     ) -> RpcResult<Vec<DeferredCallsSlotResponse>> {
+        let current_network_version = self
+            .0
+            .keypair_factory
+            .mip_store
+            .get_network_version_current();
+
+        if current_network_version < 1 {
+            return Err(ApiError::NotFound.into());
+        }
+
         if slots.len() as u64 > self.0.api_settings.max_arguments {
             return Err(ApiError::BadRequest("too many arguments".into()).into());
         }

massa-bootstrap/src/tests/universe_server.rs

@@ -202,7 +202,7 @@ impl BootstrapServerTestUniverseBuilder {
         let mut batch = DBBatch::default();
         let versioning_batch = DBBatch::default();
         self.final_ledger
-            .apply_changes_to_batch(ledger_changes, &mut batch);
+            .apply_changes_to_batch(ledger_changes, &mut batch, 1);
         self.controllers
             .database
             .write()
@@ -216,7 +216,7 @@ impl BootstrapServerTestUniverseBuilder {
         let mut batch = DBBatch::default();
         let versioning_batch = DBBatch::default();
         self.final_ledger
-            .apply_changes_to_batch(ledger_changes, &mut batch);
+            .apply_changes_to_batch(ledger_changes, &mut batch, 1);
         self.controllers
             .database
             .write()
@@ -232,7 +232,7 @@ impl BootstrapServerTestUniverseBuilder {
         let mut batch = DBBatch::default();
         let versioning_batch = DBBatch::default();
         self.final_ledger
-            .apply_changes_to_batch(ledger_changes, &mut batch);
+            .apply_changes_to_batch(ledger_changes, &mut batch, 1);
         self.controllers
             .database
             .write()

massa-client/src/display.rs

@@ -275,6 +275,7 @@ impl Output for NodeStatus {
 
         println!();
         println!("Chain id: {}", self.chain_id);
+        println!("Current MIP version: {}", self.current_mip_version);
     }
 }
 

massa-event-cache/src/event_cache.rs

@@ -944,7 +944,7 @@ mod tests {
     use tempfile::TempDir;
     // internal
     use massa_models::config::{
-        MAX_EVENT_DATA_SIZE, MAX_EVENT_PER_OPERATION, MAX_OPERATIONS_PER_BLOCK,
+        MAX_EVENT_DATA_SIZE_V1, MAX_EVENT_PER_OPERATION, MAX_OPERATIONS_PER_BLOCK,
         MAX_RECURSIVE_CALLS_DEPTH, THREAD_COUNT,
     };
     use massa_models::operation::OperationId;
@@ -959,7 +959,7 @@ mod tests {
             300,
             THREAD_COUNT,
             MAX_RECURSIVE_CALLS_DEPTH,
-            MAX_EVENT_DATA_SIZE as u64,
+            MAX_EVENT_DATA_SIZE_V1 as u64,
             MAX_EVENT_PER_OPERATION as u64,
             MAX_OPERATIONS_PER_BLOCK as u64,
             5000, // MAX_EVENTS_PER_QUERY,

massa-execution-exports/src/mapping_grpc.rs

@@ -21,6 +21,7 @@ use massa_proto_rs::massa::model::v1 as grpc_model;
 /// Convert a `grpc_api::ScExecutionEventsRequest` to a `ScExecutionEventsRequest`
 pub fn to_querystate_filter(
     query: grpc_api::ExecutionQueryRequestItem,
+    network_version: u32,
 ) -> Result<ExecutionQueryRequestItem, ModelsError> {
     if let Some(item) = query.request_item {
         match item {
@@ -135,6 +136,12 @@ pub fn to_querystate_filter(
                 Ok(ExecutionQueryRequestItem::Events(event_filter))
             }
             exec::RequestItem::DeferredCallQuote(value) => {
+                if network_version < 1 {
+                    return Err(ModelsError::InvalidVersionError(
+                        "deferred call quote is not supported in this network version".to_string(),
+                    ));
+                }
+
                 Ok(ExecutionQueryRequestItem::DeferredCallQuote {
                     target_slot: value
                         .target_slot
@@ -147,10 +154,22 @@ pub fn to_querystate_filter(
                 })
             }
             exec::RequestItem::DeferredCallInfo(info) => {
+                if network_version < 1 {
+                    return Err(ModelsError::InvalidVersionError(
+                        "deferred call quote is not supported in this network version".to_string(),
+                    ));
+                }
+
                 let id = DeferredCallId::from_str(&info.call_id)?;
                 Ok(ExecutionQueryRequestItem::DeferredCallInfo(id))
             }
             exec::RequestItem::DeferredCallsBySlot(value) => {
+                if network_version < 1 {
+                    return Err(ModelsError::InvalidVersionError(
+                        "deferred call quote is not supported in this network version".to_string(),
+                    ));
+                }
+
                 Ok(ExecutionQueryRequestItem::DeferredCallsBySlot(
                     value
                         .slot

massa-execution-exports/src/settings.rs

@@ -92,7 +92,9 @@ pub struct ExecutionConfig {
     /// slot execution outputs channel capacity
     pub broadcast_slot_execution_output_channel_capacity: usize,
     /// max size of event data, in bytes
-    pub max_event_size: usize,
+    pub max_event_size_v0: usize,
+    /// max size of event data, in bytes
+    pub max_event_size_v1: usize,
     /// chain id
     pub chain_id: u64,
     /// whether slot execution traces broadcast is enabled

massa-execution-exports/src/test_exports/config.rs

@@ -93,7 +93,8 @@ impl Default for ExecutionConfig {
             denunciation_expire_periods: DENUNCIATION_EXPIRE_PERIODS,
             broadcast_enabled: true,
             broadcast_slot_execution_output_channel_capacity: 5000,
-            max_event_size: 512,
+            max_event_size_v0: 50_000,
+            max_event_size_v1: 512,
             max_event_per_operation: 25,
             max_function_length: 1000,
             max_parameter_length: 1000,

massa-execution-worker/Cargo.toml

@@ -28,6 +28,7 @@ test-exports = [
     "massa_pos_worker",
     "massa_metrics/test-exports",
     "massa_metrics/test-exports",
+    "massa_versioning/test-exports",
     "massa_db_worker",
     "massa_event_cache/test-exports",
     "tempfile",
@@ -109,6 +110,7 @@ massa_metrics = { workspace = true, features = ["test-exports"] }
 massa_db_worker = { workspace = true }
 tempfile = { workspace = true }
 massa_test_framework = { workspace = true, "features" = ["test-exports"] }
+massa_versioning = { workspace = true, "features" = ["test-exports"] }
 tokio = { workspace = true, features = ["sync"] }
 hex-literal = { workspace = true }
 mockall = { workspace = true }

massa-execution-worker/src/active_history.rs

@@ -68,6 +68,7 @@ impl ActiveHistory {
         &self,
         message_id: &AsyncMessageId,
         mut current_updates: AsyncMessageUpdate,
+        execution_compound_version: u32,
     ) -> HistorySearchResult<SetUpdateOrDelete<AsyncMessage, AsyncMessageUpdate>> {
         for history_element in self.0.iter().rev() {
             match history_element
@@ -81,11 +82,16 @@ impl ActiveHistory {
                     msg.apply(current_updates);
                     return HistorySearchResult::Present(SetUpdateOrDelete::Set(msg));
                 }
-                Some(SetUpdateOrDelete::Update(msg_update)) => {
-                    let mut combined_message_update = msg_update.clone();
-                    combined_message_update.apply(current_updates);
-                    current_updates = combined_message_update;
-                }
+                Some(SetUpdateOrDelete::Update(msg_update)) => match execution_compound_version {
+                    0 => {
+                        current_updates.apply(msg_update.clone());
+                    }
+                    _ => {
+                        let mut combined_message_update = msg_update.clone();
+                        combined_message_update.apply(current_updates);
+                        current_updates = combined_message_update;
+                    }
+                },
                 Some(SetUpdateOrDelete::Delete) => return HistorySearchResult::Absent,
                 _ => (),
             }
@@ -498,14 +504,14 @@ mod test {
         // Test fetch_message with message_id (expect HistorySearchResult::Absent)
         {
             let current_updates = AsyncMessageUpdate::default();
-            let fetched = active_history.fetch_message(&message_id, current_updates);
+            let fetched = active_history.fetch_message(&message_id, current_updates, 1);
             assert_matches!(fetched, HistorySearchResult::Absent);
         }
 
         // Test fetch_message with message_id_2 (expect HistorySearchResult::Set)
         {
             let current_updates = AsyncMessageUpdate::default();
-            let fetched = active_history.fetch_message(&message_id_2, current_updates);
+            let fetched = active_history.fetch_message(&message_id_2, current_updates, 1);
 
             if let HistorySearchResult::Present(SetUpdateOrDelete::Set(msg)) = fetched {
                 assert_eq!(msg, msg_2);
@@ -526,7 +532,7 @@ mod test {
                 validity_end: SetOrKeep::Set(validity_end_new),
                 ..Default::default()
             };
-            let fetched = active_history.fetch_message(&message_id_2, current_updates);
+            let fetched = active_history.fetch_message(&message_id_2, current_updates, 1);
 
             if let HistorySearchResult::Present(SetUpdateOrDelete::Set(msg)) = fetched {
                 assert_ne!(msg, msg_2);
@@ -542,7 +548,7 @@ mod test {
         // Test fetch_message with message_id_3 (expect HistorySearchResult::Present)
         {
             let current_updates = AsyncMessageUpdate::default();
-            let fetched = active_history.fetch_message(&message_id_3, current_updates);
+            let fetched = active_history.fetch_message(&message_id_3, current_updates, 1);
 
             if let HistorySearchResult::Present(SetUpdateOrDelete::Set(msg)) = fetched {
                 // Check the updates were applied correctly
@@ -561,7 +567,7 @@ mod test {
         // Expect updates to be empty (or default) here
         {
             let current_updates = AsyncMessageUpdate::default();
-            let fetched = active_history.fetch_message(&message_id_3_2, current_updates);
+            let fetched = active_history.fetch_message(&message_id_3_2, current_updates, 1);
             if let HistorySearchResult::Present(SetUpdateOrDelete::Update(updates)) = fetched {
                 assert_eq!(updates, AsyncMessageUpdate::default());
             } else {