@@ -3,9 +3,9 @@ extern crate random_access_memory as ram;
33mod common;
44
55use common:: create_feed;
6- use hypercore:: { generate_keypair, Feed , NodeTrait , PublicKey , SecretKey , Storage } ;
7- use hypercore:: { storage_disk, storage_memory} ;
86use futures:: stream:: StreamExt ;
7+ use hypercore:: { generate_keypair, Event , Feed , NodeTrait , PublicKey , SecretKey , Storage } ;
8+ use hypercore:: { storage_disk, storage_memory} ;
99use std:: env:: temp_dir;
1010use std:: fs;
1111use std:: io:: Write ;
@@ -245,21 +245,6 @@ async fn create_with_stored_keys() {
245245 ) ;
246246}
247247
248- fn copy_keys ( feed : & Feed ) -> ( PublicKey , SecretKey ) {
249- match & feed. secret_key ( ) {
250- Some ( secret) => {
251- let secret = secret. to_bytes ( ) ;
252- let public = & feed. public_key ( ) . to_bytes ( ) ;
253-
254- let public = PublicKey :: from_bytes ( public) . unwrap ( ) ;
255- let secret = SecretKey :: from_bytes ( & secret) . unwrap ( ) ;
256-
257- ( public, secret)
258- }
259- _ => panic ! ( "<tests/common>: Could not access secret key" ) ,
260- }
261- }
262-
263248#[ async_std:: test]
264249async fn audit ( ) {
265250 let mut feed = create_feed ( 50 ) . await . unwrap ( ) ;
@@ -355,16 +340,7 @@ async fn try_open_file_as_dir() {
355340 }
356341}
357342
358- async fn create_clone ( feed : & Feed ) -> Result < Feed , anyhow:: Error > {
359- let ( public, secret) = copy_keys ( & feed) ;
360- let storage = storage_memory ( ) . await ?;
361- let clone = Feed :: builder ( public, storage)
362- . secret_key ( secret)
363- . build ( )
364- . await ?;
365- Ok ( clone)
366- }
367-
343+ #[ async_std:: test]
368344async fn events_append ( ) {
369345 let mut feed = create_feed ( 50 ) . await . unwrap ( ) ;
370346 let event_task = collect_events ( & mut feed, 3 ) ;
@@ -407,9 +383,17 @@ async fn events_download() {
407383 assert_eq ! ( event_list, expected, "Correct events emitted" )
408384}
409385
410- fn copy_keys (
411- feed : & Feed < impl RandomAccess < Error = Box < dyn std:: error:: Error + Send + Sync > > + Debug + Send > ,
412- ) -> ( PublicKey , SecretKey ) {
386+ async fn create_clone ( feed : & Feed ) -> Result < Feed , anyhow:: Error > {
387+ let ( public, secret) = copy_keys ( & feed) ;
388+ let storage = storage_memory ( ) . await ?;
389+ let clone = Feed :: builder ( public, storage)
390+ . secret_key ( secret)
391+ . build ( )
392+ . await ?;
393+ Ok ( clone)
394+ }
395+
396+ fn copy_keys ( feed : & Feed ) -> ( PublicKey , SecretKey ) {
413397 match & feed. secret_key ( ) {
414398 Some ( secret) => {
415399 let secret = secret. to_bytes ( ) ;
@@ -424,12 +408,7 @@ fn copy_keys(
424408 }
425409}
426410
427- fn collect_events (
428- feed : & mut Feed <
429- impl RandomAccess < Error = Box < dyn std:: error:: Error + Send + Sync > > + Debug + Send ,
430- > ,
431- n : usize ,
432- ) -> async_std:: task:: JoinHandle < Vec < Event > > {
411+ fn collect_events ( feed : & mut Feed , n : usize ) -> async_std:: task:: JoinHandle < Vec < Event > > {
433412 let mut events = feed. subscribe ( ) ;
434413 let event_task = async_std:: task:: spawn ( async move {
435414 let mut event_list = vec ! [ ] ;
@@ -443,4 +422,3 @@ fn collect_events(
443422 } ) ;
444423 event_task
445424}
446- >>>>>>> c7e774c... Emit Download and Append events
0 commit comments