gameplay: port early client routing policy

crates/urt-gameplay/src/bin/urt-client-processing.rs

@@ -0,0 +1,64 @@
+use urt_gameplay::client_processing::*;
+fn hex(v: &[u8]) -> String {
+    v.iter().map(|v| format!("{v:02x}")).collect()
+}
+fn list(v: &[u32]) -> String {
+    format!(
+        "[{}]",
+        v.iter()
+            .map(|v| v.to_string())
+            .collect::<Vec<_>>()
+            .join(",")
+    )
+}
+fn events(v: &[ProcessingEffect]) -> String {
+    v.iter()
+        .map(|e| match e {
+            ProcessingEffect::Intermission { slot } => {
+                format!(r#"{{"op":"intermission","slot":{}}}"#, slot)
+            }
+            ProcessingEffect::Spectator { slot, command_time } => format!(
+                r#"{{"op":"spectator","slot":{},"command_time":{}}}"#,
+                slot, command_time
+            ),
+            ProcessingEffect::Team { slot, text, force } => format!(
+                r#"{{"op":"team","slot":{},"text":"{}","force":{}}}"#,
+                slot,
+                hex(text),
+                force
+            ),
+            ProcessingEffect::Send { slot, text } => {
+                format!(r#"{{"op":"send","slot":{},"text":"{}"}}"#, slot, hex(text))
+            }
+            ProcessingEffect::Drop { slot, text } => {
+                format!(r#"{{"op":"drop","slot":{},"text":"{}"}}"#, slot, hex(text))
+            }
+        })
+        .collect::<Vec<_>>()
+        .join(",")
+}
+fn main() {
+    let mut args = std::env::args().skip(1);
+    let kind = args.next().unwrap();
+    let w: Vec<u32> = args.map(|v| v.parse().unwrap()).collect();
+    match kind.as_str() {
+        "route" => {
+            assert_eq!(w.len(), 4);
+            let out = route_client(RoutingInput {
+                intermission: w[0],
+                team: w[1],
+                follow: w[2],
+                spectator: w[3],
+                slot: 2,
+                command_time: 12345,
+            })
+            .unwrap();
+            println!(
+                r#"{{"events":[{}],"proceed":{}}}"#,
+                events(&out.effects),
+                out.route == ClientRoute::Continue
+            );
+        }
+        _ => panic!("unknown policy"),
+    }
+}

crates/urt-gameplay/src/client_processing.rs

@@ -0,0 +1,129 @@
+//! Recovered pre-movement client policies with explicit captured callback effects.
+use crate::native_policy::Error;
+#[derive(Clone, Debug, PartialEq, Eq)]
+pub enum ProcessingEffect {
+    Intermission {
+        slot: i32,
+    },
+    Spectator {
+        slot: i32,
+        command_time: u32,
+    },
+    Team {
+        slot: i32,
+        text: Vec<u8>,
+        force: u32,
+    },
+    Send {
+        slot: i32,
+        text: Vec<u8>,
+    },
+    Drop {
+        slot: i32,
+        text: Vec<u8>,
+    },
+}
+#[derive(Clone, Copy, Debug, PartialEq, Eq)]
+pub enum ClientRoute {
+    Continue,
+    Intermission,
+    Spectator,
+    Return,
+}
+#[derive(Clone, Debug, PartialEq, Eq)]
+pub struct RoutingOutcome {
+    pub route: ClientRoute,
+    pub effects: Vec<ProcessingEffect>,
+}
+#[derive(Clone, Copy, Debug, PartialEq, Eq)]
+pub struct RoutingInput {
+    pub intermission: u32,
+    pub team: u32,
+    pub follow: u32,
+    pub spectator: u32,
+    pub slot: i32,
+    pub command_time: u32,
+}
+/// Original154210 routing, stopping before command rewriting or at early return.
+pub fn route_client(input: RoutingInput) -> Result<RoutingOutcome, Error> {
+    if !(0..64).contains(&input.slot) {
+        return Err(Error::InvalidIndex);
+    }
+    let (route, effects) = if input.intermission != 0 {
+        (
+            ClientRoute::Intermission,
+            vec![ProcessingEffect::Intermission { slot: input.slot }],
+        )
+    } else if input.team == 3 || input.follow != 0 {
+        if input.spectator == 3 {
+            (ClientRoute::Return, vec![])
+        } else {
+            (
+                ClientRoute::Spectator,
+                vec![ProcessingEffect::Spectator {
+                    slot: input.slot,
+                    command_time: input.command_time,
+                }],
+            )
+        }
+    } else {
+        (ClientRoute::Continue, vec![])
+    };
+    Ok(RoutingOutcome { route, effects })
+}
+#[cfg(test)]
+mod routing_tests {
+    use super::*;
+    fn input() -> RoutingInput {
+        RoutingInput {
+            intermission: 0,
+            team: 0,
+            follow: 0,
+            spectator: 0,
+            slot: 2,
+            command_time: 12345,
+        }
+    }
+    #[test]
+    fn intermission_precedes_spectator_state() {
+        let p = route_client(RoutingInput {
+            intermission: 1,
+            team: 3,
+            follow: 1,
+            spectator: 3,
+            ..input()
+        })
+        .unwrap();
+        assert_eq!(p.route, ClientRoute::Intermission);
+        assert_eq!(p.effects, [ProcessingEffect::Intermission { slot: 2 }]);
+    }
+    #[test]
+    fn spectator_word_only_suppresses_with_outer_gate() {
+        assert_eq!(
+            route_client(RoutingInput {
+                spectator: 3,
+                ..input()
+            })
+            .unwrap()
+            .route,
+            ClientRoute::Continue
+        );
+        let p = route_client(RoutingInput {
+            team: 3,
+            spectator: 3,
+            ..input()
+        })
+        .unwrap();
+        assert_eq!(p.route, ClientRoute::Return);
+        assert!(p.effects.is_empty());
+        assert_eq!(
+            route_client(RoutingInput {
+                follow: 1,
+                ..input()
+            })
+            .unwrap()
+            .route,
+            ClientRoute::Spectator
+        );
+    }
+}

crates/urt-gameplay/src/lib.rs

@@ -189,3 +189,5 @@ pub mod filter_loading;
 pub mod filter_commands;
 
 pub mod client_timer;
+
+pub mod client_processing;

docs/FINDINGS.md

@@ -1881,3 +1881,5 @@ RE-972: Ninety-six original154089-prefix cases recover connection-word gating, o
 RE-973: Rust matches96 original caller-prefix cases, preserving connection-word gating, pre-clamp timestamp copies, signed wrapping bounds, the nonpositive-delta exception,200ms cap and post-delta8ms rounding. Unit tests cover unchanged disconnected state, retained pre-round delta, negative exception deltas and sequential bounds at signed wrap. The remaining caller body and actual timer dispatch are explicitly unrecovered. [Evidence](research/RUST_CLIENT_TIMER_PREPARE.md).
 
 RE-974: Sixteen source154210-prefix paths recover intermission precedence, team3/follow gates and spectator-word3 callback suppression. Normal paths stop at154256; routed paths stop at the original early return155716. Callback151133/149671 effects remain captured, with their client/command inputs recorded. Later command and movement processing are outside this first contract. [Evidence](research/QVM_CLIENT_ROUTING.md).
+
+RE-975: Rust matches16 source routing cases, preserving intermission precedence and spectator callback suppression. Typed effects carry source slot/command-time inputs and keep actual callback bodies outside this contract. Unit tests cover outer-gate precedence and spectator-word suppression without conflating normal clients with routed ones. [Evidence](research/RUST_CLIENT_ROUTING.md).

docs/PROVISIONAL_TODO.md

@@ -1935,3 +1935,5 @@ RE-954–963 completed add/remove wrappers, resolved duration export, full-capac
 RE-964–973 completed timer deadline/phase/recovery contracts, whole-body composition and caller timing preparation. RE-974 tracks remaining caller paths, damage feedback and native/runtime integration. [Batch and next work](research/QVM_CLIENT_TIMER_BATCH.md).
 
 - [x] RE-974 Original client intermission and spectator routing ([evidence](research/QVM_CLIENT_ROUTING.md)).
+
+- [x] RE-975 Rust early client routing with captured callbacks ([evidence](research/RUST_CLIENT_ROUTING.md)).

docs/RESEARCH_LEDGER.md

@@ -2569,3 +2569,7 @@ Batch RE-964–973 boundary: the single `cargo xtask test-full --since c1e91e2e`
 ## 2026-10-28 — RE-974 Original client intermission and spectator routing
 
 Sixteen source154210-prefix paths recover intermission precedence, team3/follow gates and spectator-word3 callback suppression. Normal paths stop at154256; routed paths stop at the original early return155716. Callback151133/149671 effects remain captured, with their client/command inputs recorded. Later command and movement processing are outside this first contract. Focused `cargo xtask test-group qvm-client-routing` passes with deterministic report regeneration, relevant regressions and storage/documentation/whitespace checks. Full suite deferred to the tenth-commit boundary. Original assets unchanged; native IO effects remain captured.
+
+## 2026-10-28 — RE-975 Rust early client routing with captured callbacks
+
+Rust matches16 source routing cases, preserving intermission precedence and spectator callback suppression. Typed effects carry source slot/command-time inputs and keep actual callback bodies outside this contract. Unit tests cover outer-gate precedence and spectator-word suppression without conflating normal clients with routed ones. Focused `cargo xtask test-group rust-client-routing` passes with deterministic report regeneration, relevant regressions and storage/documentation/whitespace checks. Full suite deferred to the tenth-commit boundary. Original assets unchanged; native IO effects remain captured.

docs/REVERSE_ENGINEERING_TODO.md

@@ -1972,3 +1972,5 @@ RE-964–973 recover the complete bounded timer body and its caller timing prefi
 - [ ] RE-974 Recover the remaining timer caller, damage feedback, initialization/native ownership and full Rust/Bevy/Solari acceptance ([next work](research/QVM_CLIENT_TIMER_BATCH.md)).
 
 - [x] RE-974 Original client intermission and spectator routing ([evidence](research/QVM_CLIENT_ROUTING.md)).
+
+- [x] RE-975 Rust early client routing with captured callbacks ([evidence](research/RUST_CLIENT_ROUTING.md)).

docs/research/README.md

@@ -1507,3 +1507,5 @@ The extension collector adds five focused tests for native tail calls, command-r
 - [RE-964–973 client timer batch and RE-974 next work](QVM_CLIENT_TIMER_BATCH.md).
 
 - [RE-974: Original client intermission and spectator routing](QVM_CLIENT_ROUTING.md).
+
+- [RE-975: Rust early client routing with captured callbacks](RUST_CLIENT_ROUTING.md).

docs/research/RUST_CLIENT_ROUTING.md

@@ -0,0 +1,5 @@
+# Rust early client routing with captured callbacks
+
+RE-975. Focused validation: `cargo xtask test-group rust-client-routing`. [Machine report](rust-client-routing.json).
+
+Rust matches16 source routing cases, preserving intermission precedence and spectator callback suppression. Typed effects carry source slot/command-time inputs and keep actual callback bodies outside this contract. Unit tests cover outer-gate precedence and spectator-word suppression without conflating normal clients with routed ones.

docs/research/rust-client-routing.json

@@ -0,0 +1,283 @@
+{
+  "limits": "Finite source/Rust contract parity; native time/file/network replies remain supplied or captured.",
+  "probes": [
+    {
+      "rust": {
+        "events": [],
+        "proceed": true
+      },
+      "source": {
+        "events": [],
+        "proceed": true
+      }
+    },
+    {
+      "rust": {
+        "events": [],
+        "proceed": true
+      },
+      "source": {
+        "events": [],
+        "proceed": true
+      }
+    },
+    {
+      "rust": {
+        "events": [
+          {
+            "command_time": 12345,
+            "op": "spectator",
+            "slot": 2
+          }
+        ],
+        "proceed": false
+      },
+      "source": {
+        "events": [
+          {
+            "command_time": 12345,
+            "op": "spectator",
+            "slot": 2
+          }
+        ],
+        "proceed": false
+      }
+    },
+    {
+      "rust": {
+        "events": [],
+        "proceed": false
+      },
+      "source": {
+        "events": [],
+        "proceed": false
+      }
+    },
+    {
+      "rust": {
+        "events": [
+          {
+            "command_time": 12345,
+            "op": "spectator",
+            "slot": 2
+          }
+        ],
+        "proceed": false
+      },
+      "source": {
+        "events": [
+          {
+            "command_time": 12345,
+            "op": "spectator",
+            "slot": 2
+          }
+        ],
+        "proceed": false
+      }
+    },
+    {
+      "rust": {
+        "events": [],
+        "proceed": false
+      },
+      "source": {
+        "events": [],
+        "proceed": false
+      }
+    },
+    {
+      "rust": {
+        "events": [
+          {
+            "command_time": 12345,
+            "op": "spectator",
+            "slot": 2
+          }
+        ],
+        "proceed": false
+      },
+      "source": {
+        "events": [
+          {
+            "command_time": 12345,
+            "op": "spectator",
+            "slot": 2
+          }
+        ],
+        "proceed": false
+      }
+    },
+    {
+      "rust": {
+        "events": [],
+        "proceed": false
+      },
+      "source": {
+        "events": [],
+        "proceed": false
+      }
+    },
+    {
+      "rust": {
+        "events": [
+          {
+            "op": "intermission",
+            "slot": 2
+          }
+        ],
+        "proceed": false
+      },
+      "source": {
+        "events": [
+          {
+            "op": "intermission",
+            "slot": 2
+          }
+        ],
+        "proceed": false
+      }
+    },
+    {
+      "rust": {
+        "events": [
+          {
+            "op": "intermission",
+            "slot": 2
+          }
+        ],
+        "proceed": false
+      },
+      "source": {
+        "events": [
+          {
+            "op": "intermission",
+            "slot": 2
+          }
+        ],
+        "proceed": false
+      }
+    },
+    {
+      "rust": {
+        "events": [
+          {
+            "op": "intermission",
+            "slot": 2
+          }
+        ],
+        "proceed": false
+      },
+      "source": {
+        "events": [
+          {
+            "op": "intermission",
+            "slot": 2
+          }
+        ],
+        "proceed": false
+      }
+    },
+    {
+      "rust": {
+        "events": [
+          {
+            "op": "intermission",
+            "slot": 2
+          }
+        ],
+        "proceed": false
+      },
+      "source": {
+        "events": [
+          {
+            "op": "intermission",
+            "slot": 2
+          }
+        ],
+        "proceed": false
+      }
+    },
+    {
+      "rust": {
+        "events": [
+          {
+            "op": "intermission",
+            "slot": 2
+          }
+        ],
+        "proceed": false
+      },
+      "source": {
+        "events": [
+          {
+            "op": "intermission",
+            "slot": 2
+          }
+        ],
+        "proceed": false
+      }
+    },
+    {
+      "rust": {
+        "events": [
+          {
+            "op": "intermission",
+            "slot": 2
+          }
+        ],
+        "proceed": false
+      },
+      "source": {
+        "events": [
+          {
+            "op": "intermission",
+            "slot": 2
+          }
+        ],
+        "proceed": false
+      }
+    },
+    {
+      "rust": {
+        "events": [
+          {
+            "op": "intermission",
+            "slot": 2
+          }
+        ],
+        "proceed": false
+      },
+      "source": {
+        "events": [
+          {
+            "op": "intermission",
+            "slot": 2
+          }
+        ],
+        "proceed": false
+      }
+    },
+    {
+      "rust": {
+        "events": [
+          {
+            "op": "intermission",
+            "slot": 2
+          }
+        ],
+        "proceed": false
+      },
+      "source": {
+        "events": [
+          {
+            "op": "intermission",
+            "slot": 2
+          }
+        ],
+        "proceed": false
+      }
+    }
+  ],
+  "source_report": "docs/research/qvm-client-routing.json",
+  "source_report_sha256": "dafa28fafa50f72fa77e876c28e979ac3ad0084dc78bcd1103dd598589449b16"
+}

docs/research/rust-health-impulse.json

@@ -2985,7 +2985,7 @@
       "exit_code": 2
     }
   ],
-  "rust_unit_tests": 230,
+  "rust_unit_tests": 232,
   "source_report": "docs/research/qvm-health-impulse.json",
   "source_report_sha256": "625fd8064004ea6dbdf398d51d0af844d9c635ff04c0a0790886dddb6ab81e71"
 }

