offline_protocol/

config.rs

//! Protocol configuration.

use crate::constants::DEFAULT_INITIAL_TTL;
use crate::protocol::mesh_relay::{MeshRelayConfig, RELAY_QUEUE_MAX_OVERDUE};
use offline_protocol_reliability::{AckConfig, DeduplicatorConfig, RetryConfig};
use offline_protocol_router::{DorsConfig, RelayConfig};
use serde::{Deserialize, Serialize};
use std::sync::Arc;

/// Overflow policy for bounded pending encrypted message queues.
#[derive(Debug, Clone, Copy, Default, PartialEq, Eq, Serialize, Deserialize)]
#[serde(rename_all = "snake_case")]
pub enum OverflowPolicy {
    /// Evict the oldest queued message to make room for the new message.
    #[default]
    DropOldest,
    /// Drop the newly received message when capacity is reached.
    DropNewest,
}

/// Configuration for inbound encrypted messages received before session readiness.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct PendingQueueConfig {
    /// Maximum number of pending encrypted messages per peer.
    pub max_pending_per_peer: usize,
    /// Maximum number of pending encrypted messages across all peers.
    pub max_pending_global: usize,
    /// Maximum total payload bytes (content plus binary content) queued per
    /// peer.
    ///
    /// Encrypted media chunks are queued whole while the sender's session is
    /// not yet ready, so the count limits alone would admit up to
    /// `max_pending_per_peer` × chunk-size bytes of ciphertext. The default
    /// (4 MB) covers the largest legitimate pre-session backlog: 2 concurrent
    /// transfers × 8 in-flight chunks × 256 KB internet chunks.
    #[serde(default = "default_max_pending_bytes_per_peer")]
    pub max_pending_bytes_per_peer: usize,
    /// Maximum total payload bytes queued across all peers. The default
    /// (32 MB) bounds worst-case queue memory on mobile devices regardless of
    /// how many peers are mid-establishment.
    #[serde(default = "default_max_pending_bytes_global")]
    pub max_pending_bytes_global: usize,
    /// Time-to-live for pending encrypted messages in milliseconds.
    pub pending_ttl_ms: u64,
    /// Overflow policy when queue limits are reached.
    pub overflow_policy: OverflowPolicy,
}

/// Default TTL for the pending-decryption queue (24 hours, in ms).
///
/// Under the deferred-ACK model an undecryptable message is no longer ACKed on
/// receipt, so this queue is the primary recovery window before the session
/// confirms — a 2-minute window was too short for a peer whose Welcome is slow
/// to arrive/adopt, and 30 minutes was too short once the queue became
/// durable: with a relay that pushes ciphertext without store-and-forward
/// there is no second copy, so a frame that arrives while the recipient's
/// session is still being set up has to outlive the handshake, which for a
/// phone that is opened once a day means a day. Memory stays bounded by the
/// per-peer/global byte caps plus the `DropOldest` overflow policy; a longer
/// TTL only lets entries linger within those caps, it does not raise the
/// ceiling. The TTL is measured on an `Instant` and so restarts with the
/// process; the persisted copy is bounded separately by
/// `PENDING_DECRYPT_PERSISTED_MAX_AGE_MS` (7 days).
///
/// The UniFFI `PendingQueueConfig` default mirrors this value — reference this
/// constant there rather than re-hardcoding it.
pub const DEFAULT_PENDING_TTL_MS: u64 = 86_400_000;

fn default_max_pending_bytes_per_peer() -> usize {
    4 * 1024 * 1024
}

fn default_max_pending_bytes_global() -> usize {
    32 * 1024 * 1024
}

impl Default for PendingQueueConfig {
    fn default() -> Self {
        Self {
            max_pending_per_peer: 64,
            max_pending_global: 4096,
            max_pending_bytes_per_peer: default_max_pending_bytes_per_peer(),
            max_pending_bytes_global: default_max_pending_bytes_global(),
            // 24 hours; see DEFAULT_PENDING_TTL_MS for the deferred-ACK
            // rationale and the FFI-mirror contract.
            pending_ttl_ms: DEFAULT_PENDING_TTL_MS,
            overflow_policy: OverflowPolicy::DropOldest,
        }
    }
}

/// Encryption configuration for automatic MLS handling.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct EncryptionConfig {
    /// Whether automatic encryption is enabled.
    /// When enabled, messages are automatically encrypted/decrypted using MLS.
    pub enabled: bool,

    /// Auto-exchange key packages on peer discovery.
    /// When enabled, key packages are automatically sent when neighbors are discovered.
    pub auto_key_exchange: bool,

    /// Store pending messages when no session exists.
    /// Messages will be sent automatically after the session is established.
    pub store_pending: bool,

    /// Require encryption for messages (default: `true`).
    ///
    /// When enabled, sends fail closed if encryption cannot be applied:
    /// with MLS uninitialized every send returns [`crate::Error::EncryptFailed`],
    /// and with no confirmed session messages are queued (when
    /// `store_pending` is set) or fail with
    /// [`crate::Error::SessionNotReady`] instead of ever leaving as
    /// plaintext. Inbound plaintext content — text messages and legacy
    /// media alike — is rejected without being surfaced to the app
    /// (plaintext carries no sender authentication, so anyone could
    /// inject it under a contact's name); each rejection emits a
    /// [`crate::events::SecurityWarningCode::PlaintextReceiveRejected`]
    /// warning, once per peer. Even under the opt-out, inbound plaintext
    /// from a peer *known to run MLS* is rejected as a downgrade/forgery
    /// attempt — see `OfflineProtocol::encryption_capable_peers`. A
    /// confirmed session is not required, and deliberately so: an honest
    /// peer queues rather than downgrading while a session is pending, so
    /// cleartext from a peer we know speaks MLS is never legitimate.
    /// Peers that have shown no MLS signal stay readable, which is what
    /// makes this opt-out usable for legacy interop.
    ///
    /// Disable only for deployments that deliberately send cleartext
    /// (e.g. open broadcast/mesh bootstrap without provisioned MLS
    /// storage) — set this to `false` explicitly, or use
    /// [`EncryptionConfig::disabled`] to turn encryption off entirely.
    /// Every plaintext send then emits a
    /// [`crate::events::SecurityWarningCode::PlaintextSend`] warning
    /// (once per peer). Internal control messages (key exchange, ACKs,
    /// service discovery) are exempt and unaffected.
    pub require_encryption: bool,

    /// Bounds and eviction policy for pending inbound encrypted messages.
    pub pending_queue: PendingQueueConfig,

    /// Whether to negotiate and emit the compact MLS envelope for encrypted
    /// messages (base64 of the binary `EncryptedMessage` form instead of JSON
    /// with an integer-array ciphertext — roughly 2.7x smaller).
    ///
    /// Defaults to `true`. It only takes effect toward recipients that
    /// advertise support in their key package (`env_versions`), so a mixed
    /// fleet automatically stays on the JSON envelope. Parsing of inbound
    /// compact envelopes is always on, independent of this flag; this gates
    /// only advertising and emitting. The end-to-end sibling of
    /// [`TransportConfig::binary_wire_enabled`], with an independent kill
    /// switch because the two degrade separately.
    pub compact_envelope_enabled: bool,

    /// Whether to negotiate and seal the rich `__RICH_V1__` payload for
    /// encrypted messages: quoted-reply context, rich media metadata, and
    /// forward attribution carried *inside* the MLS ciphertext instead of on
    /// the relay-visible outer message.
    ///
    /// Defaults to `true`. It only takes effect toward recipients that
    /// advertise support in their key package (`rich_versions`); toward
    /// everyone else the rich extras are silently dropped — never sent
    /// cleartext. Parsing of inbound sealed payloads is always on,
    /// independent of this flag; this gates only advertising and sealing.
    /// Independent kill switch from
    /// [`EncryptionConfig::compact_envelope_enabled`] — the two degrade
    /// separately.
    pub rich_payload_enabled: bool,

    /// Whether to recover an inbound encrypted message that failed to decrypt,
    /// rather than silently dropping it while telling the sender it was
    /// delivered.
    ///
    /// Defaults to `true`. When enabled, an inbound encrypted DM (or media
    /// chunk) that fails to decrypt is **not delivery-ACKed** and its id is not
    /// left dedup-marked, so the sender keeps retrying instead of marking it
    /// delivered — and each resend of a DM is re-sealed against the peer's
    /// current session, so a resend can actually land. A message that stays
    /// undeliverable settles as an honest `MessageFailed` once the sender's
    /// retry budget lapses. When disabled, every decrypt failure falls back to
    /// the legacy drop-and-ACK behavior.
    ///
    /// **Only an epoch mismatch additionally triggers a re-key.** A decrypt
    /// failure *specifically* because the two sides disagree on the MLS epoch
    /// (e.g. after a fork) also starts a rate-limited `session_reset`
    /// key-package exchange to rebuild the channel. Failures that are *not* an
    /// epoch mismatch — an AEAD / authentication failure, a discarded past
    /// ratchet generation, a malformed frame — withhold the ACK but never
    /// re-key: widening the re-key trigger to cover them would turn every
    /// malformed frame into a teardown, which is an unbounded churn vector.
    /// That separation is why the two classifications stay distinct.
    ///
    /// One consequence worth planning for: `MessageDecryptionFailed` is
    /// **advisory, not terminal**, and fires once per failed *attempt* rather
    /// than once per message. Treat it as "this attempt did not decrypt", and
    /// read `MessageFailed` (or `FileReceiveFailed` for media) as the terminal
    /// signal.
    ///
    /// **The re-key trigger is unauthenticated, by construction — do not read
    /// this switch as "only genuine peers can cause a re-key".** An MLS epoch is
    /// checked during *framing* validation, which happens before any AEAD,
    /// sender-data, or signature check, and a 1:1 session slot id is derivable
    /// from two public user ids. A hand-built frame carrying a wrong epoch
    /// therefore reaches the recoverable classification with its sender still
    /// entirely unverified: any party who can inject a frame can drive a re-key,
    /// with no key material, no captured ciphertext and no session
    /// (`test_forged_frame_reaches_session_desync_without_any_key_material`
    /// builds one from scratch). This is inherent to MLS framing, not a defect,
    /// and cannot be authenticated away — the credential a sender check would
    /// compare against only exists once decrypt *succeeds*.
    ///
    /// What makes that safe is that acting on the trigger is **harmless**, not
    /// that it is trusted: the re-key is confined to the claimed sender's own
    /// session slot (so one derivable id cannot be aimed at other peers), is
    /// rate-limited to one per peer per 30 s, discards no queued message, and
    /// emits a `SESSION_REKEY_TRIGGERED` security warning so a sustained rate —
    /// injection rather than a real fork — is visible to the app. The residual
    /// is bounded re-key churn on a single pair: delivery delayed, never lost.
    /// `OfflineProtocol::schedule_session_rekey` carries the full analysis.
    ///
    /// **The split-session heal is not governed by this switch.** Any ordinary
    /// decrypt failure on a 1:1 session asks the peer to corroborate it, and
    /// only a signed answer to that side's own live challenge, showing the two
    /// hold different groups, makes the greater side give up its group (ADR
    /// 0033). That trigger is authenticated, unlike the epoch re-key above, so
    /// turning recovery off does not turn it off.
    pub crypto_recovery_enabled: bool,

    /// Whether service request and response bodies (`__SVC_REQ__`,
    /// `__SVC_RESP__`) are sealed inside the recipient's 1:1 MLS session
    /// instead of crossing every hop as signed plaintext.
    ///
    /// Defaults to `true`. It takes effect only toward a peer that advertised
    /// `svc_versions` entry 1 in a signed key package (or proved it by sending
    /// a sealed service frame) and only once the session with that peer is
    /// confirmed. Toward everyone else, and before the session confirms, the
    /// body still leaves as signed plaintext, because that form is the floor
    /// every older peer depends on: the first request to a provider this
    /// device has never met is readable by the hops that carry it. Discovery
    /// (`__SVC_DISC_Q__` / `__SVC_DISC_R__`) is never sealed, since every hop
    /// must read it to match and forward.
    ///
    /// Gates advertising, recording and emitting. Routing an inbound sealed
    /// service frame is unconditional, so switching this off never makes a
    /// peer's sealed request surface as chat text.
    #[serde(default = "default_encrypt_service_messages")]
    pub encrypt_service_messages: bool,
}

/// The default for [`EncryptionConfig::encrypt_service_messages`], by name so
/// a config serialized before the field existed still parses, and parses on.
fn default_encrypt_service_messages() -> bool {
    true
}

impl Default for EncryptionConfig {
    fn default() -> Self {
        Self {
            enabled: true,
            auto_key_exchange: true,
            store_pending: true,
            // Fail closed by default (SEC-M3): a stock-config node must never
            // silently degrade to plaintext because MLS was left uninitialized.
            require_encryption: true,
            pending_queue: PendingQueueConfig::default(),
            compact_envelope_enabled: true,
            rich_payload_enabled: true,
            crypto_recovery_enabled: true,
            encrypt_service_messages: true,
        }
    }
}

