Add audio sink selection dropdown to general settings

common/wireplumber.c

@@ -0,0 +1,160 @@
+#include <stdio.h>
+#include <unistd.h>
+#include <fcntl.h>
+#include <string.h>
+#include <stdlib.h>
+#include "json/json.h"
+#include "wireplumber.h"
+
+#include <errno.h>
+
+#include "common.h"
+#include "log.h"
+
+static int parse_json_to_sinks(const char *json_output, Sink **sinks, int *count);
+
+int get_sinks(Sink **sinks, int *count) {
+    printf("Executing pw-dump command to retrieve sinks...\n");
+
+    FILE *fp = popen("pw-dump", "r");
+    if (!fp) {
+        LOG_ERROR(mux_module, "Failed to run pw-dump: %s", strerror(errno));
+        return -1;
+    }
+
+    char *json_output = NULL;
+    size_t json_size = 0;
+    char buffer[512];
+
+    while (fgets(buffer, sizeof(buffer), fp)) {
+        size_t line_length = strlen(buffer);
+        char *new_output = realloc(json_output, json_size + line_length + 1);
+        if (!new_output) {
+            LOG_ERROR(mux_module, "Failed to allocate memory for JSON buffer: %s", strerror(errno));
+            free(json_output);
+            pclose(fp);
+            return -1;
+        }
+        json_output = new_output;
+        memcpy(json_output + json_size, buffer, line_length);
+        json_size += line_length;
+        json_output[json_size] = '\0';
+    }
+    pclose(fp);
+
+    if (!json_output) {
+        fprintf(stderr, "Failed to retrieve JSON output from pw-dump\n");
+        return -1;
+    }
+
+    int result = parse_json_to_sinks(json_output, sinks, count);
+    free(json_output);
+
+    return result;
+}
+
+static int parse_json_to_sinks(const char *json_output, Sink **sinks, int *count) {
+    struct json root = json_parse(json_output);
+    if (!json_exists(root) || json_type(root) != JSON_ARRAY) {
+        fprintf(stderr, "Failed to parse JSON or JSON is not an array\n");
+        return -1;
+    }
+
+    *sinks = NULL;
+    *count = 0;
+
+    size_t total_items = json_array_count(root);
+    for (size_t i = 0; i < total_items; i++) {
+        struct json item = json_array_get(root, i);
+        if (json_type(item) != JSON_OBJECT) {
+            continue;
+        }
+
+        struct json info = json_object_get(item, "info");
+        if (!json_exists(info) || json_type(info) != JSON_OBJECT) {
+            continue;
+        }
+
+        struct json props = json_object_get(info, "props");
+        if (!json_exists(props) || json_type(props) != JSON_OBJECT) {
+            continue;
+        }
+
+        struct json media_class = json_object_get(props, "media.class");
+        if (!json_exists(media_class) || json_type(media_class) != JSON_STRING ||
+            json_string_compare(media_class, "Audio/Sink") != 0) {
+            continue;
+        }
+
+        struct json description = json_object_get(props, "node.description");
+        struct json nick = json_object_get(props, "node.nick");
+        struct json name = json_object_get(props, "node.name");
+        struct json object_id = json_object_get(item, "id");
+
+        if (!json_exists(description) || !json_exists(object_id) || json_type(object_id) != JSON_NUMBER) {
+            continue;
+        }
+
+        Sink sink = {0};
+        sink.id = json_int(object_id);
+        json_string_copy(description, sink.description, sizeof(sink.description));
+        if (json_exists(nick)) {
+            json_string_copy(nick, sink.nick, sizeof(sink.nick));
+        } else {
+            strncpy(sink.nick, "Unknown", sizeof(sink.nick));
+        }
+        if (json_exists(name)) {
+            json_string_copy(name, sink.name, sizeof(sink.name));
+        } else {
+            strncpy(sink.name, "Unknown", sizeof(sink.name));
+        }
+
+        // Allocate memory for the new sink
+        Sink *new_sinks = realloc(*sinks, (*count + 1) * sizeof(Sink));
+        if (!new_sinks) {
+            LOG_ERROR(mux_module, "Failed to allocate memory for sinks array: %s", strerror(errno));
+            free(*sinks);
+            return -1;
+        }
+
+        *sinks = new_sinks;
+        (*sinks)[*count] = sink;
+        (*count)++;
+    }
+
+    return 0;
+}
+
+int get_default_sink_id(int *sink_id) {
+    const char* command = "wpctl status | grep -A 5 Sinks | grep '\\*' | sed 's/ \\|.*\\*   //' | cut -f1 -d'.'";
+    FILE *fp = popen(command, "r");
+    if (fp == NULL) {
+        LOG_ERROR(mux_module, "Failed to run command: %s", strerror(errno));
+        return -1;
+    }
+
+    char buffer[128];
+    if (fgets(buffer, sizeof(buffer), fp) != NULL) {
+        buffer[strcspn(buffer, "\n")] = '\0';
+        *sink_id = atoi(buffer);
+    } else {
+        LOG_ERROR(mux_module, "Failed to read sink ID: %s", strerror(errno));
+        pclose(fp);
+        return -1;
+    }
+
+    pclose(fp);
+    return 0;
+}
+
+int set_default_sink(int sink_id) {
+    char command[256];
+    snprintf(command, sizeof(command), "wpctl set-default %d", sink_id);
+    LOG_INFO(mux_module, "Executing command: %s", command);
+    int result = system(command);
+    if (result != 0) {
+        LOG_ERROR(mux_module, "Failed to execute command: %s", strerror(errno));
+    }
+    LOG_INFO(mux_module, "Command result: %d", result);
+    return result;
+}

common/wireplumber.h

@@ -0,0 +1,13 @@
+#pragma once
+
+typedef struct
+{
+    int id;
+    char description[256];
+    char nick[256];
+    char name[256];
+} Sink;
+
+int get_sinks(Sink** sinks, int* count);
+int get_default_sink_id(int *sink_id);
+int set_default_sink(int sink_id);