rspack_fs 0.100.4

use std::{
  io::{BufRead, Cursor, Read, Seek},
  sync::{Arc, Mutex},
};

use rspack_paths::{AssertUtf8, Utf8Path, Utf8PathBuf};
use rspack_util::{
  current_time,
  fx_hash::{FxHashMap, FxHashSet},
};

use crate::{
  Error, FileMetadata, IntermediateFileSystem, IntermediateFileSystemExtras, IoResultToFsResultExt,
  ReadStream, ReadableFileSystem, Result, WritableFileSystem, WriteStream,
  file_metadata::FilePermissions,
};

fn new_error(msg: &str) -> Error {
  Error::Io(std::io::Error::other(msg))
}

#[derive(Debug)]
enum FileType {
  Dir(FileMetadata),
  File {
    content: Vec<u8>,
    metadata: FileMetadata,
  },
}

impl FileType {
  pub fn new_dir() -> FileType {
    let now = current_time();
    FileType::Dir(FileMetadata {
      is_file: false,
      is_directory: true,
      is_symlink: false,
      atime_ms: now,
      mtime_ms: now,
      ctime_ms: now,
      size: 0,
    })
  }

  pub fn new_file(content: Vec<u8>) -> FileType {
    let now = current_time();
    FileType::File {
      metadata: FileMetadata {
        is_file: true,
        is_directory: false,
        is_symlink: false,
        atime_ms: now,
        mtime_ms: now,
        ctime_ms: now,
        size: content.len() as u64,
      },
      content,
    }
  }

  pub fn metadata(&self) -> &FileMetadata {
    match self {
      Self::Dir(metadata) => metadata,
      Self::File { metadata, .. } => metadata,
    }
  }
}

#[derive(Debug, Default, Clone)]
pub struct MemoryFileSystem {
  files: Arc<Mutex<FxHashMap<Utf8PathBuf, FileType>>>,
}

impl MemoryFileSystem {
  pub fn clear(&self) {
    let mut files = self.files.lock().expect("should get lock");
    files.clear();
  }

  fn contains_dir(&self, dir: &Utf8Path) -> Result<bool> {
    let files = self.files.lock().expect("should get lock");
    if let Some(ft) = files.get(dir) {
      if let FileType::Dir(_) = ft {
        return Ok(true);
      } else {
        return Err(new_error("invalid dir path"));
      }
    }
    Ok(false)
  }

  fn contains_file(&self, file: &Utf8Path) -> Result<bool> {
    let files = self.files.lock().expect("should get lock");
    if let Some(ft) = files.get(file) {
      if let FileType::File { .. } = ft {
        return Ok(true);
      } else {
        return Err(new_error("invalid file path"));
      }
    }
    Ok(false)
  }

  fn _remove_file(&self, file: &Utf8Path) -> Result<()> {
    if self.contains_file(file)? {
      let mut files = self.files.lock().expect("should get lock");
      files.remove(file);
    }
    Ok(())
  }

  async fn _remove_dir_all(&self, dir: &Utf8Path) -> Result<()> {
    if self.contains_dir(dir)? {
      let mut files = self.files.lock().expect("should get lock");
      files.retain(|path, _| !path.starts_with(dir));
    }
    Ok(())
  }

  fn _read_dir(&self, dir: &Utf8Path) -> Result<Vec<String>> {
    if !self.contains_dir(dir)? {
      return Err(new_error("dir not exist"));
    }

    let files = self.files.lock().expect("should get lock");
    let mut res: FxHashSet<String> = FxHashSet::default();
    for path in files.keys() {
      if let Ok(relative) = path.strip_prefix(dir)
        && let Some(s) = relative.iter().next()
      {
        res.insert(s.to_string());
      }
    }
    Ok(res.into_iter().collect())
  }

  fn _rename_file(&self, from: &Utf8Path, to: &Utf8Path) -> Result<()> {
    if !self.contains_file(from)? {
      return Err(new_error("from dir not exist"));
    }
    let mut files = self.files.lock().expect("should get lock");
    let file = files.remove(from).expect("should have file");
    files.insert(to.into(), file);

    Ok(())
  }
}
#[async_trait::async_trait]
impl WritableFileSystem for MemoryFileSystem {
  async fn create_dir(&self, dir: &Utf8Path) -> Result<()> {
    if self.contains_dir(dir)? {
      return Ok(());
    }

    if let Some(p) = dir.parent()
      && !self.contains_dir(p)?
    {
      return Err(new_error("parent directory not exist"));
    }

    let mut files = self.files.lock().expect("should get lock");
    files.insert(dir.to_path_buf(), FileType::new_dir());
    Ok(())
  }

