chore: Update dependency (#327)

Cargo.toml

@@ -81,7 +81,7 @@ either = "1"
 void = "1"
 
 #ipfs dependency
-rust-ipfs = "0.4.3"
+rust-ipfs = "0.4.4"
 
 # Blink related crates
 # av-data is needed to use libaom. need to ensure that Warp and libaom use the same version of av-data

extensions/warp-ipfs/src/behaviour/phonebook.rs

@@ -1,5 +1,3 @@
-mod handler;
-
 use std::{
     collections::{hash_map::Entry, HashMap, HashSet, VecDeque},
     task::{Context, Poll},
@@ -8,9 +6,8 @@ use std::{
 use rust_ipfs::libp2p::{
     core::Endpoint,
     swarm::{
-        derive_prelude::ConnectionEstablished, ConnectionClosed, ConnectionDenied,
-        ConnectionHandler, ConnectionId, FromSwarm, NotifyHandler, PollParameters, THandler,
-        THandlerInEvent, THandlerOutEvent, ToSwarm,
+        derive_prelude::ConnectionEstablished, ConnectionClosed, ConnectionDenied, ConnectionId,
+        FromSwarm, PollParameters, THandler, THandlerInEvent, THandlerOutEvent, ToSwarm,
     },
     Multiaddr, PeerId,
 };
@@ -123,7 +120,7 @@ impl Behaviour {
 }
 
 impl NetworkBehaviour for Behaviour {
-    type ConnectionHandler = handler::Handler;
+    type ConnectionHandler = rust_ipfs::libp2p::swarm::dummy::ConnectionHandler;
     type ToSwarm = void::Void;
 
     fn handle_pending_inbound_connection(
@@ -148,29 +145,21 @@ impl NetworkBehaviour for Behaviour {
     fn handle_established_inbound_connection(
         &mut self,
         _: ConnectionId,
-        peer_id: PeerId,
+        _: PeerId,
         _: &Multiaddr,
         _: &Multiaddr,
     ) -> Result<THandler<Self>, ConnectionDenied> {
-        let mut handler = handler::Handler::default();
-        if self.entry.contains(&peer_id) {
-            handler.on_behaviour_event(handler::In::Set);
-        }
-        Ok(handler)
+        Ok(rust_ipfs::libp2p::swarm::dummy::ConnectionHandler)
     }
 
     fn handle_established_outbound_connection(
         &mut self,
         _: ConnectionId,
-        peer_id: PeerId,
+        _: PeerId,
         _: &Multiaddr,
         _: Endpoint,
     ) -> Result<THandler<Self>, ConnectionDenied> {
-        let mut handler = handler::Handler::default();
-        if self.entry.contains(&peer_id) {
-            handler.on_behaviour_event(handler::In::Set);
-        }
-        Ok(handler)
+        Ok(rust_ipfs::libp2p::swarm::dummy::ConnectionHandler)
     }
 
     fn on_connection_handler_event(
@@ -246,11 +235,6 @@ impl NetworkBehaviour for Behaviour {
                     }
 
                     self.send_online_event(peer_id);
-                    self.events.push_back(ToSwarm::NotifyHandler {
-                        peer_id,
-                        handler: NotifyHandler::Any,
-                        event: handler::In::Set,
-                    });
                     let _ = response.send(Ok(()));
                 }
                 Poll::Ready(Some(PhoneBookCommand::RemoveEntry { peer_id, response })) => {
@@ -260,11 +244,6 @@ impl NetworkBehaviour for Behaviour {
                     }
 
                     self.send_offline_event(peer_id);
-                    self.events.push_back(ToSwarm::NotifyHandler {
-                        peer_id,
-                        handler: NotifyHandler::Any,
-                        event: handler::In::Unset,
-                    });
                     let _ = response.send(Ok(()));
                 }
                 Poll::Ready(None) => unreachable!("Channels are owned"),