Adds two new in-memory maps to the service in to prepare for better handlers

@@ -67,0 +72,4 @@
+		return Ok(response);
+	}
+	// Or are currently processing it
+	if let Some(receiver) = services.transaction_ids.get_active_federation_txn(&txn_key) {

@@ -209,0 +301,4 @@
+		if let Err(e) = services.server.check_running() {
+			debug_warn!("Server shutting down, returning partial transaction results: {e}");
+			results.push((event_id, Err(e)));
+			results.extend(event_ids.map(|id| (id, Err(err!("Server is shutting down")))));

@@ -6,0 +27,4 @@
+/// Minimum interval between cache cleanup runs.
+/// Exists to prevent thrashing when the cache is full of things that can't be
+/// cleared
+const CLEANUP_INTERVAL_SECS: u64 = 30;

@@ -131,0 +222,4 @@
+/// Converts a TransactionError into an appropriate HTTP error response.
+fn transaction_error_to_response(err: &TransactionError) -> Error {
+	match err {
+		| TransactionError::ShuttingDown => Error::Request(

@@ -6,0 +37,4 @@
+impl fmt::Display for TransactionError {
+	fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
+		match self {
+			| Self::ShuttingDown => write!(f, "Server is shutting down"),

@@ -89,0 +110,4 @@
+async fn wait_for_result(
+	mut recv: Receiver<WrappedTransactionResponse>,
+) -> Result<send_transaction_message::v1::Response> {
+	if tokio::time::timeout(Duration::from_secs(50), recv.changed())

@@ -131,0 +216,4 @@
+	// Send the error to any waiters
+	sender
+		.send(Some(Err(err)))
+		.expect("couldn't send error to channel");

@@ -172,0 +276,4 @@
+/// dependencies, however it is ultimately the sender's responsibility to send
+/// them in a processable order, so this is just a best effort attempt. It does
+/// not account for power levels or other tie breaks.
+async fn build_local_dag(

@@ -54,0 +192,4 @@
+		let max_active_txns = self.services.config.max_concurrent_inbound_transactions;
+
+		// Check if we're at capacity
+		if state.len() >= max_active_txns

@@ -54,0 +243,4 @@
+			.send(Some(Ok(response)))
+			.expect("couldn't send response to channel");
+
+		// explicitly close