Skip to content

Commit 9aa48c6

Browse files
committed
Add helper to create peers in peer pool
1 parent 7078b44 commit 9aa48c6

File tree

1 file changed

+22
-0
lines changed

1 file changed

+22
-0
lines changed

tests/trinity/core/p2p-proto/bcc/helpers.py

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,5 @@
1+
import asyncio
2+
13
from cancel_token import CancelToken
24

35
from eth.db.atomic import AtomicDB
@@ -98,3 +100,23 @@ async def get_directly_linked_peers(request, event_loop, alice_chain_db=None, bo
98100
alice_factory=alice_factory,
99101
bob_factory=bob_factory,
100102
)
103+
104+
105+
async def get_directly_linked_peers_in_peer_pools(request, event_loop, chain_db=None):
106+
alice, bob = await get_directly_linked_peers(request, event_loop, bob_chain_db=chain_db)
107+
alice_peer_pool = BCCPeerPool(alice.privkey, alice.context)
108+
bob_peer_pool = BCCPeerPool(bob.privkey, bob.context)
109+
110+
asyncio.ensure_future(alice_peer_pool.run())
111+
asyncio.ensure_future(bob_peer_pool.run())
112+
113+
def finalizer():
114+
event_loop.run_until_complete(alice_peer_pool.cancel())
115+
event_loop.run_until_complete(bob_peer_pool.cancel())
116+
117+
request.addfinalizer(finalizer)
118+
119+
alice_peer_pool._add_peer(alice, [])
120+
bob_peer_pool._add_peer(bob, [])
121+
122+
return alice, alice_peer_pool, bob, bob_peer_pool

0 commit comments

Comments
 (0)