plane 0.5.5

Session backend orchestrator for ambitious browser-based apps.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51

use crate::database::{subscribe::EventSubscriptionManager, PlaneDatabase};
use anyhow::Result;

const CLEANUP_LOOP_INTERVAL_SECONDS: u64 = 60 * 3;
const DEFAULT_BATCH_SIZE: i32 = 100;

pub async fn run_cleanup(
    db: &PlaneDatabase,
    min_age_days: Option<i32>,
    cleanup_batch_size: Option<i32>,
) -> Result<()> {
    tracing::info!("Running cleanup");

    if let Some(min_age_days) = min_age_days {
        db.backend()
            .cleanup(
                min_age_days,
                cleanup_batch_size.unwrap_or(DEFAULT_BATCH_SIZE),
            )
            .await?;
        EventSubscriptionManager::clean_up_events(&db.pool, min_age_days).await?;
    }

    db.clean_up_tokens().await?;

    tracing::info!("Done running cleanup");

    Ok(())
}

pub async fn run_cleanup_loop(
    db: PlaneDatabase,
    min_age_days: Option<i32>,
    cleanup_batch_size: Option<i32>,
) {
    // Each controller runs a cleanup loop. To avoid having them all run at the same time, we
    // introduce a random offset to the start time.
    let random_offset_seconds = rand::random::<u64>() % CLEANUP_LOOP_INTERVAL_SECONDS;
    tokio::time::sleep(tokio::time::Duration::from_secs(random_offset_seconds)).await;

    loop {
        if let Err(e) = run_cleanup(&db, min_age_days, cleanup_batch_size).await {
            tracing::error!("Error running cleanup: {:?}", e);
        }

        tokio::time::sleep(tokio::time::Duration::from_secs(
            CLEANUP_LOOP_INTERVAL_SECONDS,
        ))
        .await;
    }
}