pawkit-fs 0.1.12

use std::{
    fs::{self, File},
    io::{ErrorKind, Read},
    ops::Deref,
    path::Path,
    sync::{Arc, Mutex},
};

use zip::{ZipArchive, result::ZipError};

use crate::{VfsBuffer, VfsError};

#[derive(Debug, Clone)]
pub(crate) enum VfsKind {
    Working,
    ZipArchive(Arc<Mutex<ZipArchive<VfsBuffer>>>),
}

impl VfsKind {
    pub(crate) fn subdirectory_exists(&self, subdirectory: &str) -> bool {
        match self {
            VfsKind::Working => {
                let path = Path::new(subdirectory);
                let Ok(meta) = fs::metadata(path) else {
                    return false;
                };

                return meta.is_dir();
            }

            VfsKind::ZipArchive(zip) => {
                let prefix = format!("{}/", subdirectory);

                let Ok(mut zip) = zip.lock() else {
                    return false;
                };

                for i in 0..zip.len() {
                    if let Ok(file) = zip.by_index(i) {
                        if file.name().starts_with(&prefix) {
                            return true;
                        }
                    }
                }

                return false;
            }
        }
    }

    pub(crate) fn open(&self, path: &str) -> Result<VfsBuffer, VfsError> {
        match self {
            VfsKind::Working => {
                let file_path = Path::new(path);

                return Ok(match File::open(file_path) {
                    Ok(it) => it.into(),
                    Err(it) => {
                        if let ErrorKind::NotFound = it.kind() {
                            return Err(VfsError::NotFound(path.into()));
                        }

                        return Err(it.into());
                    }
                });
            }

            VfsKind::ZipArchive(zip) => {
                let Ok(mut zip) = zip.lock() else {
                    return Err(VfsError::Other);
                };

                let mut file = match zip.by_name(path) {
                    Ok(it) => it,
                    Err(ZipError::FileNotFound) => {
                        return Err(VfsError::NotFound(path.into()));
                    }
                    Err(it) => return Err(it.into()),
                };

                let mut buf = vec![];
                file.read_to_end(&mut buf)?;

                return Ok(buf.deref().into());
            }
        }
    }
}