use super::{ Id, event::{Created, Event}, }; use crate::{clock::DateTime, name::Name}; #[derive(Clone, Debug, Eq, PartialEq, serde::Serialize)] pub struct Channel { pub id: Id, pub name: Name, #[serde(skip_serializing_if = "Option::is_none")] pub deleted_at: Option, } impl Channel { fn apply(state: Option, event: Event) -> Option { match (state, event) { (None, Event::Created(event)) => Some(event.into()), (Some(channel), Event::Deleted(event)) if channel.id == event.id => None, (state, event) => panic!("invalid channel event {event:#?} for state {state:#?}"), } } } impl FromIterator for Option { fn from_iter>(events: I) -> Self { events.into_iter().fold(None, Channel::apply) } } impl From<&Created> for Channel { fn from(event: &Created) -> Self { event.channel.clone() } } impl From for Channel { fn from(event: Created) -> Self { event.channel } }