Add archiving to make sure node sync from DSN succeeds

Author: nazar-pc

Cargo.lock

@@ -38,6 +38,7 @@ sc-cli = { version = "0.10.0-dev", git = "https://github.com/subspace/substrate"
 sc-client-api = { version = "4.0.0-dev", git = "https://github.com/subspace/substrate", rev = "6d57dbc639bb3d9460dabeccb063cc6556452535" }
 sc-consensus = { version = "0.10.0-dev", git = "https://github.com/subspace/substrate", rev = "6d57dbc639bb3d9460dabeccb063cc6556452535" }
 sc-consensus-slots = { version = "0.10.0-dev", git = "https://github.com/subspace/substrate", rev = "6d57dbc639bb3d9460dabeccb063cc6556452535" }
+sc-consensus-subspace = { version = "0.1.0", path = "../sc-consensus-subspace" }
 sc-subspace-chain-specs = { version = "0.1.0", path = "../sc-subspace-chain-specs" }
 sc-executor = { version = "0.10.0-dev", git = "https://github.com/subspace/substrate", rev = "6d57dbc639bb3d9460dabeccb063cc6556452535", features = ["wasmtime"] }
 sc-service = { version = "0.10.0-dev", git = "https://github.com/subspace/substrate", rev = "6d57dbc639bb3d9460dabeccb063cc6556452535", default-features = false, features = ["wasmtime"] }

crates/subspace-node/Cargo.toml

@@ -196,8 +196,18 @@ fn main() -> Result<(), Error> {
                     client,
                     import_queue,
                     task_manager,
+                    other: (_block_import, subspace_link, _telemetry),
                     ..
                 } = subspace_service::new_partial::<RuntimeApi, ExecutorDispatch>(&config)?;
+
+                sc_consensus_subspace::start_subspace_archiver(
+                    &subspace_link,
+                    client.clone(),
+                    None,
+                    &task_manager.spawn_essential_handle(),
+                    config.role.is_authority(),
+                );
+
                 Ok((
                     cmd.run(client, import_queue, task_manager.spawn_essential_handle())
                         .map_err(Error::SubstrateCli),

crates/subspace-node/src/bin/subspace-node.rs

@@ -121,7 +121,7 @@ impl<B: BlockT> Link<B> for WaitLink<B> {
             B::Hash,
         )>,
     ) {
-        println!("Imported {imported} blocks");
+        debug!("Imported {imported} blocks");
         self.imported_blocks += imported as u64;
 
         for result in results {
@@ -297,9 +297,11 @@ where
     }
 
     info!(
-        "🎉 Imported {} blocks, best #{}, exiting...",
+        "🎉 Imported {} blocks, best #{}/#{}, check against reliable sources to make sure it is a \
+        block on canonical chain",
         imported_blocks,
-        client.info().best_number
+        client.info().best_number,
+        client.info().best_hash
     );
 
     Ok(())