Mercurial > libervia-web
diff src/server/utils.py @ 1113:cdd389ef97bc
server: code style reformatting using black
author | Goffi <goffi@goffi.org> |
---|---|
date | Fri, 29 Jun 2018 17:45:26 +0200 |
parents | 63ed5f6bd4eb |
children |
line wrap: on
line diff
--- a/src/server/utils.py Sun Jun 24 22:21:25 2018 +0200 +++ b/src/server/utils.py Fri Jun 29 17:45:26 2018 +0200 @@ -22,16 +22,18 @@ from sat.core import exceptions from sat.core.log import getLogger import urllib + log = getLogger(__name__) -def quote(value, safe='@'): +def quote(value, safe="@"): """shortcut to quote an unicode value for URL""" - return urllib.quote(value.encode('utf-8'), safe=safe) + return urllib.quote(value.encode("utf-8"), safe=safe) class ProgressHandler(object): """class to help the management of progressions""" + handlers = {} def __init__(self, host, progress_id, profile): @@ -44,34 +46,40 @@ handlers = cls.handlers if profile in handlers and progress_id in handlers[profile]: handler_data = handlers[profile][progress_id] - timeout = handler_data[u'timeout'] + timeout = handler_data[u"timeout"] if timeout.active(): timeout.cancel() cb = handler_data[name] if cb is not None: cb(data) - if name == u'started': + if name == u"started": pass - elif name == u'finished': - handler_data[u'deferred'].callback(data) - handler_data[u'instance'].unregister_handler() - elif name == u'error': - handler_data[u'deferred'].errback(Exception(data)) - handler_data[u'instance'].unregister_handler() + elif name == u"finished": + handler_data[u"deferred"].callback(data) + handler_data[u"instance"].unregister_handler() + elif name == u"error": + handler_data[u"deferred"].errback(Exception(data)) + handler_data[u"instance"].unregister_handler() else: - log.error(u'unexpected signal: {name}'.format(name=name)) + log.error(u"unexpected signal: {name}".format(name=name)) def _timeout(self): - log.warning(_(u"No progress received, cancelling handler: {progress_id} [{profile}]").format( - progress_id = self.progress_id, profile = self.profile)) + log.warning( + _( + u"No progress received, cancelling handler: {progress_id} [{profile}]" + ).format(progress_id=self.progress_id, profile=self.profile) + ) def unregister_handler(self): """remove a previously registered handler""" try: del self.handlers[self.profile][self.progress_id] except KeyError: - log.warning(_(u"Trying to remove unknown handler: {progress_id} [{profile}]").format( - progress_id = self.progress_id, profile = self.profile)) + log.warning( + _(u"Trying to remove unknown handler: {progress_id} [{profile}]").format( + progress_id=self.progress_id, profile=self.profile + ) + ) else: if not self.handlers[self.profile]: self.handlers[self.profile] @@ -87,15 +95,19 @@ an exception is raised @return (D(dict[unicode,unicode])): a deferred called when progression is finished """ - handler_data = self.handlers.setdefault(self.profile, {}).setdefault(self.progress_id, {}) + handler_data = self.handlers.setdefault(self.profile, {}).setdefault( + self.progress_id, {} + ) if handler_data: - raise exceptions.ConflictError(u"There is already one handler for this progression") - handler_data[u'instance'] = self - deferred = handler_data[u'deferred'] = defer.Deferred() - handler_data[u'started'] = started_cb - handler_data[u'finished'] = finished_cb - handler_data[u'error'] = error_cb - handler_data[u'timeout'] = reactor.callLater(timeout, self._timeout) + raise exceptions.ConflictError( + u"There is already one handler for this progression" + ) + handler_data[u"instance"] = self + deferred = handler_data[u"deferred"] = defer.Deferred() + handler_data[u"started"] = started_cb + handler_data[u"finished"] = finished_cb + handler_data[u"error"] = error_cb + handler_data[u"timeout"] = reactor.callLater(timeout, self._timeout) return deferred