Changeset 753

Show
Ignore:
Timestamp:
07/31/08 10:24:21 (4 months ago)
Author:
sylvain
Message:

more PubSub? coverage

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved
  • oss/headstock/headstock/api/discovery.py

    r748 r753  
    6464    def __init__(self, from_jid, to_jid, node_name=None, type=u'get', stanza_id=None): 
    6565        Entity.__init__(self, from_jid, to_jid, type, stanza_id) 
    66         self.data_form = None 
     66        self.x = None 
    6767        self.node_name = node_name 
    6868        self.identities = [] 
     
    117117                            disco.items.append(item) 
    118118                    elif i.xml_ns == XMPP_DATA_FORM_NS: 
    119                         disco.data_form = Data.from_element(i) 
     119                        disco.x = Data.from_element(i) 
    120120            elif c.xml_ns == XMPP_CLIENT_NS and c.xml_name == 'error': 
    121121                disco.error = Error.from_element(c) 
     
    253253    def __init__(self, from_jid, to_jid, node_name=None, type=u'get', stanza_id=None): 
    254254        Entity.__init__(self, from_jid, to_jid, type, stanza_id) 
    255         self.data_form = None 
     255        self.x = None 
    256256        self.node_name = node_name 
    257         self.identities = [] 
     257        self.identity = None 
    258258        self.features = [] 
    259259        self.items = [] 
     
    287287                                             i.get_attribute_value('category'), 
    288288                                             i.get_attribute_value('type')) 
    289                             disco.identities.append(ident) 
     289                            disco.identity = ident 
    290290                        elif i.xml_name == 'feature': 
    291291                            feat = Feature(i.get_attribute_value('var')) 
     
    298298                            disco.items.append(item) 
    299299                    elif i.xml_ns == XMPP_DATA_FORM_NS: 
    300                         disco.data_form = Data.from_element(i) 
    301             elif c.xml_ns == XMPP_CLIENT_NS and c.xml_name == 'error': 
    302                 disco.error = Error.from_element(c) 
    303         return disco 
     300                        disco.x = Data.from_element(i) 
     301            elif c.xml_ns == XMPP_CLIENT_NS and c.xml_name == 'error': 
     302                disco.error = Error.from_element(c) 
     303        return disco 
  • oss/headstock/headstock/api/im.py

    r716 r753  
    55 
    66from xml.sax.saxutils import unescape 
     7     
    78from datetime import datetime 
    89 
  • oss/headstock/headstock/api/pubsub.py

    r739 r753  
    317317        attrs = {u'node': e.node_name} 
    318318        items = E(u'items', attributes=attrs, namespace=XMPP_PUBSUB_NS, parent=pubsub) 
    319         attrs = {u'id': e.item.id} 
    320         item = E(u'item', attributes=attrs, namespace=XMPP_PUBSUB_NS, parent=items) 
     319        if e.item: 
     320            attrs = {u'id': e.item.id} 
     321            E(u'item', attributes=attrs, namespace=XMPP_PUBSUB_NS, parent=items) 
    321322 
    322323        return iq 
     
    345346 
    346347        return node 
    347          
    348348     
     349    from_request_all_items = from_request_item 
     350    to_request_all_items = to_request_item 
     351 
  • oss/headstock/headstock/protocol/core/message.py

    r459 r753  
    2525     
    2626    def __init__(self): 
    27        super(MessageDispatcher, self).__init__()  
     27       super(MessageDispatcher, self).__init__() 
    2828 
    2929    def main(self): 
  • oss/headstock/headstock/protocol/extension/pubsub.py

    r748 r753  
    726726        self.link((self, 'in.retrieve.result'), (itemretrievedisp, 'forward'), passthrough=1) 
    727727        self.link((self, 'in.retrieve.error'), (itemretrievedisp, 'forward'), passthrough=1) 
     728        self.link((self, 'retrieve.all.inbox'), (itemretrievedisp, 'inbox'), passthrough=1) 
     729        self.link((self, 'retrieve.all.forward'), (itemretrievedisp, 'forward'), passthrough=1) 
     730        self.link((self, 'in.retrieve.get'), (itemretrievedisp, 'forward'), passthrough=1) 
     731        self.link((self, 'in.retrieve.set'), (itemretrievedisp, 'forward'), passthrough=1) 
     732        self.link((self, 'in.retrieve.result'), (itemretrievedisp, 'forward'), passthrough=1) 
     733        self.link((self, 'in.retrieve.error'), (itemretrievedisp, 'forward'), passthrough=1) 
    728734        self.link((itemretrievedisp, 'outbox'), (self, 'retrieve.outbox'), passthrough=2) 
    729735        self.link((itemretrievedisp, 'xmpp.get'), (self, 'out.retrieve.get'), passthrough=2)