ursaryd.c

   1 /*
   2  *      The Ursary Audio Controls
   3  *
   4  *      (c) 2014--2020 Martin Mares <mj@ucw.cz>
   5  */
   6
   7 #undef LOCAL_DEBUG
   8
   9 #include <ucw/lib.h>
  10 #include <ucw/clists.h>
  11 #include <ucw/daemon.h>
  12 #include <ucw/log.h>
  13 #include <ucw/mainloop.h>
  14 #include <ucw/opt.h>
  15 #include <ucw/stkstring.h>
  16
  17 #include <math.h>
  18 #include <signal.h>
  19 #include <stdio.h>
  20 #include <string.h>
  21 #include <stdlib.h>
  22 #include <syslog.h>
  23
  24 #include "ursaryd.h"
  25 #include "usb.h"
  26
  27 /*
  28  *      Map of all controls
  29  *
  30  *              rotary          red button      green button
  31  *              ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
  32  *      0       sink PCH        mute            switch to PCH
  33  *      1       sink BT         mute            switch to BT
  34  *      2       ceil brightness mic non-mute    ceiling lights on
  35  *      3       desk brightness -               desk lights on
  36  *      4       MPD             mute            MPD play/pause
  37  *      5       Albireo MPV     mute            MPD stop
  38  *      6       Albireo other   mute            MPD prev
  39  *      7       other machines  mute            MPD next
  40  *
  41  *      center  -
  42  *      slider  light color temperature
  43  */
  44
  45 #define PCH_SINK "alsa_output.pci-0000_00_1f.3.analog-stereo"
  46 #define BT_SINK "bluez_sink.CC_98_8B_D0_8C_06.a2dp_sink"
  47 #define LOGI_SOURCE "alsa_input.usb-046d_Logitech_Webcam_C925e_EF163C5F-02.analog-stereo"
  48
  49 /*** Sink controls ***/
  50
  51 static double volume_from_pa(pa_volume_t vol)
  52 {
  53   return (double) vol / PA_VOLUME_NORM;
  54 }
  55
  56 static pa_volume_t volume_to_pa(double vol)
  57 {
  58   return vol * PA_VOLUME_NORM + 0.0001;
  59 }
  60
  61 static void update_ring_from_sink(int ring, const char *sink_name)
  62 {
  63   struct pulse_sink *s = pulse_sink_by_name(sink_name);
  64   if (!s)
  65     {
  66       noct_set_ring(ring, RING_MODE_SINGLE_ON, 0x7f);
  67       noct_set_button(ring, 0);
  68       return;
  69     }
  70
  71   if (s->mute)
  72     {
  73       noct_set_ring(ring, RING_MODE_SINGLE_ON, 0x7f);
  74       noct_set_button(ring, 1);
  75       return;
  76     }
  77
  78   double vol = CLAMP(volume_from_pa(s->volume), 0, 1);
  79   noct_set_ring(ring, RING_MODE_LEFT, CLAMP((int)(0x7f * vol), 12, 0x7f));
  80   noct_set_button(ring, 0);
  81 }
  82
  83 static void update_sink_from_rotary(int delta, const char *sink_name)
  84 {
  85   struct pulse_sink *s = pulse_sink_by_name(sink_name);
  86   if (!s)
  87     return;
  88
  89   double vol = volume_from_pa(s->volume) + delta * 0.02;
  90   pa_volume_t pavol = volume_to_pa(CLAMP(vol, 0, 1));
  91   if (pavol == s->volume)
  92     return;
  93   pa_cvolume cvol;
  94   pa_cvolume_set(&cvol, s->channels, pavol);
  95
  96   DBG("## Setting volume of sink %s to %d", s->name, cvol.values[0]);
  97   pulse_sink_set_volume(s->idx, &cvol);
  98 }
  99
 100 static void update_sink_mute_from_button(int on, const char *sink_name)
 101 {
 102   if (!on)
 103     return;
 104
 105   struct pulse_sink *s = pulse_sink_by_name(sink_name);
 106   if (!s)
 107     return;
 108
 109   DBG("## Setting mute of sink %s to %d", s->name, !s->mute);
 110   pulse_sink_set_mute(s->idx, !s->mute);
 111 }
 112
 113 /*** Client controls ***/
 114
 115 struct client_map {
 116   int group;
 117   const char *client;
 118   const char *host;
 119 };
 120
 121 static struct client_map client_map[] = {
 122   { 4, "Music Player Daemon",   "albireo",      },
 123   { 5, "mpv",                   "albireo",      },
 124   { 6, NULL,                    "albireo",      },
 125   { 7, NULL,                    NULL,           },
 126 };
 127
 128 #define CLIENT_MAP_SIZE ARRAY_SIZE(client_map)
 129
 130 struct group_config {
 131   bool enabled;
 132   double range;
 133 };
 134
 135 struct group_state {
 136   double volume;
 137   bool have_muted[2];
 138 };
 139
 140 #define NUM_GROUPS 9
 141
 142 static struct group_config group_config[NUM_GROUPS] = {
 143   [4] = { .enabled = 1, .range = 1.5 },
 144   [5] = { .enabled = 1, .range = 1.5 },
 145   [6] = { .enabled = 1, .range = 1.5 },
 146   [7] = { .enabled = 1, .range = 1.5 },
 147 };
 148
 149 static struct group_state group_state[NUM_GROUPS];
 150
 151 static void calc_groups(void)
 152 {
 153   bzero(group_state, sizeof(group_state));
 154
 155   CLIST_FOR_EACH(struct pulse_sink_input *, s, pulse_sink_input_list)
 156     {
 157       s->noct_group_idx = -1;
 158
 159       if (s->client_idx < 0 || s->sink_idx < 0)
 160         continue;
 161
 162       struct pulse_client *c = pulse_client_by_idx(s->client_idx);
 163       if (!c)
 164         continue;
 165
 166       for (uns i=0; i < CLIENT_MAP_SIZE; i++)
 167         {
 168           struct client_map *cm = &client_map[i];
 169           if ((!cm->client || !strcmp(cm->client, c->name)) &&
 170               (!cm->host || !strcmp(cm->host, c->host)))
 171             {
 172               int g = cm->group;
 173               struct group_state *gs = &group_state[g];
 174               DBG("@@ Client #%d, sink input #%d -> group %d", s->client_idx, s->idx, g);
 175               s->noct_group_idx = g;
 176               gs->volume = MAX(gs->volume, s->volume);
 177               gs->have_muted[!!s->mute] = 1;
 178               break;
 179             }
 180         }
 181     }
 182 }
 183
 184 static void update_groups(void)
 185 {
 186   calc_groups();
 187
 188   for (uns i=0; i < NUM_GROUPS; i++)
 189     {
 190       struct group_config *gc = &group_config[i];
 191       struct group_state *gs = &group_state[i];
 192       if (!gc->enabled)
 193         continue;
 194
 195       DBG("@@ Group #%d: mute=%d/%d volume=%.3f/%.3f", i, gs->have_muted[0], gs->have_muted[1], volume_from_pa(gs->volume), gc->range);
 196
 197       if (!gs->have_muted[0] && !gs->have_muted[1])
 198         {
 199           noct_set_ring(i, RING_MODE_LEFT, 0);
 200           noct_set_button(i, 0);
 201         }
 202       else if (!gs->have_muted[0])
 203         {
 204           noct_set_ring(i, RING_MODE_SINGLE_ON, 0x7f);
 205           noct_set_button(i, 1);
 206         }
 207       else
 208         {
 209           double vol = CLAMP(volume_from_pa(gs->volume), 0, gc->range);
 210           int val = 0x7f * vol / gc->range;
 211           val = CLAMP(val, 12, 0x7f);
 212           noct_set_ring(i, RING_MODE_LEFT, val);
 213           noct_set_button(i, 0);
 214         }
 215     }
 216 }
 217
 218 static void update_group_from_rotary(int i, int delta)
 219 {
 220   if (i >= NUM_GROUPS)
 221     return;
 222   struct group_config *gc = &group_config[i];
 223   struct group_state *gs = &group_state[i];
 224   if (!gc->enabled)
 225     return;
 226
 227   calc_groups();
 228   double vol = volume_from_pa(gs->volume) + delta*0.02;
 229   pa_volume_t pavol = volume_to_pa(CLAMP(vol, 0, gc->range));
 230
 231   CLIST_FOR_EACH(struct pulse_sink_input *, s, pulse_sink_input_list)
 232     {
 233       if (s->noct_group_idx == i && s->volume != pavol)
 234         {
 235           DBG("@@ Client #%d, sink input #%d: setting volume=%u", s->client_idx, s->idx, pavol);
 236           pa_cvolume cvol;
 237           pa_cvolume_set(&cvol, s->channels, pavol);
 238           pulse_sink_input_set_volume(s->idx, &cvol);
 239         }
 240     }
 241 }
 242
 243 static void update_group_from_button(int i, int on)
 244 {
 245   if (!on)
 246     return;
 247   if (i >= NUM_GROUPS)
 248     return;
 249   struct group_config *gc = &group_config[i];
 250   struct group_state *gs = &group_state[i];
 251   if (!gc->enabled)
 252     return;
 253
 254   calc_groups();
 255   if (!gs->have_muted[0] && !gs->have_muted[1])
 256     return;
 257   uns mute = !gs->have_muted[1];
 258
 259   CLIST_FOR_EACH(struct pulse_sink_input *, s, pulse_sink_input_list)
 260     {
 261       if (s->noct_group_idx == i)
 262         {
 263           DBG("@@ Client #%d, sink input #%d: setting mute=%u", s->client_idx, s->idx, mute);
 264           pulse_sink_input_set_mute(s->idx, mute);
 265         }
 266     }
 267 }
 268
 269 static int find_touched_client(void)
 270 {
 271   int touched = -1;
 272
 273   for (uns i=0; i < NUM_GROUPS; i++)
 274     if (group_config[i].enabled && noct_rotary_touched[i])
 275       {
 276         if (touched >= 0)
 277           return -1;
 278         touched = i;
 279       }
 280   return touched;
 281 }
 282
 283 /*** Default sink controls ***/
 284
 285 static const char *get_client_sink(int i)
 286 {
 287   const char *sink = NULL;
 288
 289   CLIST_FOR_EACH(struct pulse_sink_input *, s, pulse_sink_input_list)
 290     if (s->noct_group_idx == i)
 291       {
 292         struct pulse_sink *sk = (s->sink_idx >= 0) ? pulse_sink_by_idx(s->sink_idx) : NULL;
 293         const char *ss = sk ? sk->name : NULL;
 294         if (!sink)
 295           sink = ss;
 296         else if (strcmp(sink, ss))
 297           sink = "?";
 298       }
 299   return sink ? : "?";
 300 }
 301
 302 static void update_default_sink(void)
 303 {
 304   int i = find_touched_client();
 305   const char *sink;
 306   if (i >= 0)
 307     sink = get_client_sink(i);
 308   else
 309     sink = pulse_default_sink_name ? : "?";
 310
 311   if (!strcmp(sink, PCH_SINK))
 312     {
 313       noct_set_button(8, 1);
 314       noct_set_button(9, 0);
 315     }
 316   else if (!strcmp(sink, BT_SINK))
 317     {
 318       noct_set_button(8, 0);
 319       noct_set_button(9, 1);
 320     }
 321   else
 322     {
 323       noct_set_button(8, 0);
 324       noct_set_button(9, 0);
 325     }
 326 }
 327
 328 static void update_default_sink_from_button(int button, int on)
 329 {
 330   if (!on)
 331     return;
 332
 333   int i = find_touched_client();
 334 #if 0
 335   const char *sink;
 336   if (i >= 0)
 337     sink = get_client_sink(i);
 338   else
 339     sink = pulse_default_sink_name ? : "?";
 340 #endif
 341
 342   const char *switch_to = NULL;
 343   if (button == 8)
 344     switch_to = PCH_SINK;
 345   else if (button == 9)
 346     switch_to = BT_SINK;
 347
 348   if (!switch_to)
 349     return;
 350
 351   if (i >= 0)
 352     {
 353       struct pulse_sink *sk = pulse_sink_by_name(switch_to);
 354       if (!sk)
 355         return;
 356
 357       CLIST_FOR_EACH(struct pulse_sink_input *, s, pulse_sink_input_list)
 358         if (s->noct_group_idx == i)
 359           {
 360             DBG("Moving input #%d to sink #%d", s->idx, sk->idx);
 361             pulse_sink_input_move(s->idx, sk->idx);
 362           }
 363     }
 364   else
 365     {
 366       DBG("Switching default sink to %s", switch_to);
 367       pulse_server_set_default_sink(switch_to);
 368     }
 369 }
 370
 371 /*** Source mute controls ***/
 372
 373 static void update_source_buttons(void)
 374 {
 375   struct pulse_source *source = pulse_source_by_name(LOGI_SOURCE);
 376   if (!source)
 377     return;
 378
 379   // if (source->suspended || source->mute)
 380   if (source->mute)
 381     noct_set_button(2, 0);
 382   else
 383     noct_set_button(2, 1);
 384 }
 385
 386 static void update_source_mute_from_button(int on, const char *source_name)
 387 {
 388   if (!on)
 389     return;
 390
 391   struct pulse_source *s = pulse_source_by_name(source_name);
 392   if (!s)
 393     return;
 394
 395   DBG("## Setting mute of source %s to %d", s->name, !s->mute);
 396   pulse_source_set_mute(s->idx, !s->mute);
 397 }
 398
 399 /*** MPD controls ***/
 400
 401 static bool mpd_flash_state;
 402
 403 static void mpd_flash_timeout(struct main_timer *t)
 404 {
 405   mpd_flash_state ^= 1;
 406   noct_set_button(12, mpd_flash_state);
 407   timer_add_rel(t, 500);
 408 }
 409
 410 static struct main_timer mpd_flash_timer = {
 411   .handler = mpd_flash_timeout,
 412 };
 413
 414 static void update_mpd(void)
 415 {
 416   const char *state = mpd_get_player_state();
 417   if (!strcmp(state, "play"))
 418     {
 419       noct_set_button(12, 1);
 420       timer_del(&mpd_flash_timer);
 421     }
 422   else if (!strcmp(state, "pause"))
 423     {
 424       if (!timer_is_active(&mpd_flash_timer))
 425         {
 426           mpd_flash_state = 1;
 427           mpd_flash_timeout(&mpd_flash_timer);
 428         }
 429     }
 430   else
 431     {
 432       noct_set_button(12, 0);
 433       timer_del(&mpd_flash_timer);
 434     }
 435 }
 436
 437 static void mpd_button_timeout(struct main_timer *t)
 438 {
 439   DBG("MPD stop");
 440   timer_del(t);
 441   mpd_stop();
 442 }
 443
 444 static void update_mpd_from_button(int button UNUSED, int on)
 445 {
 446   static struct main_timer mpd_button_timer = {
 447     .handler = mpd_button_timeout,
 448   };
 449
 450   const char *state = mpd_get_player_state();
 451
 452   if (!on)
 453     {
 454       if (timer_is_active(&mpd_button_timer))
 455         {
 456           timer_del(&mpd_button_timer);
 457           if (!strcmp(state, "play"))
 458             {
 459               DBG("MPD pause");
 460               mpd_pause(1);
 461             }
 462           else if (!strcmp(state, "pause"))
 463             {
 464               DBG("MPD resume");
 465               mpd_pause(0);
 466             }
 467         }
 468       return;
 469     }
 470
 471   if (!strcmp(state, "stop"))
 472     {
 473       DBG("MPD play");
 474       mpd_play();
 475     }
 476   else
 477     {
 478       DBG("MPD starting button timer");
 479       timer_add_rel(&mpd_button_timer, 1000);
 480     }
 481 }
 482
 483 /*** Lights ***/
 484
 485 static bool lights_on[2];
 486 static double lights_brightness[2];
 487 static double lights_temperature[2];
 488
 489 static void update_lights(void)
 490 {
 491   if (!dmx_is_ready())
 492     {
 493       noct_set_ring(3, RING_MODE_SINGLE_ON, 0x7f);
 494       noct_set_button(10, 0);
 495       noct_set_button(11, 0);
 496       return;
 497     }
 498
 499   for (uint i=0; i<2; i++)
 500     {
 501       uint warm, cold;
 502       if (lights_on[i])
 503         {
 504           noct_set_ring(3-i, RING_MODE_LEFT, lights_brightness[i] * 127);
 505           noct_set_button(11-i, 1);
 506           double r = 2;
 507           double x = (exp(r*lights_brightness[i]) - 1) / (exp(r) - 1);
 508           double t = lights_temperature[i];
 509           double w = 2*x*(1-t);
 510           double c = 2*x*t;
 511           warm = CLAMP((int)(255*w), 0, 255);
 512           cold = CLAMP((int)(255*c), 0, 255);
 513         }
 514       else
 515         {
 516           noct_set_ring(3-i, RING_MODE_LEFT, 0);
 517           noct_set_button(11-i, 0);
 518           warm = cold = 0;
 519         }
 520       DBG("Lights[%d]: on=%d bri=%.3f temp=%.3f -> warm=%d cold=%d", i, lights_on[i], lights_brightness[i], lights_temperature[i], warm, cold);
 521       dmx_set_pwm(2*i, warm);
 522       dmx_set_pwm(2*i+1, cold);
 523     }
 524 }
 525
 526 static void update_lights_from_rotary(int ch, int delta)
 527 {
 528   if (lights_on[ch])
 529     lights_brightness[ch] = CLAMP(lights_brightness[ch] + 0.015*delta*abs(delta), 0., 1.);
 530   update_lights();
 531 }
 532
 533 static void update_lights_from_slider(int value)
 534 {
 535   lights_temperature[0] = value / 127.;
 536   lights_temperature[1] = value / 127.;
 537   update_lights();
 538 }
 539
 540 static void lights_button_timeout(struct main_timer *t)
 541 {
 542   int ch = (uintptr_t) t->data;
 543   DBG("Lights[%d]: Full throttle!", ch);
 544   timer_del(t);
 545   lights_on[ch] = 1;
 546   lights_brightness[ch] = 1;
 547   update_lights();
 548 }
 549
 550 static void update_lights_from_button(int ch, int on)
 551 {
 552   static struct main_timer lights_button_timer[2] = {{
 553     .handler = lights_button_timeout,
 554     .data = (void *)(uintptr_t) 0,
 555   },{
 556     .handler = lights_button_timeout,
 557     .data = (void *)(uintptr_t) 1,
 558   }};
 559
 560   if (on)
 561     {
 562       lights_on[ch] = !lights_on[ch];
 563       update_lights();
 564       timer_add_rel(&lights_button_timer[ch], 1000);
 565     }
 566   else
 567     timer_del(&lights_button_timer[ch]);
 568 }
 569
 570 /*** Main update routines ***/
 571
 572 static struct main_timer update_timer;
 573 static timestamp_t last_touch_time;
 574
 575 enum update_state {
 576   US_OFFLINE,
 577   US_ONLINE,
 578   US_SLEEPING,
 579   US_PULSE_DEAD,
 580 };
 581
 582 static enum update_state update_state;
 583
 584 static bool want_sleep_p(void)
 585 {
 586   CLIST_FOR_EACH(struct pulse_sink *, s, pulse_sink_list)
 587     if (!s->suspended)
 588       return 0;
 589   return 1;
 590 }
 591
 592 static void do_update(struct main_timer *t)
 593 {
 594   DBG("## UPDATE in state %u", update_state);
 595   timer_del(t);
 596
 597   // Nocturn dead?
 598   if (!noct_is_ready())
 599     {
 600       DBG("## UPDATE: Nocturn is not ready");
 601       update_state = US_OFFLINE;
 602       return;
 603     }
 604   else if (update_state == US_OFFLINE)
 605     {
 606       DBG("## UPDATE: Going online");
 607       update_state = US_ONLINE;
 608     }
 609
 610   // Pulse dead?
 611   if (!pulse_is_ready())
 612     {
 613       DBG("## UPDATE: Pulse is not online");
 614       if (update_state != US_PULSE_DEAD)
 615         {
 616           update_state = US_PULSE_DEAD;
 617           noct_clear();
 618           for (int i=0; i<8; i++)
 619             noct_set_button(i, 1);
 620         }
 621       return;
 622     }
 623   else if (update_state == US_PULSE_DEAD)
 624     {
 625       DBG("## UPDATE: Waking up from the dead");
 626       update_state = US_ONLINE;
 627       noct_clear();
 628     }
 629
 630 #ifdef LOCAL_DEBUG
 631   pulse_dump();
 632 #endif
 633
 634   // Sleeping?
 635   bool want_sleep = want_sleep_p();
 636   if (!want_sleep)
 637     last_touch_time = main_get_now();
 638   timestamp_t since_touch = last_touch_time ? main_get_now() - last_touch_time : 0;
 639   timestamp_t sleep_in = 30000;
 640   if (since_touch >= sleep_in)
 641     {
 642       DBG("UPDATE: Sleeping");
 643       if (update_state == US_ONLINE)
 644         {
 645           update_state = US_SLEEPING;
 646           noct_clear();
 647           noct_set_ring(8, RING_MODE_LEFT, 127);
 648         }
 649       return;
 650     }
 651   else
 652     {
 653       if (update_state == US_SLEEPING)
 654         {
 655           DBG("UPDATE: Waking up");
 656           update_state = US_ONLINE;
 657           noct_clear();
 658         }
 659       if (want_sleep)
 660         {
 661           timestamp_t t = sleep_in - since_touch + 10;
 662           DBG("UPDATE: Scheduling sleep in %d ms", (int) t);
 663           timer_add_rel(&update_timer, t);
 664         }
 665     }
 666
 667   // Everything normal
 668   update_ring_from_sink(0, PCH_SINK);
 669   update_ring_from_sink(1, BT_SINK);
 670   update_groups();
 671   update_default_sink();
 672   update_source_buttons();
 673   update_mpd();
 674   update_lights();
 675 }
 676
 677 void schedule_update(void)
 678 {
 679   timer_add_rel(&update_timer, 10);
 680 }
 681
 682 static bool prepare_notify(void)
 683 {
 684   if (!pulse_is_ready())
 685     {
 686       DBG("## NOTIFY: Pulse is not online");
 687       return 0;
 688     }
 689
 690   last_touch_time = main_get_now();
 691   if (update_state == US_SLEEPING)
 692     {
 693       DBG("## NOTIFY: Scheduling wakeup");
 694       schedule_update();
 695     }
 696
 697   return 1;
 698 }
 699
 700 void notify_rotary(int rotary, int delta)
 701 {
 702   if (!prepare_notify())
 703     return;
 704
 705   switch (rotary)
 706     {
 707     case 0:
 708       update_sink_from_rotary(delta, PCH_SINK);
 709       break;
 710     case 1:
 711       update_sink_from_rotary(delta, BT_SINK);
 712       break;
 713     case 2:
 714       update_lights_from_rotary(1, delta);
 715       break;
 716     case 3:
 717       update_lights_from_rotary(0, delta);
 718       break;
 719     case 9:
 720       update_lights_from_slider(delta);
 721       break;
 722     default:
 723       update_group_from_rotary(rotary, delta);
 724     }
 725 }
 726
 727 void notify_button(int button, int on)
 728 {
 729   if (!prepare_notify())
 730     return;
 731
 732   switch (button)
 733     {
 734     case 0:
 735       update_sink_mute_from_button(on, PCH_SINK);
 736       break;
 737     case 1:
 738       update_sink_mute_from_button(on, BT_SINK);
 739       break;
 740     case 2:
 741       update_source_mute_from_button(on, LOGI_SOURCE);
 742       break;
 743     case 8:
 744     case 9:
 745       update_default_sink_from_button(button, on);
 746       break;
 747     case 10:
 748       update_lights_from_button(1, on);
 749       break;
 750     case 11:
 751       update_lights_from_button(0, on);
 752       break;
 753     case 12:
 754       update_mpd_from_button(button, on);
 755       break;
 756     case 13:
 757       if (on)
 758         mpd_stop();
 759       break;
 760     case 14:
 761       if (on)
 762         mpd_prev();
 763       break;
 764     case 15:
 765       if (on)
 766         mpd_next();
 767       break;
 768     default:
 769       update_group_from_button(button, on);
 770     }
 771 }
 772
 773 void notify_touch(int rotary UNUSED, int on UNUSED)
 774 {
 775   if (!prepare_notify())
 776     return;
 777
 778   // Rotary touches switch meaning of LEDs, this is handled inside display updates
 779   if (rotary >= 4 && rotary < 8)
 780     schedule_update();
 781 }
 782
 783 /*** Main entry point ***/
 784
 785 static int debug;
 786 static int no_fork;
 787
 788 static struct opt_section options = {
 789   OPT_ITEMS {
 790     OPT_HELP("Control console for the Ursary"),
 791     OPT_HELP(""),
 792     OPT_HELP("Options:"),
 793     OPT_HELP_OPTION,
 794     OPT_BOOL('d', "debug", debug, 0, "\tEnable debugging mode (no fork etc.)"),
 795     OPT_BOOL(0, "no-fork", no_fork, 0, "\tDo not fork\n"),
 796     OPT_END
 797   }
 798 };
 799
 800 static void sigterm_handler(struct main_signal *ms UNUSED)
 801 {
 802   main_shut_down();
 803 }
 804
 805 static void daemon_body(struct daemon_params *dp)
 806 {
 807   main_init();
 808   update_timer.handler = do_update;
 809
 810   usb_init();
 811   noct_init();
 812   dmx_init();
 813   pulse_init();
 814   mpd_init();
 815
 816   static struct main_signal term_sig = {
 817     .signum = SIGTERM,
 818     .handler = sigterm_handler,
 819   };
 820   signal_add(&term_sig);
 821
 822   msg(L_INFO, "Ursary daemon starting");
 823   main_loop();
 824   msg(L_INFO, "Ursary daemon shut down");
 825   daemon_exit(dp);
 826 }
 827
 828 int main(int argc UNUSED, char **argv)
 829 {
 830   opt_parse(&options, argv+1);
 831   unsetenv("DISPLAY");
 832   unsetenv("HOME");
 833
 834   struct daemon_params dp = {
 835     .flags = ((debug || no_fork) ? DAEMON_FLAG_SIMULATE : 0),
 836     .pid_file = "/run/ursaryd.pid",
 837     .run_as_user = "ursary",
 838   };
 839   daemon_init(&dp);
 840
 841   log_init(argv[0]);
 842   if (!debug)
 843     {
 844       struct log_stream *ls = log_new_syslog("daemon", LOG_PID);
 845       ls->levels = ~(1U << L_DEBUG);
 846       log_set_default_stream(ls);
 847     }
 848
 849   daemon_run(&dp, daemon_body);
 850   return 0;
 851 }