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

use glory_hot_reload::diff::Patches;
use once_cell::sync::Lazy;
use tokio::sync::broadcast;

static RELOAD_CHANNEL: Lazy<broadcast::Sender<ReloadType>> = Lazy::new(|| broadcast::channel::<ReloadType>(1).0);

#[derive(Debug, Clone)]
pub enum ReloadType {
    Full,
    Style,
    ViewPatches(String),
}

pub struct ReloadSignal {}

impl ReloadSignal {
    pub fn send_full() {
        if let Err(e) = RELOAD_CHANNEL.send(ReloadType::Full) {
            log::error!(r#"Error could not send reload "Full" due to: {e}"#);
        }
    }
    pub fn send_style() {
        if let Err(e) = RELOAD_CHANNEL.send(ReloadType::Style) {
            log::error!(r#"Error could not send reload "Style" due to: {e}"#);
        }
    }

    pub fn send_view_patches(view_patches: &Patches) {
        match serde_json::to_string(view_patches) {
            Ok(data) => {
                if let Err(e) = RELOAD_CHANNEL.send(ReloadType::ViewPatches(data)) {
                    log::error!(r#"Error could not send reload "View Patches" due to: {e}"#);
                }
            }
            Err(e) => log::error!(r#"Error could not send reload "View Patches" due to: {e}"#),
        }
    }

    pub fn subscribe() -> broadcast::Receiver<ReloadType> {
        RELOAD_CHANNEL.subscribe()
    }
}