build(deps-dev): bump matrix-synapse from 1.33.0 to 1.45.1 in /requirements

raiden/network/transport/matrix/client.py

@@ -542,20 +542,23 @@ def _sync(self, timeout_ms: int, latency_ms: int) -> None:
         if response:
             token = uuid4()
 
+            presence = response.get("presence")
+            to_device = response.get("to_device")
             log.debug(
                 "Sync returned",
                 node=node_address_from_userid(self.user_id),
                 token=token,
                 elapsed=time_after_sync - time_before_sync,
                 current_user=self.user_id,
-                presence_events_qty=len(response["presence"]["events"]),
-                to_device_events_qty=len(response["to_device"]["events"]),
+                presence_events_qty=presence and len(presence["events"]) or 0,
+                to_device_events_qty=to_device and len(to_device["events"]) or 0,
             )
 
             # Updating the sync token should only be done after the response is
             # saved in the queue, otherwise the data can be lost in a stop/start.
             self.response_queue.put((token, response, datetime.now()))
-            self.sync_token = response["next_batch"]
+            # XXX what to do if none?
+            self.sync_token = response.get("next_batch")
             self.sync_progress.set_synced(token)
 
     def _handle_message(
@@ -624,17 +627,19 @@ def _handle_responses(self, currently_queued_responses: List[JSONResponse]) -> N
         messages: List[MatrixMessage] = []
 
         for response in currently_queued_responses:
-            for presence_update in response["presence"]["events"]:
-                for callback in list(self.presence_listeners.values()):
-                    callback(presence_update, next(self._presence_update_ids))
-
-            for to_device_message in response["to_device"]["events"]:
-                for listener in self.listeners[:]:
-                    if listener["event_type"] == "to_device":
-                        listener["callback"](to_device_message)
-
-            # Add toDevice messages to message queue
-            messages.extend(response["to_device"]["events"])
+            if "presence" in response:
+                for presence_update in response["presence"]["events"]:
+                    for callback in list(self.presence_listeners.values()):
+                        callback(presence_update, next(self._presence_update_ids))
+
+            if "to_device" in response:
+                for to_device_message in response["to_device"]["events"]:
+                    for listener in self.listeners[:]:
+                        if listener["event_type"] == "to_device":
+                            listener["callback"](to_device_message)
+
+                # Add toDevice messages to message queue
+                messages.extend(response["to_device"]["events"])
 
         if messages:
             self.handle_messages_callback(messages)

requirements/requirements-ci.txt

@@ -304,6 +304,10 @@ idna==2.8
     #   requests
     #   twisted
     #   yarl
+ijson==3.1.4
+    # via
+    #   -r requirements-dev.txt
+    #   matrix-synapse
 importlib-metadata==4.8.1
     # via
     #   -r requirements-dev.txt
@@ -383,7 +387,7 @@ matplotlib-inline==0.1.2
     #   ipython
 matrix-client==0.3.2
     # via -r requirements-dev.txt
-matrix-synapse==1.33.0
+matrix-synapse==1.41.1
     # via -r requirements-dev.txt
 mccabe==0.6.1
     # via

requirements/requirements-dev.txt

@@ -277,6 +277,8 @@ idna==2.8
     #   requests
     #   twisted
     #   yarl
+ijson==3.1.4
+    # via matrix-synapse
 importlib-metadata==4.8.1
     # via pluggy
 incremental==17.5.0
@@ -341,7 +343,7 @@ matplotlib-inline==0.1.2
     # via ipython
 matrix-client==0.3.2
     # via -r requirements.txt
-matrix-synapse==1.33.0
+matrix-synapse==1.41.1
     # via -r requirements-dev.in
 mccabe==0.6.1
     # via