Struct SessionCommandHandler 

pub struct SessionCommandHandler<R, P, F = InMemoryFrameStore>
where
    R: StreamRepositoryGat + 'static,
    P: EventPublisherGat + 'static,
    F: FrameStoreGat + 'static,
{ /* private fields */ }

Handler for session management commands.

Holds an optional DictionaryStore (defaulting to NoopDictionaryStore) so that frame-generating commands can feed accepted frame payloads into the per-session training corpus. Without this wiring the GET /pjs/sessions/{id}/dictionary endpoint would be unreachable end-to-end.

Also holds a FrameStoreGat (defaulting to InMemoryFrameStore) so frames produced by GenerateFramesCommand / BatchGenerateFramesCommand remain queryable through GET /pjs/sessions/{id}/streams/{id}/frames.

Implementations

impl<R, P> SessionCommandHandler<R, P, InMemoryFrameStore>

where R: StreamRepositoryGat + 'static, P: EventPublisherGat + 'static,

pub fn new(repository: Arc<R>, event_publisher: Arc<P>) -> Self

Create a handler with the no-op DictionaryStore and a fresh InMemoryFrameStore.

The dictionary endpoint will return 404 Not Found until the handler is constructed with SessionCommandHandler::with_stores and a concrete DictionaryStore such as crate::infrastructure::repositories::InMemoryDictionaryStore.

pub fn with_dictionary_store( repository: Arc<R>, event_publisher: Arc<P>, dictionary_store: Arc<dyn DictionaryStore>, ) -> Self

Create a handler with a custom DictionaryStore and a fresh InMemoryFrameStore.

impl<R, P, F> SessionCommandHandler<R, P, F>

where R: StreamRepositoryGat + 'static, P: EventPublisherGat + 'static, F: FrameStoreGat + 'static,

pub fn with_stores( repository: Arc<R>, event_publisher: Arc<P>, dictionary_store: Arc<dyn DictionaryStore>, frame_store: Arc<F>, ) -> Self

Create a handler that feeds accepted frames into both the dictionary training corpus and the FrameStoreGat used by the frames query endpoint.

Trait Implementations

impl<R, P, F> CommandHandlerGat<BatchGenerateFramesCommand> for SessionCommandHandler<R, P, F>

where R: StreamRepositoryGat + Send + Sync, P: EventPublisherGat + Send + Sync, F: FrameStoreGat + Send + Sync,

type Response = Vec<Frame>

The response type for this command

type HandleFuture<'a> = impl Future<Output = Result<<SessionCommandHandler<R, P, F> as CommandHandlerGat<BatchGenerateFramesCommand>>::Response, ApplicationError>> + Send + 'a where Self: 'a

Future type returned by handle method

fn handle(&self, command: BatchGenerateFramesCommand) -> Self::HandleFuture<'_>

Handle the command and return a future

impl<R, P, F> CommandHandlerGat<CloseSessionCommand> for SessionCommandHandler<R, P, F>

where R: StreamRepositoryGat + Send + Sync, P: EventPublisherGat + Send + Sync, F: FrameStoreGat + Send + Sync,

type Response = ()

The response type for this command

type HandleFuture<'a> = impl Future<Output = Result<<SessionCommandHandler<R, P, F> as CommandHandlerGat<CloseSessionCommand>>::Response, ApplicationError>> + Send + 'a where Self: 'a

Future type returned by handle method

fn handle(&self, command: CloseSessionCommand) -> Self::HandleFuture<'_>

Handle the command and return a future

impl<R, P, F> CommandHandlerGat<CompleteStreamCommand> for SessionCommandHandler<R, P, F>

where R: StreamRepositoryGat + Send + Sync, P: EventPublisherGat + Send + Sync, F: FrameStoreGat + Send + Sync,

type Response = ()

The response type for this command

type HandleFuture<'a> = impl Future<Output = Result<<SessionCommandHandler<R, P, F> as CommandHandlerGat<CompleteStreamCommand>>::Response, ApplicationError>> + Send + 'a where Self: 'a

Future type returned by handle method

fn handle(&self, command: CompleteStreamCommand) -> Self::HandleFuture<'_>

Handle the command and return a future

impl<R, P, F> CommandHandlerGat<CreateSessionCommand> for SessionCommandHandler<R, P, F>

where R: StreamRepositoryGat + Send + Sync, P: EventPublisherGat + Send + Sync, F: FrameStoreGat + Send + Sync,

type Response = Id<SessionMarker>

The response type for this command

type HandleFuture<'a> = impl Future<Output = Result<<SessionCommandHandler<R, P, F> as CommandHandlerGat<CreateSessionCommand>>::Response, ApplicationError>> + Send + 'a where Self: 'a

Future type returned by handle method

fn handle(&self, command: CreateSessionCommand) -> Self::HandleFuture<'_>

Handle the command and return a future

impl<R, P, F> CommandHandlerGat<CreateStreamCommand> for SessionCommandHandler<R, P, F>

where R: StreamRepositoryGat + Send + Sync, P: EventPublisherGat + Send + Sync, F: FrameStoreGat + Send + Sync,

type Response = Id<StreamMarker>

The response type for this command

type HandleFuture<'a> = impl Future<Output = Result<<SessionCommandHandler<R, P, F> as CommandHandlerGat<CreateStreamCommand>>::Response, ApplicationError>> + Send + 'a where Self: 'a

Future type returned by handle method

fn handle(&self, command: CreateStreamCommand) -> Self::HandleFuture<'_>

Handle the command and return a future

impl<R, P, F> CommandHandlerGat<GenerateFramesCommand> for SessionCommandHandler<R, P, F>

where R: StreamRepositoryGat + Send + Sync, P: EventPublisherGat + Send + Sync, F: FrameStoreGat + Send + Sync,

type Response = Vec<Frame>

The response type for this command

type HandleFuture<'a> = impl Future<Output = Result<<SessionCommandHandler<R, P, F> as CommandHandlerGat<GenerateFramesCommand>>::Response, ApplicationError>> + Send + 'a where Self: 'a

Future type returned by handle method

fn handle(&self, command: GenerateFramesCommand) -> Self::HandleFuture<'_>

Handle the command and return a future

impl<R, P, F> CommandHandlerGat<StartStreamCommand> for SessionCommandHandler<R, P, F>

where R: StreamRepositoryGat + Send + Sync, P: EventPublisherGat + Send + Sync, F: FrameStoreGat + Send + Sync,

type Response = ()

The response type for this command

type HandleFuture<'a> = impl Future<Output = Result<<SessionCommandHandler<R, P, F> as CommandHandlerGat<StartStreamCommand>>::Response, ApplicationError>> + Send + 'a where Self: 'a

Future type returned by handle method

fn handle(&self, command: StartStreamCommand) -> Self::HandleFuture<'_>

Handle the command and return a future

impl<R, P, F> Debug for SessionCommandHandler<R, P, F>

where R: StreamRepositoryGat + 'static, P: EventPublisherGat + 'static, F: FrameStoreGat + 'static,

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

Formats the value using the given formatter.