From b28241622081791ec4589d83a53078c768d4dea2 Mon Sep 17 00:00:00 2001 From: Conor Curran Date: Thu, 2 Dec 2010 19:35:49 +0000 Subject: moving in the right direction, registration happening on dbus watching --- src/mpris2-watcher.vala | 76 +++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 76 insertions(+) create mode 100644 src/mpris2-watcher.vala (limited to 'src/mpris2-watcher.vala') diff --git a/src/mpris2-watcher.vala b/src/mpris2-watcher.vala new file mode 100644 index 0000000..55212ec --- /dev/null +++ b/src/mpris2-watcher.vala @@ -0,0 +1,76 @@ +/* +Copyright 2010 Canonical Ltd. + +Authors: + Conor Curran + +This program is free software: you can redistribute it and/or modify it +under the terms of the GNU General Public License version 3, as published +by the Free Software Foundation. + +This program is distributed in the hope that it will be useful, but +WITHOUT ANY WARRANTY; without even the implied warranties of +MERCHANTABILITY, SATISFACTORY QUALITY, or FITNESS FOR A PARTICULAR +PURPOSE. See the GNU General Public License for more details. + +You should have received a copy of the GNU General Public License along +with this program. If not, see . +*/ + +// TODO: Until match rules are properly supported in vala we need to explicitly +// watch for each client inorder to facilitate proper registration. + +public class Mpris2Watcher : GLib.Object +{ + public MusicPlayerBridge the_bridge {get; construct;} + const string BANSHEE_BUS_NAME = "org.mpris.MediaPlayer2.banshee"; + private MprisRoot mpris2_root; + private DBusConnection connection; + + public Mpris2Watcher ( MusicPlayerBridge bridge ) + { + GLib.Object(the_bridge: bridge); + } + + construct{ + try { + this.connection = Bus.get_sync ( BusType.SESSION ); + GLib.BusNameAppearedCallback banshee_change_cb = (GLib.BusNameAppearedCallback)banshee_appeared; + GLib.BusNameVanishedCallback banshee_gone_cb = (GLib.BusNameVanishedCallback)banshee_disappeared; + Bus.watch_name_on_connection ( this.connection, + BANSHEE_BUS_NAME, + BusNameWatcherFlags.AUTO_START, + banshee_change_cb, + banshee_gone_cb ); + } + catch ( IOError e ){ + warning( "Mpris2watcher could not set up a watch for mpris clients appearing on the bus: %s", + e.message ); + } + } + + private void banshee_appeared ( GLib.DBusConnection connection, + string name, + string name_owner ) + { + try { + this.mpris2_root = Bus.get_proxy_sync ( BusType.SESSION, + BANSHEE_BUS_NAME, + "/org/mpris/MediaPlayer2" ); + this.the_bridge.client_has_become_available ( this.mpris2_root.DesktopEntry ); + debug ( "On Name Appeared - name %s, name_owner %s", this.mpris2_root.DesktopEntry, name_owner ); + } + catch ( IOError e ){ + warning( "Mpris2watcher could not instantiate an mpris root for banshee: %s", + e.message ); + } + } + + private void banshee_disappeared ( GLib.DBusConnection connection, + string name, + string name_owner ) + { + debug ( "On Name Disappeared - name %s, name_owner %s", name, name_owner ); + } + +} \ No newline at end of file -- cgit v1.2.3 From d113aa188ab72d8ca3efe22ad7f336f753fb4e48 Mon Sep 17 00:00:00 2001 From: Conor Curran Date: Fri, 3 Dec 2010 13:58:30 +0000 Subject: used a signal instead of passing in ref, still vala bug is biting --- src/mpris2-watcher.vala | 36 +++++++----- src/music-player-bridge.vala | 129 ++++++++++++++++++++++--------------------- 2 files changed, 88 insertions(+), 77 deletions(-) (limited to 'src/mpris2-watcher.vala') diff --git a/src/mpris2-watcher.vala b/src/mpris2-watcher.vala index 55212ec..ed7388f 100644 --- a/src/mpris2-watcher.vala +++ b/src/mpris2-watcher.vala @@ -22,17 +22,15 @@ with this program. If not, see . public class Mpris2Watcher : GLib.Object { - public MusicPlayerBridge the_bridge {get; construct;} const string BANSHEE_BUS_NAME = "org.mpris.MediaPlayer2.banshee"; - private MprisRoot mpris2_root; private DBusConnection connection; - - public Mpris2Watcher ( MusicPlayerBridge bridge ) + public signal void clientappeared ( string desktop_name ); + + public Mpris2Watcher () { - GLib.Object(the_bridge: bridge); } - - construct{ + construct + { try { this.connection = Bus.get_sync ( BusType.SESSION ); GLib.BusNameAppearedCallback banshee_change_cb = (GLib.BusNameAppearedCallback)banshee_appeared; @@ -46,19 +44,23 @@ public class Mpris2Watcher : GLib.Object catch ( IOError e ){ warning( "Mpris2watcher could not set up a watch for mpris clients appearing on the bus: %s", e.message ); - } + } } private void banshee_appeared ( GLib.DBusConnection connection, string name, - string name_owner ) + string name_owner) { try { - this.mpris2_root = Bus.get_proxy_sync ( BusType.SESSION, - BANSHEE_BUS_NAME, - "/org/mpris/MediaPlayer2" ); - this.the_bridge.client_has_become_available ( this.mpris2_root.DesktopEntry ); - debug ( "On Name Appeared - name %s, name_owner %s", this.mpris2_root.DesktopEntry, name_owner ); + MprisRoot mpris2_root = Bus.get_proxy_sync ( BusType.SESSION, + BANSHEE_BUS_NAME, + "/org/mpris/MediaPlayer2" ); + //this.the_bridge.client_has_become_available ( mpris2_root.DesktopEntry ); + debug ( "On Name Appeared - name %s, name_owner %s", + mpris2_root.DesktopEntry, + name_owner ); + debug ( "this pointer in banshee appeared callback %i", (int)this); + this.clientappeared ( "mpris2_root.DesktopEntry" ); } catch ( IOError e ){ warning( "Mpris2watcher could not instantiate an mpris root for banshee: %s", @@ -66,6 +68,12 @@ public class Mpris2Watcher : GLib.Object } } + public void test_signal_emission() + { + this.clientappeared ( "test signal emission" ); + debug ( "this pointer in test-signal-emission %i", (int)this); + } + private void banshee_disappeared ( GLib.DBusConnection connection, string name, string name_owner ) diff --git a/src/music-player-bridge.vala b/src/music-player-bridge.vala index 8d7998e..73469a4 100644 --- a/src/music-player-bridge.vala +++ b/src/music-player-bridge.vala @@ -24,54 +24,55 @@ using GLib; public class MusicPlayerBridge : GLib.Object { private Dbusmenu.Menuitem root_menu; - private HashMap registered_clients; - private FamiliarPlayersDB playersDB; + private HashMap registered_clients; + private FamiliarPlayersDB playersDB; private Mpris2Watcher watcher; private const string DESKTOP_PREFIX = "/usr/share/applications/"; + public MusicPlayerBridge() { - playersDB = new FamiliarPlayersDB(); - registered_clients = new HashMap (); + playersDB = new FamiliarPlayersDB(); + registered_clients = new HashMap (); } - private void try_to_add_inactive_familiar_clients(){ - foreach(string app in this.playersDB.records()){ - if(app == null){ - warning("App string in keyfile is null therefore moving on to next player"); - continue; - } + private void try_to_add_inactive_familiar_clients(){ + foreach(string app in this.playersDB.records()){ + if(app == null){ + warning("App string in keyfile is null therefore moving on to next player"); + continue; + } + + debug("attempting to make an app info from %s", app); - debug("attempting to make an app info from %s", app); - - DesktopAppInfo info = new DesktopAppInfo.from_filename(app); + DesktopAppInfo info = new DesktopAppInfo.from_filename(app); if(info == null){ - warning("Could not create a desktopappinfo instance from app,: %s , moving on to the next client", app); - continue; - } + warning("Could not create a desktopappinfo instance from app,: %s , moving on to the next client", app); + continue; + } - GLib.AppInfo app_info = info as GLib.AppInfo; + GLib.AppInfo app_info = info as GLib.AppInfo; var mpris_key = determine_key(app); - PlayerController ctrl = new PlayerController(this.root_menu, - app_info, + PlayerController ctrl = new PlayerController(this.root_menu, + app_info, mpris_key, playersDB.fetch_icon_name(app), - calculate_menu_position(), - PlayerController.state.OFFLINE); - this.registered_clients.set(mpris_key, ctrl); - } - } + calculate_menu_position(), + PlayerController.state.OFFLINE); + this.registered_clients.set(mpris_key, ctrl); + } + } - private int calculate_menu_position() - { - if(this.registered_clients.size == 0){ - return 2; - } - else{ - return (2 + (this.registered_clients.size * PlayerController.WIDGET_QUANTITY)); - } - } - + private int calculate_menu_position() + { + if(this.registered_clients.size == 0){ + return 2; + } + else{ + return (2 + (this.registered_clients.size * PlayerController.WIDGET_QUANTITY)); + } + } + /*public void on_server_added(Indicate.ListenerServer object, string type) { debug("MusicPlayerBridge -> on_server_added with value %s", type); @@ -84,8 +85,9 @@ public class MusicPlayerBridge : GLib.Object public void client_has_become_available ( string desktop_file_name ) { + debug ( "client_has_become_available %s", desktop_file_name ); string path = DESKTOP_PREFIX.concat ( desktop_file_name.concat( ".desktop" ) ); - AppInfo? app_info = create_app_info ( path ); + AppInfo? app_info = create_app_info ( path ); if ( app_info == null ){ warning ( "Could not create app_info for path %s \n Getting out of here ", path); return; @@ -93,24 +95,24 @@ public class MusicPlayerBridge : GLib.Object var mpris_key = determine_key ( desktop_file_name ); - if ( this.playersDB.already_familiar ( path ) == false ){ - debug("New client has registered that we have not seen before: %s", desktop_file_name ); - this.playersDB.insert ( path ); - PlayerController ctrl = new PlayerController ( this.root_menu, - app_info, + if ( this.playersDB.already_familiar ( path ) == false ){ + debug("New client has registered that we have not seen before: %s", desktop_file_name ); + this.playersDB.insert ( path ); + PlayerController ctrl = new PlayerController ( this.root_menu, + app_info, mpris_key, playersDB.fetch_icon_name(path), - this.calculate_menu_position(), - PlayerController.state.READY ); + this.calculate_menu_position(), + PlayerController.state.READY ); this.registered_clients.set ( mpris_key, ctrl ); debug ( "successfully created appinfo and instance from path and set it on the respective instance" ); - } - else{ - this.registered_clients[mpris_key].update_state ( PlayerController.state.READY ); - this.registered_clients[mpris_key].activate ( ); - debug("Ignoring desktop file path callback because the db cache file has it already: %s \n", path); - } - } + } + else{ + this.registered_clients[mpris_key].update_state ( PlayerController.state.READY ); + this.registered_clients[mpris_key].activate ( ); + debug("Ignoring desktop file path callback because the db cache file has it already: %s \n", path); + } + } /*public void on_server_removed(Indicate.ListenerServer object, string type) { @@ -126,24 +128,25 @@ public class MusicPlayerBridge : GLib.Object } }*/ - public void set_root_menu_item(Dbusmenu.Menuitem menu) { - this.root_menu = menu; - this.try_to_add_inactive_familiar_clients(); - this.watcher = new Mpris2Watcher (this) ; + this.root_menu = menu; + this.try_to_add_inactive_familiar_clients(); + this.watcher = new Mpris2Watcher (); + this.watcher.clientappeared += this.client_has_become_available; + this.watcher.test_signal_emission(); } - public static AppInfo? create_app_info ( string path ) - { - DesktopAppInfo info = new DesktopAppInfo.from_filename ( path ) ; - if ( path == null || info == null ){ - warning ( "Could not create a desktopappinfo instance from app: %s", path ); - return null; - } - GLib.AppInfo app_info = info as GLib.AppInfo; - return app_info; - } + public static AppInfo? create_app_info ( string path ) + { + DesktopAppInfo info = new DesktopAppInfo.from_filename ( path ) ; + if ( path == null || info == null ){ + warning ( "Could not create a desktopappinfo instance from app: %s", path ); + return null; + } + GLib.AppInfo app_info = info as GLib.AppInfo; + return app_info; + } private static string? determine_key(owned string name) { -- cgit v1.2.3 From 5aada20653702ce8996abd7d25c9bce0a59b65ff Mon Sep 17 00:00:00 2001 From: Conor Curran Date: Fri, 3 Dec 2010 15:05:07 +0000 Subject: used a signal instead of passing in ref, still vala bug is biting --- src/mpris2-watcher.vala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'src/mpris2-watcher.vala') diff --git a/src/mpris2-watcher.vala b/src/mpris2-watcher.vala index ed7388f..775d9b6 100644 --- a/src/mpris2-watcher.vala +++ b/src/mpris2-watcher.vala @@ -47,7 +47,7 @@ public class Mpris2Watcher : GLib.Object } } - private void banshee_appeared ( GLib.DBusConnection connection, + public void banshee_appeared ( GLib.DBusConnection connection, string name, string name_owner) { -- cgit v1.2.3 From 91aa96835684880832c8e535798ebeb6dcca4039 Mon Sep 17 00:00:00 2001 From: Conor Curran Date: Fri, 3 Dec 2010 20:03:21 +0000 Subject: new registration process complete and seemingly healthy --- src/mpris2-watcher.vala | 92 ++++++++++++++++++++++---------------------- src/music-player-bridge.vala | 4 +- 2 files changed, 48 insertions(+), 48 deletions(-) (limited to 'src/mpris2-watcher.vala') diff --git a/src/mpris2-watcher.vala b/src/mpris2-watcher.vala index 775d9b6..7e41b5f 100644 --- a/src/mpris2-watcher.vala +++ b/src/mpris2-watcher.vala @@ -17,68 +17,68 @@ You should have received a copy of the GNU General Public License along with this program. If not, see . */ -// TODO: Until match rules are properly supported in vala we need to explicitly -// watch for each client inorder to facilitate proper registration. +[DBus (name = "org.freedesktop.DBus")] +public interface FreeDesktopObject: Object { + public abstract signal void name_owner_changed (string name, + string old_owner, + string new_owner); +} public class Mpris2Watcher : GLib.Object { - const string BANSHEE_BUS_NAME = "org.mpris.MediaPlayer2.banshee"; - private DBusConnection connection; - public signal void clientappeared ( string desktop_name ); + private const string FREEDESKTOP_SERVICE = "org.freedesktop.DBus"; + private const string FREEDESKTOP_OBJECT = "/org/freedesktop/DBus"; + private const string MPRIS_PREFIX = "org.mpris.MediaPlayer2."; + private const string MPRIS_MEDIA_PLAYER_PATH = "/org/mpris/MediaPlayer2"; + + FreeDesktopObject fdesktop_obj; + + public signal void client_appeared ( string desktop_name ); + public signal void client_disappeared ( string desktop_name ); public Mpris2Watcher () { } + construct { try { - this.connection = Bus.get_sync ( BusType.SESSION ); - GLib.BusNameAppearedCallback banshee_change_cb = (GLib.BusNameAppearedCallback)banshee_appeared; - GLib.BusNameVanishedCallback banshee_gone_cb = (GLib.BusNameVanishedCallback)banshee_disappeared; - Bus.watch_name_on_connection ( this.connection, - BANSHEE_BUS_NAME, - BusNameWatcherFlags.AUTO_START, - banshee_change_cb, - banshee_gone_cb ); + this.fdesktop_obj = Bus.get_proxy_sync ( BusType.SESSION, + FREEDESKTOP_SERVICE, + FREEDESKTOP_OBJECT, + DBusProxyFlags.DO_NOT_LOAD_PROPERTIES ); + this.fdesktop_obj.name_owner_changed.connect (this.name_changes_detected); } catch ( IOError e ){ warning( "Mpris2watcher could not set up a watch for mpris clients appearing on the bus: %s", - e.message ); + e.message ); } } - public void banshee_appeared ( GLib.DBusConnection connection, - string name, - string name_owner) - { - try { - MprisRoot mpris2_root = Bus.get_proxy_sync ( BusType.SESSION, - BANSHEE_BUS_NAME, - "/org/mpris/MediaPlayer2" ); - //this.the_bridge.client_has_become_available ( mpris2_root.DesktopEntry ); - debug ( "On Name Appeared - name %s, name_owner %s", - mpris2_root.DesktopEntry, - name_owner ); - debug ( "this pointer in banshee appeared callback %i", (int)this); - this.clientappeared ( "mpris2_root.DesktopEntry" ); + private void name_changes_detected ( FreeDesktopObject dbus_obj, + string name, + string previous_owner, + string current_owner ) { + MprisRoot mpris2_root; + if ( name.has_prefix (MPRIS_PREFIX) ){ + try { + mpris2_root = Bus.get_proxy_sync ( BusType.SESSION, + name, + MPRIS_MEDIA_PLAYER_PATH ); + } + catch (IOError e){ + warning( "Mpris2watcher could not create a root interface: %s", + e.message ); + return; + } + if (previous_owner != "" && current_owner == "") { + debug ("Service '%s' going down", name); + client_disappeared (mpris2_root.DesktopEntry); + } + else if (previous_owner == "" && current_owner != "") { + debug ("Service '%s' has appeared", name); + client_appeared (mpris2_root.DesktopEntry); + } } - catch ( IOError e ){ - warning( "Mpris2watcher could not instantiate an mpris root for banshee: %s", - e.message ); - } } - - public void test_signal_emission() - { - this.clientappeared ( "test signal emission" ); - debug ( "this pointer in test-signal-emission %i", (int)this); - } - - private void banshee_disappeared ( GLib.DBusConnection connection, - string name, - string name_owner ) - { - debug ( "On Name Disappeared - name %s, name_owner %s", name, name_owner ); - } - } \ No newline at end of file diff --git a/src/music-player-bridge.vala b/src/music-player-bridge.vala index 73469a4..8124021 100644 --- a/src/music-player-bridge.vala +++ b/src/music-player-bridge.vala @@ -133,8 +133,8 @@ public class MusicPlayerBridge : GLib.Object this.root_menu = menu; this.try_to_add_inactive_familiar_clients(); this.watcher = new Mpris2Watcher (); - this.watcher.clientappeared += this.client_has_become_available; - this.watcher.test_signal_emission(); + this.watcher.client_appeared += this.client_has_become_available; + //this.watcher.client_appeared += this.client_has_become_available; } public static AppInfo? create_app_info ( string path ) -- cgit v1.2.3 From aef17a4810d3480b64b20dd6aebd8b12e104778a Mon Sep 17 00:00:00 2001 From: Conor Curran Date: Mon, 6 Dec 2010 15:33:58 +0000 Subject: registration working perfectly and operational all over gdbus --- src/mpris2-controller.vala | 207 +++++++++++++++++++++---------------------- src/mpris2-watcher.vala | 8 +- src/music-player-bridge.vala | 34 ++++--- 3 files changed, 124 insertions(+), 125 deletions(-) (limited to 'src/mpris2-watcher.vala') diff --git a/src/mpris2-controller.vala b/src/mpris2-controller.vala index c382e97..ff19598 100644 --- a/src/mpris2-controller.vala +++ b/src/mpris2-controller.vala @@ -20,11 +20,9 @@ with this program. If not, see . using Dbusmenu; -/*[DBus (name = "org.freedesktop.DBus.Properties")] - public interface FreeDesktopProperties : DBus.Object{ - // signals - public signal void PropertiesChanged(string source, HashTable changed_properties, +[DBus (name = "org.freedesktop.DBus.Properties")] + public interface FreeDesktopProperties : Object{ + public signal void PropertiesChanged(string source, HashTable changed_properties, string[] invalid); } @@ -33,136 +31,131 @@ using Dbusmenu; point in trying to get encorporate both into the same object model. */ public class Mpris2Controller : GLib.Object -{ - public static const string root_interface = "org.mpris.MediaPlayer2" ; - public MprisRoot mpris2_root {get; construct;} - public MprisPlayer player {get; construct;} - //public FreeDesktopProperties properties_interface {get; construct;} +{ + public static const string root_interface = "org.mpris.MediaPlayer2" ; + public MprisRoot mpris2_root {get; construct;} + public MprisPlayer player {get; construct;} + public FreeDesktopProperties properties_interface {get; construct;} public PlayerController owner {get; construct;} - - public Mpris2Controller(PlayerController ctrl) - { - GLib.Object(owner: ctrl); - } - - construct{ + + public Mpris2Controller(PlayerController ctrl) + { + GLib.Object(owner: ctrl); + } + + construct{ try { - this.mpris2_root = Bus.get_proxy_sync ( BusType.SESSION, + this.mpris2_root = Bus.get_proxy_sync ( BusType.SESSION, root_interface.concat(".").concat(this.owner.mpris_name), - "/org/mpris/MediaPlayer2"); - this.player = Bus.get_proxy_sync ( BusType.SESSION, + "/org/mpris/MediaPlayer2"); + this.player = Bus.get_proxy_sync ( BusType.SESSION, root_interface.concat(".").concat(this.owner.mpris_name), - "/org/mpris/MediaPlayer2" ); - /* - this.properties_interface = (FreeDesktopProperties) connection.get_object("org.freedesktop.Properties.PropertiesChanged", - "/org/mpris/MediaPlayer2"); - this.properties_interface.PropertiesChanged += property_changed_cb;*/ + "/org/mpris/MediaPlayer2" ); - } catch (IOError e) { - error("Problems connecting to the session bus - %s", e.message); - } - } - - /*public void property_changed_cb(string interface_source, HashTable changed_properties, string[] invalid ) - { - debug("properties-changed for interface %s and owner %s", interface_source, this.owner.mpris_name); - - if(changed_properties == null || interface_source.has_prefix(this.root_interface) == false ){ - warning("Property-changed hash is null or this is an interface that doesn't concerns us"); - return; - } - Value? play_v = changed_properties.lookup("PlaybackStatus"); - if(play_v != null){ - string state = this.player.PlaybackStatus; - TransportMenuitem.state p = (TransportMenuitem.state)this.determine_play_state(state); - (this.owner.custom_items[PlayerController.widget_order.TRANSPORT] as TransportMenuitem).change_play_state(p); - } - - Value? meta_v = changed_properties.lookup("Metadata"); - if(meta_v != null){ - GLib.HashTable changed_updates = clean_metadata(); + this.properties_interface = Bus.get_proxy_sync ( BusType.SESSION, + "org.freedesktop.Properties.PropertiesChanged", + "/org/mpris/MediaPlayer2" ); + this.properties_interface.PropertiesChanged += property_changed_cb; + } + catch (IOError e) { + error("Problems connecting to the session bus - %s", e.message); + } + } + + public void property_changed_cb ( string interface_source, + HashTable changed_properties, + string[] invalid ) + { + debug("properties-changed for interface %s and owner %s", interface_source, this.owner.mpris_name); + if(changed_properties == null || interface_source.has_prefix(this.root_interface) == false ){ + warning("Property-changed hash is null or this is an interface that doesn't concerns us"); + return; + } + Variant? play_v = changed_properties.lookup("PlaybackStatus"); + if(play_v != null){ + string state = this.player.PlaybackStatus; + TransportMenuitem.state p = (TransportMenuitem.state)this.determine_play_state(state); + (this.owner.custom_items[PlayerController.widget_order.TRANSPORT] as TransportMenuitem).change_play_state(p); + } + Variant? meta_v = changed_properties.lookup("Metadata"); + if(meta_v != null){ + GLib.HashTable changed_updates = clean_metadata(); PlayerItem metadata = this.owner.custom_items[PlayerController.widget_order.METADATA]; - metadata.reset(MetadataMenuitem.attributes_format()); - metadata.update(changed_updates, - MetadataMenuitem.attributes_format()); - metadata.property_set_bool(MENUITEM_PROP_VISIBLE, - metadata.populated(MetadataMenuitem.attributes_format())); + metadata.reset( MetadataMenuitem.attributes_format()); + metadata.update ( changed_updates, + MetadataMenuitem.attributes_format()); + metadata.property_set_bool ( MENUITEM_PROP_VISIBLE, + metadata.populated(MetadataMenuitem.attributes_format())); } - }*/ + } - private GLib.HashTable? clean_metadata() + private GLib.HashTable? clean_metadata() { - /*GLib.HashTable changed_updates = this.player.Metadata; - Value? artist_v = this.player.Metadata.lookup("xesam:artist"); + GLib.HashTable changed_updates = this.player.Metadata; + Variant? artist_v = this.player.Metadata.lookup("xesam:artist"); if(artist_v != null){ string[] artists = (string[])this.player.Metadata.lookup("xesam:artist"); string display_artists = string.joinv(", ", artists); changed_updates.replace("xesam:artist", display_artists); debug("artist : %s", display_artists); } - Value? length_v = this.player.Metadata.lookup("mpris:length"); + Variant? length_v = this.player.Metadata.lookup("mpris:length"); if(length_v != null){ int64 duration = this.player.Metadata.lookup("mpris:length").get_int64(); changed_updates.replace("mpris:length", duration/1000000); } return changed_updates; - */ - return null; - } - - private TransportMenuitem.state determine_play_state(string? status){ - if(status != null && status == "Playing"){ - return TransportMenuitem.state.PLAYING; - } - return TransportMenuitem.state.PAUSED; + //return null; } - public void initial_update() - { - TransportMenuitem.state update; - /*if(this.player.PlaybackStatus == null){ - update = TransportMenuitem.state.PAUSED; - }*/ + private TransportMenuitem.state determine_play_state(string? status){ + if(status != null && status == "Playing"){ + return TransportMenuitem.state.PLAYING; + } + return TransportMenuitem.state.PAUSED; + } + + public void initial_update() + { + TransportMenuitem.state update; + if(this.player.PlaybackStatus == null){ + update = TransportMenuitem.state.PAUSED; + } update = determine_play_state(null); - + (this.owner.custom_items[PlayerController.widget_order.TRANSPORT] as TransportMenuitem).change_play_state(TransportMenuitem.state.PAUSED); - GLib.HashTable? cleaned_metadata = this.clean_metadata(); - //this.owner.custom_items[PlayerController.widget_order.METADATA].update(cleaned_metadata, - // MetadataMenuitem.attributes_format()); - } - - public void transport_update(TransportMenuitem.action command) - { - debug("transport_event input = %i", (int)command); - if(command == TransportMenuitem.action.PLAY_PAUSE){ - this.player.PlayPause.begin(); - } - else if(command == TransportMenuitem.action.PREVIOUS){ - this.player.Previous.begin(); - } - else if(command == TransportMenuitem.action.NEXT){ - this.player.Next.begin(); - } - } - - public bool connected() - { - return false; - } + GLib.HashTable? cleaned_metadata = this.clean_metadata(); + this.owner.custom_items[PlayerController.widget_order.METADATA].update(cleaned_metadata, + MetadataMenuitem.attributes_format()); + } + + public void transport_update(TransportMenuitem.action command) + { + debug("transport_event input = %i", (int)command); + if(command == TransportMenuitem.action.PLAY_PAUSE){ + this.player.PlayPause.begin(); + } + else if(command == TransportMenuitem.action.PREVIOUS){ + this.player.Previous.begin(); + } + else if(command == TransportMenuitem.action.NEXT){ + this.player.Next.begin(); + } + } - - public bool was_successfull(){ - return false; - } + public bool connected() + { + return (this.player != null && this.mpris2_root != null); + } - public void expose() - { - if(this.connected() == true){ - //this.mpris2_root.Raise.begin(); - } - } + public void expose() + { + if(this.connected() == true){ + this.mpris2_root.Raise.begin(); + } + } } diff --git a/src/mpris2-watcher.vala b/src/mpris2-watcher.vala index 7e41b5f..1cf8baa 100644 --- a/src/mpris2-watcher.vala +++ b/src/mpris2-watcher.vala @@ -34,7 +34,7 @@ public class Mpris2Watcher : GLib.Object FreeDesktopObject fdesktop_obj; public signal void client_appeared ( string desktop_name ); - public signal void client_disappeared ( string desktop_name ); + public signal void client_disappeared ( string mpris_root_interface ); public Mpris2Watcher () { @@ -72,11 +72,11 @@ public class Mpris2Watcher : GLib.Object return; } if (previous_owner != "" && current_owner == "") { - debug ("Service '%s' going down", name); - client_disappeared (mpris2_root.DesktopEntry); + debug ("Client '%s' gone down", name); + client_disappeared (name); } else if (previous_owner == "" && current_owner != "") { - debug ("Service '%s' has appeared", name); + debug ("Client '%s' has appeared", name); client_appeared (mpris2_root.DesktopEntry); } } diff --git a/src/music-player-bridge.vala b/src/music-player-bridge.vala index c905c12..d1c2334 100644 --- a/src/music-player-bridge.vala +++ b/src/music-player-bridge.vala @@ -114,19 +114,18 @@ public class MusicPlayerBridge : GLib.Object } } - /*public void on_server_removed(Indicate.ListenerServer object, string type) + public void client_has_vanished ( string mpris_root_interface ) { - debug("MusicPlayerBridge -> on_server_removed with value %s", type); - if(server_is_not_of_interest(type)) return; - if (root_menu != null){ - var tmp = type.split("."); - debug("attempt to remove %s", tmp[tmp.length-1]); - if(tmp.length > 0){ - registered_clients[tmp[tmp.length - 1]].hibernate(); - debug("Successively offlined client %s", tmp[tmp.length - 1]); + debug("MusicPlayerBridge -> on_server_removed with value %s", mpris_root_interface); + if (root_menu != null){ + debug("attempt to remove %s", mpris_root_interface); + var mpris_key = determine_key ( mpris_root_interface ); + if ( mpris_key != null ){ + registered_clients[mpris_key].hibernate(); + debug("Successively offlined client %s", mpris_key); } - } - }*/ + } + } public void set_root_menu_item(Dbusmenu.Menuitem menu) { @@ -134,7 +133,7 @@ public class MusicPlayerBridge : GLib.Object this.try_to_add_inactive_familiar_clients(); this.watcher = new Mpris2Watcher (); this.watcher.client_appeared += this.client_has_become_available; - //this.watcher.client_appeared += this.client_has_become_available; + this.watcher.client_disappeared += this.client_has_vanished; } public static AppInfo? create_app_info ( string path ) @@ -150,8 +149,15 @@ public class MusicPlayerBridge : GLib.Object private static string? determine_key(owned string path) { - var tokens = path.split("/"); - if ( tokens.length < 2) return null; + var tokens = path.split( "/" ); + if ( tokens.length < 2 ){ + // try to split on "." + tokens = path.split("."); + if ( tokens.length < 2 ){ + // don't know what this is + return null; + } + } var filename = tokens[tokens.length - 1]; var result = filename.split(".")[0]; var temp = result.split("-"); -- cgit v1.2.3