aboutsummaryrefslogtreecommitdiff
path: root/import
diff options
context:
space:
mode:
Diffstat (limited to 'import')
-rw-r--r--import/src/plugins/acoustid.rs2
-rw-r--r--import/src/plugins/infojson.rs8
-rw-r--r--import/src/plugins/musicbrainz.rs14
-rw-r--r--import/src/plugins/omdb.rs2
-rw-r--r--import/src/plugins/tags.rs6
-rw-r--r--import/src/plugins/tmdb.rs4
-rw-r--r--import/src/plugins/trakt.rs20
7 files changed, 30 insertions, 26 deletions
diff --git a/import/src/plugins/acoustid.rs b/import/src/plugins/acoustid.rs
index c829aac..411f9d1 100644
--- a/import/src/plugins/acoustid.rs
+++ b/import/src/plugins/acoustid.rs
@@ -199,7 +199,7 @@ impl ImportPlugin for AcoustID {
ct.ic.update_node(node, |node| {
node.as_object().update(NO_IDENTIFIERS, |ids| {
- ids.insert(IDENT_ACOUST_ID_TRACK, &atid)
+ ids.insert_s(ct.is, IDENT_ACOUST_ID_TRACK, &atid)
.as_object()
.insert_s(ct.is, IDENT_MUSICBRAINZ_RECORDING, &mbid)
})
diff --git a/import/src/plugins/infojson.rs b/import/src/plugins/infojson.rs
index 6905e57..8a3ba5d 100644
--- a/import/src/plugins/infojson.rs
+++ b/import/src/plugins/infojson.rs
@@ -198,7 +198,7 @@ impl ImportPlugin for Infojson {
}
if let Some(followers) = data.channel_follower_count {
node = node.as_object().update(NO_RATINGS, |rat| {
- rat.insert(RTYP_YOUTUBE_SUBSCRIBERS, followers as f64)
+ rat.insert_s(ct.is, RTYP_YOUTUBE_SUBSCRIBERS, followers as f64)
});
}
@@ -274,13 +274,15 @@ impl ImportPlugin for Infojson {
rat.insert_s(ct.is, IDENT_YOUTUBE_VIDEO, &infojson.id)
});
node = node.as_object().update(NO_RATINGS, |rat| {
- rat.insert(
+ rat.insert_s(
+ ct.is,
RTYP_YOUTUBE_VIEWS,
infojson.view_count.unwrap_or_default() as f64,
)
});
node = node.as_object().update(NO_RATINGS, |rat| {
- rat.insert(
+ rat.insert_s(
+ ct.is,
RTYP_YOUTUBE_LIKES,
infojson.like_count.unwrap_or_default() as f64,
)
diff --git a/import/src/plugins/musicbrainz.rs b/import/src/plugins/musicbrainz.rs
index 454c562..ec44d11 100644
--- a/import/src/plugins/musicbrainz.rs
+++ b/import/src/plugins/musicbrainz.rs
@@ -402,7 +402,7 @@ impl MusicBrainz {
let mut artist_node = txn.get(artist_row)?.unwrap();
artist_node = artist_node.as_object().update(NO_IDENTIFIERS, |ids| {
- ids.insert(IDENT_MUSICBRAINZ_ARTIST, &artist.id)
+ ids.insert_s(ct.is, IDENT_MUSICBRAINZ_ARTIST, &artist.id)
});
artist_node = artist_node.as_object().insert(NO_KIND, KIND_PERSON);
txn.update(artist_row, artist_node)?;
@@ -449,18 +449,18 @@ impl MusicBrainz {
if let Some(url) = url
&& let Some(id) = url.strip_prefix("https://www.wikidata.org/wiki/")
{
- node = node
- .as_object()
- .update(NO_IDENTIFIERS, |ids| ids.insert(IDENT_WIKIDATA, id))
+ node = node.as_object().update(NO_IDENTIFIERS, |ids| {
+ ids.insert_s(ct.is, IDENT_WIKIDATA, id)
+ })
}
}
VGMDB => {
if let Some(url) = url
&& let Some(id) = url.strip_prefix("https://vgmdb.net/artist/")
{
- node = node
- .as_object()
- .update(NO_IDENTIFIERS, |ids| ids.insert(IDENT_VGMDB_ARTIST, id))
+ node = node.as_object().update(NO_IDENTIFIERS, |ids| {
+ ids.insert_s(ct.is, IDENT_VGMDB_ARTIST, id)
+ })
}
}
_ => (),
diff --git a/import/src/plugins/omdb.rs b/import/src/plugins/omdb.rs
index 20fb933..3b97a9d 100644
--- a/import/src/plugins/omdb.rs
+++ b/import/src/plugins/omdb.rs
@@ -167,7 +167,7 @@ impl ImportPlugin for Omdb {
if let Some(x) = val {
node = node
.as_object()
- .update(NO_RATINGS, |rts| rts.insert(typ, x));
+ .update(NO_RATINGS, |rts| rts.insert_s(ct.is, typ, x));
}
}
node
diff --git a/import/src/plugins/tags.rs b/import/src/plugins/tags.rs
index b60ef37..c27ea70 100644
--- a/import/src/plugins/tags.rs
+++ b/import/src/plugins/tags.rs
@@ -69,9 +69,9 @@ impl ImportPlugin for Tags {
"BARCODE" => IDENT_BARCODE,
_ => continue,
};
- node = node
- .as_object()
- .update(NO_IDENTIFIERS, |idents| idents.insert(idty, &value));
+ node = node.as_object().update(NO_IDENTIFIERS, |idents| {
+ idents.insert_s(ct.is, idty, &value)
+ });
}
}
}
diff --git a/import/src/plugins/tmdb.rs b/import/src/plugins/tmdb.rs
index db336fe..39f8115 100644
--- a/import/src/plugins/tmdb.rs
+++ b/import/src/plugins/tmdb.rs
@@ -246,7 +246,7 @@ impl Tmdb {
.as_object()
.insert_s(ct.is, NO_DESCRIPTION, &details.overview);
node = node.as_object().update(NO_RATINGS, |rat| {
- rat.insert(RTYP_TMDB, details.vote_average)
+ rat.insert_s(ct.is, RTYP_TMDB, details.vote_average)
});
if let Some(poster) = &poster {
node = node
@@ -312,7 +312,7 @@ impl Tmdb {
.insert_s(ct.is, NO_RELEASEDATE, release_date)
}
node = node.as_object().update(NO_RATINGS, |rat| {
- rat.insert(RTYP_TMDB, details.vote_average)
+ rat.insert_s(ct.is, RTYP_TMDB, details.vote_average)
});
if let Some(cover) = &cover {
node = node.as_object().update(NO_PICTURES, |picts| {
diff --git a/import/src/plugins/trakt.rs b/import/src/plugins/trakt.rs
index cc3b119..bb4a1b0 100644
--- a/import/src/plugins/trakt.rs
+++ b/import/src/plugins/trakt.rs
@@ -483,13 +483,13 @@ impl Trakt {
node = node.as_object().insert_s(ct.is, NO_TAGLINE, &tagline);
}
if let Some(x) = details.ids.imdb.clone() {
- node = node
- .as_object()
- .update(NO_IDENTIFIERS, |idents| idents.insert(IDENT_IMDB, &x));
+ node = node.as_object().update(NO_IDENTIFIERS, |idents| {
+ idents.insert_s(ct.is, IDENT_IMDB, &x)
+ });
}
if let Some(x) = details.ids.tvdb.clone() {
node = node.as_object().update(NO_IDENTIFIERS, |idents| {
- idents.insert(IDENT_TVDB, &x.to_string())
+ idents.insert_s(ct.is, IDENT_TVDB, &x.to_string())
});
}
if let Some(x) = details.ids.tmdb.clone() {
@@ -530,12 +530,14 @@ impl Trakt {
c = c.as_object().update(NO_IDENTIFIERS, |ids| {
let mut ids = ids.insert(IDENT_TRAKT_PERSON, &traktid.to_string());
if let Some(tmdbid) = ap.person.ids.tmdb {
- ids = ids
- .as_object()
- .insert(IDENT_TMDB_PERSON, &tmdbid.to_string());
+ ids = ids.as_object().insert_s(
+ ct.is,
+ IDENT_TMDB_PERSON,
+ &tmdbid.to_string(),
+ );
}
if let Some(imdbid) = &ap.person.ids.imdb {
- ids = ids.as_object().insert(IDENT_IMDB_PERSON, imdbid);
+ ids = ids.as_object().insert_s(ct.is, IDENT_IMDB_PERSON, imdbid);
}
ids
});
@@ -604,7 +606,7 @@ impl Trakt {
if let Some(r) = episode.rating {
node = node
.as_object()
- .update(NO_RATINGS, |rats| rats.insert(RTYP_TRAKT, r));
+ .update(NO_RATINGS, |rats| rats.insert_s(ct.is, RTYP_TRAKT, r));
}
node
})?;
generated by cgit v1.3 (git 2.53.0) at 2026-03-26 04:54:08 +0000