impl EncryptionConfig {
    /// Creates a new encryption config with encryption disabled.
    pub fn disabled() -> Self {
        Self {
            enabled: false,
            auto_key_exchange: false,
            store_pending: false,
            require_encryption: false,
            pending_queue: PendingQueueConfig::default(),
            compact_envelope_enabled: false,
            rich_payload_enabled: false,
            crypto_recovery_enabled: false,
            encrypt_service_messages: false,
        }
    }
}

/// Security configuration for transport and control-message hardening.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct SecurityConfig {
    /// When `true`, control messages with no transport-level peer identity
    /// (`transport_peer_id` is `None`) are rejected. When `false` (default),
    /// missing transport identity emits a `SecurityWarning` but allows the
    /// message through (best-effort / fail-open).
    ///
    /// # Why the default (`false`) is not the weak setting it once was
    ///
    /// This flag used to carry real weight, because a forged `sender` was
    /// otherwise cheap: identities were app-chosen strings and the only thing
    /// standing behind one was a trust-on-first-use pin, so first contact with
    /// any peer was open to a man-in-the-middle and transport identity was the
    /// only independent corroboration available.
    ///
    /// Under self-certifying addressing it is not. Every security-gated control
    /// frame must now carry an Ed25519 signature — unconditionally, no longer
    /// gated on this flag — and the signing key must derive to the address in
    /// `sender`. A forged `sender` therefore requires the private key behind
    /// that address, on first contact as much as on the thousandth. Transport
    /// identity adds no authenticity on top of that; it only cross-checks a
    /// claim the signature already proved.
    ///
    /// The strict match on frames claiming direct origin (`hop_count == 0`) runs
    /// regardless of this flag, as it always has, and is unaffected.
    ///
    /// # What enabling it still does, and what it costs
    ///
    /// Exactly one thing: control frames arriving with **no** transport identity
    /// at all are rejected instead of falling through to the signature gate.
    ///
    /// That is a real cost with no matching benefit on most deployments. Nostr
    /// frames carry no transport identity by construction — the Nostr pubkey is
    /// an install signing key, not the protocol id, so attaching it would fail
    /// the strict match (see `nostr_message_received_inner`) — and relay frames
    /// that arrive without a named sender are in the same position. Turning this
    /// on rejects **every** control message on those paths, including the
    /// key-package exchange that cold contact depends on. Mesh-forwarded frames
    /// re-created by intermediate nodes legitimately lack identity too.
    ///
    /// Set to `true` only on a deployment that runs neither Nostr nor
    /// sender-less relay delivery, and wants frames without transport identity
    /// refused as a matter of policy rather than of authentication.
    pub require_transport_identity: bool,

    /// Whether a control frame is refused for being stale, and whether a peer
    /// that has proved it signs the freshness-bound payload is held to it.
    ///
    /// Defaults to `true`. With it on, a control frame signed under
    /// `offline-ctrl-v2` is checked against
    /// [`CTRL_FRESHNESS_PAST_MS`](offline_protocol_sealed::CTRL_FRESHNESS_PAST_MS)
    /// and its future counterpart, a peer that once verifiably signed v2 may
    /// not fall back to v1, and a `session_reset` is honoured only on a frame
    /// whose freshness was actually checked. With it off, this node behaves
    /// exactly as it did before any of that existed: signatures are still
    /// verified, and no frame is refused for its age.
    ///
    /// # What it is for
    ///
    /// The timestamp is read against *this device's* clock, so the failure
    /// this switch exists for is a clock, not a peer. A device that comes up
    /// with an unset clock reads every honest peer's frame as being from
    /// decades in the future and refuses all of them, which takes out the
    /// whole control plane — key package exchange included — for as long as
    /// the clock is wrong. That is a self-inflicted outage a shipped app
    /// cannot wait for a new binary to fix, which is why the lever exists and
    /// why it reaches the bindings rather than staying internal.
    ///
    /// # What turning it off costs
    ///
    /// A captured control frame verifies forever again, and a recorded
    /// `session_reset` is once more a repeatable way to tear down a live
    /// session (issue 403). It is a diagnosis and recovery tool, not a
    /// configuration a deployment should settle on.
    pub control_freshness_enforced: bool,
}

impl Default for SecurityConfig {
    fn default() -> Self {
        Self {
            // Fail-open, and safe to: see the field's own documentation for
            // why transport identity adds no authenticity over a signature
            // that must derive to the sender's address.
            require_transport_identity: false,
            // Fail-closed, like `require_encryption`: a freshness check that
            // has to be switched on is one that is off on every install that
            // never heard about it.
            control_freshness_enforced: true,
        }
    }
}

/// Transport-specific configuration.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct TransportConfig {
    /// Whether BLE transport is enabled.
    pub ble_enabled: bool,

    /// Whether Wi-Fi Direct transport is enabled.
    pub wifi_direct_enabled: bool,

    /// Whether Internet transport is enabled.
    pub internet_enabled: bool,

    /// Whether Reticulum mesh transport is enabled.
    /// Defaults to `false` because Reticulum requires external infrastructure
    /// (a running Reticulum daemon or RNode hardware).
    pub reticulum_enabled: bool,

    /// Whether Nostr relay transport is enabled.
    /// Defaults to `false` because Nostr requires relay configuration
    /// and a secp256k1 keypair.
    pub nostr_enabled: bool,

    /// Whether outgoing Nostr frames are sealed into NIP-59 gift wraps.
    ///
    /// Defaults to `true`. With it off, the transport publishes the legacy
    /// kind-4 event whose content is the whole protocol envelope in cleartext —
    /// both usernames, the app id, the metadata map, the content type and a
    /// millisecond timestamp, readable by every relay, permanently. Turn it off
    /// only to interoperate with a relay that rejects kind 1059 outright.
    ///
    /// Send-side only, and never negotiated: inbound gift wraps are always
    /// unsealed and inbound legacy frames always parsed, so whatever this is
    /// set to, anything a peer sends us stays readable.
    ///
    /// It does still affect *outbound* reachability, in the one direction the
    /// receive path cannot cover. A peer on a build that predates sealing
    /// subscribes with `kinds: [4]` only, so it is never handed our kind-1059
    /// events and has no NIP-44 layer to open one with — leaving it on makes
    /// such a peer unreachable over Nostr (visibly: no ACK returns, so the
    /// send fails through the retry ladder rather than vanishing). That is the
    /// second reason to turn this off, alongside a relay that rejects
    /// kind 1059.
    pub nostr_sealing_enabled: bool,

    /// Whether this install publishes MLS key packages to the relays and
    /// resolves peers' published packages.
    ///
    /// Defaults to `true`, and takes effect only when `nostr_enabled` is on —
    /// which is itself off by default, so nothing is published unless an app
    /// deliberately turns Nostr on.
    ///
    /// Buys **cold first contact**: a peer known only by address becomes
    /// reachable over Nostr with no prior key-package exchange over some other
    /// transport, which is otherwise impossible. A send to, or a session
    /// asked for with, a peer this device holds no key package for asks the
    /// relays for one that peer published. It also bounds the sealing
    /// downgrade that follows a peer-key eviction, since a forgotten key is
    /// re-resolved on the next send instead of waiting for a fresh exchange.
    ///
    /// **What it costs is worth stating plainly.** Publication is the first
    /// thing this SDK emits to a relay unprompted: a small set of addressable
    /// records sits at this install's routing tag and is refreshed as slots are
    /// consumed, whether or not any message is ever sent. Their *content* is
    /// sealed — a scraper filtering on the kind alone reads nothing, which
    /// matters because an MLS key package carries its owner's username in the
    /// leaf credential and cannot be stripped of it — but the existence of a
    /// record at a given tag, and the timing of its refreshes, are visible to
    /// every relay published to. Turn this off to keep the transport silent
    /// until it has traffic, at the price of cold contact.
    pub nostr_cold_contact_enabled: bool,

    /// Whether this install publishes a username discovery record and can
    /// resolve usernames to the devices claiming them.
    ///
    /// Defaults to **`false`**, unlike `nostr_cold_contact_enabled`, and gates
    /// publication and resolution together. It also *requires* cold contact:
    /// a discovery record points at an address whose key packages are what a
    /// resolver fetches next, so with cold contact off the claim resolves and
    /// then dead-ends one hop later. The two are hard-coupled in the transport
    /// rather than merely documented.
    ///
    /// Buys back **reach by username**, which the addressing migration removed:
    /// a stranger who knows only a name can find the addresses claiming it and
    /// open a session. The name is published as the app's configured `profile`,
    /// normalized to NFC and lowercase.
    ///
    /// **Default-off is the deliberate choice, and the reason is disclosure.**
    /// Publishing binds a human-readable name to an address in a public place.
    /// That is materially more than the key-package record's "an install with
    /// this tag exists": the mapping *is* the payload. The record is sealed to
    /// a key derived from the username, so a relay scraping by kind alone reads
    /// nothing, but anyone who guesses the name can compute the tag, confirm a
    /// claim exists, and read it. That is the same class of exposure a public
    /// user directory has, and it is a decision an app should make explicitly.
    ///
    /// **What the directory is not: authoritative.** Anyone may publish any
    /// claim at any name. Every record is a claim that *some key* asserts a
    /// name, and a resolution returns the whole set of claimants with their
    /// verification status. An app that silently picks the first result has
    /// converted a non-authoritative directory into an authoritative-looking
    /// one; the user must confirm out of band. See
    /// `docs/spec/username-discovery.md`.
    pub nostr_username_discovery_enabled: bool,

    /// Whether to negotiate and emit the compact binary wire codec.
    ///
    /// Defaults to `true`. It only takes effect between two peers that both
    /// advertise support (via their signed key package), so a mixed fleet
    /// automatically stays on JSON. Decoding of binary frames is always on,
    /// independent of this flag; this gates only advertising and emitting.
    pub binary_wire_enabled: bool,
}

impl Default for TransportConfig {
    fn default() -> Self {
        Self {
            ble_enabled: true,
            wifi_direct_enabled: true,
            internet_enabled: true,
            reticulum_enabled: false,
            nostr_enabled: false,
            nostr_sealing_enabled: true,
            nostr_cold_contact_enabled: true,
            nostr_username_discovery_enabled: false,
            binary_wire_enabled: true,
        }
    }
}

/// Reliability configuration combining ACK, retry, and deduplication settings.
#[derive(Debug, Clone, Default)]
pub struct ReliabilityConfig {
    /// ACK manager configuration.
    pub ack: AckConfig,

    /// Retry queue configuration.
    pub retry: RetryConfig,

    /// Deduplicator configuration.
    pub dedup: DeduplicatorConfig,
}

