--- /dev/null
+/* $Id: plugin_mpris_dbus.c 870 2009-04-09 14:55:23Z abbaskosan $
+ * $URL: https://ssl.bulix.org/svn/lcd4linux/trunk/plugin_mpris_dbus.c $
+ *
+ * plugin mpris dbus
+ *
+ * Copyright (C) 2009 Abbas Kosan <abbaskosan@gmail.com>
+ * Copyright (C) 2004, 2005, 2006, 2007, 2008 The LCD4Linux Team <lcd4linux-devel@users.sourceforge.net>
+ *
+ * This file is part of LCD4Linux.
+ *
+ * LCD4Linux 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, or (at your option)
+ * any later version.
+ *
+ * LCD4Linux 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., 675 Mass Ave, Cambridge, MA 02139, USA.
+ *
+ */
+
+/*
+ * exported functions:
+ *
+ * int plugin_init_mpris_dbus (void)
+ * adds various functions
+ *
+ */
+
+#include "config.h"
+
+#include <stdlib.h>
+#include <string.h>
+#include <ctype.h>
+
+#include <stdio.h>
+
+// TODO: dbus-1 folder should be added to include path
+#include <dbus/dbus.h>
+
+/* these should always be included */
+#include "debug.h"
+#include "plugin.h"
+#include "hash.h"
+
+#ifdef WITH_DMALLOC
+#include <dmalloc.h>
+#endif
+
+static HASH DBUS;
+
+// D-Bus variables
+static DBusMessage* msg;
+static DBusMessageIter args;
+static DBusConnection* conn;
+static DBusError err;
+static DBusPendingCall* pending;
+
+static void read_MetaData()
+{
+ // put pairs to hash table
+ int current_type;
+ // TODO: check size of char arrays
+ char str_key[255];
+ char str_value[2048];
+ DBusMessageIter subiter1;
+
+ dbus_message_iter_recurse (&args, &subiter1);
+ while ((current_type = dbus_message_iter_get_arg_type (&subiter1)) != DBUS_TYPE_INVALID)
+ {
+ DBusMessageIter subiter2;
+ DBusMessageIter subiter3;
+
+ strcpy(str_key,"");
+ strcpy(str_value,"");
+ dbus_message_iter_recurse (&subiter1, &subiter2);
+ current_type = dbus_message_iter_get_arg_type (&subiter2);
+
+ if (current_type == DBUS_TYPE_INVALID)
+ break;
+ if (current_type == DBUS_TYPE_STRING)
+ {
+ void *str_tmp1;
+ void *str_tmp2;
+ dbus_message_iter_get_basic (&subiter2, &str_tmp1);
+ strcpy(str_key,str_tmp1);
+ dbus_message_iter_next (&subiter2);
+ dbus_message_iter_recurse (&subiter2, &subiter3);
+ current_type = dbus_message_iter_get_arg_type (&subiter3);
+ switch (current_type)
+ {
+ case DBUS_TYPE_STRING:
+ {
+ dbus_message_iter_get_basic (&subiter3, &str_tmp2);
+ strcpy(str_value,str_tmp2);
+ break;
+ }
+ case DBUS_TYPE_INT32:
+ {
+ dbus_int32_t val;
+ dbus_message_iter_get_basic (&subiter3, &val);
+ sprintf (str_value,"%d", val);
+ break;
+ }
+ case DBUS_TYPE_INT64:
+ {
+ dbus_int64_t val;
+ dbus_message_iter_get_basic (&subiter3, &val);
+ sprintf (str_value,"%Ld", val);
+ break;
+ }
+ default:
+ // unexpected type
+ //printf (" (2-dbus-monitor too dumb to decipher arg type '%c')\n", current_type);
+ break;
+ }
+ // add key-value pair to hash
+ hash_put(&DBUS,str_key,str_value);
+ //printf("Key: %s , Value: %s\t",str_key,str_value);
+ }
+ //else
+ // unexpected type
+ //printf (" (2-dbus-monitor too dumb to decipher arg type '%c')\n", current_type);
+ dbus_message_iter_next (&subiter1);
+ }
+}
+
+static int listen_TrackChange(void)
+{
+ // non blocking read of the next available message
+ dbus_connection_read_write(conn, 0);
+ msg = dbus_connection_pop_message(conn);
+
+ // nothing to do if we haven't read a message
+ if (NULL == msg)
+ return 0;
+
+ // check if the message is a signal from the correct interface and with the correct name
+ if (dbus_message_is_signal(msg, "org.freedesktop.MediaPlayer", "TrackChange")) {
+ // read the parameters
+ // TrackChange signal returns an array of string-variant pairs
+ if (!dbus_message_iter_init(msg, &args)) {
+ // No parameter !
+ //fprintf(stderr, "Message Has No Parameters\n");
+ return 0;
+ }
+ else if (DBUS_TYPE_ARRAY != dbus_message_iter_get_arg_type(&args)) {
+ // Argument is not array
+ //fprintf(stderr, "Argument is not array!\n");
+ return 0;
+ }
+ else
+ read_MetaData();
+ //printf("Got Signal\n");
+ }
+ // free message
+ dbus_message_unref(msg);
+ return 1;
+}
+
+static unsigned long int call_PositionGet(char* target)
+{
+ unsigned long int value=0;
+
+ // create a new method call and check for errors
+ msg = dbus_message_new_method_call(target, //target for the method call e.g "org.kde.amarok"
+ "/Player", // object to call on
+ "org.freedesktop.MediaPlayer", // interface to call on
+ "PositionGet"); // method name
+ if (NULL == msg) {
+ //fprintf(stderr, "Message Null\n");
+ return 0;
+ }
+
+ // send message and get a handle for a reply
+ if (!dbus_connection_send_with_reply (conn, msg, &pending, -1)) { // -1 is default timeout
+ //fprintf(stderr, "Out Of Memory!\n");
+ return 0;
+ }
+ if (NULL == pending) {
+ //fprintf(stderr, "Pending Call Null\n");
+ return 0;
+ }
+ dbus_connection_flush(conn);
+
+ //printf("Request Sent\n");
+
+ // free message
+ dbus_message_unref(msg);
+
+ // block until we recieve a reply
+ dbus_pending_call_block(pending);
+
+ // get the reply message
+ msg = dbus_pending_call_steal_reply(pending);
+ if (NULL == msg) {
+ //fprintf(stderr, "Reply Null\n");
+ return 0;
+ }
+ // free the pending message handle
+ dbus_pending_call_unref(pending);
+
+ // read the parameters
+ if (!dbus_message_iter_init(msg, &args)) {
+ //fprintf(stderr, "Message has no arguments!\n");
+ return 0;
+ }
+ if (DBUS_TYPE_INT32 != dbus_message_iter_get_arg_type(&args)) {
+ //fprintf(stderr, "Argument is not INT32!\n");
+ return 0;
+ }
+ else
+ dbus_message_iter_get_basic(&args, &value);
+ //printf("\nGot Reply: %d", value);
+
+ // free message
+ dbus_message_unref(msg);
+
+ return value;
+}
+
+static void signal_TrackChange(RESULT * result, RESULT * arg1)
+{
+ char *str_tmp;
+ /*
+ if (listen_TrackChange() < 0) {
+ SetResult(&result, R_STRING, "");
+ return;
+ }
+ */
+ listen_TrackChange();
+ str_tmp = hash_get(&DBUS, R2S(arg1), NULL);
+ if (str_tmp == NULL)
+ str_tmp = "";
+
+ SetResult(&result, R_STRING, str_tmp);
+}
+
+static void method_PositionGet(RESULT * result, RESULT * arg1)
+{
+ unsigned long int mtime=0;
+ unsigned long int value=0;
+ double ratio=0;
+ char *str_tmp;
+
+ value = call_PositionGet(R2S(arg1));
+ //printf("\ncalled :call_PositionGet %d",value);
+
+ if (value < 0)
+ value=0;
+
+ str_tmp = hash_get(&DBUS, "mtime", NULL);
+ if (str_tmp != NULL)
+ mtime = atoi(str_tmp);
+ if (mtime > 0)
+ ratio = (double)(((float)value / mtime)*100);
+
+ //printf("\nvalue:%d mtime:%d ratio:%f",value,mtime,ratio);
+ // return actual position as percentage of total length
+ SetResult(&result, R_NUMBER, &ratio);
+}
+
+/* plugin initialization */
+/* MUST NOT be declared 'static'! */
+int plugin_init_mpris_dbus(void)
+{
+ hash_create(&DBUS);
+
+ int ret;
+
+ //printf("Listening for signals\n");
+
+ // initialise the errors
+ dbus_error_init(&err);
+
+ // connect to the bus and check for errors
+ conn = dbus_bus_get(DBUS_BUS_SESSION, &err);
+ /*
+ if (dbus_error_is_set(&err)) {
+ fprintf(stderr, "Connection Error (%s)\n", err.message);
+ dbus_error_free(&err);
+ }
+ */
+ if (NULL == conn)
+ return 0;
+
+ // request our name on the bus and check for errors
+ ret = dbus_bus_request_name(conn, "org.lcd4linux.mpris_dbus", DBUS_NAME_FLAG_REPLACE_EXISTING , &err);
+ /*
+ if (dbus_error_is_set(&err)) {
+ fprintf(stderr, "Name Error (%s)\n", err.message);
+ dbus_error_free(&err);
+ }
+ */
+ if (DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER != ret)
+ return 0;
+
+ // add a rule for which messages we want to see
+ dbus_bus_add_match(conn, "type='signal',interface='org.freedesktop.MediaPlayer'", &err); // see signals from the given interface
+ dbus_connection_flush(conn);
+ /*
+ if (dbus_error_is_set(&err)) {
+ fprintf(stderr, "Match Error (%s)\n", err.message);
+ return 0;
+ }
+ */
+ //printf("Match rule sent\n");
+
+
+ /* register all our cool functions */
+ /* the second parameter is the number of arguments */
+ /* -1 stands for variable argument list */
+ AddFunction("mpris_dbus::signal_TrackChange", 1, signal_TrackChange);
+ AddFunction("mpris_dbus::method_PositionGet", 1, method_PositionGet);
+
+ return 0;
+}
+
+void plugin_exit_mpris_dbus(void)
+{
+ /* free any allocated memory */
+ /* close filedescriptors */
+ hash_destroy(&DBUS);
+
+ if (NULL != msg)
+ dbus_message_unref(msg);
+ dbus_error_free(&err);
+}
AC_MSG_RESULT(
[available plugins:]
[ apm,cpuinfo,diskstats,dvb,exec,file,gps,i2c_sensors,iconv,imon,isdn,kvv,]
- [ loadavg,meminfo,mpd,mysql,netdev,netinfo,pop3,ppp,proc_stat,sample,seti,]
- [ statfs,uname,uptime,wireless,xmms])
+ [ loadavg,meminfo,mpd,mpris_dbus,mysql,netdev,netinfo,pop3,ppp,proc_stat,]
+ [ sample,seti,statfs,uname,uptime,wireless,xmms])
AC_MSG_ERROR([run ./configure --with-plugins=...])
;;
all)
PLUGIN_LOADAVG="yes"
PLUGIN_MEMINFO="yes"
PLUGIN_MPD="yes"
+ PLUGIN_MPRIS_DBUS="yes"
PLUGIN_MYSQL="yes"
PLUGIN_NETDEV="yes"
PLUGIN_NETINFO="yes"
mpd)
PLUGIN_MPD=$val
;;
+ mpris_dbus)
+ PLUGIN_MPRIS_DBUS=$val
+ ;;
mysql)
PLUGIN_MYSQL=$val
;;
fi
fi
+# MPRIS D-Bus
+if test "$PLUGIN_MPRIS_DBUS" = "yes"; then
+ AC_CHECK_HEADERS(dbus/dbus.h, [has_dbus_header="true"], [has_dbus_header="false"])
+ if test "$has_dbus_header" = "true"; then
+ AC_CHECK_LIB(dbus-1, dbus_bus_get, [has_libdbus1_lib="true"], [has_libdbus1_lib="false"])
+ if test "$has_libdbus1_lib" = "true"; then
+ PLUGINS="$PLUGINS plugin_mpris_dbus.o"
+ PLUGINLIBS="$PLUGINLIBS -ldbus-1"
+ AC_DEFINE(PLUGIN_MPRIS_DBUS,1,[mpris_dbus plugin])
+ else
+ AC_MSG_WARN(libdbus-1 lib not found: mpris_dbus plugin disabled)
+ fi
+ else
+ AC_MSG_WARN(dbus/dbus.h header not found: mpris_dbus plugin disabled)
+ fi
+fi
+
+
# MySQL
if test "$PLUGIN_MYSQL" = "yes"; then
AC_CHECK_HEADERS(mysql/mysql.h, [has_mysql_header="true"], [has_mysql_header="false"])
projects / lcd4linux.git / commitdiff