varun-r-mallya/py-libp2p
1
0
Fork 0
mirror of https://github.com/varun-r-mallya/py-libp2p.git synced 2026-02-12 16:10:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

Commented out the bool variable from env_to_send_in_RPC() at places

Browse Source
This commit is contained in:
lla-dane
2025-08-23 15:52:43 +05:30
parent 15f4a399ec
commit 091ac082b9
4 changed files with 12 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
libp2p/kad_dht/kad_dht.py
View File

@ -323,7 +323,7 @@ class KadDHT(Service):
) )
# Create sender_signed_peer_record # Create sender_signed_peer_record
envelope_bytes, bool = env_to_send_in_RPC(self.host) envelope_bytes, _ = env_to_send_in_RPC(self.host)
response.senderRecord = envelope_bytes response.senderRecord = envelope_bytes
# Serialize and send response # Serialize and send response
@ -394,7 +394,7 @@ class KadDHT(Service):
response.key = key response.key = key
# Add sender's signed-peer-record # Add sender's signed-peer-record
envelope_bytes, bool = env_to_send_in_RPC(self.host) envelope_bytes, _ = env_to_send_in_RPC(self.host)
response.senderRecord = envelope_bytes response.senderRecord = envelope_bytes
response_bytes = response.SerializeToString() response_bytes = response.SerializeToString()
@ -428,7 +428,7 @@ class KadDHT(Service):
response.key = key response.key = key
# Create sender_signed_peer_record for the response # Create sender_signed_peer_record for the response
envelope_bytes, bool = env_to_send_in_RPC(self.host) envelope_bytes, _ = env_to_send_in_RPC(self.host)
response.senderRecord = envelope_bytes response.senderRecord = envelope_bytes
# Add provider information to response # Add provider information to response
@ -525,7 +525,7 @@ class KadDHT(Service):
response.record.timeReceived = str(time.time()) response.record.timeReceived = str(time.time())
# Create sender_signed_peer_record # Create sender_signed_peer_record
envelope_bytes, bool = env_to_send_in_RPC(self.host) envelope_bytes, _ = env_to_send_in_RPC(self.host)
response.senderRecord = envelope_bytes response.senderRecord = envelope_bytes
# Serialize and send response # Serialize and send response
@ -542,7 +542,7 @@ class KadDHT(Service):
response.key = key response.key = key
# Create sender_signed_peer_record for the response # Create sender_signed_peer_record for the response
envelope_bytes, bool = env_to_send_in_RPC(self.host) envelope_bytes, _ = env_to_send_in_RPC(self.host)
response.senderRecord = envelope_bytes response.senderRecord = envelope_bytes
# Add closest peers to key # Add closest peers to key
@ -626,7 +626,7 @@ class KadDHT(Service):
response.key = key response.key = key
# Create sender_signed_peer_record for the response # Create sender_signed_peer_record for the response
envelope_bytes, bool = env_to_send_in_RPC(self.host) envelope_bytes, _ = env_to_send_in_RPC(self.host)
response.senderRecord = envelope_bytes response.senderRecord = envelope_bytes
# Serialize and send response # Serialize and send response

4
libp2p/kad_dht/peer_routing.py
View File

@ -259,7 +259,7 @@ class PeerRouting(IPeerRouting):
find_node_msg.key = target_key # Set target key directly as bytes find_node_msg.key = target_key # Set target key directly as bytes
# Create sender_signed_peer_record # Create sender_signed_peer_record
envelope_bytes, bool = env_to_send_in_RPC(self.host) envelope_bytes, _ = env_to_send_in_RPC(self.host)
find_node_msg.senderRecord = envelope_bytes find_node_msg.senderRecord = envelope_bytes
# Serialize and send the protobuf message with varint length prefix # Serialize and send the protobuf message with varint length prefix
@ -393,7 +393,7 @@ class PeerRouting(IPeerRouting):
response.type = Message.MessageType.FIND_NODE response.type = Message.MessageType.FIND_NODE
# Create sender_signed_peer_record for the response # Create sender_signed_peer_record for the response
envelope_bytes, bool = env_to_send_in_RPC(self.host) envelope_bytes, _ = env_to_send_in_RPC(self.host)
response.senderRecord = envelope_bytes response.senderRecord = envelope_bytes
# Add peer information to response # Add peer information to response

4
libp2p/kad_dht/provider_store.py
View File

@ -242,7 +242,7 @@ class ProviderStore:
message.key = key message.key = key
# Create sender's signed-peer-record # Create sender's signed-peer-record
envelope_bytes, bool = env_to_send_in_RPC(self.host) envelope_bytes, _ = env_to_send_in_RPC(self.host)
message.senderRecord = envelope_bytes message.senderRecord = envelope_bytes
# Add our provider info # Add our provider info
@ -394,7 +394,7 @@ class ProviderStore:
message.key = key message.key = key
# Create sender's signed-peer-record # Create sender's signed-peer-record
envelope_bytes, bool = env_to_send_in_RPC(self.host) envelope_bytes, _ = env_to_send_in_RPC(self.host)
message.senderRecord = envelope_bytes message.senderRecord = envelope_bytes
# Serialize and send the message # Serialize and send the message

4
libp2p/kad_dht/value_store.py
View File

@ -112,7 +112,7 @@ class ValueStore:
message.type = Message.MessageType.PUT_VALUE message.type = Message.MessageType.PUT_VALUE
# Create sender's signed-peer-record # Create sender's signed-peer-record
envelope_bytes, bool = env_to_send_in_RPC(self.host) envelope_bytes, _ = env_to_send_in_RPC(self.host)
message.senderRecord = envelope_bytes message.senderRecord = envelope_bytes
# Set message fields # Set message fields
@ -243,7 +243,7 @@ class ValueStore:
message.key = key message.key = key
# Create sender's signed-peer-record # Create sender's signed-peer-record
envelope_bytes, bool = env_to_send_in_RPC(self.host) envelope_bytes, _ = env_to_send_in_RPC(self.host)
message.senderRecord = envelope_bytes message.senderRecord = envelope_bytes
# Serialize and send the protobuf message # Serialize and send the protobuf message