/// Configuration for group messaging.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct GroupConfig {
    /// Maximum number of members allowed in a single group.
    ///
    /// Per-member fan-out is O(N) when using mesh transports.
    /// This cap prevents unbounded groups from overwhelming the network.
    pub max_group_members: usize,

    /// Whether to attempt relay server registration for groups.
    ///
    /// When `true` (default), groups are registered with the relay server
    /// for optimized fan-out when Internet transport is available.
    /// When `false`, groups always use per-member fan-out regardless of
    /// transport.
    ///
    /// This gates *registration* only — the relay group registry is what
    /// invite links resolve against, so it stays on independently of
    /// [`Self::relay_broadcast_enabled`].
    pub relay_enabled: bool,

    /// Whether a relay-synced group may send via a single O(1) relay
    /// broadcast instead of per-member fan-out.
    ///
    /// **Default `true`, and additionally gated on the relay's advertised
    /// capabilities.** The flag alone does not select the broadcast: the
    /// path is taken only when the connected relay also advertised the
    /// `group_delivery_v3` capability in its `Authenticated` answer (v3 =
    /// the v2 settled-report contract plus an address-aware group path —
    /// members named in the identifier space the roster was registered in,
    /// so the report is comparable against the MLS roster). Against
    /// such a relay the broadcast keeps a delivery contract — the relay
    /// answers every broadcast with a *settled* per-recipient delivery
    /// report (`GroupMessageSent`) naming who took the message over a
    /// socket and who took a device push, and the SDK re-sends a per-member
    /// copy through the ordinary outbox/ACK/park ladder to every MLS roster
    /// member the report does not account for. A lost report re-sends the
    /// broadcast under the same logical message id (receiver and push dedup
    /// absorb the duplicate fan-out) a bounded number of times, then
    /// downgrades the message to full per-member fan-out. Against an older
    /// relay the capability gate fails and every send takes per-member
    /// fan-out — the fire-and-forget broadcast of the v1 relay (no presence
    /// check, no push fallback, no persistence, "sent" answered before
    /// delivery was known) is never taken, regardless of this flag.
    ///
    /// The one gap on the broadcast path: the tracker awaiting the report
    /// lives in memory only, so a process death inside the report window
    /// (up to `RELAY_BROADCAST_REPORT_TIMEOUT_SECS` per attempt) loses the
    /// backstop with it — members the relay could not reach get no
    /// per-member re-send, and nothing retries on restart. It needs both a
    /// missed member and a kill in that window, and is strictly smaller than
    /// the pre-report broadcast's exposure, but it is a real difference from
    /// per-member fan-out, whose outbox entries persist for 7 days.
    ///
    /// Set `false` to force per-member fan-out even against a v2 relay —
    /// the right choice for an app that must not lose a group message to a
    /// mid-flight process kill.
    /// Per-member fan-out (`__GRP_MLS_MSG__` as ordinary `SendMessage`
    /// frames) inherits the full DM ladder end to end — outbox + ACK +
    /// retry, relay write-ack + successor retry + offline push carrying the
    /// ciphertext, park-on-unreachable with presence-driven flush, and
    /// receiver-side deferred-ACK-after-decrypt — at the cost of O(N)
    /// uplink frames per send.
    ///
    /// O(N) fan-out does **not** risk tripping the relay's rate limiter at
    /// any group size. The platform bridge meters every relay-bound frame
    /// through a client-side token bucket (`RelayRateLimiter`: 28 capacity,
    /// 9/s refill) deliberately tighter than the relay's (30 burst, 10/s),
    /// and a frame that cannot take a token is *deferred to a later poll
    /// tick*, never dropped — so client spend stays at `28 + 9t` against a
    /// server budget of `30 + 10t` and the fan-out self-paces below it
    /// regardless of member count. Core enqueues all N frames at once; the
    /// bridge drains that queue.
    ///
    /// What large groups actually cost on the per-member path is drain
    /// latency. Frame N reaches the wire at roughly `(N - 28) / 9` seconds.
    /// Since the ACK timer starts at local *enqueue* (`handle_send_success`)
    /// and not at wire-confirm — `on_transport_send_confirmed` advances only
    /// the welcome lifecycle — past roughly 118 members the tail of a single
    /// fan-out exceeds the 10s ACK timeout and is retransmitted by the
    /// ladder before it was ever written. That is wasted duplicate frames,
    /// absorbed by receiver and push dedup via the stable outbox id, not
    /// lost messages. Presence checks, typing, and receipts draw on the same
    /// bucket and lower the threshold. This is the strongest reason to leave
    /// the broadcast enabled for large groups.
    pub relay_broadcast_enabled: bool,

    /// Whether an incoming MLS membership commit is refused when the local
    /// admin overlay does not authorize its committer.
    ///
    /// **Off by default, and turning it on is a decision about partition
    /// risk, not a hardening toggle.** Refusing a commit means declining the
    /// MLS merge: our epoch stays behind every member who did merge, and MLS
    /// has no way back — the application has to re-invite us. Enforcement is
    /// therefore fork-free only if every member reaches the *same* verdict,
    /// and the admin overlay is replicated best-effort (role changes ride
    /// unreconciled mesh notifications; a joiner gets a point-in-time
    /// snapshot). Two members whose role maps merely disagree will partition
    /// each other with no attacker involved.
    ///
    /// The check fails open on every *absent* input — no metadata, no admin
    /// role stored, an unreadable roster — so the common lag case stays
    /// harmless. It cannot detect *divergent* views, which is the residual
    /// risk that keeps this opt-in. Enable it only for a closed deployment
    /// that controls role distribution.
    ///
    /// With it off (the default), unauthorized membership changes are still
    /// applied and reported: `group_unauthorized_membership_change` fires and
    /// the roster events carry `authorized: false`. That reporting is
    /// unaffected by this flag; the flag only decides whether the commit is
    /// *also* refused.
    ///
    /// Rejection is receiver-local. The sender's message is still ACKed, so
    /// a committer gets no signal that anyone refused, and members with the
    /// flag off will apply a commit that members with it on rejected — do not
    /// enable it on part of a fleet.
    #[serde(default)]
    pub enforce_admin_commits: bool,
}

impl Default for GroupConfig {
    fn default() -> Self {
        Self {
            max_group_members: 256,
            relay_enabled: true,
            relay_broadcast_enabled: true,
            enforce_admin_commits: false,
        }
    }
}

/// Configuration for the replicated-document data layer.
///
/// [`Self::enabled`] governs the whole layer: with it off no documents are
/// opened, nothing is persisted, and no capability is advertised to peers.
#[derive(Clone, Serialize, Deserialize)]
pub struct DataConfig {
    /// Whether the data layer accepts work at all.
    ///
    /// **Defaults to `true`.** It defaulted to `false` while the layer could
    /// store documents but not replicate them: advertising a capability with
    /// no sync behind it invites peers to expect a sync that never comes.
    /// Both halves land in the same release, so no application ever ran
    /// against the old default, and the switch is on.
    ///
    /// What being on costs an application that ignores documents entirely:
    /// nothing at rest and nothing on the wire. The layer allocates when a
    /// store is opened, and a capability is advertised in a key package that
    /// is sent anyway. What it buys is that an application that *does* open a
    /// store gets replication without discovering a flag.
    #[serde(default = "default_data_enabled")]
    pub enabled: bool,

    /// Where documents are stored, when the application wants them somewhere
    /// other than the store protocol state already uses.
    ///
    /// `None` — the default — means documents live in the same backend as the
    /// rest of protocol state, which is what makes the layer work with zero
    /// storage setup: every binding already ships a default provider.
    ///
    /// Setting it points documents at SQLite, RocksDB, files, a corporate
    /// store, or anything else implementing the same trait, while protocol
    /// secrets stay exactly where they are. The two concerns swap
    /// independently and the swap is a runtime choice: no rebuild, no cargo
    /// feature, and no change to any data API. Anything that makes this
    /// harder than assigning this field is a design regression.
    ///
    /// Sealing sits above this seam. An adapter is handed sealed bytes and
    /// never sees document content, so a custom backend cannot weaken the
    /// at-rest posture even by accident.
    ///
    /// # Logout
    ///
    /// `wipePersistedState` clears the account directory of the *default*
    /// provider. A custom backend is somewhere the bindings cannot know
    /// about, so an application that sets this must call the data layer's
    /// own wipe on logout, or documents outlive the account that made them.
    #[serde(skip)]
    pub storage: Option<Arc<dyn crate::protocol_state_storage::ProtocolStateStorage>>,
}

/// The default for [`DataConfig::enabled`], needed by name because `serde`
/// cannot ask a field's type for anything other than its own default.
fn default_data_enabled() -> bool {
    true
}

impl Default for DataConfig {
    fn default() -> Self {
        Self {
            enabled: default_data_enabled(),
            storage: None,
        }
    }
}

impl std::fmt::Debug for DataConfig {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        f.debug_struct("DataConfig")
            .field("enabled", &self.enabled)
            .field("storage", &self.storage.as_ref().map(|_| "<custom>"))
            .finish()
    }
}

/// How long a custodian holds a deposited frame by default: six hours.
///
/// Hours, not days, because a custodian holds ciphertext it cannot re-seal
/// (`docs/spec/custody.md`, invariant three): the depositor survives a
/// session re-key by re-sealing from retained plaintext, and the custodian's
/// copy has a validity horizon it cannot observe. Strictly under the seven-day
/// outbox lifetime by a wide margin, so the default configuration validates.
pub const DEFAULT_CUSTODY_HOLD_MS: u64 = 6 * 60 * 60 * 1000;

/// Held frames one depositor may have in custody at once, by default.
pub const DEFAULT_CUSTODY_MAX_ENTRIES_PER_DEPOSITOR: usize = 64;

/// Bytes one depositor may have in custody at once, by default: 2 MiB.
pub const DEFAULT_CUSTODY_MAX_BYTES_PER_DEPOSITOR: usize = 2 * 1024 * 1024;

/// Held frames across every depositor, by default.
pub const DEFAULT_CUSTODY_MAX_ENTRIES: usize = 512;

/// Bytes across every depositor, by default: 16 MiB.
pub const DEFAULT_CUSTODY_MAX_BYTES: usize = 16 * 1024 * 1024;

/// The smallest per-depositor byte budget that admits one replication frame at
/// its ceiling: 64 KiB.
///
/// A Class A frame carries at most 32 KiB of blob
/// (`data_sync::MAX_SYNC_BLOB_BYTES`), which base64 grows by a third, which
/// the MLS envelope then encodes again, so a sealed frame at the ceiling is
/// around 58 KiB of content with the outer message's addresses and metadata
/// on top. A byte cap below this admits no such frame and refuses every
/// deposit as `depositor_full`, which is the silent dial the `enabled` switch
/// exists to replace.
pub const CUSTODY_MIN_BYTES_PER_DEPOSITOR: usize = 64 * 1024;

/// Custody: holding a neighbour's replication frame for hours instead of the
/// seconds a forwarder gives it (`docs/spec/custody.md`).
///
/// Off by default, and every dial here is the custodian's. A device that
/// never enables it behaves exactly as before, and a device that enables it
/// takes on other people's ciphertext under the quotas below. The hold is
/// validated strictly shorter than `reliability.retry.outbox_max_lifetime_ms`,
/// because a custodian that outlived the depositor's outbox would deliver
/// frames whose sender already reported them failed.
#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
pub struct CustodyConfig {
    /// Whether this device accepts deposits. The off switch: refusing to hold
    /// other people's traffic is this dial's job, never a zeroed budget's.
    pub enabled: bool,
    /// How long an accepted frame is held, in milliseconds, judged in wall
    /// time from each record's acceptance timestamp against the value in
    /// force at the sweep. Lowering it expires records already held.
    pub hold_ms: u64,
    /// Held frames one depositor with an established session may have at once.
    pub max_entries_per_depositor: usize,
    /// Bytes one depositor with an established session may have at once.
    pub max_bytes_per_depositor: usize,
    /// Held frames across every depositor.
    pub max_entries: usize,
    /// Bytes across every depositor.
    pub max_bytes: usize,
    /// Held frames one proven peer *without* an established session may have
    /// at once. Zero, the default, means deposits are accepted only from peers
    /// with a session, which costs a key package exchange and is what makes
    /// the session tier resistant to an attacker who mints addresses for free.
    pub stranger_max_entries: usize,
    /// Bytes one proven peer without an established session may have at once.
    pub stranger_max_bytes: usize,
    /// What happens when a budget is full: evict the oldest held frame to
    /// admit the new one, or refuse the new one.
    pub overflow_policy: OverflowPolicy,
}

impl Default for CustodyConfig {
    fn default() -> Self {
        Self {
            enabled: false,
            hold_ms: DEFAULT_CUSTODY_HOLD_MS,
            max_entries_per_depositor: DEFAULT_CUSTODY_MAX_ENTRIES_PER_DEPOSITOR,
            max_bytes_per_depositor: DEFAULT_CUSTODY_MAX_BYTES_PER_DEPOSITOR,
            max_entries: DEFAULT_CUSTODY_MAX_ENTRIES,
            max_bytes: DEFAULT_CUSTODY_MAX_BYTES,
            stranger_max_entries: 0,
            stranger_max_bytes: 0,
            overflow_policy: OverflowPolicy::DropOldest,
        }
    }
}

/// Main configuration for the Offline Protocol.
#[derive(Debug, Clone)]
pub struct ProtocolConfig {
    /// Application identifier (required).
    ///
    /// Two jobs. It is one of the two inputs to the storage namespace, with
    /// [`Self::profile`], so changing it selects fresh storage and a fresh
    /// identity. And it is the id stamped on every frame this instance
    /// originates: messages, media chunks, acknowledgements and control
    /// traffic. A rich send may name another id for its own frame
    /// ([`crate::SendMessageOptions::app_id`]), which is how one instance
    /// serves several local applications behind one identity; the
    /// acknowledgements and control frames the engine sends always carry
    /// this one. The bindings also derive the BLE app tag from it.
    ///
    /// It is cleartext on the wire and covered by no signature, so every
    /// carrier and hop can read it and rewrite it (threat model R17). It
    /// names an application, so it is not secret, but treat it as routing
    /// metadata only: the receive path delivers a message whatever id it
    /// carries.
    pub app_id: String,

