kanidm/kanidmd/src/lib/interval.rs

use actix::prelude::*;
use std::time::Duration;

use crate::actors::v1::QueryServerV1;
use crate::constants::PURGE_TIMEOUT;
use crate::event::{PurgeRecycledEvent, PurgeTombstoneEvent};

pub struct IntervalActor {
    // Store any addresses we require
    server: actix::Addr<QueryServerV1>,
}

impl IntervalActor {
    pub fn new(server: actix::Addr<QueryServerV1>) -> Self {
        IntervalActor { server: server }
    }

    // Define new events here
    fn purge_tombstones(&mut self) {
        // Make a purge request ...
        let pe = PurgeTombstoneEvent::new();
        self.server.do_send(pe)
    }

    fn purge_recycled(&mut self) {
        let pe = PurgeRecycledEvent::new();
        self.server.do_send(pe)
    }
}

impl Actor for IntervalActor {
    type Context = actix::Context<Self>;

    fn started(&mut self, ctx: &mut Self::Context) {
        // TODO #65: This timeout could be configurable from config?
        ctx.run_interval(Duration::from_secs(PURGE_TIMEOUT), move |act, _ctx| {
            act.purge_recycled();
        });
        ctx.run_interval(Duration::from_secs(PURGE_TIMEOUT), move |act, _ctx| {
            act.purge_tombstones();
        });
    }
}