diff options
Diffstat (limited to 'src/platform/freedesktop')
| -rw-r--r-- | src/platform/freedesktop/dbus.c | 187 | ||||
| -rw-r--r-- | src/platform/freedesktop/dbus.h | 16 | ||||
| -rw-r--r-- | src/platform/freedesktop/desktop.c | 150 | ||||
| -rw-r--r-- | src/platform/freedesktop/meson.build | 1 |
4 files changed, 354 insertions, 0 deletions
diff --git a/src/platform/freedesktop/dbus.c b/src/platform/freedesktop/dbus.c new file mode 100644 index 0000000..abca900 --- /dev/null +++ b/src/platform/freedesktop/dbus.c @@ -0,0 +1,187 @@ +#define _GNU_SOURCE +#include "platform/freedesktop/dbus.h" + +#if YASL_HAS_DBUS + +#include <dbus/dbus.h> +#include <stdio.h> +#include <stdlib.h> +#include <string.h> +#include <sys/stat.h> + +/* The portal may need activation on first use; bound how long a query blocks. */ +#define PORTAL_TIMEOUT_MS 1000 + +static DBusConnection *bus; + +/* The session bus address, without libdbus's X11 autolaunch fallback. */ +static char *session_address(void) +{ + const char *env = getenv("DBUS_SESSION_BUS_ADDRESS"); + if (env && *env) return strdup(env); + const char *run = getenv("XDG_RUNTIME_DIR"); + if (!run || !*run) return NULL; + char path[4096]; + struct stat st; + if (snprintf(path, sizeof(path), "%s/bus", run) >= (int)sizeof(path) || + stat(path, &st) != 0 || !S_ISSOCK(st.st_mode)) + return NULL; + char *escaped = dbus_address_escape_value(path); + if (!escaped) return NULL; + char *address = NULL; + if (asprintf(&address, "unix:path=%s", escaped) < 0) address = NULL; + dbus_free(escaped); + return address; +} + +static DBusConnection *session_bus(void) +{ + if (bus && dbus_connection_get_is_connected(bus)) return bus; + if (bus) { + dbus_connection_close(bus); + dbus_connection_unref(bus); + bus = NULL; + } + char *address = session_address(); + if (!address) return NULL; + DBusError err; + dbus_error_init(&err); + DBusConnection *c = dbus_connection_open_private(address, &err); + free(address); + if (!c) { + dbus_error_free(&err); + return NULL; + } + dbus_connection_set_exit_on_disconnect(c, FALSE); + if (!dbus_bus_register(c, &err)) { + dbus_error_free(&err); + dbus_connection_close(c); + dbus_connection_unref(c); + return NULL; + } + bus = c; + return bus; +} + +bool bus_notify(const char *app, const char *title, const char *body) +{ + DBusConnection *c = session_bus(); + if (!c) return false; + DBusMessage *msg = dbus_message_new_method_call("org.freedesktop.Notifications", + "/org/freedesktop/Notifications", "org.freedesktop.Notifications", "Notify"); + if (!msg) return false; + + const char *icon = ""; + dbus_uint32_t replaces = 0; + dbus_int32_t expire = -1; + DBusMessageIter it, sub, entry, value; + dbus_message_iter_init_append(msg, &it); + bool ok = dbus_message_iter_append_basic(&it, DBUS_TYPE_STRING, &app) && + dbus_message_iter_append_basic(&it, DBUS_TYPE_UINT32, &replaces) && + dbus_message_iter_append_basic(&it, DBUS_TYPE_STRING, &icon) && + dbus_message_iter_append_basic(&it, DBUS_TYPE_STRING, &title) && + dbus_message_iter_append_basic(&it, DBUS_TYPE_STRING, &body); + /* No actions. */ + ok = ok && dbus_message_iter_open_container(&it, DBUS_TYPE_ARRAY, "s", &sub) && + dbus_message_iter_close_container(&it, &sub); + /* Hints: desktop-entry names the application's .desktop file. */ + const char *hint = "desktop-entry"; + ok = ok && dbus_message_iter_open_container(&it, DBUS_TYPE_ARRAY, "{sv}", &sub) && + dbus_message_iter_open_container(&sub, DBUS_TYPE_DICT_ENTRY, NULL, &entry) && + dbus_message_iter_append_basic(&entry, DBUS_TYPE_STRING, &hint) && + dbus_message_iter_open_container(&entry, DBUS_TYPE_VARIANT, "s", &value) && + dbus_message_iter_append_basic(&value, DBUS_TYPE_STRING, &app) && + dbus_message_iter_close_container(&entry, &value) && + dbus_message_iter_close_container(&sub, &entry) && + dbus_message_iter_close_container(&it, &sub); + ok = ok && dbus_message_iter_append_basic(&it, DBUS_TYPE_INT32, &expire); + + if (ok) { + dbus_message_set_no_reply(msg, TRUE); + ok = dbus_connection_send(c, msg, NULL); + if (ok) dbus_connection_flush(c); + } + dbus_message_unref(msg); + return ok; +} + +/* Read an integer from it, unwrapping variants: Settings.Read nests one more. */ +static bool iter_int(DBusMessageIter *it, int64_t *out) +{ + DBusMessageIter inner[4]; + int depth = 0; + while (dbus_message_iter_get_arg_type(it) == DBUS_TYPE_VARIANT && depth < 4) { + dbus_message_iter_recurse(it, &inner[depth]); + it = &inner[depth++]; + } + DBusBasicValue v; + switch (dbus_message_iter_get_arg_type(it)) { + case DBUS_TYPE_BYTE: dbus_message_iter_get_basic(it, &v); *out = v.byt; return true; + case DBUS_TYPE_BOOLEAN: dbus_message_iter_get_basic(it, &v); *out = v.bool_val; return true; + case DBUS_TYPE_INT16: dbus_message_iter_get_basic(it, &v); *out = v.i16; return true; + case DBUS_TYPE_UINT16: dbus_message_iter_get_basic(it, &v); *out = v.u16; return true; + case DBUS_TYPE_INT32: dbus_message_iter_get_basic(it, &v); *out = v.i32; return true; + case DBUS_TYPE_UINT32: dbus_message_iter_get_basic(it, &v); *out = v.u32; return true; + case DBUS_TYPE_INT64: dbus_message_iter_get_basic(it, &v); *out = v.i64; return true; + case DBUS_TYPE_UINT64: + dbus_message_iter_get_basic(it, &v); + if (v.u64 > INT64_MAX) return false; + *out = (int64_t)v.u64; + return true; + default: return false; + } +} + +bool portal_read_int(const char *ns, const char *key, int64_t *out) +{ + DBusConnection *c = session_bus(); + if (!c) return false; + /* ReadOne is portal version 2; older portals only have Read. */ + static const char *const methods[] = {"ReadOne", "Read"}; + for (int i = 0; i < 2; i++) { + DBusMessage *msg = dbus_message_new_method_call("org.freedesktop.portal.Desktop", + "/org/freedesktop/portal/desktop", "org.freedesktop.portal.Settings", methods[i]); + if (!msg) return false; + if (!dbus_message_append_args(msg, DBUS_TYPE_STRING, &ns, DBUS_TYPE_STRING, &key, + DBUS_TYPE_INVALID)) { + dbus_message_unref(msg); + return false; + } + DBusError err; + dbus_error_init(&err); + DBusMessage *reply = dbus_connection_send_with_reply_and_block(c, msg, + PORTAL_TIMEOUT_MS, &err); + dbus_message_unref(msg); + if (!reply) { + bool retry = dbus_error_has_name(&err, DBUS_ERROR_UNKNOWN_METHOD); + dbus_error_free(&err); + if (retry) continue; + return false; + } + DBusMessageIter it; + bool ok = dbus_message_iter_init(reply, &it) && iter_int(&it, out); + dbus_message_unref(reply); + return ok; + } + return false; +} + +#else + +bool bus_notify(const char *app, const char *title, const char *body) +{ + (void)app; + (void)title; + (void)body; + return false; +} + +bool portal_read_int(const char *ns, const char *key, int64_t *out) +{ + (void)ns; + (void)key; + (void)out; + return false; +} + +#endif diff --git a/src/platform/freedesktop/dbus.h b/src/platform/freedesktop/dbus.h new file mode 100644 index 0000000..3b1662b --- /dev/null +++ b/src/platform/freedesktop/dbus.h @@ -0,0 +1,16 @@ +#ifndef YASL_FREEDESKTOP_DBUS_H +#define YASL_FREEDESKTOP_DBUS_H + +#include <stdbool.h> +#include <stdint.h> + +/* Session-bus helpers. The first call opens a private connection that later + * calls reuse. Each returns false when YASL is built without libdbus-1 or no + * session bus is reachable. Call from one thread at a time. */ + +/* Send org.freedesktop.Notifications.Notify without waiting for a reply. */ +bool bus_notify(const char *app, const char *title, const char *body); +/* Read an integer setting through the XDG Settings portal, waiting briefly. */ +bool portal_read_int(const char *ns, const char *key, int64_t *out); + +#endif diff --git a/src/platform/freedesktop/desktop.c b/src/platform/freedesktop/desktop.c new file mode 100644 index 0000000..a8b9bc7 --- /dev/null +++ b/src/platform/freedesktop/desktop.c @@ -0,0 +1,150 @@ +#define _GNU_SOURCE +#include "common/desktop.h" +#include "platform/freedesktop/dbus.h" +#include "yasl/desktop.h" + +#include <errno.h> +#include <fcntl.h> +#include <signal.h> +#include <stdlib.h> +#include <string.h> +#include <sys/syscall.h> +#include <sys/wait.h> +#include <unistd.h> + +extern char **environ; + +static size_t copy_str(char *buf, size_t cap, const char *s) +{ + size_t len = strlen(s); + if (!len || len >= cap) return 0; + memcpy(buf, s, len + 1); + return len; +} + +/* Find an executable in PATH, like execvp but before forking. */ +static bool find_program(const char *name, char *out, size_t cap) +{ + const char *path = getenv("PATH"); + if (!path || !*path) path = "/usr/local/bin:/usr/bin:/bin"; + size_t name_len = strlen(name); + while (*path) { + const char *end = strchr(path, ':'); + size_t dir_len = end ? (size_t)(end - path) : strlen(path); + if (dir_len && dir_len + 1 + name_len < cap) { + memcpy(out, path, dir_len); + out[dir_len] = '/'; + memcpy(out + dir_len + 1, name, name_len + 1); + if (access(out, X_OK) == 0) return true; + } + if (!end) break; + path = end + 1; + } + return false; +} + +bool desktop_open_uri(const char *uri) +{ + char program[4096]; + if (!find_program("xdg-open", program, sizeof(program))) return false; + char *argv[] = {"xdg-open", (char *)uri, NULL}; + + /* Prepare everything before fork: the children of a threaded process may + * only make async-signal-safe calls. */ + struct sigaction dfl = {.sa_handler = SIG_DFL}; + sigemptyset(&dfl.sa_mask); + sigset_t none; + sigemptyset(&none); + long max_fd = sysconf(_SC_OPEN_MAX); + if (max_fd < 0 || max_fd > 65536) max_fd = 65536; + + /* The middle child exits at once, so the opener is reparented away from + * the application and never needs reaping here. */ + pid_t pid = fork(); + if (pid < 0) return false; + if (pid == 0) { + setsid(); + pid_t opener = fork(); + if (opener != 0) _exit(opener < 0 ? 1 : 0); + for (int sig = 1; sig < NSIG; sig++) + if (sig != SIGKILL && sig != SIGSTOP) sigaction(sig, &dfl, NULL); + sigprocmask(SIG_SETMASK, &none, NULL); + int null = open("/dev/null", O_RDONLY); + if (null > 0) { + dup2(null, STDIN_FILENO); + close(null); + } + /* Keep application descriptors, such as pty masters, out of the opener. */ +#ifdef SYS_close_range + if (syscall(SYS_close_range, 3u, ~0u, 0u) != 0) +#endif + for (int fd = 3; fd < max_fd; fd++) close(fd); + execve(program, argv, environ); + _exit(127); + } + + int status; + pid_t done; + do { + done = waitpid(pid, &status, 0); + } while (done < 0 && errno == EINTR); + /* An application reaper can collect the middle child first. */ + if (done < 0) return errno == ECHILD; + return WIFEXITED(status) && WEXITSTATUS(status) == 0; +} + +bool desktop_notify(const char *app_id, const char *title, const char *body) +{ + return bus_notify(app_id ? app_id : "yasl", title, body); +} + +uint32_t desktop_appearance(void) +{ + uint32_t flags = 0; + bool portal = false; + int64_t value; + if (portal_read_int("org.freedesktop.appearance", "color-scheme", &value)) { + portal = true; + if (value == 1) flags |= YASL_APPEARANCE_DARK; + else if (value == 2) flags |= YASL_APPEARANCE_LIGHT; + } + if (portal_read_int("org.freedesktop.appearance", "contrast", &value)) { + portal = true; + if (value == 1) flags |= YASL_APPEARANCE_HIGH_CONTRAST; + } + if (portal) return flags; + + /* GTK_THEME is "Name" or "Name:variant", as in "Adwaita:dark". */ + const char *theme = getenv("GTK_THEME"); + if (!theme) return 0; + if (strstr(theme, "HighContrast")) flags |= YASL_APPEARANCE_HIGH_CONTRAST; + if (strstr(theme, ":dark") || strstr(theme, "HighContrastInverse")) + flags |= YASL_APPEARANCE_DARK; + return flags; +} + +size_t desktop_executable_path(char *buf, size_t cap) +{ + /* readlink truncates silently, so a full buffer may hold a cut path. */ + ssize_t len = readlink("/proc/self/exe", buf, cap); + if (len <= 0 || (size_t)len >= cap) return 0; + buf[len] = '\0'; + return (size_t)len; +} + +size_t desktop_resource_dir(char *buf, size_t cap) +{ + (void)buf; + (void)cap; + return 0; +} + +size_t desktop_default_locale(char *buf, size_t cap) +{ + static const char *const vars[] = {"LC_ALL", "LC_CTYPE", "LANG"}; + for (size_t i = 0; i < sizeof(vars) / sizeof(vars[0]); i++) { + const char *v = getenv(vars[i]); + if (v && *v) return copy_str(buf, cap, v); + } + return copy_str(buf, cap, "C.UTF-8"); +} diff --git a/src/platform/freedesktop/meson.build b/src/platform/freedesktop/meson.build new file mode 100644 index 0000000..6f43895 --- /dev/null +++ b/src/platform/freedesktop/meson.build @@ -0,0 +1 @@ +sources += files('desktop.c', 'dbus.c') |
