Git-Mirrors/lxmf_messageboard
1
0
Fork 0
mirror of https://github.com/markqvist/lxmf_messageboard.git synced 2025-02-22 07:30:01 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

Added Message Board pruning

Browse Source 
* Script will now prune the message board to 'max_messages' to ensure the board doesn't get too long, default set to 20
* adjusted indents to match in all functions
This commit is contained in:
chengtripp 2023-02-01 10:29:58 +00:00 committed by GitHub
parent c343ac170a
commit 6b9418a917
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 37 additions and 31 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

68
messageboard.py
View File

@ -9,11 +9,11 @@ display_name = "SolarExpress Message Board"
configdir = os.getcwd() configdir = os.getcwd()
identitypath = configdir+"/storage/identity" identitypath = configdir+"/storage/identity"
redis_db = 2 redis_db = 2
max_messages = 20
r = redis.Redis(db=redis_db, decode_responses=True) r = redis.Redis(db=redis_db, decode_responses=True)
def setup_lxmf(): def setup_lxmf():
if os.path.isfile(identitypath): if os.path.isfile(identitypath):
identity = RNS.Identity.from_file(identitypath) identity = RNS.Identity.from_file(identitypath)
RNS.log('Loaded identity from file', RNS.LOG_INFO) RNS.log('Loaded identity from file', RNS.LOG_INFO)
@ -57,43 +57,43 @@ def announce_now(lxmf_destination):
lxmf_destination.announce() lxmf_destination.announce()
def send_message(destination_hash, message_content): def send_message(destination_hash, message_content):
try: try:
# Make a binary destination hash from a hexadecimal string # Make a binary destination hash from a hexadecimal string
destination_hash = bytes.fromhex(destination_hash) destination_hash = bytes.fromhex(destination_hash)
except Exception as e: except Exception as e:
RNS.log("Invalid destination hash", RNS.LOG_ERROR) RNS.log("Invalid destination hash", RNS.LOG_ERROR)
return return
# Check that size is correct # Check that size is correct
if not len(destination_hash) == RNS.Reticulum.TRUNCATED_HASHLENGTH//8: if not len(destination_hash) == RNS.Reticulum.TRUNCATED_HASHLENGTH//8:
RNS.log("Invalid destination hash length", RNS.LOG_ERROR) RNS.log("Invalid destination hash length", RNS.LOG_ERROR)
else:
# Length of address was correct, let's try to recall the
# corresponding Identity
destination_identity = RNS.Identity.recall(destination_hash)
if destination_identity == None:
# No path/identity known, we'll have to abort or request one
RNS.log("Could not recall an Identity for the requested address. You have probably never received an announce from it. Try requesting a path from the network first. In fact, let's do this now :)", RNS.LOG_ERROR)
RNS.Transport.request_path(destination_hash)
RNS.log("OK, a path was requested. If the network knows a path, you will receive an announce with the Identity data shortly.", RNS.LOG_INFO)
else: else:
# We know the identity for the destination hash, let's # Length of address was correct, let's try to recall the
# reconstruct a destination object. # corresponding Identity
lxmf_destination = RNS.Destination(destination_identity, RNS.Destination.OUT, RNS.Destination.SINGLE, "lxmf", "delivery") destination_identity = RNS.Identity.recall(destination_hash)
# Create a new message object if destination_identity == None:
lxm = LXMF.LXMessage(lxmf_destination, local_lxmf_destination, message_content, title="Reply", desired_method=LXMF.LXMessage.DIRECT) # No path/identity known, we'll have to abort or request one
RNS.log("Could not recall an Identity for the requested address. You have probably never received an announce from it. Try requesting a path from the network first. In fact, let's do this now :)", RNS.LOG_ERROR)
RNS.Transport.request_path(destination_hash)
RNS.log("OK, a path was requested. If the network knows a path, you will receive an announce with the Identity data shortly.", RNS.LOG_INFO)
# You can optionally tell LXMF to try to send the message else:
# as a propagated message if a direct link fails # We know the identity for the destination hash, let's
lxm.try_propagation_on_fail = True # reconstruct a destination object.
lxmf_destination = RNS.Destination(destination_identity, RNS.Destination.OUT, RNS.Destination.SINGLE, "lxmf", "delivery")
# Send it # Create a new message object
message_router.handle_outbound(lxm) lxm = LXMF.LXMessage(lxmf_destination, local_lxmf_destination, message_content, title="Reply", desired_method=LXMF.LXMessage.DIRECT)
# You can optionally tell LXMF to try to send the message
# as a propagated message if a direct link fails
lxm.try_propagation_on_fail = True
# Send it
message_router.handle_outbound(lxm)
def announce_check(): def announce_check():
if r.exists('announce'): if r.exists('announce'):
@ -104,6 +104,9 @@ def announce_check():
announce_now(local_lxmf_destination) announce_now(local_lxmf_destination)
RNS.log('Announcement sent, expr set 1800 seconds', RNS.LOG_INFO) RNS.log('Announcement sent, expr set 1800 seconds', RNS.LOG_INFO)
def prune_messageboard(max_messages):
RNS.log('Pruning message board', RNS.LOG_DEBUG)
r.ltrim('message_board_general', 0, max_messages -1)
# Start Reticulum and print out all the debug messages # Start Reticulum and print out all the debug messages
reticulum = RNS.Reticulum(loglevel=RNS.LOG_VERBOSE) reticulum = RNS.Reticulum(loglevel=RNS.LOG_VERBOSE)
@ -142,5 +145,8 @@ while True:
# Check whether we need to make another announcement # Check whether we need to make another announcement
announce_check() announce_check()
# Keep the message board trim
prune_messageboard(max_messages)
#Sleep #Sleep
time.sleep(10) time.sleep(10)