fix: avoid panic

src/ruma_wrapper.rs

@@ -66,7 +66,11 @@ where
         let limit = db.globals.max_request_size();
         let mut handle = data.open(ByteUnit::Byte(limit.into()));
         let mut body = Vec::new();
-        handle.read_to_end(&mut body).await.unwrap();
+        if let Err(_) = handle.read_to_end(&mut body).await {
+            // Client disconnected
+            // Missing Token
+            return Failure((Status::new(582), ()));
+        }
 
         let mut json_body = serde_json::from_slice::<CanonicalJsonValue>(&body).ok();
 

src/server_server.rs

@@ -1439,13 +1439,7 @@ async fn upgrade_outlier_to_timeline_pdu(
 
             let fork_states = &fork_states
                 .into_iter()
-                .map(|map| {
-                    map.into_iter()
-                        .map(|(k, id)| {
-                            (k, (*id).clone())
-                        })
-                        .collect()
-                })
+                .map(|map| map.into_iter().map(|(k, id)| (k, (*id).clone())).collect())
                 .collect::<Vec<_>>();
 
             state_at_incoming_event = match state_res::StateResolution::resolve(