mirrors/prosody
1
0
Fork 0
mirror of https://github.com/bjc/prosody.git synced 2025-04-05 22:27:38 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

Actually inject de- and compression into the reading/writing functions.

Browse source
This commit is contained in:
Tobias Markmann 2009-08-13 09:34:27 +02:00
parent 7e7a5ab089
commit 13bfc062ef
1 changed files with 33 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

34
plugins/mod_compression.lua
View file

@ -6,6 +6,7 @@
--
local st = require "util.stanza";
local zlib = require "zlib";
local print = print
local xmlns_compression_feature = "http://jabber.org/features/compress"
@ -15,7 +16,7 @@ local compression_stream_feature = st.stanza("compression", {xmlns=xmlns_compres
module:add_event_hook("stream-features",
function (session, features)
features:add_child(compression_stream_feature);
if not session.compressed then features:add_child(compression_stream_feature); end
end
);
@ -26,6 +27,37 @@ module:add_handler("c2s_unauthed", "compress", xmlns_compression_protocol,
if method == "zlib" then
session.log("info", method.." compression selected.");
session.send(st.stanza("compressed", {xmlns=xmlns_compression_protocol}));
session:reset_stream();
-- create deflate and inflate streams
local deflate_stream = zlib.deflate(9);
local inflate_stream = zlib.inflate();
-- setup compression for session.w
local old_send = session.send;
session.send = function(t)
local compressed, eof = deflate_stream(tostring(t), 'sync');
old_send(compressed);
end;
-- setup decompression for session.data
local function setup_decompression(session)
local old_data = session.data
session.data = function(conn, data)
local decompressed, eof = inflate_stream(data);
old_data(conn, decompressed);
end;
end
setup_decompression(session);
local session_reset_stream = session.reset_stream;
session.reset_stream = function(session)
session_reset_stream(session);
setup_decompression(session);
return true;
end;
session.compressed = true;
else
session.log("info", method.." compression selected. But we don't support it.");
local error_st = st.stanza("failure", {xmlns=xmlns_compression_protocol}):tag("unsupported-method");