Skip to content

Commit 1df4e08

Browse files
committed
try fix incoming peer handling
1 parent b2a2107 commit 1df4e08

File tree

1 file changed

+10
-3
lines changed

1 file changed

+10
-3
lines changed

p2p/src/connection/incoming/p2p_connection_incoming_reducer.rs

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -9,10 +9,11 @@ use crate::{
99
connection::{
1010
incoming::P2pConnectionIncomingError,
1111
incoming_effectful::P2pConnectionIncomingEffectfulAction,
12-
outgoing::P2pConnectionOutgoingInitOpts, P2pConnectionResponse, P2pConnectionState,
12+
outgoing::{P2pConnectionOutgoingInitLibp2pOpts, P2pConnectionOutgoingInitOpts},
13+
P2pConnectionResponse, P2pConnectionState,
1314
},
1415
disconnection::{P2pDisconnectionAction, P2pDisconnectionReason},
15-
webrtc::{HttpSignalingInfo, SignalingMethod},
16+
webrtc::{Host, HttpSignalingInfo, SignalingMethod},
1617
ConnectionAddr, P2pNetworkSchedulerAction, P2pPeerAction, P2pPeerState, P2pPeerStatus,
1718
P2pState, PeerId,
1819
};
@@ -416,7 +417,13 @@ impl P2pConnectionIncomingState {
416417
.entry(peer_id)
417418
.or_insert_with(|| P2pPeerState {
418419
is_libp2p: true,
419-
dial_opts: None,
420+
dial_opts: Some(P2pConnectionOutgoingInitOpts::LibP2P(
421+
P2pConnectionOutgoingInitLibp2pOpts {
422+
peer_id,
423+
host: Host::from(addr.ip()),
424+
port: addr.port(),
425+
},
426+
)),
420427
status: P2pPeerStatus::Disconnected { time: meta.time() },
421428
identify: None,
422429
});

0 commit comments

Comments
 (0)