test: verify terminal stream delivery and lock dependencies

Author: nosam1998

.github/workflows/ci.yml

@@ -15,10 +15,6 @@ jobs:
       - uses: actions/checkout@v4
       - uses: dtolnay/rust-toolchain@stable
       - uses: Swatinem/rust-cache@v2
-      - name: Resolve WebSocket dependencies
-        run: |
-          cargo update --workspace
-          python3 -c 'import json,pathlib; print("GFA_LOCK_JSON:"+json.dumps({"path":"Cargo.lock","content":pathlib.Path("Cargo.lock").read_text()}))'
       - name: Prepare SQLite schema for query checking
         run: python3 .github/scripts/sqlite-query-check.py prepare
         env:

Cargo.lock

@@ -43,11 +43,19 @@ pub fn local_router(service: Arc<GameService>, address: SocketAddr) -> Result<Ro
 ///
 /// The host must install this same LiveUpdates instance with GameService::with_observer.
 /// Periodic reconciliation also catches commits from other hosts sharing the store.
-pub fn local_router_with_updates(service: Arc<GameService>, address: SocketAddr, updates: Arc<LiveUpdates>) -> Result<Router, ApiError> {
+pub fn local_router_with_updates(
+    service: Arc<GameService>,
+    address: SocketAddr,
+    updates: Arc<LiveUpdates>,
+) -> Result<Router, ApiError> {
     build_router(service, address, Some(updates))
 }
 
-fn build_router(service: Arc<GameService>, address: SocketAddr, updates: Option<Arc<LiveUpdates>>) -> Result<Router, ApiError> {
+fn build_router(
+    service: Arc<GameService>,
+    address: SocketAddr,
+    updates: Option<Arc<LiveUpdates>>,
+) -> Result<Router, ApiError> {
     if !address.ip().is_loopback() || address.port() == 0 {
         return Err(ApiError::new(
             "INVALID_CONFIG",
@@ -67,9 +75,13 @@ fn build_router(service: Arc<GameService>, address: SocketAddr, updates: Option<
         .fallback(not_found)
         .method_not_allowed_fallback(method_not_allowed);
     if let Some(updates) = updates {
-        router = router.route("/v1/matches/{id}/stream", get(stream::upgrade).layer(axum::Extension(updates)));
+        router = router.route(
+            "/v1/matches/{id}/stream",
+            get(stream::upgrade).layer(axum::Extension(updates)),
+        );
     }
-    Ok(router.layer(DefaultBodyLimit::max(MAX_BODY_BYTES))
+    Ok(router
+        .layer(DefaultBodyLimit::max(MAX_BODY_BYTES))
         .layer(middleware::from_fn_with_state(
             access::LocalAccess::new(address),
             access::guard,