Mercurial > prosody-modules
diff mod_smacks/mod_smacks.lua @ 1343:7dbde05b48a9
all the things: Remove trailing whitespace
author | Florian Zeitz <florob@babelmonkeys.de> |
---|---|
date | Tue, 11 Mar 2014 18:44:01 +0100 |
parents | b21236b6b8d8 |
children | 26a2092e289f |
line wrap: on
line diff
--- a/mod_smacks/mod_smacks.lua Mon Mar 10 08:22:58 2014 +0000 +++ b/mod_smacks/mod_smacks.lua Tue Mar 11 18:44:01 2014 +0100 @@ -28,7 +28,7 @@ local function can_do_smacks(session, advertise_only) if session.smacks then return false, "unexpected-request", "Stream management is already enabled"; end - + local session_type = session.type; if session_type == "c2s" then if not(advertise_only) and not(session.resource) then -- Fail unless we're only advertising sm @@ -79,17 +79,17 @@ else queue = session.outgoing_stanza_queue; end - + local _send = session.sends2s or session.send; local function new_send(stanza) local attr = stanza.attr; if attr and not attr.xmlns then -- Stanza in default stream namespace local cached_stanza = st.clone(stanza); - + if cached_stanza and cached_stanza:get_child("delay", xmlns_delay) == nil then cached_stanza = cached_stanza:tag("delay", { xmlns = xmlns_delay, from = session.host, stamp = datetime.datetime()}); end - + queue[#queue+1] = cached_stanza; end if session.hibernating then @@ -104,7 +104,7 @@ end return ok, err; end - + if session.sends2s then session.sends2s = new_send; else @@ -119,7 +119,7 @@ end return session_close(...); end - + if not resume then session.handled_stanza_count = 0; add_filter(session, "stanzas/in", function (stanza) @@ -144,9 +144,9 @@ module:log("debug", "Enabling stream management"); session.smacks = true; - + wrap_session(session, false, xmlns_sm); - + local resume_token; local resume = stanza.attr.resume; if resume == "true" or resume == "1" then @@ -163,11 +163,11 @@ function handle_enabled(session, stanza, xmlns_sm) module:log("debug", "Enabling stream management"); session.smacks = true; - + wrap_session(session, false, xmlns_sm); -- FIXME Resume? - + return true; end module:hook_stanza(xmlns_sm2, "enabled", function (session, stanza) return handle_enabled(session, stanza, xmlns_sm2); end, 100); @@ -269,7 +269,7 @@ end); return true; -- Postpone destruction for now end - + end end); @@ -325,11 +325,11 @@ session.send(st.stanza("resumed", { xmlns = xmlns_sm, h = original_session.handled_stanza_count, previd = id })); - + -- Fake an <a> with the h of the <resume/> from the client original_session:dispatch_stanza(st.stanza("a", { xmlns = xmlns_sm, h = stanza.attr.h })); - + -- Ok, we need to re-send any stanzas that the client didn't see -- ...they are what is now left in the outgoing stanza queue local queue = original_session.outgoing_stanza_queue;