From 58feae6cee1c090565fc1e9a5908ef01dd65c93c Mon Sep 17 00:00:00 2001 From: Yann Leboulanger Date: Fri, 29 Oct 2010 16:49:53 +0200 Subject: [PATCH] use NEC to handle jingle-disconnected events --- src/common/connection_handlers_events.py | 10 ++++++++ src/common/jingle_session.py | 25 +++++++++++-------- src/gui_interface.py | 31 ++++++++++++------------ 3 files changed, 40 insertions(+), 26 deletions(-) diff --git a/src/common/connection_handlers_events.py b/src/common/connection_handlers_events.py index 2f7bdcbd7..a5e1a0969 100644 --- a/src/common/connection_handlers_events.py +++ b/src/common/connection_handlers_events.py @@ -1128,6 +1128,16 @@ class JingleConnectedReceivedEvent(nec.NetworkIncomingEvent): name = 'jingle-connected-received' base_network_events = [] + def generate(self): + self.fjid = self.jingle_session.peerjid + self.jid, self.resource = gajim.get_room_and_nick_from_fjid(self.fjid) + self.sid = self.jingle_session.sid + return True + +class JingleDisconnectedReceivedEvent(nec.NetworkIncomingEvent): + name = 'jingle-disconnected-received' + base_network_events = [] + def generate(self): self.fjid = self.jingle_session.peerjid self.jid, self.resource = gajim.get_room_and_nick_from_fjid(self.fjid) diff --git a/src/common/jingle_session.py b/src/common/jingle_session.py index e83a3dcab..2447e7759 100644 --- a/src/common/jingle_session.py +++ b/src/common/jingle_session.py @@ -368,8 +368,9 @@ class JingleSession(object): if (creator, name) in self.contents: content = self.contents[(creator, name)] # TODO: this will fail if content is not an RTP content - self.connection.dispatch('JINGLE_DISCONNECTED', - (self.peerjid, self.sid, content.media, 'removed')) + gajim.nec.push_incoming_event(JingleDisconnectedReceivedEvent( + None, conn=self.connection, jingle_session=self, + media=content.media, reason='removed')) content.destroy() if not self.contents: reason = xmpp.Node('reason') @@ -482,8 +483,9 @@ class JingleSession(object): else: # TODO text = reason - self.connection.dispatch('JINGLE_DISCONNECTED', - (self.peerjid, self.sid, None, text)) + gajim.nec.push_incoming_event(JingleDisconnectedReceivedEvent(None, + conn=self.connection, jingle_session=self, media=None, + reason=text)) def __broadcast_all(self, stanza, jingle, error, action): """ @@ -634,8 +636,9 @@ class JingleSession(object): else: text = reason self.connection.delete_jingle_session(self.sid) - self.connection.dispatch('JINGLE_DISCONNECTED', - (self.peerjid, self.sid, None, text)) + gajim.nec.push_incoming_event(JingleDisconnectedReceivedEvent(None, + conn=self.connection, jingle_session=self, media=None, + reason=text)) def __content_add(self, content): # TODO: test @@ -659,8 +662,9 @@ class JingleSession(object): self.__append_content(jingle, content) self.connection.connection.send(stanza) # TODO: this will fail if content is not an RTP content - self.connection.dispatch('JINGLE_DISCONNECTED', - (self.peerjid, self.sid, content.media, 'rejected')) + gajim.nec.push_incoming_event(JingleDisconnectedReceivedEvent(None, + conn=self.connection, jingle_session=self, media=content.media, + reason='rejected')) def __content_modify(self): assert self.state != JingleStates.ended @@ -671,8 +675,9 @@ class JingleSession(object): self.__append_content(jingle, content) self.connection.connection.send(stanza) # TODO: this will fail if content is not an RTP content - self.connection.dispatch('JINGLE_DISCONNECTED', - (self.peerjid, self.sid, content.media, 'removed')) + gajim.nec.push_incoming_event(JingleDisconnectedReceivedEvent(None, + conn=self.connection, jingle_session=self, media=content.media, + reason='removed')) def content_negotiated(self, media): gajim.nec.push_incoming_event(JingleConnectedReceivedEvent(None, diff --git a/src/gui_interface.py b/src/gui_interface.py index ff7a0ac04..38ff32b50 100644 --- a/src/gui_interface.py +++ b/src/gui_interface.py @@ -1555,26 +1555,24 @@ class Interface: else: ctrl.set_video_state('connected', obj.sid) - def handle_event_jingle_disconnected(self, account, data): + def handle_event_jingle_disconnected(self, obj): # ('JINGLE_DISCONNECTED', account, (peerjid, sid, reason)) - peerjid, sid, media, reason = data - jid = gajim.get_jid_without_resource(peerjid) - resource = gajim.get_resource_from_jid(peerjid) - ctrl = (self.msg_win_mgr.get_control(peerjid, account) - or self.msg_win_mgr.get_control(jid, account)) + account = obj.conn.name + ctrl = (self.msg_win_mgr.get_control(obj.fjid, account) + or self.msg_win_mgr.get_control(obj.jid, account)) if ctrl: - if media is None: - ctrl.stop_jingle(sid=sid, reason=reason) - elif media == 'audio': - ctrl.set_audio_state('stop', sid=sid, reason=reason) - elif media == 'video': - ctrl.set_video_state('stop', sid=sid, reason=reason) - dialog = dialogs.VoIPCallReceivedDialog.get_dialog(peerjid, sid) + if obj.media is None: + ctrl.stop_jingle(sid=obj.sid, reason=obj.reason) + elif obj.media == 'audio': + ctrl.set_audio_state('stop', sid=obj.sid, reason=obj.reason) + elif obj.media == 'video': + ctrl.set_video_state('stop', sid=obj.sid, reason=obj.reason) + dialog = dialogs.VoIPCallReceivedDialog.get_dialog(obj.fjid, obj.sid) if dialog: - if media is None: + if obj.media is None: dialog.dialog.destroy() else: - dialog.remove_contents((media, )) + dialog.remove_contents((obj.media, )) def handle_event_jingle_error(self, account, data): # ('JINGLE_ERROR', account, (peerjid, sid, reason)) @@ -1890,7 +1888,6 @@ class Interface: 'INSECURE_SSL_CONNECTION': \ [self.handle_event_insecure_ssl_connection], 'INSECURE_PASSWORD': [self.handle_event_insecure_password], - 'JINGLE_DISCONNECTED': [self.handle_event_jingle_disconnected], 'JINGLE_ERROR': [self.handle_event_jingle_error], 'PEP_RECEIVED': [self.handle_event_pep_received], 'CAPS_RECEIVED': [self.handle_event_caps_received], @@ -1903,6 +1900,8 @@ class Interface: 'http-auth-received': [self.handle_event_http_auth], 'iq-error-received': [self.handle_event_iq_error], 'jingle-connected-received': [self.handle_event_jingle_connected], + 'jingle-disconnected-received': [ + self.handle_event_jingle_disconnected], 'jingle-request-received': [self.handle_event_jingle_incoming], 'last-result-received': [self.handle_event_last_status_time], 'muc-admin-received': [self.handle_event_gc_affiliation],