From b2646ccab322549880d76788ecd5366b9eccb929 Mon Sep 17 00:00:00 2001 From: Paul Campbell Date: Fri, 1 Nov 2024 08:55:59 +0000 Subject: [PATCH] feat(fs)!: remove legacy filesystem module --- src/filesystem.rs | 167 ---------------------------------------- src/lib.rs | 4 +- src/tests/filesystem.rs | 12 --- src/tests/mod.rs | 4 +- 4 files changed, 2 insertions(+), 185 deletions(-) delete mode 100644 src/filesystem.rs delete mode 100644 src/tests/filesystem.rs diff --git a/src/filesystem.rs b/src/filesystem.rs deleted file mode 100644 index f651d65..0000000 --- a/src/filesystem.rs +++ /dev/null @@ -1,167 +0,0 @@ -#![allow(deprecated)] - -use std::{ - ops::Deref, - path::PathBuf, - sync::{Arc, Mutex}, -}; - -use tempfile::{tempdir, TempDir}; -use tracing::{debug, info}; - -pub fn real(cwd: Option) -> FileSystem { - let cwd = cwd.unwrap_or_default(); - FileSystem::Real(RealFileSystem::new(cwd)) -} -pub fn temp() -> std::io::Result { - TempFileSystem::new().map(FileSystem::Temp) -} - -#[derive(Clone, Debug)] -#[deprecated(since = "1.1.0", note = "Use [kxio::fs::FileSystem] instead")] -pub enum FileSystem { - Real(RealFileSystem), - Temp(TempFileSystem), -} -impl FileSystem { - #[deprecated(since = "1.1.0", note = "Use [kxio::filesystem::real()] instead")] - pub fn new_real(cwd: Option) -> Self { - real(cwd) - } - #[deprecated(since = "1.1.0", note = "Use [kxio::filesystem::temp()] instead")] - pub fn new_temp() -> std::io::Result { - temp() - } -} -impl Deref for FileSystem { - type Target = dyn FileSystemLike; - - fn deref(&self) -> &Self::Target { - match self { - Self::Real(env) => env, - Self::Temp(env) => env, - } - } -} - -pub trait FileSystemLike: Sync + Send + std::fmt::Debug { - fn cwd(&self) -> &PathBuf; - - fn in_cwd(&self, name: &str) -> PathBuf { - self.cwd().join(name) - } - - fn write_file(&self, file_name: &str, content: &str) -> std::io::Result { - use std::fs::File; - use std::io::{LineWriter, Write}; - - let path = self.in_cwd(file_name); - debug!("writing to {:?}", path); - let file = File::create(path.clone())?; - let mut file = LineWriter::new(file); - file.write_all(content.as_bytes())?; - Ok(path) - } - - fn file_exists(&self, name: &PathBuf) -> bool { - use std::fs::File; - File::open(name).is_ok() - } - - fn read_file(&self, file_name: &str) -> std::io::Result { - use std::fs::File; - use std::io::Read; - - let path = self.in_cwd(file_name); - debug!("reading from {:?}", path); - let mut file = File::open(path)?; - let mut content = String::new(); - file.read_to_string(&mut content)?; - Ok(content) - } -} - -#[derive(Clone, Debug, Default)] -pub struct RealFileSystem { - cwd: PathBuf, -} - -#[derive(Clone, Debug)] -pub struct TempFileSystem { - cwd: PathBuf, - - // Handle to the temporary directory - // When this handle is dropped the directory is deleted - _temp_dir: Arc>, -} - -impl FileSystemLike for TempFileSystem { - fn cwd(&self) -> &PathBuf { - &self.cwd - } -} - -impl FileSystemLike for RealFileSystem { - fn cwd(&self) -> &PathBuf { - &self.cwd - } -} - -impl RealFileSystem { - const fn new(cwd: PathBuf) -> Self { - Self { cwd } - } -} - -impl TempFileSystem { - fn new() -> std::io::Result { - let temp_dir = tempdir()?; - info!("temp dir: {:?}", temp_dir.path()); - let cwd = temp_dir.path().to_path_buf(); - let temp_dir = Arc::new(Mutex::new(temp_dir)); - Ok(Self { - cwd, - _temp_dir: temp_dir, - }) - } -} - -#[cfg(test)] -mod tests { - - use super::*; - - use std::path::PathBuf; - - #[test_log::test] - fn test_cwd() { - let cwd = PathBuf::from("/tmp"); - let env = RealFileSystem::new(cwd.clone()); - assert_eq!(env.cwd(), &cwd); - } - - #[test_log::test] - fn test_create_on_temp_fs() -> std::io::Result<()> { - let env = TempFileSystem::new()?; - assert!(env.cwd().exists()); - Ok(()) - } - - #[test_log::test] - fn test_create_on_real_fs() { - let cwd = PathBuf::from("/tmp"); - let env = RealFileSystem::new(cwd.clone()); - assert_eq!(env.cwd(), &cwd); - } - - #[test_log::test] - fn test_write_and_read_file() -> std::io::Result<()> { - let env = TempFileSystem::new()?; - let file_name = "test.txt"; - let content = "Hello, World!"; - let path = env.write_file(file_name, content)?; - assert_eq!(env.read_file(file_name)?, content); - assert!(path.exists()); - Ok(()) - } -} diff --git a/src/lib.rs b/src/lib.rs index 83c0cba..3bf5b20 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -1,6 +1,4 @@ -#[cfg(feature = "fs")] -pub mod filesystem; - +// #[cfg(feature = "fs")] pub mod fs; diff --git a/src/tests/filesystem.rs b/src/tests/filesystem.rs deleted file mode 100644 index ede71e9..0000000 --- a/src/tests/filesystem.rs +++ /dev/null @@ -1,12 +0,0 @@ -type TestResult = Result<(), Box>; - -#[test] -fn write_read_file_exists() -> TestResult { - let fs = crate::filesystem::temp()?; - let pathbuf = fs.write_file("foo", "content")?; - let c = fs.read_file("foo")?; - assert_eq!(c, "content"); - assert!(fs.file_exists(&pathbuf)); - - Ok(()) -} diff --git a/src/tests/mod.rs b/src/tests/mod.rs index 0ea12c5..2448679 100644 --- a/src/tests/mod.rs +++ b/src/tests/mod.rs @@ -1,6 +1,4 @@ -#[cfg(feature = "fs")] -pub mod filesystem; - +// #[cfg(feature = "fs")] pub mod fs;