scripts/analyze_rust_client_routing.py

@@ -0,0 +1,16 @@
+"""Compare recovered Rust policy with original QVM fixtures."""
+import hashlib,json,os,subprocess
+from pathlib import Path
+from analyze_qvm import write_json
+from rust_lifecycle_support import result
+
+def main():
+ subprocess.run(['cargo','build','--offline','--package','urt-gameplay','--bin','urt-client-processing'],check=True,capture_output=True)
+ binary=Path(os.environ.get('CARGO_TARGET_DIR','target'))/'debug'/'urt-client-processing'
+ path=Path('docs/research/qvm-client-routing.json');data=path.read_bytes();probes=[]
+ for p in json.loads(data)['probes']:
+  probes.append(dict(source={k:p[k] for k in ['events', 'proceed']},rust=result(binary,'route',encode(p['input']))))
+ write_json(Path('docs/research/rust-client-routing.json'),dict(source_report=str(path),source_report_sha256=hashlib.sha256(data).hexdigest(),probes=probes,limits='Finite source/Rust contract parity; native time/file/network replies remain supplied or captured.'))
+
+def encode(a):return [a[k] for k in ['intermission','team','follow','spectator']]
+if __name__=='__main__':main()

scripts/test_rust_client_routing.py

@@ -0,0 +1,9 @@
+import hashlib,json,unittest
+from pathlib import Path
+class PortTests(unittest.TestCase):
+ def test_original_parity(self):
+  r=json.loads(Path('docs/research/rust-client-routing.json').read_text());self.assertGreaterEqual(len(r['probes']),12)
+  for p in r['probes']:self.assertEqual(p['source'],p['rust'])
+ def test_identity(self):
+  r=json.loads(Path('docs/research/rust-client-routing.json').read_text());self.assertEqual(hashlib.sha256(Path(r['source_report']).read_bytes()).hexdigest(),r['source_report_sha256'])
+if __name__=='__main__':unittest.main()

