summary refs log tree commit diff
path: root/src/data/mod.rs
blob: 0c61bd7931fa786b541d21af0dc9b04085d86d1c (plain)
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
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
use serde::{Deserialize, Serialize};
use uuid::Uuid;

#[cfg(feature = "ssr")]
use fs2::FileExt;
#[cfg(feature = "ssr")]
use std::fs::File;
#[cfg(feature = "ssr")]
use std::sync::LazyLock;

use std::{collections::HashMap, path::Path};

mod config;
mod namespace;
mod page;

use config::Config;
pub use namespace::{Namespace, Namespaces};
pub use page::{Page, Pages};

#[derive(Hash, PartialEq, Eq, Clone, Debug, Deserialize, Serialize)]
pub struct PageUuid(Uuid);

#[cfg(feature = "ssr")]
pub static CONFIG: LazyLock<Config> =
    LazyLock::new(|| Config::read_from_file().expect("Could not open config file"));

#[cfg(feature = "ssr")]
static DATA_LOCK: LazyLock<StormscribeData> = LazyLock::new(|| {
    let config = &CONFIG;
    let lock_path = Path::join(&config.data_dir, ".lock");
    let lockfile = std::fs::OpenOptions::new()
        .read(true)
        .write(true)
        .create(true)
        .open(&lock_path)
        .map_err(|_| "Could not open data directory".to_string())
        .unwrap();

    lockfile
        .try_lock_exclusive()
        .map_err(|_| "Could not lock data directory".to_string())
        .unwrap();

    StormscribeData {
        file_lock: lockfile,
        namespaces: Namespaces::init(&Path::join(&config.data_dir, "namespace/")).unwrap(),
        pages: Pages::init(&Path::join(&config.data_dir, "pages/")).unwrap(),
    }
});

#[cfg(feature = "ssr")]
pub struct StormscribeData {
    file_lock: File,
    namespaces: Namespaces,
    pages: Pages,
}

#[cfg(feature = "ssr")]
impl StormscribeData {
    fn get_data() -> &'static Self {
        &DATA_LOCK
    }

    pub fn get_namespace() -> Namespace {
        DATA_LOCK.namespaces.root.clone()
    }

    pub fn get_pages() -> HashMap<PageUuid, Page> {
        DATA_LOCK.pages.pages.clone()
    }
}