diff --git a/boswatch/inputSource/lineInInput.py b/boswatch/inputSource/lineInInput.py index 5556d4c..b6b182d 100644 --- a/boswatch/inputSource/lineInInput.py +++ b/boswatch/inputSource/lineInInput.py @@ -48,6 +48,11 @@ class LineInInput(InputBase): if not lineInProc.isRunning: logging.warning("asla was down - try to restart") lineInProc.start() + + if lineInProc.isRunning: + logging.info("rtl_fm is back up - restarting multimon...") + mmProc.setStdin(lineInProc.stdout) + mmProc.start() elif not mmProc.isRunning: logging.warning("multimon was down - try to restart") mmProc.start() diff --git a/boswatch/inputSource/pulseaudioInput.py b/boswatch/inputSource/pulseaudioInput.py index 3b9b42d..7a4c104 100644 --- a/boswatch/inputSource/pulseaudioInput.py +++ b/boswatch/inputSource/pulseaudioInput.py @@ -47,6 +47,11 @@ class PulseAudioInput(InputBase): if not PulseAudioProc.isRunning: logging.warning("PulseAudio was down - try to restart") PulseAudioProc.start() + + if PulseAudioProc.isRunning: + logging.info("rtl_fm is back up - restarting multimon...") + mmProc.setStdin(PulseAudioProc.stdout) + mmProc.start() elif not mmProc.isRunning: logging.warning("multimon was down - try to restart") mmProc.start() diff --git a/plugin/http.py b/plugin/http.py index 1af3035..fa14036 100644 --- a/plugin/http.py +++ b/plugin/http.py @@ -72,7 +72,7 @@ class BoswatchPlugin(PluginBase): loop = asyncio.get_event_loop() - future = asyncio.ensure_future(self.asyncRequests(urls)) + future = asyncio.ensure_future(self._asyncRequests(urls)) loop.run_until_complete(future) async def _asyncRequests(self, urls): diff --git a/requirements.txt b/requirements.txt index 5e215ff..0cca07d 100644 --- a/requirements.txt +++ b/requirements.txt @@ -8,6 +8,7 @@ mkdocs # for develope only pytest pytest-cov +flake8==4.0.1 pytest-flake8 pytest-flakes pytest-randomly