Struct StoredGroupMessage 

pub struct StoredGroupMessage {

    pub id: Vec<u8>,
    pub group_id: GroupId,
    pub decrypted_message_bytes: Vec<u8>,
    pub sent_at_ns: i64,
    pub kind: GroupMessageKind,
    pub sender_installation_id: Vec<u8>,
    pub sender_inbox_id: String,
    pub delivery_status: DeliveryStatus,
    pub content_type: ContentType,
    pub version_major: i32,
    pub version_minor: i32,
    pub authority_id: String,
    pub reference_id: Option<Vec<u8>>,
    pub sequence_id: i64,
    pub envelope_hash: Option<Vec<u8>>,
    pub expiry_ns: Option<i64>,
    pub inserted_at_ns: i64,
    pub expire_at_ns: Option<i64>,
    pub should_push: bool,
    pub idempotency_key: String,
}

Successfully processed messages to be returned to the User.

Fields

id: Vec<u8>

Id of the message.

group_id: GroupId

Id of the group this message is tied to.

decrypted_message_bytes: Vec<u8>

Contents of message after decryption.

sent_at_ns: i64

Time in nanoseconds the message was sent.

kind: GroupMessageKind

Group Message Kind Enum: 1 = Application, 2 = MembershipChange

sender_installation_id: Vec<u8>

The ID of the App Installation this message was sent from.

sender_inbox_id: String

The Inbox ID of the Sender

delivery_status: DeliveryStatus

We optimistically store messages before sending.

content_type: ContentType

The Content Type of the message

version_major: i32

The content type version major

version_minor: i32

The content type version minor

authority_id: String

The ID of the authority defining the content type

reference_id: Option<Vec<u8>>

The ID of a referenced message

sequence_id: i64

The Message SequenceId

envelope_hash: Option<Vec<u8>>

Canonical envelope hash assigned by the backend.

expiry_ns: Option<i64>

Backend retention metadata. This does not control message deletion.

inserted_at_ns: i64

Time in nanoseconds the message was inserted into the database This field is automatically set by the database

expire_at_ns: Option<i64>

Timestamp (in NS) after which the message must be deleted

should_push: bool

Whether to send a push notification when publishing this message

idempotency_key: String

The idempotency key the message id is derived from. Defaults to the send timestamp, but callers may supply their own to make retries idempotent.

Implementations

impl StoredGroupMessage

pub fn cursor(&self) -> Cursor

Trait Implementations

impl Clone for StoredGroupMessage

fn clone(&self) -> StoredGroupMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StoredGroupMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for StoredGroupMessage

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<StoredGroupMessage> for GroupMessageSave

fn from(value: StoredGroupMessage) -> Self

Converts to this type from the input type.

impl HasTable for StoredGroupMessage

type Table = table

The table this type is associated with.

fn table() -> <Self as HasTable>::Table

Returns the table this type is associated with.

impl<'ident> Identifiable for &'ident StoredGroupMessage

type Id = &'ident Vec<u8>

The type of this struct’s identifier.

fn id(self) -> <Self as Identifiable>::Id

Returns the identifier for this record.

impl PartialEq for StoredGroupMessage

fn eq(&self, other: &StoredGroupMessage) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<__DB: Backend, __ST0, __ST1, __ST2, __ST3, __ST4, __ST5, __ST6, __ST7, __ST8, __ST9, __ST10, __ST11, __ST12, __ST13, __ST14, __ST15, __ST16, __ST17, __ST18, __ST19> Queryable<(__ST0, __ST1, __ST2, __ST3, __ST4, __ST5, __ST6, __ST7, __ST8, __ST9, __ST10, __ST11, __ST12, __ST13, __ST14, __ST15, __ST16, __ST17, __ST18, __ST19), __DB> for StoredGroupMessage

where (Vec<u8>, GroupId, Vec<u8>, i64, GroupMessageKind, Vec<u8>, String, DeliveryStatus, ContentType, i32, i32, String, Option<Vec<u8>>, i64, Option<Vec<u8>>, Option<i64>, i64, Option<i64>, bool, String): FromStaticSqlRow<(__ST0, __ST1, __ST2, __ST3, __ST4, __ST5, __ST6, __ST7, __ST8, __ST9, __ST10, __ST11, __ST12, __ST13, __ST14, __ST15, __ST16, __ST17, __ST18, __ST19), __DB>,

type Row = (Vec<u8>, GroupId, Vec<u8>, i64, GroupMessageKind, Vec<u8>, String, DeliveryStatus, ContentType, i32, i32, String, Option<Vec<u8>>, i64, Option<Vec<u8>>, Option<i64>, i64, Option<i64>, bool, String)

The Rust type you’d like to map from.

fn build( row: (Vec<u8>, GroupId, Vec<u8>, i64, GroupMessageKind, Vec<u8>, String, DeliveryStatus, ContentType, i32, i32, String, Option<Vec<u8>>, i64, Option<Vec<u8>>, Option<i64>, i64, Option<i64>, bool, String), ) -> Result<Self>

Construct an instance of this type

impl<__DB: Backend> Selectable<__DB> for StoredGroupMessage

type SelectExpression = (id, group_id, decrypted_message_bytes, sent_at_ns, kind, sender_installation_id, sender_inbox_id, delivery_status, content_type, version_major, version_minor, authority_id, reference_id, sequence_id, envelope_hash, expiry_ns, inserted_at_ns, expire_at_ns, should_push, idempotency_key)

The expression you’d like to select.

fn construct_selection() -> Self::SelectExpression

Construct an instance of the expression

impl Serialize for StoredGroupMessage

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<C> Store<C> for StoredGroupMessage

where C: ConnectionExt,

type Output = ()

fn store(&self, into: &C) -> Result<(), StorageError>

impl<C> StoreOrIgnore<C> for StoredGroupMessage

where C: ConnectionExt,

type Output = ()

fn store_or_ignore(&self, into: &C) -> Result<(), StorageError>

impl TryFrom<GroupMessageSave> for StoredGroupMessage

type Error = ConversionError

The type returned in the event of a conversion error.

fn try_from(value: GroupMessageSave) -> Result<Self, Self::Error>

Performs the conversion.

impl Eq for StoredGroupMessage

impl StructuralPartialEq for StoredGroupMessage