diff src/core/xmpp.py @ 587:952322b1d490

Remove trailing whitespaces.
author Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
date Fri, 18 Jan 2013 17:55:34 +0100
parents ca13633d3b6b
children d1b4805124a1
line wrap: on
line diff
--- a/src/core/xmpp.py	Fri Jan 18 17:55:27 2013 +0100
+++ b/src/core/xmpp.py	Fri Jan 18 17:55:34 2013 +0100
@@ -28,7 +28,7 @@
 
 
 class SatXMPPClient(client.XMPPClient):
-    
+
     def __init__(self, host_app, profile, user_jid, password, host=None, port=5222):
         client.XMPPClient.__init__(self, user_jid, password, host, port)
         self.factory.clientConnectionLost = self.connectionLost
@@ -39,7 +39,7 @@
         self.conn_deferred = defer.Deferred()
         self._waiting_conf = {}  #callback called when a confirmation is received
         self._progress_cb_map = {}  #callback called when a progress is requested (key = progress id)
-        
+
 
     def getConnectionDeferred(self):
         """Return a deferred which fire when the client is connected"""
@@ -53,28 +53,28 @@
         info (_("********** [%s] CONNECTED **********") % self.profile)
         self.streamInitialized()
         self.host_app.bridge.connected(self.profile) #we send the signal to the clients
-   
+
 
     def streamInitialized(self):
         """Called after _authd"""
         debug (_("XML stream is initialized"))
         self.keep_alife = task.LoopingCall(self.xmlstream.send, " ")  #Needed to avoid disconnection (specially with openfire)
         self.keep_alife.start(180)
-        
+
         self.disco = SatDiscoProtocol(self)
         self.disco.setHandlerParent(self)
         self.discoHandler = disco.DiscoHandler()
         self.discoHandler.setHandlerParent(self)
-        
+
         if not self.host_app.trigger.point("Disco Handled", self.profile):
             return
 
         self.roster.requestRoster()
-        
+
         self.presence.available()
-       
+
         self.disco.requestInfo(jid.JID(self.jid.host)).addCallback(self.host_app.serverDisco, self.profile)  #FIXME: use these informations
-        
+
         self.disco.requestItems(jid.JID(self.jid.host)).addCallback(self.host_app.serverDiscoItems, self.disco, self.profile, self.client_initialized)
         self.conn_deferred.callback(None)
 
@@ -90,7 +90,7 @@
 
     def isConnected(self):
         return self.__connected
-    
+
     def connectionLost(self, connector, unused_reason):
         self.__connected=False
         info (_("********** [%s] DISCONNECTED **********") % self.profile)
@@ -103,7 +103,7 @@
 
 
 class SatMessageProtocol(xmppim.MessageProtocol):
-    
+
     def __init__(self, host):
         xmppim.MessageProtocol.__init__(self)
         self.host = host
@@ -128,7 +128,7 @@
                     self.host.memory.addToHistory(jid.JID(message["from"]), jid.JID(message["to"]), mess_body, mess_type, profile=self.parent.profile)
                 self.host.bridge.newMessage(message["from"], mess_body, mess_type, message['to'], extra, profile=self.parent.profile)
                 break
-    
+
 class SatRosterProtocol(xmppim.RosterClientProtocol):
 
     def __init__(self, host):
@@ -138,7 +138,7 @@
         #XXX: the two following dicts keep a local copy of the roster
         self._groups = {} #map from groups to bare jids: key=group value=set of bare jids
         self._jids = {} #map from bare jids to RosterItem: key=jid value=RosterItem
-    
+
     def rosterCb(self, roster):
         for raw_jid, item in roster.iteritems():
             self.onRosterSet(item)
@@ -153,7 +153,7 @@
         """Remove a contact from roster list"""
         xmppim.RosterClientProtocol.removeItem(self, to)
         #TODO: check IQ result
-    
+
     #XXX: disabled (cf http://wokkel.ik.nu/ticket/56))
     #def addItem(self, to):
         #"""Add a contact to roster list"""
@@ -187,7 +187,7 @@
         if item.name:
             item_attr['name'] = item.name
         return item_attr
