Custom import thread count and fixes

3 files changed, 19 insertions, 5 deletions

diff --git a/import/src/plugins/infojson.rs b/import/src/plugins/infojson.rs
index 5c3645c..03db70c 100644
--- a/import/src/plugins/infojson.rs
+++ b/import/src/plugins/infojson.rs
@@ -273,8 +273,9 @@ impl ImportPlugin for Infojson {
 }
 
 fn clean_uploader_name(mut s: &str) -> &str {
-    s = s.strip_suffix(" - Videos").unwrap_or(s);
-    s = s.strip_suffix(" - Topic").unwrap_or(s);
-    s = s.strip_prefix("Uploads from ").unwrap_or(s);
+    s = s.strip_suffix(" - Videos").unwrap_or(s); // youtube
+    s = s.strip_suffix(" - Topic").unwrap_or(s); // youtube
+    s = s.strip_prefix("Uploads from ").unwrap_or(s); // youtube
+    s = s.strip_prefix("Discography of ").unwrap_or(s); // bandcamp
     s
 }
diff --git a/import/src/plugins/misc.rs b/import/src/plugins/misc.rs
index 0444d0c..4a4851e 100644
--- a/import/src/plugins/misc.rs
+++ b/import/src/plugins/misc.rs
@@ -122,6 +122,19 @@ impl ImportPlugin for General {
                 Ok(())
             })?;
         }
+        if let Some(title) = line.strip_prefix("title=") {
+            ct.db.update_node_init(node, |node| {
+                node.title = Some(title.to_owned());
+                Ok(())
+            })?;
+        }
+        if let Some(index) = line.strip_prefix("index=") {
+            let index = index.parse().context("parse index")?;
+            ct.db.update_node_init(node, |node| {
+                node.index = Some(index);
+                Ok(())
+            })?;
+        }
         Ok(())
     }
 }
diff --git a/import/src/plugins/trakt.rs b/import/src/plugins/trakt.rs
index 48a97ae..1268e56 100644
--- a/import/src/plugins/trakt.rs
+++ b/import/src/plugins/trakt.rs
@@ -409,14 +409,14 @@ impl ImportPlugin for Trakt {
         Ok(())
     }
     fn process(&self, ct: &ImportContext, node: NodeID, data: &Node) -> Result<()> {
-        self.process_show(ct, node, data)?;
+        self.process_primary(ct, node, data)?;
         self.process_episode(ct, node, data)?;
         Ok(())
     }
 }
 
 impl Trakt {
-    fn process_show(&self, ct: &ImportContext, node: NodeID, data: &Node) -> Result<()> {
+    fn process_primary(&self, ct: &ImportContext, node: NodeID, data: &Node) -> Result<()> {
         let (trakt_kind, trakt_id): (_, u64) =
             if let Some(id) = data.identifiers.get(&IdentifierType::TraktShow) {
                 (TraktKind::Show, id.parse()?)