Changeset 103

Show
Ignore:
Timestamp:
04/15/02 18:44:09 (6 years ago)
Author:
sholloway
Message:

*** empty log message ***

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved

  • trunk/RBJabber/RBJabber/Client.py

    r102 r103  
    118118    stream = None 
    119119    SupportedNS = None 
    120     ClientMonitors = None 
    121120 
    122121    def __init__(self, *args, **kw): 
    …… 
    126125         
    127126        self.SupportedNS = [] 
    128         self.ClientMonitors = [] 
    129127        self.__NextID = 0 
    130128 
    …… 
    156154 
    157155    def SetData(self, namespace, xml): 
    158         self.SenddXML('''<iq id='%s' type='set'><query xmlns='%s'>%s</query></iq> ''' % (self._GetNextID(), namespace, xmlData)) 
     156        self.SendXML('''<iq id='%s' type='set'><query xmlns='%s'>%s</query></iq> ''' % (self._GetNextID(), namespace, xmlData)) 
    159157  
    160158    def GetData(self, namespace, callback=None, xml=''): 

  • trunk/RBJabber/RBJabber/JabberObserver.py

    r96 r103  
    116116 
    117117class JabberObserver(BoundCallable): 
     118    _debug = 0 
    118119    def __init__(self, callback=None, Match=None, BidValue=1): 
    119120        super(JabberObserver, self).__init__(callback) 
    …… 
    125126            if self.Match(value): 
    126127                return self.BidValue 
     128            elif self._debug: 
     129                print "!!! No Match !!!" 
     130                for each in self.Match: 
     131                    print each(value), '==', each.__class__.__name__ 
    127132 
    128133 

  • trunk/RBJabber/RBJabber/Test.py

    r96 r103  
    4040import iqBrowseResponse 
    4141import SubscribeApproveResponse 
     42import PresenceMap 
    4243 
    4344#~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ 
    …… 
    4647 
    4748def _test(server, username, password, resource='Foundation.Jabber.Test'): 
     49    def PrintMe(*args, **kw): 
     50        print "PrintMe:", args, kw 
    4851    try: 
    4952        jc = Client.Client(server) 
    …… 
    5154 
    5255        #jc.Register(username, password) 
    53         authq = jc.Authenticate(username, password, resource) 
     56        jc.Authenticate(username, password, resource, callback=PrintMe) 
    5457         
    55         #pm = PresenceMap(jc) 
     58        pm = PresenceMap.PresenceMap(jc) 
    5659 
    5760        jc.BrowseJID('www.runeblade.com', None) 
     61        jc.BrowseJID('sholloway@www.runeblade.com', None) 
    5862 
    5963        jc.Presence() 
    …… 
    7175        jc.SendXML('''<presence type="unavailable" />''') 
    7276 
     77    # Print out the roster 
     78    print  
     79    print "Roster" 
     80    print "~"*10 
     81    for jid, rosteritem in jc.Roster.ByJID.iteritems(): 
     82        print jid, rosteritem.subscription 
     83        print "    ", ''.join([x() for x in getattr(rosteritem, 'group', [])]) 
     84    print "~"*10 
     85    print  
     86 
     87    # Print out the presence map 
     88    print  
     89    print "Presence Map" 
     90    print "~"*10 
     91    for jid, resouces in pm.ByResource.iteritems(): 
     92        print jid 
     93        for resource, presence in resouces.iteritems(): 
     94            print "    %s: %s (%s)" % (resource, getattr(presence, 'status', [''])[0], getattr(presence, 'show', [''])[0]) 
     95    print "~"*10 
     96    print 
     97 
    7398#~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ 
    7499 

  • trunk/RBJabber/RBJabber/iqAuthQuery.py

    r96 r103  
    4646class iqAuthQuery(iqQueryBase): 
    4747    def __init__(self, JC, username, password, resource, callback=None, BidValue=1): 
    48         self.OnAuthCallback = BindCallable(callback) 
    49         iqQueryBase.__init__(self, JC, self.OnAuthReply, BidValue) 
     48        iqQueryBase.__init__(self, JC, callback, BidValue) 
    5049 
    5150        while not self.JC()._elements: 
    …… 
    5958         
    6059        self.SendQuery('jabber:iq:auth', typeQuery='set', xmlQueryPayload=xmlAuthInfo) 
     60        # The last match assertion says that there is a child  
     61        # in the jabber:iq:auth namespace, which there won't be.   
     62        # So remove that match criteria. 
     63        self.Match.pop() 
    6164 
    62     def OnAuthReply(self, stream, iq): 
     65    def __nonzero__(self): 
     66        if self.JC().information.authorized: 
     67            # We can be deallocated when we have been authenticated 
     68            return 0 
     69        else: return super(iqAuthQuery, self).__nonzero__() 
     70         
     71    def __call__(self, stream, iq): 
    6372        if iq.type == 'result': 
    6473            self.JC().information.authorized = 1 
    65         if self.OnAuthCallback: 
    66             self.OnAuthCallback(stream, iq) 
     74        super(iqAuthQuery, self).__call__(stream, iq) 
    6775 

  • trunk/RBJabber/RBJabber/iqQuery.py

    r96 r103  
    7676 
    7777class iqQuery(iqQueryBase): 
    78     pass 
     78    _serviced = 0 
     79    def __nonzero__(self): 
     80        if self._serviced: return 0 
     81        else: super(iqQuery, self).__nonzero__() 
    7982 
     83    def __call__(self, *args, **kw): 
     84        self._serviced = 1 
     85        apply(super(iqQuery, self).__call__, args, kw)