# HG changeset patch
# User Kim Alvefur <zash@zash.se>
# Date 1431347617 -7200
# Node ID 2f9ee9ed62675062c31a492910f623b6d634d844
# Parent  b912cb8e0b3c26712eda601d48ebc1cb77f0651f
mod_smacks: Handle unacked messages in s2s queues

diff -r b912cb8e0b3c -r 2f9ee9ed6267 mod_smacks/mod_smacks.lua
--- a/mod_smacks/mod_smacks.lua	Mon May 11 14:32:37 2015 +0200
+++ b/mod_smacks/mod_smacks.lua	Mon May 11 14:33:37 2015 +0200
@@ -298,6 +298,18 @@
 	end
 end);
 
+local function handle_s2s_destroyed(event)
+	local session = event.session;
+	local queue = session.outgoing_stanza_queue;
+	if queue and #queue > 0 then
+		session.log("warn", "Destroying session with %d unacked stanzas", #queue);
+		handle_unacked_stanzas(session);
+	end
+end
+
+module:hook("s2sout-destroyed", handle_s2s_destroyed);
+module:hook("s2sin-destroyed", handle_s2s_destroyed);
+
 function handle_resume(session, stanza, xmlns_sm)
 	if session.full_jid then
 		session.log("warn", "Tried to resume after resource binding");