use std::path::PathBuf;
use std::sync::Arc;
use anyhow::{Context, Result};
use async_std::task::{spawn, JoinHandle};
use nipper::Document;
use super::ATTR_HREF;
use super::{AssetFile, LinkAttrs, TrunkLinkPipelineOutput};
use crate::config::RtcBuild;
pub struct CopyFile {
id: usize,
cfg: Arc<RtcBuild>,
asset: AssetFile,
}
impl CopyFile {
pub const TYPE_COPY_FILE: &'static str = "copy-file";
pub async fn new(cfg: Arc<RtcBuild>, html_dir: Arc<PathBuf>, attrs: LinkAttrs, id: usize) -> Result<Self> {
let href_attr = attrs
.get(ATTR_HREF)
.context(r#"required attr `href` missing for <link data-trunk rel="copyfile" .../> element"#)?;
let mut path = PathBuf::new();
path.extend(href_attr.split('/'));
let asset = AssetFile::new(&html_dir, path).await?;
Ok(Self { id, cfg, asset })
}
#[tracing::instrument(level = "trace", skip(self))]
pub fn spawn(self) -> JoinHandle<Result<TrunkLinkPipelineOutput>> {
spawn(self.run())
}
#[tracing::instrument(level = "trace", skip(self))]
async fn run(self) -> Result<TrunkLinkPipelineOutput> {
let rel_path = crate::common::strip_prefix(&self.asset.path);
tracing::info!(path = ?rel_path, "copying file");
let _ = self.asset.copy(&self.cfg.staging_dist).await?;
tracing::info!(path = ?rel_path, "finished copying file");
Ok(TrunkLinkPipelineOutput::CopyFile(CopyFileOutput(self.id)))
}
}
pub struct CopyFileOutput(usize);
impl CopyFileOutput {
pub async fn finalize(self, dom: &mut Document) -> Result<()> {
dom.select(&super::trunk_id_selector(self.0)).remove();
Ok(())
}
}