From c64bac1535a4b28f5c4e1c6a2a109bf42aaa4dcc Mon Sep 17 00:00:00 2001 From: Jefry Lagrange Date: Thu, 30 Aug 2012 23:09:23 -0400 Subject: [PATCH] refactoring --- src/common/connection_handlers_events.py | 31 ++++++++---------------- src/common/jingle_session.py | 5 ++-- 2 files changed, 13 insertions(+), 23 deletions(-) diff --git a/src/common/connection_handlers_events.py b/src/common/connection_handlers_events.py index ee133c33f..f790c1620 100644 --- a/src/common/connection_handlers_events.py +++ b/src/common/connection_handlers_events.py @@ -1986,23 +1986,11 @@ class FileRequestReceivedEvent(nec.NetworkIncomingEvent, HelperEvent): self.file_props.transport_sid = self.FT_content.transport.sid self.FT_content.file_props = self.file_props self.FT_content.transport.set_file_props(self.file_props) - if self.file_props.streamhosts: - self.file_props.streamhosts.extend( + self.file_props.streamhosts.extend( self.FT_content.transport.remote_candidates) - else: - self.file_props.streamhosts = \ - self.FT_content.transport.remote_candidates for host in self.file_props.streamhosts: host['initiator'] = self.FT_content.session.initiator host['target'] = self.FT_content.session.responder - else: - si = self.stanza.getTag('si') - self.file_props = FilesProp.getNewFileProp(self.conn.name, - unicode(si.getAttr('id')) - ) - self.file_props.sender = self.fjid - self.file_props.request_id = self.id_ - if self.jingle_content: self.file_props.session_type = 'jingle' self.file_props.stream_methods = xmpp.NS_BYTESTREAM desc = self.jingle_content.getTag('description') @@ -2024,8 +2012,11 @@ class FileRequestReceivedEvent(nec.NetworkIncomingEvent, HelperEvent): self.file_props.hash_ = val if name == 'date': self.file_props.date = val - else: + si = self.stanza.getTag('si') + self.file_props = FilesProp.getNewFileProp(self.conn.name, + unicode(si.getAttr('id')) + ) profile = si.getAttr('profile') if profile != xmpp.NS_FILE: self.conn.send_file_rejection(self.file_props, code='400', @@ -2056,18 +2047,16 @@ class FileRequestReceivedEvent(nec.NetworkIncomingEvent, HelperEvent): self.file_props.name = val if name == 'size': self.file_props.size = val - file_desc_tag = file_tag.getTag('desc') - if file_desc_tag is not None: - self.file_props.desc = file_desc_tag.getData() - - if not self.jingle_content: mime_type = si.getAttr('mime-type') if mime_type is not None: self.file_props.mime_type = mime_type - + self.file_props.sender = self.fjid + self.file_props.request_id = self.id_ + file_desc_tag = file_tag.getTag('desc') + if file_desc_tag is not None: + self.file_props.desc = file_desc_tag.getData() self.file_props.receiver = self.conn._ft_get_our_jid() self.file_props.transfered_size = [] - return True class FileRequestErrorEvent(nec.NetworkIncomingEvent): diff --git a/src/common/jingle_session.py b/src/common/jingle_session.py index e5da46212..68c0ee313 100644 --- a/src/common/jingle_session.py +++ b/src/common/jingle_session.py @@ -335,8 +335,8 @@ class JingleSession(object): action = 'iq-result' callables = self.callbacks[action] try: - for callable in callables: - callable(stanza=stanza, jingle=jingle, error=error, action=action) + for call in callables: + call(stanza=stanza, jingle=jingle, error=error, action=action) except xmpp.NodeProcessed: pass except TieBreak: @@ -528,6 +528,7 @@ class JingleSession(object): ' is requesting a ' + \ 'file that we dont have') self.decline_session() + raise xmpp.NodeProcessed # If there's no content we understand... if not contents: # TODO: http://xmpp.org/extensions/xep-0166.html#session-terminate