lariv-rs 0.1.0

Compile-time plugin web application framework built on Axum, SeaORM, Maud, and HTMX
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

//! Start the IMAP email listener when the HTTP server starts (`serve` only).

use crate::{app::MountedApp, hooks::RunServeStartup, traits::get::GetByTag};

use super::{LlmAssistantTag, state::LlmAssistantState};

/// Start the background IMAP IDLE listener (not on migrate/seed).
#[derive(Clone, Copy, Default)]
pub struct ServeStartupHook;

#[async_trait::async_trait]
impl<M, AsstIdx> RunServeStartup<M, AsstIdx> for ServeStartupHook
where
    M: GetByTag<LlmAssistantTag, AsstIdx, Value = LlmAssistantState> + Sync,
{
    async fn run_serve_startup(app: &MountedApp<M>) -> anyhow::Result<()> {
        let state = app.get_capability_output::<LlmAssistantTag, AsstIdx>();
        state.email_listener.ensure_started();
        Ok(())
    }
}