squash! filedag.md

checkpoint
ipfs-shipyard · Nov 13, 2023 · 6458cfa · 6458cfa
1 parent ce5bd39
commit 6458cfa
Showing 1 changed file with 0 additions and 76 deletions.
diff --git a/myceli/tests/listener_test.rs b/myceli/tests/listener_test.rs
@@ -20,82 +20,6 @@ pub fn test_verify_listener_alive() {
     assert_eq!(response, Message::available_blocks(vec![]));
 }
 
-#[cfg(feature = "proto_ship")]
-#[test]
-pub fn test_transmit_receive_dag() {
-    let transmitter = TestListener::new();
-    let receiver = TestListener::new();
-    let mut controller = TestController::new();
-
-    transmitter.start().unwrap();
-    receiver.start().unwrap();
-
-    let test_file_path = transmitter.generate_file().unwrap();
-    let resp = controller.send_and_recv(
-        &transmitter.listen_addr,
-        Message::import_file(&test_file_path),
-    );
-    let root_cid = match resp {
-        Message::ApplicationAPI(ApplicationAPI::FileImported { cid, .. }) => cid,
-        other => panic!("Failed to receive FileImported msg {other:?}"),
-    };
-
-    controller.send_msg(
-        Message::transmit_dag(&root_cid, &receiver.listen_addr, 0),
-        &transmitter.listen_addr,
-    );
-
-    utils::wait_receiving_done(&receiver, &mut controller);
-
-    let receiver_blocks =
-        controller.send_and_recv(&receiver.listen_addr, Message::request_available_blocks());
-
-    let transmitter_blocks = controller.send_and_recv(
-        &transmitter.listen_addr,
-        Message::request_available_blocks(),
-    );
-
-    assert_eq!(receiver_blocks, transmitter_blocks);
-}
-
-#[cfg(feature = "proto_ship")]
-#[test]
-pub fn test_transmit_receive_dag_with_retries() {
-    let transmitter = TestListener::new();
-    let receiver = TestListener::new();
-    let mut controller = TestController::new();
-
-    transmitter.start().unwrap();
-    receiver.start().unwrap();
-
-    let test_file_path = transmitter.generate_file().unwrap();
-    let resp = controller.send_and_recv(
-        &transmitter.listen_addr,
-        Message::import_file(&test_file_path),
-    );
-    let root_cid = match resp {
-        Message::ApplicationAPI(ApplicationAPI::FileImported { cid, .. }) => cid,
-        other => panic!("Failed to receive FileImported msg {other:?}"),
-    };
-
-    controller.send_msg(
-        Message::transmit_dag(&root_cid, &receiver.listen_addr, 5),
-        &transmitter.listen_addr,
-    );
-
-    utils::wait_receiving_done(&receiver, &mut controller);
-
-    let receiver_blocks =
-        controller.send_and_recv(&receiver.listen_addr, Message::request_available_blocks());
-
-    let transmitter_blocks = controller.send_and_recv(
-        &transmitter.listen_addr,
-        Message::request_available_blocks(),
-    );
-
-    assert_eq!(receiver_blocks, transmitter_blocks);
-}
-
 #[cfg(feature = "proto_ship")]
 #[ignore]
 #[test]