@@ -197,0 +209,4 @@
+
+		// See if the event matches any known pushers via power level
+		if *pdu.kind() != TimelineEventType::RoomCreate {
+			tokio::join!(

@@ -435,0 +495,4 @@
+			.values()
+			.map(ToOwned::to_owned)  // TODO: is this to_owned expensive?
+			.collect::<Vec<_>>();
+		interested_appservices

@@ -346,0 +272,4 @@
+	/// immutable. Since the PDU is immutable, the `event_id` field is
+	/// populated.
+	///
+	/// TODO: The `event_id` field should be a separate return option, not

@@ -107,0 +119,4 @@
+			return false;
+		};
+
+		let (as_user_joined, any_as_namespace_user_joined) = tokio::join!(

@@ -439,3 +456,1 @@
-			val.deserialize_as_unchecked().map_err(Into::into)
-		})
-}
+		match states {

@@ -125,3 +128,3 @@
 		self.room_state_get_content(room_id, &StateEventType::RoomTopic, "")
 			.await
-			.map(|c: RoomTopicEventContent| c.topic)
+			.map(|c: RoomTopicEventContent| {

@@ -225,0 +156,4 @@
+		Ok((count, pdus))
+	}
+
+	// TODO: The next 4 functions can be, theoretically, squashed into one.

@@ -1,20 +1,22 @@
-use std::collections::BTreeMap;
-
 use conduwuit::{Result, info, pdu::PartialPdu};

@@ -217,0 +189,4 @@
+			.await
+			.expect("admin room should have power levels");
+		if room_power_levels.users.remove(user_id).is_some() {
+			// drop the target's power level

@@ -21,0 +14,4 @@
+	/// Asserts that the server has access to the room and event (if any).
+	/// If the server is permitted, `Ok(())` is returned. Otherwise, a Forbidden
+	/// error is returned.
+	pub(super) async fn assert(&self) -> Result {