@@ -0,0 +28,4 @@
+) -> Result<get_notifications::v3::Response> {
+	// Extract the `limit` and `from` query parameters
+	let limit = body.limit.unwrap_or(uint!(10));
+	let _from = body.from.as_deref();

@@ -0,0 +39,4 @@
+	let mut rooms_stream = std::pin::pin!(services.rooms.user.stream_notification_counts(sender_user));
+
+	while let Some((room_id, count)) = rooms_stream.next().await {
+		let Ok(room_id) = room_id else { continue };

@@ -0,0 +21,4 @@
+///
+/// Get notifications for the user.
+///
+/// Currently just returns an empty response.

@@ -0,0 +30,4 @@
+	let limit = body.limit.unwrap_or(uint!(10));
+	let _from = body.from.as_deref();
+
+	let sender_user = body.sender_user.as_ref().expect("user is authenticated");

@@ -0,0 +127,4 @@
+	// Sort by timestamp descending (newest first)
+	notifications.sort_by(|a, b| b.ts.cmp(&a.ts));
+
+	// Apply limit

@@ -61,0 +70,4 @@
+		.stream_prefix::<(OwnedUserId, OwnedRoomId), u64, _>(&prefix)
+		.map(|res| match res {
+			| Ok(((_user_id, room_id), count)) => (Ok(room_id), count),
+			| Err(e) => (Err(e), 0),

@@ -644,6 +644,15 @@ path = "src/main"
 strip = "symbols"
 lto = "thin"
 
+# Hybrid dev/release: "fast" here refers to compile times, not runtime speed

@@ -85,3 +80,1 @@
-	// if let Some(ref_path) = run_git_command(&["symbolic-ref", "--quiet", "HEAD"])
-	// { 	println!("cargo:rerun-if-changed=.git/{ref_path}");
-	// }
+	// Rerun if the git HEAD changes

@@ -121,3 +121,1 @@
-			let last_state = self.services.state.summary_stripped(pdu, room_id).await;
-			self.mark_as_invited(user_id, room_id, pdu.sender(), Some(last_state), None)
-				.await?;
+			let sender = pdu.sender();

@@ -0,0 +3,4 @@
+use futures::StreamExt;
+use ruma::{
+	MilliSecondsSinceUnixEpoch, UInt,
+	api::client::push::{get_notifications, get_notifications::v3 as r},

@@ -0,0 +27,4 @@
+
+	// Wrapper to order notifications by timestamp
+	#[derive(Debug)]
+	struct NotificationItem(r::Notification);

@@ -0,0 +109,4 @@
+			.is_joined(sender_user, &room_id)
+			.await
+		{
+			continue;

@@ -0,0 +163,4 @@
+			}
+
+			// Skip events sent by the user themselves
+			if pdu.sender == *sender_user {

@@ -0,0 +175,4 @@
+				.get_actions(sender_user, &ruleset, &power_levels, &pdu_raw, &room_id)
+				.await;
+
+			let mut notify = false;

@@ -0,0 +208,4 @@
+	}
+
+	// Capture heap stats before consuming
+	let heap_count = notifications.len();

@@ -56,22 +55,69 @@ impl crate::Service for Service {
 	}
 
 	async fn worker(self: Arc<Self>) -> Result<()> {
+		use std::collections::HashMap;

@@ -119,2 +119,4 @@
 		},
 		| MembershipState::Invite => {
+			// Check invite filter before expensive stripped state computation
+			let sender = pdu.sender();

@@ -121,6 +125,19 @@ impl crate::Service for Service {
 					joinset
 				});
 
+		// Periodic federation stats reporter (tracked via JoinSet so it

@@ -843,6 +848,15 @@ impl Service {
 			return Ok(Destination::Federation(server));
 		}
 
+		// Track federation stats

@@ -0,0 +5,4 @@
+/// Lightweight atomic counters for federation activity.
+/// Logged periodically and reset after each report.
+#[derive(Default)]
+pub struct FederationStats {