diff options
| -rw-r--r-- | Makefile.am | 1 | ||||
| -rw-r--r-- | plugin.c | 9 | ||||
| -rw-r--r-- | plugin_mpris_dbus.c | 333 | ||||
| -rw-r--r-- | plugins.m4 | 26 |
4 files changed, 367 insertions, 2 deletions
diff --git a/Makefile.am b/Makefile.am index 8e1a997..ea46d97 100644 --- a/Makefile.am +++ b/Makefile.am @@ -135,6 +135,7 @@ plugin_kvv.c \ plugin_loadavg.c \ plugin_meminfo.c \ plugin_mpd.c \ +plugin_mpris_dbus.c \ plugin_mysql.c \ plugin_netdev.c \ plugin_netinfo.c \ @@ -107,6 +107,9 @@ char *Plugins[] = { #ifdef PLUGIN_MPD "mpd", #endif +#ifdef PLUGIN_MPRIS_DBUS + "mpris_dbus", +#endif #ifdef PLUGIN_MYSQL "mysql", #endif @@ -319,6 +322,9 @@ int plugin_init(void) #ifdef PLUGIN_MPD plugin_init_mpd(); #endif +#ifdef PLUGIN_MPRIS_DBUS + plugin_init_mpris_dbus(); +#endif #ifdef PLUGIN_MYSQL plugin_init_mysql(); #endif @@ -425,6 +431,9 @@ void plugin_exit(void) #ifdef PLUGIN_MPD plugin_exit_mpd(); #endif +#ifdef PLUGIN_MPRIS_DBUS + plugin_exit_mpris_dbus(); +#endif #ifdef PLUGIN_MYSQL plugin_exit_mysql(); #endif diff --git a/plugin_mpris_dbus.c b/plugin_mpris_dbus.c new file mode 100644 index 0000000..1404bae --- /dev/null +++ b/plugin_mpris_dbus.c @@ -0,0 +1,333 @@ +/* $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); +} @@ -54,8 +54,8 @@ for plugin in $plugins; do 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) @@ -78,6 +78,7 @@ for plugin in $plugins; do PLUGIN_LOADAVG="yes" PLUGIN_MEMINFO="yes" PLUGIN_MPD="yes" + PLUGIN_MPRIS_DBUS="yes" PLUGIN_MYSQL="yes" PLUGIN_NETDEV="yes" PLUGIN_NETINFO="yes" @@ -151,6 +152,9 @@ for plugin in $plugins; do mpd) PLUGIN_MPD=$val ;; + mpris_dbus) + PLUGIN_MPRIS_DBUS=$val + ;; mysql) PLUGIN_MYSQL=$val ;; @@ -365,6 +369,24 @@ if test "$PLUGIN_MPD" = "yes"; then 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"]) |