Alan-Jowett / sonde / 26555759966

82%

Build Type

push

github

Committed by web-flow

Commit Message

Wire gateway ACTUAL_STATE emission and rotation engine in binary startup (GW-2003, GW-2004) (#1076)

* Wire gateway ACTUAL_STATE emission and rotation engine in binary startup (GW-2003, GW-2004)

Wire the gateway binary (in/gateway.rs) to call existing library
infrastructure for ACTUAL_STATE publication and DESIRED_STATE handling,
completing the binary-level plumbing for the escrow/rotation subsystem.

Binary startup additions (per gateway-design.md §23.11):

- Step 2a: Call RotationEngine::resume_pending_rotation() to recover
  from crash-interrupted rotations. If a pending rotation is found and
  completed, re-emit gateway ACTUAL_STATE with updated master_key_id
  and master_key_epoch.
- Steps 2c/2d: Initialize master_key_id, master_key_epoch via
  init_master_key_id() and otation_code via init_rotation_code().

Channel wiring:

- Create DESIRED_STATE channel and wire to
  ConnectorService::set_gateway_desired_state_tx() and
  RotationEngine::new().
- Create rotation gRPC channel and wire to
  AdminService::with_rotation_tx() and RotationEngine::new().
- Create otation_complete and state_changed notification channels
  for the re-emission task.
- Spawn RotationEngine::run() as a tokio task.

ACTUAL_STATE emission (§23.11 step 9a, §23.14):

- Emit initial gateway ACTUAL_STATE after connector starts, with all
  required fields: ntity_id, channel, master_key_id,
  master_key_epoch, x25519_public_key, ingerprint_words,
  missing_key_hints, salt, kdf_params, gateway_version,
  gateway_commit, otation_in_progress.
- Spawn re-emission task with three trigger sources:
  1. otation_complete_rx — immediate re-emission on rotation complete
  2. state_changed_rx — immediate re-emission on salt/KDF adoption
  3. missing_hints_notify — 60-second debounced re-emission when
     MissingKeyHintTracker accepts a new hint

Engine changes:

- Add missing_hints_notify: Arc<Notify> to Gateway struct.
- Add eport_missing_hint() helper that combines eport() +

oti... (continued)

Coverage Stats

224 of 436 new or added lines in 4 files covered. (51.38%)

1 existing line in 1 file now uncovered.

39651 of 48183 relevant lines covered (82.29%)

236.84 hits per line