summaryrefslogtreecommitdiff
path: root/src/connection.py
diff options
context:
space:
mode:
authorlouiz@4325f9fc-e183-4c21-96ce-0ab188b42d13 <louiz@4325f9fc-e183-4c21-96ce-0ab188b42d13>2010-07-19 23:55:20 +0000
committerlouiz@4325f9fc-e183-4c21-96ce-0ab188b42d13 <louiz@4325f9fc-e183-4c21-96ce-0ab188b42d13>2010-07-19 23:55:20 +0000
commit0cd619660c83a238bd0192ac5707e1ab591d7408 (patch)
tree5a7311a1f6997de4bef22cf13c15ba38b1c6eebf /src/connection.py
parente656e5924bef38d5e69fffca6e1d46c7bed69139 (diff)
downloadpoezio-0cd619660c83a238bd0192ac5707e1ab591d7408.tar.gz
poezio-0cd619660c83a238bd0192ac5707e1ab591d7408.tar.bz2
poezio-0cd619660c83a238bd0192ac5707e1ab591d7408.tar.xz
poezio-0cd619660c83a238bd0192ac5707e1ab591d7408.zip
fixed #1587
Diffstat (limited to 'src/connection.py')
-rw-r--r--src/connection.py29
1 files changed, 20 insertions, 9 deletions
diff --git a/src/connection.py b/src/connection.py
index 62f17bb5..5e36ba97 100644
--- a/src/connection.py
+++ b/src/connection.py
@@ -31,7 +31,7 @@ import xmpp
from config import config
from logging import logger
from handler import Handler
-from common import jid_get_node, jid_get_domain, is_jid_the_same
+from common import jid_get_node, jid_get_domain, is_jid_the_same, exception_handler
class Connection(threading.Thread):
"""
@@ -125,21 +125,32 @@ class Connection(threading.Thread):
def handler_presence(self, connection, presence):
"""
- handles the presence messages
+ check if it's a normal or a muc presence
+ """
+ x = presence.getTag('x')
+ if x and x.getAttr('xmlns') == 'http://jabber.org/protocol/muc#user':
+ self.handler_muc_presence(connection, presence)
+ else:
+ self.handler_normal_presence(connection, presence)
+
+ def handler_normal_presence(self, connection, presence):
+ """
"""
- from common import debug
- debug('%s\n' % presence)
- if not connection:
- return
- if presence.getType() == 'error':
- self.error_message(presence)
- return
fro = presence.getFrom()
toj = presence.getAttr('to')
if fro == toj: # own presence
self.online = 2
self.jid = toj
self.handler.emit('on-connected', jid=fro)
+
+ def handler_muc_presence(self, connection, presence):
+ """
+ handles the presence messages
+ """
+ if not connection:
+ return
+ if presence.getType() == 'error':
+ self.error_message(presence)
return
self.handler.emit('room-presence', stanza=presence)
raise xmpp.protocol.NodeProcessed