Handle new properties
This commit is contained in:
parent
036db7b1a7
commit
07e44b035d
38
xfconf.py
38
xfconf.py
|
@ -10,18 +10,26 @@ class Xfconf:
|
||||||
def __init__(self, xq=None):
|
def __init__(self, xq=None):
|
||||||
self._xq = xq or self.find_xq()
|
self._xq = xq or self.find_xq()
|
||||||
|
|
||||||
def xq(self, command):
|
def xq(self, command, print_failures=True):
|
||||||
"""Run a xion-query command and return its output or None on error."""
|
"""Run a xion-query command and return its output or None on error."""
|
||||||
command.insert(0, self._xq)
|
command.insert(0, self._xq)
|
||||||
try:
|
try:
|
||||||
return subprocess.check_output(command).decode()
|
return subprocess.check_output(
|
||||||
|
command, stderr=subprocess.STDOUT
|
||||||
|
).decode()
|
||||||
except subprocess.CalledProcessError as exc:
|
except subprocess.CalledProcessError as exc:
|
||||||
print(exc)
|
if not print_failures:
|
||||||
|
return None
|
||||||
|
print(f"xion-query command failed with code {exc.returncode}.")
|
||||||
|
if exc.stdout:
|
||||||
|
print("stdout:", exc.stdout.decode().strip())
|
||||||
|
if exc.stderr:
|
||||||
|
print("stderr:", exc.stderr.decode().strip())
|
||||||
return None
|
return None
|
||||||
|
|
||||||
def xqs(self, command_str):
|
def xqs(self, command_str, print_failures=True):
|
||||||
"""Wrapper of xq, splitting a string command."""
|
"""Wrapper of xq, splitting a string command."""
|
||||||
return self.xq(command_str.split(" "))
|
return self.xq(command_str.split(" "), print_failures=print_failures)
|
||||||
|
|
||||||
def get_channel_list(self):
|
def get_channel_list(self):
|
||||||
"""Return the channel list or None on error."""
|
"""Return the channel list or None on error."""
|
||||||
|
@ -37,6 +45,11 @@ class Xfconf:
|
||||||
return None
|
return None
|
||||||
return [p for p in output.splitlines() if p.startswith(root)]
|
return [p for p in output.splitlines() if p.startswith(root)]
|
||||||
|
|
||||||
|
def does_property_exist(self, channel, prop):
|
||||||
|
"""Return True if this property exists."""
|
||||||
|
output = self.xqs(f"-c {channel} -p {prop}", print_failures=False)
|
||||||
|
return output is not None
|
||||||
|
|
||||||
def get_property(self, channel, prop):
|
def get_property(self, channel, prop):
|
||||||
"""Return this property or None on error."""
|
"""Return this property or None on error."""
|
||||||
output = self.xqs(f"-c {channel} -p {prop}")
|
output = self.xqs(f"-c {channel} -p {prop}")
|
||||||
|
@ -46,14 +59,25 @@ class Xfconf:
|
||||||
|
|
||||||
def set_property(self, channel, prop, prop_type, value):
|
def set_property(self, channel, prop, prop_type, value):
|
||||||
"""Create or update this property."""
|
"""Create or update this property."""
|
||||||
# TODO handle new properties
|
if not self.does_property_exist(channel, prop):
|
||||||
|
self.create_property(channel, prop, prop_type, value)
|
||||||
|
else:
|
||||||
self.update_property(channel, prop, value)
|
self.update_property(channel, prop, value)
|
||||||
|
|
||||||
|
def create_property(self, channel, prop, prop_type, value):
|
||||||
|
"""Create a new property with those params, return True on success."""
|
||||||
|
if " " in value:
|
||||||
|
value = f'"{value}"'
|
||||||
|
output = self.xq(["-c", channel, "-p", prop, "-n",
|
||||||
|
"-t", prop_type, "-s", value])
|
||||||
|
if output is None:
|
||||||
|
return False
|
||||||
|
|
||||||
def update_property(self, channel, prop, value):
|
def update_property(self, channel, prop, value):
|
||||||
"""Update an existing property, return True on success."""
|
"""Update an existing property, return True on success."""
|
||||||
if " " in value:
|
if " " in value:
|
||||||
value = f'"{value}"'
|
value = f'"{value}"'
|
||||||
output = self.xqs(f"-c {channel} -p {prop} -s {value}")
|
output = self.xq(["-c", channel, "-p", prop, "-s", value])
|
||||||
return output == ""
|
return output == ""
|
||||||
|
|
||||||
@staticmethod
|
@staticmethod
|
||||||
|
|
Loading…
Reference in a new issue