logging: add more logging for when event handlers raise exceptions

Author: sumnerevans

CHANGELOG.md

@@ -1,7 +1,8 @@
-# v0.4.2rc1
+# v0.4.2rc2
 
 * Explicitly specify the timeout of each event stream connection to help avoid
   weird states where the event stream is open but not receiving events.
+* Add more logging and error handling when event listener handlers fail.
 
 # v0.4.1
 

linkedin_messaging/__init__.py

@@ -2,7 +2,7 @@
 from .api_objects import URN
 
 __title__ = "linkedin_messaging"
-__version__ = "0.4.2rc1"
+__version__ = "0.4.2rc2"
 __description__ = "An unofficial API for interacting with LinkedIn Messaging"
 
 __license__ = "MIT"

linkedin_messaging/linkedin.py

@@ -515,7 +515,10 @@ def add_event_listener(
 
     async def _fire(self, payload_key: str, event: Any):
         for listener in self.event_listeners[payload_key]:
-            await listener(event)
+            try:
+                await listener(event)
+            except Exception:
+                logging.exception(f"Listener {listener} failed to handle {event}")
 
     async def _listen_to_event_stream(self):
         logging.info("Starting event stream listener")
@@ -543,7 +546,12 @@ async def _listen_to_event_stream(self):
                 # Special handling for ALL_EVENTS handler.
                 if all_events_handlers := self.event_listeners.get("ALL_EVENTS"):
                     for handler in all_events_handlers:
-                        await handler(data)
+                        try:
+                            await handler(data)
+                        except Exception:
+                            logging.exception(
+                                f"Handler {handler} failed to handle {data}"
+                            )
 
                 event_payload = data.get(
                     "com.linkedin.realtimefrontend.DecoratedEvent", {}
@@ -565,16 +573,20 @@ async def start_listener(self):
                 # Special handling for TIMEOUT handler.
                 if all_events_handlers := self.event_listeners.get("TIMEOUT"):
                     for handler in all_events_handlers:
-                        await handler(te)
-                await asyncio.sleep(1)
-                continue
+                        try:
+                            await handler(te)
+                        except Exception:
+                            logging.exception(
+                                f"Handler {handler} failed to handle {te}"
+                            )
             except Exception as e:
                 logging.exception(f"Error listening to event stream: {e}")
                 # Special handling for STREAM_ERROR handler.
                 if all_events_handlers := self.event_listeners.get("STREAM_ERROR"):
                     for handler in all_events_handlers:
-                        await handler(e)
-                await asyncio.sleep(1)
-                continue
+                        try:
+                            await handler(e)
+                        except Exception:
+                            logging.exception(f"Handler {handler} failed to handle {e}")
 
     # endregion

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "linkedin_messaging"
-version = "0.4.2rc1"
+version = "0.4.2rc2"
 description = "An unofficial API for interacting with LinkedIn Messaging"
 authors = ["Sumner Evans <inquiries@sumnerevans.com>"]
 license = "Apache-2.0"