lineparser: Log after saving is done.
This will make end to end tests easier as we can easily wait until saving is done.
This commit is contained in:
parent
8d5b6b2dad
commit
e26c499bd6
@ -78,11 +78,14 @@ class BaseLineParser(QObject):
|
|||||||
"""
|
"""
|
||||||
if self._configdir is None:
|
if self._configdir is None:
|
||||||
return False
|
return False
|
||||||
log.destroy.debug("Saving to {}".format(self._configfile))
|
|
||||||
if not os.path.exists(self._configdir):
|
if not os.path.exists(self._configdir):
|
||||||
os.makedirs(self._configdir, 0o755)
|
os.makedirs(self._configdir, 0o755)
|
||||||
return True
|
return True
|
||||||
|
|
||||||
|
def _after_save(self):
|
||||||
|
"""Log a message after saving is done."""
|
||||||
|
log.destroy.debug("Saved to {}".format(self._configfile))
|
||||||
|
|
||||||
@contextlib.contextmanager
|
@contextlib.contextmanager
|
||||||
def _open(self, mode):
|
def _open(self, mode):
|
||||||
"""Open self._configfile for reading.
|
"""Open self._configfile for reading.
|
||||||
@ -178,6 +181,7 @@ class AppendLineParser(BaseLineParser):
|
|||||||
with self._open('a') as f:
|
with self._open('a') as f:
|
||||||
self._write(f, self.new_data)
|
self._write(f, self.new_data)
|
||||||
self.new_data = []
|
self.new_data = []
|
||||||
|
self._after_save()
|
||||||
|
|
||||||
|
|
||||||
class LineParser(BaseLineParser):
|
class LineParser(BaseLineParser):
|
||||||
@ -231,6 +235,7 @@ class LineParser(BaseLineParser):
|
|||||||
self._write(f, self.data)
|
self._write(f, self.data)
|
||||||
finally:
|
finally:
|
||||||
self._opened = False
|
self._opened = False
|
||||||
|
self._after_save()
|
||||||
|
|
||||||
|
|
||||||
class LimitLineParser(LineParser):
|
class LimitLineParser(LineParser):
|
||||||
@ -283,3 +288,4 @@ class LimitLineParser(LineParser):
|
|||||||
assert self._configfile is not None
|
assert self._configfile is not None
|
||||||
with qtutils.savefile_open(self._configfile, self._binary) as f:
|
with qtutils.savefile_open(self._configfile, self._binary) as f:
|
||||||
self._write(f, self.data[-limit:])
|
self._write(f, self.data[-limit:])
|
||||||
|
self._after_save()
|
||||||
|
Loading…
Reference in New Issue
Block a user