Git-Mirrors/NomadNet
1
0
Fork 0
mirror of https://github.com/markqvist/NomadNet.git synced 2025-05-17 13:20:25 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Added handling for authenticated propagation nodes

Browse source
This commit is contained in:
Mark Qvist 2022-06-17 13:43:38 +02:00
parent 2354ba3412
commit 7a625d677d
2 changed files with 11 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

9
nomadnet/NomadNetworkApp.py
View file

@ -255,6 +255,9 @@ class NomadNetworkApp:
if self.enable_node:
self.message_router.enable_propagation()
# TODO: Set LXMF storage limits
RNS.log("LXMF Propagation Node started on: "+RNS.prettyhexrep(self.message_router.propagation_destination.hash))
self.node = nomadnet.Node(self)
else:
@ -352,6 +355,10 @@ class NomadNetworkApp:
return "Done, no new messages"
else:
return "Downloaded "+str(new_msgs)+" new messages"
elif self.message_router.propagation_transfer_state == LXMF.LXMRouter.PR_NO_IDENTITY_RCVD:
return "Node did not receive identification"
elif self.message_router.propagation_transfer_state == LXMF.LXMRouter.PR_NO_ACCESS:
return "Node did not allow request"
else:
return "Unknown"
@ -379,7 +386,7 @@ class NomadNetworkApp:
return self.message_router.propagation_transfer_progress
def request_lxmf_sync(self, limit = None):
if self.message_router.propagation_transfer_state == LXMF.LXMRouter.PR_IDLE or self.message_router.propagation_transfer_state == LXMF.LXMRouter.PR_COMPLETE:
if self.message_router.propagation_transfer_state == LXMF.LXMRouter.PR_IDLE or self.message_router.propagation_transfer_state >= LXMF.LXMRouter.PR_COMPLETE:
self.peer_settings["last_lxmf_sync"] = time.time()
self.save_peer_settings()
self.message_router.request_messages_from_propagation_node(self.identity, max_messages = limit)