mirror of
https://github.com/varun-r-mallya/py-libp2p.git
synced 2026-02-12 16:10:57 +00:00
Compare commits
4 Commits
dependency
...
a0ca284e8f
| Author | SHA1 | Date | |
|---|---|---|---|
| a0ca284e8f | |||
| d6cf83051e | |||
| fe761baa49 | |||
| 5de09ed8a1 |
@ -219,11 +219,25 @@ class CircuitV2Transport(ITransport):
|
||||
# Get a relay from the list of discovered relays
|
||||
relays = self.discovery.get_relays()
|
||||
if relays:
|
||||
# TODO: Implement more sophisticated relay selection
|
||||
# For now, just return the first available relay
|
||||
return relays[0]
|
||||
# Prioritize relays with active reservations
|
||||
relays_with_reservations = []
|
||||
other_relays = []
|
||||
|
||||
for relay_id in relays:
|
||||
relay_info = self.discovery.get_relay_info(relay_id)
|
||||
if relay_info and relay_info.has_reservation:
|
||||
relays_with_reservations.append(relay_id)
|
||||
else:
|
||||
other_relays.append(relay_id)
|
||||
|
||||
# Return first available relay with reservation, or fallback to others
|
||||
if relays_with_reservations:
|
||||
return relays_with_reservations[
|
||||
attempts % len(relays_with_reservations)
|
||||
]
|
||||
elif other_relays:
|
||||
return other_relays[attempts % len(other_relays)]
|
||||
|
||||
# Wait and try discovery
|
||||
await trio.sleep(1)
|
||||
attempts += 1
|
||||
|
||||
|
||||
@ -1 +0,0 @@
|
||||
update cryptographic dependencies: pycryptodome to ≥3.19.1, pynacl to ≥1.5.0, coincurve to ≥21.0.0
|
||||
@ -17,7 +17,7 @@ maintainers = [
|
||||
]
|
||||
dependencies = [
|
||||
"base58>=1.0.3",
|
||||
"coincurve>=21.0.0",
|
||||
"coincurve>=10.0.0",
|
||||
"exceptiongroup>=1.2.0; python_version < '3.11'",
|
||||
"grpcio>=1.41.0",
|
||||
"lru-dict>=1.1.6",
|
||||
@ -28,7 +28,7 @@ dependencies = [
|
||||
"protobuf>=4.25.0,<5.0.0",
|
||||
"pycryptodome>=3.9.2",
|
||||
"pymultihash>=0.8.2",
|
||||
"pynacl>=1.5.0",
|
||||
"pynacl>=1.3.0",
|
||||
"rpcudp>=3.0.0",
|
||||
"trio-typing>=0.0.4",
|
||||
"trio>=0.26.0",
|
||||
|
||||
Reference in New Issue
Block a user