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

Fixed missing checks for file corruption

Browse Source
This commit is contained in:
Mark Qvist 2025-01-14 21:32:10 +01:00
parent 2d175a331f
commit d97c4f292e
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
LXMF/LXMRouter.py
View File

@ -145,6 +145,9 @@ class LXMRouter:
data = locally_delivered_file.read() data = locally_delivered_file.read()
locally_delivered_file.close() locally_delivered_file.close()
self.locally_delivered_transient_ids = msgpack.unpackb(data) self.locally_delivered_transient_ids = msgpack.unpackb(data)
if not type(self.locally_delivered_transient_ids) == dict:
RNS.log("Invalid data format for loaded locally delivered transient IDs, recreating...", RNS.LOG_ERROR)
self.locally_delivered_transient_ids = {}
except Exception as e: except Exception as e:
RNS.log("Could not load locally delivered message ID cache from storage. The contained exception was: "+str(e), RNS.LOG_ERROR) RNS.log("Could not load locally delivered message ID cache from storage. The contained exception was: "+str(e), RNS.LOG_ERROR)
@ -156,6 +159,10 @@ class LXMRouter:
data = locally_processed_file.read() data = locally_processed_file.read()
locally_processed_file.close() locally_processed_file.close()
self.locally_processed_transient_ids = msgpack.unpackb(data) self.locally_processed_transient_ids = msgpack.unpackb(data)
if not type(self.locally_processed_transient_ids) == dict:
RNS.log("Invalid data format for loaded locally processed transient IDs, recreating...", RNS.LOG_ERROR)
self.locally_processed_transient_ids = {}
except Exception as e: except Exception as e:
RNS.log("Could not load locally processed message ID cache from storage. The contained exception was: "+str(e), RNS.LOG_ERROR) RNS.log("Could not load locally processed message ID cache from storage. The contained exception was: "+str(e), RNS.LOG_ERROR)
@ -175,6 +182,9 @@ class LXMRouter:
with open(self.storagepath+"/outbound_stamp_costs", "rb") as outbound_stamp_cost_file: with open(self.storagepath+"/outbound_stamp_costs", "rb") as outbound_stamp_cost_file:
data = outbound_stamp_cost_file.read() data = outbound_stamp_cost_file.read()
self.outbound_stamp_costs = msgpack.unpackb(data) self.outbound_stamp_costs = msgpack.unpackb(data)
if not type(self.outbound_stamp_costs) == dict:
RNS.log("Invalid data format for loaded outbound stamp costs, recreating...", RNS.LOG_ERROR)
self.outbound_stamp_costs = {}
self.clean_outbound_stamp_costs() self.clean_outbound_stamp_costs()
self.save_outbound_stamp_costs() self.save_outbound_stamp_costs()