  async fn create_dir_all(&self, dir: &Utf8Path) -> Result<()> {
    if self.contains_dir(dir)? {
      return Ok(());
    }

    if let Some(p) = dir.parent() {
      WritableFileSystem::create_dir_all(self, p).await?;
    }
    let mut files = self.files.lock().expect("should get lock");
    files.insert(dir.to_path_buf(), FileType::new_dir());
    Ok(())
  }

  async fn write(&self, file: &Utf8Path, data: &[u8]) -> Result<()> {
    {
      // check file exist and update it
      let mut files = self.files.lock().expect("should get lock");
      if let Some(ft) = files.get_mut(file) {
        if let FileType::File { content, metadata } = ft {
          let now = current_time();
          *content = data.to_vec();
          metadata.mtime_ms = now;
          metadata.atime_ms = now;
          metadata.size = data.len() as u64;
          return Ok(());
        } else {
          return Err(new_error("invalid file path"));
        }
      };
    }

    // create file
    let p = file.parent().expect("should have parent dir");
    if !self.contains_dir(p)? {
      return Err(new_error("parent dir not exist"));
    }

    let mut files = self.files.lock().expect("should get lock");
    files.insert(file.to_path_buf(), FileType::new_file(data.to_vec()));
    Ok(())
  }

  async fn remove_file(&self, file: &Utf8Path) -> Result<()> {
    self._remove_file(file)
  }

  async fn remove_dir_all(&self, dir: &Utf8Path) -> Result<()> {
    self._remove_dir_all(dir).await
  }

  async fn read_dir(&self, dir: &Utf8Path) -> Result<Vec<String>> {
    self._read_dir(dir)
  }

  async fn read_file(&self, file: &Utf8Path) -> Result<Vec<u8>> {
    ReadableFileSystem::read(self, file).await
  }

  async fn stat(&self, file: &Utf8Path) -> Result<FileMetadata> {
    ReadableFileSystem::metadata(self, file).await
  }

  async fn set_permissions(&self, _path: &Utf8Path, _perm: FilePermissions) -> Result<()> {
    Ok(())
  }
}

#[async_trait::async_trait]
impl ReadableFileSystem for MemoryFileSystem {
  async fn read(&self, path: &Utf8Path) -> Result<Vec<u8>> {
    self.read_sync(path)
  }

  fn read_sync(&self, path: &Utf8Path) -> Result<Vec<u8>> {
    let files = self.files.lock().expect("should get lock");
    match files.get(path) {
      Some(FileType::File { content, .. }) => Ok(content.clone()),
      _ => Err(Error::Io(std::io::Error::new(
        std::io::ErrorKind::NotFound,
        "file not exist",
      ))),
    }
  }

  async fn metadata(&self, path: &Utf8Path) -> Result<FileMetadata> {
    self.metadata_sync(path)
  }

  fn metadata_sync(&self, path: &Utf8Path) -> Result<FileMetadata> {
    let files = self.files.lock().expect("should get lock");
    match files.get(path) {
      Some(ft) => Ok(ft.metadata().clone()),
      None => Err(Error::Io(std::io::Error::new(
        std::io::ErrorKind::NotFound,
        "file not exist",
      ))),
    }
  }

  async fn symlink_metadata(&self, path: &Utf8Path) -> Result<FileMetadata> {
    self.metadata(path).await
  }

  async fn canonicalize(&self, path: &Utf8Path) -> Result<Utf8PathBuf> {
    let path = dunce::canonicalize(path)?;
    Ok(path.assert_utf8())
  }

  async fn read_dir(&self, dir: &Utf8Path) -> Result<Vec<String>> {
    self._read_dir(dir)
  }

  fn read_dir_sync(&self, dir: &Utf8Path) -> Result<Vec<String>> {
    self._read_dir(dir)
  }

  async fn permissions(&self, _path: &Utf8Path) -> Result<Option<FilePermissions>> {
    Ok(None)
  }
}

