jlpoole/LMXF-specification
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Added outbound processing trigger for pn node announces

Browse source
This commit is contained in:
Mark Qvist 2026-05-10 14:12:51 +02:00
commit a8505eade9
2 changed files with 13 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

12
LXMF/Handlers.py
View file

@ -41,6 +41,18 @@ class LXMFPropagationAnnounceHandler:
def received_announce(self, destination_hash, announced_identity, app_data, announce_packet_hash, is_path_response): def received_announce(self, destination_hash, announced_identity, app_data, announce_packet_hash, is_path_response):
try: try:
if type(app_data) == bytes: if type(app_data) == bytes:
if destination_hash == self.lxmrouter.get_outbound_propagation_node():
if pn_announce_data_is_valid(app_data):
for lxmessage in self.lxmrouter.pending_outbound:
if lxmessage.method == LXMessage.PROPAGATED:
lxmessage.next_delivery_attempt = time.time()
def outbound_trigger():
while self.lxmrouter.outbound_processing_lock.locked(): time.sleep(0.1)
self.lxmrouter.process_outbound()
threading.Thread(target=outbound_trigger, daemon=True).start()
if self.lxmrouter.propagation_node: if self.lxmrouter.propagation_node:
if pn_announce_data_is_valid(app_data): if pn_announce_data_is_valid(app_data):
data = msgpack.unpackb(app_data) data = msgpack.unpackb(app_data)

2
LXMF/_version.py
View file

@ -1 +1 @@
__version__ = "0.9.7" __version__ = "0.9.8"