    /// Local profile selector (required).
    ///
    /// Selects which stored identity this instance runs as — one namespace per
    /// `(app_id, profile)` pair — so an app hosting several accounts gives each
    /// its own value, and an app hosting one can pass a constant like
    /// `"default"`.
    ///
    /// It is **not** the device's identity. The wire identity is the
    /// self-certifying address derived from the identity key held in this
    /// profile's storage: it is minted on first start, reported by
    /// [`crate::OfflineProtocol::local_address`], and it is what gets stamped
    /// as `Message.sender`, what peers see as `NeighborDiscovered.peer_id`,
    /// and what others use as `recipient`. An app cannot choose it, because
    /// choosing it would mean claiming a key one does not hold.
    ///
    /// Under any configuration that reaches the wire the profile stays local.
    /// The one exception is the explicit
    /// [`EncryptionConfig::require_encryption`]` = false` opt-out, which lets a
    /// plaintext send go out with MLS never initialized — no address has been
    /// derived at that point, so the frame carries the profile as its sender
    /// and the send emits
    /// [`crate::events::SecurityWarningCode::PlaintextSend`]. The default
    /// (`require_encryption = true`) fails such a send closed instead. Treat
    /// the profile as private if that opt-out is in use.
    pub profile: String,

    /// Transport configuration.
    pub transport: TransportConfig,

    /// DORS (Dynamic Offline Relay Switch) configuration.
    pub dors: DorsConfig,

    /// Relay management configuration: whether this device carries traffic
    /// for other people at all, and the battery floors under which it stops.
    pub relay: RelayConfig,

    /// How this device carries traffic for other people: how far frames
    /// travel, how many neighbors each is handed to, and the ceilings that
    /// keep forwarding from crowding the radio out.
    ///
    /// Whether to forward is [`Self::relay`]'s decision; this is the shape of
    /// it once the answer is yes.
    pub mesh_relay: MeshRelayConfig,

    /// Reliability layer configuration.
    pub reliability: ReliabilityConfig,

    /// Encryption configuration for automatic MLS handling.
    pub encryption: EncryptionConfig,

    /// Initial TTL (Time-To-Live) for messages.
    pub initial_ttl: u8,

    /// Mesh group messaging configuration.
    pub group: GroupConfig,

    /// Security configuration for transport and control-message hardening.
    pub security: SecurityConfig,

    /// Replicated-document data layer configuration.
    pub data: DataConfig,

    /// Custody: holding a neighbour's replication frames for hours. Off by
    /// default; see [`CustodyConfig`].
    pub custody: CustodyConfig,
}

impl ProtocolConfig {
    /// Creates a new protocol configuration.
    ///
    /// # Arguments
    ///
    /// * `app_id` - Application identifier
    /// * `profile` - Local profile selector (storage namespace, never on the wire)
    pub fn new(app_id: impl Into<String>, profile: impl Into<String>) -> Self {
        Self {
            app_id: app_id.into(),
            profile: profile.into(),
            transport: TransportConfig::default(),
            dors: DorsConfig::default(),
            relay: RelayConfig::default(),
            mesh_relay: MeshRelayConfig::default(),
            reliability: ReliabilityConfig::default(),
            encryption: EncryptionConfig::default(),
            initial_ttl: DEFAULT_INITIAL_TTL,
            group: GroupConfig::default(),
            security: SecurityConfig::default(),
            data: DataConfig::default(),
            custody: CustodyConfig::default(),
        }
    }

    /// Creates a builder for more granular configuration.
    pub fn builder(app_id: impl Into<String>, profile: impl Into<String>) -> ProtocolConfigBuilder {
        ProtocolConfigBuilder::new(app_id, profile)
    }

    /// Validates the configuration.
    ///
    /// # Returns
    ///
    /// Returns `Ok(())` if valid, `Err` with a description of the problem if invalid.
    pub fn validate(&self) -> crate::Result<()> {
        // Both become storage keys — `app_id` and `profile` are the two inputs
        // to the account namespace — so hold them to the same length cap and
        // charset ban as every other identifier rather than only rejecting the
        // empty string. Going through the core constructors keeps one policy
        // instead of a second copy that can drift. Catching this here turns a
        // later failure deep inside a storage backend into one clear
        // configuration error.
        offline_protocol_core::AppId::new(self.app_id.as_str())
            .map_err(|e| crate::Error::InvalidConfiguration(e.to_string()))?;

        offline_protocol_core::UserId::new(self.profile.as_str())
            .map_err(|e| crate::Error::InvalidConfiguration(e.to_string()))?;

        if self.initial_ttl == 0 {
            return Err(crate::Error::InvalidConfiguration(
                "initial_ttl must be greater than 0".to_string(),
            ));
        }

        if !self.transport.ble_enabled
            && !self.transport.wifi_direct_enabled
            && !self.transport.internet_enabled
            && !self.transport.reticulum_enabled
            && !self.transport.nostr_enabled
        {
            return Err(crate::Error::InvalidConfiguration(
                "At least one transport must be enabled".to_string(),
            ));
        }

        if self.reliability.ack.default_timeout_ms == 0 {
            return Err(crate::Error::InvalidConfiguration(
                "ack.default_timeout_ms must be greater than 0".to_string(),
            ));
        }

        if self.reliability.ack.max_pending_acks == 0 {
            return Err(crate::Error::InvalidConfiguration(
                "ack.max_pending_acks must be greater than 0".to_string(),
            ));
        }

        if self.reliability.retry.initial_delay_ms == 0 {
            return Err(crate::Error::InvalidConfiguration(
                "retry.initial_delay_ms must be greater than 0".to_string(),
            ));
        }

        if self.reliability.retry.max_delay_ms == 0 {
            return Err(crate::Error::InvalidConfiguration(
                "retry.max_delay_ms must be greater than 0".to_string(),
            ));
        }

        if self.reliability.retry.initial_delay_ms > self.reliability.retry.max_delay_ms {
            return Err(crate::Error::InvalidConfiguration(
                "retry.initial_delay_ms must be <= retry.max_delay_ms".to_string(),
            ));
        }

        if self.reliability.retry.outbox_max_lifetime_ms == 0
            || self.reliability.retry.outbox_max_lifetime_ms > i64::MAX as u64
        {
            return Err(crate::Error::InvalidConfiguration(
                "retry.outbox_max_lifetime_ms must be in 1..=i64::MAX".to_string(),
            ));
        }

        if self.reliability.retry.pending_message_max_lifetime_ms == 0 {
            return Err(crate::Error::InvalidConfiguration(
                "retry.pending_message_max_lifetime_ms must be greater than 0".to_string(),
            ));
        }

        if self.reliability.retry.pending_message_max_lifetime_ms > i64::MAX as u64 {
            return Err(crate::Error::InvalidConfiguration(
                "retry.pending_message_max_lifetime_ms must be <= i64::MAX".to_string(),
            ));
        }

        if !self.reliability.retry.backoff_multiplier.is_finite()
            || self.reliability.retry.backoff_multiplier < 1.0
        {
            return Err(crate::Error::InvalidConfiguration(
                "retry.backoff_multiplier must be finite and >= 1.0".to_string(),
            ));
        }

        // Checked outside the Bloom guard below, and that placement is the
        // whole point: these two are the *only* dedup fields the UniFFI
        // `DedupConfig` carries, so every constraint hidden behind
        // `use_bloom_filter` is unreachable from a binding caller. A zero here
        // is not a cosmetic problem — `Deduplicator` fails safe on the Bloom
        // parameters, but nothing fails safe on these. At
        // `max_tracked_messages == 0` the HashMap branch of `mark_seen` evicts
        // on every insert, so the map holds one id and duplicate suppression is
        // effectively off; `retention_time_secs == 0` expires every entry
        // immediately for the same net result.
        //
        // What this rejects is the *degenerate* value, and that is the whole of
        // the claim: a floor of 1 is not a floor on how well duplicates are
        // suppressed. `max_tracked_messages == 1` behaves indistinguishably
        // from `0`, and a two-second retention on a link whose retry backoff is
        // longer than that suppresses nothing either. Choosing a window wide
        // enough for the deployment is the application's call — the SDK refuses
        // only the values that cannot be a choice, because nothing downstream
        // spells them as a configuration error and the failure they produce
        // (silently re-delivered messages) does not look like a config bug.
        // Raising either floor to a policy minimum is a wider behavioural break
        // and would need its own decision.
        if self.reliability.dedup.max_tracked_messages == 0 {
            return Err(crate::Error::InvalidConfiguration(
                "reliability.dedup.max_tracked_messages must be greater than 0".to_string(),
            ));
        }

        if self.reliability.dedup.retention_time_secs == 0 {
            return Err(crate::Error::InvalidConfiguration(
                "reliability.dedup.retention_time_secs must be greater than 0".to_string(),
            ));
        }

        if self.reliability.dedup.use_bloom_filter {
            if self.reliability.dedup.bloom_filter_bits == 0 {
                return Err(crate::Error::InvalidConfiguration(
                    "reliability.dedup.bloom_filter_bits must be greater than 0".to_string(),
                ));
            }

            if self.reliability.dedup.bloom_hash_count == 0 {
                return Err(crate::Error::InvalidConfiguration(
                    "reliability.dedup.bloom_hash_count must be greater than 0".to_string(),
                ));
            }

            if self.reliability.dedup.bloom_filter_count == 0 {
                return Err(crate::Error::InvalidConfiguration(
                    "reliability.dedup.bloom_filter_count must be greater than 0".to_string(),
                ));
            }

            if self.reliability.dedup.bloom_rotation_secs == 0 {
                return Err(crate::Error::InvalidConfiguration(
                    "reliability.dedup.bloom_rotation_secs must be greater than 0".to_string(),
                ));
            }
        }

        if self.encryption.require_encryption && !self.encryption.enabled {
            return Err(crate::Error::InvalidConfiguration(
                "encryption.require_encryption requires encryption.enabled=true".to_string(),
            ));
        }

        if self.encryption.pending_queue.max_pending_per_peer == 0 {
            return Err(crate::Error::InvalidConfiguration(
                "encryption.pending_queue.max_pending_per_peer must be greater than 0".to_string(),
            ));
        }

        if self.encryption.pending_queue.max_pending_global == 0 {
            return Err(crate::Error::InvalidConfiguration(
                "encryption.pending_queue.max_pending_global must be greater than 0".to_string(),
            ));
        }

        if self.encryption.pending_queue.max_pending_global
            < self.encryption.pending_queue.max_pending_per_peer
        {
            return Err(crate::Error::InvalidConfiguration(
                "encryption.pending_queue.max_pending_global must be >= max_pending_per_peer"
                    .to_string(),
            ));
        }

        if self.encryption.pending_queue.pending_ttl_ms == 0 {
            return Err(crate::Error::InvalidConfiguration(
                "encryption.pending_queue.pending_ttl_ms must be greater than 0".to_string(),
            ));
        }

        if self.group.max_group_members == 0 {
            return Err(crate::Error::InvalidConfiguration(
                "group.max_group_members must be greater than 0".to_string(),
            ));
        }

        // A fan-out of zero is not a cheaper forward, it is a silent drop: the
        // frame has already been admitted and recorded as seen, so no copy goes
        // out and this node's suppression entry stops it arriving again by
        // another path. Same argument as `bias_min_scale` below — declining to
        // carry other people's traffic is `relay.allow_relay`'s job, and it is
        // visible. The forwarding paths clamp with `.max(1)`; rejecting zero
        // here keeps that clamp an unreachable defensive floor instead of a
        // silent rewrite of what zero means.
        if self.mesh_relay.fanout == 0 {
            return Err(crate::Error::InvalidConfiguration(
                "mesh_relay.fanout must be greater than 0".to_string(),
            ));
        }

        // The same argument as fan-out, for every other dial that can reach
        // zero. Each of these reads like a conservative setting and is in fact
        // an off switch that reports nothing: the failure is total, silent, and
        // indistinguishable from a quiet neighborhood, which is what makes
        // rejecting it at construction worth more than any runtime clamp.
        //
        // A hop ceiling of zero clamps every arriving budget to nothing, so
        // `prepare_hop` refuses the frame before it is ever queued. Both
        // ceilings are checked: the dense one applies only in a crowded room,
        // so a zero there fails exactly where the mesh is most needed and
        // nowhere else — the hardest version of this bug to reproduce.
        if self.mesh_relay.max_ttl == 0 {
            return Err(crate::Error::InvalidConfiguration(
                "mesh_relay.max_ttl must be greater than 0".to_string(),
            ));
        }

        if self.mesh_relay.dense_max_ttl == 0 {
            return Err(crate::Error::InvalidConfiguration(
                "mesh_relay.dense_max_ttl must be greater than 0".to_string(),
            ));
        }

        // A queue that holds nothing refuses every admission: the length is
        // always at or over capacity, and eviction has no victim to find, so
        // each frame is rejected as queue-full. Nothing is forwarded and the
        // only trace is `refused_queue_full`.
        if self.mesh_relay.queue_capacity == 0 {
            return Err(crate::Error::InvalidConfiguration(
                "mesh_relay.queue_capacity must be greater than 0".to_string(),
            ));
        }

        // The rate and burst dials feed token buckets that clamp their inputs
        // with `.max(0.0)`. That clamp makes a negative or NaN value safe in
        // the arithmetic sense and catastrophic in every other: the bucket
        // simply never yields a token, so forwarding stops for good with no
        // error and no counter. NaN matters on its own because `f32::max`
        // returns the *other* operand for it, so a NaN rate silently becomes
        // zero rather than propagating anywhere visible.
        //
        // Checked as a set: they are the same failure, and naming the field in
        // the message is what makes a rejected config actionable.
        for (name, value) in [
            ("rate_per_sec", self.mesh_relay.rate_per_sec),
            ("burst", self.mesh_relay.burst),
            ("peer_rate_per_sec", self.mesh_relay.peer_rate_per_sec),
            ("peer_burst", self.mesh_relay.peer_burst),
        ] {
            if !value.is_finite() || value <= 0.0 {
                return Err(crate::Error::InvalidConfiguration(format!(
                    "mesh_relay.{name} must be finite and greater than 0"
                )));
            }
        }

        // Capability bias scales forwarding effort; it must never be able to
        // scale it to nothing. Zero would make a low-battery device stop
        // forwarding by the back door, which is the partition the bias design
        // exists to avoid — refusing to relay is `relay.allow_relay`'s job.
        if !self.mesh_relay.bias_min_scale.is_finite()
            || self.mesh_relay.bias_min_scale <= 0.0
            || self.mesh_relay.bias_min_scale > 1.0
        {
            return Err(crate::Error::InvalidConfiguration(
                "mesh_relay.bias_min_scale must be finite and in (0.0, 1.0]".to_string(),
            ));
        }

        // An inverted jitter window is not a narrow window, it is two separate
        // failures. `jitter_for` raises the effective maximum to meet the
        // minimum, so the span collapses to a single millisecond and every
        // neighbor picks essentially the same delay — losing the spread that
        // stops a crowded room transmitting on top of itself, which is the
        // whole reason the delay exists. And because the check below reads
        // `jitter_max`, an oversized `jitter_min` would slip past the overdue
        // cut-off entirely: a ten-minute minimum with the default maximum
        // validates clean and abandons every forward.
        if self.mesh_relay.jitter_min > self.mesh_relay.jitter_max {
            return Err(crate::Error::InvalidConfiguration(format!(
                "mesh_relay.jitter_min ({}ms) must not exceed mesh_relay.jitter_max ({}ms)",
                self.mesh_relay.jitter_min.as_millis(),
                self.mesh_relay.jitter_max.as_millis(),
            )));
        }

        // A forward is abandoned rather than sent once it sits
        // `RELAY_QUEUE_MAX_OVERDUE` past its due time, so the delay tunables
        // must not be able to reach that on their own. Checked at the density
        // the jitter span is configured for; the span also grows with neighbor
        // count, which is a runtime quantity this cannot see and a documented
        // ceiling of the mesh's venue-sized target rather than a config error.
        let worst_delay = self
            .mesh_relay
            .jitter_max
            .saturating_add(self.mesh_relay.bias_max_handicap);
        if worst_delay >= RELAY_QUEUE_MAX_OVERDUE {
            return Err(crate::Error::InvalidConfiguration(format!(
                "mesh_relay.jitter_max + mesh_relay.bias_max_handicap ({}ms) must stay under \
                 the {}ms overdue cut-off, or every biased forward is abandoned instead of sent",
                worst_delay.as_millis(),
                RELAY_QUEUE_MAX_OVERDUE.as_millis(),
            )));
        }

        if self.mesh_relay.activity_window.is_zero() {
            return Err(crate::Error::InvalidConfiguration(
                "mesh_relay.activity_window must be greater than zero".to_string(),
            ));
        }

        if self.mesh_relay.activity_min_forwards == 0 {
            return Err(crate::Error::InvalidConfiguration(
                "mesh_relay.activity_min_forwards must be greater than 0".to_string(),
            ));
        }

        if self.mesh_relay.activity_idle_windows == 0 {
            return Err(crate::Error::InvalidConfiguration(
                "mesh_relay.activity_idle_windows must be greater than 0".to_string(),
            ));
        }

        self.validate_custody()?;

        Ok(())
    }

