diff options
author | Xavi Garcia Mena <xavi.garcia.mena@canonical.com> | 2016-03-07 10:13:38 +0000 |
---|---|---|
committer | CI Train Bot <ci-train-bot@canonical.com> | 2016-03-07 10:13:38 +0000 |
commit | 57f5cbe43e95d72e0904473ab371e9e016b73956 (patch) | |
tree | b8186a4701bbafcf9fc9a71bbcb35fd9b3ee81d1 /src | |
parent | de4abb7448d329f7e7c20e01f8b14f22627a69a3 (diff) | |
parent | 3aa67455801c7db139be5a9293ddb6d7d703a981 (diff) | |
download | ayatana-indicator-sound-57f5cbe43e95d72e0904473ab371e9e016b73956.tar.gz ayatana-indicator-sound-57f5cbe43e95d72e0904473ab371e9e016b73956.tar.bz2 ayatana-indicator-sound-57f5cbe43e95d72e0904473ab371e9e016b73956.zip |
This branch sets the last running player using accounts service instead of gsettings.
It also includes a new class AccountsServiceAccess, to centralize all accesses to account service properties.
Approved by: PS Jenkins bot, Charles Kerr
Diffstat (limited to 'src')
-rw-r--r-- | src/CMakeLists.txt | 33 | ||||
-rw-r--r-- | src/accounts-service-access.vala | 235 | ||||
-rw-r--r-- | src/main.c | 108 | ||||
-rw-r--r-- | src/service.vala | 23 | ||||
-rw-r--r-- | src/sound-menu.vala | 48 | ||||
-rw-r--r-- | src/volume-control-pulse.vala | 153 |
6 files changed, 374 insertions, 226 deletions
diff --git a/src/CMakeLists.txt b/src/CMakeLists.txt index ff03859..0498903 100644 --- a/src/CMakeLists.txt +++ b/src/CMakeLists.txt @@ -69,29 +69,37 @@ vala_add(indicator-sound-service media-player-list mpris2-interfaces accounts-service-user + accounts-service-access ) vala_add(indicator-sound-service options.vala DEPENDS volume-control volume-control-pulse + accounts-service-access ) vala_add(indicator-sound-service options-gsettings.vala DEPENDS options - volume-control-pulse + volume-control-pulse volume-control + accounts-service-access ) vala_add(indicator-sound-service volume-control.vala DEPENDS options - volume-control-pulse + volume-control-pulse + accounts-service-access +) +vala_add(indicator-sound-service + accounts-service-access.vala ) vala_add(indicator-sound-service volume-control-pulse.vala DEPENDS + accounts-service-access options volume-control ) @@ -99,20 +107,22 @@ vala_add(indicator-sound-service volume-warning.vala DEPENDS options - volume-control-pulse + volume-control-pulse volume-control warn-notification - notification + notification + accounts-service-access ) vala_add(indicator-sound-service volume-warning-pulse.vala DEPENDS volume-warning - options - volume-control-pulse - volume-control - warn-notification - notification + options + volume-control-pulse + volume-control + warn-notification + notification + accounts-service-access ) vala_add(indicator-sound-service media-player.vala @@ -161,8 +171,9 @@ vala_add(indicator-sound-service DEPENDS media-player volume-control - options - volume-control-pulse + options + volume-control-pulse + accounts-service-access ) vala_add(indicator-sound-service accounts-service-user.vala diff --git a/src/accounts-service-access.vala b/src/accounts-service-access.vala new file mode 100644 index 0000000..2c73922 --- /dev/null +++ b/src/accounts-service-access.vala @@ -0,0 +1,235 @@ +/* + * -*- Mode:Vala; indent-tabs-mode:t; tab-width:4; encoding:utf8 -*- + * Copyright 2016 Canonical Ltd. + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; version 3. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY 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 <http://www.gnu.org/licenses/>. + * + * Authors: + * Xavi Garcia <xavi.garcia.mena@canonical.com> + */ + +using PulseAudio; +using Notify; +using Gee; + +[DBus (name="com.canonical.UnityGreeter.List")] +interface GreeterListInterfaceAccess : Object +{ + public abstract async string get_active_entry () throws IOError; + public signal void entry_selected (string entry_name); +} + +public class AccountsServiceAccess : Object +{ + private DBusProxy _user_proxy; + private GreeterListInterfaceAccess _greeter_proxy; + private double _volume = 0.0; + private string _last_running_player = ""; + private bool _mute = false; + private Cancellable _dbus_call_cancellable; + + public AccountsServiceAccess () + { + _dbus_call_cancellable = new Cancellable (); + setup_accountsservice.begin (); + } + + ~AccountsServiceAccess () + { + _dbus_call_cancellable.cancel (); + } + + public string last_running_player + { + get + { + return _last_running_player; + } + set + { + sync_last_running_player_to_accountsservice.begin (value); + } + } + + public bool mute + { + get + { + return _mute; + } + set + { + sync_mute_to_accountsservice.begin (value); + } + } + + public double volume + { + get + { + return _volume; + } + set + { + sync_volume_to_accountsservice.begin (value); + } + } + + /* AccountsService operations */ + private void accountsservice_props_changed_cb (DBusProxy proxy, Variant changed_properties, string[]? invalidated_properties) + { + Variant volume_variant = changed_properties.lookup_value ("Volume", VariantType.DOUBLE); + if (volume_variant != null) { + var volume = volume_variant.get_double (); + if (volume >= 0 && _volume != volume) { + _volume = volume; + this.notify_property("volume"); + } + } + + Variant mute_variant = changed_properties.lookup_value ("Muted", VariantType.BOOLEAN); + if (mute_variant != null) { + _mute = mute_variant.get_boolean (); + this.notify_property("mute"); + } + + Variant last_running_player_variant = changed_properties.lookup_value ("LastRunningPlayer", VariantType.STRING); + if (last_running_player_variant != null) { + _last_running_player = last_running_player_variant.get_string (); + this.notify_property("last-running-player"); + } + } + + private async void setup_user_proxy (string? username_in = null) + { + var username = username_in; + _user_proxy = null; + + // Look up currently selected greeter user, if asked + if (username == null) { + try { + username = yield _greeter_proxy.get_active_entry (); + if (username == "" || username == null) + return; + } catch (GLib.Error e) { + warning ("unable to find Accounts path for user %s: %s", username == null ? "null" : username, e.message); + return; + } + } + + // Get master AccountsService object + DBusProxy accounts_proxy; + try { + accounts_proxy = yield DBusProxy.create_for_bus (BusType.SYSTEM, DBusProxyFlags.DO_NOT_LOAD_PROPERTIES | DBusProxyFlags.DO_NOT_CONNECT_SIGNALS, null, "org.freedesktop.Accounts", "/org/freedesktop/Accounts", "org.freedesktop.Accounts"); + } catch (GLib.Error e) { + warning ("unable to get greeter proxy: %s", e.message); + return; + } + + // Find user's AccountsService object + try { + var user_path_variant = yield accounts_proxy.call ("FindUserByName", new Variant ("(s)", username), DBusCallFlags.NONE, -1); + string user_path; + if (user_path_variant.check_format_string ("(o)", true)) { + user_path_variant.get ("(o)", out user_path); + _user_proxy = yield DBusProxy.create_for_bus (BusType.SYSTEM, DBusProxyFlags.GET_INVALIDATED_PROPERTIES, null, "org.freedesktop.Accounts", user_path, "com.ubuntu.AccountsService.Sound"); + } else { + warning ("Unable to find user name after calling FindUserByName. Expected type: %s and obtained %s", "(o)", user_path_variant.get_type_string () ); + return; + } + } catch (GLib.Error e) { + warning ("unable to find Accounts path for user %s: %s", username, e.message); + return; + } + + // Get current values and listen for changes + _user_proxy.g_properties_changed.connect (accountsservice_props_changed_cb); + try { + var props_variant = yield _user_proxy.get_connection ().call (_user_proxy.get_name (), _user_proxy.get_object_path (), "org.freedesktop.DBus.Properties", "GetAll", new Variant ("(s)", _user_proxy.get_interface_name ()), null, DBusCallFlags.NONE, -1); + if (props_variant.check_format_string ("(@a{sv})", true)) { + Variant props; + props_variant.get ("(@a{sv})", out props); + accountsservice_props_changed_cb(_user_proxy, props, null); + } else { + warning ("Unable to get accounts service properties after calling GetAll. Expected type: %s and obtained %s", "(@a{sv})", props_variant.get_type_string () ); + return; + } + } catch (GLib.Error e) { + debug("Unable to get properties for user %s at first try: %s", username, e.message); + } + } + + private void greeter_user_changed (string username) + { + setup_user_proxy.begin (username); + } + + private async void setup_accountsservice () + { + if (Environment.get_variable ("XDG_SESSION_CLASS") == "greeter") { + try { + _greeter_proxy = yield Bus.get_proxy (BusType.SESSION, "com.canonical.UnityGreeter", "/list"); + } catch (GLib.Error e) { + warning ("unable to get greeter proxy: %s", e.message); + return; + } + _greeter_proxy.entry_selected.connect (greeter_user_changed); + yield setup_user_proxy (); + } else { + // We are in a user session. We just need our own proxy + unowned string username = Environment.get_variable ("USER"); + if (username != null && username != "") { + yield setup_user_proxy (username); + } + } + } + + private async void sync_last_running_player_to_accountsservice (string last_running_player) + { + if (_user_proxy == null) + return; + + try { + yield _user_proxy.get_connection ().call (_user_proxy.get_name (), _user_proxy.get_object_path (), "org.freedesktop.DBus.Properties", "Set", new Variant ("(ssv)", _user_proxy.get_interface_name (), "LastRunningPlayer", new Variant ("s", last_running_player)), null, DBusCallFlags.NONE, -1, _dbus_call_cancellable); + } catch (GLib.Error e) { + warning ("unable to sync last running player %s to AccountsService: %s",last_running_player, e.message); + } + _last_running_player = last_running_player; + } + + private async void sync_volume_to_accountsservice (double volume) + { + if (_user_proxy == null) + return; + + try { + yield _user_proxy.get_connection ().call (_user_proxy.get_name (), _user_proxy.get_object_path (), "org.freedesktop.DBus.Properties", "Set", new Variant ("(ssv)", _user_proxy.get_interface_name (), "Volume", new Variant ("d", volume)), null, DBusCallFlags.NONE, -1, _dbus_call_cancellable); + } catch (GLib.Error e) { + warning ("unable to sync volume %f to AccountsService: %s", volume, e.message); + } + } + + private async void sync_mute_to_accountsservice (bool mute) + { + if (_user_proxy == null) + return; + + try { + yield _user_proxy.get_connection ().call (_user_proxy.get_name (), _user_proxy.get_object_path (), "org.freedesktop.DBus.Properties", "Set", new Variant ("(ssv)", _user_proxy.get_interface_name (), "Muted", new Variant ("b", mute)), null, DBusCallFlags.NONE, -1, _dbus_call_cancellable); + } catch (GLib.Error e) { + warning ("unable to sync mute %s to AccountsService: %s", mute ? "true" : "false", e.message); + } + } +} + + @@ -27,9 +27,9 @@ static pa_glib_mainloop * pgloop = NULL; static gboolean sigterm_handler (gpointer data) { - g_debug("Got SIGTERM"); - g_main_loop_quit((GMainLoop *)data); - return G_SOURCE_REMOVE; + g_debug("Got SIGTERM"); + g_main_loop_quit((GMainLoop *)data); + return G_SOURCE_REMOVE; } static void @@ -37,8 +37,8 @@ on_name_lost(GDBusConnection * connection, const gchar * name, gpointer user_data) { - g_warning("Name lost or unable to acquire bus: %s", name); - g_main_loop_quit((GMainLoop *)user_data); + g_warning("Name lost or unable to acquire bus: %s", name); + g_main_loop_quit((GMainLoop *)user_data); } static void @@ -46,66 +46,68 @@ on_bus_acquired(GDBusConnection *connection, const gchar *name, gpointer user_data) { - MediaPlayerList * playerlist = NULL; - IndicatorSoundOptions * options = NULL; - VolumeControlPulse * volume = NULL; - AccountsServiceUser * accounts = NULL; - VolumeWarning * warning = NULL; - - - if (g_strcmp0("lightdm", g_get_user_name()) == 0) { - playerlist = MEDIA_PLAYER_LIST(media_player_list_greeter_new()); - } else { - playerlist = MEDIA_PLAYER_LIST(media_player_list_mpris_new()); - accounts = accounts_service_user_new(); - } - - pgloop = pa_glib_mainloop_new(NULL); - options = indicator_sound_options_gsettings_new(); - volume = volume_control_pulse_new(options, pgloop); - warning = volume_warning_pulse_new(options, pgloop); - - service = indicator_sound_service_new (playerlist, volume, accounts, options, warning); - - g_clear_object(&playerlist); - g_clear_object(&options); - g_clear_object(&volume); - g_clear_object(&accounts); - g_clear_object(&warning); + MediaPlayerList * playerlist = NULL; + IndicatorSoundOptions * options = NULL; + VolumeControlPulse * volume = NULL; + AccountsServiceUser * accounts = NULL; + VolumeWarning * warning = NULL; + AccountsServiceAccess * accounts_service_access = NULL; + + + if (g_strcmp0("lightdm", g_get_user_name()) == 0) { + playerlist = MEDIA_PLAYER_LIST(media_player_list_greeter_new()); + } else { + playerlist = MEDIA_PLAYER_LIST(media_player_list_mpris_new()); + accounts = accounts_service_user_new(); + } + + pgloop = pa_glib_mainloop_new(NULL); + options = indicator_sound_options_gsettings_new(); + accounts_service_access = accounts_service_access_new(); + volume = volume_control_pulse_new(options, pgloop, accounts_service_access); + warning = volume_warning_pulse_new(options, pgloop); + + service = indicator_sound_service_new (playerlist, volume, accounts, options, warning, accounts_service_access); + + g_clear_object(&playerlist); + g_clear_object(&options); + g_clear_object(&volume); + g_clear_object(&accounts); + g_clear_object(&warning); } int main (int argc, char ** argv) { - GMainLoop * loop = NULL; - bind_textdomain_codeset (GETTEXT_PACKAGE, "UTF-8"); - setlocale (LC_ALL, ""); - bindtextdomain (GETTEXT_PACKAGE, GNOMELOCALEDIR); + GMainLoop * loop = NULL; + bind_textdomain_codeset (GETTEXT_PACKAGE, "UTF-8"); + setlocale (LC_ALL, ""); + bindtextdomain (GETTEXT_PACKAGE, GNOMELOCALEDIR); - /* Build Mainloop */ - loop = g_main_loop_new(NULL, FALSE); + /* Build Mainloop */ + loop = g_main_loop_new(NULL, FALSE); - g_unix_signal_add(SIGTERM, sigterm_handler, loop); + g_unix_signal_add(SIGTERM, sigterm_handler, loop); - /* Initialize libnotify */ - notify_init ("indicator-sound"); + /* Initialize libnotify */ + notify_init ("indicator-sound"); - g_bus_own_name(G_BUS_TYPE_SESSION, - "com.canonical.indicator.sound", - G_BUS_NAME_OWNER_FLAGS_NONE, - on_bus_acquired, - NULL, /* name acquired */ - on_name_lost, - loop, - NULL); + g_bus_own_name(G_BUS_TYPE_SESSION, + "com.canonical.indicator.sound", + G_BUS_NAME_OWNER_FLAGS_NONE, + on_bus_acquired, + NULL, /* name acquired */ + on_name_lost, + loop, + NULL); - g_main_loop_run(loop); + g_main_loop_run(loop); - g_clear_object(&service); - g_clear_pointer(&pgloop, pa_glib_mainloop_free); + g_clear_object(&service); + g_clear_pointer(&pgloop, pa_glib_mainloop_free); - notify_uninit(); + notify_uninit(); - return 0; + return 0; } diff --git a/src/service.vala b/src/service.vala index cb30820..bdc4d40 100644 --- a/src/service.vala +++ b/src/service.vala @@ -20,7 +20,9 @@ public class IndicatorSound.Service: Object { DBusConnection bus; - public Service (MediaPlayerList playerlist, VolumeControl volume, AccountsServiceUser? accounts, Options options, VolumeWarning volume_warning) { + public Service (MediaPlayerList playerlist, VolumeControl volume, AccountsServiceUser? accounts, Options options, VolumeWarning volume_warning, AccountsServiceAccess? accounts_service_access) { + + _accounts_service_access = accounts_service_access; try { bus = Bus.get_sync(GLib.BusType.SESSION); @@ -60,7 +62,6 @@ public class IndicatorSound.Service: Object { headphones = false; break; } - message("setting _volume_warning.headphones_active to %d", (int)headphones); _volume_warning.headphones_active = headphones; update_root_icon(); @@ -91,12 +92,11 @@ public class IndicatorSound.Service: Object { this.actions.add_action (this.create_high_volume_action ()); this.actions.add_action (this.create_volume_sync_action ()); - string last_player = this.settings.get_string ("last-running-player"); this.menus = new HashTable<string, SoundMenu> (str_hash, str_equal); - this.menus.insert ("desktop_greeter", new SoundMenu (null, SoundMenu.DisplayFlags.SHOW_MUTE | SoundMenu.DisplayFlags.HIDE_PLAYERS | SoundMenu.DisplayFlags.GREETER_PLAYERS, last_player)); - this.menus.insert ("phone_greeter", new SoundMenu (null, SoundMenu.DisplayFlags.SHOW_SILENT_MODE | SoundMenu.DisplayFlags.HIDE_INACTIVE_PLAYERS | SoundMenu.DisplayFlags.GREETER_PLAYERS, last_player)); - this.menus.insert ("desktop", new SoundMenu ("indicator.desktop-settings", SoundMenu.DisplayFlags.SHOW_MUTE | SoundMenu.DisplayFlags.HIDE_INACTIVE_PLAYERS_PLAY_CONTROLS | SoundMenu.DisplayFlags.ADD_PLAY_CONTROL_INACTIVE_PLAYER, last_player)); - this.menus.insert ("phone", new SoundMenu ("indicator.phone-settings", SoundMenu.DisplayFlags.SHOW_SILENT_MODE | SoundMenu.DisplayFlags.HIDE_INACTIVE_PLAYERS, last_player)); + this.menus.insert ("desktop_greeter", new SoundMenu (null, SoundMenu.DisplayFlags.SHOW_MUTE | SoundMenu.DisplayFlags.HIDE_PLAYERS | SoundMenu.DisplayFlags.GREETER_PLAYERS)); + this.menus.insert ("phone_greeter", new SoundMenu (null, SoundMenu.DisplayFlags.SHOW_SILENT_MODE | SoundMenu.DisplayFlags.HIDE_INACTIVE_PLAYERS | SoundMenu.DisplayFlags.GREETER_PLAYERS)); + this.menus.insert ("desktop", new SoundMenu ("indicator.desktop-settings", SoundMenu.DisplayFlags.SHOW_MUTE | SoundMenu.DisplayFlags.HIDE_INACTIVE_PLAYERS_PLAY_CONTROLS | SoundMenu.DisplayFlags.ADD_PLAY_CONTROL_INACTIVE_PLAYER)); + this.menus.insert ("phone", new SoundMenu ("indicator.phone-settings", SoundMenu.DisplayFlags.SHOW_SILENT_MODE | SoundMenu.DisplayFlags.HIDE_INACTIVE_PLAYERS)); this.menus.@foreach ( (profile, menu) => { this.volume_control.bind_property ("active-mic", menu, "show-mic-volume", BindingFlags.SYNC_CREATE); @@ -112,7 +112,13 @@ public class IndicatorSound.Service: Object { this.menus.@foreach ( (profile, menu) => { menu.last_player_updated.connect ((player_id) => { - this.settings.set_value ("last-running-player", player_id); + this._accounts_service_access.last_running_player = player_id; + }); + }); + + this._accounts_service_access.notify["last-running-player"].connect(() => { + this.menus.@foreach ( (profile, menu) => { + menu.set_default_player (this._accounts_service_access.last_running_player); }); }); @@ -199,6 +205,7 @@ public class IndicatorSound.Service: Object { private Options _options; private VolumeWarning _volume_warning; private IndicatorSound.InfoNotification _info_notification = new IndicatorSound.InfoNotification(); + private AccountsServiceAccess _accounts_service_access; const double volume_step_percentage = 0.06; diff --git a/src/sound-menu.vala b/src/sound-menu.vala index 630dca0..2ef089a 100644 --- a/src/sound-menu.vala +++ b/src/sound-menu.vala @@ -38,7 +38,7 @@ public class SoundMenu: Object const string PLAYBACK_ITEM_TYPE = "com.canonical.unity.playback-item"; - public SoundMenu (string? settings_action, DisplayFlags flags, string default_player_id) { + public SoundMenu (string? settings_action, DisplayFlags flags) { /* A sound menu always has at least two sections: the volume section (this.volume_section) * at the start of the menu, and the settings section at the end. Between those two, * it has a dynamic amount of player sections, one for each registered player. @@ -83,9 +83,6 @@ public class SoundMenu: Object this.notify_handlers = new HashTable<MediaPlayer, ulong> (direct_hash, direct_equal); this.greeter_players = (flags & DisplayFlags.GREETER_PLAYERS) != 0; - - this.default_player = default_player_id; - } ~SoundMenu () { @@ -95,6 +92,16 @@ public class SoundMenu: Object } } + public void set_default_player (string default_player_id) { + this.default_player = default_player_id; + foreach (var player_stored in notify_handlers.get_keys ()) { + int index = this.find_player_section(player_stored); + if (index != -1 && player_stored.id == this.default_player) { + add_player_playback_controls (player_stored, index, true); + } + } + } + DBusConnection? bus = null; uint export_id = 0; @@ -171,7 +178,17 @@ public class SoundMenu: Object } } } - + + private void check_last_running_player () { + foreach (var player in notify_handlers.get_keys ()) { + if (player.is_running && number_of_running_players == 1) { + // this is the first or the last player running... + // store its id + this.last_player_updated (player.id); + } + } + } + public void add_player (MediaPlayer player) { if (this.notify_handlers.contains (player)) return; @@ -198,11 +215,15 @@ public class SoundMenu: Object // we need to update the rest of players, because we might have // a non running player still showing the playback controls update_all_players_play_section(); + + check_last_running_player (); }); this.notify_handlers.insert (player, handler_id); player.playlists_changed.connect (this.update_playlists); player.playbackstatus_changed.connect (this.update_playbackstatus); + + check_last_running_player (); } public void remove_player (MediaPlayer player) { @@ -217,6 +238,8 @@ public class SoundMenu: Object /* this'll drop our ref to it */ this.notify_handlers.remove (player); + + check_last_running_player (); } public void update_volume_slider (VolumeControl.ActiveOutput active_output) { @@ -368,16 +391,11 @@ public class SoundMenu: Object this.menu.remove (index); } - void update_player_section (MediaPlayer player, int index) { + void add_player_playback_controls (MediaPlayer player, int index, bool adding_default_player) { var player_section = this.menu.get_item_link(index, Menu.LINK_SECTION) as Menu; int play_control_index = find_player_playback_controls_section (player_section); - if (player.is_running && number_of_running_players == 1) { - // this is the first or the last player running... - // store its id - this.last_player_updated (player.id); - } - if (player.is_running || !this.hide_inactive_player_controls) { + if (player.is_running || !this.hide_inactive_player_controls || (number_of_running_players == 0 && adding_default_player) ) { MenuItem playback_item = create_playback_menu_item (player); if (play_control_index != -1) { player_section.remove (PlayerSectionPosition.PLAYER_CONTROLS); @@ -389,7 +407,11 @@ public class SoundMenu: Object player_section.remove (PlayerSectionPosition.PLAYLIST); player_section.remove (PlayerSectionPosition.PLAYER_CONTROLS); } - } + } + } + + void update_player_section (MediaPlayer player, int index) { + add_player_playback_controls (player, index, false); } void update_playlists (MediaPlayer player) { diff --git a/src/volume-control-pulse.vala b/src/volume-control-pulse.vala index 6021447..c8a6071 100644 --- a/src/volume-control-pulse.vala +++ b/src/volume-control-pulse.vala @@ -22,13 +22,6 @@ using PulseAudio; using Notify; using Gee; -[DBus (name="com.canonical.UnityGreeter.List")] -interface GreeterListInterface : Object -{ - public abstract async string get_active_entry () throws IOError; - public signal void entry_selected (string entry_name); -} - public class VolumeControlPulse : VolumeControl { private unowned PulseAudio.GLibMainLoop loop = null; @@ -55,20 +48,17 @@ public class VolumeControlPulse : VolumeControl private string? _objp_role_phone = null; private uint _pa_volume_sig_count = 0; - private DBusProxy _user_proxy; - private GreeterListInterface _greeter_proxy; - private Cancellable _mute_cancellable; - private Cancellable _volume_cancellable; private uint _local_volume_timer = 0; private uint _accountservice_volume_timer = 0; private bool _send_next_local_volume = false; private double _account_service_volume = 0.0; private VolumeControl.ActiveOutput _active_output = VolumeControl.ActiveOutput.SPEAKERS; + private AccountsServiceAccess _accounts_service_access; /** true when a microphone is active **/ public override bool active_mic { get; private set; default = false; } - public VolumeControlPulse (IndicatorSound.Options options, PulseAudio.GLibMainLoop loop) + public VolumeControlPulse (IndicatorSound.Options options, PulseAudio.GLibMainLoop loop, AccountsServiceAccess? accounts_service_access) { base(options); @@ -77,11 +67,14 @@ public class VolumeControlPulse : VolumeControl this.loop = loop; - _mute_cancellable = new Cancellable (); - _volume_cancellable = new Cancellable (); - - setup_accountsservice.begin (); - + _accounts_service_access = accounts_service_access; + this._accounts_service_access.notify["volume"].connect(() => { + if (this._accounts_service_access.volume >= 0 && _account_service_volume != this._accounts_service_access.volume) { + _account_service_volume = this._accounts_service_access.volume; + // we need to wait for this to settle. + start_account_service_volume_timer(); + } + }); this.reconnect_to_pulse (); } @@ -537,7 +530,7 @@ public class VolumeControlPulse : VolumeControl public override void set_mute (bool mute) { if (set_mute_internal (mute)) - sync_mute_to_accountsservice.begin (mute); + _accounts_service_access.mute = mute; } public void toggle_mute () @@ -773,128 +766,6 @@ public class VolumeControlPulse : VolumeControl } /* AccountsService operations */ - private void accountsservice_props_changed_cb (DBusProxy proxy, Variant changed_properties, string[]? invalidated_properties) - { - Variant volume_variant = changed_properties.lookup_value ("Volume", VariantType.DOUBLE); - if (volume_variant != null) { - var volume = volume_variant.get_double (); - if (volume >= 0) { - _account_service_volume = volume; - // we need to wait for this to settle. - start_account_service_volume_timer(); - } - } - - Variant mute_variant = changed_properties.lookup_value ("Muted", VariantType.BOOLEAN); - if (mute_variant != null) { - var mute = mute_variant.get_boolean (); - set_mute_internal (mute); - } - } - - private async void setup_user_proxy (string? username_in = null) - { - var username = username_in; - _user_proxy = null; - - // Look up currently selected greeter user, if asked - if (username == null) { - try { - username = yield _greeter_proxy.get_active_entry (); - if (username == "" || username == null) - return; - } catch (GLib.Error e) { - warning ("unable to find Accounts path for user %s: %s", username, e.message); - return; - } - } - - // Get master AccountsService object - DBusProxy accounts_proxy; - try { - accounts_proxy = yield DBusProxy.create_for_bus (BusType.SYSTEM, DBusProxyFlags.DO_NOT_LOAD_PROPERTIES | DBusProxyFlags.DO_NOT_CONNECT_SIGNALS, null, "org.freedesktop.Accounts", "/org/freedesktop/Accounts", "org.freedesktop.Accounts"); - } catch (GLib.Error e) { - warning ("unable to get greeter proxy: %s", e.message); - return; - } - - // Find user's AccountsService object - try { - var user_path_variant = yield accounts_proxy.call ("FindUserByName", new Variant ("(s)", username), DBusCallFlags.NONE, -1); - string user_path; - user_path_variant.get ("(o)", out user_path); - _user_proxy = yield DBusProxy.create_for_bus (BusType.SYSTEM, DBusProxyFlags.GET_INVALIDATED_PROPERTIES, null, "org.freedesktop.Accounts", user_path, "com.ubuntu.AccountsService.Sound"); - } catch (GLib.Error e) { - warning ("unable to find Accounts path for user %s: %s", username, e.message); - return; - } - - // Get current values and listen for changes - _user_proxy.g_properties_changed.connect (accountsservice_props_changed_cb); - try { - var props_variant = yield _user_proxy.get_connection ().call (_user_proxy.get_name (), _user_proxy.get_object_path (), "org.freedesktop.DBus.Properties", "GetAll", new Variant ("(s)", _user_proxy.get_interface_name ()), null, DBusCallFlags.NONE, -1); - Variant props; - props_variant.get ("(@a{sv})", out props); - accountsservice_props_changed_cb(_user_proxy, props, null); - } catch (GLib.Error e) { - debug("Unable to get properties for user %s at first try: %s", username, e.message); - } - } - - private void greeter_user_changed (string username) - { - setup_user_proxy.begin (username); - } - - private async void setup_accountsservice () - { - if (Environment.get_variable ("XDG_SESSION_CLASS") == "greeter") { - try { - _greeter_proxy = yield Bus.get_proxy (BusType.SESSION, "com.canonical.UnityGreeter", "/list"); - } catch (GLib.Error e) { - warning ("unable to get greeter proxy: %s", e.message); - return; - } - _greeter_proxy.entry_selected.connect (greeter_user_changed); - yield setup_user_proxy (); - } else { - // We are in a user session. We just need our own proxy - unowned string username = Environment.get_variable ("USER"); - if (username != "" && username != null) { - yield setup_user_proxy (username); - } - } - } - - private async void sync_mute_to_accountsservice (bool mute) - { - if (_user_proxy == null) - return; - - _mute_cancellable.cancel (); - _mute_cancellable.reset (); - - try { - yield _user_proxy.get_connection ().call (_user_proxy.get_name (), _user_proxy.get_object_path (), "org.freedesktop.DBus.Properties", "Set", new Variant ("(ssv)", _user_proxy.get_interface_name (), "Muted", new Variant ("b", mute)), null, DBusCallFlags.NONE, -1, _mute_cancellable); - } catch (GLib.Error e) { - warning ("unable to sync mute to AccountsService: %s", e.message); - } - } - - private async void sync_volume_to_accountsservice (VolumeControl.Volume volume) - { - if (_user_proxy == null) - return; - - _volume_cancellable.cancel (); - _volume_cancellable.reset (); - - try { - yield _user_proxy.get_connection ().call (_user_proxy.get_name (), _user_proxy.get_object_path (), "org.freedesktop.DBus.Properties", "Set", new Variant ("(ssv)", _user_proxy.get_interface_name (), "Volume", new Variant ("d", volume.volume)), null, DBusCallFlags.NONE, -1, _volume_cancellable); - } catch (GLib.Error e) { - warning ("unable to sync volume to AccountsService: %s", e.message); - } - } private void start_local_volume_timer() { @@ -904,7 +775,7 @@ public class VolumeControlPulse : VolumeControl stop_account_service_volume_timer(); if (_local_volume_timer == 0) { - sync_volume_to_accountsservice.begin (_volume); + _accounts_service_access.volume = _volume.volume; _local_volume_timer = Timeout.add_seconds (1, local_volume_changed_timeout); } else { _send_next_local_volume = true; |