forked from kemitix/git-next
81 lines
2 KiB
Rust
81 lines
2 KiB
Rust
type TestResult = Result<(), Box<dyn std::error::Error>>;
|
|
|
|
mod init {
|
|
use super::*;
|
|
#[test]
|
|
fn should_not_update_file_if_it_exists() -> TestResult {
|
|
let fs = kxio::fs::temp()?;
|
|
let file = fs.base().join(".git-next.toml");
|
|
fs.file_write(&file, "contents")?;
|
|
|
|
crate::init::run(&fs)?;
|
|
|
|
assert_eq!(
|
|
fs.file_read_to_string(&file)?,
|
|
"contents",
|
|
"The file has been changed"
|
|
);
|
|
|
|
Ok(())
|
|
}
|
|
|
|
#[test]
|
|
fn should_create_default_file_if_not_exists() -> TestResult {
|
|
let fs = kxio::fs::temp()?;
|
|
|
|
crate::init::run(&fs)?;
|
|
|
|
let file = fs.base().join(".git-next.toml");
|
|
|
|
assert!(fs.path_exists(&file)?, "The file has not been created");
|
|
|
|
assert_eq!(
|
|
fs.file_read_to_string(&file)?,
|
|
include_str!("../default.toml"),
|
|
"The file does not match the default template"
|
|
);
|
|
|
|
Ok(())
|
|
}
|
|
}
|
|
mod file_watcher {
|
|
use std::{sync::atomic::Ordering, time::Duration};
|
|
|
|
use actix::{Actor, Context, Handler};
|
|
use rstest::*;
|
|
|
|
use crate::file_watcher::{self, FileUpdated};
|
|
|
|
use super::TestResult;
|
|
|
|
#[rstest]
|
|
#[actix::test]
|
|
#[timeout(Duration::from_millis(80))]
|
|
async fn should_not_block_calling_thread() -> TestResult {
|
|
let fs = kxio::fs::temp()?;
|
|
let path = fs.base().join("file");
|
|
fs.file_write(&path, "foo")?;
|
|
|
|
let listener = Listener;
|
|
let l_addr = listener.start();
|
|
let recipient = l_addr.recipient();
|
|
|
|
let fw_shutdown = file_watcher::watch_file(path, recipient)?;
|
|
std::thread::sleep(Duration::from_millis(10));
|
|
fw_shutdown.store(true, Ordering::Relaxed);
|
|
|
|
Ok(()) // was not blocked
|
|
}
|
|
|
|
struct Listener;
|
|
impl Actor for Listener {
|
|
type Context = Context<Self>;
|
|
}
|
|
impl Handler<FileUpdated> for Listener {
|
|
type Result = ();
|
|
|
|
fn handle(&mut self, _msg: FileUpdated, _ctx: &mut Self::Context) -> Self::Result {
|
|
// todo!()
|
|
}
|
|
}
|
|
}
|