varun-r-mallya/py-libp2p
1
0
Fork 0
mirror of https://github.com/varun-r-mallya/py-libp2p.git synced 2026-02-11 23:51:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

refractored Peer_Info to PeerInfo as imports

Browse Source
This commit is contained in:
Winter-Soren
2025-05-08 01:47:24 +05:30
committed by Paul Robinson
parent 99238403dd
commit e9674d2bca
2 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
libp2p/host/autonat/pb/autonat.proto
View File

@ -32,17 +32,17 @@ message Message {
// Dial request // Dial request
message DialRequest { message DialRequest {
repeated Peer_Info peers = 1; repeated PeerInfo peers = 1;
} }
// Dial response // Dial response
message DialResponse { message DialResponse {
Status status = 1; Status status = 1;
repeated Peer_Info peers = 2; repeated PeerInfo peers = 2;
} }
// Peer information // Peer information
message Peer_Info { message PeerInfo {
bytes id = 1; bytes id = 1;
repeated bytes addrs = 2; repeated bytes addrs = 2;
bool success = 3; bool success = 3;

8
tests/core/host/test_autonat.py
View File

@ -14,7 +14,7 @@ from libp2p.host.autonat.pb.autonat_pb2 import (
DialRequest, DialRequest,
DialResponse, DialResponse,
Message, Message,
Peer_Info, PeerInfo,
Status, Status,
Type, Type,
) )
@ -137,7 +137,7 @@ async def test_handle_dial():
# Create a mock message with a peer to dial # Create a mock message with a peer to dial
message = Message() message = Message()
message.type = Type.Value("DIAL") message.type = Type.Value("DIAL")
peer_info = Peer_Info() peer_info = PeerInfo()
peer_info.id = peer_id.to_bytes() peer_info.id = peer_id.to_bytes()
peer_info.addrs.extend([b"/ip4/127.0.0.1/tcp/4001"]) peer_info.addrs.extend([b"/ip4/127.0.0.1/tcp/4001"])
message.dial.peers.append(peer_info) message.dial.peers.append(peer_info)
@ -169,7 +169,7 @@ async def test_handle_request():
message = Message() message = Message()
message.type = Type.DIAL message.type = Type.DIAL
dial_request = DialRequest() dial_request = DialRequest()
peer_info = Peer_Info() peer_info = PeerInfo()
dial_request.peers.append(peer_info) dial_request.peers.append(peer_info)
message.dial.CopyFrom(dial_request) message.dial.CopyFrom(dial_request)
@ -208,7 +208,7 @@ async def test_handle_stream():
request = Message() request = Message()
request.type = Type.DIAL request.type = Type.DIAL
dial_request = DialRequest() dial_request = DialRequest()
peer_info = Peer_Info() peer_info = PeerInfo()
peer_info.id = b"peer_id" peer_info.id = b"peer_id"
peer_info.addrs.append(b"addr1") peer_info.addrs.append(b"addr1")
dial_request.peers.append(peer_info) dial_request.peers.append(peer_info)