#[async_trait::async_trait]
impl IntermediateFileSystemExtras for MemoryFileSystem {
  async fn rename(&self, from: &Utf8Path, to: &Utf8Path) -> Result<()> {
    self._rename_file(from, to)?;
    Ok(())
  }

  async fn create_read_stream(&self, file: &Utf8Path) -> Result<Box<dyn ReadStream>> {
    let contents = self.read(file).await?;
    let reader = MemoryReadStream::new(contents);
    Ok(Box::new(reader))
  }

  async fn create_write_stream(&self, file: &Utf8Path) -> Result<Box<dyn WriteStream>> {
    let writer = MemoryWriteStream::new(file, self.clone());
    Ok(Box::new(writer))
  }
}

impl IntermediateFileSystem for MemoryFileSystem {}

#[derive(Debug)]
pub struct MemoryReadStream(Cursor<Vec<u8>>);

impl MemoryReadStream {
  pub fn new(contents: Vec<u8>) -> Self {
    Self(Cursor::new(contents))
  }
}

#[async_trait::async_trait]
impl ReadStream for MemoryReadStream {
  async fn read(&mut self, length: usize) -> Result<Vec<u8>> {
    let mut buf = vec![0u8; length];
    self.0.read_exact(&mut buf).to_fs_result()?;
    Ok(buf)
  }

  async fn read_until(&mut self, byte: u8) -> Result<Vec<u8>> {
    let mut buf = vec![];
    self.0.read_until(byte, &mut buf).to_fs_result()?;
    if buf.last().is_some_and(|b| b == &byte) {
      buf.pop();
    }
    Ok(buf)
  }
  async fn read_to_end(&mut self) -> Result<Vec<u8>> {
    let mut buf = vec![];
    self.0.read_to_end(&mut buf).to_fs_result()?;
    Ok(buf)
  }
  async fn skip(&mut self, offset: usize) -> Result<()> {
    self.0.seek_relative(offset as i64).to_fs_result()
  }
  async fn close(&mut self) -> Result<()> {
    Ok(())
  }
}

#[derive(Debug)]
pub struct MemoryWriteStream {
  file: Utf8PathBuf,
  contents: Vec<u8>,
  fs: MemoryFileSystem,
}

impl MemoryWriteStream {
  pub fn new(file: &Utf8Path, fs: MemoryFileSystem) -> Self {
    Self {
      file: file.to_path_buf(),
      contents: vec![],
      fs,
    }
  }
}

#[async_trait::async_trait]
impl WriteStream for MemoryWriteStream {
  async fn write(&mut self, buf: &[u8]) -> Result<usize> {
    self.contents.extend(buf);
    Ok(buf.len())
  }
  async fn write_all(&mut self, buf: &[u8]) -> Result<()> {
    self.contents = buf.to_vec();
    Ok(())
  }
  async fn flush(&mut self) -> Result<()> {
    self.fs.write(&self.file, &self.contents).await?;
    Ok(())
  }
  async fn close(&mut self) -> Result<()> {
    Ok(())
  }
}

#[cfg(test)]
mod tests {
  use rspack_paths::Utf8Path;