-    
+
     def onRosterSet(self, item):
         """Called when a new/update roster item is received"""
         #TODO: send a signal to frontends
@@ -199,13 +199,13 @@
             return
         info (_("new contact in roster list: %s"), item.jid.full())
         #self.host.memory.addContact(item.jid, item_attr, item.groups, self.parent.profile)
-       
+
         bare_jid = item.jid.userhost()
         self._jids[bare_jid] = item
         for group in item.groups:
             self._groups.setdefault(group,set()).add(bare_jid)
         self.host.bridge.newContact(item.jid.full(), self.getAttributes(item), item.groups, self.parent.profile)
-    
+
     def onRosterRemove(self, entity):
         """Called when a roster removal event is received"""
         print _("removing %s from roster list") % entity.full()
@@ -226,7 +226,7 @@
             except KeyError:
                 log.warning("there is not cache for the group [%(groups)s] of the removed roster item [%(jid)s]" %
                             {"group": group, "jid": bare_jid})
-                                                                                                                            
+
         #then we send the bridge signal
         self.host.bridge.contactDeleted(entity.userhost(), self.parent.profile)
 
@@ -247,7 +247,7 @@
     def isJidInRoster(self, entity_jid):
         """Return True if jid is in roster"""
         return entity_jid.userhost() in self._jids
-    
+
     def getItems(self):
         """Return all items of the roster"""
         return self._jids.values()
@@ -257,20 +257,20 @@
             return self._groups[group]
         except KeyError:
             return  exceptions.UnknownGroupError
-        
+
 
 class SatPresenceProtocol(xmppim.PresenceClientProtocol):
 
     def __init__(self, host):
         xmppim.PresenceClientProtocol.__init__(self)
         self.host = host
-    
+
     def availableReceived(self, entity, show=None, statuses=None, priority=0):
         debug (_("presence update for [%(entity)s] (available, show=%(show)s statuses=%(statuses)s priority=%(priority)d)") % {'entity':entity, 'show':show, 'statuses':statuses, 'priority':priority})
-        
+
         if not statuses:
             statuses = {}
-        
+
         if statuses.has_key(None):   #we only want string keys
             statuses["default"] = statuses[None]
             del statuses[None]
@@ -281,13 +281,13 @@
         #now it's time to notify frontends
         self.host.bridge.presenceUpdate(entity.full(),  show or "",
                 int(priority), statuses, self.parent.profile)
-    
+
     def unavailableReceived(self, entity, statuses=None):
         debug (_("presence update for [%(entity)s] (unavailable, statuses=%(statuses)s)") % {'entity':entity, 'statuses':statuses})
-        
+
         if not statuses:
             statuses = {}
-        
+
         if statuses.has_key(None):   #we only want string keys
             statuses["default"] = statuses[None]
             del statuses[None]
@@ -295,13 +295,13 @@
 
         #now it's time to notify frontends
         self.host.bridge.presenceUpdate(entity.full(), "unavailable", 0, statuses, self.parent.profile)
-        
-    
+
+
     def available(self, entity=None, show=None, statuses=None, priority=0):
         if not statuses:
             statuses = {}
             # default for us is None for wokkel
-            # so we must temporarily switch to wokkel's convention...	
+            # so we must temporarily switch to wokkel's convention...
             if 'default' in statuses:
                 statuses[None] = statuses['default']
 
@@ -380,10 +380,10 @@
         self.answer_id = answer_id
         self.profile = profile
         print _("Registration asked for"),user_login, user_pass, jabber_host
-    
+
     def connectionMade(self):
         print "connectionMade"
-        
+
         self.xmlstream.namespace = "jabber:client"
         self.xmlstream.sendHeader()
 
@@ -405,7 +405,7 @@
         answer_data={"message":_("Registration successfull")}
         self.host.bridge.actionResult(answer_type, self.answer_id, answer_data, self.profile)
         self.xmlstream.sendFooter()
-        
+
     def registrationFailure(self, failure):
         info (_("Registration failure: %s") % str(failure.value))
         answer_type = "ERROR"