Struct BlsAggregatorService

pub struct BlsAggregatorService<A>
where
    A: Clone + AvsRegistryService,
{
    pub aggregated_response_receiver: Arc<Mutex<UnboundedReceiver<Result<BlsAggregationServiceResponse, BlsAggregationServiceError>>>>,
    /* private fields */
}

The BLS Aggregator Service main struct

Fields

aggregated_response_receiver: Arc<Mutex<UnboundedReceiver<Result<BlsAggregationServiceResponse, BlsAggregationServiceError>>>>

Implementations

impl<A: AvsRegistryService + Send + Sync + Clone + 'static> BlsAggregatorService<A>

pub fn new(avs_registry_service: A, logger: SharedLogger) -> Self

Creates a new instance of the BlsAggregatorService with the given AVS registry service

Creates a tokio unbounded_channel to send and received aggregated responses.

Arguments

• avs_registry_service - The AVS registry service
• logger - Logger to log messages

pub async fn initialize_new_task( &self, task_index: TaskIndex, task_created_block: u32, quorum_nums: Vec<u8>, quorum_threshold_percentages: QuorumThresholdPercentages, time_to_expiry: Duration, ) -> Result<(), BlsAggregationServiceError>

Creates a new task meant to process new signed task responses for a task tokio channel.

Arguments

• task_index - The index of the task
• task_created_block - The block number at which the task was created
• quorum_nums - The quorum numbers for the task
• quorum_threshold_percentages - The quorum threshold percentages for the task
• time_to_expiry - The timeout for the task reader to expire

Error

Returns error if the task index already exists

pub async fn initialize_new_task_with_window( &self, task_index: TaskIndex, task_created_block: u32, quorum_nums: Vec<u8>, quorum_threshold_percentages: QuorumThresholdPercentages, time_to_expiry: Duration, window_duration: Duration, ) -> Result<(), BlsAggregationServiceError>

Creates a new task meant to process new signed task responses for a task tokio channel.

Arguments

• task_index - The index of the task
• task_created_block - The block number at which the task was created
• quorum_nums - The quorum numbers for the task
• quorum_threshold_percentages - The quorum threshold percentages for the task
• time_to_expiry - The timeout for the task reader to expire
• window_duration - The duration of the window to wait for signatures after quorum is reached

Error

Returns error if the task index already exists

pub async fn process_new_signature( &self, task_index: TaskIndex, task_response_digest: TaskResponseDigest, bls_signature: Signature, operator_id: FixedBytes<32>, ) -> Result<(), BlsAggregationServiceError>

Processes signatures received from the channel and sends the signed task response to the task channel.

Arguments

• task_index - The index of the task
• task_response_digest - The digest of the task response
• bls_signature - The BLS signature of the task response
• operator_id - The operator ID of the operator that signed the task response

Errors

Returns error:

• TaskNotFound - If the task is not found.
• ChannelError - If there is an error while sending the task through the channel.
• SignatureVerificationError - If the signature verification fails.

pub async fn single_task_aggregator( avs_registry_service: A, task_index: TaskIndex, task_created_block: u32, quorum_nums: Vec<u8>, quorum_threshold_percentages: QuorumThresholdPercentages, time_to_expiry: Duration, aggregated_response_sender: UnboundedSender<Result<BlsAggregationServiceResponse, BlsAggregationServiceError>>, signatures_rx: UnboundedReceiver<SignedTaskResponseDigest>, window_duration: Duration, logger: SharedLogger, ) -> Result<(), BlsAggregationServiceError>

Processes each signed task responses given a task_index for a single task.

It reads the signed task responses from the receiver channel and aggregates them.

• If the quorum threshold is met, it sends the aggregated response to the aggregated response sender.
• If the time to expiry is reached, it sends a task expired error to the aggregated response sender.
• If the signature is incorrect, it sends an incorrect signature error to error channel.

Arguments

• task_index - The index of the task
• task_created_block - The block number at which the task was created
• quorum_nums - The quorum numbers for the task
• quorum_threshold_percentages - The quorum threshold percentages for the task
• time_to_expiry - The timeout for the task reader to expire
• aggregated_response_sender - The sender channel for the aggregated responses
• signatures_rx - The receiver channel for the signed task responses
• window_duration - The duration of the window to wait for signatures after quorum is reached
• logger - The logger to log messages.

pub async fn verify_signature( task_index: TaskIndex, signed_task_response_digest: &SignedTaskResponseDigest, operator_avs_state: &HashMap<FixedBytes<32>, OperatorAvsState>, logger: SharedLogger, ) -> Result<(), SignatureVerificationError>

Verifies the signature of the task response given a operator_avs_state. If the signature is correct, it returns Ok(()), otherwise it returns an error.

Arguments

• task_index - The index of the task
• signed_task_response_digest - The signed task response digest
• operator_avs_state - A hashmap containing the staked of all the operator indexed by operator_id. This is used to get the operator_state to obtain the operator public key.
• logger - The logger to log messages.

Error

Returns error:

• SignatureVerificationError::OperatorNotFound if the operator is not found,
• SignatureVerificationError::OperatorPublicKeyNotFound if the operator public key is not found,
• SignatureVerificationError::IncorrectSignature if the signature is incorrect.

pub fn check_if_stake_thresholds_met( signed_stake_per_quorum: &HashMap<u8, U256>, total_stake_per_quorum: &HashMap<u8, U256>, quorum_threshold_percentages_map: &HashMap<u8, QuorumThresholdPercentage>, ) -> bool

Checks if the stake thresholds are met for the given set of quorum members.

Arguments

• signed_stake_per_quorum - The signed stake per quorum.
• total_stake_per_quorum - The total stake per quorum.
• quorum_threshold_percentages_map - The quorum threshold percentages map, containing the quorum id as a key and its corresponding quorum threshold percentage.

Returns

Returns true if the stake thresholds are met for all the members, otherwise false.

Trait Implementations

impl<A> Debug for BlsAggregatorService<A>

where A: Clone + Debug + AvsRegistryService,

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

Formats the value using the given formatter.