aboutsummaryrefslogtreecommitdiff
path: root/import/src
diff options
context:
space:
mode:
authormetamuffin <metamuffin@disroot.org>2025-02-05 19:37:50 +0100
committermetamuffin <metamuffin@disroot.org>2025-02-05 19:37:50 +0100
commitfea9d99cef52a8ba258f5c8a11af08ec3304613e (patch)
treeb8b90affc9fea3e549349fb80434d3c4673fedcc /import/src
parent1c70f3d967b79cc4d9a8ee645921c53e95b096b1 (diff)
downloadjellything-fea9d99cef52a8ba258f5c8a11af08ec3304613e.tar
jellything-fea9d99cef52a8ba258f5c8a11af08ec3304613e.tar.bz2
jellything-fea9d99cef52a8ba258f5c8a11af08ec3304613e.tar.zst
trakt logging, jellyfin auth casing option
Diffstat (limited to 'import/src')
-rw-r--r--import/src/lib.rs20
-rw-r--r--import/src/trakt.rs3
2 files changed, 23 insertions, 0 deletions
diff --git a/import/src/lib.rs b/import/src/lib.rs
index eee7a42..0d8a10a 100644
--- a/import/src/lib.rs
+++ b/import/src/lib.rs
@@ -460,6 +460,7 @@ fn apply_node_flag(
"movie" | "" => TraktKind::Movie,
"show" => TraktKind::Show,
"season" => TraktKind::Season,
+ "episode" => TraktKind::Episode,
_ => bail!("unknown trakt kind"),
};
apply_trakt_tmdb(db, rthandle, apis, node, kind, id)?;
@@ -476,6 +477,25 @@ fn apply_node_flag(
Ok(())
})?;
}
+ if let Some(kind) = flag.strip_prefix("kind-").or(flag.strip_prefix("kind=")) {
+ let kind = match kind {
+ "movie" => NodeKind::Movie,
+ "video" => NodeKind::Video,
+ "music" => NodeKind::Music,
+ "short_form_video" => NodeKind::ShortFormVideo,
+ "collection" => NodeKind::Collection,
+ "channel" => NodeKind::Channel,
+ "show" => NodeKind::Show,
+ "series" => NodeKind::Series,
+ "season" => NodeKind::Season,
+ "episode" => NodeKind::Episode,
+ _ => bail!("unknown node kind"),
+ };
+ db.update_node_init(node, |node| {
+ node.kind = kind;
+ Ok(())
+ })?;
+ }
Ok(())
}
diff --git a/import/src/trakt.rs b/import/src/trakt.rs
index 98532c5..c7a25ad 100644
--- a/import/src/trakt.rs
+++ b/import/src/trakt.rs
@@ -8,6 +8,7 @@ use jellybase::{
cache::async_cache_memory,
common::{Appearance, ObjectIds, PeopleGroup, Person, TraktKind},
};
+use log::info;
use reqwest::{
header::{HeaderMap, HeaderName, HeaderValue},
Client, ClientBuilder,
@@ -76,6 +77,7 @@ impl Trakt {
async_cache_memory(
&["api-trakt-lookup", &format!("{id} {extended}")],
|| async move {
+ info!("trakt lookup {kind:?}:{id:?}");
let url = format!(
"https://api.trakt.tv/{}/{}{}",
kind.plural(),
@@ -98,6 +100,7 @@ impl Trakt {
async_cache_memory(
&["api-trakt-people", &format!("{id} {extended}")],
|| async move {
+ info!("trakt people {kind:?}:{id:?}");
let url = format!(
"https://api.trakt.tv/{}/{}/people{}",
kind.plural(),