libervia-backend: src/tmp/wokkel/rsm.py annotate

annotate src/tmp/wokkel/rsm.py @ 1781:0158ab00afea

tmp (wokkel.rsm): fixed incorrect behaviour which was adding max_items attribute

author	Goffi <goffi@goffi.org>
date	Thu, 07 Jan 2016 23:03:15 +0100
parents	4beb613d277c
children	514ade866261

rev	line source
1424 2d8fccec84e8 core (tests): test fixes Goffi <goffi@goffi.org> parents: 1423 diff changeset	1 # -- coding: utf-8 --
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	2 # -- test-case-name: wokkel.test.test_rsm --
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	3 #
1422 be1fccf4854d tmp (wokkel): licenses fixes: Goffi <goffi@goffi.org> parents: 1419 diff changeset	4 # SàT Wokkel extension for Result Set Management (XEP-0059)
be1fccf4854d tmp (wokkel): licenses fixes: Goffi <goffi@goffi.org> parents: 1419 diff changeset	5 # Copyright (C) 2015 Adien Cossa (souliane@mailoo.org)
be1fccf4854d tmp (wokkel): licenses fixes: Goffi <goffi@goffi.org> parents: 1419 diff changeset	6
be1fccf4854d tmp (wokkel): licenses fixes: Goffi <goffi@goffi.org> parents: 1419 diff changeset	7 # This program is free software: you can redistribute it and/or modify
be1fccf4854d tmp (wokkel): licenses fixes: Goffi <goffi@goffi.org> parents: 1419 diff changeset	8 # it under the terms of the GNU Affero General Public License as published by
be1fccf4854d tmp (wokkel): licenses fixes: Goffi <goffi@goffi.org> parents: 1419 diff changeset	9 # the Free Software Foundation, either version 3 of the License, or
be1fccf4854d tmp (wokkel): licenses fixes: Goffi <goffi@goffi.org> parents: 1419 diff changeset	10 # (at your option) any later version.
be1fccf4854d tmp (wokkel): licenses fixes: Goffi <goffi@goffi.org> parents: 1419 diff changeset	11
be1fccf4854d tmp (wokkel): licenses fixes: Goffi <goffi@goffi.org> parents: 1419 diff changeset	12 # This program is distributed in the hope that it will be useful,
be1fccf4854d tmp (wokkel): licenses fixes: Goffi <goffi@goffi.org> parents: 1419 diff changeset	13 # but WITHOUT ANY WARRANTY; without even the implied warranty of
be1fccf4854d tmp (wokkel): licenses fixes: Goffi <goffi@goffi.org> parents: 1419 diff changeset	14 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
be1fccf4854d tmp (wokkel): licenses fixes: Goffi <goffi@goffi.org> parents: 1419 diff changeset	15 # GNU Affero General Public License for more details.
be1fccf4854d tmp (wokkel): licenses fixes: Goffi <goffi@goffi.org> parents: 1419 diff changeset	16
be1fccf4854d tmp (wokkel): licenses fixes: Goffi <goffi@goffi.org> parents: 1419 diff changeset	17 # You should have received a copy of the GNU Affero General Public License
be1fccf4854d tmp (wokkel): licenses fixes: Goffi <goffi@goffi.org> parents: 1419 diff changeset	18 # along with this program. If not, see <http://www.gnu.org/licenses/>.
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	19
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	20 """
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	21 XMPP Result Set Management protocol.
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	22
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	23 This protocol is specified in
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	24 U{XEP-0059<http://xmpp.org/extensions/xep-0059.html>}.
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	25 """
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	26
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	27 from twisted.words.xish import domish
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	28
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	29 import pubsub
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	30 import copy
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	31
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	32
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	33 NS_RSM = 'http://jabber.org/protocol/rsm'
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	34
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	35
1283 7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	36 class RSMError(Exception):
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	37 """
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	38 RSM error.
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	39 """
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	40
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	41
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	42 class RSMNotFoundError(Exception):
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	43 """
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	44 An expected RSM element has not been found.
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	45 """
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	46
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	47
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	48 class RSMRequest(object):
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	49 """
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	50 A Result Set Management request.
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	51
1419 be2df1ddea8e plugins (groupblog, xep-0277) + tmp(rsm): improved style: Goffi <goffi@goffi.org> parents: 1283 diff changeset	52 @ivar max_: limit on the number of retrieved items.
be2df1ddea8e plugins (groupblog, xep-0277) + tmp(rsm): improved style: Goffi <goffi@goffi.org> parents: 1283 diff changeset	53 @itype max_: C{int} or C{unicode}
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	54
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	55 @ivar index: starting index of the requested page.
1423 882e5fabf68c plugin groupblog, tmp (mam, rsm): some style improvments/fixes: Goffi <goffi@goffi.org> parents: 1422 diff changeset	56 @itype index: C{int} or C{unicode} or C{None}
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	57
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	58 @ivar after: ID of the element immediately preceding the page.
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	59 @itype after: C{unicode}
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	60
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	61 @ivar before: ID of the element immediately following the page.
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	62 @itype before: C{unicode}
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	63 """
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	64
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	65 def __init__(self, max_=10, after=None, before=None, index=None):
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	66 self.max = int(max_)
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	67
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	68 if index is not None:
1419 be2df1ddea8e plugins (groupblog, xep-0277) + tmp(rsm): improved style: Goffi <goffi@goffi.org> parents: 1283 diff changeset	69 assert after is None and before is None
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	70 index = int(index)
1423 882e5fabf68c plugin groupblog, tmp (mam, rsm): some style improvments/fixes: Goffi <goffi@goffi.org> parents: 1422 diff changeset	71 self.index = index
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	72
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	73 if after is not None:
1419 be2df1ddea8e plugins (groupblog, xep-0277) + tmp(rsm): improved style: Goffi <goffi@goffi.org> parents: 1283 diff changeset	74 assert before is None
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	75 assert isinstance(after, basestring)
1423 882e5fabf68c plugin groupblog, tmp (mam, rsm): some style improvments/fixes: Goffi <goffi@goffi.org> parents: 1422 diff changeset	76 self.after = after
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	77
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	78 if before is not None:
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	79 assert isinstance(before, basestring)
1423 882e5fabf68c plugin groupblog, tmp (mam, rsm): some style improvments/fixes: Goffi <goffi@goffi.org> parents: 1422 diff changeset	80 self.before = before
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	81
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	82 def __str__(self):
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	83 return "RSM Request: max={0.max} after={0.after} before={0.before} index={0.index}".format(self)
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	84
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	85 @classmethod
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	86 def fromElement(cls, element):
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	87 """Parse the given request element.
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	88
1773 6e867caf4621 plugin XEP-0060, tmp(wokkel.rsm): small refactoring: Goffi <goffi@goffi.org> parents: 1771 diff changeset	89 @param element: request containing a set element, or set element itself.
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	90 @type element: L{domish.Element}
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	91
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	92 @return: RSMRequest instance.
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	93 @rtype: L{RSMRequest}
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	94 """
1773 6e867caf4621 plugin XEP-0060, tmp(wokkel.rsm): small refactoring: Goffi <goffi@goffi.org> parents: 1771 diff changeset	95
6e867caf4621 plugin XEP-0060, tmp(wokkel.rsm): small refactoring: Goffi <goffi@goffi.org> parents: 1771 diff changeset	96 if element.name == 'set' and element.uri == NS_RSM:
6e867caf4621 plugin XEP-0060, tmp(wokkel.rsm): small refactoring: Goffi <goffi@goffi.org> parents: 1771 diff changeset	97 set_elt = element
6e867caf4621 plugin XEP-0060, tmp(wokkel.rsm): small refactoring: Goffi <goffi@goffi.org> parents: 1771 diff changeset	98 else:
6e867caf4621 plugin XEP-0060, tmp(wokkel.rsm): small refactoring: Goffi <goffi@goffi.org> parents: 1771 diff changeset	99 try:
6e867caf4621 plugin XEP-0060, tmp(wokkel.rsm): small refactoring: Goffi <goffi@goffi.org> parents: 1771 diff changeset	100 set_elt = element.elements(NS_RSM, 'set').next()
6e867caf4621 plugin XEP-0060, tmp(wokkel.rsm): small refactoring: Goffi <goffi@goffi.org> parents: 1771 diff changeset	101 except StopIteration:
6e867caf4621 plugin XEP-0060, tmp(wokkel.rsm): small refactoring: Goffi <goffi@goffi.org> parents: 1771 diff changeset	102 raise RSMNotFoundError()
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	103
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	104 try:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	105 before_elt = set_elt.elements(NS_RSM, 'before').next()
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	106 except StopIteration:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	107 before = None
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	108 else:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	109 before = unicode(before_elt)
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	110
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	111 try:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	112 after_elt = set_elt.elements(NS_RSM, 'after').next()
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	113 except StopIteration:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	114 after = None
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	115 else:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	116 after = unicode(after_elt)
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	117
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	118 try:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	119 max_elt = set_elt.elements(NS_RSM, 'max').next()
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	120 except StopIteration:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	121 # FIXME: even if it doesn't make a lot of sense without it
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	122 # <max/> element is not mandatory in XEP-0059
1423 882e5fabf68c plugin groupblog, tmp (mam, rsm): some style improvments/fixes: Goffi <goffi@goffi.org> parents: 1422 diff changeset	123 raise RSMError("RSM request is missing its 'max' element")
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	124 else:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	125 try:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	126 max_ = int(unicode(max_elt))
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	127 except ValueError:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	128 raise RSMError("bad value for 'max' element")
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	129
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	130 try:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	131 index_elt = set_elt.elements(NS_RSM, 'index').next()
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	132 except StopIteration:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	133 index = None
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	134 else:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	135 try:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	136 index = int(unicode(index_elt))
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	137 except ValueError:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	138 raise RSMError("bad value for 'index' element")
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	139
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	140 return RSMRequest(max_, after, before, index)
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	141
1283 7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	142 def toElement(self):
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	143 """
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	144 Return the DOM representation of this RSM request.
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	145
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	146 @rtype: L{domish.Element}
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	147 """
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	148 set_elt = domish.Element((NS_RSM, 'set'))
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	149 set_elt.addElement('max', content=unicode(self.max))
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	150
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	151 if self.index is not None:
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	152 set_elt.addElement('index', content=unicode(self.index))
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	153
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	154 if self.before is not None:
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	155 if self.before == '': # request the last page
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	156 set_elt.addElement('before')
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	157 else:
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	158 set_elt.addElement('before', content=self.before)
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	159
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	160 if self.after is not None:
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	161 set_elt.addElement('after', content=self.after)
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	162
1283 7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	163 return set_elt
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	164
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	165 def render(self, element):
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	166 """Embed the DOM representation of this RSM request in the given element.
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	167
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	168 @param element: Element to contain the RSM request.
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	169 @type element: L{domish.Element}
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	170
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	171 @return: RSM request element.
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	172 @rtype: L{domish.Element}
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	173 """
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	174 set_elt = self.toElement()
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	175 element.addChild(set_elt)
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	176
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	177 return set_elt
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	178
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	179
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	180 class RSMResponse(object):
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	181 """
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	182 A Result Set Management response.
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	183
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	184 @ivar first: ID of the first element of the returned page.
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	185 @itype first: C{unicode}
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	186
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	187 @ivar last: ID of the last element of the returned page.
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	188 @itype last: C{unicode}
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	189
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	190 @ivar index: starting index of the returned page.
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	191 @itype index: C{int}
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	192
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	193 @ivar count: total number of items.
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	194 @itype count: C{int}
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	195
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	196 """
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	197
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	198 def __init__(self, first=None, last=None, index=None, count=None):
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	199 if first is None:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	200 assert last is None and index is None
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	201 if last is None:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	202 assert first is None
1423 882e5fabf68c plugin groupblog, tmp (mam, rsm): some style improvments/fixes: Goffi <goffi@goffi.org> parents: 1422 diff changeset	203 self.first = first
882e5fabf68c plugin groupblog, tmp (mam, rsm): some style improvments/fixes: Goffi <goffi@goffi.org> parents: 1422 diff changeset	204 self.last = last
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	205 if count is not None:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	206 self.count = int(count)
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	207 else:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	208 self.count = None
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	209 if index is not None:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	210 self.index = int(index)
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	211 else:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	212 self.index = None
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	213
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	214 def __str__(self):
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	215 return "RSM Request: first={0.first} last={0.last} index={0.index} count={0.count}".format(self)
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	216
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	217 @classmethod
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	218 def fromElement(cls, element):
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	219 """Parse the given response element.
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	220
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	221 @param element: response element.
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	222 @type element: L{domish.Element}
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	223
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	224 @return: RSMResponse instance.
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	225 @rtype: L{RSMResponse}
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	226 """
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	227 try:
1432 60c41422ee48 tmp (rsm): better use of domish.Element.elements() + minor fixes Goffi <goffi@goffi.org> parents: 1424 diff changeset	228 set_elt = element.elements(NS_RSM, 'set').next()
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	229 except StopIteration:
1439 ea48663b2605 tmp (wokkel): pubsub response do not fail when target server doesn't handle RSM souliane <souliane@mailoo.org> parents: 1432 diff changeset	230 raise RSMNotFoundError()
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	231
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	232 try:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	233 first_elt = set_elt.elements(NS_RSM, 'first').next()
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	234 except StopIteration:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	235 first = None
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	236 index = None
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	237 else:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	238 first = unicode(first_elt)
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	239 try:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	240 index = int(first_elt['index'])
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	241 except KeyError:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	242 index = None
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	243 except ValueError:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	244 raise RSMError("bad index in RSM response")
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	245
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	246 try:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	247 last_elt = set_elt.elements(NS_RSM, 'last').next()
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	248 except StopIteration:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	249 if first is not None:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	250 raise RSMError("RSM response is missing its 'last' element")
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	251 else:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	252 last = None
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	253 else:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	254 if first is None:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	255 raise RSMError("RSM response is missing its 'first' element")
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	256 last = unicode(last_elt)
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	257
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	258 try:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	259 count_elt = set_elt.elements(NS_RSM, 'count').next()
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	260 except StopIteration:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	261 count = None
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	262 else:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	263 try:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	264 count = int(unicode(count_elt))
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	265 except ValueError:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	266 raise RSMError("invalid count in RSM response")
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	267
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	268 return RSMResponse(first, last, index, count)
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	269
1283 7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	270 def toElement(self):
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	271 """
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	272 Return the DOM representation of this RSM request.
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	273
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	274 @rtype: L{domish.Element}
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	275 """
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	276 set_elt = domish.Element((NS_RSM, 'set'))
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	277 if self.first is not None:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	278 first_elt = set_elt.addElement('first', content=self.first)
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	279 if self.index is not None:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	280 first_elt['index'] = unicode(self.index)
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	281
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	282 set_elt.addElement('last', content=self.last)
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	283
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	284 if self.count is not None:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	285 set_elt.addElement('count', content=unicode(self.count))
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	286
1283 7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	287 return set_elt
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	288
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	289 def render(self, element):
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	290 """Embed the DOM representation of this RSM response in the given element.
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	291
1283 7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	292 @param element: Element to contain the RSM response.
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	293 @type element: L{domish.Element}
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	294
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	295 @return: RSM request element.
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	296 @rtype: L{domish.Element}
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	297 """
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	298 set_elt = self.toElement()
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	299 element.addChild(set_elt)
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	300 return set_elt
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	301
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	302 def toDict(self):
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	303 """Return a dict representation of the object.
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	304
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	305 @return: a dict of strings.
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	306 @rtype: C{dict} binding C{unicode} to C{unicode}
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	307 """
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	308 result = {}
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	309 for attr in ('first', 'last', 'index', 'count'):
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	310 value = getattr(self, attr)
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	311 if value is not None:
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	312 result[attr] = unicode(value)
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	313 return result
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	314
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	315
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	316 class PubSubRequest(pubsub.PubSubRequest):
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	317 """PubSubRequest extension to handle RSM.
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	318
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	319 @ivar rsm: RSM request instance.
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	320 @type rsm: L{RSMRequest}
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	321 """
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	322
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	323 rsm = None
1773 6e867caf4621 plugin XEP-0060, tmp(wokkel.rsm): small refactoring: Goffi <goffi@goffi.org> parents: 1771 diff changeset	324 _parameters = copy.deepcopy(pubsub.PubSubRequest._parameters)
6e867caf4621 plugin XEP-0060, tmp(wokkel.rsm): small refactoring: Goffi <goffi@goffi.org> parents: 1771 diff changeset	325 _parameters['items'].append('rsm')
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	326
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	327 def _parse_rsm(self, verbElement):
1283 7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	328 try:
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	329 self.rsm = RSMRequest.fromElement(verbElement.parent)
1283 7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	330 except RSMNotFoundError:
7d9ff14a2d9d tmp: update tmp.wokkel.rsm, add tmp.wokkel.mam souliane <souliane@mailoo.org> parents: 1266 diff changeset	331 self.rsm = None
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	332
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	333 def _render_rsm(self, verbElement):
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	334 if self.rsm:
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	335 self.rsm.render(verbElement.parent)
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	336
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	337
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	338 class PubSubClient(pubsub.PubSubClient):
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	339 """PubSubClient extension to handle RSM."""
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	340
1773 6e867caf4621 plugin XEP-0060, tmp(wokkel.rsm): small refactoring: Goffi <goffi@goffi.org> parents: 1771 diff changeset	341 _request_class = PubSubRequest
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	342
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	343 def items(self, service, nodeIdentifier, maxItems=None, itemIdentifiers=None,
1773 6e867caf4621 plugin XEP-0060, tmp(wokkel.rsm): small refactoring: Goffi <goffi@goffi.org> parents: 1771 diff changeset	344 subscriptionIdentifier=None, sender=None, rsm_request=None):
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	345 """
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	346 Retrieve previously published items from a publish subscribe node.
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	347
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	348 @param service: The publish subscribe service that keeps the node.
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	349 @type service: L{JID<twisted.words.protocols.jabber.jid.JID>}
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	350
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	351 @param nodeIdentifier: The identifier of the node.
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	352 @type nodeIdentifier: C{unicode}
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	353
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	354 @param maxItems: Optional limit on the number of retrieved items.
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	355 @type maxItems: C{int}
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	356
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	357 @param itemIdentifiers: Identifiers of the items to be retrieved.
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	358 @type itemIdentifiers: C{set}
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	359
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	360 @param subscriptionIdentifier: Optional subscription identifier. In
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	361 case the node has been subscribed to multiple times, this narrows
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	362 the results to the specific subscription.
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	363 @type subscriptionIdentifier: C{unicode}
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	364
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	365 @param ext_data: extension data.
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	366 @type ext_data: L{dict}
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	367
1773 6e867caf4621 plugin XEP-0060, tmp(wokkel.rsm): small refactoring: Goffi <goffi@goffi.org> parents: 1771 diff changeset	368 @return: a Deferred that fires a C{list} of C{tuple} of L{domish.Element}, L{RSMResponse}.
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	369 @rtype: L{defer.Deferred}
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	370 """
1773 6e867caf4621 plugin XEP-0060, tmp(wokkel.rsm): small refactoring: Goffi <goffi@goffi.org> parents: 1771 diff changeset	371 # XXX: we have to copy initial method instead of calling it,
6e867caf4621 plugin XEP-0060, tmp(wokkel.rsm): small refactoring: Goffi <goffi@goffi.org> parents: 1771 diff changeset	372 # as original cb remove all non item elements
6e867caf4621 plugin XEP-0060, tmp(wokkel.rsm): small refactoring: Goffi <goffi@goffi.org> parents: 1771 diff changeset	373 request = self._request_class('items')
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	374 request.recipient = service
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	375 request.nodeIdentifier = nodeIdentifier
1773 6e867caf4621 plugin XEP-0060, tmp(wokkel.rsm): small refactoring: Goffi <goffi@goffi.org> parents: 1771 diff changeset	376 if maxItems:
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	377 request.maxItems = str(int(maxItems))
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	378 request.subscriptionIdentifier = subscriptionIdentifier
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	379 request.sender = sender
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	380 request.itemIdentifiers = itemIdentifiers
1773 6e867caf4621 plugin XEP-0060, tmp(wokkel.rsm): small refactoring: Goffi <goffi@goffi.org> parents: 1771 diff changeset	381 request.rsm = rsm_request
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	382
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	383 def cb(iq):
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	384 items = []
1773 6e867caf4621 plugin XEP-0060, tmp(wokkel.rsm): small refactoring: Goffi <goffi@goffi.org> parents: 1771 diff changeset	385 pubsub_elt = iq.pubsub
6e867caf4621 plugin XEP-0060, tmp(wokkel.rsm): small refactoring: Goffi <goffi@goffi.org> parents: 1771 diff changeset	386 for element in pubsub_elt.items.elements(pubsub.NS_PUBSUB, 'item'):
6e867caf4621 plugin XEP-0060, tmp(wokkel.rsm): small refactoring: Goffi <goffi@goffi.org> parents: 1771 diff changeset	387 items.append(element)
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	388
1773 6e867caf4621 plugin XEP-0060, tmp(wokkel.rsm): small refactoring: Goffi <goffi@goffi.org> parents: 1771 diff changeset	389 try:
1780 4beb613d277c tmp (wokkel.rsm): fixed forgotten method renaming Goffi <goffi@goffi.org> parents: 1773 diff changeset	390 rsm_response = RSMResponse.fromElement(pubsub_elt)
1773 6e867caf4621 plugin XEP-0060, tmp(wokkel.rsm): small refactoring: Goffi <goffi@goffi.org> parents: 1771 diff changeset	391 except RSMNotFoundError:
6e867caf4621 plugin XEP-0060, tmp(wokkel.rsm): small refactoring: Goffi <goffi@goffi.org> parents: 1771 diff changeset	392 rsm_response = None
6e867caf4621 plugin XEP-0060, tmp(wokkel.rsm): small refactoring: Goffi <goffi@goffi.org> parents: 1771 diff changeset	393 return (items, rsm_response)
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	394
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	395 d = request.send(self.xmlstream)
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	396 d.addCallback(cb)
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	397 return d
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	398
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	399
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	400 class PubSubService(pubsub.PubSubService):
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	401 """PubSubService extension to handle RSM."""
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	402
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	403 _request_class = PubSubRequest
9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	404
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	405 def _toResponse_items(self, elts, resource, request):
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	406 # default method only manage <item/> elements
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	407 # but we need to add RSM set element
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	408 rsm_elt = None
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	409 for idx, elt in enumerate(reversed(elts)):
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	410 if elt.name == "set" and elt.uri == NS_RSM:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	411 rsm_elt = elts.pop(-1-idx)
1510 91631837ce5c tmp (wokkel): fixes RSM implementation to fit sat_pubsub answer when in "unrestricted" mode souliane <souliane@mailoo.org> parents: 1455 diff changeset	412 break
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	413
1771 b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	414 response = pubsub.PubSubService._toResponse_items(self, elts,
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	415 resource, request)
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	416 if rsm_elt is not None:
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	417 response.addChild(rsm_elt)
b77dc676a4df tmp (wokkel/rsm): various improvments: Goffi <goffi@goffi.org> parents: 1768 diff changeset	418
1266 9141bde7ff31 use sat.tmp.wokkel as a buffer module until the changes are integrated to wokkel souliane <souliane@mailoo.org> parents: diff changeset	419 return response

Mercurial > libervia-backend

annotate src/tmp/wokkel/rsm.py @ 1781:0158ab00afea