# HG changeset patch
# User Matthew Wild <mwild1@gmail.com>
# Date 1291745891 0
# Node ID b758e4ad30a0b489dad13e8688950f4b9f90c067
# Parent  ddbac8737c2d4d1830f961e1303b8d441684f73c
xmppcomponent_listener: Switch to util.xmppstream from xmlhandlers

diff -r ddbac8737c2d -r b758e4ad30a0 net/xmppcomponent_listener.lua
--- a/net/xmppcomponent_listener.lua	Tue Dec 07 22:55:28 2010 +0500
+++ b/net/xmppcomponent_listener.lua	Tue Dec 07 18:18:11 2010 +0000
@@ -19,7 +19,7 @@
 local jid_split = require "util.jid".split;
 local sha1 = require "util.hashes".sha1;
 local st = require "util.stanza";
-local init_xmlhandlers = require "core.xmlhandlers";
+local new_xmpp_stream = require "util.xmppstream".new;
 
 local sessions = {};
 
@@ -29,7 +29,7 @@
 
 local xmlns_component = 'jabber:component:accept';
 
---- Callbacks/data for xmlhandlers to handle streams for us ---
+--- Callbacks/data for xmppstream to handle streams for us ---
 
 local stream_callbacks = { default_ns = xmlns_component };
 
@@ -177,13 +177,18 @@
 		
 		session.log("info", "Incoming Jabber component connection");
 		
-		local parser = lxp.new(init_xmlhandlers(session, stream_callbacks), "\1");
-		session.parser = parser;
+		local stream = new_xmpp_stream(session, stream_callbacks);
+		session.stream = stream;
 		
 		session.notopen = true;
 		
+		function session.reset_stream()
+			session.notopen = true;
+			session.stream:reset();
+		end
+	
 		function session.data(conn, data)
-			local ok, err = parser:parse(data);
+			local ok, err = stream:feed(data);
 			if ok then return; end
 			log("debug", "Received invalid XML (%s) %d bytes: %s", tostring(err), #data, data:sub(1, 300):gsub("[\r\n]+", " "):gsub("[%z\1-\31]", "_"));
 			session:close("not-well-formed");