Skip to content

Commit

Permalink
event stream: update the realtime connection ID on every request
Browse files Browse the repository at this point in the history
Signed-off-by: Sumner Evans <[email protected]>
  • Loading branch information
sumnerevans committed Jan 17, 2024
1 parent 6368166 commit b4fec48
Showing 1 changed file with 2 additions and 4 deletions.
6 changes: 2 additions & 4 deletions linkedin_messaging/linkedin.py
Original file line number Diff line number Diff line change
Expand Up @@ -577,10 +577,8 @@ async def _listen_to_event_stream(self):

if cc := data.get("com.linkedin.realtimefrontend.ClientConnection", {}):
logging.info(f"Got realtime connection ID: {cc.get('id')}")
if not self._realtime_sesion_id:
logging.info("No existing realtime connection ID, setting the ID")
self._request_headers["x-li-realtime-session"] = cc.get("id")
self._realtime_sesion_id = cc.get("id")
self._request_headers["x-li-realtime-session"] = cc.get("id")
self._realtime_sesion_id = cc.get("id")

event_payload = data.get("com.linkedin.realtimefrontend.DecoratedEvent", {}).get(
"payload", {}
Expand Down

0 comments on commit b4fec48

Please sign in to comment.