    /// The custody dials (`docs/spec/custody.md`, "Quotas").
    ///
    /// A zero hold is refused whatever the switch says: it is not a shorter
    /// hold, it is a store that expires everything at the first sweep. The
    /// remaining bounds are checked only while custody is enabled. The
    /// default hold is six hours, and a disabled section that could refuse a
    /// configuration whose outbox lifetime is shorter than that would turn
    /// every such configuration, which today holds nothing, into a startup
    /// error for a feature it never switched on.
    fn validate_custody(&self) -> crate::Result<()> {
        let custody = &self.custody;

        if custody.hold_ms == 0 {
            return Err(crate::Error::InvalidConfiguration(
                "custody.hold_ms must be greater than 0".to_string(),
            ));
        }

        if !custody.enabled {
            return Ok(());
        }

        // The inversion this refuses is silent: a custodian whose hold
        // outlives the depositor's outbox keeps bytes whose sender has already
        // reported the message failed, and delivers a frame to settle an entry
        // that no longer exists. Nothing at runtime would notice, because the
        // custodian cannot see the depositor's ladder.
        let outbox_lifetime_ms = self.reliability.retry.outbox_max_lifetime_ms;
        if custody.hold_ms >= outbox_lifetime_ms {
            return Err(crate::Error::InvalidConfiguration(format!(
                "custody.hold_ms ({}ms) must be strictly shorter than \
                 retry.outbox_max_lifetime_ms ({}ms): a hold that outlives the outbox \
                 delivers frames whose sender has already reported them failed",
                custody.hold_ms, outbox_lifetime_ms,
            )));
        }

        // The session tier is the one that admits anything by default, so a
        // zero there is custody switched on and holding nothing: the silent
        // dial `enabled` exists to replace.
        if custody.max_entries_per_depositor == 0 || custody.max_bytes_per_depositor == 0 {
            return Err(crate::Error::InvalidConfiguration(
                "custody.max_entries_per_depositor and custody.max_bytes_per_depositor must \
                 both be greater than 0 while custody is enabled: zero is not a smaller \
                 quota, it is a store that refuses every deposit"
                    .to_string(),
            ));
        }

        if custody.max_bytes_per_depositor < CUSTODY_MIN_BYTES_PER_DEPOSITOR {
            return Err(crate::Error::InvalidConfiguration(format!(
                "custody.max_bytes_per_depositor ({}) must admit one replication frame at \
                 its ceiling ({} bytes), or every deposit is refused as depositor_full",
                custody.max_bytes_per_depositor, CUSTODY_MIN_BYTES_PER_DEPOSITOR,
            )));
        }

        if custody.max_entries < custody.max_entries_per_depositor
            || custody.max_bytes < custody.max_bytes_per_depositor
        {
            return Err(crate::Error::InvalidConfiguration(
                "custody.max_entries and custody.max_bytes must each be at least their \
                 per-depositor sibling, or the per-depositor dial can never be reached"
                    .to_string(),
            ));
        }

        // The stranger tier is off by both dials or on by both. One at zero
        // with the other positive reads like a narrow allowance and is a
        // refusal of every stranger, which is the default said in a way an
        // operator would not recognise as the default.
        let stranger_on = custody.stranger_max_entries > 0 || custody.stranger_max_bytes > 0;
        if stranger_on && (custody.stranger_max_entries == 0 || custody.stranger_max_bytes == 0) {
            return Err(crate::Error::InvalidConfiguration(
                "custody.stranger_max_entries and custody.stranger_max_bytes must be both \
                 zero (no stranger deposits) or both greater than 0"
                    .to_string(),
            ));
        }

        if stranger_on && custody.stranger_max_bytes < CUSTODY_MIN_BYTES_PER_DEPOSITOR {
            return Err(crate::Error::InvalidConfiguration(format!(
                "custody.stranger_max_bytes ({}) must admit one replication frame at its \
                 ceiling ({} bytes), or every stranger deposit is refused as depositor_full",
                custody.stranger_max_bytes, CUSTODY_MIN_BYTES_PER_DEPOSITOR,
            )));
        }

        if custody.max_entries < custody.stranger_max_entries
            || custody.max_bytes < custody.stranger_max_bytes
        {
            return Err(crate::Error::InvalidConfiguration(
                "custody.max_entries and custody.max_bytes must each be at least the \
                 stranger tier's dial, or that tier can never be reached"
                    .to_string(),
            ));
        }

        Ok(())
    }
}

/// Builder for ProtocolConfig with a fluent API.
pub struct ProtocolConfigBuilder {
    config: ProtocolConfig,
}

impl ProtocolConfigBuilder {
    /// Creates a new builder.
    pub fn new(app_id: impl Into<String>, profile: impl Into<String>) -> Self {
        Self {
            config: ProtocolConfig::new(app_id, profile),
        }
    }

    /// Configures transports.
    pub fn transport(mut self, config: TransportConfig) -> Self {
        self.config.transport = config;
        self
    }

    /// Enables or disables BLE transport.
    pub fn ble_enabled(mut self, enabled: bool) -> Self {
        self.config.transport.ble_enabled = enabled;
        self
    }

    /// Enables or disables Wi-Fi Direct transport.
    pub fn wifi_direct_enabled(mut self, enabled: bool) -> Self {
        self.config.transport.wifi_direct_enabled = enabled;
        self
    }

    /// Enables or disables Internet transport.
    pub fn internet_enabled(mut self, enabled: bool) -> Self {
        self.config.transport.internet_enabled = enabled;
        self
    }

    /// Enables or disables Nostr relay transport.
    pub fn nostr_enabled(mut self, enabled: bool) -> Self {
        self.config.transport.nostr_enabled = enabled;
        self
    }

    /// Enables or disables sealing of outgoing Nostr frames (default on).
    pub fn nostr_sealing_enabled(mut self, enabled: bool) -> Self {
        self.config.transport.nostr_sealing_enabled = enabled;
        self
    }

    /// Enables username discovery publication and resolution
    /// (default **off**; see
    /// [`TransportConfig::nostr_username_discovery_enabled`]).
    pub fn nostr_username_discovery_enabled(mut self, enabled: bool) -> Self {
        self.config.transport.nostr_username_discovery_enabled = enabled;
        self
    }

    /// Enables or disables Nostr key-package publication and peer resolution
    /// (default on; see [`TransportConfig::nostr_cold_contact_enabled`]).
    pub fn nostr_cold_contact_enabled(mut self, enabled: bool) -> Self {
        self.config.transport.nostr_cold_contact_enabled = enabled;
        self
    }

    /// Configures DORS (Dynamic Offline Relay Switch).
    pub fn dors(mut self, config: DorsConfig) -> Self {
        self.config.dors = config;
        self
    }

    /// Enables online-first mode (prefer Internet when available).
    pub fn online_first(mut self, enabled: bool) -> Self {
        self.config.dors.prefer_online = enabled;
        self
    }

    /// Configures relay management.
    pub fn relay(mut self, config: RelayConfig) -> Self {
        self.config.relay = config;
        self
    }

    /// Configures how traffic is carried for other people.
    pub fn mesh_relay(mut self, config: MeshRelayConfig) -> Self {
        self.config.mesh_relay = config;
        self
    }

    /// Configures reliability layer.
    pub fn reliability(mut self, config: ReliabilityConfig) -> Self {
        self.config.reliability = config;
        self
    }

    /// Sets the initial TTL for messages.
    pub fn initial_ttl(mut self, ttl: u8) -> Self {
        self.config.initial_ttl = ttl;
        self
    }

    /// Configures encryption settings.
    pub fn encryption(mut self, config: EncryptionConfig) -> Self {
        self.config.encryption = config;
        self
    }

    /// Enables or disables automatic encryption.
    pub fn encryption_enabled(mut self, enabled: bool) -> Self {
        self.config.encryption.enabled = enabled;
        self
    }

    /// Enables or disables automatic key exchange on peer discovery.
    pub fn auto_key_exchange(mut self, enabled: bool) -> Self {
        self.config.encryption.auto_key_exchange = enabled;
        self
    }

    /// Enables or disables storing pending messages for later encryption.
    pub fn store_pending_messages(mut self, enabled: bool) -> Self {
        self.config.encryption.store_pending = enabled;
        self
    }

    /// Enables or disables strict encryption requirement.
    pub fn require_encryption(mut self, required: bool) -> Self {
        self.config.encryption.require_encryption = required;
        self
    }

    /// Configures pending encrypted message queue bounds and overflow behavior.
    pub fn pending_queue(mut self, config: PendingQueueConfig) -> Self {
        self.config.encryption.pending_queue = config;
        self
    }

    /// Configures group messaging settings.
    pub fn group(mut self, config: GroupConfig) -> Self {
        self.config.group = config;
        self
    }

    /// Sets the maximum number of members allowed in a single group.
    pub fn max_group_members(mut self, max: usize) -> Self {
        self.config.group.max_group_members = max;
        self
    }

