plugins/compression.lua

changeset 197
7e98cf2c1d8d
parent 176
6004486e8b6c
child 250
a5ac643a7fd6
--- a/plugins/compression.lua	Thu Mar 17 01:30:44 2011 +0100
+++ b/plugins/compression.lua	Thu Mar 17 18:33:52 2011 +0100
@@ -5,7 +5,6 @@
 -- COPYING file in the source package for more information.
 --
 
-local st = require "util.stanza";
 local zlib = require "zlib";
 
 local xmlns_compression_feature = "http://jabber.org/features/compress"
@@ -18,7 +17,7 @@
 local function get_deflate_stream(session)
 	local status, deflate_stream = pcall(zlib.deflate, compression_level);
 	if status == false then
-		local error_st = st.stanza("failure", {xmlns=xmlns_compression_protocol}):tag("setup-failed");
+		local error_st = verse.stanza("failure", {xmlns=xmlns_compression_protocol}):tag("setup-failed");
 		session:send(error_st);
 		session:error("Failed to create zlib.deflate filter: %s", tostring(deflate_stream));
 		return
@@ -30,7 +29,7 @@
 local function get_inflate_stream(session)
 	local status, inflate_stream = pcall(zlib.inflate);
 	if status == false then
-		local error_st = st.stanza("failure", {xmlns=xmlns_compression_protocol}):tag("setup-failed");
+		local error_st = verse.stanza("failure", {xmlns=xmlns_compression_protocol}):tag("setup-failed");
 		session:send(error_st);
 		session:error("Failed to create zlib.inflate filter: %s", tostring(inflate_stream));
 		return
@@ -47,7 +46,7 @@
 				session:close({
 					condition = "undefined-condition";
 					text = compressed;
-					extra = st.stanza("failure", {xmlns=xmlns_compression_protocol}):tag("processing-failed");
+					extra = verse.stanza("failure", {xmlns=xmlns_compression_protocol}):tag("processing-failed");
 				});
 				session:warn("Compressed send failed: %s", tostring(compressed));
 				return;
@@ -66,7 +65,7 @@
 				session:close({
 					condition = "undefined-condition";
 					text = decompressed;
-					extra = st.stanza("failure", {xmlns=xmlns_compression_protocol}):tag("processing-failed");
+					extra = verse.stanza("failure", {xmlns=xmlns_compression_protocol}):tag("processing-failed");
 				});
 				stream:warn("%s", tostring(decompressed));
 				return;
@@ -85,7 +84,7 @@
 				for a in comp_st:children() do
 					local algorithm = a[1]
 					if algorithm == "zlib" then
-						stream:send(st.stanza("compress", {xmlns=xmlns_compression_protocol}):tag("method"):text("zlib"))
+						stream:send(verse.stanza("compress", {xmlns=xmlns_compression_protocol}):tag("method"):text("zlib"))
 						stream:debug("Enabled compression using zlib.")
 						return true;
 					end

mercurial