aboutsummaryrefslogtreecommitdiff
path: root/import/src/plugins/trakt.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/trakt.rs
parentf508ec842da225f4946c40953bf24b424f52512d (diff)
downloadjellything-b99fc498f2cf26c93d7888ea9aba4dd8cea60b2f.tar
jellything-b99fc498f2cf26c93d7888ea9aba4dd8cea60b2f.tar.bz2
jellything-b99fc498f2cf26c93d7888ea9aba4dd8cea60b2f.tar.zst
can import again
Diffstat (limited to 'import/src/plugins/trakt.rs')
-rw-r--r--import/src/plugins/trakt.rs18
1 files changed, 9 insertions, 9 deletions
diff --git a/import/src/plugins/trakt.rs b/import/src/plugins/trakt.rs
index ebbe879..b67bb42 100644
--- a/import/src/plugins/trakt.rs
+++ b/import/src/plugins/trakt.rs
@@ -416,7 +416,7 @@ impl ImportPlugin for Trakt {
"episode" => IDENT_TRAKT_EPISODE,
_ => bail!("unknown trakt kind"),
};
- ct.dba.update_node(node, |node| {
+ ct.ic.update_node(node, |node| {
node.as_object()
.update(NO_IDENTIFIERS, |idents| idents.insert(ty, id))
})?;
@@ -432,7 +432,7 @@ impl ImportPlugin for Trakt {
impl Trakt {
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 (trakt_kind, trakt_id): (_, u64) = if let Some(id) = data
.get(NO_IDENTIFIERS)
@@ -450,7 +450,7 @@ impl Trakt {
return Ok(());
};
- let details = self.lookup(&ct.dba.cache, trakt_kind, trakt_id, ct.rt)?;
+ let details = self.lookup(&ct.ic.cache, trakt_kind, trakt_id, ct.rt)?;
// let people = self.people(trakt_kind, trakt_id, ct.rt)?;
// let mut people_map = BTreeMap::<CreditCategory, Vec<Appearance>>::new();
@@ -479,7 +479,7 @@ impl Trakt {
// }
// }
- ct.dba.update_node(node, |mut node| {
+ ct.ic.update_node(node, |mut node| {
node = node.as_object().insert(NO_KIND, trakt_kind.as_node_kind());
node = node.as_object().insert(NO_TITLE, &details.title);
if let Some(overview) = &details.overview {
@@ -518,7 +518,7 @@ impl Trakt {
Ok(())
}
fn process_episode(&self, ct: &PluginContext, node: RowNum) -> Result<()> {
- let node_data = ct.dba.get_node(node)?.unwrap();
+ let node_data = ct.ic.get_node(node)?.unwrap();
let node_data = node_data.as_object();
let (Some(episode), Some(season)) =
@@ -527,7 +527,7 @@ impl Trakt {
return Ok(());
};
let mut show_id = None;
- ct.dba.db.transaction(&mut |txn| {
+ ct.ic.db.transaction(&mut |txn| {
for parent in node_data.iter(NO_PARENT) {
let parent_data = txn.get(parent)?.ok_or(anyhow!("parent missing"))?;
if let Some(id) = parent_data
@@ -546,11 +546,11 @@ impl Trakt {
return Ok(());
};
- let seasons = self.show_seasons(&ct.dba.cache, show_id, ct.rt)?;
+ let seasons = self.show_seasons(&ct.ic.cache, show_id, ct.rt)?;
if seasons.iter().any(|x| x.number == season) {
- let episodes = self.show_season_episodes(&ct.dba.cache, show_id, season, ct.rt)?;
+ let episodes = self.show_season_episodes(&ct.ic.cache, show_id, season, ct.rt)?;
if let Some(episode) = episodes.get(episode.saturating_sub(1) as usize) {
- ct.dba.update_node(node, |mut node| {
+ ct.ic.update_node(node, |mut node| {
node = node.as_object().insert(NO_KIND, KIND_EPISODE);
node = node.as_object().insert(NO_INDEX, episode.number);
node = node.as_object().insert(NO_TITLE, &episode.title);