From 40bd6b81b884ae36013a6314d10ec8a1795ce9ba Mon Sep 17 00:00:00 2001
From: ruv <ruv@ruv.net>
Date: Sat, 23 May 2026 13:47:14 -0400
Subject: [PATCH] =?UTF-8?q?test(adr-110):=20end-to-end=20sync=20decode=20?=
 =?UTF-8?q?=E2=86=92=20frame=20mesh=20recovery=20integration=20test?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Iter 20 — defensive ultra-opt: one test that exercises the entire
iter 14→17 chain in a single assertion, so any future refactor that
breaks the contract surfaces as a single, named regression instead of
14 unit-test diffs to triangulate.

  1. firmware emits sync packet (bytes built here as a stand-in)
  2. host decodes via SyncPacket::from_bytes — assert round-trip
  3. a CSI frame arrives 100 sequences later (≈ 5 s @ 20 fps)
  4. mesh_aligned_us_for_sequence recovers the mesh timestamp
  5. cross-check: same value via raw apply_to_local

Asserts mesh_us == sync.epoch_us + 5_000_000 µs exactly, plus both
paths (sequence-interpolation + direct local→mesh) agree byte-for-byte.

Result: 14/14 sync_packet tests pass, full wifi-densepose-hardware
crate at 136/136 (no regression from iter 1-19). Contract for any
ADR-029/030 multistatic fusion consumer is now defended by a test that
fails loud if either piece of the chain drifts.

Co-Authored-By: claude-flow <ruv@ruv.net>
---
 .../src/sync_packet.rs                        | 33 +++++++++++++++++++
 1 file changed, 33 insertions(+)

diff --git a/v2/crates/wifi-densepose-hardware/src/sync_packet.rs b/v2/crates/wifi-densepose-hardware/src/sync_packet.rs
index fa7429d1..55540185 100644
--- a/v2/crates/wifi-densepose-hardware/src/sync_packet.rs
+++ b/v2/crates/wifi-densepose-hardware/src/sync_packet.rs
@@ -383,6 +383,39 @@ mod tests {
         assert_eq!(mesh, pkt.epoch_us + 50_000);  // 1 frame at 20 fps = 50 ms
     }
 
+    /// End-to-end ADR-110 pipeline sanity:
+    ///   (1) firmware emits sync packet (bytes built here as a stand-in)
+    ///   (2) host wire-decodes via from_bytes
+    ///   (3) a CSI frame arrives 100 sequences later (≈ 5 s @ 20 fps)
+    ///   (4) mesh_aligned_us_for_sequence recovers its mesh timestamp
+    /// Asserts that the recovered mesh time matches sync.epoch_us + Δus exactly,
+    /// and cross-checks against apply_to_local. This is the contract every
+    /// downstream multistatic-fusion consumer relies on.
+    #[test]
+    fn end_to_end_sync_decode_then_frame_mesh_recovery() {
+        let pkt = SyncPacket {
+            node_id: 9,
+            proto_ver: 1,
+            flags: SyncPacketFlags { is_leader: false, is_valid: true, smoothed_used: true },
+            local_us: 28_798_450,
+            epoch_us: 27_634_885,
+            sequence: 20,
+        };
+        let wire = pkt.to_bytes();
+        assert_eq!(wire.len(), SYNC_PACKET_SIZE);
+        let decoded = SyncPacket::from_bytes(&wire).unwrap();
+        assert_eq!(decoded, pkt);
+
+        // 5 s after sync at 20 fps = 100 frames later
+        let frame_seq = pkt.sequence + 100;
+        let mesh_us = decoded.mesh_aligned_us_for_sequence(frame_seq, 20.0);
+        assert_eq!(mesh_us, pkt.epoch_us + 5_000_000);
+
+        // Same mesh time via direct apply_to_local — both paths must agree
+        let local_at_frame = pkt.local_us + 5_000_000;
+        assert_eq!(decoded.apply_to_local(local_at_frame), mesh_us);
+    }
+
     #[test]
     fn wire_size_constant_is_correct() {
         let pkt = SyncPacket {