pub trait HasFileData: std::any::Any {
fn files(&self) -> Option<std::sync::Arc<dyn FileEngine>> {
None
}
}
#[cfg(feature = "serialize")]
#[derive(serde::Serialize, serde::Deserialize, Debug, PartialEq, Clone)]
pub struct SerializedFileEngine {
pub files: std::collections::HashMap<String, Vec<u8>>,
}
#[cfg(feature = "serialize")]
#[async_trait::async_trait(?Send)]
impl FileEngine for SerializedFileEngine {
fn files(&self) -> Vec<String> {
self.files.keys().cloned().collect()
}
async fn file_size(&self, file: &str) -> Option<u64> {
let file = self.files.get(file)?;
Some(file.len() as u64)
}
async fn read_file(&self, file: &str) -> Option<Vec<u8>> {
self.files.get(file).cloned()
}
async fn read_file_to_string(&self, file: &str) -> Option<String> {
self.read_file(file)
.await
.map(|bytes| String::from_utf8_lossy(&bytes).to_string())
}
async fn get_native_file(&self, file: &str) -> Option<Box<dyn std::any::Any>> {
self.read_file(file)
.await
.map(|val| Box::new(val) as Box<dyn std::any::Any>)
}
}
#[async_trait::async_trait(?Send)]
pub trait FileEngine {
fn files(&self) -> Vec<String>;
async fn file_size(&self, file: &str) -> Option<u64>;
async fn read_file(&self, file: &str) -> Option<Vec<u8>>;
async fn read_file_to_string(&self, file: &str) -> Option<String>;
async fn get_native_file(&self, file: &str) -> Option<Box<dyn std::any::Any>>;
}