mirror of
https://github.com/meshcore-dev/meshcore_py.git
synced 2026-06-11 11:56:18 +00:00
revert ensure_contacts and increase timeout in get_contacts
This commit is contained in:
@@ -4,7 +4,7 @@ build-backend = "hatchling.build"
|
|||||||
|
|
||||||
[project]
|
[project]
|
||||||
name = "meshcore"
|
name = "meshcore"
|
||||||
version = "2.1.11"
|
version = "2.1.12"
|
||||||
authors = [
|
authors = [
|
||||||
{ name="Florent de Lamotte", email="florent@frizoncorrea.fr" },
|
{ name="Florent de Lamotte", email="florent@frizoncorrea.fr" },
|
||||||
{ name="Alex Wolden", email="awolden@gmail.com" },
|
{ name="Alex Wolden", email="awolden@gmail.com" },
|
||||||
|
|||||||
@@ -13,7 +13,7 @@ class ContactCommands(CommandHandlerBase):
|
|||||||
data = b"\x04"
|
data = b"\x04"
|
||||||
if lastmod > 0:
|
if lastmod > 0:
|
||||||
data = data + lastmod.to_bytes(4, "little")
|
data = data + lastmod.to_bytes(4, "little")
|
||||||
return await self.send(data, [EventType.CONTACTS, EventType.ERROR])
|
return await self.send(data, [EventType.CONTACTS, EventType.ERROR], timeout=30)
|
||||||
|
|
||||||
async def reset_path(self, key: DestinationType) -> Event:
|
async def reset_path(self, key: DestinationType) -> Event:
|
||||||
key_bytes = _validate_destination(key, prefix_length=32)
|
key_bytes = _validate_destination(key, prefix_length=32)
|
||||||
|
|||||||
@@ -464,6 +464,5 @@ class MeshCore:
|
|||||||
"""Ensure contacts are fetched"""
|
"""Ensure contacts are fetched"""
|
||||||
if not self._contacts or (follow and self._contacts_dirty):
|
if not self._contacts or (follow and self._contacts_dirty):
|
||||||
await self.commands.get_contacts(lastmod=self._lastmod)
|
await self.commands.get_contacts(lastmod=self._lastmod)
|
||||||
await self.wait_for_event(EventType.CONTACTS, timeout=30) # contact list can be huge
|
|
||||||
return True
|
return True
|
||||||
return False
|
return False
|
||||||
|
|||||||
Reference in New Issue
Block a user