diff options
author | Tobias Markmann <tm@ayena.de> | 2009-08-12 20:05:05 +0200 |
---|---|---|
committer | Tobias Markmann <tm@ayena.de> | 2009-08-12 20:05:05 +0200 |
commit | 2a6728cb478ac50e23202a8a7f04344f8bdd372c (patch) | |
tree | 621d273899035f9b32d7a5deedc965fcf08bda2b /plugins/mod_compression.lua | |
parent | f8e114fc45beb5935b27a537a91e01063617109a (diff) | |
download | prosody-2a6728cb478ac50e23202a8a7f04344f8bdd372c.tar.gz prosody-2a6728cb478ac50e23202a8a7f04344f8bdd372c.zip |
Commit initial version of mod_compression.
Diffstat (limited to 'plugins/mod_compression.lua')
-rw-r--r-- | plugins/mod_compression.lua | 35 |
1 files changed, 35 insertions, 0 deletions
diff --git a/plugins/mod_compression.lua b/plugins/mod_compression.lua new file mode 100644 index 00000000..4b898833 --- /dev/null +++ b/plugins/mod_compression.lua @@ -0,0 +1,35 @@ +-- Prosody IM +-- Copyright (C) 2009 Tobias Markmann +-- +-- This project is MIT/X11 licensed. Please see the +-- COPYING file in the source package for more information. +-- + +local st = require "util.stanza"; +local print = print + +local xmlns_compression_feature = "http://jabber.org/features/compress" +local xmlns_compression_protocol = "http://jabber.org/protocol/compress" +local compression_stream_feature = st.stanza("compression", {xmlns=xmlns_compression_feature}):tag("method"):text("zlib"):up(); + + +module:add_event_hook("stream-features", + function (session, features) + features:add_child(compression_stream_feature); + end +); + +module:add_handler("c2s_unauthed", "compress", xmlns_compression_protocol, + function(session, stanza) + -- checking if the compression method is supported + local method = stanza:child_with_name("method")[1]; + if method == "zlib" then + session.log("info", method.." compression selected."); + session.send(st.stanza("compressed", {xmlns=xmlns_compression_protocol})); + 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"); + session.send(error_st); + end + end +); |