diff options
Diffstat (limited to 'raveos-theme/hyprland/theme-data/DankMaterialShell/quickshell/Services/DMSService.qml')
| -rw-r--r-- | raveos-theme/hyprland/theme-data/DankMaterialShell/quickshell/Services/DMSService.qml | 757 |
1 files changed, 757 insertions, 0 deletions
diff --git a/raveos-theme/hyprland/theme-data/DankMaterialShell/quickshell/Services/DMSService.qml b/raveos-theme/hyprland/theme-data/DankMaterialShell/quickshell/Services/DMSService.qml new file mode 100644 index 0000000..217b96a --- /dev/null +++ b/raveos-theme/hyprland/theme-data/DankMaterialShell/quickshell/Services/DMSService.qml @@ -0,0 +1,757 @@ +pragma Singleton +pragma ComponentBehavior: Bound + +import QtQuick +import Quickshell +import Quickshell.Io +import qs.Common + +Singleton { + id: root + + property bool dmsAvailable: false + property var capabilities: [] + property int apiVersion: 0 + property string cliVersion: "" + readonly property int expectedApiVersion: 1 + property var availablePlugins: [] + property var installedPlugins: [] + property var availableThemes: [] + property var installedThemes: [] + property bool isConnected: false + property bool isConnecting: false + property bool subscribeConnected: false + readonly property bool forceExtWorkspace: false + + readonly property string socketPath: Quickshell.env("DMS_SOCKET") + + property var pendingRequests: ({}) + property var clipboardRequestIds: ({}) + property int requestIdCounter: 0 + property bool shownOutdatedError: false + property string updateCommand: "dms update" + property bool checkingUpdateCommand: false + + signal pluginsListReceived(var plugins) + signal installedPluginsReceived(var plugins) + signal searchResultsReceived(var plugins) + signal themesListReceived(var themes) + signal installedThemesReceived(var themes) + signal themeSearchResultsReceived(var themes) + signal operationSuccess(string message) + signal operationError(string error) + signal connectionStateChanged + + signal networkStateUpdate(var data) + signal cupsStateUpdate(var data) + signal loginctlStateUpdate(var data) + signal loginctlEvent(var event) + signal capabilitiesReceived + signal credentialsRequest(var data) + signal bluetoothPairingRequest(var data) + signal dwlStateUpdate(var data) + signal brightnessStateUpdate(var data) + signal brightnessDeviceUpdate(var device) + signal extWorkspaceStateUpdate(var data) + signal wlrOutputStateUpdate(var data) + signal evdevStateUpdate(var data) + signal gammaStateUpdate(var data) + signal themeAutoStateUpdate(var data) + signal openUrlRequested(string url) + signal appPickerRequested(var data) + signal screensaverStateUpdate(var data) + signal clipboardStateUpdate(var data) + signal locationStateUpdate(var data) + + property bool capsLockState: false + property bool screensaverInhibited: false + property var screensaverInhibitors: [] + + property var activeSubscriptions: ["network", "network.credentials", "loginctl", "freedesktop", "freedesktop.screensaver", "gamma", "theme.auto", "bluetooth", "bluetooth.pairing", "dwl", "brightness", "wlroutput", "evdev", "browser", "dbus", "clipboard", "location"] + + Component.onCompleted: { + if (socketPath && socketPath.length > 0) { + detectUpdateCommand(); + } + } + + function detectUpdateCommand() { + checkingUpdateCommand = true; + checkAurHelper.running = true; + } + + function startSocketConnection() { + if (socketPath && socketPath.length > 0) { + testProcess.running = true; + } + } + + Process { + id: checkAurHelper + command: ["sh", "-c", "command -v paru || command -v yay"] + running: false + + stdout: StdioCollector { + onStreamFinished: { + const helper = text.trim(); + if (helper.includes("paru")) { + checkDmsPackage.helper = "paru"; + checkDmsPackage.running = true; + } else if (helper.includes("yay")) { + checkDmsPackage.helper = "yay"; + checkDmsPackage.running = true; + } else { + updateCommand = "dms update"; + checkingUpdateCommand = false; + startSocketConnection(); + } + } + } + + onExited: exitCode => { + if (exitCode !== 0) { + updateCommand = "dms update"; + checkingUpdateCommand = false; + startSocketConnection(); + } + } + } + + Process { + id: checkDmsPackage + property string helper: "" + command: ["sh", "-c", "pacman -Qi dms-shell-git 2>/dev/null || pacman -Qi dms-shell-bin 2>/dev/null"] + running: false + + stdout: StdioCollector { + onStreamFinished: { + if (text.includes("dms-shell-git")) { + updateCommand = checkDmsPackage.helper + " -S dms-shell-git"; + } else if (text.includes("dms-shell-bin")) { + updateCommand = checkDmsPackage.helper + " -S dms-shell-bin"; + } else { + updateCommand = "dms update"; + } + checkingUpdateCommand = false; + startSocketConnection(); + } + } + + onExited: exitCode => { + if (exitCode !== 0) { + updateCommand = "dms update"; + checkingUpdateCommand = false; + startSocketConnection(); + } + } + } + + Process { + id: testProcess + command: ["test", "-S", root.socketPath] + + onExited: exitCode => { + if (exitCode === 0) { + root.dmsAvailable = true; + connectSocket(); + } else { + root.dmsAvailable = false; + } + } + } + + function connectSocket() { + if (!dmsAvailable || isConnected || isConnecting) { + return; + } + + isConnecting = true; + requestSocket.connected = true; + } + + DankSocket { + id: requestSocket + path: root.socketPath + connected: false + + onConnectionStateChanged: { + if (connected) { + root.isConnected = true; + root.isConnecting = false; + root.connectionStateChanged(); + subscribeSocket.connected = true; + } else { + root.isConnected = false; + root.isConnecting = false; + root.apiVersion = 0; + root.capabilities = []; + root.connectionStateChanged(); + } + } + + parser: SplitParser { + onRead: line => { + if (!line || line.length === 0) + return; + + let response; + try { + response = JSON.parse(line); + } catch (e) { + console.warn("DMSService: Failed to parse request response:", line.substring(0, 100)); + return; + } + const isClipboard = clipboardRequestIds[response.id]; + if (isClipboard) + delete clipboardRequestIds[response.id]; + else + console.log("DMSService: Request socket <<", line); + handleResponse(response); + } + } + } + + DankSocket { + id: subscribeSocket + path: root.socketPath + connected: false + + onConnectionStateChanged: { + root.subscribeConnected = connected; + if (connected) { + sendSubscribeRequest(); + } + } + + parser: SplitParser { + onRead: line => { + if (!line || line.length === 0) + return; + + let response; + try { + response = JSON.parse(line); + } catch (e) { + console.warn("DMSService: Failed to parse subscription event:", line.substring(0, 100)); + return; + } + if (!line.includes("clipboard")) + console.log("DMSService: Subscribe socket <<", line); + handleSubscriptionEvent(response); + } + } + } + + function sendSubscribeRequest() { + const request = { + "method": "subscribe" + }; + + if (activeSubscriptions.length > 0) { + request.params = { + "services": activeSubscriptions + }; + console.log("DMSService: Subscribing to services:", JSON.stringify(activeSubscriptions)); + } else { + console.log("DMSService: Subscribing to all services"); + } + + subscribeSocket.send(request); + } + + function subscribe(services) { + if (!Array.isArray(services)) { + services = [services]; + } + + activeSubscriptions = services; + + if (subscribeConnected) { + subscribeSocket.connected = false; + Qt.callLater(() => { + subscribeSocket.connected = true; + }); + } + } + + function addSubscription(service) { + if (activeSubscriptions.includes("all")) + return; + if (!activeSubscriptions.includes(service)) { + const newSubs = [...activeSubscriptions, service]; + subscribe(newSubs); + } + } + + function removeSubscription(service) { + if (activeSubscriptions.includes("all")) { + const allServices = ["network", "loginctl", "freedesktop", "gamma", "bluetooth", "dwl", "brightness", "extworkspace", "browser", "location"]; + const filtered = allServices.filter(s => s !== service); + subscribe(filtered); + } else { + const filtered = activeSubscriptions.filter(s => s !== service); + if (filtered.length === 0) { + console.warn("DMSService: Cannot remove last subscription"); + return; + } + subscribe(filtered); + } + } + + function subscribeAll() { + subscribe(["all"]); + } + + function subscribeAllExcept(excludeServices) { + if (!Array.isArray(excludeServices)) { + excludeServices = [excludeServices]; + } + + const allServices = ["network", "loginctl", "freedesktop", "gamma", "theme.auto", "bluetooth", "cups", "dwl", "brightness", "extworkspace", "browser", "dbus", "location"]; + const filtered = allServices.filter(s => !excludeServices.includes(s)); + subscribe(filtered); + } + + function handleSubscriptionEvent(response) { + if (response.error) { + if (response.error.includes("unknown method") && response.error.includes("subscribe")) { + if (!shownOutdatedError) { + console.error("DMSService: Server does not support subscribe method"); + ToastService.showError(I18n.tr("DMS out of date"), I18n.tr("To update, run the following command:"), updateCommand); + shownOutdatedError = true; + } + } + return; + } + + if (!response.result) { + return; + } + + const service = response.result.service; + const data = response.result.data; + + if (service === "server") { + apiVersion = data.apiVersion || 0; + cliVersion = data.cliVersion || ""; + capabilities = data.capabilities || []; + + console.info("DMSService: Connected (API v" + apiVersion + ", CLI " + cliVersion + ") -", JSON.stringify(capabilities)); + + if (apiVersion < expectedApiVersion) { + ToastService.showError("DMS server is outdated (API v" + apiVersion + ", expected v" + expectedApiVersion + ")"); + } + + capabilitiesReceived(); + } else if (service === "network") { + networkStateUpdate(data); + } else if (service === "network.credentials") { + credentialsRequest(data); + } else if (service === "loginctl") { + if (data.event) { + loginctlEvent(data); + } else { + loginctlStateUpdate(data); + } + } else if (service === "bluetooth.pairing") { + bluetoothPairingRequest(data); + } else if (service === "cups") { + cupsStateUpdate(data); + } else if (service === "dwl") { + dwlStateUpdate(data); + } else if (service === "brightness") { + brightnessStateUpdate(data); + } else if (service === "brightness.update") { + if (data.device) { + brightnessDeviceUpdate(data.device); + } + } else if (service === "extworkspace") { + extWorkspaceStateUpdate(data); + } else if (service === "wlroutput") { + wlrOutputStateUpdate(data); + } else if (service === "evdev") { + if (data.capsLock !== undefined) { + capsLockState = data.capsLock; + } + evdevStateUpdate(data); + } else if (service === "gamma") { + gammaStateUpdate(data); + } else if (service === "theme.auto") { + themeAutoStateUpdate(data); + } else if (service === "browser.open_requested") { + if (data.target) { + if (data.requestType === "url" || !data.requestType) { + openUrlRequested(data.target); + } else { + appPickerRequested(data); + } + } else if (data.url) { + openUrlRequested(data.url); + } + } else if (service === "freedesktop.screensaver") { + screensaverInhibited = data.inhibited || false; + screensaverInhibitors = data.inhibitors || []; + screensaverStateUpdate(data); + } else if (service === "dbus") { + dbusSignalReceived(data.subscriptionId || "", data); + } else if (service === "clipboard") { + clipboardStateUpdate(data); + } else if (service === "location") { + locationStateUpdate(data); + } + } + + function sendRequest(method, params, callback) { + if (!isConnected) { + console.warn("DMSService.sendRequest: Not connected, method:", method); + if (callback) { + callback({ + "error": "not connected to DMS socket" + }); + } + return; + } + + requestIdCounter++; + const id = Date.now() + requestIdCounter; + const request = { + "id": id, + "method": method + }; + + if (params) { + request.params = params; + } + + if (callback) + pendingRequests[id] = callback; + + if (method.startsWith("clipboard")) { + clipboardRequestIds[id] = true; + } else { + console.log("DMSService.sendRequest: Sending request id=" + id + " method=" + method); + } + requestSocket.send(request); + } + + function handleResponse(response) { + const callback = pendingRequests[response.id]; + + if (callback) { + delete pendingRequests[response.id]; + callback(response); + } + } + + function ping(callback) { + sendRequest("ping", null, callback); + } + + function listPlugins(callback) { + sendRequest("plugins.list", null, response => { + if (response.result) { + availablePlugins = response.result; + pluginsListReceived(response.result); + } + if (callback) { + callback(response); + } + }); + } + + function listInstalled(callback) { + sendRequest("plugins.listInstalled", null, response => { + if (response.result) { + installedPlugins = response.result; + installedPluginsReceived(response.result); + } + if (callback) { + callback(response); + } + }); + } + + function search(query, category, compositor, capability, callback) { + const params = { + "query": query + }; + if (category) { + params.category = category; + } + if (compositor) { + params.compositor = compositor; + } + if (capability) { + params.capability = capability; + } + + sendRequest("plugins.search", params, response => { + if (response.result) { + searchResultsReceived(response.result); + } + if (callback) { + callback(response); + } + }); + } + + function install(pluginName, callback) { + sendRequest("plugins.install", { + "name": pluginName + }, response => { + if (callback) { + callback(response); + } + if (!response.error) { + listInstalled(); + } + }); + } + + function uninstall(pluginName, callback) { + sendRequest("plugins.uninstall", { + "name": pluginName + }, response => { + if (callback) { + callback(response); + } + if (!response.error) { + listInstalled(); + } + }); + } + + function update(pluginName, callback) { + sendRequest("plugins.update", { + "name": pluginName + }, response => { + if (callback) { + callback(response); + } + if (!response.error) { + listInstalled(); + } + }); + } + + function listThemes(callback) { + sendRequest("themes.list", null, response => { + if (response.result) { + availableThemes = response.result; + themesListReceived(response.result); + } + if (callback) { + callback(response); + } + }); + } + + function listInstalledThemes(callback) { + sendRequest("themes.listInstalled", null, response => { + if (response.result) { + installedThemes = response.result; + installedThemesReceived(response.result); + } + if (callback) { + callback(response); + } + }); + } + + function searchThemes(query, callback) { + sendRequest("themes.search", { + "query": query + }, response => { + if (response.result) { + themeSearchResultsReceived(response.result); + } + if (callback) { + callback(response); + } + }); + } + + function installTheme(themeName, callback) { + sendRequest("themes.install", { + "name": themeName + }, response => { + if (callback) { + callback(response); + } + if (!response.error) { + listInstalledThemes(); + } + }); + } + + function uninstallTheme(themeName, callback) { + sendRequest("themes.uninstall", { + "name": themeName + }, response => { + if (callback) { + callback(response); + } + if (!response.error) { + listInstalledThemes(); + } + }); + } + + function updateTheme(themeName, callback) { + sendRequest("themes.update", { + "name": themeName + }, response => { + if (callback) { + callback(response); + } + if (!response.error) { + listInstalledThemes(); + } + }); + } + + function lockSession(callback) { + sendRequest("loginctl.lock", null, callback); + } + + function unlockSession(callback) { + sendRequest("loginctl.unlock", null, callback); + } + + function bluetoothPair(devicePath, callback) { + sendRequest("bluetooth.pair", { + "device": devicePath + }, callback); + } + + function bluetoothConnect(devicePath, callback) { + sendRequest("bluetooth.connect", { + "device": devicePath + }, callback); + } + + function bluetoothDisconnect(devicePath, callback) { + sendRequest("bluetooth.disconnect", { + "device": devicePath + }, callback); + } + + function bluetoothRemove(devicePath, callback) { + sendRequest("bluetooth.remove", { + "device": devicePath + }, callback); + } + + function bluetoothTrust(devicePath, callback) { + sendRequest("bluetooth.trust", { + "device": devicePath + }, callback); + } + + function bluetoothSubmitPairing(token, secrets, accept, callback) { + sendRequest("bluetooth.pairing.submit", { + "token": token, + "secrets": secrets, + "accept": accept + }, callback); + } + + function bluetoothCancelPairing(token, callback) { + sendRequest("bluetooth.pairing.cancel", { + "token": token + }, callback); + } + + signal dbusSignalReceived(string subscriptionId, var data) + + property var dbusSubscriptions: ({}) + + function dbusCall(bus, dest, path, iface, method, args, callback) { + sendRequest("dbus.call", { + "bus": bus, + "dest": dest, + "path": path, + "interface": iface, + "method": method, + "args": args || [] + }, callback); + } + + function dbusGetProperty(bus, dest, path, iface, property, callback) { + sendRequest("dbus.getProperty", { + "bus": bus, + "dest": dest, + "path": path, + "interface": iface, + "property": property + }, callback); + } + + function dbusSetProperty(bus, dest, path, iface, property, value, callback) { + sendRequest("dbus.setProperty", { + "bus": bus, + "dest": dest, + "path": path, + "interface": iface, + "property": property, + "value": value + }, callback); + } + + function dbusGetAllProperties(bus, dest, path, iface, callback) { + sendRequest("dbus.getAllProperties", { + "bus": bus, + "dest": dest, + "path": path, + "interface": iface + }, callback); + } + + function dbusIntrospect(bus, dest, path, callback) { + sendRequest("dbus.introspect", { + "bus": bus, + "dest": dest, + "path": path || "/" + }, callback); + } + + function dbusListNames(bus, callback) { + sendRequest("dbus.listNames", { + "bus": bus + }, callback); + } + + function dbusSubscribe(bus, sender, path, iface, member, callback) { + sendRequest("dbus.subscribe", { + "bus": bus, + "sender": sender || "", + "path": path || "", + "interface": iface || "", + "member": member || "" + }, response => { + if (!response.error && response.result?.subscriptionId) { + dbusSubscriptions[response.result.subscriptionId] = true; + } + if (callback) + callback(response); + }); + } + + function dbusUnsubscribe(subscriptionId, callback) { + sendRequest("dbus.unsubscribe", { + "subscriptionId": subscriptionId + }, response => { + if (!response.error) { + delete dbusSubscriptions[subscriptionId]; + } + if (callback) + callback(response); + }); + } + + function renameWorkspace(name, callback) { + sendRequest("extworkspace.renameWorkspace", { + "name": name + }, callback); + } +} |