Mercurial > libervia-backend
diff sat/plugins/plugin_misc_tickets.py @ 2624:56f94936df1e
code style reformatting using black
author | Goffi <goffi@goffi.org> |
---|---|
date | Wed, 27 Jun 2018 20:14:46 +0200 |
parents | 5d4ac5415b40 |
children | 003b8b4b56a7 |
line wrap: on
line diff
--- a/sat/plugins/plugin_misc_tickets.py Wed Jun 27 07:51:29 2018 +0200 +++ b/sat/plugins/plugin_misc_tickets.py Wed Jun 27 20:14:46 2018 +0200 @@ -24,9 +24,10 @@ from sat.tools import utils import shortuuid from sat.core.log import getLogger + log = getLogger(__name__) -NS_TICKETS = 'org.salut-a-toi.tickets:0' +NS_TICKETS = "org.salut-a-toi.tickets:0" PLUGIN_INFO = { C.PI_NAME: _("Tickets management"), @@ -36,49 +37,84 @@ C.PI_DEPENDENCIES: ["XEP-0060", "PUBSUB_SCHEMA", "XEP-0277", "IDENTITY"], C.PI_MAIN: "Tickets", C.PI_HANDLER: "no", - C.PI_DESCRIPTION: _("""Tickets management plugin""") + C.PI_DESCRIPTION: _("""Tickets management plugin"""), } class Tickets(object): - def __init__(self, host): log.info(_(u"Tickets plugin initialization")) self.host = host - host.registerNamespace('tickets', NS_TICKETS) + host.registerNamespace("tickets", NS_TICKETS) self._p = self.host.plugins["XEP-0060"] self._s = self.host.plugins["PUBSUB_SCHEMA"] self._m = self.host.plugins["XEP-0277"] - host.bridge.addMethod("ticketsGet", ".plugin", - in_sign='ssiassa{ss}s', out_sign='(asa{ss})', - method=utils.partial( - self._s._get, - default_node=NS_TICKETS, - form_ns=NS_TICKETS, - filters = {u'author': self._s.valueOrPublisherFilter, - u'created': self._s.dateFilter, - u'updated': self._s.dateFilter, - }), + host.bridge.addMethod( + "ticketsGet", + ".plugin", + in_sign="ssiassa{ss}s", + out_sign="(asa{ss})", + method=utils.partial( + self._s._get, + default_node=NS_TICKETS, + form_ns=NS_TICKETS, + filters={ + u"author": self._s.valueOrPublisherFilter, + u"created": self._s.dateFilter, + u"updated": self._s.dateFilter, + }, + ), + async=True, + ) + host.bridge.addMethod( + "ticketSet", + ".plugin", + in_sign="ssa{sas}ssa{ss}s", + out_sign="s", + method=self._set, + async=True, + ) + host.bridge.addMethod( + "ticketsSchemaGet", + ".plugin", + in_sign="sss", + out_sign="s", + method=utils.partial(self._s._getUISchema, default_node=NS_TICKETS), + async=True, + ) - async=True - ) - host.bridge.addMethod("ticketSet", ".plugin", - in_sign='ssa{sas}ssa{ss}s', out_sign='s', - method=self._set, - async=True) - host.bridge.addMethod("ticketsSchemaGet", ".plugin", - in_sign='sss', out_sign='s', - method=utils.partial(self._s._getUISchema, default_node=NS_TICKETS), - async=True) - - def _set(self, service, node, values, schema=None, item_id=None, extra=None, profile_key=C.PROF_KEY_NONE): - client, service, node, schema, item_id, extra = self._s.prepareBridgeSet(service, node, schema, item_id, extra, profile_key) - d = self.set(client, service, node, values, schema, item_id, extra, deserialise=True) - d.addCallback(lambda ret: ret or u'') + def _set( + self, + service, + node, + values, + schema=None, + item_id=None, + extra=None, + profile_key=C.PROF_KEY_NONE, + ): + client, service, node, schema, item_id, extra = self._s.prepareBridgeSet( + service, node, schema, item_id, extra, profile_key + ) + d = self.set( + client, service, node, values, schema, item_id, extra, deserialise=True + ) + d.addCallback(lambda ret: ret or u"") return d @defer.inlineCallbacks - def set(self, client, service, node, values, schema=None, item_id=None, extra=None, deserialise=False, form_ns=NS_TICKETS): + def set( + self, + client, + service, + node, + values, + schema=None, + item_id=None, + extra=None, + deserialise=False, + form_ns=NS_TICKETS, + ): """Publish a tickets @param node(unicode, None): Pubsub node to use @@ -102,15 +138,25 @@ # we need to use uuid for comments node, because we don't know item id in advance # (we don't want to set it ourselves to let the server choose, so we can have # a nicer id if serial ids is activated) - comments_node = self._m.getCommentsNode(node + u'_' + unicode(shortuuid.uuid())) - options = {self._p.OPT_ACCESS_MODEL: self._p.ACCESS_OPEN, - self._p.OPT_PERSIST_ITEMS: 1, - self._p.OPT_MAX_ITEMS: -1, - self._p.OPT_DELIVER_PAYLOADS: 1, - self._p.OPT_SEND_ITEM_SUBSCRIBE: 1, - self._p.OPT_PUBLISH_MODEL: self._p.ACCESS_OPEN, - } + comments_node = self._m.getCommentsNode( + node + u"_" + unicode(shortuuid.uuid()) + ) + options = { + self._p.OPT_ACCESS_MODEL: self._p.ACCESS_OPEN, + self._p.OPT_PERSIST_ITEMS: 1, + self._p.OPT_MAX_ITEMS: -1, + self._p.OPT_DELIVER_PAYLOADS: 1, + self._p.OPT_SEND_ITEM_SUBSCRIBE: 1, + self._p.OPT_PUBLISH_MODEL: self._p.ACCESS_OPEN, + } yield self._p.createNode(client, comments_service, comments_node, options) - values['comments_uri'] = uri.buildXMPPUri(u'pubsub', subtype='microblog', path=comments_service.full(), node=comments_node) - item_id = yield self._s.set(client, service, node, values, schema, item_id, extra, deserialise, form_ns) + values["comments_uri"] = uri.buildXMPPUri( + u"pubsub", + subtype="microblog", + path=comments_service.full(), + node=comments_node, + ) + item_id = yield self._s.set( + client, service, node, values, schema, item_id, extra, deserialise, form_ns + ) defer.returnValue(item_id)