chiark / gitweb /
Delete key now works in playlist editor
[disorder] / disobedience / disobedience.c
CommitLineData
460b9539 1/*
2 * This file is part of DisOrder.
4778e044 3 * Copyright (C) 2006-2009 Richard Kettlewell
460b9539 4 *
e7eb3a27 5 * This program is free software: you can redistribute it and/or modify
460b9539 6 * it under the terms of the GNU General Public License as published by
e7eb3a27 7 * the Free Software Foundation, either version 3 of the License, or
460b9539 8 * (at your option) any later version.
9 *
e7eb3a27
RK
10 * This program is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 * GNU General Public License for more details.
14 *
460b9539 15 * You should have received a copy of the GNU General Public License
e7eb3a27 16 * along with this program. If not, see <http://www.gnu.org/licenses/>.
460b9539 17 */
219dc95c
RK
18/** @file disobedience/disobedience.c
19 * @brief Main Disobedience program
20 */
460b9539 21
22#include "disobedience.h"
3fbdc96d 23#include "version.h"
460b9539 24
25#include <getopt.h>
26#include <locale.h>
fe8f8518 27#include <pcre.h>
5bf7c546 28#include <gcrypt.h>
460b9539 29
30/* Apologies for the numerous de-consting casts, but GLib et al do not seem to
31 * have heard of const. */
32
460b9539 33/* Variables --------------------------------------------------------------- */
34
219dc95c
RK
35/** @brief Event loop */
36GMainLoop *mainloop;
37
38/** @brief Top-level window */
39GtkWidget *toplevel;
40
41/** @brief Label for progress indicator */
42GtkWidget *report_label;
43
44/** @brief Main tab group */
45GtkWidget *tabs;
46
47/** @brief Main client */
48disorder_eclient *client;
460b9539 49
73f1b9f3
RK
50/** @brief Log client */
51disorder_eclient *logclient;
52
219dc95c
RK
53/** @brief Last reported state
54 *
55 * This is updated by log_state().
56 */
57unsigned long last_state;
58
59/** @brief True if some track is playing
60 *
61 * This ought to be removed in favour of last_state & DISORDER_PLAYING
62 */
63int playing;
64
65/** @brief Left channel volume */
66int volume_l;
67
68/** @brief Right channel volume */
69int volume_r;
460b9539 70
b50cfb8a
RK
71/** @brief Audio backend */
72const struct uaudio *backend;
73
460b9539 74double goesupto = 10; /* volume upper bound */
219dc95c 75
7858930d 76/** @brief True if a NOP is in flight */
77static int nop_in_flight;
78
a99c4e9a
RK
79/** @brief True if an rtp-address command is in flight */
80static int rtp_address_in_flight;
81
6f09d54d
RK
82/** @brief True if a rights lookup is in flight */
83static int rights_lookup_in_flight;
84
85/** @brief Current rights bitmap */
86rights_type last_rights;
87
a99c4e9a
RK
88/** @brief True if RTP play is available
89 *
90 * This is a bit of a bodge...
91 */
92int rtp_supported;
93
94/** @brief True if RTP play is enabled */
95int rtp_is_running;
96
45e6d04a
RK
97/** @brief Server version */
98const char *server_version;
99
100/** @brief Parsed server version */
101long server_version_bytes;
102
00e0c652
RK
103static void check_rtp_address(const char *event,
104 void *eventdata,
105 void *callbackdata);
adafcbcf 106
460b9539 107/* Window creation --------------------------------------------------------- */
108
109/* Note that all the client operations kicked off from here will only complete
110 * after we've entered the event loop. */
111
219dc95c
RK
112/** @brief Called when main window is deleted
113 *
114 * Terminates the program.
115 */
460b9539 116static gboolean delete_event(GtkWidget attribute((unused)) *widget,
117 GdkEvent attribute((unused)) *event,
118 gpointer attribute((unused)) data) {
119 D(("delete_event"));
120 exit(0); /* die immediately */
121}
122
219dc95c
RK
123/** @brief Called when the current tab is switched
124 *
125 * Updates the menu settings to correspond to the new page.
126 */
2a3fe554 127static void tab_switched(GtkNotebook *notebook,
460b9539 128 GtkNotebookPage attribute((unused)) *page,
129 guint page_num,
130 gpointer attribute((unused)) user_data) {
2a3fe554
RK
131 GtkWidget *const tab = gtk_notebook_get_nth_page(notebook, page_num);
132 const struct tabtype *const t = g_object_get_data(G_OBJECT(tab), "type");
ee7552f8 133 assert(t != 0);
2a3fe554
RK
134 if(t->selected)
135 t->selected();
460b9539 136}
137
219dc95c 138/** @brief Create the report box */
460b9539 139static GtkWidget *report_box(void) {
140 GtkWidget *vbox = gtk_vbox_new(FALSE, 0);
141
142 report_label = gtk_label_new("");
143 gtk_label_set_ellipsize(GTK_LABEL(report_label), PANGO_ELLIPSIZE_END);
144 gtk_misc_set_alignment(GTK_MISC(report_label), 0, 0);
145 gtk_container_add(GTK_CONTAINER(vbox), gtk_hseparator_new());
146 gtk_container_add(GTK_CONTAINER(vbox), report_label);
147 return vbox;
148}
149
219dc95c 150/** @brief Create and populate the main tab group */
460b9539 151static GtkWidget *notebook(void) {
152 tabs = gtk_notebook_new();
d4ef4132
RK
153 /* The current tab is _NORMAL, the rest are _ACTIVE, which is bizarre but
154 * produces not too dreadful appearance */
33288048 155 gtk_widget_set_style(tabs, tool_style);
460b9539 156 g_signal_connect(tabs, "switch-page", G_CALLBACK(tab_switched), 0);
157 gtk_notebook_append_page(GTK_NOTEBOOK(tabs), queue_widget(),
158 gtk_label_new("Queue"));
159 gtk_notebook_append_page(GTK_NOTEBOOK(tabs), recent_widget(),
160 gtk_label_new("Recent"));
161 gtk_notebook_append_page(GTK_NOTEBOOK(tabs), choose_widget(),
162 gtk_label_new("Choose"));
4eb1f430
RK
163 gtk_notebook_append_page(GTK_NOTEBOOK(tabs), added_widget(),
164 gtk_label_new("Added"));
460b9539 165 return tabs;
166}
167
219dc95c 168/** @brief Create and populate the main window */
460b9539 169static void make_toplevel_window(void) {
170 GtkWidget *const vbox = gtk_vbox_new(FALSE, 1);
171 GtkWidget *const rb = report_box();
172
173 D(("top_window"));
174 toplevel = gtk_window_new(GTK_WINDOW_TOPLEVEL);
175 /* default size is too small */
176 gtk_window_set_default_size(GTK_WINDOW(toplevel), 640, 480);
177 /* terminate on close */
178 g_signal_connect(G_OBJECT(toplevel), "delete_event",
179 G_CALLBACK(delete_event), NULL);
180 /* lay out the window */
181 gtk_window_set_title(GTK_WINDOW(toplevel), "Disobedience");
182 gtk_container_add(GTK_CONTAINER(toplevel), vbox);
183 /* lay out the vbox */
184 gtk_box_pack_start(GTK_BOX(vbox),
185 menubar(toplevel),
186 FALSE, /* expand */
187 FALSE, /* fill */
188 0);
189 gtk_box_pack_start(GTK_BOX(vbox),
190 control_widget(),
191 FALSE, /* expand */
192 FALSE, /* fill */
193 0);
194 gtk_container_add(GTK_CONTAINER(vbox), notebook());
195 gtk_box_pack_end(GTK_BOX(vbox),
196 rb,
197 FALSE, /* expand */
198 FALSE, /* fill */
199 0);
33288048 200 gtk_widget_set_style(toplevel, tool_style);
460b9539 201}
202
6f09d54d 203static void userinfo_rights_completed(void attribute((unused)) *v,
abf99697 204 const char *err,
6f09d54d
RK
205 const char *value) {
206 rights_type r;
207
abf99697
RK
208 if(err) {
209 popup_protocol_error(0, err);
6f09d54d
RK
210 r = 0;
211 } else {
212 if(parse_rights(value, &r, 0))
213 r = 0;
214 }
215 /* If rights have changed, signal everything that cares */
216 if(r != last_rights) {
217 last_rights = r;
218 ++suppress_actions;
219 event_raise("rights-changed", 0);
220 --suppress_actions;
221 }
222 rights_lookup_in_flight = 0;
223}
224
45e6d04a
RK
225static void check_rights(void) {
226 if(!rights_lookup_in_flight) {
227 rights_lookup_in_flight = 1;
228 disorder_eclient_userinfo(client,
229 userinfo_rights_completed,
230 config->username, "rights",
231 0);
232 }
233}
234
321f7536
RK
235/** @brief Called occasionally */
236static gboolean periodic_slow(gpointer attribute((unused)) data) {
6f09d54d 237 D(("periodic_slow"));
460b9539 238 /* Expire cached data */
239 cache_expire();
240 /* Update everything to be sure that the connection to the server hasn't
241 * mysteriously gone stale on us. */
242 all_update();
fc36ecb7 243 event_raise("periodic-slow", 0);
adafcbcf 244 /* Recheck RTP status too */
00e0c652 245 check_rtp_address(0, 0, 0);
460b9539 246 return TRUE; /* don't remove me */
247}
248
321f7536
RK
249/** @brief Called frequently */
250static gboolean periodic_fast(gpointer attribute((unused)) data) {
251#if 0 /* debugging hack */
460b9539 252 static struct timeval last;
253 struct timeval now;
254 double delta;
255
256 xgettimeofday(&now, 0);
257 if(last.tv_sec) {
258 delta = (now.tv_sec + now.tv_sec / 1.0E6)
259 - (last.tv_sec + last.tv_sec / 1.0E6);
260 if(delta >= 1.0625)
261 fprintf(stderr, "%f: %fs between 1s heartbeats\n",
262 now.tv_sec + now.tv_sec / 1.0E6,
263 delta);
264 }
265 last = now;
321f7536 266#endif
b50cfb8a 267 if(rtp_supported && backend && backend->get_volume) {
321f7536 268 int nl, nr;
b50cfb8a
RK
269 backend->get_volume(&nl, &nr);
270 if(nl != volume_l || nr != volume_r) {
321f7536
RK
271 volume_l = nl;
272 volume_r = nr;
1f868ca3 273 event_raise("volume-changed", 0);
321f7536
RK
274 }
275 }
00e0c652 276 /* Periodically check what our rights are */
45e6d04a
RK
277 int recheck_rights = 1;
278 if(server_version_bytes >= 0x04010000)
279 /* Server versions after 4.1 will send updates */
280 recheck_rights = 0;
281 if((server_version_bytes & 0xFF) == 0x01)
282 /* Development servers might do regardless of their version number */
283 recheck_rights = 0;
284 if(recheck_rights)
285 check_rights();
fc36ecb7 286 event_raise("periodic-fast", 0);
460b9539 287 return TRUE;
288}
289
7858930d 290/** @brief Called when a NOP completes */
53fa91bb 291static void nop_completed(void attribute((unused)) *v,
abf99697 292 const char attribute((unused)) *err) {
53fa91bb 293 /* TODO report the error somewhere */
7858930d 294 nop_in_flight = 0;
295}
296
297/** @brief Called from time to time to arrange for a NOP to be sent
298 *
299 * At most one NOP remains in flight at any moment. If the client is not
300 * currently connected then no NOP is sent.
301 */
302static gboolean maybe_send_nop(gpointer attribute((unused)) data) {
8f763f1b 303 if(!nop_in_flight && (disorder_eclient_state(client) & DISORDER_CONNECTED)) {
7858930d 304 nop_in_flight = 1;
305 disorder_eclient_nop(client, nop_completed, 0);
306 }
a99c4e9a 307 if(rtp_supported) {
6c7a654c 308 const int rtp_was_running = rtp_is_running;
a99c4e9a 309 rtp_is_running = rtp_running();
6c7a654c
RK
310 if(rtp_was_running != rtp_is_running)
311 event_raise("rtp-changed", 0);
a99c4e9a 312 }
7858930d 313 return TRUE; /* keep call me please */
314}
315
a99c4e9a
RK
316/** @brief Called when a rtp-address command succeeds */
317static void got_rtp_address(void attribute((unused)) *v,
abf99697 318 const char *err,
a99c4e9a
RK
319 int attribute((unused)) nvec,
320 char attribute((unused)) **vec) {
3849817f 321 const int rtp_was_supported = rtp_supported;
6c7a654c
RK
322 const int rtp_was_running = rtp_is_running;
323
fb44b59e 324 ++suppress_actions;
a99c4e9a 325 rtp_address_in_flight = 0;
abf99697 326 if(err) {
4190a4d9
RK
327 /* An error just means that we're not using network play */
328 rtp_supported = 0;
329 rtp_is_running = 0;
330 } else {
331 rtp_supported = 1;
332 rtp_is_running = rtp_running();
4190a4d9 333 }
00e0c652
RK
334 /*fprintf(stderr, "rtp supported->%d, running->%d\n",
335 rtp_supported, rtp_is_running);*/
3849817f
RK
336 if(rtp_supported != rtp_was_supported
337 || rtp_is_running != rtp_was_running)
6c7a654c 338 event_raise("rtp-changed", 0);
fb44b59e 339 --suppress_actions;
a99c4e9a
RK
340}
341
342/** @brief Called to check whether RTP play is available */
00e0c652
RK
343static void check_rtp_address(const char attribute((unused)) *event,
344 void attribute((unused)) *eventdata,
345 void attribute((unused)) *callbackdata) {
346 if(!rtp_address_in_flight) {
347 //fprintf(stderr, "checking rtp\n");
4190a4d9 348 disorder_eclient_rtp_address(client, got_rtp_address, NULL);
00e0c652 349 }
a99c4e9a
RK
350}
351
460b9539 352/* main -------------------------------------------------------------------- */
353
354static const struct option options[] = {
355 { "help", no_argument, 0, 'h' },
356 { "version", no_argument, 0, 'V' },
357 { "config", required_argument, 0, 'c' },
358 { "tufnel", no_argument, 0, 't' },
460b9539 359 { "debug", no_argument, 0, 'd' },
360 { 0, 0, 0, 0 }
361};
362
363/* display usage message and terminate */
364static void help(void) {
365 xprintf("Disobedience - GUI client for DisOrder\n"
366 "\n"
367 "Usage:\n"
368 " disobedience [OPTIONS]\n"
369 "Options:\n"
370 " --help, -h Display usage message\n"
371 " --version, -V Display version number\n"
372 " --config PATH, -c PATH Set configuration file\n"
373 " --debug, -d Turn on debugging\n"
374 "\n"
375 "Also GTK+ options will work.\n");
376 xfclose(stdout);
377 exit(0);
378}
379
45e6d04a
RK
380static void version_completed(void attribute((unused)) *v,
381 const char attribute((unused)) *err,
3665689a 382 const char *ver) {
45e6d04a
RK
383 long major, minor, patch, dev;
384
3665689a 385 if(!ver) {
45e6d04a
RK
386 server_version = 0;
387 server_version_bytes = 0;
388 return;
389 }
3665689a 390 server_version = ver;
45e6d04a 391 server_version_bytes = 0;
3665689a
RK
392 major = strtol(ver, (char **)&ver, 10);
393 if(*ver != '.')
45e6d04a 394 return;
3665689a
RK
395 ++ver;
396 minor = strtol(ver, (char **)&ver, 10);
397 if(*ver == '.') {
398 ++ver;
399 patch = strtol(ver, (char **)&ver, 10);
45e6d04a
RK
400 } else
401 patch = 0;
3665689a
RK
402 if(*ver) {
403 if(*ver == '+') {
45e6d04a 404 dev = 1;
3665689a 405 ++ver;
45e6d04a 406 }
3665689a 407 if(*ver)
45e6d04a
RK
408 dev = 2;
409 } else
410 dev = 0;
411 server_version_bytes = (major << 24) + (minor << 16) + (patch << 8) + dev;
412}
413
7c30fc75 414void logged_in(void) {
73f1b9f3
RK
415 /* reset the clients */
416 disorder_eclient_close(client);
417 disorder_eclient_close(logclient);
a99c4e9a 418 rtp_supported = 0;
7c30fc75 419 event_raise("logged-in", 0);
6f09d54d 420 /* Force the periodic checks */
6f09d54d
RK
421 periodic_slow(0);
422 periodic_fast(0);
45e6d04a
RK
423 /* Recheck server version */
424 disorder_eclient_version(client, version_completed, 0);
68210888
RK
425 disorder_eclient_enable_connect(client);
426 disorder_eclient_enable_connect(logclient);
73f1b9f3
RK
427}
428
460b9539 429int main(int argc, char **argv) {
430 int n;
ce73fea7 431 gboolean gtkok;
460b9539 432
320598d4 433 mem_init();
fe8f8518
RK
434 /* garbage-collect PCRE's memory */
435 pcre_malloc = xmalloc;
436 pcre_free = xfree;
2e9ba080 437 if(!setlocale(LC_CTYPE, "")) disorder_fatal(errno, "error calling setlocale");
ce73fea7 438 gtkok = gtk_init_check(&argc, &argv);
c3df9503 439 while((n = getopt_long(argc, argv, "hVc:dtHC", options, 0)) >= 0) {
460b9539 440 switch(n) {
441 case 'h': help();
3fbdc96d 442 case 'V': version("disobedience");
460b9539 443 case 'c': configfile = optarg; break;
444 case 'd': debugging = 1; break;
445 case 't': goesupto = 11; break;
2e9ba080 446 default: disorder_fatal(0, "invalid option");
460b9539 447 }
448 }
ce73fea7 449 if(!gtkok)
2e9ba080 450 disorder_fatal(0, "failed to initialize GTK+");
5bf7c546
RK
451 /* gcrypt initialization */
452 if(!gcry_check_version(NULL))
453 disorder_fatal(0, "gcry_check_version failed");
454 gcry_control(GCRYCTL_INIT_SECMEM, 0);
455 gcry_control (GCRYCTL_INITIALIZATION_FINISHED, 0);
346ba8d5 456 signal(SIGPIPE, SIG_IGN);
33288048 457 init_styles();
b4f8eba1 458 load_settings();
460b9539 459 /* create the event loop */
460 D(("create main loop"));
461 mainloop = g_main_loop_new(0, 0);
2e9ba080 462 if(config_read(0, NULL)) disorder_fatal(0, "cannot read configuration");
b50cfb8a
RK
463 /* we'll need mixer support */
464 backend = uaudio_apis[0];
61ad0645
RK
465 if(backend->configure)
466 backend->configure();
b50cfb8a
RK
467 if(backend->open_mixer)
468 backend->open_mixer();
460b9539 469 /* create the clients */
1c0d78bd
RK
470 if(!(client = gtkclient())
471 || !(logclient = gtkclient()))
472 return 1; /* already reported an error */
321f7536 473 /* periodic operations (e.g. expiring the cache, checking local volume) */
00e0c652 474 g_timeout_add(600000/*milliseconds*/, periodic_slow, 0);
321f7536 475 g_timeout_add(1000/*milliseconds*/, periodic_fast, 0);
460b9539 476 make_toplevel_window();
477 /* reset styles now everything has its name */
478 gtk_rc_reset_styles(gtk_settings_get_for_screen(gdk_screen_get_default()));
479 gtk_widget_show_all(toplevel);
7858930d 480 /* issue a NOP every so often */
481 g_timeout_add_full(G_PRIORITY_LOW,
d37d5336 482 2000/*interval, ms*/,
7858930d 483 maybe_send_nop,
484 0/*data*/,
485 0/*notify*/);
6d1302f0
RK
486 /* Start monitoring the log */
487 disorder_eclient_log(logclient, &log_callbacks, 0);
6f09d54d 488 /* Initiate all the checks */
6f09d54d 489 periodic_fast(0);
45e6d04a 490 disorder_eclient_version(client, version_completed, 0);
00e0c652 491 event_register("log-connected", check_rtp_address, 0);
fb44b59e 492 suppress_actions = 0;
fc36ecb7 493 playlists_init();
bf5fdf14
RK
494 /* If no password is set yet pop up a login box */
495 if(!config->password)
496 login_box();
460b9539 497 D(("enter main loop"));
498 g_main_loop_run(mainloop);
499 return 0;
500}
501
502/*
503Local Variables:
504c-basic-offset:2
505comment-column:40
506fill-column:79
507indent-tabs-mode:nil
508End:
509*/