ursaryd.c

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