    /// Sets whether groups should attempt relay server registration.
    pub fn group_relay_enabled(mut self, enabled: bool) -> Self {
        self.config.group.relay_enabled = enabled;
        self
    }

    /// Sets whether relay-synced groups may send via a single relay broadcast
    /// instead of per-member fan-out. See
    /// [`GroupConfig::relay_broadcast_enabled`] — on by default, but only
    /// ever taken against a relay that advertised the `group_delivery_v3`
    /// capability, whose settled, address-space delivery report gives the
    /// broadcast a per-recipient delivery contract.
    pub fn group_relay_broadcast_enabled(mut self, enabled: bool) -> Self {
        self.config.group.relay_broadcast_enabled = enabled;
        self
    }

    /// Sets whether unauthorized MLS membership commits are refused rather
    /// than applied-and-reported. See
    /// [`GroupConfig::enforce_admin_commits`] — off by default, and enabling
    /// it risks permanently forking members whose admin overlay disagrees.
    pub fn group_enforce_admin_commits(mut self, enabled: bool) -> Self {
        self.config.group.enforce_admin_commits = enabled;
        self
    }

    /// Configures security settings.
    pub fn security(mut self, config: SecurityConfig) -> Self {
        self.config.security = config;
        self
    }

    /// Sets whether transport identity is required for control messages.
    pub fn require_transport_identity(mut self, required: bool) -> Self {
        self.config.security.require_transport_identity = required;
        self
    }

    /// Configures the replicated-document data layer.
    pub fn data(mut self, config: DataConfig) -> Self {
        self.config.data = config;
        self
    }

    /// Sets whether the data layer accepts work. See [`DataConfig::enabled`].
    pub fn data_enabled(mut self, enabled: bool) -> Self {
        self.config.data.enabled = enabled;
        self
    }

    /// Points documents at a storage backend of the application's choosing.
    ///
    /// The whole bring-your-own-backend path, in one call. See
    /// [`DataConfig::storage`], including what it means for logout.
    pub fn data_storage(
        mut self,
        storage: Arc<dyn crate::protocol_state_storage::ProtocolStateStorage>,
    ) -> Self {
        self.config.data.storage = Some(storage);
        self
    }

    /// Configures custody: whether this device holds a neighbour's replication
    /// frames, and under what quotas. See [`CustodyConfig`].
    pub fn custody(mut self, config: CustodyConfig) -> Self {
        self.config.custody = config;
        self
    }

