prosody
74b9e05af71e
plugins/mod_csi_simple.lua

Find changesets by keywords by author, files, the commit message, revision number or hash, or revset expression.

Software / code / prosody

Comparison

plugins/mod_csi_simple.lua @ 12977:74b9e05af71e

plugins: Prefix module imports with prosody namespace
author Kim Alvefur <zash@zash.se>
date Fri, 24 Mar 2023 13:15:28 +0100
parent 12552:b4bc5a715e65
child 13092:bc46cfe7c037
comparison
equal deleted inserted replaced
12976:a187600ec7d6 12977:74b9e05af71e
4 -- COPYING file in the source package for more information. 4 -- COPYING file in the source package for more information.
5 -- 5 --
6 6
7 module:depends"csi" 7 module:depends"csi"
8 8
9 local jid = require "util.jid"; 9 local jid = require "prosody.util.jid";
10 local st = require "util.stanza"; 10 local st = require "prosody.util.stanza";
11 local dt = require "util.datetime"; 11 local dt = require "prosody.util.datetime";
12 local filters = require "util.filters"; 12 local filters = require "prosody.util.filters";
13 local timer = require "util.timer"; 13 local timer = require "prosody.util.timer";
14 14
15 local queue_size = module:get_option_number("csi_queue_size", 256); 15 local queue_size = module:get_option_number("csi_queue_size", 256);
16 local resume_delay = module:get_option_number("csi_resume_inactive_delay", 5); 16 local resume_delay = module:get_option_number("csi_resume_inactive_delay", 5);
17 17
18 local important_payloads = module:get_option_set("csi_important_payloads", { }); 18 local important_payloads = module:get_option_set("csi_important_payloads", { });
253 print(""); 253 print("");
254 print("Provide a series of stanzas to test against importance algorithm"); 254 print("Provide a series of stanzas to test against importance algorithm");
255 return 1; 255 return 1;
256 end 256 end
257 -- luacheck: ignore 212/self 257 -- luacheck: ignore 212/self
258 local xmppstream = require "util.xmppstream"; 258 local xmppstream = require "prosody.util.xmppstream";
259 local input_session = { notopen = true } 259 local input_session = { notopen = true }
260 local stream_callbacks = { stream_ns = "jabber:client", default_ns = "jabber:client" }; 260 local stream_callbacks = { stream_ns = "jabber:client", default_ns = "jabber:client" };
261 function stream_callbacks:handlestanza(stanza) 261 function stream_callbacks:handlestanza(stanza)
262 local important, because = is_important(stanza); 262 local important, because = is_important(stanza);
263 print("--"); 263 print("--");