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