chore(rivetkit): note duplicate admission logic

rivetkit-rust/packages/rivetkit-core/src/actor/task.rs

@@ -1160,6 +1160,7 @@
 	}
 
 	fn dispatch_lifecycle_error(&self) -> Option<anyhow::Error> {
+		// TODO: Share admission policy with RegistryDispatcher::active_actor.
 		if self.ctx.destroy_requested() {
 			self.ctx.warn_work_sent_to_stopping_instance("dispatch");
 			return Some(ActorLifecycleError::Destroying.build());
@@ -2156,7 +2157,7 @@
 		self.lifecycle = lifecycle;
 		if matches!(lifecycle, LifecycleState::Started) {
 			// A restarted actor is a new generation. Clear shutdown state that was
 			// only meant to stop the previous generation.
 			self.ctx.reset_abort_signal_for_start();
 			self.ctx.clear_sleep_requested();
 			}

rivetkit-rust/packages/rivetkit-core/src/registry/http.rs

@@ -625,6 +625,19 @@ pub(super) fn normalize_actor_request_path(path: &str) -> String {
 	}
 }
 
+#[cfg(test)]
+pub(super) fn is_actor_request_path(path: &str) -> bool {
+	let Some(stripped) = path.strip_prefix("/request") else {
+		return false;
+	};
+
+	stripped.is_empty()
+		|| stripped
+			.as_bytes()
+			.first()
+			.is_some_and(|byte| matches!(byte, b'/' | b'?'))
+}
+
 pub(super) fn build_envoy_response(response: Response) -> Result<HttpResponse> {
 	let (status, headers, body) = response.to_parts();
 

rivetkit-rust/packages/rivetkit-core/src/registry/mod.rs

@@ -675,7 +675,7 @@
 			Ok(instance) => {
 				let pending_stop = self
 					.pending_stops
 					.remove_async(&request.actor_id.clone())
 					.await
 					.map(|(_, pending_stop)| pending_stop);
 					if let Some(pending_stop) = pending_stop {
@@ -754,7 +754,7 @@
 			SccEntry::Vacant(entry) => {
 				entry.insert_entry(state);
 			}
 		}
 	}
 
 		async fn transition_actor_to_stopping(
@@ -784,7 +784,7 @@
 		}
 	}
 
 	async fn remove_stopping_actor_instance(&self, actor_id: &str, expected: &ActiveActorInstance) {
 		match self.actor_instances.entry_async(actor_id.to_owned()).await {
 			SccEntry::Occupied(entry) => {
 					let should_remove = match entry.get() {
@@ -803,11 +803,12 @@
 		}
 	}
 
 	async fn active_actor(&self, actor_id: &str) -> Result<Arc<ActorTaskHandle>> {
 		if let Some(instance) = self.actor_instances.get_async(&actor_id.to_owned()).await {
 			match instance.get() {
 					ActorInstanceState::Active(instance) => {
 						let instance = instance.clone();
+						// TODO: Share admission policy with ActorTask::dispatch_lifecycle_error.
 						if instance.ctx.started() {
 							if instance.ctx.destroy_requested() {
 								instance