@@ -0,0 +59,4 @@
+			return Ok(());
+		},
+	};
+	if response.recommendation == "spam" {

@@ -45,3 +45,3 @@
 	}
 
-	debug!("Upgrading to timeline pdu");
+	debug!("Upgrading pdu {} from outlier to timeline pdu", incoming_pdu.event_id);

@@ -217,1 +219,4 @@
 
+	// 14-pre. If the event is not a state event, ask the policy server about it
+	if incoming_pdu.state_key.is_none()
+		&& incoming_pdu.sender().server_name() != self.services.globals.server_name()

@@ -218,0 +222,4 @@
+		&& incoming_pdu.sender().server_name() != self.services.globals.server_name()
+	{
+		debug!("Checking policy server for event {}", incoming_pdu.event_id);
+		let policy = self.policyserv_check(&incoming_pdu, room_id);

@@ -218,0 +223,4 @@
+	{
+		debug!("Checking policy server for event {}", incoming_pdu.event_id);
+		let policy = self.policyserv_check(&incoming_pdu, room_id);
+		if let Err(e) = policy.await {

@@ -701,0 +701,4 @@
+		if state_key.is_none() {
+			if prev_events.is_empty() {
+				warn!("Timeline event had zero prev_events, something broke.");
+				return Err!(Request(Unknown("Timeline event had zero prev_events.")));

@@ -0,0 +10,4 @@
+/// Returns Ok if the policy server allows the event
+#[implement(super::Service)]
+#[tracing::instrument(skip_all, level = "debug")]
+pub async fn policyserv_check(&self, pdu: &PduEvent, room_id: &RoomId) -> Result {

@@ -0,0 +25,4 @@
+		return Ok(());
+	};
+
+	let via = match policyserver.via {

@@ -0,0 +12,4 @@
+	events::{StateEventType, room::policy::RoomPolicyEventContent},
+};
+
+/// Returns Ok if the policy server allows the event

@@ -0,0 +104,4 @@
+			room_id = %room_id,
+			"Event was marked as spam by policy server",
+		);
+		return Err!(Request(Forbidden("Event was marked as spam by policy server")));

@@ -343,0 +344,4 @@
+# servers should respond near instantly, however may slow down under
+# load. If a policy server doesn't respond in a short amount of time, the
+# room it is configured in may become unusable if this limit is set too
+# high. 10 seconds is a good default, however dropping this to 3-5 seconds