From 7b7a7e40398c0c2abb9d7a5ceadfaf0b03fcabdf Mon Sep 17 00:00:00 2001
From: Egor Tensin <Egor.Tensin@gmail.com>
Date: Thu, 5 Mar 2020 17:56:21 +0300
Subject: StatusTracker: handle SIGTERM also

---
 vk/tracking/status_tracker.py | 33 ++++++++++++++++++++++++---------
 1 file changed, 24 insertions(+), 9 deletions(-)

(limited to 'vk/tracking/status_tracker.py')

diff --git a/vk/tracking/status_tracker.py b/vk/tracking/status_tracker.py
index b87e059..a16a34e 100644
--- a/vk/tracking/status_tracker.py
+++ b/vk/tracking/status_tracker.py
@@ -102,23 +102,38 @@ class StatusTracker:
             for user in self._filter_status_updates(users, updated_users):
                 self._notify_status_update(user)
 
+    class StopLooping(RuntimeError):
+        pass
+
+    @staticmethod
+    def _stop_looping(signo, frame):
+        raise StatusTracker.StopLooping()
+
     @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)
+    def _handle_signal(signo, handler):
+        old_handler = signal.getsignal(signo)
+        signal.signal(signo, handler)
         try:
             yield
         finally:
             signal.signal(signal.SIGINT, old_handler)
 
+    @staticmethod
+    def _handle_sigint():
+        # Python doesn't raise KeyboardInterrupt in case a real SIGINT is sent
+        # from outside, surprisingly.
+        return StatusTracker._handle_signal(signal.SIGINT,
+                                            StatusTracker._stop_looping)
+
+    @staticmethod
+    def _handle_sigterm():
+        return StatusTracker._handle_signal(signal.SIGTERM,
+                                            StatusTracker._stop_looping)
+
     def loop(self, uids):
-        with self._handle_sigint():
+        with self._handle_sigint(), self._handle_sigterm():
             try:
                 self._do_loop(uids)
-            except KeyboardInterrupt:
+            except (KeyboardInterrupt, StatusTracker.StopLooping):
                 pass
-- 
cgit v1.2.3