aboutsummaryrefslogtreecommitdiff
path: root/import/src/plugins/tmdb.rs
diff options
context:
space:
mode:
authormetamuffin <metamuffin@disroot.org>2026-02-16 19:29:39 +0100
committermetamuffin <metamuffin@disroot.org>2026-02-16 19:29:39 +0100
commitb99fc498f2cf26c93d7888ea9aba4dd8cea60b2f (patch)
treee99420c820052654556ff1eeea185e4706e83c31 /import/src/plugins/tmdb.rs
parentf508ec842da225f4946c40953bf24b424f52512d (diff)
downloadjellything-b99fc498f2cf26c93d7888ea9aba4dd8cea60b2f.tar
jellything-b99fc498f2cf26c93d7888ea9aba4dd8cea60b2f.tar.bz2
jellything-b99fc498f2cf26c93d7888ea9aba4dd8cea60b2f.tar.zst
can import again
Diffstat (limited to 'import/src/plugins/tmdb.rs')
-rw-r--r--import/src/plugins/tmdb.rs20
1 files changed, 10 insertions, 10 deletions
diff --git a/import/src/plugins/tmdb.rs b/import/src/plugins/tmdb.rs
index e9e92d4..b7bd797 100644
--- a/import/src/plugins/tmdb.rs
+++ b/import/src/plugins/tmdb.rs
@@ -192,7 +192,7 @@ impl ImportPlugin for Tmdb {
}
impl Tmdb {
fn process_primary(&self, ct: &PluginContext, node: RowNum) -> Result<()> {
- let data = ct.dba.get_node(node)?.unwrap();
+ let data = ct.ic.get_node(node)?.unwrap();
let data = data.as_object();
let (tmdb_kind, tmdb_id): (_, u64) = if let Some(id) = data
@@ -211,17 +211,17 @@ impl Tmdb {
return Ok(());
};
- let details = self.details(&ct.dba.cache, tmdb_kind, tmdb_id, ct.rt)?;
+ let details = self.details(&ct.ic.cache, tmdb_kind, tmdb_id, ct.rt)?;
let backdrop = details
.backdrop_path
.as_ref()
- .map(|path| self.image(&ct.dba.cache, &path, ct.rt))
+ .map(|path| self.image(&ct.ic.cache, &path, ct.rt))
.transpose()
.context("backdrop image")?;
let poster = details
.poster_path
.as_ref()
- .map(|path| self.image(&ct.dba.cache, &path, ct.rt))
+ .map(|path| self.image(&ct.ic.cache, &path, ct.rt))
.transpose()
.context("poster image")?;
@@ -232,7 +232,7 @@ impl Tmdb {
.transpose()?
.flatten();
- ct.dba.update_node(node, |mut node| {
+ ct.ic.update_node(node, |mut node| {
if let Some(title) = &details.title {
node = node.as_object().insert(NO_TITLE, &title);
}
@@ -261,14 +261,14 @@ impl Tmdb {
Ok(())
}
fn process_episode(&self, ct: &PluginContext, node: RowNum) -> Result<()> {
- let data = ct.dba.get_node(node)?.unwrap();
+ let data = ct.ic.get_node(node)?.unwrap();
let data = data.as_object();
let (Some(episode), Some(season)) = (data.get(NO_INDEX), data.get(NO_SEASON_INDEX)) else {
return Ok(());
};
let mut series_id = None;
- ct.dba.db.transaction(&mut |txn| {
+ ct.ic.db.transaction(&mut |txn| {
for parent in data.iter(NO_PARENT) {
let parent_data = txn.get(parent)?.ok_or(anyhow!("parent missing"))?;
if let Some(id) = parent_data
@@ -286,15 +286,15 @@ impl Tmdb {
let Some(series_id) = series_id else {
return Ok(());
};
- let details = self.episode_details(&ct.dba.cache, series_id, season, episode, ct.rt)?;
+ let details = self.episode_details(&ct.ic.cache, series_id, season, episode, ct.rt)?;
let cover = details
.still_path
.as_ref()
- .map(|path| self.image(&ct.dba.cache, &path, ct.rt))
+ .map(|path| self.image(&ct.ic.cache, &path, ct.rt))
.transpose()
.context("still image download")?;
let release_date = parse_release_date(&details.air_date)?;
- ct.dba.update_node(node, |mut node| {
+ ct.ic.update_node(node, |mut node| {
node = node.as_object().insert(NO_TITLE, &details.name);
node = node.as_object().insert(NO_DESCRIPTION, &details.overview);
if let Some(release_date) = release_date {