Struct OpenMessageRepository Copy item path

impl OpenMessageRepository

pub fn new(connection: Arc<SqliteConnection>) -> Self

Instantiate service

pub async fn get_open_message( &self, signed_entity_type: &SignedEntityType, ) -> StdResult<Option<OpenMessageRecord>>

Return the latest OpenMessageRecord for the given Epoch and SignedEntityType.

pub async fn get_open_message_with_single_signatures( &self, signed_entity_type: &SignedEntityType, ) -> StdResult<Option<OpenMessageWithSingleSignaturesRecord>>

Return an open message with its associated single signatures for the given Epoch and SignedEntityType.

pub async fn get_expired_open_message( &self, signed_entity_type: &SignedEntityType, ) -> StdResult<Option<OpenMessageRecord>>

Return the expired OpenMessageRecord for the given Epoch and SignedEntityType if it exists

pub async fn create_open_message( &self, epoch: Epoch, signed_entity_type: &SignedEntityType, protocol_message: &ProtocolMessage, ) -> StdResult<OpenMessageRecord>

Create a new OpenMessageRecord in the database.

pub async fn create_or_replace_open_message( &self, record: OpenMessageRecord, ) -> StdResult<OpenMessageRecord>

Create, or replace if one with the same SignedEntityType they already exist, a OpenMessageRecord in the database.

pub async fn update_open_message( &self, open_message: &OpenMessageRecord, ) -> StdResult<OpenMessageRecord>

Updates an OpenMessageRecord in the database.

pub async fn clean_epoch(&self, epoch: Epoch) -> StdResult<usize>

Remove all the OpenMessageRecord for the strictly previous epochs of the given epoch in the database. It returns the number of messages removed.

Trait Implementations§

impl OpenMessageStorer for OpenMessageRepository

fn insert_or_replace_open_message<'life0, 'async_trait>( &'life0 self, open_message: OpenMessage, ) -> Pin<Box<dyn Future<Output = StdResult<()>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Store an open_message in the database

Auto Trait Implementations§

impl !UnwindSafe for OpenMessageRepository

Blanket Implementations§

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Az for T

fn az<Dst>(self) -> Dst
where T: Cast<Dst>,

Casts the value.

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<Src, Dst> CastFrom<Src> for Dst
where Src: Cast<Dst>,

fn cast_from(src: Src) -> Dst

Casts the value.

impl<T> CheckedAs for T

fn checked_as<Dst>(self) -> Option<Dst>
where T: CheckedCast<Dst>,

Casts the value.

impl<Src, Dst> CheckedCastFrom<Src> for Dst
where Src: CheckedCast<Dst>,

fn checked_cast_from(src: Src) -> Option<Dst>

Casts the value.

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T, U> Into for T
where U: From<T>,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more