Untested

@@ -90,0 +108,4 @@
+				trace!("no policy server configured");
+			} else {
+				error!("failed to load policy server event: {e}");
+				// TODO: Should this fail closed?

@@ -72,1 +92,3 @@
-		return Ok(true);
+) -> Result<()> {
+	let ps = match pdu.event_type().with_state_key("").0 {
+		| StateEventType::RoomPolicy => return Ok(()),

@@ -90,0 +109,4 @@
+				trace!("no policy server configured");
+			} else {
+				error!("failed to load policy server event: {e}");
+				// TODO: Should this fail closed?

@@ -156,0 +262,4 @@
+				);
+				// TODO: select between this sleep and shutdown signal
+				sleep(saturated).await;
+				if !self.services.server.running() {