use super::{snapshot::Message, Id}; use crate::{ channel::Channel, event::{Instant, Sequenced}, }; #[derive(Clone, Debug, Eq, PartialEq, serde::Serialize)] pub struct Event { #[serde(flatten)] pub instant: Instant, #[serde(flatten)] pub kind: Kind, } impl Sequenced for Event { fn instant(&self) -> Instant { self.instant } } #[derive(Clone, Debug, Eq, PartialEq, serde::Serialize)] #[serde(tag = "type", rename_all = "snake_case")] pub enum Kind { Sent(Sent), Deleted(Deleted), } #[derive(Clone, Debug, Eq, PartialEq, serde::Serialize)] pub struct Sent { #[serde(flatten)] pub message: Message, } impl From for Kind { fn from(event: Sent) -> Self { Self::Sent(event) } } #[derive(Clone, Debug, Eq, PartialEq, serde::Serialize)] pub struct Deleted { pub channel: Channel, pub message: Id, } impl From for Kind { fn from(event: Deleted) -> Self { Self::Deleted(event) } }