lcd4linux.git - lcd4linux

Age	Commit message (Expand)	Author	Files	Lines
2000-03-10	[lcd4linux @ 2000-03-10 12:02:43 by reinelt]	reinelt	1	-0/+251

/* $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 <stdint.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, "%jd", (intmax_t)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); 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); }