Git-Mirrors/LXMF
1
0
Fork 0
mirror of https://github.com/markqvist/LXMF.git synced 2025-02-10 12:18:27 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

Added external processing of received messages to lxmd

Browse Source
This commit is contained in:
Mark Qvist 2022-10-22 21:07:27 +02:00
parent 2181584f69
commit 1c4928a29b
1 changed files with 25 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
LXMF/Utilities/lxmd.py
View File

@ -29,6 +29,8 @@ import RNS
import LXMF import LXMF
import argparse import argparse
import threading import threading
import subprocess
import shlex
import time import time
import os import os
@ -40,6 +42,7 @@ configpath = None
ignoredpath = None ignoredpath = None
identitypath = None identitypath = None
storagedir = None storagedir = None
lxmdir = None
targetloglevel = None targetloglevel = None
identity = None identity = None
@ -140,16 +143,27 @@ def apply_config():
exit(3) exit(3)
def lxmf_delivery(lxm): def lxmf_delivery(lxm):
global active_configuration global active_configuration, lxmdir
RNS.log("Received "+str(lxm), RNS.LOG_DEBUG)
try:
written_path = lxm.write_to_directory(lxmdir)
RNS.log("Received "+str(lxm)+" written to "+str(written_path), RNS.LOG_DEBUG)
if active_configuration["on_inbound"]: if active_configuration["on_inbound"]:
RNS.log("Calling external program to handle message", RNS.LOG_DEBUG) RNS.log("Calling external program to handle message", RNS.LOG_DEBUG)
command = active_configuration["on_inbound"]
processing_command = command+" \""+written_path+"\""
return_code = subprocess.call(shlex.split(processing_command), stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL)
else: else:
RNS.log("No action defined for inbound messages, ignoring", RNS.LOG_EXTREME) RNS.log("No action defined for inbound messages, ignoring", RNS.LOG_DEBUG)
except Exception as e:
RNS.log("Error occurred while processing received message "+str(lxm)+". The contained exception was: "+str(e), RNS.LOG_ERROR)
def program_setup(configdir = None, rnsconfigdir = None, run_pn = False, on_inbound = None, verbosity = 0, quietness = 0, service = False): def program_setup(configdir = None, rnsconfigdir = None, run_pn = False, on_inbound = None, verbosity = 0, quietness = 0, service = False):
global configpath, ignoredpath, identitypath, storagedir global configpath, ignoredpath, identitypath, storagedir, lxmdir
global lxmd_config, active_configuration, targetloglevel global lxmd_config, active_configuration, targetloglevel
global message_router, lxmf_destination global message_router, lxmf_destination
@ -174,10 +188,14 @@ def program_setup(configdir = None, rnsconfigdir = None, run_pn = False, on_inbo
ignoredpath = configdir+"/ignored" ignoredpath = configdir+"/ignored"
identitypath = configdir+"/identity" identitypath = configdir+"/identity"
storagedir = configdir+"/storage" storagedir = configdir+"/storage"
lxmdir = storagedir+"/messages"
if not os.path.isdir(storagedir): if not os.path.isdir(storagedir):
os.makedirs(storagedir) os.makedirs(storagedir)
if not os.path.isdir(lxmdir):
os.makedirs(lxmdir)
if os.path.isfile(configpath): if os.path.isfile(configpath):
try: try:
lxmd_config = ConfigObj(configpath) lxmd_config = ConfigObj(configpath)