LBRYFoundation/lbry-sdk
1
0
Fork 0
mirror of https://github.com/LBRYFoundation/lbry-sdk.git synced 2025-08-23 09:17:23 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fix checking protocol version

Browse source
This commit is contained in:
Ben van Hartingsveldt 2024-05-21 22:49:35 +02:00
parent eb5da9511e
commit a471dcb272
No known key found for this signature in database
GPG key ID: 261AA214130CE7AB
1 changed files with 10 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
lbry/wallet/network.py
View file

@ -99,13 +99,13 @@ class ClientSession(BaseClientSession):
self._concurrency.release() self._concurrency.release()
async def ensure_server_version(self, required=None, timeout=3): async def ensure_server_version(self, required=None, timeout=3):
required = required or self.network.PROTOCOL_VERSION required = required or self.network.PROTOCOL_MAX_VERSION
response = await asyncio.wait_for( response = await asyncio.wait_for(
self.send_request('server.version', [__version__, required]), timeout=timeout self.send_request('server.version', [self.network.CLIENT_NAME, required]), timeout=timeout
) )
if tuple(int(piece) for piece in response[0].split(".")) < self.network.MINIMUM_REQUIRED: if tuple(int(piece) for piece in response[1].split(".")) >= self.network.PROTOCOL_MIN_VERSION:
raise IncompatibleWalletServerError(*self.server) return response
return response raise IncompatibleWalletServerError(*self.server)
async def keepalive_loop(self, timeout=3, max_idle=60): async def keepalive_loop(self, timeout=3, max_idle=60):
try: try:
@ -149,8 +149,11 @@ class ClientSession(BaseClientSession):
class Network: class Network:
PROTOCOL_VERSION = __version__ CLIENT_VERSION = __version__
MINIMUM_REQUIRED = (0, 65, 0) CLIENT_NAME = "LBRY SDK " + CLIENT_VERSION
PROTOCOL_MIN_VERSION = (0, 65, 0)
PROTOCOL_MAX_VERSION = __version__
def __init__(self, ledger): def __init__(self, ledger):
self.ledger = ledger self.ledger = ledger