xtask/checks.tsv

@@ -3542,3 +3542,27 @@ report	scripts/analyze_qvm_client_routing.py	docs/research/qvm-client-routing.js
 edge	docs/research/qvm-client-routing.json	scripts/test_qvm_client_routing.py
 group	qvm-client-routing	scripts/analyze_qvm_client_routing.py
 edge	scripts/analyze_qvm_client_routing.py	scripts/analyze_qvm_resumer_audit.py
+report	scripts/analyze_rust_client_routing.py	docs/research/rust-client-routing.json
+edge	docs/research/rust-client-routing.json	scripts/test_rust_client_routing.py
+group	rust-client-routing	scripts/analyze_rust_client_routing.py
+edge	scripts/analyze_rust_client_routing.py	scripts/analyze_qvm_resumer_audit.py
+edge	Cargo.toml	scripts/analyze_rust_client_routing.py
+edge	Cargo.lock	scripts/analyze_rust_client_routing.py
+edge	crates/urt-gameplay/Cargo.toml	scripts/analyze_rust_client_routing.py
+edge	crates/urt-gameplay/src/lib.rs	scripts/analyze_rust_client_routing.py
+edge	crates/urt-gameplay/src/filter_loading.rs	scripts/analyze_rust_client_routing.py
+edge	crates/urt-gameplay/src/filter_lifecycle.rs	scripts/analyze_rust_client_routing.py
+edge	crates/urt-gameplay/src/native_policy.rs	scripts/analyze_rust_client_routing.py
+edge	crates/urt-gameplay/src/bin/urt-filter-loading.rs	scripts/analyze_rust_client_routing.py
+edge	crates/urt-gameplay/src/qvm_format.rs	scripts/analyze_rust_client_routing.py
+edge	docs/research/qvm-client-routing.json	scripts/analyze_rust_client_routing.py
+group	rust-client-routing	scripts/analyze_rust_health_impulse.py
+group	gameplay	scripts/analyze_rust_client_routing.py
+edge	crates/urt-gameplay/src/filter_commands.rs	scripts/analyze_rust_client_routing.py
+edge	crates/urt-gameplay/src/bin/urt-filter-commands.rs	scripts/analyze_rust_client_routing.py
+edge	crates/urt-gameplay/src/client_timer.rs	scripts/analyze_rust_client_routing.py
+edge	crates/urt-gameplay/src/bin/urt-client-timer.rs	scripts/analyze_rust_client_routing.py
+edge	crates/urt-gameplay/src/client_processing.rs	scripts/analyze_rust_client_routing.py
+edge	crates/urt-gameplay/src/bin/urt-client-processing.rs	scripts/analyze_rust_client_routing.py
+edge	crates/urt-gameplay/src/client_processing.rs	scripts/analyze_rust_health_impulse.py
+edge	crates/urt-gameplay/src/bin/urt-client-processing.rs	scripts/analyze_rust_health_impulse.py