use std::time::Duration;
use wakuwaku::deps::kanau::processor::Processor;
use wakuwaku::{CronJob, CronJobInterval, CronTick, ServiceBuilder, ServiceCreation};

#[derive(Clone)]
struct SessionStore;

struct ExpireSessions { store: SessionStore }

impl ServiceCreation for ExpireSessions {
    type Dep = SessionStore;
    fn create_service(store: SessionStore) -> Self { Self { store } }
}

impl Processor<CronTick> for ExpireSessions {
    type Output = ();
    type Error = std::convert::Infallible;
    async fn process(&self, _tick: CronTick) -> Result<(), Self::Error> {
        // Scan for expired sessions and delete them.
        Ok(())
    }
}

impl CronJob for ExpireSessions {
    const INTERVAL: CronJobInterval = CronJobInterval::AtLeast(Duration::from_secs(60));
}

#[tokio::main]
async fn main() {
    let (services, cron) = ServiceBuilder::new(SessionStore)
        .cron_job::<ExpireSessions, _>()
        .start();

    // Build gRPC servers and Iggy handlers from `services` the same way:
    // `services.grpc_service::<XxxServer<_>, Impl, _>(XxxServer::new)`,
    // `services.iggy_consumer::<Handler, _, _>()`, or from several
    // services at once with `.compose_grpc_service(|s| ...)`.
    let _ = services;

    tokio::signal::ctrl_c().await.ok();
    cron.shutdown().await;
}