aboutsummaryrefslogtreecommitdiffstats
path: root/plugins/mod_csi_simple.lua
diff options
context:
space:
mode:
authorKim Alvefur <zash@zash.se>2021-02-16 23:10:23 +0100
committerKim Alvefur <zash@zash.se>2021-02-16 23:10:23 +0100
commit51b055809af1b82334675d61a8204105a7c2c9d2 (patch)
treef8a7861db7c560d92f5e2bc2b9d7987c067c0674 /plugins/mod_csi_simple.lua
parentdcab373f45c5304aa683db64fc5fa5529e680b23 (diff)
downloadprosody-51b055809af1b82334675d61a8204105a7c2c9d2.tar.gz
prosody-51b055809af1b82334675d61a8204105a7c2c9d2.zip
mod_csi_simple: Fire event when flushing queue
To let other plugins know and take some action, e.g. flushing other buffers or whatnot.
Diffstat (limited to 'plugins/mod_csi_simple.lua')
-rw-r--r--plugins/mod_csi_simple.lua1
1 files changed, 1 insertions, 0 deletions
diff --git a/plugins/mod_csi_simple.lua b/plugins/mod_csi_simple.lua
index ebe726fe..48aca5ff 100644
--- a/plugins/mod_csi_simple.lua
+++ b/plugins/mod_csi_simple.lua
@@ -128,6 +128,7 @@ local function manage_buffer(stanza, session)
session.log("debug", "Flushing buffer (%s; queue size is %d)", why or "important", session.csi_counter);
session.conn:resume_writes();
session.state = "flushing";
+ module:fire_event("csi-flushing", { session = session });
else
session.log("debug", "Holding buffer (%s; queue size is %d)", why or "unimportant", session.csi_counter);
stanza = with_timestamp(stanza, jid.join(session.username, session.host))