Struct TaskState 

pub struct TaskState {

    pub service_id: u64,
    pub call_id: u64,
    pub output: Vec<u8>,
    pub operator_count: u32,
    pub threshold_type: ThresholdType,
    pub signer_bitmap: U256,
    pub signatures: HashMap<u32, ArkBlsBn254Signature>,
    pub public_keys: HashMap<u32, ArkBlsBn254Public>,
    pub operator_stakes: HashMap<u32, u64>,
    pub total_stake: u64,
    pub submitted: bool,
    pub created_at: Instant,
    pub expires_at: Option<Instant>,
}

State for a single aggregation task

Fields

service_id: u64

Service ID

call_id: u64

Call ID

output: Vec<u8>

The output being signed

operator_count: u32

Number of operators in the service

threshold_type: ThresholdType

Threshold type and value

signer_bitmap: U256

Bitmap of which operators have signed (bit i = operator i signed)

signatures: HashMap<u32, ArkBlsBn254Signature>

Collected signatures indexed by operator index

public_keys: HashMap<u32, ArkBlsBn254Public>

Collected public keys indexed by operator index

operator_stakes: HashMap<u32, u64>

Operator stakes for stake-weighted thresholds

total_stake: u64

Total stake of all operators

submitted: bool

Whether this task has been submitted to chain

created_at: Instant

When this task was created

expires_at: Option<Instant>

When this task expires (None = never)

Implementations

impl TaskState

pub fn new( service_id: u64, call_id: u64, output: Vec<u8>, operator_count: u32, threshold: u32, ) -> Self

Create a new task state with count-based threshold

pub fn with_config( service_id: u64, call_id: u64, output: Vec<u8>, operator_count: u32, threshold_type: ThresholdType, operator_stakes: Option<HashMap<u32, u64>>, ttl: Option<Duration>, ) -> Self

Create a new task state with full configuration

pub fn is_expired(&self) -> bool

Check if this task has expired

pub fn time_remaining(&self) -> Option<Duration>

Get remaining time until expiry

pub fn add_signature( &mut self, operator_index: u32, signature: ArkBlsBn254Signature, public_key: ArkBlsBn254Public, ) -> Result<(), &'static str>

Add a signature from an operator

pub fn has_signed(&self, operator_index: u32) -> bool

Check if an operator has already signed

pub fn signature_count(&self) -> usize

Get the number of signatures collected

pub fn signed_stake(&self) -> u64

Get the total stake that has signed

pub fn signed_stake_bps(&self) -> u32

Get the signed stake as basis points (0-10000) of total stake

pub fn threshold_met(&self) -> bool

Check if threshold is met

pub fn threshold_value(&self) -> usize

Get the threshold value (for API responses)

pub fn get_non_signers(&self) -> Vec<u32>

Get list of operators who haven’t signed (non-signers)

pub fn get_signers(&self) -> Vec<u32>

Get list of operators who have signed

pub fn get_signatures_for_aggregation( &self, ) -> (Vec<ArkBlsBn254Signature>, Vec<ArkBlsBn254Public>)

Get all signatures and public keys in order for aggregation

Trait Implementations

impl Debug for TaskState

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

Formats the value using the given formatter.