22//!
33//! Provides support for storage, and `PubSub` functionality.
44
5- #![ allow( unused, dead_code, deprecated) ]
6-
75use std:: { convert:: Infallible , str:: FromStr } ;
86
97use derive_more:: { Display , From , Into } ;
10- use futures:: { pin_mut, stream:: BoxStream , Stream , StreamExt } ;
8+ use futures:: { pin_mut, stream:: BoxStream , StreamExt } ;
119/// IPFS Content Identifier.
1210pub use ipld_core:: cid:: Cid ;
1311/// IPLD
1412pub use ipld_core:: ipld:: Ipld ;
15- use libp2p:: gossipsub:: { Message as PubsubMessage , MessageId as PubsubMessageId } ;
13+ use libp2p:: gossipsub:: MessageId as PubsubMessageId ;
1614/// `rust_ipfs` re-export.
1715pub use rust_ipfs;
1816/// Peer Info type.
@@ -30,25 +28,25 @@ pub use rust_ipfs::Multiaddr;
3028/// Peer ID type.
3129pub use rust_ipfs:: PeerId ;
3230use rust_ipfs:: {
33- builder:: UninitializedIpfs , dag:: ResolveError , dummy, gossipsub:: IntoGossipsubTopic ,
34- unixfs :: AddOpt , GossipsubMessage , NetworkBehaviour , PubsubEvent , Quorum , ToRecordKey ,
31+ builder:: IpfsBuilder , dag:: ResolveError , dummy, gossipsub:: IntoGossipsubTopic , unixfs :: AddOpt ,
32+ GossipsubMessage , NetworkBehaviour , Quorum , ToRecordKey ,
3533} ;
3634
3735#[ derive( Debug , Display , From , Into ) ]
3836/// `PubSub` Message ID.
3937pub struct MessageId ( pub PubsubMessageId ) ;
4038
4139/// Builder type for IPFS Node configuration.
42- pub struct IpfsBuilder < N > ( UninitializedIpfs < N > )
40+ pub struct HermesIpfsBuilder < N > ( IpfsBuilder < N > )
4341where N : NetworkBehaviour < ToSwarm = Infallible > + Send + Sync ;
4442
45- impl < N > IpfsBuilder < N >
43+ impl < N > HermesIpfsBuilder < N >
4644where N : NetworkBehaviour < ToSwarm = Infallible > + Send + Sync
4745{
4846 #[ must_use]
4947 /// Create a new` IpfsBuilder`.
5048 pub fn new ( ) -> Self {
51- Self ( UninitializedIpfs :: new ( ) )
49+ Self ( IpfsBuilder :: new ( ) )
5250 }
5351
5452 #[ must_use]
@@ -103,7 +101,7 @@ impl HermesIpfs {
103101 ///
104102 /// Returns an error if the IPFS daemon fails to start.
105103 pub async fn start ( ) -> anyhow:: Result < Self > {
106- let node: Ipfs = IpfsBuilder :: < dummy:: Behaviour > :: new ( )
104+ let node: Ipfs = HermesIpfsBuilder :: < dummy:: Behaviour > :: new ( )
107105 . with_default ( )
108106 . set_default_listener ( )
109107 // TODO(saibatizoku): Re-Enable default transport config when libp2p Cert bug is fixed
0 commit comments