@@ -3,9 +3,9 @@ extern crate random_access_memory as ram;
3
3
mod common;
4
4
5
5
use common:: create_feed;
6
- use hypercore:: { generate_keypair, Feed , NodeTrait , PublicKey , SecretKey , Storage } ;
7
- use hypercore:: { storage_disk, storage_memory} ;
8
6
use futures:: stream:: StreamExt ;
7
+ use hypercore:: { generate_keypair, Event , Feed , NodeTrait , PublicKey , SecretKey , Storage } ;
8
+ use hypercore:: { storage_disk, storage_memory} ;
9
9
use std:: env:: temp_dir;
10
10
use std:: fs;
11
11
use std:: io:: Write ;
@@ -245,21 +245,6 @@ async fn create_with_stored_keys() {
245
245
) ;
246
246
}
247
247
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
-
263
248
#[ async_std:: test]
264
249
async fn audit ( ) {
265
250
let mut feed = create_feed ( 50 ) . await . unwrap ( ) ;
@@ -355,16 +340,7 @@ async fn try_open_file_as_dir() {
355
340
}
356
341
}
357
342
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]
368
344
async fn events_append ( ) {
369
345
let mut feed = create_feed ( 50 ) . await . unwrap ( ) ;
370
346
let event_task = collect_events ( & mut feed, 3 ) ;
@@ -407,9 +383,17 @@ async fn events_download() {
407
383
assert_eq ! ( event_list, expected, "Correct events emitted" )
408
384
}
409
385
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 ) {
413
397
match & feed. secret_key ( ) {
414
398
Some ( secret) => {
415
399
let secret = secret. to_bytes ( ) ;
@@ -424,12 +408,7 @@ fn copy_keys(
424
408
}
425
409
}
426
410
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 > > {
433
412
let mut events = feed. subscribe ( ) ;
434
413
let event_task = async_std:: task:: spawn ( async move {
435
414
let mut event_list = vec ! [ ] ;
@@ -443,4 +422,3 @@ fn collect_events(
443
422
} ) ;
444
423
event_task
445
424
}
446
- >>>>>>> c7e774c... Emit Download and Append events
0 commit comments