diff options
author | metamuffin <metamuffin@disroot.org> | 2023-09-24 22:41:56 +0200 |
---|---|---|
committer | metamuffin <metamuffin@disroot.org> | 2023-09-24 22:41:56 +0200 |
commit | 63454aa9bd9fd4ee293c316e7ca15c88e6c5ca2a (patch) | |
tree | 36f39dd872295bec05c1b83ab9a9ab24518ce9e6 /server/src/import.rs | |
parent | fb16ea9caf4cd50e94d450ea210b7f1e10adabfc (diff) | |
download | jellything-63454aa9bd9fd4ee293c316e7ca15c88e6c5ca2a.tar jellything-63454aa9bd9fd4ee293c316e7ca15c88e6c5ca2a.tar.bz2 jellything-63454aa9bd9fd4ee293c316e7ca15c88e6c5ca2a.tar.zst |
fix federated assets (doesnt work bc dav1d-sys)
Diffstat (limited to 'server/src/import.rs')
-rw-r--r-- | server/src/import.rs | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/server/src/import.rs b/server/src/import.rs index 6e422cd..8859873 100644 --- a/server/src/import.rs +++ b/server/src/import.rs @@ -7,7 +7,7 @@ use crate::{database::Database, federation::Federation, CONF}; use anyhow::{anyhow, bail, Context, Ok}; use async_recursion::async_recursion; use futures::{stream::FuturesUnordered, StreamExt, TryFutureExt}; -use jellybase::cache_file; +use jellybase::{cache_file, AssetLocationExt}; use jellyclient::Session; use jellycommon::{AssetLocation, MediaSource, Node, NodePrivate, RemoteImportOptions}; use log::{debug, error, info}; @@ -139,7 +139,7 @@ async fn import_remote( ) -> anyhow::Result<Vec<String>> { let _permit = SEM_REMOTE_IMPORT.acquire().await.unwrap(); info!("loading federated node {identifier:?}"); - + let flatten = opts.flatten; opts.flatten = false; @@ -159,8 +159,8 @@ async fn import_remote( let mut node = Node { public: node.clone(), private: NodePrivate { - backdrop: Some(AssetLocation::Cache(backdrop)), - poster: Some(AssetLocation::Cache(poster)), + backdrop: Some(backdrop), + poster: Some(poster), import: None, id: None, source: Some(MediaSource::Remote { @@ -214,11 +214,11 @@ async fn cache_federation_asset( session: &Session, identifier: &String, role: &str, -) -> anyhow::Result<PathBuf> { +) -> anyhow::Result<AssetLocation> { let poster = cache_file(&["federation-asset", role, identifier]); - if !poster.exists() { + if !poster.path().exists() { session - .node_asset(&identifier, role, File::create(&poster)?) + .node_asset(&identifier, role, File::create(&poster.path())?) .await?; } Ok(poster) |