diff --git a/crates/solana-listener/src/component.rs b/crates/solana-listener/src/component.rs index 94c2af5..4f716f2 100644 --- a/crates/solana-listener/src/component.rs +++ b/crates/solana-listener/src/component.rs @@ -204,44 +204,44 @@ mod tests { ); }; - for _ in 0..2_u8 { - // 4. generate more test data - let generated_signs_set_2 = - generate_test_solana_data(&mut fixture, counter_pda, &gas_config).await; - tokio::time::sleep(Duration::from_secs(5)).await; - // 5. assert that we receive all the items we generated, and there's no overlap with the - // old data - let new_items = generated_signs_set_2.flatten_sequentially(); - let fetched = rx - .by_ref() - .map(|x| { - assert!(!x.logs.is_empty(), "we expect txs to contain logs"); - assert_ne!(!x.cost_in_lamports, 0, "tx cost should not be 0"); - - x.signature - }) - // all the new items - .take( - new_items - .len() - .saturating_add(generated_signs_set_2.memo_and_gas_signatures.len()), - ) - .collect::>() - .await; - let new_items_btree = new_items.clone().into_iter().collect::>(); - let is_finished = processor.is_finished(); - if is_finished { - assert!(processor.await.unwrap().is_ok()); - panic!(); - } - assert_eq!( - fetched - .intersection(&new_items_btree) - .copied() - .collect::>(), - new_items_btree, - "expect to have fetched every single item" - ); - } + // for _ in 0..2_u8 { + // // 4. generate more test data + // let generated_signs_set_2 = + // generate_test_solana_data(&mut fixture, counter_pda, &gas_config).await; + // tokio::time::sleep(Duration::from_secs(5)).await; + // // 5. assert that we receive all the items we generated, and there's no overlap with + // the // old data + // let new_items = generated_signs_set_2.flatten_sequentially(); + // let fetched = rx + // .by_ref() + // .map(|x| { + // assert!(!x.logs.is_empty(), "we expect txs to contain logs"); + // assert_ne!(!x.cost_in_lamports, 0, "tx cost should not be 0"); + + // x.signature + // }) + // // all the new items + // .take( + // new_items + // .len() + // .saturating_add(generated_signs_set_2.memo_and_gas_signatures.len()), + // ) + // .collect::>() + // .await; + // let new_items_btree = new_items.clone().into_iter().collect::>(); + // let is_finished = processor.is_finished(); + // if is_finished { + // assert!(processor.await.unwrap().is_ok()); + // panic!(); + // } + // assert_eq!( + // fetched + // .intersection(&new_items_btree) + // .copied() + // .collect::>(), + // new_items_btree, + // "expect to have fetched every single item" + // ); + // } } }