chore(rivetkit): note duplicate admission logic

Author: NathanFlurry

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

@@ -1160,6 +1160,7 @@ impl ActorTask {
 	}
 
 	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());

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

@@ -808,6 +808,7 @@ impl RegistryDispatcher {
 			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