use crate::{ models::{Chapter, EpubResponse, FileEntry}, xml::build_epub_chapter, }; use anyhow::{Context, Result}; use ogrim::xml; use relative_path::{RelativePath, RelativePathBuf}; use reqwest::Client; use std::{ collections::HashMap, io::{Read, Write}, path::Path, }; use tokio::{ fs::{self, File}, io::AsyncWriteExt, }; use zip::{CompressionMethod, ZipWriter, write::FileOptions}; /// Creates and writes container.xml. fn write_container_xml_to_zip( zip: &mut ZipWriter, opf_full_path: &RelativePathBuf, ) -> Result<()> { // Prepare file contents. let contents = xml!( ); // Write down the file. let options: FileOptions<()> = FileOptions::default().compression_method(CompressionMethod::Deflated); zip.start_file("META-INF/container.xml", options)?; zip.write_all(contents.as_str().as_bytes())?; Ok(()) } pub async fn download_all_files( client: &Client, file_entries: &[FileEntry], dest_root: &Path, ) -> Result<()> { for entry in file_entries { let dest_path = entry.full_path.to_path(dest_root); if let Some(parent_dir) = dest_path.parent() { fs::create_dir_all(parent_dir).await?; } let mut file = File::create(dest_path).await?; let bytes = client .get(entry.url.clone()) .send() .await? .error_for_status()? .bytes() .await?; file.write_all(&bytes).await?; } Ok(()) } /// Creates the EPUB archive (creates zip and includes all files in it). pub fn create_epub_archive( epub_data: &EpubResponse, epub_root: &Path, output_epub: &Path, file_entries: &[FileEntry], chapters: &HashMap, ) -> Result<()> { let out_file = std::fs::File::create(output_epub)?; let mut zip = ZipWriter::new(out_file); // Write mimetype to zip first. It must be uncompressed. let options: FileOptions<()> = FileOptions::default().compression_method(CompressionMethod::Stored); zip.start_file("mimetype", options)?; zip.write_all(b"application/epub+zip")?; // Find the OPF file entry to reference it in container.xml let opf_entry = file_entries .iter() .find(|f| f.filename_ext == ".opf" && f.media_type == "application/oebps-package+xml") .context("No OPF file with the correct MIME type was found.")?; write_container_xml_to_zip(&mut zip, &opf_entry.full_path)?; // Prepare url path to local path mapping to clean xhtml files from external dependencies. let url_path_to_local = file_entries .iter() .map(|e| (e.url.path(), &e.full_path)) .collect::>(); // Prepare url to local path mapping to insert related assets based on their URL. let url_to_file = file_entries .iter() .map(|e| (&e.url, e)) .collect::>(); // Add the rest of the files according to file_entries. let options: FileOptions<()> = FileOptions::default().compression_method(CompressionMethod::Deflated); for entry in file_entries { zip.start_file(&entry.full_path, options)?; let mut src_file = std::fs::File::open(entry.full_path.to_path(epub_root))?; let mut buffer = Vec::new(); src_file.read_to_end(&mut buffer)?; if let Some(chapter) = chapters.get(&entry.ourn) { let chapter_dir = entry.full_path.parent().unwrap_or(RelativePath::new("")); let stylesheet_links = chapter .related_assets .stylesheets .iter() .filter_map(|u| url_to_file.get(u)) .map(|e| { format!( "\n", e.media_type, chapter_dir.relative(&e.full_path) ) }) .collect::(); let html = String::from_utf8(buffer)?; let html = build_epub_chapter( epub_data, chapter, chapter_dir, &html, &stylesheet_links, &url_path_to_local, )?; zip.write_all(html.as_bytes())?; } else { zip.write_all(&buffer)?; } } zip.finish()?; Ok(()) }