Struct EventService

pub struct EventService<S>
where
    S: EventStore,
{ /* private fields */ }

Service for managing domain events with DTO conversion

Implementations

impl<S> EventService<S>

where S: EventStore,

pub fn new(event_store: Arc<Mutex<S>>) -> Self

Create new event service with event store

pub fn add_subscriber( &mut self, subscriber: Arc<dyn EventSubscriber + Send + Sync>, )

Add event subscriber

pub async fn publish_event( &mut self, event: DomainEvent, ) -> ApplicationResult<()>

Publish domain event (converts to DTO for serialization)

pub async fn publish_events( &mut self, events: Vec<DomainEvent>, ) -> ApplicationResult<()>

Publish multiple domain events

pub fn get_session_events_dto( &self, session_id: SessionId, ) -> ApplicationResult<Vec<DomainEventDto>>

Get events for session as DTOs (for API responses)

pub fn get_stream_events_dto( &self, stream_id: StreamId, ) -> ApplicationResult<Vec<DomainEventDto>>

Get events for stream as DTOs (for API responses)

pub fn get_events_since_dto( &self, since: DateTime<Utc>, ) -> ApplicationResult<Vec<DomainEventDto>>

Get events since timestamp as DTOs (for API responses)

pub fn get_session_events( &self, session_id: SessionId, ) -> ApplicationResult<Vec<DomainEvent>>

Get events for session (domain objects, for internal use)

pub fn get_stream_events( &self, stream_id: StreamId, ) -> ApplicationResult<Vec<DomainEvent>>

Get events for stream (domain objects, for internal use)

pub fn replay_from_dtos( &mut self, event_dtos: Vec<DomainEventDto>, ) -> ApplicationResult<Vec<DomainEvent>>

Replay events from DTOs (for event sourcing reconstruction)

impl<S> EventService<S>

where S: EventStore,

Event publishing convenience methods

pub async fn publish_session_activated( &mut self, session_id: SessionId, ) -> ApplicationResult<()>

Publish session activated event

pub async fn publish_session_closed( &mut self, session_id: SessionId, ) -> ApplicationResult<()>

Publish session closed event

pub async fn publish_stream_created( &mut self, session_id: SessionId, stream_id: StreamId, ) -> ApplicationResult<()>

Publish stream created event

pub async fn publish_stream_completed( &mut self, session_id: SessionId, stream_id: StreamId, ) -> ApplicationResult<()>

Publish stream completed event

pub async fn publish_stream_failed( &mut self, session_id: SessionId, stream_id: StreamId, error: String, ) -> ApplicationResult<()>

Publish stream failed event