[gnome-music/wip/carlosg/tracker3: 2/2] trackerwrapper: Drop song writeback queries
- From: Carlos Garnacho <carlosg src gnome org>
- To: commits-list gnome org
- Cc:
- Subject: [gnome-music/wip/carlosg/tracker3: 2/2] trackerwrapper: Drop song writeback queries
- Date: Wed, 17 Jun 2020 16:27:48 +0000 (UTC)
commit 9ddfd3080ba4a038546ac9a3110e32033da75ff2
Author: Carlos Garnacho <carlosg gnome org>
Date: Sun Jun 14 18:41:27 2020 +0200
trackerwrapper: Drop song writeback queries
With all metadata writeback work being done by grilo, this property
handled is unused.
gnomemusic/trackerwrapper.py | 488 +------------------------------------------
1 file changed, 1 insertion(+), 487 deletions(-)
---
diff --git a/gnomemusic/trackerwrapper.py b/gnomemusic/trackerwrapper.py
index 4f8f1269..0a02b987 100644
--- a/gnomemusic/trackerwrapper.py
+++ b/gnomemusic/trackerwrapper.py
@@ -136,435 +136,6 @@ class TrackerWrapper(GObject.GObject):
return query
- def _resource_added(self, conn, res, data):
- try:
- conn.update_finish(res)
- except GLib.Error as e:
- self._log.warning(
- "Unable to associate resource: {}".format(e.message))
-
- media, data, callback = data
- if callback:
- callback(media, data)
-
- def _add_resource_to_piece(self, conn, res, data):
- media, urn, rdf_property, owner, tags, callback = data
- if conn is not None:
- try:
- conn.update_finish(res)
- except GLib.Error as e:
- self._log.warning(
- "Unable to create new resource: {}".format(e.message))
- if callback:
- callback(media, tags)
- return
-
- where_owner = {
- "album": "nmm:musicAlbum ?album ;",
- "albumdisc": "nmm:musicAlbumDisc ?albumdisc ;",
- "performer": "nmm:performer ?performer ;",
- "song": ""
- }
-
- query_insert_resource = """
- INSERT {
- ?%(owner)s %(property)s <%(urn)s> }
- WHERE {
- ?song a nmm:MusicPiece ;
- %(where_owner)s
- nie:url "%(url)s" .
- }
- """.replace("\n", "").strip() % {
- "owner": owner,
- "property": rdf_property,
- "urn": urn,
- "where_owner": where_owner[owner],
- "url": media.get_url()
- }
-
- self._tracker.update_async(
- query_insert_resource, GLib.PRIORITY_LOW, None,
- self._resource_added, [media, tags, callback])
-
- def _create_new_external_reference(self, conn, res, data):
- media, mbref, tags = data
- try:
- conn.update_finish(res)
- except GLib.Error as e:
- self._log.warning(
- "Unable to delete previous external reference: {}".format(
- e.message))
- self.update_tags(tags)
- return
-
- def _reference_exists_cb(conn, res, data):
- try:
- cursor = conn.query_finish(res)
- except GLib.Error as e:
- self._log.warning(
- "Unable to check external if reference exists: {}".format(
- e.message))
- self.update_tags(tags)
- return
-
- data = [
- media, "", "tracker:hasExternalReference", mbref.owner, tags,
- self.update_tags]
-
- if cursor.next():
- data[1] = cursor.get_string(0)[0]
- self._add_resource_to_piece(None, None, data)
- return
-
- # In Tracker 3.0, Musicbrainz resources urns have changed
- # See
- # https://gitlab.gnome.org/GNOME/tracker-miners/merge_requests/126
- mb_id = getattr(media, mbref.method)()
- mb_source = mbref.source
- source_escaped = Tracker.sparql_escape_uri(mb_source)
- new_urn = "urn:ExternalReference:{}:{}".format(
- source_escaped, mb_id)
-
- query_new_reference = """
- INSERT DATA {
- <%(urn)s> a tracker:ExternalReference ;
- tracker:referenceSource "%(mb_source)s" ;
- tracker:referenceIdentifier "%(mb_id)s" .
- }
- """.replace("\n", "").strip() % {
- "urn": new_urn,
- "mb_source": mb_source,
- "mb_id": mb_id
- }
-
- data[1] = new_urn
- self._tracker.update_async(
- query_new_reference, GLib.PRIORITY_LOW, None,
- self._add_resource_to_piece, data)
-
- mb_id = getattr(media, mbref.method)()
- query_reference_exists = """
- SELECT
- ?reference
- WHERE{
- ?reference a tracker:ExternalReference ;
- tracker:referenceIdentifier "%(mb_id)s"
- }
- """.replace("\n", "").strip() % {
- "mb_id": mb_id
- }
-
- self._tracker.query_async(
- query_reference_exists, None, _reference_exists_cb, None)
-
- def _update_reference(self, media, mbref, tags):
- query_delete = """
- DELETE {
- ?%(owner)s tracker:hasExternalReference ?t
- }
- WHERE {
- ?song a nmm:MusicPiece ;
- nmm:musicAlbum ?album ;
- nmm:performer ?performer ;
- nie:url "%(url)s" .
- ?%(owner)s tracker:hasExternalReference ?t .
- ?t tracker:referenceSource "%(mb_source)s"
- }
- """.replace("\n", "").strip() % {
- "owner": mbref.owner,
- "url": media.get_url(),
- "mb_source": mbref.source
- }
-
- data = [media, mbref, tags]
- self._tracker.update_async(
- query_delete, GLib.PRIORITY_LOW, None,
- self._create_new_external_reference, data)
-
- def _create_new_artist(self, conn, res, data):
- media, owner, tags = data
- try:
- conn.update_finish(res)
- except GLib.Error as e:
- self._log.warning("Unable to delete previous artist: {}".format(
- e.message))
- self.update_tags(media, tags)
- return
-
- def _artist_exists_cb(conn, res, ex_data):
- try:
- cursor = conn.query_finish(res)
- except GLib.Error:
- self.update_tags(media, tags)
- return
-
- data = [media, "", "nmm:performer", owner, tags, self.update_tags]
- if owner == "album":
- data[2] = "nmm:albumArtist"
-
- if cursor.next():
- data[1] = cursor.get_string(0)[0]
- self._add_resource_to_piece(None, None, data)
- return
-
- escaped_urn = Tracker.sparql_escape_uri(artist_name)
- new_urn = "urn:artist:{}".format(escaped_urn)
- data[1] = new_urn
-
- query_new_artist = """
- INSERT DATA {
- <%(urn)s> a nmm:Artist ;
- nmm:artistName "%(name)s" .
- }
- """.replace("\n", "").strip() % {
- "urn": new_urn,
- "name": escaped_name
- }
-
- self._tracker.update_async(
- query_new_artist, GLib.PRIORITY_LOW, None,
- self._add_resource_to_piece, data)
-
- if owner == "album":
- artist_name = media.get_album_artist()
- else:
- artist_name = media.get_artist()
-
- escaped_name = Tracker.sparql_escape_string(artist_name)
- query_artist_exists = """
- SELECT
- ?artist
- WHERE{
- ?artist a nmm:Artist ;
- nmm:artistName "%(name)s" .
- }
- """.replace("\n", "").strip() % {
- "name": escaped_name
- }
-
- self._tracker.query_async(
- query_artist_exists, None, _artist_exists_cb, None)
-
- def _update_artist(self, media, tags):
- query_delete = """
- DELETE {
- ?song nmm:performer ?artist
- }
- WHERE {
- ?song a nmm:MusicPiece ;
- nmm:performer ?artist ;
- nie:url "%(url)s" .
- }
- """.replace("\n", "").strip() % {
- "url": media.get_url()
- }
-
- self._tracker.update_async(
- query_delete, GLib.PRIORITY_LOW, None, self._create_new_artist,
- [media, "song", tags])
-
- def _get_album_urn_suffix(self, media):
- shared = ""
- if media.get_album_artist():
- shared += ":{}".format(media.get_album_artist())
- if media.get_creation_date():
- creation_date = media.get_creation_date()
- date_str = creation_date.format("%FT%TZ")
- shared += ":{}".format(date_str)
-
- suffix = "{}{}".format(media.get_album(), shared)
- return Tracker.sparql_escape_uri(suffix)
-
- def _album_disc_created(self, conn, res, data):
- media, album_disc_urn, tags = data
- try:
- conn.update_finish(res)
- except GLib.Error as e:
- self._log.warning(
- "Unable to create new album disc: {}".format(e.message))
- self.update_tags(media, tags)
- return
-
- def _album_get_cb(conn, res, cb_data):
- try:
- cursor = conn.query_finish(res)
- except GLib.Error as e:
- self._log.warning("Unable to get album: {}".format(e.message))
- self.update_tags(media, tags)
- return
-
- cursor.next()
- album_urn = cursor.get_string(0)[0]
-
- # add album disc to song
- data = [
- media, album_disc_urn, "nmm:musicAlbumDisc", "song", tags,
- None]
- self._add_resource_to_piece(None, None, data)
-
- # add album to album disc
- data = [
- media, album_urn, "nmm:albumDiscAlbum", "albumdisc", tags,
- self.update_tags]
- self._add_resource_to_piece(None, None, data)
-
- query_get_album = """
- SELECT
- ?album
- WHERE {
- ?song a nmm:MusicPiece ;
- nmm:musicAlbum ?album ;
- nie:url "%(url)s" .
- }
- """.replace("\n", "").strip() % {
- "url": media.get_url()
- }
- self._tracker.query_async(
- query_get_album, None, _album_get_cb, None)
-
- def _create_new_album_disc(self, media, tags):
- def _album_disc_exists_cb(conn, res, ex_data):
- try:
- cursor = conn.query_finish(res)
- except GLib.Error as e:
- self._log.warning(
- "Unable to check that album disc exists: {}".format(
- e.message))
- self.update_tags(media, tags)
- return
-
- # If the album disc already exists, it means that the link
- # between the album disc and the album exists too. So, the
- # album disc just needs to be associated with the song.
- # If the album disc does not exist, it needs to be created.
- # Then, it needs to be associated with the song and the
- # nmm:albumDiscAlbum property of the album disc must be
- # created.
- if cursor.next():
- urn = cursor.get_string(0)[0]
- data = [
- media, urn, "nmm:musicAlbumDisc", "song", tags,
- self.update_tags]
- self._add_resource_to_piece(None, None, data)
- return
-
- disc_nr = media.get_album_disc_number()
- urn_suffix = self._get_album_urn_suffix(media)
- new_urn = "urn:album-disc:{}:Disc{}".format(urn_suffix, disc_nr)
-
- query_new_album_disc = """
- INSERT DATA {
- <%(urn)s> a nmm:MusicAlbumDisc ;
- nmm:setNumber "%(disc_nr)s" .
- }
- """.replace("\n", "").strip() % {
- "urn": new_urn,
- "disc_nr": disc_nr
- }
-
- data = [media, new_urn, tags]
- self._tracker.update_async(
- query_new_album_disc, GLib.PRIORITY_LOW, None,
- self._album_disc_created, data)
-
- escaped_name = Tracker.sparql_escape_string(media.get_album())
- if media.get_album_artist():
- artist = Tracker.sparql_escape_uri(media.get_album_artist())
- artist_urn = 'urn:artist:{}'.format(artist)
- artist_cond = "nmm:albumDiscAlbum/nmm:albumArtist '{}' ;".format(
- artist_urn)
- else:
- artist_cond = ""
-
- query_album_disc_exists = """
- SELECT
- ?albumdisc
- WHERE {
- ?albumdisc a nmm:MusicAlbumDisc ;
- nmm:setNumber %(disc_number)s ;
- %(artist_cond)s
- nmm:albumDiscAlbum/nie:title "%(title)s" .
- }
- """.replace("\n", "").strip() % {
- "disc_number": media.get_album_disc_number(),
- "artist_cond": artist_cond,
- "title": escaped_name
- }
-
- self._tracker.query_async(
- query_album_disc_exists, None, _album_disc_exists_cb, None)
-
- def _create_new_album(self, conn, res, data):
- media, tags = data
- try:
- conn.update_finish(res)
- except GLib.Error as e:
- self._log.warning(
- "Unable to delete previous album: {}".format(e.message))
- self.update_tags(media, tags)
- return
-
- def _album_exists_cb(conn, res, ex_data):
- try:
- cursor = conn.query_finish(res)
- except GLib.Error as e:
- self._log.warning(
- "Unable to check that album exists: {}".format(e.message))
- self.update_tags(media, tags)
- return
-
- data = [
- media, "", "nmm:musicAlbum", "song", tags,
- self._create_new_album_disc]
-
- if cursor.next():
- data[1] = cursor.get_string(0)[0]
- self._add_resource_to_piece(None, None, data)
- return
-
- urn_suffix = self._get_album_urn_suffix(media)
- new_urn = "urn:album:{}".format(urn_suffix)
- album_title = Tracker.sparql_escape_string(media.get_album())
-
- query_new_album = """
- INSERT DATA {
- <%(urn)s> a nmm:MusicAlbum ;
- nie:title "%(name)s" .
- }
- """.replace("\n", "").strip() % {
- "urn": new_urn,
- "name": album_title
- }
-
- data[1] = new_urn
- self._tracker.update_async(
- query_new_album, GLib.PRIORITY_LOW, None,
- self._add_resource_to_piece, data)
-
- album_title = Tracker.sparql_escape_string(media.get_album())
- if media.get_album_artist():
- artist = Tracker.sparql_escape_uri(media.get_album_artist())
- artist_urn = 'urn:artist:{}'.format(artist)
- artist_cond = "nmm:albumArtist '{}' ;".format(artist_urn)
- else:
- artist_cond = ""
-
- query_album_exists = """
- SELECT
- ?album
- WHERE {
- ?album a nmm:MusicAlbum ;
- %(artist_cond)s
- nie:title "%(title)s" .
- }
- """.replace("\n", "").strip() % {
- "artist_cond": artist_cond,
- "title": album_title
- }
-
- self._tracker.query_async(
- query_album_exists, None, _album_exists_cb, None)
-
def _update_favorite(self, media):
if (media.get_favourite()):
update = """
@@ -643,47 +214,6 @@ class TrackerWrapper(GObject.GObject):
self._tracker.update_async(
update, GLib.PRIORITY_LOW, None, _update_last_played_cb)
- def _update_album(self, media, tags):
- query_delete = """
- DELETE {
- ?song nmm:musicAlbum ?album .
- ?song nmm:musicAlbumDisc ?album_disc .
- }
- WHERE {
- ?song a nmm:MusicPiece ;
- nmm:musicAlbum ?album ;
- nmm:musicAlbumDisc ?album_disc ;
- nie:url "%(url)s" .
-
- }
- """.replace("\n", "").strip() % {
- "url": media.get_url()
- }
-
- self._tracker.update_async(
- query_delete, GLib.PRIORITY_LOW, None, self._create_new_album,
- [media, tags])
-
- def _update_album_artist(self, media, tags):
- query_delete = """
- DELETE {
- ?album nmm:albumArtist ?artist
- }
- WHERE {
- ?album a nmm:MusicAlbum ;
- nmm:albumArtist ?artist .
- ?song a nmm:MusicPiece ;
- nmm:musicAlbum ?album ;
- nie:url "%(url)s" .
- }
- """.replace("\n", "").strip() % {
- "url": media.get_url()
- }
-
- self._tracker.update_async(
- query_delete, GLib.PRIORITY_LOW, None, self._create_new_artist,
- [media, "album", tags])
-
def update_tags(self, media, tags):
"""Recursively update all tags.
@@ -714,23 +244,7 @@ class TrackerWrapper(GObject.GObject):
self._log.debug("All tags have been updated.")
return
- if tag == "album":
- self._update_album(media, tags)
- elif tag == "album-artist":
- self._update_album_artist(media, tags)
- elif tag == "artist":
- self._update_artist(media, tags)
- elif tag == "mb-recording-id":
- self._update_reference(media, MbReference.RECORDING, tags)
- elif tag == "mb-track-id":
- self._update_reference(media, MbReference.TRACK, tags)
- elif tag == "mb-artist-id":
- self._update_reference(media, MbReference.ARTIST, tags)
- elif tag == "mb-release-id":
- self._update_reference(media, MbReference.RELEASE, tags)
- elif tag == "mb-release-group-id":
- self._update_reference(media, MbReference.RELEASE_GROUP, tags)
- elif tag == "favorite":
+ if tag == "favorite":
self._update_favorite(media)
elif tag == "play-count":
self._update_play_count(media)
[
Date Prev][
Date Next] [
Thread Prev][
Thread Next]
[
Thread Index]
[
Date Index]
[
Author Index]
