mirror of
https://github.com/varun-r-mallya/py-libp2p.git
synced 2026-02-12 16:10:57 +00:00
removed redudant check in seen seqnos and peers and added test cases of handle iwant and handle ihave
This commit is contained in:
@ -787,7 +787,6 @@ class GossipSub(IPubsubRouter, Service):
|
|||||||
parse_message_id_safe(msg_id)
|
parse_message_id_safe(msg_id)
|
||||||
for msg_id in ihave_msg.messageIDs
|
for msg_id in ihave_msg.messageIDs
|
||||||
if msg_id not in seen_seqnos_and_peers
|
if msg_id not in seen_seqnos_and_peers
|
||||||
if msg_id not in str(seen_seqnos_and_peers)
|
|
||||||
]
|
]
|
||||||
|
|
||||||
# Request messages with IWANT message
|
# Request messages with IWANT message
|
||||||
|
|||||||
@ -1,4 +1,8 @@
|
|||||||
import random
|
import random
|
||||||
|
from unittest.mock import (
|
||||||
|
AsyncMock,
|
||||||
|
MagicMock,
|
||||||
|
)
|
||||||
|
|
||||||
import pytest
|
import pytest
|
||||||
import trio
|
import trio
|
||||||
@ -7,6 +11,9 @@ from libp2p.pubsub.gossipsub import (
|
|||||||
PROTOCOL_ID,
|
PROTOCOL_ID,
|
||||||
GossipSub,
|
GossipSub,
|
||||||
)
|
)
|
||||||
|
from libp2p.pubsub.pb import (
|
||||||
|
rpc_pb2,
|
||||||
|
)
|
||||||
from libp2p.tools.utils import (
|
from libp2p.tools.utils import (
|
||||||
connect,
|
connect,
|
||||||
)
|
)
|
||||||
@ -754,3 +761,93 @@ async def test_single_host():
|
|||||||
assert connected_peers == 0, (
|
assert connected_peers == 0, (
|
||||||
f"Single host has {connected_peers} connections, expected 0"
|
f"Single host has {connected_peers} connections, expected 0"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.mark.trio
|
||||||
|
async def test_handle_ihave(monkeypatch):
|
||||||
|
async with PubsubFactory.create_batch_with_gossipsub(2) as pubsubs_gsub:
|
||||||
|
gossipsub_routers = []
|
||||||
|
for pubsub in pubsubs_gsub:
|
||||||
|
if isinstance(pubsub.router, GossipSub):
|
||||||
|
gossipsub_routers.append(pubsub.router)
|
||||||
|
gossipsubs = tuple(gossipsub_routers)
|
||||||
|
|
||||||
|
index_alice = 0
|
||||||
|
index_bob = 1
|
||||||
|
id_bob = pubsubs_gsub[index_bob].my_id
|
||||||
|
|
||||||
|
# Connect Alice and Bob
|
||||||
|
await connect(pubsubs_gsub[index_alice].host, pubsubs_gsub[index_bob].host)
|
||||||
|
await trio.sleep(0.1) # Allow connections to establish
|
||||||
|
|
||||||
|
# Mock emit_iwant to capture calls
|
||||||
|
mock_emit_iwant = AsyncMock()
|
||||||
|
monkeypatch.setattr(gossipsubs[index_alice], "emit_iwant", mock_emit_iwant)
|
||||||
|
|
||||||
|
# Create a test message ID as a string representation of a (seqno, from) tuple
|
||||||
|
test_seqno = b"1234"
|
||||||
|
test_from = id_bob.to_bytes()
|
||||||
|
test_msg_id = f"(b'{test_seqno.hex()}', b'{test_from.hex()}')"
|
||||||
|
ihave_msg = rpc_pb2.ControlIHave(messageIDs=[test_msg_id])
|
||||||
|
|
||||||
|
# Mock seen_messages.cache to avoid false positives
|
||||||
|
monkeypatch.setattr(pubsubs_gsub[index_alice].seen_messages, "cache", {})
|
||||||
|
|
||||||
|
# Simulate Bob sending IHAVE to Alice
|
||||||
|
await gossipsubs[index_alice].handle_ihave(ihave_msg, id_bob)
|
||||||
|
|
||||||
|
# Check if emit_iwant was called with the correct message ID
|
||||||
|
mock_emit_iwant.assert_called_once()
|
||||||
|
called_args = mock_emit_iwant.call_args[0]
|
||||||
|
assert called_args[0] == [test_msg_id] # Expected message IDs
|
||||||
|
assert called_args[1] == id_bob # Sender peer ID
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.mark.trio
|
||||||
|
async def test_handle_iwant(monkeypatch):
|
||||||
|
async with PubsubFactory.create_batch_with_gossipsub(2) as pubsubs_gsub:
|
||||||
|
gossipsub_routers = []
|
||||||
|
for pubsub in pubsubs_gsub:
|
||||||
|
if isinstance(pubsub.router, GossipSub):
|
||||||
|
gossipsub_routers.append(pubsub.router)
|
||||||
|
gossipsubs = tuple(gossipsub_routers)
|
||||||
|
|
||||||
|
index_alice = 0
|
||||||
|
index_bob = 1
|
||||||
|
id_alice = pubsubs_gsub[index_alice].my_id
|
||||||
|
|
||||||
|
# Connect Alice and Bob
|
||||||
|
await connect(pubsubs_gsub[index_alice].host, pubsubs_gsub[index_bob].host)
|
||||||
|
await trio.sleep(0.1) # Allow connections to establish
|
||||||
|
|
||||||
|
# Mock mcache.get to return a message
|
||||||
|
test_message = rpc_pb2.Message(data=b"test_data")
|
||||||
|
test_seqno = b"1234"
|
||||||
|
test_from = id_alice.to_bytes()
|
||||||
|
|
||||||
|
# ✅ Correct: use raw tuple and str() to serialize, no hex()
|
||||||
|
test_msg_id = str((test_seqno, test_from))
|
||||||
|
|
||||||
|
mock_mcache_get = MagicMock(return_value=test_message)
|
||||||
|
monkeypatch.setattr(gossipsubs[index_bob].mcache, "get", mock_mcache_get)
|
||||||
|
|
||||||
|
# Mock write_msg to capture the sent packet
|
||||||
|
mock_write_msg = AsyncMock()
|
||||||
|
monkeypatch.setattr(gossipsubs[index_bob].pubsub, "write_msg", mock_write_msg)
|
||||||
|
|
||||||
|
# Simulate Alice sending IWANT to Bob
|
||||||
|
iwant_msg = rpc_pb2.ControlIWant(messageIDs=[test_msg_id])
|
||||||
|
await gossipsubs[index_bob].handle_iwant(iwant_msg, id_alice)
|
||||||
|
|
||||||
|
# Check if write_msg was called with the correct packet
|
||||||
|
mock_write_msg.assert_called_once()
|
||||||
|
packet = mock_write_msg.call_args[0][1]
|
||||||
|
assert isinstance(packet, rpc_pb2.RPC)
|
||||||
|
assert len(packet.publish) == 1
|
||||||
|
assert packet.publish[0] == test_message
|
||||||
|
|
||||||
|
# Verify that mcache.get was called with the correct parsed message ID
|
||||||
|
mock_mcache_get.assert_called_once()
|
||||||
|
called_msg_id = mock_mcache_get.call_args[0][0]
|
||||||
|
assert isinstance(called_msg_id, tuple)
|
||||||
|
assert called_msg_id == (test_seqno, test_from)
|
||||||
|
|||||||
Reference in New Issue
Block a user