Enhanced bundler engine for creating short and quick bundles

Author: yaroslavser

CHANGELOG.md

@@ -2,6 +2,11 @@
 
 All notable changes to this project will be documented in this file.
 
+## Version 0.58.7
+
+- Enhanced bundler engine for creating short and quick bundles
+  using state proofs instead of full state for debugging and testing purposes
+
 ## Version 0.58.6
 
 - Send SMFT messages to random workchain nodes to improve delivery across workchain

Cargo.toml

@@ -2,7 +2,7 @@
 build = 'common/build/build.rs'
 edition = '2021'
 name = 'ever-node'
-version = '0.58.6'
+version = '0.58.7'
 
 [workspace]
 members = [ 'storage' ]
@@ -100,25 +100,26 @@ validator_session = { path = 'validator-session' }
 
 [dev-dependencies]
 difference = '2.0'
-ed25519-dalek = '1.0.1'
 external-ip = '4.1.0'
 pretty_assertions = '1.3'
 tokio = { features = [ 'macros' ], version = '1.5' }
 
 [features]
 default = [ 'telemetry', 'ever_block/export_key' ]
-export_key = [ 'catchain/export_key', 'ever_block/export_key' ]
+export_key = [ 'catchain/export_key', 'ever_block/export_key', 'validator_session/export_key' ]
 external_db = [ 'rdkafka' ]
 fast_finality_extra = [  ]
 gosh = [ 'ever_block/gosh', 'ever_vm/gosh' ]
 log_metrics = [  ]
+only_sorted_clean = [  ]
 prometheus = [ 'metrics-exporter-prometheus', 'log_metrics' ]
 signature_with_id = [ 'ever_block/signature_with_id', 'ever_vm/signature_with_id', 'ever_executor/signature_with_id' ]
 slashing = [ 'validator_session/slashing' ]
 statsd = [ 'metrics-exporter-statsd', 'log_metrics', 'dep:statsd' ]
 telemetry = [ 'adnl/telemetry', 'storage/telemetry' ]
 trace_alloc = [  ]
 trace_alloc_detail = [ 'trace_alloc' ]
+tracing = [  ]
 verification = [ 'ever_block/export_key' ]
 
 [profile]

bin/console.rs

@@ -934,7 +934,6 @@ async fn main() {
 
 #[cfg(test)]
 mod test {
-    
     use super::*;
     use std::{fs, path::Path, sync::Arc, thread};
     use serde_json::json;
@@ -946,13 +945,17 @@ mod test {
         ShardIdent, ShardStateUnsplit, ValidatorDescr, ValidatorSet
     };
     use ever_node::{
-        block::BlockKind, collator_test_bundle::{create_engine_telemetry, create_engine_allocated},
+        block::BlockKind,
+        collator_test_bundle::create_engine_allocated,
         config::TonNodeConfig, engine_traits::{EngineAlloc, EngineOperations},
         internal_db::{InternalDbConfig, InternalDb, state_gc_resolver::AllowStateGcSmartResolver}, 
         network::{control::{ControlServer, DataSource}, node_network::NodeNetwork},
         shard_state::ShardStateStuff, shard_states_keeper::PinnedShardStateGuard,
         validator::validator_manager::ValidationStatus
     };
+
+    #[cfg(feature = "telemetry")]
+    use ever_node::collator_test_bundle::create_engine_telemetry;
     #[cfg(feature = "telemetry")]
     use ever_node::engine_traits::EngineTelemetry;
 

src/block.rs

@@ -347,7 +347,7 @@ impl BlockStuff {
                 BlockKind::QueueUpdate{queue_update_for: *queue_update_for, empty: *empty },
             BlockOrigin::MeshUpdate{network_id, ..} => BlockKind::MeshUpdate{network_id: *network_id},
             BlockOrigin::MeshKit{network_id, ..} => BlockKind::MeshKit{network_id: *network_id},
-        }
+    }
     }
 
     pub fn block(&self) -> Result<&Block> {
@@ -371,7 +371,7 @@ impl BlockStuff {
         if let Some(wc) = self.is_queue_update_for() {
             if wc != workchain_id {
                 fail!("{} is not queue update for wc {}", self.id(), workchain_id)
-            }
+        }
         }
         self
             .virt_block()?