[refactor] #4315: split pipeline events

Signed-off-by: Marin Veršić <[email protected]>

cli/src/lib.rs

@@ -240,7 +240,7 @@ impl Iroha {
             },
         );
 
-        let queue = Arc::new(Queue::from_config(config.queue));
+        let queue = Arc::new(Queue::from_config(config.queue, events_sender));
         match Self::start_telemetry(&logger, &config).await? {
             TelemetryStartStatus::Started => iroha_logger::info!("Telemetry started"),
             TelemetryStartStatus::NotStarted => iroha_logger::warn!("Telemetry not started"),

core/benches/blocks/apply_blocks.rs

@@ -41,9 +41,10 @@ impl WsvApplyBlocks {
                 .into_iter()
                 .map(|instructions| {
                     let block = create_block(&mut wsv, instructions, account_id.clone(), &key_pair);
-                    wsv.apply_without_execution(&block).map(|()| block)
+                    let _wsv_events = wsv.apply_without_execution(&block);
+                    block
                 })
-                .collect::<Result<Vec<_>, _>>()?
+                .collect::<Vec<_>>()
         };
 
         Ok(Self { wsv, blocks })

core/benches/blocks/common.rs

@@ -42,7 +42,9 @@ pub fn create_block(
     )
     .chain(0, wsv)
     .sign(key_pair)
+    .unpack(|_| {})
     .commit(&topology)
+    .unpack(|_| {})
     .unwrap();
 
     // Verify that transactions are valid

core/benches/blocks/validate_blocks.rs

@@ -70,7 +70,7 @@ impl WsvValidateBlocks {
         for (instructions, i) in instructions.into_iter().zip(1..) {
             finalized_wsv = wsv.clone();
             let block = create_block(&mut wsv, instructions, account_id.clone(), &key_pair);
-            wsv.apply_without_execution(&block)?;
+            let _wsv_events = wsv.apply_without_execution(&block);
             assert_eq!(wsv.height(), i);
             assert_eq!(wsv.height(), finalized_wsv.height() + 1);
         }

core/benches/kura.rs

@@ -53,7 +53,8 @@ async fn measure_block_size_for_n_executors(n_executors: u32) {
     let topology = Topology::new(UniqueVec::new());
     let mut block = BlockBuilder::new(vec![tx], topology, Vec::new())
         .chain(0, &mut wsv)
-        .sign(&KeyPair::random());
+        .sign(&KeyPair::random())
+        .unpack(|_| {});
 
     for _ in 1..n_executors {
         block = block.sign(&KeyPair::random());

core/benches/validation.rs

@@ -180,7 +180,7 @@ fn sign_blocks(criterion: &mut Criterion) {
         b.iter_batched(
             || block.clone(),
             |block| {
-                let _: ValidBlock = block.sign(&key_pair);
+                let _: ValidBlock = block.sign(&key_pair).unpack(|_| {});
                 count += 1;
             },
             BatchSize::SmallInput,