X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~mdw/git/disorder/blobdiff_plain/460b9539a7c15580e41a71bbc0f47ae776238915..f35e5800ee5e7219ec5bd2f6c17505ff0cbcbd30:/python/disorder.py.in diff --git a/python/disorder.py.in b/python/disorder.py.in index dfaddbf..01b92ed 100644 --- a/python/disorder.py.in +++ b/python/disorder.py.in @@ -53,6 +53,7 @@ import locale _configfile = "pkgconfdir/config" _dbhome = "pkgstatedir" +_userconf = True # various regexps we'll use _ws = re.compile(r"^[ \t\n\r]+") @@ -104,15 +105,20 @@ class operationError(Error): Indicates that an operation failed (e.g. an attempt to play a nonexistent track). The connection should still be usable. """ - def __init__(self, res, details): + def __init__(self, res, details, cmd=None): self.res_ = int(res) + self.cmd_ = cmd self.details_ = details def __str__(self): - """Return the complete response string from the server. + """Return the complete response string from the server, with the command + if available. Excludes the final newline. """ - return "%d %s" % (self.res_, self.details_) + if self.cmd_ is None: + return "%d %s" % (self.res_, self.details_) + else: + return "%d %s [%s]" % (self.res_, self.details_, self.cmd_) def response(self): """Return the response code from the server.""" return self.res_ @@ -291,7 +297,7 @@ class client: self._readfile(_configfile) if os.path.exists(privconf): self._readfile(privconf) - if os.path.exists(passfile): + if os.path.exists(passfile) and _userconf: self._readfile(passfile) self.state = 'disconnected' @@ -647,7 +653,7 @@ class client: all of the required words (in their path name, trackname preferences, etc.) """ - self._simple("search", *words) + self._simple("search", _quote(words)) return self._body() def stats(self): @@ -749,6 +755,34 @@ class client: ret, details = self._simple("part", track, context, part) return details + def setglobal(self, key, value): + """Set a global preference value. + + Arguments: + key -- the preference name + value -- the new preference value + """ + self._simple("set-global", key, value) + + def unsetglobal(self, key): + """Unset a global preference value. + + Arguments: + key -- the preference to remove + """ + self._simple("set-global", key, value) + + def getglobal(self, key): + """Get a global preference value. + + Arguments: + key -- the preference to look up + + The return value is the preference + """ + ret, details = self._simple("get-global", key) + return details + ######################################################################## # I/O infrastructure @@ -779,6 +813,9 @@ class client: raise protocolError(self.who, "invalid response %s") def _send(self, *command): + # Quote and send a command + # + # Returns the encoded command. quoted = _quote(command) self._debug(client.debug_proto, "==> %s" % quoted) encoded = quoted.encode("UTF-8") @@ -786,6 +823,7 @@ class client: self.w.write(encoded) self.w.write("\n") self.w.flush() + return encoded except IOError, e: # e.g. EPIPE self._disconnect() @@ -805,11 +843,13 @@ class client: if self.state == 'disconnected': self.connect() if command: - self._send(*command) + cmd = self._send(*command) + else: + cmd = None res, details = self._response() if res / 100 == 2: return res, details - raise operationError(res, details) + raise operationError(res, details, cmd) def _body(self): # Fetch a dot-stuffed body @@ -1042,4 +1082,3 @@ class monitor: # comment-column:40 # fill-column:72 # End: -# arch-tag:eea975737c837febf73a000630b5ecc4