mirrors/prosody
1
0
Fork 0
mirror of https://github.com/bjc/prosody.git synced 2025-04-06 14:47:37 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

mod_compression: Moving compression setup in a dedicated function.

Browse source
This commit is contained in:
Tobias Markmann 2009-11-29 22:18:06 +01:00
parent b1743dfea1
commit c7c629d9c8
1 changed files with 17 additions and 14 deletions
Download patch file Download diff file Expand all files Collapse all files

31
plugins/mod_compression.lua
View file

@ -108,21 +108,24 @@ module:add_handler({"c2s_unauthed", "c2s", "s2sin_unauthed", "s2sin"}, "compress
end
-- setup compression for session.w
local old_send = session.send;
local function setup_compression(session)
local old_send = session.send;
session.send = function(t)
local status, compressed, eof = pcall(deflate_stream, tostring(t), 'sync');
if status == false then
session:close({
condition = "undefined-condition";
text = compressed;
extra = st.stanza("failure", {xmlns="http://jabber.org/protocol/compress"}):tag("processing-failed");
});
module:log("warn", compressed);
return;
end
old_send(compressed);
end;
session.send = function(t)
local status, compressed, eof = pcall(deflate_stream, tostring(t), 'sync');
if status == false then
session:close({
condition = "undefined-condition";
text = compressed;
extra = st.stanza("failure", {xmlns="http://jabber.org/protocol/compress"}):tag("processing-failed");
});
module:log("warn", compressed);
return;
end
old_send(compressed);
end;
end
setup_compression(session);
-- setup decompression for session.data
local function setup_decompression(session)