Struct HandleChatCompletion 

pub struct HandleChatCompletion<FR, SR, EP, RP, LU, C, IG> {
    pub facts: FR,
    pub sessions: SR,
    pub embedder: EP,
    pub reranker: RP,
    pub upstream: LU,
    pub clock: C,
    pub id_generator: IG,
    pub retrieval_cfg: Arc<RetrievalConfig>,
    pub heat_cfg: Arc<HeatConfig>,
    pub persons: Arc<HashMap<String, PersonEntry>>,
    pub providers: Arc<Vec<ProviderEntry>>,
}

Top-level chat-completion orchestration.

Owns the ports the REQUEST-side pipeline needs (enrichment + upstream forwarding) plus the routing maps (persons, providers) needed to resolve a requested person into a concrete upstream route. Extraction ports live in AppState and are wired by the adapter — see the module docs for the layering rationale.

Fields

facts: FR

sessions: SR

embedder: EP

reranker: RP

upstream: LU

clock: C

id_generator: IG

retrieval_cfg: Arc<RetrievalConfig>

heat_cfg: Arc<HeatConfig>

persons: Arc<HashMap<String, PersonEntry>>

providers: Arc<Vec<ProviderEntry>>

Implementations

impl<FR, SR, EP, RP, LU, C, IG> HandleChatCompletion<FR, SR, EP, RP, LU, C, IG>

where FR: FactRepository, SR: SessionRepository, EP: EmbeddingProvider, RP: RerankProvider, LU: LlmUpstream, C: Clock, IG: IdGenerator,

pub async fn execute( &self, request: ChatRequest, ) -> Result<(ChatResponse, SessionId, MemoryKey), UseCaseError>

Run the chat-completion pipeline.

Returns the upstream response, the session id (so the handler injects the marker), and the memory namespace (so the adapter spawns the extraction task against the correct project).