reflexo-typst 0.7.0

Bridge Typst to Web Rendering, with power of typst.
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
52
53
54

//! The actor that handles cache evicting.

use std::sync::{atomic::AtomicUsize, Arc};

use super::{FutureFolder, SyncTaskFactory};

#[derive(Debug, Clone)]
pub struct CacheUserConfig {
    pub max_age: usize,
}

impl Default for CacheUserConfig {
    fn default() -> Self {
        Self { max_age: 30 }
    }
}

#[derive(Clone, Default)]
pub struct CacheTask {
    factory: SyncTaskFactory<CacheUserConfig>,
    cache_evict_folder: FutureFolder,
    revision: Arc<AtomicUsize>,
}

impl CacheTask {
    pub fn new(c: CacheUserConfig) -> Self {
        Self {
            factory: SyncTaskFactory::new(c),
            cache_evict_folder: FutureFolder::default(),
            revision: Arc::new(AtomicUsize::default()),
        }
    }

    pub fn evict(&self) {
        let revision = self
            .revision
            .fetch_add(1, std::sync::atomic::Ordering::Relaxed);
        let task = self.factory.task();
        self.cache_evict_folder.spawn(revision, || {
            Box::pin(async move {
                let _ = FutureFolder::compute(move |_| {
                    // Evict compilation cache.
                    let evict_start = std::time::Instant::now();
                    comemo::evict(task.max_age);
                    let elapsed = evict_start.elapsed();
                    log::debug!("CacheEvictTask: evict cache in {elapsed:?}");
                })
                .await;

                Some(())
            })
        });
    }
}