2 * This file is part of DisOrder.
3 * Copyright (C) 2006, 2007 Richard Kettlewell
5 * This program is free software; you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License as published by
7 * the Free Software Foundation; either version 2 of the License, or
8 * (at your option) any later version.
10 * This program is distributed in the hope that it will be useful, but
11 * WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 * General Public License for more details.
15 * You should have received a copy of the GNU General Public License
16 * along with this program; if not, write to the Free Software
17 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
21 #include "disobedience.h"
26 /* Apologies for the numerous de-consting casts, but GLib et al do not seem to
27 * have heard of const. */
29 #include "style.h" /* generated style */
31 /* Functions --------------------------------------------------------------- */
33 static void log_connected(void *v
);
34 static void log_completed(void *v
, const char *track
);
35 static void log_failed(void *v
, const char *track
, const char *status
);
36 static void log_moved(void *v
, const char *user
);
37 static void log_playing(void *v
, const char *track
, const char *user
);
38 static void log_queue(void *v
, struct queue_entry
*q
);
39 static void log_recent_added(void *v
, struct queue_entry
*q
);
40 static void log_recent_removed(void *v
, const char *id
);
41 static void log_removed(void *v
, const char *id
, const char *user
);
42 static void log_scratched(void *v
, const char *track
, const char *user
);
43 static void log_state(void *v
, unsigned long state
);
44 static void log_volume(void *v
, int l
, int r
);
46 /* Variables --------------------------------------------------------------- */
48 GMainLoop
*mainloop
; /* event loop */
49 GtkWidget
*toplevel
; /* top level window */
50 GtkWidget
*report_label
; /* label for progress indicator */
51 GtkWidget
*tabs
; /* main tabs */
53 disorder_eclient
*client
; /* main client */
55 unsigned long last_state
; /* last reported state */
56 int playing
; /* true if playing some track */
57 int volume_l
, volume_r
; /* volume */
58 double goesupto
= 10; /* volume upper bound */
59 int choosealpha
; /* break up choose by letter */
61 static const disorder_eclient_log_callbacks gdisorder_log_callbacks
= {
76 /* Window creation --------------------------------------------------------- */
78 /* Note that all the client operations kicked off from here will only complete
79 * after we've entered the event loop. */
81 static gboolean
delete_event(GtkWidget
attribute((unused
)) *widget
,
82 GdkEvent
attribute((unused
)) *event
,
83 gpointer
attribute((unused
)) data
) {
85 exit(0); /* die immediately */
88 /* Called when the current tab is switched. */
89 static void tab_switched(GtkNotebook
attribute((unused
)) *notebook
,
90 GtkNotebookPage
attribute((unused
)) *page
,
92 gpointer
attribute((unused
)) user_data
) {
93 menu_update(page_num
);
96 static GtkWidget
*report_box(void) {
97 GtkWidget
*vbox
= gtk_vbox_new(FALSE
, 0);
99 report_label
= gtk_label_new("");
100 gtk_label_set_ellipsize(GTK_LABEL(report_label
), PANGO_ELLIPSIZE_END
);
101 gtk_misc_set_alignment(GTK_MISC(report_label
), 0, 0);
102 gtk_container_add(GTK_CONTAINER(vbox
), gtk_hseparator_new());
103 gtk_container_add(GTK_CONTAINER(vbox
), report_label
);
107 static GtkWidget
*notebook(void) {
108 tabs
= gtk_notebook_new();
109 g_signal_connect(tabs
, "switch-page", G_CALLBACK(tab_switched
), 0);
110 gtk_notebook_append_page(GTK_NOTEBOOK(tabs
), queue_widget(),
111 gtk_label_new("Queue"));
112 gtk_notebook_append_page(GTK_NOTEBOOK(tabs
), recent_widget(),
113 gtk_label_new("Recent"));
114 gtk_notebook_append_page(GTK_NOTEBOOK(tabs
), choose_widget(),
115 gtk_label_new("Choose"));
119 static void make_toplevel_window(void) {
120 GtkWidget
*const vbox
= gtk_vbox_new(FALSE
, 1);
121 GtkWidget
*const rb
= report_box();
124 toplevel
= gtk_window_new(GTK_WINDOW_TOPLEVEL
);
125 /* default size is too small */
126 gtk_window_set_default_size(GTK_WINDOW(toplevel
), 640, 480);
127 /* terminate on close */
128 g_signal_connect(G_OBJECT(toplevel
), "delete_event",
129 G_CALLBACK(delete_event
), NULL
);
130 /* lay out the window */
131 gtk_window_set_title(GTK_WINDOW(toplevel
), "Disobedience");
132 gtk_container_add(GTK_CONTAINER(toplevel
), vbox
);
133 /* lay out the vbox */
134 gtk_box_pack_start(GTK_BOX(vbox
),
139 gtk_box_pack_start(GTK_BOX(vbox
),
144 gtk_container_add(GTK_CONTAINER(vbox
), notebook());
145 gtk_box_pack_end(GTK_BOX(vbox
),
150 gtk_widget_set_name(toplevel
, "disobedience");
153 /* State monitoring -------------------------------------------------------- */
155 static void all_update(void) {
162 static void log_connected(void attribute((unused
)) *v
) {
163 struct callbackdata
*cbd
;
165 /* Don't know what we might have missed while disconnected so update
166 * everything. We get this at startup too and this is how we do the initial
169 /* Re-get the volume */
170 cbd
= xmalloc(sizeof *cbd
);
172 disorder_eclient_volume(client
, log_volume
, -1, -1, cbd
);
175 static void log_completed(void attribute((unused
)) *v
,
176 const char attribute((unused
)) *track
) {
182 static void log_failed(void attribute((unused
)) *v
,
183 const char attribute((unused
)) *track
,
184 const char attribute((unused
)) *status
) {
190 static void log_moved(void attribute((unused
)) *v
,
191 const char attribute((unused
)) *user
) {
195 static void log_playing(void attribute((unused
)) *v
,
196 const char attribute((unused
)) *track
,
197 const char attribute((unused
)) *user
) {
201 /* we get a log_removed() anyway so we don't need to update_queue() from
205 static void log_queue(void attribute((unused
)) *v
,
206 struct queue_entry
attribute((unused
)) *q
) {
210 static void log_recent_added(void attribute((unused
)) *v
,
211 struct queue_entry
attribute((unused
)) *q
) {
215 static void log_recent_removed(void attribute((unused
)) *v
,
216 const char attribute((unused
)) *id
) {
217 /* nothing - log_recent_added() will trigger the relevant update */
220 static void log_removed(void attribute((unused
)) *v
,
221 const char attribute((unused
)) *id
,
222 const char attribute((unused
)) *user
) {
226 static void log_scratched(void attribute((unused
)) *v
,
227 const char attribute((unused
)) *track
,
228 const char attribute((unused
)) *user
) {
234 static void log_state(void attribute((unused
)) *v
,
235 unsigned long state
) {
238 /* If the track is paused or resume then the currently playing track is
239 * refetched so that we can continue to correctly calculate the played so-far
244 static void log_volume(void attribute((unused
)) *v
,
246 if(volume_l
!= l
|| volume_r
!= r
) {
253 /* Called once every 10 minutes */
254 static gboolean
periodic(gpointer
attribute((unused
)) data
) {
256 /* Expire cached data */
258 /* Update everything to be sure that the connection to the server hasn't
259 * mysteriously gone stale on us. */
261 return TRUE
; /* don't remove me */
264 static gboolean
heartbeat(gpointer
attribute((unused
)) data
) {
265 static struct timeval last
;
269 xgettimeofday(&now
, 0);
271 delta
= (now
.tv_sec
+ now
.tv_sec
/ 1.0E6
)
272 - (last
.tv_sec
+ last
.tv_sec
/ 1.0E6
);
274 fprintf(stderr
, "%f: %fs between 1s heartbeats\n",
275 now
.tv_sec
+ now
.tv_sec
/ 1.0E6
,
282 /* main -------------------------------------------------------------------- */
284 static const struct option options
[] = {
285 { "help", no_argument
, 0, 'h' },
286 { "version", no_argument
, 0, 'V' },
287 { "config", required_argument
, 0, 'c' },
288 { "tufnel", no_argument
, 0, 't' },
289 { "choosealpha", no_argument
, 0, 'C' },
290 { "debug", no_argument
, 0, 'd' },
294 /* display usage message and terminate */
295 static void help(void) {
296 xprintf("Disobedience - GUI client for DisOrder\n"
299 " disobedience [OPTIONS]\n"
301 " --help, -h Display usage message\n"
302 " --version, -V Display version number\n"
303 " --config PATH, -c PATH Set configuration file\n"
304 " --debug, -d Turn on debugging\n"
306 "Also GTK+ options will work.\n");
311 /* display version number and terminate */
312 static void version(void) {
313 xprintf("disorder version %s\n", disorder_version_string
);
318 int main(int argc
, char **argv
) {
320 disorder_eclient
*logclient
;
323 if(!setlocale(LC_CTYPE
, "")) fatal(errno
, "error calling setlocale");
324 gtk_init(&argc
, &argv
);
325 gtk_rc_parse_string(style
);
326 while((n
= getopt_long(argc
, argv
, "hVc:dtH", options
, 0)) >= 0) {
330 case 'c': configfile
= optarg
; break;
331 case 'd': debugging
= 1; break;
332 case 't': goesupto
= 11; break;
333 case 'C': choosealpha
= 1; break; /* not well tested any more */
334 default: fatal(0, "invalid option");
337 signal(SIGPIPE
, SIG_IGN
);
338 /* create the event loop */
339 D(("create main loop"));
340 mainloop
= g_main_loop_new(0, 0);
341 if(config_read()) fatal(0, "cannot read configuration");
342 /* create the clients */
343 if(!(client
= gtkclient())
344 || !(logclient
= gtkclient()))
345 return 1; /* already reported an error */
346 disorder_eclient_log(logclient
, &gdisorder_log_callbacks
, 0);
347 /* periodic operations (e.g. expiring the cache) */
348 g_timeout_add(600000/*milliseconds*/, periodic
, 0);
349 /* The point of this is to try and get a handle on mysterious
350 * unresponsiveness. It's not very useful in production use. */
352 g_timeout_add(1000/*milliseconds*/, heartbeat
, 0);
353 make_toplevel_window();
354 /* reset styles now everything has its name */
355 gtk_rc_reset_styles(gtk_settings_get_for_screen(gdk_screen_get_default()));
356 gtk_widget_show_all(toplevel
);
357 D(("enter main loop"));
358 g_main_loop_run(mainloop
);