sov-blob-storage 0.3.0

A Sovereign SDK module for holding blobs from Data Availability Layer
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42

//! Defines the CallMessages accepted by the blob storage module

use sov_modules_api::{Context, DaSpec, WorkingSet};

use crate::BlobStorage;

/// A call message for the blob storage module
#[cfg_attr(
    feature = "native",
    derive(serde::Serialize),
    derive(serde::Deserialize),
    derive(sov_modules_api::macros::CliWalletArg),
    derive(schemars::JsonSchema)
)]
#[derive(borsh::BorshDeserialize, borsh::BorshSerialize, Debug, PartialEq, Clone)]
pub enum CallMessage {
    /// Asks the blob selector to process up to the given number of deferred blobs early.
    /// Only the preferred sequencer may send this message.
    ProcessDeferredBlobsEarly {
        /// The number of blobs to process early
        number: u16,
    },
}

impl<C: Context, Da: DaSpec> BlobStorage<C, Da> {
    pub(crate) fn handle_process_blobs_early_msg(
        &self,
        context: &C,
        number: u16,
        working_set: &mut WorkingSet<C>,
    ) {
        if let Some(preferred_sequencer) = self
            .sequencer_registry
            .get_preferred_sequencer_rollup_address(working_set)
        {
            if context.sender() == &preferred_sequencer {
                self.deferred_blobs_requested_for_execution_next_slot
                    .set(&number, working_set);
            }
        }
    }
}