Mercurial > audlegacy
annotate Plugins/General/scrobbler/xmms_scrobbler.c @ 1625:79891e2fd8a5 trunk
[svn] - use $(SHARED_SUFFIX)
- use $(PICFLAGS)
- use $(PICLDFLAGS)
author | nenolod |
---|---|
date | Wed, 06 Sep 2006 13:21:40 -0700 |
parents | 651327e12a3a |
children | 837983bac90f |
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> |
1236
fc478bfe6fe6
[svn] - disconnect the scrobbler client from metatag logically
nenolod
parents:
1189
diff
changeset
|
11 #include <audacious/playlist.h> |
688 | 12 #include <libaudacious/configdb.h> |
13 #include <libaudacious/beepctrl.h> | |
14 | |
15 #include <unistd.h> | |
16 #include <stdio.h> | |
17 #include <stdlib.h> | |
18 #include <string.h> | |
19 #include <ctype.h> | |
20 #include <wchar.h> | |
21 #include <sys/time.h> | |
22 | |
23 #include "scrobbler.h" | |
24 #include "gtkstuff.h" | |
25 #include "config.h" | |
26 #include "fmt.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
|
27 #include "configure.h" |
688 | 28 |
29 #define XS_CS xmms_scrobbler.xmms_session | |
30 | |
31 typedef struct submit_t | |
32 { | |
33 int dosubmit, pos_c, len; | |
34 } submit_t; | |
35 | |
36 static void init(void); | |
37 static void cleanup(void); | |
38 static void *xs_thread(void *); | |
39 static void *hs_thread(void *); | |
40 static int going; | |
1189 | 41 static GtkWidget *cfgdlg; |
688 | 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; | |
1189 | 65 cfgdlg = create_cfgdlg(); |
1176 | 66 |
1189 | 67 prefswin_page_new(cfgdlg, "Last.FM", 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 | |
1189 | 116 prefswin_page_destroy(cfgdlg); |
1187 | 117 |
688 | 118 sc_cleaner(); |
119 } | |
120 | |
121 static char ishttp(const char *a) | |
122 { | |
123 char *tmp, *bp; | |
124 int status = 0; | |
125 | |
126 if (!a || !*a) | |
127 return 0; | |
128 | |
129 tmp = strdup(a); | |
130 for (bp = tmp; *bp; bp++) | |
131 *bp = toupper(*bp); | |
132 if (strstr(tmp, "HTTP://")) | |
133 status = -1; | |
134 free(tmp); | |
135 return status; | |
136 } | |
137 | |
138 /* Following code thanks to nosuke | |
139 * | |
140 * It should probably be cleaned up | |
141 */ | |
142 static submit_t get_song_status(void) | |
143 { | |
144 static int pos_c, playlistlen_c, playtime_c, time_c, | |
145 pos_p = 0, playlistlen_p = 0, playtime_p = 0, | |
146 playtime_i = 0, time_i = 0, | |
147 playtime_ofs = 0; | |
148 static char *file_c = NULL, *file_p = NULL; | |
149 | |
150 static enum playstatus { | |
151 ps_stop, ps_play, ps_pause | |
152 } ps_c, ps_p = ps_stop; | |
153 | |
154 static int submitted = 0, changed, seeked, repeat, | |
155 filechanged, rewind, len = 0; | |
156 | |
157 static enum state { | |
158 start, stop, pause, restart, playing, pausing, stopping | |
159 } playstate; | |
160 | |
161 submit_t dosubmit; | |
162 | |
163 struct timeval timetmp; | |
164 | |
165 /* clear dosubmit */ | |
166 dosubmit.dosubmit = dosubmit.pos_c = dosubmit.len = 0; | |
167 | |
168 /* current music number */ | |
169 pos_c = xmms_remote_get_playlist_pos(XS_CS); | |
170 /* current file name */ | |
171 file_c = xmms_remote_get_playlist_file(XS_CS, pos_c); | |
172 /* total number */ | |
173 playlistlen_c = xmms_remote_get_playlist_length(XS_CS); | |
174 /* current playtime */ | |
175 playtime_c = xmms_remote_get_output_time(XS_CS); | |
176 /* total length */ | |
177 len = xmms_remote_get_playlist_time(XS_CS, pos_c); | |
178 | |
179 /* current time (ms) */ | |
180 gettimeofday(&timetmp, NULL); | |
181 time_c = timetmp.tv_sec * 1000 + timetmp.tv_usec / 1000; | |
182 | |
183 /* current status */ | |
184 if( xmms_remote_is_paused(XS_CS) ) { | |
185 ps_c = ps_pause; | |
186 }else if( xmms_remote_is_playing(XS_CS) ) { | |
187 ps_c = ps_play; | |
188 }else{ | |
189 ps_c = ps_stop; | |
190 } | |
191 | |
192 /* repeat setting */ | |
193 repeat = xmms_remote_is_repeat(XS_CS); | |
194 | |
195 /* | |
196 #ifdef MAKE_XMMS | |
197 // advance setting (required xmms-1.2.11 or over) | |
198 advance = xmms_remote_is_advance(XS_CS); | |
199 #else | |
200 advance = 1; | |
201 #endif | |
202 */ | |
203 | |
204 if( ps_p == ps_stop && ps_c == ps_stop ) playstate = stopping; | |
205 else if( ps_p == ps_stop && ps_c == ps_play ) playstate = start; | |
206 /* else if( ps_p == ps_stop && ps_c == ps_pause ) ; */ | |
207 else if( ps_p == ps_play && ps_c == ps_play ) playstate = playing; | |
208 else if( ps_p == ps_play && ps_c == ps_stop ) playstate = stop; | |
209 else if( ps_p == ps_play && ps_c == ps_pause ) playstate = pause; | |
210 else if( ps_p == ps_pause && ps_c == ps_pause ) playstate = pausing; | |
211 else if( ps_p == ps_pause && ps_c == ps_play ) playstate = restart; | |
212 else if( ps_p == ps_pause && ps_c == ps_stop ) playstate = stop; | |
213 else playstate = stopping; | |
214 | |
215 /* filename has changed */ | |
216 if( !(file_p == NULL && file_c == NULL) && | |
217 ((file_p == NULL && file_c != NULL) || | |
218 (file_p != NULL && file_c == NULL) || | |
219 (file_p != NULL && file_c != NULL && strcmp(file_c, file_p))) ){ | |
220 filechanged = 1; | |
221 pdebug("*** filechange ***", SUB_DEBUG); | |
222 }else{ | |
223 filechanged = 0; | |
224 } | |
225 if( file_c == NULL ){ len = 0; } | |
226 | |
227 /* whole rewind has occurred (maybe) */ | |
228 if( len != 0 && len - (playtime_p - playtime_c) < 3000 ){ | |
229 rewind = 1; | |
230 pdebug("*** rewind ***", SUB_DEBUG); | |
231 }else{ | |
232 rewind = 0; | |
233 } | |
234 | |
235 | |
236 changed = 0; | |
237 seeked = 0; | |
238 | |
239 switch( playstate ){ | |
240 case start: | |
241 pdebug("*** START ***", SUB_DEBUG); | |
242 break; | |
243 case stop: | |
244 pdebug("*** STOP ***", SUB_DEBUG); | |
245 len = 0; | |
246 break; | |
247 case pause: | |
248 pdebug("*** PAUSE ***", SUB_DEBUG); | |
249 playtime_ofs += playtime_c - playtime_i; /* save playtime */ | |
250 break; | |
251 case restart: | |
252 pdebug("*** RESTART ***", SUB_DEBUG); | |
253 playtime_i = playtime_c; /* restore playtime */ | |
254 break; | |
255 case playing: | |
256 if( (playtime_c < playtime_p) || /* back */ | |
257 ( (playtime_c - playtime_i) - (time_c - time_i) > 3000 ) | |
258 /* forward */ | |
259 ) { | |
260 seeked = 1; | |
261 } | |
262 | |
263 if( filechanged || /* filename has changed */ | |
264 ( !filechanged && /* filename has not changed... */ | |
265 /* (( rewind && (repeat && (!advance || | |
266 (pos_c == 0 && playlistlen_c == 1 )))) || */ | |
267 /* looping with only one file */ | |
268 (( pos_c == 0 && playlistlen_c == 1 && repeat | |
269 && rewind ) || | |
270 /* looping? */ | |
271 ( pos_p == pos_c && rewind ) || | |
272 | |
273 ( pos_p != pos_c && seeked ) || | |
274 /* skip from current music to next music, | |
275 which has the same filename as previous one */ | |
276 ( pos_p < pos_c && playtime_c < playtime_p ) || | |
277 /* current song has removed from playlist | |
278 but the next (following) song has the same | |
279 filename */ | |
280 ( playlistlen_p > playlistlen_c | |
281 && playtime_c < playtime_p )))){ | |
282 pdebug("*** CHANGE ***",SUB_DEBUG); | |
283 pdebug(fmt_vastr(" filechanged = %d",filechanged),SUB_DEBUG); | |
284 pdebug(fmt_vastr(" pos_c = %d",pos_c),SUB_DEBUG); | |
285 pdebug(fmt_vastr(" pos_p = %d",pos_p),SUB_DEBUG); | |
286 pdebug(fmt_vastr(" rewind = %d", rewind),SUB_DEBUG); | |
287 pdebug(fmt_vastr(" seeked = %d", seeked),SUB_DEBUG); | |
288 pdebug(fmt_vastr(" playtime_c = %d", playtime_c),SUB_DEBUG); | |
289 pdebug(fmt_vastr(" playtime_p = %d", playtime_p),SUB_DEBUG); | |
290 pdebug(fmt_vastr(" playlistlen_c = %d", playlistlen_p), | |
291 SUB_DEBUG); | |
292 pdebug(fmt_vastr(" playlistlen_p = %d", playlistlen_p), | |
293 SUB_DEBUG); | |
294 changed = 1; | |
295 seeked = 0; | |
786 | 296 |
297 if (file_p != NULL) | |
298 { | |
299 g_free(file_p); | |
300 file_p = NULL; | |
301 } | |
688 | 302 }else if( seeked ) { |
303 seeked = 1; | |
304 pdebug("*** SEEK ***", SUB_DEBUG); | |
305 } | |
306 | |
307 break; | |
308 case pausing: | |
309 if(playtime_c != playtime_p){ | |
310 pdebug("*** SEEK ***", SUB_DEBUG); | |
311 seeked = 1; | |
312 } | |
313 break; | |
314 case stopping: | |
315 len = 0; | |
316 break; | |
317 default: | |
318 pdebug("*** unknown state tranfer!!! ***", SUB_DEBUG); | |
319 break; | |
320 } | |
321 | |
322 | |
323 if( playstate == start || changed || (seeked && !submitted) ){ | |
324 /* reset counter */ | |
325 pdebug(" <<< reset counter >>>", SUB_DEBUG); | |
326 | |
327 submitted = 0; | |
328 playtime_ofs = 0; | |
329 playtime_i = playtime_c; | |
330 time_i = time_c; | |
331 | |
332 }else{ | |
333 /* check playtime for submitting */ | |
334 if( !submitted ){ | |
335 if( len > 30 * 1000 && | |
336 /* len < 30 *60 * 1000 && // crazy rule!!! */ | |
337 ( | |
338 (playtime_ofs + playtime_c - playtime_i > len / 2) || | |
339 (playtime_ofs + playtime_c - playtime_i > 240 * 1000) | |
340 /* (playtime_c - playtime_i > 10 * 1000)// for debug */ | |
341 )){ | |
342 pdebug("*** submitting requirements are satisfied.", | |
343 SUB_DEBUG); | |
344 pdebug(fmt_vastr(" len = %d, playtime = %d", | |
345 len / 1000, (playtime_c - playtime_i)/1000 ), | |
346 SUB_DEBUG); | |
347 submitted = 1; | |
348 dosubmit.dosubmit = 1; | |
349 dosubmit.pos_c = pos_c; | |
350 dosubmit.len = len; | |
351 } | |
352 } | |
353 } | |
354 | |
786 | 355 g_free(file_p); |
356 | |
688 | 357 /* keep current value for next iteration */ |
358 ps_p = ps_c; | |
359 file_p = file_c; | |
360 playtime_p = playtime_c; | |
361 pos_p = pos_c; | |
362 playlistlen_p = playlistlen_c; | |
363 | |
364 return dosubmit; | |
365 } | |
366 | |
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
|
367 static void *xs_thread(void *data __attribute__((unused))) |
688 | 368 { |
1236
fc478bfe6fe6
[svn] - disconnect the scrobbler client from metatag logically
nenolod
parents:
1189
diff
changeset
|
369 int run = 1; |
688 | 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) { | |
1236
fc478bfe6fe6
[svn] - disconnect the scrobbler client from metatag logically
nenolod
parents:
1189
diff
changeset
|
384 TitleInput *tuple; |
688 | 385 |
386 pdebug("Submitting song.", DEBUG); | |
1236
fc478bfe6fe6
[svn] - disconnect the scrobbler client from metatag logically
nenolod
parents:
1189
diff
changeset
|
387 |
fc478bfe6fe6
[svn] - disconnect the scrobbler client from metatag logically
nenolod
parents:
1189
diff
changeset
|
388 tuple = playlist_get_tuple(dosubmit.pos_c); |
fc478bfe6fe6
[svn] - disconnect the scrobbler client from metatag logically
nenolod
parents:
1189
diff
changeset
|
389 |
fc478bfe6fe6
[svn] - disconnect the scrobbler client from metatag logically
nenolod
parents:
1189
diff
changeset
|
390 if (ishttp(tuple->file_name)) |
fc478bfe6fe6
[svn] - disconnect the scrobbler client from metatag logically
nenolod
parents:
1189
diff
changeset
|
391 continue; |
fc478bfe6fe6
[svn] - disconnect the scrobbler client from metatag logically
nenolod
parents:
1189
diff
changeset
|
392 |
fc478bfe6fe6
[svn] - disconnect the scrobbler client from metatag logically
nenolod
parents:
1189
diff
changeset
|
393 if(tuple->performer != NULL && tuple->track_name != NULL) |
fc478bfe6fe6
[svn] - disconnect the scrobbler client from metatag logically
nenolod
parents:
1189
diff
changeset
|
394 { |
fc478bfe6fe6
[svn] - disconnect the scrobbler client from metatag logically
nenolod
parents:
1189
diff
changeset
|
395 pdebug(fmt_vastr( |
fc478bfe6fe6
[svn] - disconnect the scrobbler client from metatag logically
nenolod
parents:
1189
diff
changeset
|
396 "submitting artist: %s, title: %s", |
fc478bfe6fe6
[svn] - disconnect the scrobbler client from metatag logically
nenolod
parents:
1189
diff
changeset
|
397 tuple->performer, tuple->track_name), DEBUG); |
fc478bfe6fe6
[svn] - disconnect the scrobbler client from metatag logically
nenolod
parents:
1189
diff
changeset
|
398 sc_addentry(m_scrobbler, tuple, |
fc478bfe6fe6
[svn] - disconnect the scrobbler client from metatag logically
nenolod
parents:
1189
diff
changeset
|
399 dosubmit.len/1000); |
fc478bfe6fe6
[svn] - disconnect the scrobbler client from metatag logically
nenolod
parents:
1189
diff
changeset
|
400 } |
fc478bfe6fe6
[svn] - disconnect the scrobbler client from metatag logically
nenolod
parents:
1189
diff
changeset
|
401 else |
fc478bfe6fe6
[svn] - disconnect the scrobbler client from metatag logically
nenolod
parents:
1189
diff
changeset
|
402 pdebug("tuple does not contain an artist or a title, not submitting.", DEBUG); |
688 | 403 } |
404 g_mutex_lock(m_scrobbler); | |
405 run = going; | |
406 g_mutex_unlock(m_scrobbler); | |
1362
651327e12a3a
[svn] - use of sleep() or usleep() in multi-thread program may cause 100% CPU usage because of signal distribution.
yaz
parents:
1245
diff
changeset
|
407 g_usleep(100000); |
688 | 408 } |
409 pdebug("scrobbler thread: exiting", DEBUG); | |
410 g_thread_exit(NULL); | |
411 | |
412 return NULL; | |
413 } | |
414 | |
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
|
415 static void *hs_thread(void *data __attribute__((unused))) |
688 | 416 { |
417 int run = 1; | |
418 | |
419 while(run) | |
420 { | |
421 if(sc_idle(m_scrobbler)) | |
422 { | |
423 pdebug("Giving up due to fatal error", DEBUG); | |
424 g_mutex_lock(m_scrobbler); | |
425 going = 0; | |
426 g_mutex_lock(m_scrobbler); | |
427 } | |
428 g_mutex_lock(m_scrobbler); | |
429 run = going; | |
430 g_mutex_unlock(m_scrobbler); | |
1362
651327e12a3a
[svn] - use of sleep() or usleep() in multi-thread program may cause 100% CPU usage because of signal distribution.
yaz
parents:
1245
diff
changeset
|
431 g_usleep(1000000); |
688 | 432 } |
433 pdebug("handshake thread: exiting", DEBUG); | |
434 g_thread_exit(NULL); | |
435 | |
436 return NULL; | |
437 } | |
438 | |
439 GeneralPlugin *get_gplugin_info(void) | |
440 { | |
441 xmms_scrobbler.description = g_strdup_printf(_("Scrobbler Plugin")); | |
442 return &xmms_scrobbler; | |
443 } |