Enum StateItem 

pub enum StateItem {
    PendingVerification {
        channel_id: ChannelId,
        request: VerifyShareRequestMessage,
    },
    PendingRecovery {
        version: u32,
        shares: Vec<GetShareResponseMessage>,
    },
    PendingUnpair {
        channel_id: ChannelId,
        started_at: u64,
    },
    SharingRound {
        version: u32,
        pending: HashSet<ChannelId>,
        confirmed: HashSet<ChannelId>,
        failed: HashSet<ChannelId>,
        started_at: u64,
    },
}

The payload of one row in the crate::protocol::DeRecStateStore.

Write pattern

The library treats crate::protocol::DeRecStateStore::save as full-replacement upsert — there is no per-item merge or append semantic at the store level. Accumulator-style state (StateItem::PendingRecovery and StateItem::SharingRound) grows via load-modify-save cycles from the library. Backends do not need to implement any append primitive; a naive replace-on-save is correct.

Variants

PendingVerification

The full outstanding derec_proto::VerifyShareRequestMessage the orchestrator sent for this channel. Retained so the corresponding inbound derec_proto::VerifyShareResponseMessage can be validated against the exact (nonce, secret_id, version) triple that was minted at request time.

Overwritten in place by a subsequent save for the same (secret_id, channel_id); the most recent challenge wins.

Fields

channel_id: ChannelId

request: VerifyShareRequestMessage

PendingRecovery

Accumulator for one in-progress recovery target.

The library writes this variant one share at a time as each inbound derec_proto::GetShareResponseMessage arrives. The write sequence under a single (secret_id, version) is:

1. First response arrives. Library calls save with a shares vector containing exactly one element.
2. Second response arrives. Library loads the accumulator, appends the new share to the returned Vec, and saves the grown Vec back.
3. …repeat until threshold. On threshold met, library removes the accumulator.

Implementations MUST accept shares vectors of any length, including one. Every save replaces the stored value in place with the caller-supplied Vec; no append primitive is required.

Concurrency

See crate::protocol::DeRecStateStore for the multi-instance concurrency contract. Concurrent inbound shares racing on the same accumulator will clobber each other via a naive load-modify-save; the application layer is responsible for serializing concurrent process() calls that touch the same (secret_id, version) if this matters.

Fields

version: u32

shares: Vec<GetShareResponseMessage>

PendingUnpair

Outstanding unpair acknowledgement window. started_at is the unix-seconds timestamp stamped when the request was sent; the orchestrator sweeps expired entries via crate::protocol::DeRecStateStore::load_all.

Fields

channel_id: ChannelId

started_at: u64

SharingRound

Active sharing round for secret_id. Created by start(ProtectSecret) and cleared by the orchestrator once every targeted helper has responded (confirmed, rejected, or timed out). At most one entry exists per secret_id; a fresh start(ProtectSecret) overwrites any prior in-flight round.

pending / confirmed / failed partition the round’s target channels; the union is invariant across the round’s lifetime. started_at is the unix-seconds timestamp used to time out unresponsive helpers.

Fields

version: u32

pending: HashSet<ChannelId>

confirmed: HashSet<ChannelId>

failed: HashSet<ChannelId>

started_at: u64

Implementations

impl StateItem

pub fn kind(&self) -> StateKind

The StateKind this item is an instance of.

pub fn key(&self) -> StateKey

The StateKey identifying this item within its (secret_id, kind) partition. Convenience so callers don’t have to hand-construct a key that matches the payload.

Trait Implementations

impl Clone for StateItem

fn clone(&self) -> StateItem

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StateItem

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.