paoutput.c: input processing and implementation of sink list

.gitignore

@@ -1,5 +1,6 @@
 # Binaries
 test
+paoutput
 
 # ---> C
 # Prerequisites

Makefile

@@ -2,12 +2,16 @@ CC=gcc
 
 LDLIBS=-lpulse
 
+CFLAGS=-g
+
 all: test
 
 test:
-	gcc -o test -g -lpulse test.cpp
+	gcc -o test -g -lpulse test.c
+
+paoutput:
 
 clean:
-	rm -f *.o test
+	rm -f *.o test paoutput
 
 .PHONY: all clean

paoutput.c

@@ -0,0 +1,131 @@
+/* paoutput.c
+ *
+ * PulseAudio output switcher, intended for use with dmenu.
+ *
+ * Usage: paoutput <-g | -s [new_sink]>
+ * Options:
+ * -g: Get a newline separated list of available sinks
+ * -s [new_sink]: Set all active streams to use the new sink.
+ *                If new_sink is not given, it will be read from stdin.
+ */
+
+#include <stdio.h>
+#include <string.h>
+
+#include<pulse/pulseaudio.h>
+
+
+char *usage_string =
+    "Usage: paoutput <-g | -s [new_sink]>\n"    \
+    "Options:\n"\
+    "-g: Get a newline separated list of available sinks\n"\
+    "-s [new_sink]: Set all active streams to use the new sink.\n"\
+    "               If new_sink is not given, it will be read from stdin.\n";
+
+enum action {GET, SET, SET_STDIN};
+
+#define N_SINKS 10
+#define N_SINK_INPUTS 30
+int sink_end = 0;
+int sink_in_end = 0;
+pa_sink_info sinks[N_SINKS];
+pa_sink_input_info sink_inputs[N_SINK_INPUTS];
+
+enum action action;
+int sink_index;
+int done = 0;
+
+void sink_callback(pa_context *c, const pa_sink_info *i, int eol, void *userdata) {
+    if (sink_end != N_SINKS && i != NULL) {
+        memcpy(&sinks[sink_end], i, sizeof(pa_sink_info));
+        sink_end++;
+    }
+    if (i == NULL) {
+        if (action == GET) {
+            for (int i = 0; i < sink_end; i++) {
+                printf("%d: %s\n", sinks[i].index, sinks[i].description);
+            }
+            done = 1;
+            return;
+        }
+    }
+}
+
+void sink_input_callback(pa_context *c, const pa_sink_input_info *i, int eol, void *userdata) {
+
+}
+
+void context_state_callback(pa_context *c, void *userdata) {
+    switch(pa_context_get_state(c)) {
+    case PA_CONTEXT_UNCONNECTED:
+    case PA_CONTEXT_CONNECTING:
+    case PA_CONTEXT_AUTHORIZING:
+    case PA_CONTEXT_SETTING_NAME:
+        break;
+    case PA_CONTEXT_READY:
+        {
+            pa_operation *o1 = pa_context_get_sink_info_list(c, sink_callback, userdata);
+            if (!o1) dprintf(2, "Failed to get sink info.\n");
+
+            if (action != GET) {
+                pa_operation *o2 = pa_context_get_sink_input_info_list(c, sink_input_callback, userdata);
+                if (!o2) dprintf(2, "Failed to get sink info.\n");
+            }
+        }
+        break;
+    case PA_CONTEXT_FAILED:
+        dprintf(2, "Failed to connect to PulseAudio server.\n");
+        break;
+    case PA_CONTEXT_TERMINATED:
+        dprintf(2, "Connection to PulseAudio server terminated.\n");
+        break;
+    }
+}
+
+int main(int argc, char **argv) {
+    if (argc < 2) {
+        printf("%s", usage_string);
+        return 0;
+    }
+
+    if (strncmp(argv[1], "-g", 2) == 0) {
+        action = GET;
+    } else if (strncmp(argv[1], "-s", 2) == 0) {
+        action = (argc == 2)? SET_STDIN : SET;
+        if (action == SET) {
+            printf("%s\n", argv[2]);
+            sink_index = strtol(argv[2], NULL, 10);
+        } else {
+            scanf("%d", &sink_index);
+            printf("index = %d\n", sink_index);
+        }
+    } else {
+        printf("%s", usage_string);
+        return 0;
+    }
+
+    pa_context *context;
+    pa_mainloop *ml;
+    pa_mainloop_api *api;
+
+    ml = pa_mainloop_new();
+    api = pa_mainloop_get_api(ml);
+
+    context = pa_context_new(api, "PulseAudio Output Select");
+    if (!context) {
+        dprintf(2, "Failed to create PulseAudio context.\n");
+        exit(1);
+    }
+
+    pa_context_set_state_callback(context, context_state_callback, ml);
+
+    if (pa_context_connect(context, NULL, PA_CONTEXT_NOFAIL, NULL) < 0) {
+        dprintf(2, "Connection to PulseAudio Server failed.\n");
+        exit(1);
+    }
+
+    int r;
+    while (!done) {
+        pa_mainloop_iterate(ml, 0, &r);
+    }
+}