Mercurial > audlegacy
annotate Plugins/General/scrobbler/xmms_scrobbler.c @ 1187:4c58ab006563 trunk
[svn] - remove the preferences UI on unload
author | nenolod |
---|---|
date | Sun, 11 Jun 2006 23:38:50 -0700 |
parents | 1eef4fd1aeb5 |
children | 22707aa5ea6f |
rev | line source |
---|---|
1179
1eef4fd1aeb5
[svn] - make the scrobbler preferences appear in the main window; this does not work yet because I need to debug apparently!
nenolod
parents:
1176
diff
changeset
|
1 #include "config.h" |
1eef4fd1aeb5
[svn] - make the scrobbler preferences appear in the main window; this does not work yet because I need to debug apparently!
nenolod
parents:
1176
diff
changeset
|
2 |
1176 | 3 #include <glib.h> |
4 #include <glib/gi18n.h> | |
5 | |
6 #include <gdk/gdkkeysyms.h> | |
7 #include <gtk/gtk.h> | |
8 | |
688 | 9 #include <audacious/plugin.h> |
1176 | 10 #include <audacious/prefswin.h> |
688 | 11 #include <libaudacious/configdb.h> |
12 #include <libaudacious/beepctrl.h> | |
13 | |
14 #include <unistd.h> | |
15 #include <stdio.h> | |
16 #include <stdlib.h> | |
17 #include <string.h> | |
18 #include <ctype.h> | |
19 #include <wchar.h> | |
20 #include <sys/time.h> | |
21 | |
22 #include "tags/include/tags.h" | |
23 #include "scrobbler.h" | |
24 #include "gtkstuff.h" | |
25 #include "config.h" | |
26 #include "fmt.h" | |
27 #include "tags/include/unicode.h" | |
1179
1eef4fd1aeb5
[svn] - make the scrobbler preferences appear in the main window; this does not work yet because I need to debug apparently!
nenolod
parents:
1176
diff
changeset
|
28 #include "configure.h" |
688 | 29 |
30 #define XS_CS xmms_scrobbler.xmms_session | |
31 | |
32 typedef struct submit_t | |
33 { | |
34 int dosubmit, pos_c, len; | |
35 } submit_t; | |
36 | |
37 static void init(void); | |
38 static void cleanup(void); | |
39 static void *xs_thread(void *); | |
40 static void *hs_thread(void *); | |
41 static int going; | |
1187 | 42 static gint sc_id; |
688 | 43 |
44 static GThread *pt_scrobbler; | |
45 static GMutex *m_scrobbler; | |
46 static GThread *pt_handshake; | |
47 | |
48 static GeneralPlugin xmms_scrobbler = | |
49 { | |
50 NULL, | |
51 NULL, | |
52 -1, | |
53 NULL, | |
54 init, | |
55 about_show, | |
1176 | 56 NULL, |
688 | 57 cleanup |
58 }; | |
59 | |
60 static void init(void) | |
61 { | |
62 char *username = NULL, *password = NULL; | |
63 ConfigDb *cfgfile; | |
64 going = 1; | |
65 GError **moo = NULL; | |
1179
1eef4fd1aeb5
[svn] - make the scrobbler preferences appear in the main window; this does not work yet because I need to debug apparently!
nenolod
parents:
1176
diff
changeset
|
66 GtkWidget *cfgdlg = create_cfgdlg(); |
1176 | 67 |
1187 | 68 sc_id = prefswin_page_new(cfgdlg, "Last.FM", DATA_DIR "/images/audioscrobbler.png"); |
688 | 69 |
70 if ((cfgfile = bmp_cfg_db_open()) != NULL) { | |
71 bmp_cfg_db_get_string(cfgfile, "audioscrobbler", "username", | |
72 &username); | |
73 bmp_cfg_db_get_string(cfgfile, "audioscrobbler", "password", | |
74 &password); | |
75 bmp_cfg_db_close(cfgfile); | |
76 } | |
77 if ((!username || !password) || (!*username || !*password)) { | |
78 pdebug("username/password not found - not starting", | |
79 DEBUG); | |
80 going = 0; | |
81 return; | |
82 } | |
83 sc_init(username, password); | |
84 g_free(username); | |
85 g_free(password); | |
86 m_scrobbler = g_mutex_new(); | |
87 if ((pt_scrobbler = g_thread_create(xs_thread, m_scrobbler, TRUE, moo)) == NULL) { | |
88 pdebug(fmt_vastr("Error creating scrobbler thread: %s", moo), DEBUG); | |
89 going = 0; | |
90 return; | |
91 } | |
92 if ((pt_handshake = g_thread_create(hs_thread, m_scrobbler, TRUE, NULL)) == NULL) { | |
93 pdebug("Error creating handshake thread", DEBUG); | |
94 going = 0; | |
95 return; | |
96 } | |
97 pdebug("plugin started", DEBUG); | |
98 } | |
99 | |
100 static void cleanup(void) | |
101 { | |
813
c8cf439179b8
[svn] - Fix a ton and a half of memory leaks, via the wonderful Leonardo Boshell <leonardop -at- gentoo.org>.
nenolod
parents:
786
diff
changeset
|
102 g_free (xmms_scrobbler.description); |
c8cf439179b8
[svn] - Fix a ton and a half of memory leaks, via the wonderful Leonardo Boshell <leonardop -at- gentoo.org>.
nenolod
parents:
786
diff
changeset
|
103 xmms_scrobbler.description = NULL; |
c8cf439179b8
[svn] - Fix a ton and a half of memory leaks, via the wonderful Leonardo Boshell <leonardop -at- gentoo.org>.
nenolod
parents:
786
diff
changeset
|
104 |
688 | 105 if (!going) |
106 return; | |
107 pdebug("about to lock mutex", DEBUG); | |
108 g_mutex_lock(m_scrobbler); | |
109 pdebug("locked mutex", DEBUG); | |
110 going = 0; | |
111 g_mutex_unlock(m_scrobbler); | |
112 pdebug("joining threads", DEBUG); | |
113 g_thread_join(pt_scrobbler); | |
114 | |
115 g_thread_join(pt_handshake); | |
116 | |
1187 | 117 prefswin_page_destroy(sc_id); |
118 | |
688 | 119 sc_cleaner(); |
120 } | |
121 | |
122 static char ishttp(const char *a) | |
123 { | |
124 char *tmp, *bp; | |
125 int status = 0; | |
126 | |
127 if (!a || !*a) | |
128 return 0; | |
129 | |
130 tmp = strdup(a); | |
131 for (bp = tmp; *bp; bp++) | |
132 *bp = toupper(*bp); | |
133 if (strstr(tmp, "HTTP://")) | |
134 status = -1; | |
135 free(tmp); | |
136 return status; | |
137 } | |
138 | |
139 /* Following code thanks to nosuke | |
140 * | |
141 * It should probably be cleaned up | |
142 */ | |
143 static submit_t get_song_status(void) | |
144 { | |
145 static int pos_c, playlistlen_c, playtime_c, time_c, | |
146 pos_p = 0, playlistlen_p = 0, playtime_p = 0, | |
147 playtime_i = 0, time_i = 0, | |
148 playtime_ofs = 0; | |
149 static char *file_c = NULL, *file_p = NULL; | |
150 | |
151 static enum playstatus { | |
152 ps_stop, ps_play, ps_pause | |
153 } ps_c, ps_p = ps_stop; | |
154 | |
155 static int submitted = 0, changed, seeked, repeat, | |
156 filechanged, rewind, len = 0; | |
157 | |
158 static enum state { | |
159 start, stop, pause, restart, playing, pausing, stopping | |
160 } playstate; | |
161 | |
162 submit_t dosubmit; | |
163 | |
164 struct timeval timetmp; | |
165 | |
166 /* clear dosubmit */ | |
167 dosubmit.dosubmit = dosubmit.pos_c = dosubmit.len = 0; | |
168 | |
169 /* current music number */ | |
170 pos_c = xmms_remote_get_playlist_pos(XS_CS); | |
171 /* current file name */ | |
172 file_c = xmms_remote_get_playlist_file(XS_CS, pos_c); | |
173 /* total number */ | |
174 playlistlen_c = xmms_remote_get_playlist_length(XS_CS); | |
175 /* current playtime */ | |
176 playtime_c = xmms_remote_get_output_time(XS_CS); | |
177 /* total length */ | |
178 len = xmms_remote_get_playlist_time(XS_CS, pos_c); | |
179 | |
180 /* current time (ms) */ | |
181 gettimeofday(&timetmp, NULL); | |
182 time_c = timetmp.tv_sec * 1000 + timetmp.tv_usec / 1000; | |
183 | |
184 /* current status */ | |
185 if( xmms_remote_is_paused(XS_CS) ) { | |
186 ps_c = ps_pause; | |
187 }else if( xmms_remote_is_playing(XS_CS) ) { | |
188 ps_c = ps_play; | |
189 }else{ | |
190 ps_c = ps_stop; | |
191 } | |
192 | |
193 /* repeat setting */ | |
194 repeat = xmms_remote_is_repeat(XS_CS); | |
195 | |
196 /* | |
197 #ifdef MAKE_XMMS | |
198 // advance setting (required xmms-1.2.11 or over) | |
199 advance = xmms_remote_is_advance(XS_CS); | |
200 #else | |
201 advance = 1; | |
202 #endif | |
203 */ | |
204 | |
205 if( ps_p == ps_stop && ps_c == ps_stop ) playstate = stopping; | |
206 else if( ps_p == ps_stop && ps_c == ps_play ) playstate = start; | |
207 /* else if( ps_p == ps_stop && ps_c == ps_pause ) ; */ | |
208 else if( ps_p == ps_play && ps_c == ps_play ) playstate = playing; | |
209 else if( ps_p == ps_play && ps_c == ps_stop ) playstate = stop; | |
210 else if( ps_p == ps_play && ps_c == ps_pause ) playstate = pause; | |
211 else if( ps_p == ps_pause && ps_c == ps_pause ) playstate = pausing; | |
212 else if( ps_p == ps_pause && ps_c == ps_play ) playstate = restart; | |
213 else if( ps_p == ps_pause && ps_c == ps_stop ) playstate = stop; | |
214 else playstate = stopping; | |
215 | |
216 /* filename has changed */ | |
217 if( !(file_p == NULL && file_c == NULL) && | |
218 ((file_p == NULL && file_c != NULL) || | |
219 (file_p != NULL && file_c == NULL) || | |
220 (file_p != NULL && file_c != NULL && strcmp(file_c, file_p))) ){ | |
221 filechanged = 1; | |
222 pdebug("*** filechange ***", SUB_DEBUG); | |
223 }else{ | |
224 filechanged = 0; | |
225 } | |
226 if( file_c == NULL ){ len = 0; } | |
227 | |
228 /* whole rewind has occurred (maybe) */ | |
229 if( len != 0 && len - (playtime_p - playtime_c) < 3000 ){ | |
230 rewind = 1; | |
231 pdebug("*** rewind ***", SUB_DEBUG); | |
232 }else{ | |
233 rewind = 0; | |
234 } | |
235 | |
236 | |
237 changed = 0; | |
238 seeked = 0; | |
239 | |
240 switch( playstate ){ | |
241 case start: | |
242 pdebug("*** START ***", SUB_DEBUG); | |
243 break; | |
244 case stop: | |
245 pdebug("*** STOP ***", SUB_DEBUG); | |
246 len = 0; | |
247 break; | |
248 case pause: | |
249 pdebug("*** PAUSE ***", SUB_DEBUG); | |
250 playtime_ofs += playtime_c - playtime_i; /* save playtime */ | |
251 break; | |
252 case restart: | |
253 pdebug("*** RESTART ***", SUB_DEBUG); | |
254 playtime_i = playtime_c; /* restore playtime */ | |
255 break; | |
256 case playing: | |
257 if( (playtime_c < playtime_p) || /* back */ | |
258 ( (playtime_c - playtime_i) - (time_c - time_i) > 3000 ) | |
259 /* forward */ | |
260 ) { | |
261 seeked = 1; | |
262 } | |
263 | |
264 if( filechanged || /* filename has changed */ | |
265 ( !filechanged && /* filename has not changed... */ | |
266 /* (( rewind && (repeat && (!advance || | |
267 (pos_c == 0 && playlistlen_c == 1 )))) || */ | |
268 /* looping with only one file */ | |
269 (( pos_c == 0 && playlistlen_c == 1 && repeat | |
270 && rewind ) || | |
271 /* looping? */ | |
272 ( pos_p == pos_c && rewind ) || | |
273 | |
274 ( pos_p != pos_c && seeked ) || | |
275 /* skip from current music to next music, | |
276 which has the same filename as previous one */ | |
277 ( pos_p < pos_c && playtime_c < playtime_p ) || | |
278 /* current song has removed from playlist | |
279 but the next (following) song has the same | |
280 filename */ | |
281 ( playlistlen_p > playlistlen_c | |
282 && playtime_c < playtime_p )))){ | |
283 pdebug("*** CHANGE ***",SUB_DEBUG); | |
284 pdebug(fmt_vastr(" filechanged = %d",filechanged),SUB_DEBUG); | |
285 pdebug(fmt_vastr(" pos_c = %d",pos_c),SUB_DEBUG); | |
286 pdebug(fmt_vastr(" pos_p = %d",pos_p),SUB_DEBUG); | |
287 pdebug(fmt_vastr(" rewind = %d", rewind),SUB_DEBUG); | |
288 pdebug(fmt_vastr(" seeked = %d", seeked),SUB_DEBUG); | |
289 pdebug(fmt_vastr(" playtime_c = %d", playtime_c),SUB_DEBUG); | |
290 pdebug(fmt_vastr(" playtime_p = %d", playtime_p),SUB_DEBUG); | |
291 pdebug(fmt_vastr(" playlistlen_c = %d", playlistlen_p), | |
292 SUB_DEBUG); | |
293 pdebug(fmt_vastr(" playlistlen_p = %d", playlistlen_p), | |
294 SUB_DEBUG); | |
295 changed = 1; | |
296 seeked = 0; | |
786 | 297 |
298 if (file_p != NULL) | |
299 { | |
300 g_free(file_p); | |
301 file_p = NULL; | |
302 } | |
688 | 303 }else if( seeked ) { |
304 seeked = 1; | |
305 pdebug("*** SEEK ***", SUB_DEBUG); | |
306 } | |
307 | |
308 break; | |
309 case pausing: | |
310 if(playtime_c != playtime_p){ | |
311 pdebug("*** SEEK ***", SUB_DEBUG); | |
312 seeked = 1; | |
313 } | |
314 break; | |
315 case stopping: | |
316 len = 0; | |
317 break; | |
318 default: | |
319 pdebug("*** unknown state tranfer!!! ***", SUB_DEBUG); | |
320 break; | |
321 } | |
322 | |
323 | |
324 if( playstate == start || changed || (seeked && !submitted) ){ | |
325 /* reset counter */ | |
326 pdebug(" <<< reset counter >>>", SUB_DEBUG); | |
327 | |
328 submitted = 0; | |
329 playtime_ofs = 0; | |
330 playtime_i = playtime_c; | |
331 time_i = time_c; | |
332 | |
333 }else{ | |
334 /* check playtime for submitting */ | |
335 if( !submitted ){ | |
336 if( len > 30 * 1000 && | |
337 /* len < 30 *60 * 1000 && // crazy rule!!! */ | |
338 ( | |
339 (playtime_ofs + playtime_c - playtime_i > len / 2) || | |
340 (playtime_ofs + playtime_c - playtime_i > 240 * 1000) | |
341 /* (playtime_c - playtime_i > 10 * 1000)// for debug */ | |
342 )){ | |
343 pdebug("*** submitting requirements are satisfied.", | |
344 SUB_DEBUG); | |
345 pdebug(fmt_vastr(" len = %d, playtime = %d", | |
346 len / 1000, (playtime_c - playtime_i)/1000 ), | |
347 SUB_DEBUG); | |
348 submitted = 1; | |
349 dosubmit.dosubmit = 1; | |
350 dosubmit.pos_c = pos_c; | |
351 dosubmit.len = len; | |
352 } | |
353 } | |
354 } | |
355 | |
786 | 356 g_free(file_p); |
357 | |
688 | 358 /* keep current value for next iteration */ |
359 ps_p = ps_c; | |
360 file_p = file_c; | |
361 playtime_p = playtime_c; | |
362 pos_p = pos_c; | |
363 playlistlen_p = playlistlen_c; | |
364 | |
365 return dosubmit; | |
366 } | |
367 | |
700
99382cddf771
[svn] Fixes for all warnings (except 3 spurious GCC 4.0 ones, upgrade to 4.1 if you see them) and a performance increase. By external contributor Diego "FlameEyes" Petteno (Gentoo).
chainsaw
parents:
697
diff
changeset
|
368 static void *xs_thread(void *data __attribute__((unused))) |
688 | 369 { |
370 int run = 1, i; | |
371 char *charpos, *dirname; | |
372 gboolean direxists; | |
373 submit_t dosubmit; | |
374 | |
375 while (run) { | |
376 /* Error catching */ | |
377 if(sc_catch_error()) | |
378 { | |
379 errorbox_show(sc_fetch_error()); | |
697 | 380 sc_clear_error(); |
688 | 381 } |
382 | |
383 /* Check for ability to submit */ | |
384 dosubmit = get_song_status(); | |
385 | |
386 if(dosubmit.dosubmit) { | |
387 char *fname, /**title, *artist,*/ *tmp = NULL; /**sep*/ | |
388 int track = 0; | |
389 metatag_t *meta; | |
390 | |
391 pdebug("Submitting song.", DEBUG); | |
392 | |
393 meta = metatag_new(); | |
394 | |
395 fname = xmms_remote_get_playlist_file(0,dosubmit.pos_c); | |
396 if (ishttp(fname)) { | |
397 g_free(fname); | |
398 continue; | |
399 } | |
400 charpos = strrchr(fname, '.'); | |
401 if(charpos != NULL && | |
402 !fmt_strncasecmp(charpos + 1, "cda", 3)) | |
403 { | |
404 ConfigDb *cfgfile; | |
405 | |
406 if ((cfgfile = bmp_cfg_db_open()) | |
407 != NULL) | |
408 { | |
409 char *direntry = calloc(32, 1); | |
410 | |
411 dirname = fname; | |
412 tmp = strrchr(fname, '.'); | |
413 *tmp = '\0'; | |
414 track = (char)atoi(tmp - 2); | |
415 pdebug(fmt_vastr("Track: %d", track), | |
416 DEBUG); | |
417 tmp = strrchr(dirname, '/'); | |
418 *(tmp + 1) = '\0'; | |
419 direxists = bmp_cfg_db_get_string( | |
420 cfgfile, "CDDA", | |
421 "directory", &fname); | |
422 for(i = 0; direxists == TRUE | |
423 && strcmp(dirname, fname) == 0;) | |
424 { | |
425 i++; | |
426 snprintf(direntry, 31, | |
427 "directory%d", i); | |
428 g_free(fname); | |
429 direxists = | |
430 bmp_cfg_db_get_string( | |
431 cfgfile, "CDDA", | |
432 direntry, &fname); | |
433 } | |
434 if(i > 0) | |
435 { | |
436 snprintf(direntry, 31, | |
437 "device%d", i); | |
438 } | |
439 else | |
440 { | |
441 snprintf(direntry, 31, | |
442 "device"); | |
443 } | |
444 g_free(fname); | |
445 bmp_cfg_db_get_string(cfgfile, "CDDA", | |
446 direntry, &fname); | |
447 bmp_cfg_db_close(cfgfile); | |
448 free(direntry); | |
449 pdebug(fmt_vastr("CD Device: %s", | |
450 fname), DEBUG); | |
451 } | |
452 } | |
453 | |
454 pdebug(fmt_vastr("get_tag_data, %s", fname), DEBUG); | |
455 get_tag_data(meta, fname, track); | |
456 | |
457 if(meta->artist != NULL && meta->title != NULL) | |
458 { | |
459 pdebug(fmt_vastr( | |
460 "submitting artist: %s, title: %s", | |
461 meta->artist, meta->title), DEBUG); | |
462 sc_addentry(m_scrobbler, meta, | |
463 dosubmit.len/1000); | |
464 } | |
465 else | |
466 pdebug("couldn't determine artist - " | |
467 "title, not submitting", | |
468 DEBUG); | |
469 /* g_free(tmp); */ | |
470 g_free(fname); | |
471 metatag_delete(meta); | |
472 } | |
473 g_mutex_lock(m_scrobbler); | |
474 run = going; | |
475 g_mutex_unlock(m_scrobbler); | |
476 usleep(100000); | |
477 } | |
478 pdebug("scrobbler thread: exiting", DEBUG); | |
479 g_thread_exit(NULL); | |
480 | |
481 return NULL; | |
482 } | |
483 | |
700
99382cddf771
[svn] Fixes for all warnings (except 3 spurious GCC 4.0 ones, upgrade to 4.1 if you see them) and a performance increase. By external contributor Diego "FlameEyes" Petteno (Gentoo).
chainsaw
parents:
697
diff
changeset
|
484 static void *hs_thread(void *data __attribute__((unused))) |
688 | 485 { |
486 int run = 1; | |
487 | |
488 while(run) | |
489 { | |
490 if(sc_idle(m_scrobbler)) | |
491 { | |
492 pdebug("Giving up due to fatal error", DEBUG); | |
493 g_mutex_lock(m_scrobbler); | |
494 going = 0; | |
495 g_mutex_lock(m_scrobbler); | |
496 } | |
497 g_mutex_lock(m_scrobbler); | |
498 run = going; | |
499 g_mutex_unlock(m_scrobbler); | |
500 sleep(1); | |
501 } | |
502 pdebug("handshake thread: exiting", DEBUG); | |
503 g_thread_exit(NULL); | |
504 | |
505 return NULL; | |
506 } | |
507 | |
508 GeneralPlugin *get_gplugin_info(void) | |
509 { | |
510 xmms_scrobbler.description = g_strdup_printf(_("Scrobbler Plugin")); | |
511 return &xmms_scrobbler; | |
512 } |