    /// Builds and validates the configuration.
    ///
    /// # Returns
    ///
    /// Returns `Ok(ProtocolConfig)` if valid, `Err` otherwise.
    pub fn build(self) -> crate::Result<ProtocolConfig> {
        self.config.validate()?;
        Ok(self.config)
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn test_config_creation() {
        let config = ProtocolConfig::new("test-app", "user123");
        assert_eq!(config.app_id, "test-app");
        assert_eq!(config.profile, "user123");
        assert_eq!(config.initial_ttl, 8);
    }

    #[test]
    fn test_config_validation_success() {
        let config = ProtocolConfig::new("test-app", "user123");
        assert!(config.validate().is_ok());
    }

    #[test]
    fn test_config_validation_empty_app_id() {
        let config = ProtocolConfig::new("", "user123");
        assert!(config.validate().is_err());
    }

    #[test]
    fn test_config_validation_empty_user_id() {
        let config = ProtocolConfig::new("test-app", "");
        assert!(config.validate().is_err());
    }

    #[test]
    fn config_validation_enforces_the_id_length_cap() {
        // An unbounded id becomes an unbounded storage key and an unbounded
        // wire field; the cap is the same one the core newtypes apply.
        let at_cap = "a".repeat(offline_protocol_core::MAX_ID_LEN);
        let over_cap = "a".repeat(offline_protocol_core::MAX_ID_LEN + 1);

        assert!(ProtocolConfig::new("test-app", &at_cap).validate().is_ok());
        assert!(ProtocolConfig::new(&at_cap, "user123").validate().is_ok());
        assert!(ProtocolConfig::new("test-app", &over_cap)
            .validate()
            .is_err());
        assert!(ProtocolConfig::new(&over_cap, "user123")
            .validate()
            .is_err());
    }

    #[test]
    fn config_validation_enforces_the_id_charset() {
        // Path separators and the KV namespace separator would let an id
        // escape or collide with another account's storage keys.
        for hostile in ["a/b", "a\\b", "a:b", ".", "..", "a\u{0}b", "a\nb"] {
            assert!(
                ProtocolConfig::new("test-app", hostile).validate().is_err(),
                "user_id {hostile:?} must be rejected"
            );
            assert!(
                ProtocolConfig::new(hostile, "user123").validate().is_err(),
                "app_id {hostile:?} must be rejected"
            );
        }
    }

    #[test]
    fn config_validation_accepts_an_address_shaped_id() {
        // The self-certifying address format must pass the id policy: the
        // bech32m charset is plain lowercase alphanumerics.
        let address = "off1qysluvwl5922yctzd0u9gpr06gn3k7ldfvgtwgvn";
        assert!(ProtocolConfig::new("test-app", address).validate().is_ok());
    }

    #[test]
    fn test_config_validation_zero_ttl() {
        let mut config = ProtocolConfig::new("test-app", "user123");
        config.initial_ttl = 0;
        assert!(config.validate().is_err());
    }

    #[test]
    fn test_config_validation_no_transports() {
        let mut config = ProtocolConfig::new("test-app", "user123");
        config.transport.ble_enabled = false;
        config.transport.wifi_direct_enabled = false;
        config.transport.internet_enabled = false;
        assert!(config.validate().is_err());
    }

    #[test]
    fn test_config_validation_retry_initial_delay_must_be_positive() {
        let mut config = ProtocolConfig::new("test-app", "user123");
        config.reliability.retry.initial_delay_ms = 0;
        assert!(config.validate().is_err());
    }

    #[test]
    fn test_config_validation_retry_delay_bounds() {
        let mut config = ProtocolConfig::new("test-app", "user123");
        config.reliability.retry.initial_delay_ms = 2000;
        config.reliability.retry.max_delay_ms = 1000;
        assert!(config.validate().is_err());
    }

    #[test]
    fn test_config_validation_retry_backoff_multiplier_bounds() {
        let mut config = ProtocolConfig::new("test-app", "user123");
        config.reliability.retry.backoff_multiplier = 0.5;
        assert!(config.validate().is_err());
    }

    #[test]
    fn test_config_validation_rejects_zero_bloom_parameters() {
        let mutations: [fn(&mut DeduplicatorConfig); 4] = [
            |dedup: &mut DeduplicatorConfig| dedup.bloom_filter_bits = 0,
            |dedup: &mut DeduplicatorConfig| dedup.bloom_hash_count = 0,
            |dedup: &mut DeduplicatorConfig| dedup.bloom_filter_count = 0,
            |dedup: &mut DeduplicatorConfig| dedup.bloom_rotation_secs = 0,
        ];

        for mutate in mutations {
            let mut config = ProtocolConfig::new("test-app", "user123");
            config.reliability.dedup.use_bloom_filter = true;
            mutate(&mut config.reliability.dedup);
            assert!(config.validate().is_err());
        }
    }

    #[test]
    fn test_config_builder() {
        let config = ProtocolConfig::builder("test-app", "user123")
            .ble_enabled(true)
            .wifi_direct_enabled(false)
            .online_first(true)
            .initial_ttl(10)
            .build()
            .unwrap();

        assert_eq!(config.app_id, "test-app");
        assert!(config.transport.ble_enabled);
        assert!(!config.transport.wifi_direct_enabled);
        assert!(config.dors.prefer_online);
        assert_eq!(config.initial_ttl, 10);
    }

    #[test]
    fn test_transport_config_default() {
        let transport = TransportConfig::default();
        assert!(transport.ble_enabled);
        assert!(transport.wifi_direct_enabled);
        assert!(transport.internet_enabled);
    }

    #[test]
    fn test_reliability_config_default() {
        let reliability = ReliabilityConfig::default();
        assert_eq!(reliability.ack.default_timeout_ms, 10000);
        assert_eq!(reliability.retry.max_retries, 10);
        // 7 days — must match the app-layer presence-flush window and the
        // fallback values hardcoded in the RN native bridges
        // (OfflineProtocolModule.kt / OfflineProtocolModule.swift).
        assert_eq!(reliability.retry.outbox_max_lifetime_ms, 604_800_000);
        // 5 min ceiling — also mirrored by the RN bridge fallbacks.
        assert_eq!(reliability.retry.max_delay_ms, 300_000);
        // Sized for the persisted seen set: see `DeduplicatorConfig::default`.
        assert_eq!(reliability.dedup.max_tracked_messages, 5000);
        assert_eq!(reliability.dedup.retention_time_secs, 604_800);
    }

    #[test]
    fn test_encryption_config_default() {
        let encryption = EncryptionConfig::default();
        assert!(encryption.enabled);
        assert!(encryption.auto_key_exchange);
        assert!(encryption.store_pending);
        // SEC-M3: encryption is required by default; plaintext is an
        // explicit opt-out, never a silent fallback.
        assert!(encryption.require_encryption);
        assert!(encryption.encrypt_service_messages);
        assert_eq!(encryption.pending_queue.max_pending_per_peer, 64);
        assert_eq!(encryption.pending_queue.max_pending_global, 4096);
        assert_eq!(
            encryption.pending_queue.pending_ttl_ms,
            DEFAULT_PENDING_TTL_MS
        );
        assert_eq!(
            encryption.pending_queue.overflow_policy,
            OverflowPolicy::DropOldest
        );
    }

    #[test]
    fn test_encryption_config_disabled() {
        let encryption = EncryptionConfig::disabled();
        assert!(!encryption.enabled);
        assert!(!encryption.auto_key_exchange);
        assert!(!encryption.store_pending);
        assert!(!encryption.require_encryption);
        assert!(!encryption.encrypt_service_messages);
    }

    /// A config serialized before `encrypt_service_messages` existed still
    /// parses, and parses with the switch on: without the named default a
    /// stored config would fail to load the release that added the field.
    #[test]
    fn an_encryption_config_without_the_service_switch_parses_with_it_on() {
        let mut value =
            serde_json::to_value(EncryptionConfig::default()).expect("the config serializes");
        value
            .as_object_mut()
            .expect("an object")
            .remove("encrypt_service_messages")
            .expect("the field was serialized");
        let parsed: EncryptionConfig =
            serde_json::from_value(value).expect("an older config still parses");
        assert!(parsed.encrypt_service_messages);
    }

    #[test]
    fn test_config_builder_with_encryption() {
        let config = ProtocolConfig::builder("test-app", "user123")
            .encryption_enabled(true)
            .auto_key_exchange(true)
            .store_pending_messages(false)
            .require_encryption(true)
            .pending_queue(PendingQueueConfig {
                max_pending_per_peer: 32,
                max_pending_global: 512,
                pending_ttl_ms: 30_000,
                overflow_policy: OverflowPolicy::DropNewest,
                ..Default::default()
            })
            .build()
            .unwrap();

        assert!(config.encryption.enabled);
        assert!(config.encryption.auto_key_exchange);
        assert!(!config.encryption.store_pending);
        assert!(config.encryption.require_encryption);
        assert_eq!(config.encryption.pending_queue.max_pending_per_peer, 32);
        assert_eq!(config.encryption.pending_queue.max_pending_global, 512);
        assert_eq!(config.encryption.pending_queue.pending_ttl_ms, 30_000);
        assert_eq!(
            config.encryption.pending_queue.overflow_policy,
            OverflowPolicy::DropNewest
        );
    }

    #[test]
    fn test_config_validation_require_encryption_requires_enabled() {
        let mut config = ProtocolConfig::new("test-app", "user123");
        config.encryption.enabled = false;
        config.encryption.require_encryption = true;
        assert!(config.validate().is_err());
    }

    #[test]
    fn test_config_validation_pending_queue_requires_positive_limits() {
        let mut config = ProtocolConfig::new("test-app", "user123");
        config.encryption.pending_queue.max_pending_per_peer = 0;
        assert!(config.validate().is_err());

        let mut config = ProtocolConfig::new("test-app", "user123");
        config.encryption.pending_queue.max_pending_global = 0;
        assert!(config.validate().is_err());

        let mut config = ProtocolConfig::new("test-app", "user123");
        config.encryption.pending_queue.pending_ttl_ms = 0;
        assert!(config.validate().is_err());
    }

    #[test]
    fn test_config_validation_pending_queue_global_must_cover_per_peer() {
        let mut config = ProtocolConfig::new("test-app", "user123");
        config.encryption.pending_queue.max_pending_per_peer = 100;
        config.encryption.pending_queue.max_pending_global = 99;
        assert!(config.validate().is_err());
    }

    #[test]
    fn test_group_config_default() {
        let group = GroupConfig::default();
        assert_eq!(group.max_group_members, 256);
        // Registration and broadcast both default on. Registration must stay
        // on because invite links resolve against the relay group registry.
        // The broadcast default is safe because the flag alone never selects
        // the path: it is additionally gated on the relay advertising the
        // `group_delivery_v3` capability, whose settled, address-space
        // delivery report is what gives the broadcast a per-recipient
        // delivery contract.
        assert!(group.relay_enabled);
        assert!(group.relay_broadcast_enabled);
        // Commit enforcement must stay OFF by default. On, a member whose
        // admin overlay merely lagged would refuse a legitimate commit and
        // fork itself out of a healthy group with no attacker involved —
        // unrecoverable without an app-level re-invite. Flipping this default
        // is a fleet-wide partition decision, not a hardening tweak.
        assert!(!group.enforce_admin_commits);
    }

    #[test]
    fn test_group_enforce_admin_commits_builder_opt_in() {
        let config = ProtocolConfig::builder("test-app", "user123")
            .group_enforce_admin_commits(true)
            .build()
            .unwrap();
        assert!(config.group.enforce_admin_commits);
        assert!(
            config.group.relay_enabled && config.group.relay_broadcast_enabled,
            "opting into enforcement must not disturb the relay flags"
        );
    }

    #[test]
    fn test_group_relay_broadcast_builder_opt_out() {
        let config = ProtocolConfig::builder("test-app", "user123")
            .group_relay_broadcast_enabled(false)
            .build()
            .unwrap();
        assert!(!config.group.relay_broadcast_enabled);
        assert!(
            config.group.relay_enabled,
            "opting out of the broadcast must not disturb registration"
        );
    }

    #[test]
    fn test_config_has_default_group_config() {
        let config = ProtocolConfig::new("test-app", "user123");
        assert_eq!(config.group.max_group_members, 256);
    }

    #[test]
    fn test_config_validation_zero_max_group_members() {
        let mut config = ProtocolConfig::new("test-app", "user123");
        config.group.max_group_members = 0;
        assert!(config.validate().is_err());
    }

    #[test]
    fn test_config_validation_positive_max_group_members() {
        let mut config = ProtocolConfig::new("test-app", "user123");
        config.group.max_group_members = 1;
        assert!(config.validate().is_ok());
    }

    /// A handicap large enough to outrun the overdue cut-off must be refused.
    ///
    /// Past that point a biased forward is not late, it is *abandoned* on
    /// release — so the tunable that exists to cost redundancy would be costing
    /// delivery, silently, on exactly the devices it is meant to spare.
    #[test]
    fn test_config_validation_rejects_a_handicap_past_the_overdue_cutoff() {
        let mut config = ProtocolConfig::new("test-app", "user123");
        config.mesh_relay.bias_max_handicap = RELAY_QUEUE_MAX_OVERDUE;
        assert!(config.validate().is_err());

        // The jitter window counts toward the same budget, so a handicap that
        // fits on its own can still be refused alongside a wide window.
        config.mesh_relay.bias_max_handicap = std::time::Duration::from_millis(400);
        config.mesh_relay.jitter_max = RELAY_QUEUE_MAX_OVERDUE;
        assert!(config.validate().is_err());

        // And the defaults must sit comfortably inside it.
        let defaults = ProtocolConfig::new("test-app", "user123");
        assert!(defaults.validate().is_ok());
    }

    /// Bias must never be configurable into an off switch.
    ///
    /// A scale of zero would stop a low-battery device forwarding by the back
    /// door, which is the partition the whole bias design exists to avoid —
    /// declining to relay is `relay.allow_relay`'s job, and it is visible.
    #[test]
    fn test_config_validation_rejects_a_bias_scale_that_silences_forwarding() {
        for scale in [0.0, -0.5, 1.5, f32::NAN, f32::INFINITY] {
            let mut config = ProtocolConfig::new("test-app", "user123");
            config.mesh_relay.bias_min_scale = scale;
            assert!(
                config.validate().is_err(),
                "bias_min_scale of {scale} must be refused",
            );
        }

        // 1.0 is the documented way to disable bias entirely, and must stay
        // accepted.
        let mut config = ProtocolConfig::new("test-app", "user123");
        config.mesh_relay.bias_min_scale = 1.0;
        assert!(config.validate().is_ok());
    }

    /// A fan-out of zero must be refused rather than clamped.
    ///
    /// It reads like an off switch and is not one: the frame is already
    /// admitted and recorded as seen by the time fan-out is chosen, so zero
    /// targets is a silent drop that also suppresses the copy arriving by
    /// another path. The forwarding paths clamp it to one; this keeps that
    /// clamp a defensive floor rather than a quiet reinterpretation.
    #[test]
    fn test_config_validation_rejects_a_fanout_of_zero() {
        let mut config = ProtocolConfig::new("test-app", "user123");
        config.mesh_relay.fanout = 0;
        assert!(config.validate().is_err());

        // One is a real setting — forward to a single neighbor — and must stay
        // accepted, or the check has swallowed the narrowest working fan-out.
        config.mesh_relay.fanout = 1;
        assert!(config.validate().is_ok());
    }

    /// Every hop-budget, queue and rate dial that can silently switch
    /// forwarding off must be refused, not clamped.
    ///
    /// These share one failure and it is the worst kind: the device keeps
    /// running, reports no error, and carries nothing. Each value below is the
    /// one a caller would reach for meaning "be conservative", so leaving them
    /// legal makes an off switch out of a dial nobody thinks is one.
    #[test]
    fn test_config_validation_rejects_dials_that_silently_stop_forwarding() {
        // Both hop ceilings: zero clamps every arriving budget to nothing, so
        // the frame is refused before it can be queued. The dense one is
        // checked separately because it only bites in a crowded room.
        let mut zero_ttl = ProtocolConfig::new("test-app", "user123");
        zero_ttl.mesh_relay.max_ttl = 0;
        assert!(zero_ttl.validate().is_err());

        let mut zero_dense_ttl = ProtocolConfig::new("test-app", "user123");
        zero_dense_ttl.mesh_relay.dense_max_ttl = 0;
        assert!(zero_dense_ttl.validate().is_err());

        // A queue that holds nothing rejects every admission as queue-full.
        let mut zero_queue = ProtocolConfig::new("test-app", "user123");
        zero_queue.mesh_relay.queue_capacity = 0;
        assert!(zero_queue.validate().is_err());

        // The token buckets clamp their inputs with `.max(0.0)`, which turns
        // each of these into a bucket that never yields a token. NaN is listed
        // on its own because `f32::max` returns the other operand for it, so it
        // arrives as zero rather than failing anywhere visible, and negatives
        // are what a bridge's own clamp hands over for validation here.
        for bad in [0.0_f32, -1.0, f32::NAN, f32::INFINITY] {
            let mut rate = ProtocolConfig::new("test-app", "user123");
            rate.mesh_relay.rate_per_sec = bad;
            assert!(
                rate.validate().is_err(),
                "rate_per_sec of {bad} must be refused",
            );

            let mut burst = ProtocolConfig::new("test-app", "user123");
            burst.mesh_relay.burst = bad;
            assert!(burst.validate().is_err(), "burst of {bad} must be refused");

            let mut peer_rate = ProtocolConfig::new("test-app", "user123");
            peer_rate.mesh_relay.peer_rate_per_sec = bad;
            assert!(
                peer_rate.validate().is_err(),
                "peer_rate_per_sec of {bad} must be refused",
            );

            let mut peer_burst = ProtocolConfig::new("test-app", "user123");
            peer_burst.mesh_relay.peer_burst = bad;
            assert!(
                peer_burst.validate().is_err(),
                "peer_burst of {bad} must be refused",
            );
        }

        // The narrowest working settings must stay accepted, or the checks have
        // swallowed real configurations along with the broken ones.
        let mut minimal = ProtocolConfig::new("test-app", "user123");
        minimal.mesh_relay.max_ttl = 1;
        minimal.mesh_relay.dense_max_ttl = 1;
        minimal.mesh_relay.queue_capacity = 1;
        minimal.mesh_relay.rate_per_sec = 0.5;
        minimal.mesh_relay.burst = 1.0;
        minimal.mesh_relay.peer_rate_per_sec = 0.5;
        minimal.mesh_relay.peer_burst = 1.0;
        assert!(minimal.validate().is_ok());
    }

    /// An inverted jitter window must be refused.
    ///
    /// Two failures in one, which is why the equal case has to stay legal to
    /// prove the check is an ordering check and not a ban on narrow windows.
    /// `jitter_for` raises the effective maximum to meet the minimum, so the
    /// span collapses to a millisecond and neighbors stop separating in time;
    /// and since the overdue check reads `jitter_max`, an oversized minimum
    /// would otherwise validate clean and abandon every forward.
    #[test]
    fn test_config_validation_rejects_an_inverted_jitter_window() {
        let mut inverted = ProtocolConfig::new("test-app", "user123");
        inverted.mesh_relay.jitter_min = std::time::Duration::from_millis(300);
        inverted.mesh_relay.jitter_max = std::time::Duration::from_millis(200);
        assert!(inverted.validate().is_err());

        // The case the overdue check alone would have missed: a minimum past
        // the 5s cut-off, with the maximum left at its default.
        let mut oversized_min = ProtocolConfig::new("test-app", "user123");
        oversized_min.mesh_relay.jitter_min = std::time::Duration::from_secs(600);
        assert!(oversized_min.validate().is_err());

        // Equal is a fixed delay, not an inversion, and stays accepted.
        let mut equal = ProtocolConfig::new("test-app", "user123");
        equal.mesh_relay.jitter_min = std::time::Duration::from_millis(200);
        equal.mesh_relay.jitter_max = std::time::Duration::from_millis(200);
        assert!(equal.validate().is_ok());
    }

    /// The activity window's tunables decide whether the relay standing can be
    /// reported at all; a zero in any of them stalls or divides it.
    #[test]
    fn test_config_validation_rejects_zero_activity_tunables() {
        let mut zero_window = ProtocolConfig::new("test-app", "user123");
        zero_window.mesh_relay.activity_window = std::time::Duration::ZERO;
        assert!(zero_window.validate().is_err());

        let mut zero_forwards = ProtocolConfig::new("test-app", "user123");
        zero_forwards.mesh_relay.activity_min_forwards = 0;
        assert!(zero_forwards.validate().is_err());

        let mut zero_idle = ProtocolConfig::new("test-app", "user123");
        zero_idle.mesh_relay.activity_idle_windows = 0;
        assert!(zero_idle.validate().is_err());
    }

    #[test]
    fn test_config_builder_max_group_members() {
        let config = ProtocolConfig::builder("test-app", "user123")
            .max_group_members(50)
            .build()
            .unwrap();
        assert_eq!(config.group.max_group_members, 50);
    }

    #[test]
    fn test_config_builder_group_config() {
        let config = ProtocolConfig::builder("test-app", "user123")
            .group(GroupConfig {
                max_group_members: 128,
                ..Default::default()
            })
            .build()
            .unwrap();
        assert_eq!(config.group.max_group_members, 128);
    }

    #[test]
    fn test_config_builder_zero_max_group_members_rejected() {
        let result = ProtocolConfig::builder("test-app", "user123")
            .max_group_members(0)
            .build();
        assert!(result.is_err());
    }

    /// The RN bridges never reach [`DEFAULT_PENDING_TTL_MS`]: each layer
    /// substitutes its own fallback when the app omits `pendingTtlMs`, and the
    /// JS layer always materializes the field before it crosses the bridge. So
    /// the Rust default is only the RN default for as long as these three
    /// literals agree with it — they silently drifted to the pre-deferred-ACK
    /// 2-minute window once already, which is the window this constant was
    /// raised to replace.
    ///
    /// The sibling guard for the ACK/retry fallbacks lives in
    /// `offline-protocol-reliability`; this one has to live here because that
    /// crate cannot depend on this one.
    #[test]
    fn rn_bridge_pending_ttl_fallbacks_match_rust_default() {
        let rn_root =
            std::path::Path::new(env!("CARGO_MANIFEST_DIR")).join("../../bindings/react-native");

        // Each entry is (path, the fallback that file must contain). The
        // pattern names the field it guards, not just the literal, so deleting
        // the fallback cannot be masked by the same number appearing on some
        // other line. Matched against the source with whitespace squeezed, so a
        // line wrap between the field and its `?:`/`??` doesn't hide it.
        let expected = [
            (
                rn_root.join("src/index.ts"),
                format!("pendingTtlMs ?? {DEFAULT_PENDING_TTL_MS}"),
            ),
            (
                rn_root.join("android/src/main/java/com/offlineprotocol/ProtocolConfigParser.kt"),
                format!(
                    "\"pending_ttl_ms\") ?: {}L",
                    format_underscored(DEFAULT_PENDING_TTL_MS)
                ),
            ),
            (
                rn_root.join("ios/EncryptionConfigReader.swift"),
                format!(
                    "\"pending_ttl_ms\") ?? {}",
                    format_underscored(DEFAULT_PENDING_TTL_MS)
                ),
            ),
        ];

        // The guard only applies in the repo checkout; skip when the bindings
        // tree isn't present (e.g. a vendored crate). Read every file up front
        // so a moved or renamed bridge skips the whole guard rather than
        // silently dropping the checks that come after it.
        let Some(sources) = expected
            .iter()
            .map(|(path, _)| std::fs::read_to_string(path).ok())
            .collect::<Option<Vec<_>>>()
        else {
            eprintln!("bindings tree not present, skipping RN pending-TTL drift check");
            return;
        };

        for ((path, fallback), source) in expected.iter().zip(&sources) {
            let squeezed = source.split_whitespace().collect::<Vec<_>>().join(" ");
            assert!(
                squeezed.contains(fallback.as_str()),
                "RN pending-queue TTL fallback drifted from DEFAULT_PENDING_TTL_MS: \
                 expected `{fallback}` in {}",
                path.display()
            );
        }
    }

    /// Drift guard: the React Native `updateDedupConfig` fallbacks match the
    /// core dedup defaults. The TypeScript layer forwards only the fields the
    /// app set, so a `reliability.dedup` section that sets one field takes the
    /// other from these literals, and a fallback that disagrees with the
    /// documented default silently changes it for that app. The id cap sat at
    /// 10000 against a documented default of 1000, then 2000, that way.
    #[test]
    fn rn_bridge_dedup_fallbacks_match_rust_default() {
        let defaults = ProtocolConfig::new("test-app", "user123").reliability.dedup;
        let rn_root =
            std::path::Path::new(env!("CARGO_MANIFEST_DIR")).join("../../bindings/react-native");
        // Fallbacks live in the shared bridge (ADR 0025), not the RN module shells.
        let kotlin =
            rn_root.join("android/src/main/java/com/offlineprotocol/ProtocolEngineHostBridge.kt");
        let swift = rn_root.join("ios/ProtocolEngineHostBridge.swift");
        let swift_max = format_underscored(defaults.max_tracked_messages as u64);
        let swift_retention = format_underscored(defaults.retention_time_secs);
        let expected = [
            (
                kotlin.clone(),
                format!(
                    "json.optLong(\"maxTrackedMessages\", {})",
                    defaults.max_tracked_messages
                ),
            ),
            (
                kotlin,
                format!(
                    "json.optLong(\"retentionTimeSecs\", {})",
                    defaults.retention_time_secs
                ),
            ),
            (
                swift.clone(),
                format!(r#"unsigned64(j, "maxTrackedMessages", {swift_max})"#),
            ),
            (
                swift,
                format!(r#"unsigned64(j, "retentionTimeSecs", {swift_retention})"#),
            ),
        ];

        let Some(sources) = expected
            .iter()
            .map(|(path, _)| std::fs::read_to_string(path).ok())
            .collect::<Option<Vec<_>>>()
        else {
            eprintln!("bindings tree not present, skipping RN dedup fallback drift check");
            return;
        };

        for ((path, fallback), source) in expected.iter().zip(&sources) {
            let squeezed = source.split_whitespace().collect::<Vec<_>>().join(" ");
            assert!(
                squeezed.contains(fallback.as_str()),
                "RN dedup fallback drifted from the core default: expected `{fallback}` in {}",
                path.display()
            );
        }
    }

    /// Drift guard: every public surface that documents
    /// [`EncryptionConfig::crypto_recovery_enabled`] must state that the re-key
    /// trigger is unauthenticated, and must not carry the retired claim that it
    /// re-keys only on genuine peer traffic.
    ///
    /// This is guarded because it has already drifted once. The trigger was
    /// hardened and honestly documented in-code, but that pass corrected only
    /// `session.rs` and the internal architecture notes — six integrator-facing
    /// surfaces kept promising that an injected frame could never drive a
    /// re-key, and framed the residual as replay-only, while
    /// `test_forged_frame_reaches_session_desync_without_any_key_material` in
    /// `offline-protocol-mls` proved the opposite in the same workspace. Nothing
    /// else fails when these lag: the code stays correct and the docs quietly
    /// promise a guarantee it does not make, which is the worst shape for a
    /// security claim to fail in.
    #[test]
    fn crypto_recovery_docs_state_the_unauthenticated_trigger() {
        let root = std::path::Path::new(env!("CARGO_MANIFEST_DIR")).join("../..");
        let surfaces = [
            "crates/offline-protocol/src/config.rs",
            "crates/offline-protocol-uniffi/src/offline_protocol.udl",
            "bindings/react-native/src/types.ts",
            "docs/mls-integration.md",
            "docs/configuration.md",
            "docs/api-reference.md",
        ];

        // Retired claims. Each was false for the same reason: an MLS epoch is
        // read during framing validation, before the sender is authenticated.
        // Split across `concat!` so the banned phrases never appear verbatim in
        // this file — belt-and-braces on top of the `#[cfg(test)]` truncation
        // below, so the guard survives either defense being refactored away.
        let retired = [
            concat!("never re-keys on ", "injected garbage"),
            concat!("injected garbage ", "can't drive"),
            concat!("injecting ", "garbage"),
        ];

        // The marker every surface must carry, concat-split for the inverse
        // reason: written verbatim, this needle alone would satisfy its own
        // check for config.rs no matter what the rustdoc says.
        let marker = concat!("re-key trigger is ", "unauthenticated");

        for surface in surfaces {
            let path = root.join(surface);
            let source = std::fs::read_to_string(&path)
                .unwrap_or_else(|e| panic!("cannot read {}: {e}", path.display()));
            // Scan only up to the first `#[cfg(test)]` token — for config.rs,
            // the non-test source. This test necessarily names the marker (doc
            // comment, panic message), so scanning its own module would satisfy
            // the marker check for the file it lives in even after the rustdoc
            // dropped it. The other surfaces don't contain the token and pass
            // through whole.
            let scanned = source.split("#[cfg(test)]").next().unwrap_or(&source);
            // Squeezed so a line wrap inside a phrase cannot hide it, and
            // lowercased so a sentence-initial capital cannot either. Standalone
            // comment/markup continuation tokens (`///`, `//`, `*`, `>`) are
            // dropped, because these six surfaces wrap prose in four different
            // comment syntaxes and a reflow would otherwise wedge one into the
            // middle of a phrase — a guard that fails on `cargo fmt` teaches
            // people to delete it.
            let squeezed = scanned
                .split_whitespace()
                .filter(|tok| !tok.chars().all(|c| matches!(c, '/' | '*' | '>')))
                .collect::<Vec<_>>()
                .join(" ")
                .to_lowercase();

            for claim in retired {
                assert!(
                    !squeezed.contains(claim),
                    "{surface} carries the retired claim `{claim}`. The re-key \
                     trigger is reachable by anyone who can inject a frame — see \
                     test_forged_frame_reaches_session_desync_without_any_key_material"
                );
            }

            assert!(
                squeezed.contains(marker),
                "{surface} documents crypto_recovery_enabled but no longer states \
                 that the re-key trigger is unauthenticated. Say so plainly, or an \
                 integrator will read a sustained SESSION_REKEY_TRIGGERED rate as a \
                 bug rather than as the injection signal it exists to surface."
            );
        }
    }

    /// Renders `86400000` as `86_400_000`, the form Kotlin and Swift use.
    fn format_underscored(value: u64) -> String {
        let digits = value.to_string();
        let mut out = String::new();
        for (i, c) in digits.chars().enumerate() {
            if i > 0 && (digits.len() - i) % 3 == 0 {
                out.push('_');
            }
            out.push(c);
        }
        out
    }

    // ====================================================================
    // Custody
    // ====================================================================

    fn enabled_custody() -> CustodyConfig {
        CustodyConfig {
            enabled: true,
            ..CustodyConfig::default()
        }
    }

    #[test]
    fn custody_is_off_by_default_and_the_default_dials_validate_when_on() {
        let config = ProtocolConfig::new("app", "user");
        assert!(!config.custody.enabled);
        assert_eq!(config.custody.hold_ms, DEFAULT_CUSTODY_HOLD_MS);
        assert_eq!(config.custody.stranger_max_entries, 0);
        assert_eq!(config.custody.stranger_max_bytes, 0);
        config.validate().unwrap();

        let mut on = ProtocolConfig::new("app", "user");
        on.custody = enabled_custody();
        on.validate().unwrap();
        // The reference defaults respect their own bounds.
        assert!(DEFAULT_CUSTODY_HOLD_MS < on.reliability.retry.outbox_max_lifetime_ms);
        assert!(DEFAULT_CUSTODY_MAX_BYTES_PER_DEPOSITOR >= CUSTODY_MIN_BYTES_PER_DEPOSITOR);
    }

    #[test]
    fn test_config_validation_rejects_a_custody_hold_that_outlives_the_outbox() {
        // The silent inversion: a custodian whose hold outlives the depositor's
        // outbox delivers frames whose sender already reported them failed.
        let mut config = ProtocolConfig::new("app", "user");
        config.custody = enabled_custody();
        config.custody.hold_ms = config.reliability.retry.outbox_max_lifetime_ms;
        let err = config.validate().unwrap_err().to_string();
        assert!(err.contains("custody.hold_ms"), "{err}");
        assert!(err.contains("strictly shorter"), "{err}");

        config.custody.hold_ms = config.reliability.retry.outbox_max_lifetime_ms - 1;
        config.validate().unwrap();

        // Disabled, the relation is not checked: a section that is off must
        // not refuse a configuration for a feature it never switched on.
        config.custody.enabled = false;
        config.custody.hold_ms = config.reliability.retry.outbox_max_lifetime_ms * 2;
        config.validate().unwrap();

        // A zero hold is refused whatever the switch says.
        config.custody.hold_ms = 0;
        let err = config.validate().unwrap_err().to_string();
        assert!(
            err.contains("custody.hold_ms must be greater than 0"),
            "{err}"
        );
    }

    #[test]
    fn test_config_validation_rejects_custody_dials_that_silently_hold_nothing() {
        let base = {
            let mut config = ProtocolConfig::new("app", "user");
            config.custody = enabled_custody();
            config
        };

        let mut zero_entries = base.clone();
        zero_entries.custody.max_entries_per_depositor = 0;
        assert!(zero_entries
            .validate()
            .unwrap_err()
            .to_string()
            .contains("max_entries_per_depositor"));

        let mut zero_bytes = base.clone();
        zero_bytes.custody.max_bytes_per_depositor = 0;
        assert!(zero_bytes
            .validate()
            .unwrap_err()
            .to_string()
            .contains("max_bytes_per_depositor"));

        let mut too_small = base.clone();
        too_small.custody.max_bytes_per_depositor = CUSTODY_MIN_BYTES_PER_DEPOSITOR - 1;
        let err = too_small.validate().unwrap_err().to_string();
        assert!(err.contains("one replication frame"), "{err}");

        let mut inverted = base.clone();
        inverted.custody.max_entries = inverted.custody.max_entries_per_depositor - 1;
        assert!(inverted
            .validate()
            .unwrap_err()
            .to_string()
            .contains("per-depositor sibling"));

        let mut inverted_bytes = base.clone();
        inverted_bytes.custody.max_bytes = inverted_bytes.custody.max_bytes_per_depositor - 1;
        assert!(inverted_bytes
            .validate()
            .unwrap_err()
            .to_string()
            .contains("per-depositor sibling"));

        // Off, none of it is checked.
        let mut off = zero_entries.clone();
        off.custody.enabled = false;
        off.validate().unwrap();
    }

    #[test]
    fn test_config_validation_holds_the_stranger_tier_to_both_dials() {
        let mut config = ProtocolConfig::new("app", "user");
        config.custody = enabled_custody();

        config.custody.stranger_max_entries = 4;
        let err = config.validate().unwrap_err().to_string();
        assert!(err.contains("both zero"), "{err}");

        config.custody.stranger_max_bytes = CUSTODY_MIN_BYTES_PER_DEPOSITOR - 1;
        let err = config.validate().unwrap_err().to_string();
        assert!(err.contains("stranger_max_bytes"), "{err}");

        config.custody.stranger_max_bytes = CUSTODY_MIN_BYTES_PER_DEPOSITOR;
        config.validate().unwrap();

        config.custody.stranger_max_entries = config.custody.max_entries + 1;
        let err = config.validate().unwrap_err().to_string();
        assert!(err.contains("stranger tier"), "{err}");
    }

    #[test]
    fn the_custody_builder_setter_reaches_validation() {
        let err = ProtocolConfig::builder("app", "user")
            .custody(CustodyConfig {
                enabled: true,
                hold_ms: u64::MAX,
                ..CustodyConfig::default()
            })
            .build()
            .unwrap_err()
            .to_string();
        assert!(err.contains("custody.hold_ms"), "{err}");
    }
}