avoid transitive crate deps by re-export

1 files changed, 29 insertions, 15 deletions

diff --git a/import/src/lib.rs b/import/src/lib.rs
index c841294..4203ba1 100644
--- a/import/src/lib.rs
+++ b/import/src/lib.rs
@@ -5,16 +5,20 @@
 */
 use anyhow::{anyhow, Context, Result};
 use infojson::YVideo;
-use jellybase::{assetfed::AssetInner, database::Database, CONF, SECRETS};
-use jellycommon::{
-    Chapter, LocalTrack, MediaInfo, Node, NodeID, NodeKind, Rating, SourceTrack, SourceTrackKind,
-    TrackSource,
+use jellybase::{
+    assetfed::AssetInner,
+    common::{
+        Chapter, LocalTrack, MediaInfo, Node, NodeID, NodeKind, Rating, SourceTrack,
+        SourceTrackKind, TrackSource,
+    },
+    database::Database,
+    CONF, SECRETS,
 };
 use matroska::matroska_metadata;
 use rayon::iter::{ParallelDrainRange, ParallelIterator};
 use std::{
     collections::HashMap,
-    fs::File,
+    fs::{read_to_string, File},
     io::BufReader,
     mem::swap,
     path::{Path, PathBuf},
@@ -118,32 +122,37 @@ fn import_iter_inner(path: &Path, db: &Database, incremental: bool) -> Result<Ve
 }
 
 fn import_file(db: &Database, path: &Path) -> Result<()> {
-    let parent_slug = path
-        .parent()
-        .ok_or(anyhow!("no parent"))?
-        .file_name()
-        .ok_or(anyhow!("parent no filename"))?
-        .to_string_lossy();
+    let parent_slug = if path == CONF.media_path {
+        "library".to_string()
+    } else {
+        path.parent()
+            .ok_or(anyhow!("no parent"))?
+            .file_name()
+            .ok_or(anyhow!("parent no filename"))?
+            .to_string_lossy()
+            .to_string()
+    };
     let parent = NodeID::from_slug(&parent_slug);
 
     let filename = path.file_name().unwrap().to_string_lossy();
     match filename.as_ref() {
-        "poster.jpeg" | "poster.webp" => {
+        "poster.jpeg" | "poster.webp" | "poster.png" => {
             db.update_node_init(parent, |node| {
                 node.slug = parent_slug.to_string();
                 node.poster = Some(AssetInner::Media(path.to_owned()).ser());
                 Ok(())
             })?;
         }
-        "backdrop.jpeg" | "backdrop.webp" => {
+        "backdrop.jpeg" | "backdrop.webp" | "backdrop#.png" => {
             db.update_node_init(parent, |node| {
                 node.slug = parent_slug.to_string();
                 node.backdrop = Some(AssetInner::Media(path.to_owned()).ser());
                 Ok(())
             })?;
         }
-        "info.json" | "info.yaml" => {
-            let data = serde_yaml::from_reader::<_, Node>(BufReader::new(File::open(path)?))?;
+        "node.json" | "node.yaml" => {
+            let raw = format!("slug: {parent_slug}\n{}", read_to_string(path)?);
+            let data = serde_yaml::from_str::<Node>(&raw)?;
             db.update_node_init(parent, |node| {
                 node.slug = parent_slug.to_string();
                 fn merge_option<T>(a: &mut Option<T>, b: Option<T>) {
@@ -151,9 +160,14 @@ fn import_file(db: &Database, path: &Path) -> Result<()> {
                         *a = b;
                     }
                 }
+                merge_option(&mut node.kind, data.kind);
                 merge_option(&mut node.title, data.title);
                 merge_option(&mut node.tagline, data.tagline);
                 merge_option(&mut node.description, data.description);
+                merge_option(&mut node.index, data.index);
+                merge_option(&mut node.release_date, data.release_date);
+                node.external_ids.extend(data.external_ids);
+
                 Ok(())
             })?;
         }