  use super::{MemoryFileSystem, ReadableFileSystem, WritableFileSystem};
  #[tokio::test]
  async fn async_fs_test() {
    let fs = MemoryFileSystem::default();
    let file_content = "1".as_bytes();
    // init fs
    WritableFileSystem::create_dir_all(&fs, Utf8Path::new("/a/b/c"))
      .await
      .unwrap();
    WritableFileSystem::write(&fs, Utf8Path::new("/a/file1"), file_content)
      .await
      .unwrap();
    tokio::time::sleep(std::time::Duration::from_millis(100)).await;

    // test create_dir
    assert!(
      WritableFileSystem::create_dir(&fs, Utf8Path::new("/a/b/c/d/e"))
        .await
        .is_err()
    );
    assert!(
      WritableFileSystem::create_dir(&fs, Utf8Path::new("/a/b/c/d"))
        .await
        .is_ok()
    );
    assert!(
      WritableFileSystem::create_dir(&fs, Utf8Path::new("/a/b/c/d/e"))
        .await
        .is_ok()
    );
    assert!(
      WritableFileSystem::create_dir(&fs, Utf8Path::new("/a/file1/c/d"))
        .await
        .is_err()
    );
    assert!(
      WritableFileSystem::create_dir(&fs, Utf8Path::new("/a/file1/c"))
        .await
        .is_err()
    );

    // test create_dir_all
    assert!(
      WritableFileSystem::create_dir_all(&fs, Utf8Path::new("/a1/b1/c1"))
        .await
        .is_ok()
    );
    assert!(
      WritableFileSystem::create_dir_all(&fs, Utf8Path::new("/a/file1/c/d"))
        .await
        .is_err()
    );
    assert!(
      WritableFileSystem::create_dir_all(&fs, Utf8Path::new("/a/file1/c"))
        .await
        .is_err()
    );

    // test write
    assert!(
      WritableFileSystem::write(&fs, Utf8Path::new("/a/temp/file2"), file_content)
        .await
        .is_err()
    );
    assert!(
      WritableFileSystem::write(&fs, Utf8Path::new("/a/file2"), file_content)
        .await
        .is_ok()
    );
    assert!(
      WritableFileSystem::write(&fs, Utf8Path::new("/a/file1/file2"), file_content)
        .await
        .is_err()
    );

    // read
    assert!(
      ReadableFileSystem::read(&fs, Utf8Path::new("/a/temp/file2"))
        .await
        .is_err()
    );
    assert!(
      ReadableFileSystem::read(&fs, Utf8Path::new("/a/file1/file2"))
        .await
        .is_err()
    );
    assert_eq!(
      ReadableFileSystem::read(&fs, Utf8Path::new("/a/file1"))
        .await
        .unwrap(),
      file_content
    );
    assert_eq!(
      ReadableFileSystem::read(&fs, Utf8Path::new("/a/file2"))
        .await
        .unwrap(),
      file_content
    );

    // stat
    assert!(
      WritableFileSystem::stat(&fs, Utf8Path::new("/a/file1/c/d"))
        .await
        .is_err()
    );
    let file1_meta = WritableFileSystem::stat(&fs, Utf8Path::new("/a/file1"))
      .await
      .unwrap();
    let file2_meta = WritableFileSystem::stat(&fs, Utf8Path::new("/a/file2"))
      .await
      .unwrap();
    assert!(file1_meta.is_file);
    assert!(file2_meta.is_file);
    assert!(file1_meta.ctime_ms < file2_meta.ctime_ms);
    let dir_meta = WritableFileSystem::stat(&fs, Utf8Path::new("/a/b"))
      .await
      .unwrap();
    assert!(dir_meta.is_directory);
    assert!(dir_meta.ctime_ms < file2_meta.ctime_ms);

    // read dir
    assert!(
      WritableFileSystem::read_dir(&fs, Utf8Path::new("/a2/b2/c2"))
        .await
        .is_err(),
    );
    let children = WritableFileSystem::read_dir(&fs, Utf8Path::new("/a"))
      .await
      .unwrap();
    assert_eq!(children.len(), 3);
    assert!(children.contains(&String::from("b")));
    assert!(children.contains(&String::from("file1")));
    assert!(children.contains(&String::from("file2")));

    // remove file
    assert!(
      WritableFileSystem::remove_file(&fs, Utf8Path::new("/a/b/c"))
        .await
        .is_err(),
    );
    assert!(
      WritableFileSystem::remove_file(&fs, Utf8Path::new("/a/file3"))
        .await
        .is_ok(),
    );
    assert!(
      WritableFileSystem::remove_file(&fs, Utf8Path::new("/a/file2"))
        .await
        .is_ok(),
    );
    assert!(
      WritableFileSystem::stat(&fs, Utf8Path::new("/a/file2"))
        .await
        .is_err(),
    );

    // remove dir
    assert!(
      WritableFileSystem::remove_dir_all(&fs, Utf8Path::new("/a3/b3/c3"))
        .await
        .is_ok(),
    );
    assert!(
      WritableFileSystem::remove_dir_all(&fs, Utf8Path::new("/a/file1"))
        .await
        .is_err(),
    );
    assert!(
      WritableFileSystem::remove_dir_all(&fs, Utf8Path::new("/a"))
        .await
        .is_ok(),
    );
    assert!(
      WritableFileSystem::stat(&fs, Utf8Path::new("/a/file1"))
        .await
        .is_err(),
    );
  }
}