Merge pull request #982 from openmina/feat/p2p/webrtc/datachannel-rs

P2p WebRTC: add datachannel-rs backend

Author: binier

Cargo.lock

@@ -1 +1 @@
-pub use tokio::sync::{broadcast, mpsc, oneshot};
+pub use tokio::sync::{broadcast, mpsc, oneshot, watch};

core/src/channels.rs

@@ -291,7 +291,8 @@ impl NodeBuilder {
     }
 
     pub fn build(mut self) -> anyhow::Result<Node> {
-        let p2p_sec_key = self.p2p_sec_key.unwrap_or_else(P2pSecretKey::rand);
+        let p2p_sec_key = self.p2p_sec_key.clone().unwrap_or_else(P2pSecretKey::rand);
+        self.p2p_sec_key(p2p_sec_key.clone());
         if self.p2p.initial_peers.is_empty() && !self.p2p_is_seed {
             self.p2p.initial_peers = default_peers();
         }

node/native/src/node/builder.rs

@@ -198,6 +198,7 @@ pub fn event_source_effects<S: Service>(store: &mut Store<S>, action: EventSourc
                     },
                     P2pConnectionEvent::Closed(peer_id) => {
                         store.dispatch(P2pDisconnectionAction::PeerClosed { peer_id });
+                        store.dispatch(P2pDisconnectionAction::Finish { peer_id });
                     }
                 },
                 P2pEvent::Channel(e) => match e {