use std::fs::File;
use std::io::{Read, Seek};
use std::path::Path;
use serde::de::DeserializeOwned;
use zip::ZipArchive;
use crate::error::{OfdError, Result};
pub struct OfdPackage<R> {
archive: ZipArchive<R>,
}
impl OfdPackage<File> {
pub fn open<P: AsRef<Path>>(path: P) -> Result<Self> {
Self::new(File::open(path)?)
}
}
impl<R: Read + Seek> OfdPackage<R> {
pub fn new(reader: R) -> Result<Self> {
Ok(OfdPackage {
archive: ZipArchive::new(reader)?,
})
}
pub fn read(&mut self, path: &str) -> Result<Vec<u8>> {
let name = normalize(path);
let mut entry = self
.archive
.by_name(&name)
.map_err(|_| OfdError::EntryNotFound(name.clone()))?;
let mut buf = Vec::with_capacity(entry.size() as usize);
entry.read_to_end(&mut buf)?;
Ok(buf)
}
pub fn read_to_string(&mut self, path: &str) -> Result<String> {
let bytes = self.read(path)?;
String::from_utf8(bytes)
.map_err(|e| OfdError::Structure(format!("entry {path} is not valid UTF-8: {e}")))
}
pub fn parse<T: DeserializeOwned>(&mut self, path: &str) -> Result<T> {
let text = self.read_to_string(path)?;
Ok(quick_xml::de::from_str(&text)?)
}
pub fn contains(&self, path: &str) -> bool {
let name = normalize(path);
self.archive.file_names().any(|n| n == name)
}
pub fn entries(&self) -> Vec<String> {
self.archive.file_names().map(|s| s.to_string()).collect()
}
pub fn len(&self) -> usize {
self.archive.len()
}
pub fn is_empty(&self) -> bool {
self.archive.is_empty()
}
}
fn normalize(path: &str) -> String {
path.trim_start_matches('/').to_string()
}