/*
- * The Ursary Audio Controls
+ * The Ursary Control Panel
*
- * (c) 2014--2018 Martin Mares <mj@ucw.cz>
+ * (c) 2014-2023 Martin Mares <mj@ucw.cz>
*/
#undef LOCAL_DEBUG
#include <ucw/mainloop.h>
#include <ucw/opt.h>
#include <ucw/stkstring.h>
+#include <ucw/string.h>
+#include <math.h>
#include <signal.h>
#include <stdio.h>
#include <string.h>
#include <syslog.h>
#include "ursaryd.h"
+#include "usb.h"
/*
* Map of all controls
*
* rotary red button green button
- * 0 sink Brum mute -
- * 1 - - -
- * 2 - - -
- * 3 - - -
- * 4 MPD mute play/pause/stop
- * 5 Albireo MPV mute -
- * 6 Albireo other mute -
- * 7 other machines mute -
+ * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+ * 0 sink PCH mute switch to PCH
+ * 1 sink BT mute switch to BT
+ * 2 ceil brightness mic non-mute ceiling lights on
+ * 3 desk brightness - desk lights on
+ * 4 Albireo MPD mute MPD play/pause
+ * 5 Albireo MPV mute MPD stop
+ * 6 Albireo Zoom mute MPD prev
+ * 7 eveyrhing else mute MPD next
*
- * center -
- * slider -
+ * center rainbow brightness
+ * slider light color temperature
*/
+#define PCH_SINK "alsa_output.pci-0000_07_00.6.analog-stereo"
+#define BT_SINK "bluez_sink.CC_98_8B_D0_8C_06.a2dp_sink"
+#define LOGI_SOURCE "alsa_input.usb-046d_Logitech_Webcam_C925e_EF163C5F-02.analog-stereo"
+
/*** Sink controls ***/
static double volume_from_pa(pa_volume_t vol)
noct_set_button(ring, 0);
}
-static void update_button_from_port(int button, const char *sink_name, const char *port_name)
-{
- struct pulse_sink *s = pulse_sink_by_name(sink_name);
- if (!s)
- {
- noct_set_button(button, 0);
- return;
- }
-
- noct_set_button(button, !strcmp(s->active_port, port_name));
-}
-
static void update_sink_from_rotary(int delta, const char *sink_name)
{
struct pulse_sink *s = pulse_sink_by_name(sink_name);
pulse_sink_set_mute(s->idx, !s->mute);
}
-static void update_port_from_button(int on, const char *sink_name, const char *port1, const char *port2)
-{
- if (!on)
- return;
-
- struct pulse_sink *s = pulse_sink_by_name(sink_name);
- if (!s)
- return;
-
- const char *port = port1;
- if (!strcmp(s->active_port, port1))
- port = port2;
-
- DBG("## Setting port of sink %s to %s", s->name, port);
- pulse_sink_set_port(s->idx, port);
-}
-
/*** Client controls ***/
struct client_map {
static struct client_map client_map[] = {
{ 4, "Music Player Daemon", "albireo", },
{ 5, "mpv", "albireo", },
- { 6, NULL, "albireo", },
+ { 6, "ZOOM VoiceEngine", "albireo", },
{ 7, NULL, NULL, },
};
else
sink = pulse_default_sink_name ? : "?";
- if (!strcmp(sink, "ursarium"))
+ if (!strcmp(sink, PCH_SINK))
{
noct_set_button(8, 1);
noct_set_button(9, 0);
- noct_set_button(10, 0);
}
- else if (!strcmp(sink, "catarium"))
+ else if (!strcmp(sink, BT_SINK))
{
noct_set_button(8, 0);
noct_set_button(9, 1);
- noct_set_button(10, 0);
- }
- else if (!strcmp(sink, "compress"))
- {
- noct_set_button(8, 0);
- noct_set_button(9, 0);
- noct_set_button(10, 1);
}
else
{
noct_set_button(8, 0);
noct_set_button(9, 0);
- noct_set_button(10, 0);
}
}
return;
int i = find_touched_client();
+#if 0
const char *sink;
if (i >= 0)
sink = get_client_sink(i);
else
sink = pulse_default_sink_name ? : "?";
+#endif
const char *switch_to = NULL;
if (button == 8)
- {
- if (!strcmp(sink, "ursarium"))
- switch_to = "burrow";
- else
- switch_to = "ursarium";
- }
+ switch_to = PCH_SINK;
else if (button == 9)
- {
- if (!strcmp(sink, "catarium"))
- switch_to = "burrow";
- else
- switch_to = "catarium";
- }
- else if (button == 10)
- {
- if (!strcmp(sink, "compress"))
- switch_to = "burrow";
- else
- switch_to = "compress";
- }
+ switch_to = BT_SINK;
if (!switch_to)
return;
}
}
+/*** Source mute controls ***/
+
+static void update_source_buttons(void)
+{
+ struct pulse_source *source = pulse_source_by_name(LOGI_SOURCE);
+ if (!source)
+ return;
+
+#if 0 // Disabled for now
+ // if (source->suspended || source->mute)
+ if (source->mute)
+ noct_set_button(2, 0);
+ else
+ noct_set_button(2, 1);
+#endif
+}
+
+static void update_source_mute_from_button(int on, const char *source_name)
+{
+ if (!on)
+ return;
+
+ struct pulse_source *s = pulse_source_by_name(source_name);
+ if (!s)
+ return;
+
+#if 0
+ DBG("## Setting mute of source %s to %d", s->name, !s->mute);
+ pulse_source_set_mute(s->idx, !s->mute);
+#endif
+}
+
/*** MPD controls ***/
static bool mpd_flash_state;
}
}
+/*** Lights ***/
+
+static bool lights_on[2];
+static double lights_brightness[2];
+static double lights_temperature[2];
+static timestamp_t lights_last_update[2];
+
+static void update_lights(void)
+{
+ for (uint ch=0; ch < 2; ch++)
+ {
+ if (lights_on[ch])
+ {
+ noct_set_ring(3-ch, RING_MODE_LEFT, lights_brightness[ch] * 127);
+ noct_set_button(11-ch, 1);
+ }
+ else
+ {
+ noct_set_ring(3-ch, RING_MODE_LEFT, 0);
+ noct_set_button(11-ch, 0);
+ }
+ }
+}
+
+static void send_lights(int ch)
+{
+ DBG("Lights[%d]: on=%d bri=%.3f temp=%.3f", ch, lights_on[ch], lights_brightness[ch], lights_temperature[ch]);
+ double b = lights_on[ch] ? lights_brightness[ch] : 0;
+ double t = lights_on[ch] ? lights_temperature[ch] : 0;
+ char topic[100], val[100];
+ snprintf(topic, sizeof(topic), "burrow/lights/catarium/%s", (ch ? "top" : "bottom"));
+ snprintf(val, sizeof(val), "%.3f %.3f", b, t);
+ mqtt_publish(topic, val);
+ lights_last_update[ch] = main_get_now();
+ update_lights();
+}
+
+static void update_lights_from_rotary(int ch, int delta)
+{
+ if (lights_on[ch])
+ lights_brightness[ch] = CLAMP(lights_brightness[ch] + 0.015*delta*abs(delta), 0., 1.);
+ send_lights(ch);
+}
+
+static void update_lights_from_slider(int value)
+{
+ lights_temperature[0] = value / 127.;
+ lights_temperature[1] = value / 127.;
+ send_lights(0);
+ send_lights(1);
+}
+
+static void lights_button_timeout(struct main_timer *t)
+{
+ int ch = (uintptr_t) t->data;
+ DBG("Lights[%d]: Full throttle!", ch);
+ timer_del(t);
+ lights_on[ch] = 1;
+ lights_brightness[ch] = 1;
+ send_lights(ch);
+}
+
+static void update_lights_from_button(int ch, int on)
+{
+ static struct main_timer lights_button_timer[2] = {{
+ .handler = lights_button_timeout,
+ .data = (void *)(uintptr_t) 0,
+ },{
+ .handler = lights_button_timeout,
+ .data = (void *)(uintptr_t) 1,
+ }};
+
+ if (on)
+ timer_add_rel(&lights_button_timer[ch], 500);
+ else if (timer_is_active(&lights_button_timer[ch]))
+ {
+ timer_del(&lights_button_timer[ch]);
+ lights_on[ch] = !lights_on[ch];
+ send_lights(ch);
+ }
+}
+
+static void update_lights_from_ir(int ch, int dir)
+{
+ if (lights_on[ch])
+ lights_brightness[ch] = CLAMP(lights_brightness[ch] + 0.07*dir, 0., 1.);
+ else if (dir > 0)
+ {
+ lights_on[ch] = 1;
+ lights_brightness[ch] = 1;
+ }
+ else
+ {
+ lights_on[ch] = 1;
+ lights_brightness[ch] = 0.05;
+ }
+ send_lights(ch);
+}
+
+static void update_lights_on_off_ir(int ch)
+{
+ lights_on[ch] ^= 1;
+ send_lights(ch);
+}
+
+static void update_lights_temp_ir(void)
+{
+ if (!lights_on[0] && !lights_on[1])
+ return;
+
+ double t = (lights_temperature[0] + lights_temperature[1]) / 2;
+ if (t >= 0.66)
+ t = 0;
+ else if (t < 0.33)
+ t = 0.5;
+ else
+ t = 1;
+ lights_temperature[0] = lights_temperature[1] = t;
+
+ send_lights(0);
+ send_lights(1);
+}
+
+/*** Rainbow ***/
+
+static double rainbow_brightness;
+static timestamp_t rainbow_last_update;
+
+static void update_rainbow(void)
+{
+ noct_set_ring(8, RING_MODE_LEFT, rainbow_brightness * 127);
+}
+
+static void send_rainbow(void)
+{
+ char val[100];
+ snprintf(val, sizeof(val), "%.3f", rainbow_brightness);
+ mqtt_publish("burrow/lights/rainbow/brightness", val);
+ rainbow_last_update = main_get_now();
+ update_rainbow();
+}
+
+static void update_rainbow_from_rotary(int delta)
+{
+ rainbow_brightness = CLAMP(rainbow_brightness + 0.015*delta*abs(delta), 0., 1.);
+ send_rainbow();
+}
+
/*** Main update routines ***/
static struct main_timer update_timer;
if (!want_sleep)
last_touch_time = main_get_now();
timestamp_t since_touch = last_touch_time ? main_get_now() - last_touch_time : 0;
- timestamp_t sleep_in = 5000;
+ timestamp_t sleep_in = 30000;
if (since_touch >= sleep_in)
{
DBG("UPDATE: Sleeping");
}
// Everything normal
- update_ring_from_sink(0, "alsa_output.brum.analog-stereo");
- update_button_from_port(8, "alsa_output.brum.analog-stereo", "analog-output-headphones");
+ update_ring_from_sink(0, PCH_SINK);
+ update_ring_from_sink(1, BT_SINK);
update_groups();
-#if 0
update_default_sink();
-#endif
+ update_source_buttons();
update_mpd();
+ update_lights();
+ update_rainbow();
}
void schedule_update(void)
switch (rotary)
{
case 0:
- update_sink_from_rotary(delta, "alsa_output.brum.analog-stereo");
+ update_sink_from_rotary(delta, PCH_SINK);
+ break;
+ case 1:
+ update_sink_from_rotary(delta, BT_SINK);
+ break;
+ case 2:
+ update_lights_from_rotary(1, delta);
+ break;
+ case 3:
+ update_lights_from_rotary(0, delta);
+ break;
+ case 8:
+ update_rainbow_from_rotary(delta);
+ break;
+ case 9:
+ update_lights_from_slider(delta);
break;
default:
update_group_from_rotary(rotary, delta);
switch (button)
{
case 0:
- update_sink_mute_from_button(on, "alsa_output.brum.analog-stereo");
+ update_sink_mute_from_button(on, PCH_SINK);
break;
- case 8:
- update_port_from_button(on, "alsa_output.brum.analog-stereo", "analog-output-lineout", "analog-output-headphones");
+ case 1:
+ update_sink_mute_from_button(on, BT_SINK);
break;
-#if 0
+ case 2:
+ update_source_mute_from_button(on, LOGI_SOURCE);
+ break;
+ case 8:
case 9:
- case 10:
update_default_sink_from_button(button, on);
break;
-#endif
+ case 10:
+ update_lights_from_button(1, on);
+ break;
+ case 11:
+ update_lights_from_button(0, on);
+ break;
case 12:
update_mpd_from_button(button, on);
break;
}
}
-void notify_touch(int rotary, int on UNUSED)
+void notify_touch(int rotary UNUSED, int on UNUSED)
{
if (!prepare_notify())
return;
schedule_update();
}
+static void notify_ir(const char *key)
+{
+ DBG("Received IR key %s", key);
+
+ // Lights
+ if (!strcmp(key, "preset+"))
+ update_lights_from_ir(1, 1);
+ else if (!strcmp(key, "preset-"))
+ update_lights_from_ir(1, -1);
+ else if (!strcmp(key, "tuning-up"))
+ update_lights_from_ir(0, 1);
+ else if (!strcmp(key, "tuning-down"))
+ update_lights_from_ir(0, -1);
+ else if (!strcmp(key, "band"))
+ update_lights_on_off_ir(1);
+ else if (!strcmp(key, "fm-mode"))
+ update_lights_on_off_ir(0);
+ else if (!strcmp(key, "dimmer"))
+ update_lights_temp_ir();
+
+ // Player
+ else if (!strcmp(key, "play"))
+ mpd_play();
+ else if (!strcmp(key, "stop"))
+ mpd_stop();
+ else if (!strcmp(key, "pause"))
+ mpd_pause(1);
+ else if (!strcmp(key, "prev-song"))
+ mpd_prev();
+ else if (!strcmp(key, "next-song"))
+ mpd_next();
+ else if (!strcmp(key, "rewind"))
+ update_sink_from_rotary(-2, PCH_SINK);
+ else if (!strcmp(key, "ffwd"))
+ update_sink_from_rotary(2, PCH_SINK);
+}
+
+void notify_mqtt(const char *topic, const char *val)
+{
+ const char blc[] = "burrow/lights/catarium/";
+ if (str_has_prefix(topic, blc))
+ {
+ topic += strlen(blc);
+ int ch;
+ if (!strcmp(topic, "top"))
+ ch = 1;
+ else if (!strcmp(topic, "bottom"))
+ ch = 0;
+ else
+ return;
+
+ double b, t;
+ if (sscanf(val, "%lf %lf", &b, &t) != 2)
+ return;
+
+ timestamp_t now = main_get_now();
+ if (!lights_last_update[ch] || lights_last_update[ch] + 1000 < now)
+ {
+ DBG("Received foreign light settings");
+ if (!b)
+ lights_on[ch] = 0;
+ else
+ {
+ lights_on[ch] = 1;
+ lights_brightness[ch] = b;
+ lights_temperature[ch] = t;
+ }
+ update_lights();
+ }
+ }
+
+ if (!strcmp(topic, "burrow/lights/rainbow/brightness"))
+ {
+ double b;
+ if (sscanf(val, "%lf", &b) == 1 && b >= 0 && b <= 1)
+ {
+ timestamp_t now = main_get_now();
+ if (!rainbow_last_update || rainbow_last_update + 1000 < now)
+ {
+ DBG("Received foreign rainbow settings");
+ rainbow_brightness = b;
+ update_rainbow();
+ }
+ }
+ }
+
+ if (!strcmp(topic, "burrow/control/catarium-ir"))
+ notify_ir(val);
+}
+
/*** Main entry point ***/
static int debug;
main_init();
update_timer.handler = do_update;
+ usb_init();
noct_init();
pulse_init();
mpd_init();
+ mqtt_init();
static struct main_signal term_sig = {
.signum = SIGTERM,
projects / ursary.git / blobdiff