mirror of
https://github.com/markqvist/LXMF.git
synced 2025-02-23 00:19:57 -05:00
46 lines
1.7 KiB
Python
46 lines
1.7 KiB
Python
import time
|
|
import RNS
|
|
import RNS.vendor.umsgpack as msgpack
|
|
|
|
from .LXMF import APP_NAME
|
|
|
|
from .LXMessage import LXMessage
|
|
|
|
class LXMFDeliveryAnnounceHandler:
|
|
def __init__(self, lxmrouter):
|
|
self.aspect_filter = APP_NAME+".delivery"
|
|
self.lxmrouter = lxmrouter
|
|
|
|
def received_announce(self, destination_hash, announced_identity, app_data):
|
|
for lxmessage in self.lxmrouter.pending_outbound:
|
|
if destination_hash == lxmessage.destination_hash:
|
|
if lxmessage.method == LXMessage.DIRECT:
|
|
lxmessage.next_delivery_attempt = time.time()
|
|
|
|
while self.lxmrouter.processing_outbound:
|
|
time.sleep(0.1)
|
|
|
|
self.lxmrouter.process_outbound()
|
|
|
|
|
|
class LXMFPropagationAnnounceHandler:
|
|
def __init__(self, lxmrouter):
|
|
self.aspect_filter = APP_NAME+".propagation"
|
|
self.lxmrouter = lxmrouter
|
|
|
|
def received_announce(self, destination_hash, announced_identity, app_data):
|
|
try:
|
|
if type(app_data) == bytes:
|
|
data = msgpack.unpackb(app_data)
|
|
|
|
if self.lxmrouter.propagation_node and self.lxmrouter.autopeer:
|
|
if data[0] == True:
|
|
if RNS.Transport.hops_to(destination_hash) <= self.lxmrouter.autopeer_maxdepth:
|
|
self.lxmrouter.peer(destination_hash, data[1])
|
|
elif data[0] == False:
|
|
self.lxmrouter.unpeer(destination_hash, data[1])
|
|
|
|
except Exception as e:
|
|
RNS.log("Error while evaluating propagation node announce, ignoring announce.", RNS.LOG_DEBUG)
|
|
RNS.log("The contained exception was: "+str(e), RNS.LOG_DEBUG)
|