5954012408

Committed 23 Aug 2023 04:32PM UTC coverage: 75.86% (-0.2%) from 76.088%

Build # 5954012408

Build Type

push

github

Committed by

web-flow

Commit Message

chore: Move ContractService implementation to Contract (#1899)

* chore: Split `build.rs` to several files

* chore: Remove `serde` from `dozer-cli/Cargo.toml`

* chore: Move `ContractService` implementation to `Contract`

Run Details

461 of 461 new or added lines in 8 files covered. (100.0%)

46996 of 61951 relevant lines covered (75.86%)

73804.64 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/dozer-cli/src/live/watcher.rs

use std::{sync::Arc, time::Duration};

use crate::shutdown::ShutdownReceiver;

use super::{state::LiveState, LiveError};

use dozer_types::log::info;
use notify::{RecursiveMode, Watcher};
use notify_debouncer_full::new_debouncer;
use tokio::runtime::Runtime;

pub async fn watch(
    runtime: &Arc<Runtime>,
    state: Arc<LiveState>,
    shutdown: ShutdownReceiver,
) -> Result<(), LiveError> {
    // setup debouncer
    let (tx, rx) = std::sync::mpsc::channel();

    let dir: std::path::PathBuf = std::env::current_dir()?;
    let mut debouncer = new_debouncer(Duration::from_millis(500), None, tx)?;

    let watcher = debouncer.watcher();

    watcher.watch(dir.as_path(), RecursiveMode::Recursive)?;

    debouncer
        .cache()
        .add_root(dir.as_path(), RecursiveMode::Recursive);

    let running = shutdown.get_running_flag().clone();
    loop {
        let event = rx.recv_timeout(Duration::from_millis(100));
        match event {
            Ok(result) => match result {
                Ok(_events) => {
                    build(runtime.clone(), state.clone()).await;
                }
                Err(errors) => errors.iter().for_each(|error| info!("{error:?}")),
            },
            Err(e) => {
                if !running.load(std::sync::atomic::Ordering::Relaxed) {
                    break;
                }
                if e == std::sync::mpsc::RecvTimeoutError::Disconnected {
                    break;
                }
            }
        }
    }

    Ok(())
}

async fn build(runtime: Arc<Runtime>, state: Arc<LiveState>) {
    state.set_dozer(None).await;

    state.broadcast().await;

    if let Err(res) = state.build(runtime).await {
        state.set_error_message(Some(res.to_string())).await;
    } else {
        state.set_error_message(None).await;
    }
    state.broadcast().await;
}

1	use std::{sync::Arc, time::Duration};
2
3	use crate::shutdown::ShutdownReceiver;
4
5	use super::{state::LiveState, LiveError};
6
7	use dozer_types::log::info;
8	use notify::{RecursiveMode, Watcher};
9	use notify_debouncer_full::new_debouncer;
10	use tokio::runtime::Runtime;
11
12	pub async fn watch(	×
13	runtime: &Arc<Runtime>,	×
14	state: Arc<LiveState>,	×
15	shutdown: ShutdownReceiver,	×
16	) -> Result<(), LiveError> {	×
17	// setup debouncer	×
18	let (tx, rx) = std::sync::mpsc::channel();	×
19
20	let dir: std::path::PathBuf = std::env::current_dir()?;	×
21	let mut debouncer = new_debouncer(Duration::from_millis(500), None, tx)?;	×
22
23	let watcher = debouncer.watcher();	×
24		×
25	watcher.watch(dir.as_path(), RecursiveMode::Recursive)?;	×
26
27	debouncer	×
28	.cache()	×
29	.add_root(dir.as_path(), RecursiveMode::Recursive);	×
30		×
31	let running = shutdown.get_running_flag().clone();	×
32	loop {	×
33	let event = rx.recv_timeout(Duration::from_millis(100));	×
34	match event {	×
35	Ok(result) => match result {	×
36	Ok(_events) => {	×
37	build(runtime.clone(), state.clone()).await;	×
38	}
39	Err(errors) => errors.iter().for_each(\|error\| info!("{error:?}")),	×
40	},
41	Err(e) => {	×
42	if !running.load(std::sync::atomic::Ordering::Relaxed) {	×
43	break;	×
44	}	×
45	if e == std::sync::mpsc::RecvTimeoutError::Disconnected {	×
46	break;	×
47	}	×
48	}
49	}
50	}
51
52	Ok(())	×
53	}	×
54
55	async fn build(runtime: Arc<Runtime>, state: Arc<LiveState>) {	×
56	state.set_dozer(None).await;	×
57
58	state.broadcast().await;	×
59
60	if let Err(res) = state.build(runtime).await {	×
61	state.set_error_message(Some(res.to_string())).await;	×
62	} else {
63	state.set_error_message(None).await;	×
64	}
65	state.broadcast().await;	×
66	}	×

getdozer / dozer / 5954012408

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous