Git-Mirrors/LXMF
1
0
Fork 0
mirror of https://github.com/markqvist/LXMF.git synced 2024-12-26 07:39:28 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

Added ignore functionality

Browse Source
This commit is contained in:
Mark Qvist 2022-05-17 19:43:51 +02:00
parent ece55d10d6
commit b2aba3f6db
1 changed files with 17 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
LXMF/LXMF.py
View File

@ -843,6 +843,8 @@ class LXMRouter:
self.direct_links = {}
self.delivery_destinations = {}
self.ignored_list = []
self.processing_outbound = False
self.processing_inbound = False
self.processing_count = 0
@ -1136,6 +1138,10 @@ class LXMRouter:
message.transport_encrypted = False
message.transport_encryption = None
if message.source_hash in self.ignored_list:
RNS.log(str(self)+" ignored message from "+RNS.prettyhexrep(message.source_hash), RNS.LOG_DEBUG)
return False
if self.__delivery_callback != None and callable(self.__delivery_callback):
try:
self.__delivery_callback(message)
@ -1595,6 +1601,14 @@ class LXMRouter:
RNS.log("Error while removing peer "+RNS.prettyhexrep(peer_id)+". The contained exception was: "+str(e), RNS.LOG_ERROR)
def ignore_destination(self, destination_hash):
if not destination_hash in self.ignored_list:
self.ignored_list.append(destination_hash)
def unignore_destination(self, destination_hash):
if destination_hash in self.ignored_list:
self.ignored_list.remove(destination_hash)
def fail_message(self, lxmessage):
RNS.log(str(lxmessage)+" failed to send", RNS.LOG_DEBUG)
@ -1605,6 +1619,9 @@ class LXMRouter:
if lxmessage.failed_callback != None and callable(lxmessage.failed_callback):
lxmessage.failed_callback(lxmessage)
def __str__(self):
return "<LXMRouter "+RNS.hexrep(self.identity.hash, delimit=False)+">"
def process_outbound(self, sender = None):
if self.processing_outbound:
return