[refactor] #2664: Introduce new wsv

Signed-off-by: Shanin Roman <shanin1000@yandex.ru>
hyperledger · Nov 21, 2023 · dc0cc41 · dc0cc41
1 parent af85650
commit dc0cc41
Show file tree

Hide file tree

Showing 49 changed files with 3,091 additions and 2,180 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -134,6 +134,8 @@ serde_with = { version = "3.3.0", default-features = false }
 parity-scale-codec = { version = "3.6.5", default-features = false }
 json5 = "0.4.1"
 
+storage = { git = "https://github.com/Erigara/storage.git", branch="main" }
+
 [workspace.lints]
 rust.anonymous_parameters = "deny"
 rust.future_incompatible = "deny"

diff --git a/cli/src/lib.rs b/cli/src/lib.rs
@@ -19,13 +19,13 @@ use iroha_core::{
     gossiper::{TransactionGossiper, TransactionGossiperHandle},
     handler::ThreadHandler,
     kura::Kura,
-    prelude::{World, WorldStateView},
     query::store::LiveQueryStore,
     queue::Queue,
     smartcontracts::isi::Registrable as _,
     snapshot::{try_read_snapshot, SnapshotMaker, SnapshotMakerHandle},
     sumeragi::{SumeragiHandle, SumeragiStartArgs},
     tx::PeerId,
+    wsv::{State, World},
     IrohaNetwork,
 };
 use iroha_data_model::prelude::*;
@@ -95,6 +95,8 @@ pub struct Iroha {
     pub torii: Option<Torii>,
     /// Snapshot service
     pub snapshot_maker: SnapshotMakerHandle,
+    /// State of blockchain
+    pub wsv: Arc<State>,
     /// Thread handlers
     thread_handlers: Vec<ThreadHandler>,
 
@@ -256,7 +258,7 @@ impl Iroha {
         .map_or_else(
             |error| {
                 iroha_logger::warn!(%error, "Failed to load wsv from snapshot, creating empty wsv");
-                WorldStateView::from_configuration(
+                State::from_configuration(
                     *config.wsv,
                     world,
                     Arc::clone(&kura),
@@ -265,12 +267,13 @@ impl Iroha {
             },
             |wsv| {
                 iroha_logger::info!(
-                    at_height = wsv.height(),
+                    at_height = wsv.view().height(),
                     "Successfully loaded wsv from snapshot"
                 );
                 wsv
             },
         );
+        let wsv = Arc::new(wsv);
 
         let queue = Arc::new(Queue::from_configuration(&config.queue));
         if Self::start_telemetry(telemetry, &config).await? {
@@ -284,7 +287,7 @@ impl Iroha {
         let sumeragi = SumeragiHandle::start(SumeragiStartArgs {
             configuration: &config.sumeragi,
             events_sender: events_sender.clone(),
-            wsv,
+            wsv: Arc::clone(&wsv),
             queue: Arc::clone(&queue),
             kura: Arc::clone(&kura),
             network: network.clone(),
@@ -298,14 +301,15 @@ impl Iroha {
             Arc::clone(&kura),
             PeerId::new(&config.torii.p2p_addr, &config.public_key),
             network.clone(),
+            Arc::clone(&wsv),
         )
         .start();
 
         let gossiper = TransactionGossiper::from_configuration(
             &config.sumeragi,
             network.clone(),
             Arc::clone(&queue),
-            sumeragi.clone(),
+            Arc::clone(&wsv),
         )
         .start();
 
@@ -326,7 +330,7 @@ impl Iroha {
         .start();
 
         let snapshot_maker =
-            SnapshotMaker::from_configuration(&config.snapshot, sumeragi.clone()).start();
+            SnapshotMaker::from_configuration(&config.snapshot, Arc::clone(&wsv)).start();
 
         let torii = Torii::from_configuration(
             config.clone(),
@@ -336,6 +340,7 @@ impl Iroha {
             sumeragi.clone(),
             live_query_store_handle,
             Arc::clone(&kura),
+            Arc::clone(&wsv),
         );
 
         Self::start_listening_signal(Arc::clone(&notify_shutdown))?;
@@ -349,6 +354,7 @@ impl Iroha {
             kura,
             torii,
             snapshot_maker,
+            wsv,
             thread_handlers: vec![kura_thread_handler],
             #[cfg(debug_assertions)]
             freeze_status,

diff --git a/cli/src/torii/mod.rs b/cli/src/torii/mod.rs
@@ -16,6 +16,7 @@ use iroha_core::{
     query::store::LiveQueryStoreHandle,
     queue::{self, Queue},
     sumeragi::SumeragiHandle,
+    wsv::State,
     EventsSender,
 };
 use tokio::sync::Notify;
@@ -40,6 +41,7 @@ pub struct Torii {
     sumeragi: SumeragiHandle,
     query_service: LiveQueryStoreHandle,
     kura: Arc<Kura>,
+    wsv: Arc<State>,
 }
 
 /// Torii errors.