add support for output enable/disable

htdocs/index.html

@@ -142,6 +142,8 @@
               <span class="glyphicon glyphicon-repeat"></span> Repeat
             </button>
           </div>
+          <div id="btn-outputs-block" class="btn-group-vertical btn-block btn-group-lg">
+          </div>
 
           <div id="btn-responsive-block" class="btn-group-vertical btn-block btn-group-lg">
             <button type="button" class="btn btn-default" onclick="updateDB();">

htdocs/js/mpd.js

@@ -18,6 +18,7 @@
 
 var socket;
 var last_state;
+var last_outputs;
 var current_app;
 var pagination = 0;
 var browsepath;
@@ -130,6 +131,8 @@ function webSocketConnect() {
             }).show();
 
             app.run();
+            /* emit initial request for output names */
+            socket.send("MPD_API_GET_OUTPUTS");
         }
 
         socket.onmessage = function got_packet(msg) {
@@ -337,6 +340,26 @@ function webSocketConnect() {
 
                     last_state = obj;
                     break;
+                case "outputnames":
+                    $('#btn-outputs-block button').remove();
+                    $.each(obj.data, function(id, name){
+                        var btn = $('<button id="btnoutput'+id+'" class="btn btn-default" onclick="toggleoutput(this, '+id+')"><span class="glyphicon glyphicon-volume-up"></span> '+name+'</button>');
+                        btn.appendTo($('#btn-outputs-block'));
+                    });
+                    /* remove cache, since the buttons have been recreated */
+                    last_outputs = '';
+                    break;
+                case "outputs":
+                    if(JSON.stringify(obj) === JSON.stringify(last_outputs))
+                        break;
+                    $.each(obj.data, function(id, enabled){
+                        if (enabled)
+                        $('#btnoutput'+id).addClass("active");
+                        else
+                        $('#btnoutput'+id).removeClass("active");
+                    });
+                    last_outputs = obj;
+                    break;
                 case "disconnected":
                     if($('.top-right').has('div').length == 0)
                         $('.top-right').notify({
@@ -500,6 +523,10 @@ $('#btnrepeat').on('click', function (e) {
     socket.send("MPD_API_TOGGLE_REPEAT," + ($(this).hasClass('active') ? 0 : 1));
 });
 
+function toggleoutput(button, id) {
+    socket.send("MPD_API_TOGGLE_OUTPUT,"+id+"," + ($(button).hasClass('active') ? 0 : 1));
+}
+
 $('#btnnotify').on('click', function (e) {
     if($.cookie("notification") === "true") {
         $.cookie("notification", false);

src/mpd_client.c

@@ -27,6 +27,9 @@
 #include "config.h"
 #include "json_encode.h"
 
+/* forward declaration */
+static int mpd_notify_callback(struct mg_connection *c, enum mg_event ev);
+
 const char * mpd_cmd_strs[] = {
     MPD_CMDS(GEN_STR)
 };
@@ -106,6 +109,19 @@ int callback_mpd(struct mg_connection *c)
             if(sscanf(c->content, "MPD_API_TOGGLE_CROSSFADE,%u", &uint_buf))
                 mpd_run_crossfade(mpd.conn, uint_buf);
             break;
+        case MPD_API_GET_OUTPUTS:
+            mpd.buf_size = mpd_put_outputnames(mpd.buf);
+            c->callback_param = NULL;
+            mpd_notify_callback(c, MG_POLL);
+            break;
+        case MPD_API_TOGGLE_OUTPUT:
+            if (sscanf(c->content, "MPD_API_TOGGLE_OUTPUT,%u,%u", &uint_buf, &uint_buf_2)) {
+                if (uint_buf_2)
+                    mpd_run_enable_output(mpd.conn, uint_buf);
+                else
+                    mpd_run_disable_output(mpd.conn, uint_buf);
+            }
+            break;
         case MPD_API_SET_VOLUME:
             if(sscanf(c->content, "MPD_API_SET_VOLUME,%ud", &uint_buf) && uint_buf <= 100)
                 mpd_run_set_volume(mpd.conn, uint_buf);
@@ -339,6 +355,13 @@ void mpd_poll(struct mg_server *s)
             fprintf(stderr, "MPD connected.\n");
             mpd_connection_set_timeout(mpd.conn, 10000);
             mpd.conn_state = MPD_CONNECTED;
+            /* write outputs */
+            mpd.buf_size = mpd_put_outputnames(mpd.buf);
+            for (struct mg_connection *c = mg_next(s, NULL); c != NULL; c = mg_next(s, c))
+            {
+                c->callback_param = NULL;
+                mpd_notify_callback(c, MG_POLL);
+            }
             break;
 
         case MPD_FAILURE:
@@ -359,6 +382,12 @@ void mpd_poll(struct mg_server *s)
                 c->callback_param = NULL;
                 mpd_notify_callback(c, MG_POLL);
             }
+            mpd.buf_size = mpd_put_outputs(mpd.buf);
+            for (struct mg_connection *c = mg_next(s, NULL); c != NULL; c = mg_next(s, c))
+            {
+                c->callback_param = NULL;
+                mpd_notify_callback(c, MG_POLL);
+            }
             break;
     }
 }
@@ -412,6 +441,67 @@ int mpd_put_state(char *buffer, int *current_song_id, unsigned *queue_version)
     return len;
 }
 
+int mpd_put_outputs(char *buffer)
+{
+    struct mpd_output *out;
+    static int *outputs;
+    static int soutputs;
+    int idx, maxidx;
+    char *str, *strend;
+
+    maxidx = 0;
+    mpd_send_outputs(mpd.conn);
+    while ((out = mpd_recv_output(mpd.conn)) != NULL) {
+        idx = mpd_output_get_id(out);
+        if (idx >= soutputs) {
+            /* realloc some more */
+            soutputs = (idx + 15) & ~15; /* round up to 16 */
+            outputs = realloc(outputs, sizeof(*outputs)*soutputs);
+            if (!outputs)
+                exit(1);
+        }
+        if (idx > maxidx)
+            maxidx = idx;
+        outputs[idx] = mpd_output_get_enabled(out);
+        mpd_output_free(out);
+    }
+    mpd_response_finish(mpd.conn);
+
+    str = buffer;
+    strend = buffer+MAX_SIZE;
+    str += snprintf(str, strend-str, "{\"type\":\"outputs\", \"data\":{");
+    for (idx = 0; idx <= maxidx; ++idx)
+        str += snprintf(str, strend-str, "%c \"%d\":%d",
+                idx ? ',' : ' ', idx, outputs[idx]);
+    str += snprintf(str, strend-str, " }}");
+    return str-buffer;
+}
+
+int mpd_put_outputnames(char *buffer)
+{
+    struct mpd_output *out;
+    int nout;
+    char *str, *strend;
+
+    str = buffer;
+    strend = buffer+MAX_SIZE;
+    str += snprintf(str, strend-str, "{\"type\":\"outputnames\", \"data\":{");
+
+    mpd_send_outputs(mpd.conn);
+    nout = 0;
+    while ((out = mpd_recv_output(mpd.conn)) != NULL) {
+        if (nout++)
+            *str++ = ',';
+        str += snprintf(str, strend - str, " \"%d\":\"%s\"",
+                mpd_output_get_id(out),
+                mpd_output_get_name(out));
+        mpd_output_free(out);
+    }
+    mpd_response_finish(mpd.conn);
+    str += snprintf(str, strend-str, " }}");
+    return str-buffer;
+}
+
 int mpd_put_current_song(char *buffer)
 {
     char *cur = buffer;

src/mpd_client.h

@@ -57,6 +57,8 @@
     X(MPD_API_SET_MPDHOST) \
     X(MPD_API_SET_MPDPASS) \
     X(MPD_API_UPDATE_DB) \
+    X(MPD_API_GET_OUTPUTS) \
+    X(MPD_API_TOGGLE_OUTPUT) \
     X(MPD_API_TOGGLE_RANDOM) \
     X(MPD_API_TOGGLE_CONSUME) \
     X(MPD_API_TOGGLE_SINGLE) \
@@ -100,6 +102,8 @@ void mpd_poll(struct mg_server *s);
 int callback_mpd(struct mg_connection *c);
 int mpd_close_handler(struct mg_connection *c);
 int mpd_put_state(char *buffer, int *current_song_id, unsigned *queue_version);
+int mpd_put_outputs(char *buffer);
+int mpd_put_outputnames(char *buffer);
 int mpd_put_current_song(char *buffer);
 int mpd_put_queue(char *buffer, unsigned int offset);
 int mpd_put_browse(char *buffer, char *path, unsigned int offset);