Compare commits

..

No commits in common. "2de01b2a0e512fa25e798eec586766e782a725d4" and "a23429104c50260af8e304c53629c9008949c306" have entirely different histories.

2 changed files with 11 additions and 23 deletions

View File

@ -6,30 +6,19 @@ use url::Url;
#[instrument(skip(data))] #[instrument(skip(data))]
pub async fn store(data: &str, url: &Url) { pub async fn store(data: &str, url: &Url) {
// extract data from url to save it accurately let path = PathBuf::from("./downloaded".to_string() + url.path());
let url_path = PathBuf::from("./downloaded/".to_string() + url.domain().unwrap_or("UnknownDomain") + url.path()); let basepath = path.ancestors().skip(1).take(1).collect::<PathBuf>();
trace!("Save path: {:?} and base path: {:?}", &path, &basepath);
// if it's a file
let (basepath, filename) = if url_path.extension().is_some() {
// get everything up till the file
let basepath = url_path.ancestors().skip(1).take(1).collect::<PathBuf>();
// get the file name
let filename = url_path.file_name().expect("This should exist").to_string_lossy();
trace!("Save path: {:?} and base path: {:?}", &url_path, &basepath);
(basepath, filename.to_string())
} else {
(url_path.clone(), "index.html".into())
};
// create the folders
if let Err(err) = fs::create_dir_all(&basepath).await { if let Err(err) = fs::create_dir_all(&basepath).await {
error!("Dir creation: {err} {:?}", basepath); let ex = path.ancestors().fold(String::new(), |mut s, item| {
s += ", ";
s += &item.to_string_lossy().to_string();
s
});
error!("Dir creation: {err} {:?} {ex}", basepath);
} else { } else {
// FIXME I don't think this handles index.html files well... if let Err(err) = fs::write(&path, data).await {
// TODO this should probably append .html to non-described files error!("File creation: {err} {:?}", path);
// create the file if that was successful
if let Err(err) = fs::write(&basepath.join(filename), data).await {
error!("File creation: {err} {:?}", url_path);
} }
} }
} }

View File

@ -167,7 +167,6 @@ async fn process(mut site: Website, db: Surreal<Client>, reqwest: reqwest::Clien
.text() .text()
.await .await
.expect("Failed to read http response's body!"); .expect("Failed to read http response's body!");
// Store document // Store document
filesystem::store(&data, &site.site).await; filesystem::store(&data, &site.site).await;