diff options
Diffstat (limited to 'plugins/mpris/msd-mpris-manager.c')
| -rw-r--r-- | plugins/mpris/msd-mpris-manager.c | 472 |
1 files changed, 472 insertions, 0 deletions
diff --git a/plugins/mpris/msd-mpris-manager.c b/plugins/mpris/msd-mpris-manager.c new file mode 100644 index 0000000..00cd8dc --- /dev/null +++ b/plugins/mpris/msd-mpris-manager.c @@ -0,0 +1,472 @@ +/* -*- Mode: C; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 8 -*- + * + * Copyright (C) 2013 Stefano Karapetsas <[email protected]> + * + * 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; either version 2 of the License, or + * (at your option) any later version. + * + * 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, write to the Free Software + * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA. + * + * Authors: + * Stefano Karapetsas <[email protected]> + * Steve Zesch <[email protected]> + */ + +#include "config.h" + +#include <sys/types.h> +#include <sys/wait.h> +#include <stdlib.h> +#include <stdio.h> +#include <unistd.h> +#include <string.h> +#include <errno.h> + +#include <locale.h> + +#include <glib.h> +#include <glib/gi18n.h> +#include <gdk/gdk.h> +#include <gdk/gdkx.h> +#include <gtk/gtk.h> + +#include "mate-settings-profile.h" +#include "msd-mpris-manager.h" + +#define MPRIS_OBJECT_PATH "/org/mpris/MediaPlayer2" +#define MPRIS_INTERFACE "org.mpris.MediaPlayer2.Player" +#define MPRIS_PREFIX "org.mpris.MediaPlayer2." + +/* Number of media players supported. + * Correlates to the number of elements in BUS_NAMES */ +static const gint NUM_BUS_NAMES = 16; + +/* Names to we want to watch */ +static const gchar *BUS_NAMES[] = {"org.mpris.MediaPlayer2.audacious", + "org.mpris.MediaPlayer2.clementine", + "org.mpris.MediaPlayer2.vlc", + "org.mpris.MediaPlayer2.mpd", + "org.mpris.MediaPlayer2.exaile", + "org.mpris.MediaPlayer2.banshee", + "org.mpris.MediaPlayer2.rhythmbox", + "org.mpris.MediaPlayer2.pragha", + "org.mpris.MediaPlayer2.quodlibet", + "org.mpris.MediaPlayer2.guayadeque", + "org.mpris.MediaPlayer2.amarok", + "org.mpris.MediaPlayer2.googlemusicframe", + "org.mpris.MediaPlayer2.xbmc", + "org.mpris.MediaPlayer2.xnoise", + "org.mpris.MediaPlayer2.gmusicbrowser", + "org.mpris.MediaPlayer2.spotify"}; + +#define MSD_MPRIS_MANAGER_GET_PRIVATE(o) (G_TYPE_INSTANCE_GET_PRIVATE ((o), MSD_TYPE_MPRIS_MANAGER, MsdMprisManagerPrivate)) + +struct MsdMprisManagerPrivate +{ + GQueue *media_player_queue; + GDBusProxy *media_keys_proxy; + guint watch_id; +}; + +enum { + PROP_0, +}; + +static void msd_mpris_manager_class_init (MsdMprisManagerClass *klass); +static void msd_mpris_manager_init (MsdMprisManager *mpris_manager); +static void msd_mpris_manager_finalize (GObject *object); + +G_DEFINE_TYPE (MsdMprisManager, msd_mpris_manager, G_TYPE_OBJECT) + +static gpointer manager_object = NULL; + +/* Returns the name of the media player. + * User must free. */ +static gchar* +get_player_name(const gchar *name) +{ + gchar **tokens; + gchar *player_name; + + /* max_tokens is 4 because a player could have additional instances, + * lile org.mpris.MediaPlayer2.vlc.instance7389 */ + tokens = g_strsplit (name, ".", 4); + player_name = g_strdup (tokens[3]); + g_strfreev (tokens); + + return player_name; +} + +/* A media player was just run and should be + * added to the head of media_player_queue. */ +static void +mp_name_appeared (GDBusConnection *connection, + const gchar *name, + const gchar *name_owner, + MsdMprisManager *manager) +{ + GDBusProxyFlags flags = G_DBUS_PROXY_FLAGS_DO_NOT_AUTO_START; + GDBusProxy *proxy = NULL; + GError *error = NULL; + gchar *player_name; + + g_debug ("MPRIS Name acquired: %s\n", name); + + player_name = get_player_name(name); + g_queue_push_head (manager->priv->media_player_queue, + player_name); +} + +/* A media player quit running and should be + * removed from media_player_queue. */ +static void +mp_name_vanished (GDBusConnection *connection, + const gchar *name, + MsdMprisManager *manager) +{ + gchar *player_name; + + if (g_queue_is_empty (manager->priv->media_player_queue)) + return; + + g_debug ("MPRIS Name vanished: %s\n", name); + + player_name = get_player_name(name); + + g_queue_remove (manager->priv->media_player_queue, player_name); + + g_free (player_name); +} + +static void +on_media_player_key_pressed (MsdMprisManager *manager, + const gchar *key) +{ + GDBusProxyFlags flags = G_DBUS_PROXY_FLAGS_DO_NOT_AUTO_START; + GDBusProxy *proxy = NULL; + GError *error = NULL; + const char *mpris_key = NULL; + const char *mpris_head = NULL; + char *mpris_name = NULL; + + if (g_queue_is_empty (manager->priv->media_player_queue)) + return; + + if (strcmp ("Play", key) == 0) + mpris_key = "PlayPause"; + else if (strcmp ("Pause", key) == 0) + mpris_key = "Pause"; + else if (strcmp ("Previous", key) == 0) + mpris_key = "Previous"; + else if (strcmp ("Next", key) == 0) + mpris_key = "Next"; + else if (strcmp ("Stop", key) == 0) + mpris_key = "Stop"; + + if (mpris_key != NULL) + { + mpris_head = g_queue_peek_head (manager->priv->media_player_queue); + mpris_name = g_strdup_printf (MPRIS_PREFIX "%s", mpris_head); + + g_debug ("MPRIS Sending '%s' to '%s'!", mpris_key, mpris_head); + + proxy = g_dbus_proxy_new_for_bus_sync(G_BUS_TYPE_SESSION, + flags, + NULL, + mpris_name, + MPRIS_OBJECT_PATH, + MPRIS_INTERFACE, + NULL, + &error); + g_free (mpris_name); + if (proxy == NULL) + { + g_printerr("Error creating proxy: %s\n", error->message); + g_error_free(error); + return; + } + + g_dbus_proxy_call (proxy, mpris_key, NULL, + G_DBUS_CALL_FLAGS_NONE, + -1, NULL, NULL, NULL); + g_object_unref (proxy); + + } +} + +static void +grab_media_player_keys_cb (GDBusProxy *proxy, + GAsyncResult *res, + MsdMprisManager *manager) +{ + GVariant *variant; + GError *error = NULL; + + variant = g_dbus_proxy_call_finish (proxy, res, &error); + + if (variant == NULL) { + if (!g_error_matches (error, G_IO_ERROR, G_IO_ERROR_CANCELLED)) + g_warning ("Failed to call \"GrabMediaPlayerKeys\": %s", error->message); + g_error_free (error); + return; + } + g_variant_unref (variant); +} + +static void +grab_media_player_keys (MsdMprisManager *manager) +{ + if (manager->priv->media_keys_proxy == NULL) + return; + + g_dbus_proxy_call (manager->priv->media_keys_proxy, + "GrabMediaPlayerKeys", + g_variant_new ("(su)", "MsdMpris", 0), + G_DBUS_CALL_FLAGS_NONE, + -1, NULL, + (GAsyncReadyCallback) grab_media_player_keys_cb, + manager); +} + +static void +key_pressed (GDBusProxy *proxy, + gchar *sender_name, + gchar *signal_name, + GVariant *parameters, + MsdMprisManager *manager) +{ + char *app, *cmd; + + if (g_strcmp0 (signal_name, "MediaPlayerKeyPressed") != 0) + return; + g_variant_get (parameters, "(ss)", &app, &cmd); + if (g_strcmp0 (app, "MsdMpris") == 0) { + on_media_player_key_pressed (manager, cmd); + } + g_free (app); + g_free (cmd); +} + +static void +got_proxy_cb (GObject *source_object, + GAsyncResult *res, + MsdMprisManager *manager) +{ + GError *error = NULL; + + manager->priv->media_keys_proxy = g_dbus_proxy_new_for_bus_finish (res, &error); + + if (manager->priv->media_keys_proxy == NULL) { + if (!g_error_matches (error, G_IO_ERROR, G_IO_ERROR_CANCELLED)) + g_warning ("Failed to contact settings daemon: %s", error->message); + g_error_free (error); + return; + } + + grab_media_player_keys (manager); + + g_signal_connect (G_OBJECT (manager->priv->media_keys_proxy), "g-signal", + G_CALLBACK (key_pressed), manager); +} + +static void +msd_name_appeared (GDBusConnection *connection, + const gchar *name, + const gchar *name_owner, + MsdMprisManager *manager) +{ + g_dbus_proxy_new_for_bus (G_BUS_TYPE_SESSION, + G_DBUS_PROXY_FLAGS_DO_NOT_LOAD_PROPERTIES | + G_DBUS_PROXY_FLAGS_DO_NOT_AUTO_START, + NULL, + "org.mate.SettingsDaemon", + "/org/mate/SettingsDaemon/MediaKeys", + "org.mate.SettingsDaemon.MediaKeys", + NULL, + (GAsyncReadyCallback) got_proxy_cb, + manager); +} + +static void +msd_name_vanished (GDBusConnection *connection, + const gchar *name, + MsdMprisManager *manager) +{ + if (manager->priv->media_keys_proxy != NULL) { + g_object_unref (manager->priv->media_keys_proxy); + manager->priv->media_keys_proxy = NULL; + } +} + + +gboolean +msd_mpris_manager_start (MsdMprisManager *manager, + GError **error) +{ + GBusNameWatcherFlags flags = G_BUS_NAME_WATCHER_FLAGS_NONE; + int i; + + g_debug ("Starting mpris manager"); + mate_settings_profile_start (NULL); + + manager->priv->media_player_queue = g_queue_new(); + + /* Register all the names we wish to watch.*/ + for (i = 0; i < NUM_BUS_NAMES; i++) + { + g_bus_watch_name(G_BUS_TYPE_SESSION, + BUS_NAMES[i], + flags, + mp_name_appeared, + mp_name_vanished, + manager, + NULL); + } + + + manager->priv->watch_id = g_bus_watch_name (G_BUS_TYPE_SESSION, + "org.mate.SettingsDaemon", + G_BUS_NAME_WATCHER_FLAGS_NONE, + (GBusNameAppearedCallback) msd_name_appeared, + (GBusNameVanishedCallback) msd_name_vanished, + manager, NULL); + + mate_settings_profile_end (NULL); + return TRUE; +} + +void +msd_mpris_manager_stop (MsdMprisManager *manager) +{ + g_debug ("Stopping mpris manager"); + + if (manager->priv->media_keys_proxy != NULL) { + g_object_unref (manager->priv->media_keys_proxy); + manager->priv->media_keys_proxy = NULL; + } + + if (manager->priv->watch_id != 0) { + g_bus_unwatch_name (manager->priv->watch_id); + manager->priv->watch_id = 0; + } +} + +static void +msd_mpris_manager_set_property (GObject *object, + guint prop_id, + const GValue *value, + GParamSpec *pspec) +{ + MsdMprisManager *self; + + self = MSD_MPRIS_MANAGER (object); + + switch (prop_id) { + default: + G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec); + break; + } +} + +static void +msd_mpris_manager_get_property (GObject *object, + guint prop_id, + GValue *value, + GParamSpec *pspec) +{ + MsdMprisManager *self; + + self = MSD_MPRIS_MANAGER (object); + + switch (prop_id) { + default: + G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec); + break; + } +} + +static GObject * +msd_mpris_manager_constructor (GType type, + guint n_construct_properties, + GObjectConstructParam *construct_properties) +{ + MsdMprisManager *mpris_manager; + MsdMprisManagerClass *klass; + + klass = MSD_MPRIS_MANAGER_CLASS (g_type_class_peek (MSD_TYPE_MPRIS_MANAGER)); + + mpris_manager = MSD_MPRIS_MANAGER (G_OBJECT_CLASS (msd_mpris_manager_parent_class)->constructor (type, + n_construct_properties, + construct_properties)); + + return G_OBJECT (mpris_manager); +} + +static void +msd_mpris_manager_dispose (GObject *object) +{ + MsdMprisManager *mpris_manager; + + mpris_manager = MSD_MPRIS_MANAGER (object); + + G_OBJECT_CLASS (msd_mpris_manager_parent_class)->dispose (object); +} + +static void +msd_mpris_manager_class_init (MsdMprisManagerClass *klass) +{ + GObjectClass *object_class = G_OBJECT_CLASS (klass); + + object_class->get_property = msd_mpris_manager_get_property; + object_class->set_property = msd_mpris_manager_set_property; + object_class->constructor = msd_mpris_manager_constructor; + object_class->dispose = msd_mpris_manager_dispose; + object_class->finalize = msd_mpris_manager_finalize; + + g_type_class_add_private (klass, sizeof (MsdMprisManagerPrivate)); +} + +static void +msd_mpris_manager_init (MsdMprisManager *manager) +{ + manager->priv = MSD_MPRIS_MANAGER_GET_PRIVATE (manager); + +} + +static void +msd_mpris_manager_finalize (GObject *object) +{ + MsdMprisManager *mpris_manager; + + g_return_if_fail (object != NULL); + g_return_if_fail (MSD_IS_MPRIS_MANAGER (object)); + + mpris_manager = MSD_MPRIS_MANAGER (object); + + g_return_if_fail (mpris_manager->priv != NULL); + + G_OBJECT_CLASS (msd_mpris_manager_parent_class)->finalize (object); +} + +MsdMprisManager * +msd_mpris_manager_new (void) +{ + if (manager_object != NULL) { + g_object_ref (manager_object); + } else { + manager_object = g_object_new (MSD_TYPE_MPRIS_MANAGER, NULL); + g_object_add_weak_pointer (manager_object, + (gpointer *) &manager_object); + } + + return MSD_MPRIS_MANAGER (manager_object); +} |