diff --git a/pypeman/msgstore.py b/pypeman/msgstore.py index 8d5748f..2bdaa9b 100644 --- a/pypeman/msgstore.py +++ b/pypeman/msgstore.py @@ -191,6 +191,10 @@ async def total(self): return 0 async def delete(self, id): + """ + we delete nothing here, but return what would have been deleted + (for testing) + """ return {'id': id, 'state': 'processed', 'message': None} @@ -517,7 +521,7 @@ async def delete(self, id): if not fpath.exists(): raise IndexError - with open(fpath, "rb") as f: + with fpath.open("rb") as f: msg = Message.from_json(f.read().decode('utf-8')) data_to_return = {'id': id, 'state': await self.get_message_state(id), 'message': msg}