Mercurial > prosody-modules

changeset 2623:a65260300708

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
mod_smacks: Made module more error resistant
author tmolitor <thilo@eightysoft.de>
date Wed, 15 Mar 2017 16:21:55 +0100
parents ac3ca6233ded
children c110b6bfe5d1
files mod_smacks/mod_smacks.lua
diffstat 1 files changed, 10 insertions(+), 6 deletions(-) [+]
line wrap: on
line diff
--- a/mod_smacks/mod_smacks.lua	Wed Mar 15 09:01:50 2017 +0000
+++ b/mod_smacks/mod_smacks.lua	Wed Mar 15 16:21:55 2017 +0100
@@ -213,7 +213,7 @@
 			session.resumption_token = nil;
 		end
 		-- send out last ack as per revision 1.5.2 of XEP-0198
-		if session.smacks then
+		if session.smacks and session.conn then
 			(session.sends2s or session.send)(st.stanza("a", { xmlns = session.smacks, h = tostring(session.handled_stanza_count) }));
 		end
 		return session_close(...);
@@ -409,7 +409,6 @@
 			end);
 			return true; -- Postpone destruction for now
 		end
-
 	end
 end);
 
@@ -470,6 +469,7 @@
 		original_session.ip = session.ip;
 		original_session.conn = session.conn;
 		original_session.send = session.send;
+		original_session.close = session.close;
 		original_session.filter = session.filter;
 		original_session.filter.session = original_session;
 		original_session.filters = session.filters;
@@ -482,7 +482,7 @@
 		-- Similar for connlisteners
 		c2s_sessions[session.conn] = original_session;
 
-		session.send(st.stanza("resumed", { xmlns = xmlns_sm,
+		original_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
@@ -493,11 +493,15 @@
 		-- ...they are what is now left in the outgoing stanza queue
 		local queue = original_session.outgoing_stanza_queue;
 		module:fire_event("smacks-hibernation-end", {origin = session, resumed = original_session, queue = queue});
-		session.log("debug", "#queue = %d", #queue);
+		original_session.log("debug", "#queue = %d", #queue);
 		for i=1,#queue do
-			session.send(queue[i]);
+			original_session.send(queue[i]);
 		end
-		session.log("debug", "#queue = %d -- after send", #queue);
+		original_session.log("debug", "#queue = %d -- after send", #queue);
+		function session.send(stanza)
+			session.log("warn", "Tried to send stanza on old session migrated by smacks resume (maybe there is a bug?): %s", tostring(stanza));
+			return false;
+		end
 	else
 		module:log("warn", "Client %s@%s[%s] tried to resume stream for %s@%s[%s]",
 			session.username or "?", session.host or "?", session.type,