Skip to content

test: consolidate deterministic protocol parity harness [RUST-CI-031] - #82

Merged
itlezy merged 185 commits into
mainfrom
feature/persisted-soak-parity-analysis
Nov 2, 2026
Merged

itlezy merged 185 commits into
mainfrom
feature/persisted-soak-parity-analysis

Conversation

@itlezy

@itlezy itlezy commented Nov 2, 2026

Copy link
Copy Markdown
Collaborator

Tracks emulebb/emulebb-rust#164

Depends on

Summary

  • replace scattered parity paths with one machine-readable 100-ID protocol catalog, strict verdict model, deterministic campaigns, immutable receipts, and independent registration
  • make local codec, state-machine, and Rust/MFC cross-client evidence authoritative while retaining the persisted public soak as discovery only
  • complete deterministic server-session and server-query-reply coverage, including plaintext/obfuscated/fallback login, search, TCP/UDP metadata, TCP/UDP sources, and routed callback replies
  • classify and retire duplicate legacy runners without compatibility shims; keep MFC diagnostics-only and ed2k-server upstream-clean

Validation

  • protocol catalog: 23 of 100 IDs covered and 4 of 17 groups complete; server-query-reply is 9 of 9
  • complete test gate: 3177 passed, 1 expected POSIX-only skip, 1 deliberate deselection in 201.69 seconds
  • focused callback, registrar, and catalog gate: 131 passed
  • catalog validator, Ruff, formatting, and diff checks passed
  • canonical deterministic Rust/MFC callback campaign passed in 17 seconds with independent immutable registration

Threepwood-7 added 30 commits October 31, 2026 00:06
Surveyed observer_action_evidence, diagnostic_run_scan, diagnostic_run_index, and diag_event_runs. None owns a bounded transfer-specific proof artifact, so this adds a focused module over the existing immutable closed-segment scanner.
Threepwood-7 added 23 commits November 2, 2026 02:09
listener = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
try:
listener.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
listener.bind(("0.0.0.0", self.tcp_port))
search_id = str(created.get("id") or "")
if not search_id:
return None
search = created
obfuscated=True,
)
finally:
client.close()
except TimeoutError:
continue
self._handle_datagram(udp_socket, datagram, peer)
except BaseException as exc:
probe.bind(("127.0.0.1", tcp_port + offset))
sockets.append(probe)
return tcp_port, admin_port
except OSError:
if callable(wait):
try:
wait(timeout=WATCH_FAILURE_GRACE_SECONDS)
except subprocess.TimeoutExpired:
if payload is not None:
try:
decoded_id_change = ed2k_wire.decode_id_change(payload)
except ed2k_wire.Ed2kWireError:
@itlezy
itlezy merged commit f3a7eb4 into main Nov 2, 2026
25 checks passed
@itlezy
itlezy deleted the feature/persisted-soak-parity-analysis branch November 2, 2026 02:59
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants