listener: raise all errors

Signed-off-by: Sumner Evans <[email protected]>

Author: sumnerevans

.pre-commit-config.yaml

@@ -9,7 +9,7 @@ repos:
       - id: check-added-large-files
 
   - repo: https://github.com/tox-dev/pyproject-fmt
-    rev: 0.9.1
+    rev: 0.9.2
     hooks:
       - id: pyproject-fmt
 
@@ -36,7 +36,7 @@ repos:
 
   # mypy
   - repo: https://github.com/pre-commit/mirrors-mypy
-    rev: v1.0.0
+    rev: v1.1.1
     hooks:
       - id: mypy
         additional_dependencies: [types-termcolor==1.1.3]

cicd/custom_style_check.py

@@ -67,5 +67,4 @@ def check_file(path: Path) -> bool:
     with open(Path("CHANGELOG.md")) as f:
         assert f.readline().strip() == f"# v{version}", "Version mismatch: CHANGELOG"
 
-
 sys.exit(0 if valid else 1)

linkedin_messaging/linkedin.py

@@ -7,6 +7,7 @@
 from typing import Any, AsyncGenerator, Awaitable, Callable, Optional, TypeVar, Union, cast
 
 import aiohttp
+import aiohttp.client_exceptions
 from bs4 import BeautifulSoup
 from dataclasses_json.api import DataClassJsonMixin
 
@@ -501,12 +502,10 @@ def add_event_listener(
         ],
     ):
         """
-        There are three special event types:
+        There is one special event type:
 
-        * ALL_EVENTS - an event fired on every event, and which contains the entirety of
-            the raw event payload
-        * TIMEOUT - an event fired if the event listener connection times out
-        * STREAM_ERROR - an event fired if the event stream errors for any other reason
+        * ``ALL_EVENTS`` - an event fired on every event, and which contains the entirety of the
+          raw event payload
         """
         self.event_listeners[payload_key].append(fn)
 
@@ -571,13 +570,7 @@ async def start_listener(self):
                         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 stream_error_handlers := self.event_listeners.get("STREAM_ERROR"):
-                    for handler in stream_error_handlers:
-                        try:
-                            await handler(e)
-                        except Exception:
-                            logging.exception(f"Handler {handler} failed to handle {e}")
+                logging.exception(f"Got exception in listener: {e}")
+                raise
 
     # endregion