Mercurial > audlegacy-plugins
view src/scrobbler/plugin.c @ 1062:1d65dcdb714c trunk
[svn] - bump version of plugins and version requirements per plugin api v2
author | nenolod |
---|---|
date | Thu, 24 May 2007 02:12:43 -0700 |
parents | 2649ba83333b |
children | d1f8b0594f37 |
line wrap: on
line source
#include "settings.h" #include "config.h" #include <glib.h> #include <audacious/i18n.h> #include <gdk/gdkkeysyms.h> #include <gtk/gtk.h> #include <audacious/plugin.h> #include <audacious/ui_preferences.h> #include <audacious/playlist.h> #include <audacious/configdb.h> #include <audacious/hook.h> #include <audacious/strings.h> #include <audacious/main.h> #include <unistd.h> #include <stdio.h> #include <stdlib.h> #include <string.h> #include <ctype.h> #include <wchar.h> #include <sys/time.h> #include "scrobbler.h" #include "gerpok.h" #include "gtkstuff.h" #include "config.h" #include "fmt.h" #include "configure.h" #define XS_CS xmms_scrobbler.xmms_session #define XS_SLEEP 1 #define HS_SLEEP 10 typedef struct submit_t { int dosubmit, pos_c, len, gerpok; } submit_t; static void init(void); static void cleanup(void); static void *xs_thread(void *); static void *hs_thread(void *); static int sc_going, ge_going; static GtkWidget *cfgdlg; static gboolean submit; static GMutex *m_scrobbler; static GThread *pt_scrobbler; static GThread *pt_handshake; static GMutex *hs_mutex, *xs_mutex; static GCond *hs_cond, *xs_cond; static GeneralPlugin xmms_scrobbler = { NULL, NULL, NULL, init, about_show, NULL, cleanup }; static gboolean ishttp(const char *a) { g_return_val_if_fail(a != NULL, FALSE); return str_has_prefix_nocase(a, "http://") || str_has_prefix_nocase(a, "https://"); } static void hook_playback_begin(gpointer hook_data, gpointer user_data) { PlaylistEntry *entry = (PlaylistEntry *) hook_data; g_return_if_fail(entry != NULL); if (entry->length < 30) { pdebug(" *** not submitting due to entry->length < 30", DEBUG); return; } if (ishttp(entry->filename)) { pdebug(" *** not submitting due to HTTP source", DEBUG); return; } /* wake up the scrobbler thread to submit or queue */ submit = TRUE; g_cond_signal(xs_cond); } static void init(void) { char *username = NULL, *password = NULL; char *ge_username = NULL, *ge_password = NULL; ConfigDb *cfgfile; sc_going = 1; ge_going = 1; GError **moo = NULL; cfgdlg = create_cfgdlg(); prefswin_page_new(cfgdlg, "Scrobbler", DATA_DIR "/images/audioscrobbler.png"); if ((cfgfile = bmp_cfg_db_open()) != NULL) { bmp_cfg_db_get_string(cfgfile, "audioscrobbler", "username", &username); bmp_cfg_db_get_string(cfgfile, "audioscrobbler", "password", &password); bmp_cfg_db_get_string(cfgfile, "audioscrobbler", "ge_username", &ge_username); bmp_cfg_db_get_string(cfgfile, "audioscrobbler", "ge_password", &ge_password); bmp_cfg_db_close(cfgfile); } if ((!username || !password) || (!*username || !*password)) { pdebug("username/password not found - not starting last.fm support", DEBUG); sc_going = 0; } else { sc_init(username, password); g_free(username); g_free(password); } if ((!ge_username || !ge_password) || (!*ge_username || !*ge_password)) { pdebug("username/password not found - not starting Gerpok support", DEBUG); ge_going = 0; } else { gerpok_sc_init(ge_username, ge_password); g_free(ge_username); g_free(ge_password); } m_scrobbler = g_mutex_new(); hs_mutex = g_mutex_new(); xs_mutex = g_mutex_new(); hs_cond = g_cond_new(); xs_cond = g_cond_new(); if ((pt_scrobbler = g_thread_create(xs_thread, NULL, TRUE, moo)) == NULL) { pdebug(fmt_vastr("Error creating scrobbler thread: %s", moo), DEBUG); sc_going = 0; ge_going = 0; return; } if ((pt_handshake = g_thread_create(hs_thread, NULL, TRUE, moo)) == NULL) { pdebug(fmt_vastr("Error creating handshake thread: %s", moo), DEBUG); sc_going = 0; ge_going = 0; return; } hook_associate("playback begin", hook_playback_begin, NULL); pdebug("plugin started", DEBUG); } static void cleanup(void) { g_free (xmms_scrobbler.description); xmms_scrobbler.description = NULL; prefswin_page_destroy(cfgdlg); if (!sc_going && !ge_going) return; pdebug("about to lock mutex", DEBUG); g_mutex_lock(m_scrobbler); pdebug("locked mutex", DEBUG); sc_going = 0; ge_going = 0; g_mutex_unlock(m_scrobbler); pdebug("joining threads", DEBUG); /* wake up waiting threads */ pdebug("send signal to xs and hs", DEBUG); g_cond_signal(xs_cond); g_cond_signal(hs_cond); pdebug("wait xs", DEBUG); g_thread_join(pt_scrobbler); pdebug("wait hs", DEBUG); g_thread_join(pt_handshake); g_cond_free(hs_cond); g_cond_free(xs_cond); g_mutex_free(hs_mutex); g_mutex_free(xs_mutex); g_mutex_free(m_scrobbler); sc_cleaner(); gerpok_sc_cleaner(); hook_dissociate("playback begin", hook_playback_begin); } static void *xs_thread(void *data __attribute__((unused))) { int run = 1; while (run) { TitleInput *tuple; GTimeVal sleeptime; /* Error catching */ if(sc_catch_error()) { errorbox_show(sc_fetch_error()); sc_clear_error(); } if(gerpok_sc_catch_error()) { errorbox_show(gerpok_sc_fetch_error()); gerpok_sc_clear_error(); } if (submit) { Playlist *playlist; pdebug("Submitting song.", DEBUG); playlist = playlist_get_active(); tuple = playlist_get_tuple(playlist, playlist_get_position(playlist)); if (tuple == NULL) continue; if (ishttp(tuple->file_name)) continue; if(tuple->performer != NULL && tuple->track_name != NULL) { pdebug(fmt_vastr( "submitting artist: %s, title: %s", tuple->performer, tuple->track_name), DEBUG); sc_addentry(m_scrobbler, tuple, tuple->length / 1000); gerpok_sc_addentry(m_scrobbler, tuple, tuple->length / 1000); } else pdebug("tuple does not contain an artist or a title, not submitting.", DEBUG); submit = FALSE; } g_get_current_time(&sleeptime); sleeptime.tv_sec += XS_SLEEP; g_mutex_lock(xs_mutex); g_cond_timed_wait(xs_cond, xs_mutex, &sleeptime); g_mutex_unlock(xs_mutex); g_mutex_lock(m_scrobbler); run = (sc_going != 0 || ge_going != 0); g_mutex_unlock(m_scrobbler); } pdebug("scrobbler thread: exiting", DEBUG); g_thread_exit(NULL); return NULL; } static void *hs_thread(void *data __attribute__((unused))) { int run = 1; GTimeVal sleeptime; while(run) { if(sc_idle(m_scrobbler)) { pdebug("Giving up due to fatal error", DEBUG); g_mutex_lock(m_scrobbler); sc_going = 0; g_mutex_unlock(m_scrobbler); } if(gerpok_sc_idle(m_scrobbler)) { pdebug("Giving up due to fatal error", DEBUG); g_mutex_lock(m_scrobbler); ge_going = 0; g_mutex_unlock(m_scrobbler); } g_mutex_lock(m_scrobbler); run = (sc_going != 0 || ge_going != 0); g_mutex_unlock(m_scrobbler); if(run) { g_get_current_time(&sleeptime); sleeptime.tv_sec += HS_SLEEP; g_mutex_lock(hs_mutex); g_cond_timed_wait(hs_cond, hs_mutex, &sleeptime); g_mutex_unlock(hs_mutex); } } pdebug("handshake thread: exiting", DEBUG); g_thread_exit(NULL); return NULL; } GeneralPlugin *get_gplugin_info(void) { xmms_scrobbler.description = g_strdup_printf(_("Scrobbler Plugin")); return &xmms_scrobbler; }