[#345] Rewritten sun plugin.

Closes: #345

platypush/plugins/sun/__init__.py

@@ -1,9 +1,8 @@
 import datetime
-import time
+from typing import Dict, Optional
-from typing import Optional
 
 import requests
-from dateutil.tz import gettz, tzutc
+from dateutil.tz import gettz
 
 from platypush.message.event.sun import SunriseEvent, SunsetEvent
 from platypush.plugins import RunnablePlugin, action
@@ -16,6 +15,7 @@ class SunPlugin(RunnablePlugin):
     """
 
     _base_url = 'https://api.sunrise-sunset.org/json'
+    _schema = SunEventsSchema()
     _attr_to_event_class = {
         'sunrise': SunriseEvent,
         'sunset': SunsetEvent,
@@ -32,9 +32,10 @@ class SunPlugin(RunnablePlugin):
 
     def main(self):
         while not self.should_stop():
-            # noinspection PyUnresolvedReferences
+            next_events = self._get_events()
-            next_events = self.get_events().output
+            next_event = next(
-            next_events = sorted(
+                iter(
+                    sorted(
                         [
                             event_class(
                                 latitude=self.latitude,
@@ -46,52 +47,39 @@ class SunPlugin(RunnablePlugin):
                         ],
                         key=lambda t: t.time,
                     )
+                ),
+                None,
+            )
 
-            for event in next_events:
+            assert next_event is not None, 'No next event found'
-                # noinspection PyTypeChecker
+            wait_secs = max(
-                dt = datetime.datetime.fromisoformat(event.time)
+                0, (next_event.time - datetime.datetime.now(tz=gettz())).seconds
-                while (not self.should_stop()) and (
+            )
-                    dt > datetime.datetime.now(tz=gettz())
+            self.wait_stop(wait_secs)
-                ):
-                    time.sleep(1)
 
-                if dt <= datetime.datetime.now(tz=gettz()):
+            if not self.should_stop():
-                    self.bus.post(event)
+                self._bus.post(next_event)
+                self.wait_stop(2)
 
     @staticmethod
     def _convert_time(t: str) -> datetime.datetime:
-        now = datetime.datetime.now().replace(
+        now = datetime.datetime.now(datetime.UTC).replace(microsecond=0)
-            tzinfo=gettz()
+        dt = datetime.datetime.strptime(
-        )  # lgtm [py/call-to-non-callable]
+            f'{now.year}-{now.month:02d}-{now.day:02d} {t}',
-        dt = datetime.datetime.strptime(t, '%H:%M:%S %p')
+            '%Y-%m-%d %I:%M:%S %p',
-        dt = datetime.datetime(
+        ).replace(tzinfo=datetime.UTC)
-            year=now.year,
-            month=now.month,
-            day=now.day,
-            hour=dt.hour,
-            minute=dt.minute,
-            second=dt.second,
-            tzinfo=tzutc(),
-        )
 
         if dt < now:
             dt += datetime.timedelta(days=1)
-        return datetime.datetime.fromtimestamp(dt.timestamp(), tz=gettz())
+        return dt
 
-    @action
+    def _get_events(
-    def get_events(
         self, latitude: Optional[float] = None, longitude: Optional[float] = None
-    ) -> dict:
+    ) -> Dict[str, datetime.datetime]:
-        """
-        Return the next sun events.
-
-        :param latitude: Default latitude override.
-        :param longitude: Default longitude override.
-        :return: .. schema:: sun.SunEventsSchema
-        """
         response = (
             requests.get(
                 self._base_url,
+                timeout=10,
                 params={
                     'lat': latitude or self.latitude,
                     'lng': longitude or self.longitude,
@@ -101,11 +89,24 @@ class SunPlugin(RunnablePlugin):
             .get('results', {})
         )
 
-        schema = SunEventsSchema()
+        return {
-        return schema.dump(
-            {
             attr: self._convert_time(t)
             for attr, t in response.items()
-                if attr in schema.declared_fields
+            if attr in self._schema.declared_fields
         }
+
+    @action
+    def get_events(
+        self, latitude: Optional[float] = None, longitude: Optional[float] = None
+    ) -> dict:
+        """
+        Return the next sun events.
+
+        :param latitude: Override the default latitude.
+        :param longitude: Override the default longitude.
+        :return: .. schema:: sun.SunEventsSchema
+        """
+        schema = SunEventsSchema()
+        return dict(
+            schema.dump(self._get_events(latitude=latitude, longitude=longitude))
         )