diff options
author | Egor Tensin <Egor.Tensin@gmail.com> | 2019-09-09 20:05:36 +0300 |
---|---|---|
committer | Egor Tensin <Egor.Tensin@gmail.com> | 2019-09-09 20:05:36 +0300 |
commit | a6a01fd6355dde9ccade53cda4a946960d673af1 (patch) | |
tree | 7f2112de22c8021a46ffe780a51d5665124060b0 /vk/tracking/status_tracker.py | |
parent | Travis: run more scripts (diff) | |
download | vk-scripts-a6a01fd6355dde9ccade53cda4a946960d673af1.tar.gz vk-scripts-a6a01fd6355dde9ccade53cda4a946960d673af1.zip |
handle SIGINT in StatusTracker properly
Diffstat (limited to '')
-rw-r--r-- | vk/tracking/status_tracker.py | 25 |
1 files changed, 21 insertions, 4 deletions
diff --git a/vk/tracking/status_tracker.py b/vk/tracking/status_tracker.py index 8b90d1c..30e0f97 100644 --- a/vk/tracking/status_tracker.py +++ b/vk/tracking/status_tracker.py @@ -4,7 +4,9 @@ # Distributed under the MIT License. from collections.abc import Callable +import contextlib import time +import signal import vk.error from vk.user import UserField @@ -98,8 +100,23 @@ class StatusTracker: for user in self._filter_status_updates(users, updated_users): self._notify_status_update(user) - def loop(self, uids): + @staticmethod + @contextlib.contextmanager + def _handle_sigint(): + # Python doesn't raise KeyboardInterrupt in case a real SIGINT is sent + # from outside, surprisingly. + def _raise_keyboard_interrupt(signum, frame): + raise KeyboardInterrupt() + old_handler = signal.getsignal(signal.SIGINT) + signal.signal(signal.SIGINT, _raise_keyboard_interrupt) try: - self._do_loop(uids) - except KeyboardInterrupt: - pass + yield + finally: + signal.signal(signal.SIGINT, old_handler) + + def loop(self, uids): + with self._handle_sigint(): + try: + self._do_loop(uids) + except KeyboardInterrupt: + pass |