summaryrefslogtreecommitdiff
path: root/plugins/mpris/msd-mpris-manager.c
diff options
context:
space:
mode:
authorStefano Karapetsas <[email protected]>2013-03-22 14:08:12 +0100
committerStefano Karapetsas <[email protected]>2013-03-22 14:08:12 +0100
commit9384398bdd679647ca362a72f20c63e5d056f309 (patch)
tree0c269e6c66b5fab148514a3071d61d6f4d131bfa /plugins/mpris/msd-mpris-manager.c
parent017c93b447c419843cbd4f0e105ad0604efe90c6 (diff)
downloadmate-settings-daemon-9384398bdd679647ca362a72f20c63e5d056f309.tar.bz2
mate-settings-daemon-9384398bdd679647ca362a72f20c63e5d056f309.tar.xz
Add MPRIS plugin
Diffstat (limited to 'plugins/mpris/msd-mpris-manager.c')
-rw-r--r--plugins/mpris/msd-mpris-manager.c472
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);
+}
generated by cgit v1.2.1 (git 2.18.0) at 2024-05-10 20:07:32 +0000