Skip to content
Commits on Source (3)
......@@ -418,7 +418,7 @@ class XMPPDispatcher(PlugIn):
#log.info('dispatch called: stanza = %s, session = %s, direct= %s'
# % (stanza, session, direct))
self.Event('', 'STANZA_RECEIVED', stanza)
self.Event('', 'STANZA RECEIVED', stanza)
if not session:
session = self
......@@ -441,7 +441,7 @@ class XMPPDispatcher(PlugIn):
xmlns = 'unknown'
# features stanza has been handled before
if name not in self.handlers[xmlns]:
if name != 'features':
if name not in ('features', 'stream'):
log.warning('Unknown stanza: %s', stanza)
else:
log.debug('Got %s/%s stanza' % (xmlns, name))
......@@ -577,8 +577,6 @@ class XMPPDispatcher(PlugIn):
if self._owner._registered_name and not stanza.getAttr('from'):
stanza.setAttr('from', self._owner._registered_name)
self.Event('', 'STANZA_SENT', stanza)
self._owner.Connection.send(stanza, now)
# If no ID then it is a whitespace
......
......@@ -634,6 +634,9 @@ class NodeBuilder(object):
self._document_attrs[attr] = val
ns = self._document_nsp.get(nsp, 'http://www.gajim.org/xmlns/undeclared-root')
try:
header = Node(tag=tag, attrs=attrs,
nsp=self._document_nsp, node_built=True)
self.dispatch(header)
self.stream_header_received(ns, name, attrs)
except ValueError as e:
self._document_attrs = None
......