prosody-hg: plugins/mod_c2s.lua annotate

annotate plugins/mod_c2s.lua @ 14179:25beb66fab38 13.0

util.crypto: Use post-Lua 5.1 buffer API Tha Lua 5.1 buffer API was frustrating to work with. luaL_prepbuffer() only allocates LUAL_BUFFERSIZE - there is no way to request a specific size. LUAL_BUFFERSIZE is set to BUFSIZ by default, which is generally 8192 bytes on Linux, however it may vary between platforms. The variation means this buffer could potentially overflow (small BUFSIZ with large signature). The Lua 5.2+ buffer API enables requesting a specific buffer size, so that's what we do now.

author	Matthew Wild <mwild1@gmail.com>
date	Mon, 25 May 2026 15:11:47 +0100
parents	e3ddbf7f2d3f
children	9728c3fabeef

rev	line source
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	1 -- Prosody IM
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	2 -- Copyright (C) 2008-2010 Matthew Wild
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	3 -- Copyright (C) 2008-2010 Waqas Hussain
5776 bd0ff8ae98a8 Remove all trailing whitespace Florian Zeitz <florob@babelmonkeys.de> parents: 5773 diff changeset	4 --
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	5 -- This project is MIT/X11 licensed. Please see the
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	6 -- COPYING file in the source package for more information.
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	7 --
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	8
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	9 module:set_global();
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	10
14135 836a70deb3c9 mod_c2s: Remove timers immediately on disconnection Waqas Hussain <waqas20@gmail.com> parents: 14132 diff changeset	11 local timer = require "prosody.util.timer";
14155 ead9e645741a mod_c2s: Remove timers immediately on disconnection Waqas Hussain <waqas20@gmail.com> parents: 14154 diff changeset	12 local add_task = timer.add_task;
ead9e645741a mod_c2s: Remove timers immediately on disconnection Waqas Hussain <waqas20@gmail.com> parents: 14154 diff changeset	13 local stop_task = timer.stop;
12977 74b9e05af71e plugins: Prefix module imports with prosody namespace Kim Alvefur <zash@zash.se> parents: 12907 diff changeset	14 local new_xmpp_stream = require "prosody.util.xmppstream".new;
74b9e05af71e plugins: Prefix module imports with prosody namespace Kim Alvefur <zash@zash.se> parents: 12907 diff changeset	15 local nameprep = require "prosody.util.encodings".stringprep.nameprep;
74b9e05af71e plugins: Prefix module imports with prosody namespace Kim Alvefur <zash@zash.se> parents: 12907 diff changeset	16 local sessionmanager = require "prosody.core.sessionmanager";
74b9e05af71e plugins: Prefix module imports with prosody namespace Kim Alvefur <zash@zash.se> parents: 12907 diff changeset	17 local statsmanager = require "prosody.core.statsmanager";
74b9e05af71e plugins: Prefix module imports with prosody namespace Kim Alvefur <zash@zash.se> parents: 12907 diff changeset	18 local st = require "prosody.util.stanza";
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	19 local sm_new_session, sm_destroy_session = sessionmanager.new_session, sessionmanager.destroy_session;
12977 74b9e05af71e plugins: Prefix module imports with prosody namespace Kim Alvefur <zash@zash.se> parents: 12907 diff changeset	20 local uuid_generate = require "prosody.util.uuid".generate;
74b9e05af71e plugins: Prefix module imports with prosody namespace Kim Alvefur <zash@zash.se> parents: 12907 diff changeset	21 local async = require "prosody.util.async";
12301 4f1fe6eb1ddb mod_c2s,mod_s2s: Wait for sessions to close before proceeding with shutdown steps Kim Alvefur <zash@zash.se> parents: 12300 diff changeset	22 local runner = async.runner;
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	23
8044 e38e3300b955 mod_c2s: Remove unused locals [luacheck] Kim Alvefur <zash@zash.se> parents: 7957 diff changeset	24 local tostring, type = tostring, type;
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	25
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	26 local xmlns_xmpp_streams = "urn:ietf:params:xml:ns:xmpp-streams";
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	27
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	28 local log = module._log;
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	29
14155 ead9e645741a mod_c2s: Remove timers immediately on disconnection Waqas Hussain <waqas20@gmail.com> parents: 14154 diff changeset	30 local function stop_session_timers(session)
ead9e645741a mod_c2s: Remove timers immediately on disconnection Waqas Hussain <waqas20@gmail.com> parents: 14154 diff changeset	31 if session.c2s_timeout then
ead9e645741a mod_c2s: Remove timers immediately on disconnection Waqas Hussain <waqas20@gmail.com> parents: 14154 diff changeset	32 stop_task(session.c2s_timeout);
ead9e645741a mod_c2s: Remove timers immediately on disconnection Waqas Hussain <waqas20@gmail.com> parents: 14154 diff changeset	33 session.c2s_timeout = nil;
ead9e645741a mod_c2s: Remove timers immediately on disconnection Waqas Hussain <waqas20@gmail.com> parents: 14154 diff changeset	34 end
ead9e645741a mod_c2s: Remove timers immediately on disconnection Waqas Hussain <waqas20@gmail.com> parents: 14154 diff changeset	35 end
ead9e645741a mod_c2s: Remove timers immediately on disconnection Waqas Hussain <waqas20@gmail.com> parents: 14154 diff changeset	36
13209 c8d949cf6b09 plugins: Switch to :get_option_period() for time range options Kim Alvefur <zash@zash.se> parents: 13095 diff changeset	37 local c2s_timeout = module:get_option_period("c2s_timeout", "5 minutes");
c8d949cf6b09 plugins: Switch to :get_option_period() for time range options Kim Alvefur <zash@zash.se> parents: 13095 diff changeset	38 local stream_close_timeout = module:get_option_period("c2s_close_timeout", 5);
5757 b5ba004beb0a mod_c2s: Change default of tcp_keepalives to true, and make it individually configurable through c2s_tcp_keepalives Kim Alvefur <zash@zash.se> parents: 5571 diff changeset	39 local opt_keepalives = module:get_option_boolean("c2s_tcp_keepalives", module:get_option_boolean("tcp_keepalives", true));
14122 8a4417d32b0f mod_c2s,mod_s2s: Introduce separate pre-authentication stanza size limit Kim Alvefur <zash@zash.se> parents: 13764 diff changeset	40 local unauthed_stanza_size_limit = module:get_option_integer("c2s_unauthed_stanza_size_limit", 10000,1000);
8a4417d32b0f mod_c2s,mod_s2s: Introduce separate pre-authentication stanza size limit Kim Alvefur <zash@zash.se> parents: 13764 diff changeset	41 local authed_stanza_size_limit = module:get_option_integer("c2s_stanza_size_limit", 1024*256,10000);
14132 1e005ba71f0d mod_c2s, mod_s2s: Add configurable limit for stanza max child elements Matthew Wild <mwild1@gmail.com> parents: 14125 diff changeset	42 local max_child_elements = module:get_option_integer("c2s_max_child_elements", 25000, 0);
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	43
13504 2159a206684e mod_c2s,mod_s2s: Advertise idle-seconds per XEP-0478 Kim Alvefur <zash@zash.se> parents: 13420 diff changeset	44 local advertised_idle_timeout = 14*60; -- default in all net.server implementations
2159a206684e mod_c2s,mod_s2s: Advertise idle-seconds per XEP-0478 Kim Alvefur <zash@zash.se> parents: 13420 diff changeset	45 local network_settings = module:get_option("network_settings");
2159a206684e mod_c2s,mod_s2s: Advertise idle-seconds per XEP-0478 Kim Alvefur <zash@zash.se> parents: 13420 diff changeset	46 if type(network_settings) == "table" and type(network_settings.read_timeout) == "number" then
2159a206684e mod_c2s,mod_s2s: Advertise idle-seconds per XEP-0478 Kim Alvefur <zash@zash.se> parents: 13420 diff changeset	47 advertised_idle_timeout = network_settings.read_timeout;
2159a206684e mod_c2s,mod_s2s: Advertise idle-seconds per XEP-0478 Kim Alvefur <zash@zash.se> parents: 13420 diff changeset	48 end
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	49
11524 6de302b53a3e mod_c2s: Port to new OpenMetrics API Jonas Schäfer <jonas@wielicki.name> parents: 11517 diff changeset	50 local measure_connections = module:metric("gauge", "connections", "", "Established c2s connections", {"host", "type", "ip_family"});
6630 6735e2d735d6 mod_c2s, mod_s2s: Collect statistics on number of connections Kim Alvefur <zash@zash.se> parents: 6382 diff changeset	51
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	52 local sessions = module:shared("sessions");
5013 ab693eea0869 mod_admin_adhoc, mod_admin_telnet, mod_bosh, mod_c2s, mod_component, mod_pep, mod_presence, mod_roster, mod_s2s: Import core_post_stanza from the global prosody table. Kim Alvefur <zash@zash.se> parents: 4996 diff changeset	53 local core_process_stanza = prosody.core_process_stanza;
5370 7838acadb0fa mod_announce, mod_auth_anonymous, mod_c2s, mod_c2s, mod_component, mod_iq, mod_message, mod_presence, mod_tls: Access prosody.{hosts,bare_sessions,full_sessions} instead of the old globals Kim Alvefur <zash@zash.se> parents: 5281 diff changeset	54 local hosts = prosody.hosts;
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	55
5773 c9a712673d8a mod_c2s: Add session:sleep() and session:wake() to pause a session (e.g. while waiting for an external event). Needs a gallon or two of testing. Matthew Wild <mwild1@gmail.com> parents: 5764 diff changeset	56 local stream_callbacks = { default_ns = "jabber:client" };
4625 325965bafae1 mod_c2s, mod_s2s: Drop default_port and default_mode from listener objects (default_port is deprecated, and default_mode already defaults to a) Matthew Wild <mwild1@gmail.com>* parents: 4620 diff changeset	57 local listener = {};
7286 30b9433a9f3e Merge 0.10->trunk Kim Alvefur <zash@zash.se> parents: 7284 diff changeset	58 local runner_callbacks = {};
13575 750ff9f579e2 mod_c2s, mod_s2s: Support for queuing callbacks to run in session thread Matthew Wild <mwild1@gmail.com> parents: 13504 diff changeset	59 local session_events = {};
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	60
11608 b2610460d9ab mod_c2s,mod_s2s: Collect stats on TLS versions and ciphers Kim Alvefur <zash@zash.se> parents: 11560 diff changeset	61 local m_tls_params = module:metric(
b2610460d9ab mod_c2s,mod_s2s: Collect stats on TLS versions and ciphers Kim Alvefur <zash@zash.se> parents: 11560 diff changeset	62 "counter", "encrypted", "",
b2610460d9ab mod_c2s,mod_s2s: Collect stats on TLS versions and ciphers Kim Alvefur <zash@zash.se> parents: 11560 diff changeset	63 "Encrypted connections",
b2610460d9ab mod_c2s,mod_s2s: Collect stats on TLS versions and ciphers Kim Alvefur <zash@zash.se> parents: 11560 diff changeset	64 {"protocol"; "cipher"}
b2610460d9ab mod_c2s,mod_s2s: Collect stats on TLS versions and ciphers Kim Alvefur <zash@zash.se> parents: 11560 diff changeset	65 );
b2610460d9ab mod_c2s,mod_s2s: Collect stats on TLS versions and ciphers Kim Alvefur <zash@zash.se> parents: 11560 diff changeset	66
7662 946871f6e3c8 mod_c2s, mod_s2s: Switch connection counting to 'amount' type and enumerate once per statistics interval Kim Alvefur <zash@zash.se> parents: 7540 diff changeset	67 module:hook("stats-update", function ()
11524 6de302b53a3e mod_c2s: Port to new OpenMetrics API Jonas Schäfer <jonas@wielicki.name> parents: 11517 diff changeset	68 -- for push backends, avoid sending out updates for each increment of
6de302b53a3e mod_c2s: Port to new OpenMetrics API Jonas Schäfer <jonas@wielicki.name> parents: 11517 diff changeset	69 -- the metric below.
6de302b53a3e mod_c2s: Port to new OpenMetrics API Jonas Schäfer <jonas@wielicki.name> parents: 11517 diff changeset	70 statsmanager.cork()
6de302b53a3e mod_c2s: Port to new OpenMetrics API Jonas Schäfer <jonas@wielicki.name> parents: 11517 diff changeset	71 measure_connections:clear()
8764 81d305bbe7bc mod_c2s: Add a counter for IPv6. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 8390 diff changeset	72 for _, session in pairs(sessions) do
11524 6de302b53a3e mod_c2s: Port to new OpenMetrics API Jonas Schäfer <jonas@wielicki.name> parents: 11517 diff changeset	73 local host = session.host or ""
6de302b53a3e mod_c2s: Port to new OpenMetrics API Jonas Schäfer <jonas@wielicki.name> parents: 11517 diff changeset	74 local type_ = session.type or "other"
6de302b53a3e mod_c2s: Port to new OpenMetrics API Jonas Schäfer <jonas@wielicki.name> parents: 11517 diff changeset	75
6de302b53a3e mod_c2s: Port to new OpenMetrics API Jonas Schäfer <jonas@wielicki.name> parents: 11517 diff changeset	76 -- we want to expose both v4 and v6 counters in all cases to make
6de302b53a3e mod_c2s: Port to new OpenMetrics API Jonas Schäfer <jonas@wielicki.name> parents: 11517 diff changeset	77 -- queries smoother
6de302b53a3e mod_c2s: Port to new OpenMetrics API Jonas Schäfer <jonas@wielicki.name> parents: 11517 diff changeset	78 local is_ipv6 = session.ip and session.ip:match(":") and 1 or 0
6de302b53a3e mod_c2s: Port to new OpenMetrics API Jonas Schäfer <jonas@wielicki.name> parents: 11517 diff changeset	79 local is_ipv4 = 1 - is_ipv6
6de302b53a3e mod_c2s: Port to new OpenMetrics API Jonas Schäfer <jonas@wielicki.name> parents: 11517 diff changeset	80 measure_connections:with_labels(host, type_, "ipv4"):add(is_ipv4)
6de302b53a3e mod_c2s: Port to new OpenMetrics API Jonas Schäfer <jonas@wielicki.name> parents: 11517 diff changeset	81 measure_connections:with_labels(host, type_, "ipv6"):add(is_ipv6)
7466 f28fa742def3 mod_c2s, mod_s2s: Bootstrap connection count statistic on module load Kim Alvefur <zash@zash.se> parents: 7329 diff changeset	82 end
11524 6de302b53a3e mod_c2s: Port to new OpenMetrics API Jonas Schäfer <jonas@wielicki.name> parents: 11517 diff changeset	83 statsmanager.uncork()
7662 946871f6e3c8 mod_c2s, mod_s2s: Switch connection counting to 'amount' type and enumerate once per statistics interval Kim Alvefur <zash@zash.se> parents: 7540 diff changeset	84 end);
7466 f28fa742def3 mod_c2s, mod_s2s: Bootstrap connection count statistic on module load Kim Alvefur <zash@zash.se> parents: 7329 diff changeset	85
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	86 --- Stream events handlers
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	87 local stream_xmlns_attr = {xmlns='urn:ietf:params:xml:ns:xmpp-streams'};
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	88
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	89 function stream_callbacks.streamopened(session, attr)
10811 16bcbd574801 mod_c2s: Run stream open and close events in async thread, fixes #1103 Kim Alvefur <zash@zash.se> parents: 10727 diff changeset	90 -- run _streamopened in async context
13575 750ff9f579e2 mod_c2s, mod_s2s: Support for queuing callbacks to run in session thread Matthew Wild <mwild1@gmail.com> parents: 13504 diff changeset	91 session.thread:run({ event = "streamopened", attr = attr });
10811 16bcbd574801 mod_c2s: Run stream open and close events in async thread, fixes #1103 Kim Alvefur <zash@zash.se> parents: 10727 diff changeset	92 end
16bcbd574801 mod_c2s: Run stream open and close events in async thread, fixes #1103 Kim Alvefur <zash@zash.se> parents: 10727 diff changeset	93
13575 750ff9f579e2 mod_c2s, mod_s2s: Support for queuing callbacks to run in session thread Matthew Wild <mwild1@gmail.com> parents: 13504 diff changeset	94 function session_events.streamopened(session, event)
750ff9f579e2 mod_c2s, mod_s2s: Support for queuing callbacks to run in session thread Matthew Wild <mwild1@gmail.com> parents: 13504 diff changeset	95 local send, attr = session.send, event.attr;
10379 b917602eac04 mod_c2s: Validate that a 'to' attribute exists at all Kim Alvefur <zash@zash.se> parents: 10226 diff changeset	96 if not attr.to then
b917602eac04 mod_c2s: Validate that a 'to' attribute exists at all Kim Alvefur <zash@zash.se> parents: 10226 diff changeset	97 session:close{ condition = "improper-addressing",
b917602eac04 mod_c2s: Validate that a 'to' attribute exists at all Kim Alvefur <zash@zash.se> parents: 10226 diff changeset	98 text = "A 'to' attribute is required on stream headers" };
b917602eac04 mod_c2s: Validate that a 'to' attribute exists at all Kim Alvefur <zash@zash.se> parents: 10226 diff changeset	99 return;
b917602eac04 mod_c2s: Validate that a 'to' attribute exists at all Kim Alvefur <zash@zash.se> parents: 10226 diff changeset	100 end
8844 29c6d2681bad mod_c2s: Do not allow the stream 'to' to change across stream restarts (fixes #1147) Kim Alvefur <zash@zash.se> parents: 8232 diff changeset	101 local host = nameprep(attr.to);
29c6d2681bad mod_c2s: Do not allow the stream 'to' to change across stream restarts (fixes #1147) Kim Alvefur <zash@zash.se> parents: 8232 diff changeset	102 if not host then
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	103 session:close{ condition = "improper-addressing",
4551 8f25f3b1c62f mod_c2s: Code reduction Matthew Wild <mwild1@gmail.com> parents: 4548 diff changeset	104 text = "A valid 'to' attribute is required on stream headers" };
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	105 return;
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	106 end
8844 29c6d2681bad mod_c2s: Do not allow the stream 'to' to change across stream restarts (fixes #1147) Kim Alvefur <zash@zash.se> parents: 8232 diff changeset	107 if not session.host then
29c6d2681bad mod_c2s: Do not allow the stream 'to' to change across stream restarts (fixes #1147) Kim Alvefur <zash@zash.se> parents: 8232 diff changeset	108 session.host = host;
29c6d2681bad mod_c2s: Do not allow the stream 'to' to change across stream restarts (fixes #1147) Kim Alvefur <zash@zash.se> parents: 8232 diff changeset	109 elseif session.host ~= host then
29c6d2681bad mod_c2s: Do not allow the stream 'to' to change across stream restarts (fixes #1147) Kim Alvefur <zash@zash.se> parents: 8232 diff changeset	110 session:close{ condition = "not-authorized",
29c6d2681bad mod_c2s: Do not allow the stream 'to' to change across stream restarts (fixes #1147) Kim Alvefur <zash@zash.se> parents: 8232 diff changeset	111 text = "The 'to' attribute must remain the same across stream restarts" };
29c6d2681bad mod_c2s: Do not allow the stream 'to' to change across stream restarts (fixes #1147) Kim Alvefur <zash@zash.se> parents: 8232 diff changeset	112 return;
29c6d2681bad mod_c2s: Do not allow the stream 'to' to change across stream restarts (fixes #1147) Kim Alvefur <zash@zash.se> parents: 8232 diff changeset	113 end
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	114 session.version = tonumber(attr.version) or 0;
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	115 session.streamid = uuid_generate();
9490 6e4fbd12c11c mod_c2s: Fix fallback for missing session logger Kim Alvefur <zash@zash.se> parents: 8847 diff changeset	116 (session.log or log)("debug", "Client sent opening <stream:stream> to %s", session.host);
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	117
5668 5a9318ac92f6 mod_c2s: Become a shared module and allow being disabled on some virtualhosts Kim Alvefur <zash@zash.se> parents: 5638 diff changeset	118 if not hosts[session.host] or not hosts[session.host].modules.c2s then
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	119 -- We don't serve this host...
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	120 session:close{ condition = "host-unknown", text = "This server does not serve "..tostring(session.host)};
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	121 return;
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	122 end
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	123
11359 db146bf7b120 mod_c2s: Reflect stream 'from' attribute back if set (fix #1625) Kim Alvefur <zash@zash.se> parents: 11120 diff changeset	124 session:open_stream(host, attr.from);
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	125
11517 f7275c2c58fa mod_c2s: Fix traceback if session was destroyed while opening stream (thanks Ge0rG) Kim Alvefur <zash@zash.se> parents: 11514 diff changeset	126 -- Opening the stream can cause the stream to be closed
f7275c2c58fa mod_c2s: Fix traceback if session was destroyed while opening stream (thanks Ge0rG) Kim Alvefur <zash@zash.se> parents: 11514 diff changeset	127 if session.destroyed then return end
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	128
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	129 (session.log or log)("debug", "Sent reply <stream:stream> to client");
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	130 session.notopen = nil;
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	131
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	132 -- If session.secure is false (not nil) then it means we /were/ encrypting
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	133 -- since we now have a new stream header, session is secured
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	134 if session.secure == false then
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	135 session.secure = true;
5859 e327f2d4e09f mod_c2s, mod_s2s: Set session.encrypted as session.secure does not allways mean encrypted (eg consider_bosh_secure) Kim Alvefur <zash@zash.se> parents: 5802 diff changeset	136 session.encrypted = true;
5228 edabb34417b7 mod_c2s: Check if TLS compression is used Kim Alvefur <zash@zash.se> parents: 5120 diff changeset	137
12480 7e9ebdc75ce4 net: isolate LuaSec-specifics Jonas Schäfer <jonas@wielicki.name> parents: 12311 diff changeset	138 local info = session.conn:ssl_info();
11622 a62146353528 mod_c2s: Guard against LuaSec not returning TLS info (thanks Martin) Kim Alvefur <zash@zash.se> parents: 11619 diff changeset	139 if type(info) == "table" then
5801 224644752bf4 mod_c2s, mod_s2s: Log cipher and encryption info in a more compact and (hopefully) less confusing way Kim Alvefur <zash@zash.se> parents: 5789 diff changeset	140 (session.log or log)("info", "Stream encrypted (%s with %s)", info.protocol, info.cipher);
5764 969e0a054795 mod_c2s, mod_s2s: Log a message that stream encryption has been enabled with some details Kim Alvefur <zash@zash.se> parents: 5759 diff changeset	141 session.compressed = info.compression;
11608 b2610460d9ab mod_c2s,mod_s2s: Collect stats on TLS versions and ciphers Kim Alvefur <zash@zash.se> parents: 11560 diff changeset	142 m_tls_params:with_labels(info.protocol, info.cipher):add(1)
5764 969e0a054795 mod_c2s, mod_s2s: Log a message that stream encryption has been enabled with some details Kim Alvefur <zash@zash.se> parents: 5759 diff changeset	143 else
969e0a054795 mod_c2s, mod_s2s: Log a message that stream encryption has been enabled with some details Kim Alvefur <zash@zash.se> parents: 5759 diff changeset	144 (session.log or log)("info", "Stream encrypted");
5228 edabb34417b7 mod_c2s: Check if TLS compression is used Kim Alvefur <zash@zash.se> parents: 5120 diff changeset	145 end
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	146 end
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	147
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	148 local features = st.stanza("stream:features");
12773 f100c1035576 mod_c2s: Include stream attributes in stream-features event Matthew Wild <mwild1@gmail.com> parents: 12677 diff changeset	149 hosts[session.host].events.fire_event("stream-features", { origin = session, features = features, stream = attr });
6846 7eb166fa1f26 mod_c2s, mod_s2s: Close incoming connections if there are no features to offer on incomplete streams (fixes #285) Kim Alvefur <zash@zash.se> parents: 6630 diff changeset	150 if features.tags[1] or session.full_jid then
14122 8a4417d32b0f mod_c2s,mod_s2s: Introduce separate pre-authentication stanza size limit Kim Alvefur <zash@zash.se> parents: 13764 diff changeset	151 if session.stanza_size_limit or advertised_idle_timeout then
12804 3eef052c72d8 mod_c2s: Advertise stanza size limit to clients Kim Alvefur <zash@zash.se> parents: 12773 diff changeset	152 features:reset();
13504 2159a206684e mod_c2s,mod_s2s: Advertise idle-seconds per XEP-0478 Kim Alvefur <zash@zash.se> parents: 13420 diff changeset	153 local limits = features:tag("limits", { xmlns = "urn:xmpp:stream-limits:0" });
14122 8a4417d32b0f mod_c2s,mod_s2s: Introduce separate pre-authentication stanza size limit Kim Alvefur <zash@zash.se> parents: 13764 diff changeset	154 if session.stanza_size_limit then
8a4417d32b0f mod_c2s,mod_s2s: Introduce separate pre-authentication stanza size limit Kim Alvefur <zash@zash.se> parents: 13764 diff changeset	155 limits:text_tag("max-bytes", string.format("%d", session.stanza_size_limit));
13504 2159a206684e mod_c2s,mod_s2s: Advertise idle-seconds per XEP-0478 Kim Alvefur <zash@zash.se> parents: 13420 diff changeset	156 end
2159a206684e mod_c2s,mod_s2s: Advertise idle-seconds per XEP-0478 Kim Alvefur <zash@zash.se> parents: 13420 diff changeset	157 if advertised_idle_timeout then
2159a206684e mod_c2s,mod_s2s: Advertise idle-seconds per XEP-0478 Kim Alvefur <zash@zash.se> parents: 13420 diff changeset	158 limits:text_tag("idle-seconds", string.format("%d", advertised_idle_timeout));
2159a206684e mod_c2s,mod_s2s: Advertise idle-seconds per XEP-0478 Kim Alvefur <zash@zash.se> parents: 13420 diff changeset	159 end
2159a206684e mod_c2s,mod_s2s: Advertise idle-seconds per XEP-0478 Kim Alvefur <zash@zash.se> parents: 13420 diff changeset	160 limits:reset();
12804 3eef052c72d8 mod_c2s: Advertise stanza size limit to clients Kim Alvefur <zash@zash.se> parents: 12773 diff changeset	161 end
6846 7eb166fa1f26 mod_c2s, mod_s2s: Close incoming connections if there are no features to offer on incomplete streams (fixes #285) Kim Alvefur <zash@zash.se> parents: 6630 diff changeset	162 send(features);
7eb166fa1f26 mod_c2s, mod_s2s: Close incoming connections if there are no features to offer on incomplete streams (fixes #285) Kim Alvefur <zash@zash.se> parents: 6630 diff changeset	163 else
9739 a74d78f79b23 mod_c2s: Improve log message in case there are no stream features on offer (thanks hexa) Kim Alvefur <zash@zash.se> parents: 9490 diff changeset	164 if session.secure then
10727 fa2a89132dfb mod_c2s: Swap comments Kim Alvefur <zash@zash.se> parents: 10465 diff changeset	165 -- Here SASL should be offered
9739 a74d78f79b23 mod_c2s: Improve log message in case there are no stream features on offer (thanks hexa) Kim Alvefur <zash@zash.se> parents: 9490 diff changeset	166 (session.log or log)("warn", "No stream features to offer on secure session. Check authentication settings.");
a74d78f79b23 mod_c2s: Improve log message in case there are no stream features on offer (thanks hexa) Kim Alvefur <zash@zash.se> parents: 9490 diff changeset	167 else
10727 fa2a89132dfb mod_c2s: Swap comments Kim Alvefur <zash@zash.se> parents: 10465 diff changeset	168 -- Normally STARTTLS would be offered
9739 a74d78f79b23 mod_c2s: Improve log message in case there are no stream features on offer (thanks hexa) Kim Alvefur <zash@zash.se> parents: 9490 diff changeset	169 (session.log or log)("warn", "No stream features to offer on insecure session. Check encryption and security settings.");
a74d78f79b23 mod_c2s: Improve log message in case there are no stream features on offer (thanks hexa) Kim Alvefur <zash@zash.se> parents: 9490 diff changeset	170 end
7862 f5cbbf69cac8 mod_c2s: Clarify that there were no stream features to offer Kim Alvefur <zash@zash.se> parents: 7662 diff changeset	171 session:close{ condition = "undefined-condition", text = "No stream features to proceed with" };
6846 7eb166fa1f26 mod_c2s, mod_s2s: Close incoming connections if there are no features to offer on incomplete streams (fixes #285) Kim Alvefur <zash@zash.se> parents: 6630 diff changeset	172 end
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	173 end
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	174
10811 16bcbd574801 mod_c2s: Run stream open and close events in async thread, fixes #1103 Kim Alvefur <zash@zash.se> parents: 10727 diff changeset	175 function stream_callbacks.streamclosed(session, attr)
16bcbd574801 mod_c2s: Run stream open and close events in async thread, fixes #1103 Kim Alvefur <zash@zash.se> parents: 10727 diff changeset	176 -- run _streamclosed in async context
13575 750ff9f579e2 mod_c2s, mod_s2s: Support for queuing callbacks to run in session thread Matthew Wild <mwild1@gmail.com> parents: 13504 diff changeset	177 session.thread:run({ event = "streamclosed", attr = attr });
10811 16bcbd574801 mod_c2s: Run stream open and close events in async thread, fixes #1103 Kim Alvefur <zash@zash.se> parents: 10727 diff changeset	178 end
16bcbd574801 mod_c2s: Run stream open and close events in async thread, fixes #1103 Kim Alvefur <zash@zash.se> parents: 10727 diff changeset	179
13575 750ff9f579e2 mod_c2s, mod_s2s: Support for queuing callbacks to run in session thread Matthew Wild <mwild1@gmail.com> parents: 13504 diff changeset	180 function session_events.streamclosed(session)
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	181 session.log("debug", "Received </stream:stream>");
4986 9da430b69f13 mod_c2s: Change 'reason' parameter of session:close() to take nil to mean 'graceful close initiated by us' and false for 'graceful close initiated by client' Matthew Wild <mwild1@gmail.com> parents: 4964 diff changeset	182 session:close(false);
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	183 end
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	184
13575 750ff9f579e2 mod_c2s, mod_s2s: Support for queuing callbacks to run in session thread Matthew Wild <mwild1@gmail.com> parents: 13504 diff changeset	185 function session_events.callback(session, event)
750ff9f579e2 mod_c2s, mod_s2s: Support for queuing callbacks to run in session thread Matthew Wild <mwild1@gmail.com> parents: 13504 diff changeset	186 session.log("debug", "Running session callback %s", event.name);
750ff9f579e2 mod_c2s, mod_s2s: Support for queuing callbacks to run in session thread Matthew Wild <mwild1@gmail.com> parents: 13504 diff changeset	187 event.callback(session, event);
750ff9f579e2 mod_c2s, mod_s2s: Support for queuing callbacks to run in session thread Matthew Wild <mwild1@gmail.com> parents: 13504 diff changeset	188 end
750ff9f579e2 mod_c2s, mod_s2s: Support for queuing callbacks to run in session thread Matthew Wild <mwild1@gmail.com> parents: 13504 diff changeset	189
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	190 function stream_callbacks.error(session, error, data)
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	191 if error == "no-stream" then
6364 4e93e8768c36 mod_c2s, mod_s2s: Log received invalid stream headers Matthew Wild <mwild1@gmail.com> parents: 6279 diff changeset	192 session.log("debug", "Invalid opening stream header (%s)", (data:gsub("^([^\1]+)\1", "{%1}")));
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	193 session:close("invalid-namespace");
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	194 elseif error == "parse-error" then
10111 0f335815244f plugins: Remove tostring call from logging Kim Alvefur <zash@zash.se> parents: 10017 diff changeset	195 (session.log or log)("debug", "Client XML parse error: %s", data);
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	196 session:close("not-well-formed");
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	197 elseif error == "stream-error" then
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	198 local condition, text = "undefined-condition";
8232 176b7f4e4ac9 mod_c2s: Iterate over child tags instead of child nodes in stream error (fixes traceback from #987) Kim Alvefur <zash@zash.se> parents: 7328 diff changeset	199 for child in data:childtags(nil, xmlns_xmpp_streams) do
176b7f4e4ac9 mod_c2s: Iterate over child tags instead of child nodes in stream error (fixes traceback from #987) Kim Alvefur <zash@zash.se> parents: 7328 diff changeset	200 if child.name ~= "text" then
176b7f4e4ac9 mod_c2s: Iterate over child tags instead of child nodes in stream error (fixes traceback from #987) Kim Alvefur <zash@zash.se> parents: 7328 diff changeset	201 condition = child.name;
176b7f4e4ac9 mod_c2s: Iterate over child tags instead of child nodes in stream error (fixes traceback from #987) Kim Alvefur <zash@zash.se> parents: 7328 diff changeset	202 else
176b7f4e4ac9 mod_c2s: Iterate over child tags instead of child nodes in stream error (fixes traceback from #987) Kim Alvefur <zash@zash.se> parents: 7328 diff changeset	203 text = child:get_text();
176b7f4e4ac9 mod_c2s: Iterate over child tags instead of child nodes in stream error (fixes traceback from #987) Kim Alvefur <zash@zash.se> parents: 7328 diff changeset	204 end
176b7f4e4ac9 mod_c2s: Iterate over child tags instead of child nodes in stream error (fixes traceback from #987) Kim Alvefur <zash@zash.se> parents: 7328 diff changeset	205 if condition ~= "undefined-condition" and text then
176b7f4e4ac9 mod_c2s: Iterate over child tags instead of child nodes in stream error (fixes traceback from #987) Kim Alvefur <zash@zash.se> parents: 7328 diff changeset	206 break;
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	207 end
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	208 end
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	209 text = condition .. (text and (" ("..text..")") or "");
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	210 session.log("info", "Session closed by remote with error: %s", text);
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	211 session:close(nil, text);
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	212 end
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	213 end
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	214
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	215 function stream_callbacks.handlestanza(session, stanza)
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	216 stanza = session.filter("stanzas/in", stanza);
7286 30b9433a9f3e Merge 0.10->trunk Kim Alvefur <zash@zash.se> parents: 7284 diff changeset	217 session.thread:run(stanza);
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	218 end
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	219
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	220 --- Session methods
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	221 local function session_close(session, reason)
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	222 local log = session.log or log;
12071 85c8fcb4192e mod_c2s: Fire pre-closing event regardless of connected state Kim Alvefur <zash@zash.se> parents: 11974 diff changeset	223 local close_event_payload = { session = session, reason = reason };
85c8fcb4192e mod_c2s: Fire pre-closing event regardless of connected state Kim Alvefur <zash@zash.se> parents: 11974 diff changeset	224 module:context(session.host):fire_event("pre-session-close", close_event_payload);
85c8fcb4192e mod_c2s: Fire pre-closing event regardless of connected state Kim Alvefur <zash@zash.se> parents: 11974 diff changeset	225 reason = close_event_payload.reason;
14155 ead9e645741a mod_c2s: Remove timers immediately on disconnection Waqas Hussain <waqas20@gmail.com> parents: 14154 diff changeset	226 stop_session_timers(session);
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	227 if session.conn then
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	228 if session.notopen then
6005 98b768a41c9d mod_c2s: Break out stream opening into a separate function Florian Zeitz <florob@babelmonkeys.de> parents: 5859 diff changeset	229 session:open_stream();
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	230 end
4986 9da430b69f13 mod_c2s: Change 'reason' parameter of session:close() to take nil to mean 'graceful close initiated by us' and false for 'graceful close initiated by client' Matthew Wild <mwild1@gmail.com> parents: 4964 diff changeset	231 if reason then -- nil == no err, initiated by us, false == initiated by client
5518 0220093e34fa mod_c2s: Refactor <stream:error> building to allways tostring() it and only call send once Kim Alvefur <zash@zash.se> parents: 5505 diff changeset	232 local stream_error = st.stanza("stream:error");
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	233 if type(reason) == "string" then -- assume stream error
5518 0220093e34fa mod_c2s: Refactor <stream:error> building to allways tostring() it and only call send once Kim Alvefur <zash@zash.se> parents: 5505 diff changeset	234 stream_error:tag(reason, {xmlns = 'urn:ietf:params:xml:ns:xmpp-streams' });
11868 ae093c259da2 mod_c2s,etc: Identify stanza object with appropriate function Kim Alvefur <zash@zash.se> parents: 11778 diff changeset	235 elseif st.is_stanza(reason) then
ae093c259da2 mod_c2s,etc: Identify stanza object with appropriate function Kim Alvefur <zash@zash.se> parents: 11778 diff changeset	236 stream_error = reason;
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	237 elseif type(reason) == "table" then
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	238 if reason.condition then
5518 0220093e34fa mod_c2s: Refactor <stream:error> building to allways tostring() it and only call send once Kim Alvefur <zash@zash.se> parents: 5505 diff changeset	239 stream_error:tag(reason.condition, stream_xmlns_attr):up();
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	240 if reason.text then
5518 0220093e34fa mod_c2s: Refactor <stream:error> building to allways tostring() it and only call send once Kim Alvefur <zash@zash.se> parents: 5505 diff changeset	241 stream_error:tag("text", stream_xmlns_attr):text(reason.text):up();
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	242 end
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	243 if reason.extra then
5518 0220093e34fa mod_c2s: Refactor <stream:error> building to allways tostring() it and only call send once Kim Alvefur <zash@zash.se> parents: 5505 diff changeset	244 stream_error:add_child(reason.extra);
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	245 end
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	246 end
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	247 end
5518 0220093e34fa mod_c2s: Refactor <stream:error> building to allways tostring() it and only call send once Kim Alvefur <zash@zash.se> parents: 5505 diff changeset	248 stream_error = tostring(stream_error);
0220093e34fa mod_c2s: Refactor <stream:error> building to allways tostring() it and only call send once Kim Alvefur <zash@zash.se> parents: 5505 diff changeset	249 log("debug", "Disconnecting client, <stream:error> is: %s", stream_error);
0220093e34fa mod_c2s: Refactor <stream:error> building to allways tostring() it and only call send once Kim Alvefur <zash@zash.se> parents: 5505 diff changeset	250 session.send(stream_error);
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	251 end
5776 bd0ff8ae98a8 Remove all trailing whitespace Florian Zeitz <florob@babelmonkeys.de> parents: 5773 diff changeset	252
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	253 session.send("</stream:stream>");
4964 c9b8ec3eb1e9 mod_c2s: Don't call ondisconnect manually on close, it is now called by net.server. Replace with inline code for destroying the session, and also waiting for a reply </stream:stream> if there is a chance of further data sent by the client. session.send() on a half-closed stream returns false (and does not deliver the data). Matthew Wild <mwild1@gmail.com> parents: 4852 diff changeset	254 function session.send() return false; end
5776 bd0ff8ae98a8 Remove all trailing whitespace Florian Zeitz <florob@babelmonkeys.de> parents: 5773 diff changeset	255
7954 60b83f83f317 mod_c2s: Rename variable no avoid name clash [luacheck] Kim Alvefur <zash@zash.se> parents: 7866 diff changeset	256 local reason_text = (reason and (reason.name or reason.text or reason.condition)) or reason;
8819 780d728f969f mod_c2s: Avoid concatenating potential nil value (fixes #753) Kim Alvefur <zash@zash.se> parents: 8388 diff changeset	257 session.log("debug", "c2s stream for %s closed: %s", session.full_jid or session.ip or "<unknown>", reason_text or "session closed");
4964 c9b8ec3eb1e9 mod_c2s: Don't call ondisconnect manually on close, it is now called by net.server. Replace with inline code for destroying the session, and also waiting for a reply </stream:stream> if there is a chance of further data sent by the client. session.send() on a half-closed stream returns false (and does not deliver the data). Matthew Wild <mwild1@gmail.com> parents: 4852 diff changeset	258
c9b8ec3eb1e9 mod_c2s: Don't call ondisconnect manually on close, it is now called by net.server. Replace with inline code for destroying the session, and also waiting for a reply </stream:stream> if there is a chance of further data sent by the client. session.send() on a half-closed stream returns false (and does not deliver the data). Matthew Wild <mwild1@gmail.com> parents: 4852 diff changeset	259 -- Authenticated incoming stream may still be sending us stanzas, so wait for </stream:stream> from remote
c9b8ec3eb1e9 mod_c2s: Don't call ondisconnect manually on close, it is now called by net.server. Replace with inline code for destroying the session, and also waiting for a reply </stream:stream> if there is a chance of further data sent by the client. session.send() on a half-closed stream returns false (and does not deliver the data). Matthew Wild <mwild1@gmail.com> parents: 4852 diff changeset	260 local conn = session.conn;
7954 60b83f83f317 mod_c2s: Rename variable no avoid name clash [luacheck] Kim Alvefur <zash@zash.se> parents: 7866 diff changeset	261 if reason_text == nil and not session.notopen and session.type == "c2s" then
4964 c9b8ec3eb1e9 mod_c2s: Don't call ondisconnect manually on close, it is now called by net.server. Replace with inline code for destroying the session, and also waiting for a reply </stream:stream> if there is a chance of further data sent by the client. session.send() on a half-closed stream returns false (and does not deliver the data). Matthew Wild <mwild1@gmail.com> parents: 4852 diff changeset	262 -- Grace time to process data from authenticated cleanly-closed stream
c9b8ec3eb1e9 mod_c2s: Don't call ondisconnect manually on close, it is now called by net.server. Replace with inline code for destroying the session, and also waiting for a reply </stream:stream> if there is a chance of further data sent by the client. session.send() on a half-closed stream returns false (and does not deliver the data). Matthew Wild <mwild1@gmail.com> parents: 4852 diff changeset	263 add_task(stream_close_timeout, function ()
c9b8ec3eb1e9 mod_c2s: Don't call ondisconnect manually on close, it is now called by net.server. Replace with inline code for destroying the session, and also waiting for a reply </stream:stream> if there is a chance of further data sent by the client. session.send() on a half-closed stream returns false (and does not deliver the data). Matthew Wild <mwild1@gmail.com> parents: 4852 diff changeset	264 if not session.destroyed then
c9b8ec3eb1e9 mod_c2s: Don't call ondisconnect manually on close, it is now called by net.server. Replace with inline code for destroying the session, and also waiting for a reply </stream:stream> if there is a chance of further data sent by the client. session.send() on a half-closed stream returns false (and does not deliver the data). Matthew Wild <mwild1@gmail.com> parents: 4852 diff changeset	265 session.log("warn", "Failed to receive a stream close response, closing connection anyway...");
7954 60b83f83f317 mod_c2s: Rename variable no avoid name clash [luacheck] Kim Alvefur <zash@zash.se> parents: 7866 diff changeset	266 sm_destroy_session(session, reason_text);
13764 667a58e74fd9 mod_c2s: Code formatting change Matthew Wild <mwild1@gmail.com> parents: 13642 diff changeset	267 if conn then
667a58e74fd9 mod_c2s: Code formatting change Matthew Wild <mwild1@gmail.com> parents: 13642 diff changeset	268 conn:close();
667a58e74fd9 mod_c2s: Code formatting change Matthew Wild <mwild1@gmail.com> parents: 13642 diff changeset	269 end
4964 c9b8ec3eb1e9 mod_c2s: Don't call ondisconnect manually on close, it is now called by net.server. Replace with inline code for destroying the session, and also waiting for a reply </stream:stream> if there is a chance of further data sent by the client. session.send() on a half-closed stream returns false (and does not deliver the data). Matthew Wild <mwild1@gmail.com> parents: 4852 diff changeset	270 end
c9b8ec3eb1e9 mod_c2s: Don't call ondisconnect manually on close, it is now called by net.server. Replace with inline code for destroying the session, and also waiting for a reply </stream:stream> if there is a chance of further data sent by the client. session.send() on a half-closed stream returns false (and does not deliver the data). Matthew Wild <mwild1@gmail.com> parents: 4852 diff changeset	271 end);
c9b8ec3eb1e9 mod_c2s: Don't call ondisconnect manually on close, it is now called by net.server. Replace with inline code for destroying the session, and also waiting for a reply </stream:stream> if there is a chance of further data sent by the client. session.send() on a half-closed stream returns false (and does not deliver the data). Matthew Wild <mwild1@gmail.com> parents: 4852 diff changeset	272 else
7954 60b83f83f317 mod_c2s: Rename variable no avoid name clash [luacheck] Kim Alvefur <zash@zash.se> parents: 7866 diff changeset	273 sm_destroy_session(session, reason_text);
13764 667a58e74fd9 mod_c2s: Code formatting change Matthew Wild <mwild1@gmail.com> parents: 13642 diff changeset	274 if conn then
667a58e74fd9 mod_c2s: Code formatting change Matthew Wild <mwild1@gmail.com> parents: 13642 diff changeset	275 conn:close();
667a58e74fd9 mod_c2s: Code formatting change Matthew Wild <mwild1@gmail.com> parents: 13642 diff changeset	276 end
4964 c9b8ec3eb1e9 mod_c2s: Don't call ondisconnect manually on close, it is now called by net.server. Replace with inline code for destroying the session, and also waiting for a reply </stream:stream> if there is a chance of further data sent by the client. session.send() on a half-closed stream returns false (and does not deliver the data). Matthew Wild <mwild1@gmail.com> parents: 4852 diff changeset	277 end
7328 de76ded98b84 mod_c2s: Just destroy the session when it has no connection (see #641) Kim Alvefur <zash@zash.se> parents: 7221 diff changeset	278 else
7954 60b83f83f317 mod_c2s: Rename variable no avoid name clash [luacheck] Kim Alvefur <zash@zash.se> parents: 7866 diff changeset	279 local reason_text = (reason and (reason.name or reason.text or reason.condition)) or reason;
60b83f83f317 mod_c2s: Rename variable no avoid name clash [luacheck] Kim Alvefur <zash@zash.se> parents: 7866 diff changeset	280 sm_destroy_session(session, reason_text);
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	281 end
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	282 end
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	283
11899 6d06068363aa mod_c2s: Disconnect user sessions on a role change event Matthew Wild <mwild1@gmail.com> parents: 11868 diff changeset	284 -- Close all user sessions with the specified reason. If leave_resource is
6d06068363aa mod_c2s: Disconnect user sessions on a role change event Matthew Wild <mwild1@gmail.com> parents: 11868 diff changeset	285 -- true, the resource named by event.resource will not be closed.
6d06068363aa mod_c2s: Disconnect user sessions on a role change event Matthew Wild <mwild1@gmail.com> parents: 11868 diff changeset	286 local function disconnect_user_sessions(reason, leave_resource)
6d06068363aa mod_c2s: Disconnect user sessions on a role change event Matthew Wild <mwild1@gmail.com> parents: 11868 diff changeset	287 return function (event)
6d06068363aa mod_c2s: Disconnect user sessions on a role change event Matthew Wild <mwild1@gmail.com> parents: 11868 diff changeset	288 local username, host, resource = event.username, event.host, event.resource;
13420 7dc7e2e15b2a mod_c2s: Fix error on role change on Components (thanks Menel) Kim Alvefur <zash@zash.se> parents: 13384 diff changeset	289 if not (hosts[host] and hosts[host].type == "local") then
7dc7e2e15b2a mod_c2s: Fix error on role change on Components (thanks Menel) Kim Alvefur <zash@zash.se> parents: 13384 diff changeset	290 return -- not a local VirtualHost so no sessions
7dc7e2e15b2a mod_c2s: Fix error on role change on Components (thanks Menel) Kim Alvefur <zash@zash.se> parents: 13384 diff changeset	291 end
13642 1b2de94f0580 mod_c2s: Add debug log when disconnecting all user sessions Matthew Wild <mwild1@gmail.com> parents: 13575 diff changeset	292 module:log("debug", "Disconnecting %s sessions of %s@%s (%s)", not leave_resource and "all" or "other", username, host, reason.text);
11899 6d06068363aa mod_c2s: Disconnect user sessions on a role change event Matthew Wild <mwild1@gmail.com> parents: 11868 diff changeset	293 local user = hosts[host].sessions[username];
6d06068363aa mod_c2s: Disconnect user sessions on a role change event Matthew Wild <mwild1@gmail.com> parents: 11868 diff changeset	294 if user and user.sessions then
6d06068363aa mod_c2s: Disconnect user sessions on a role change event Matthew Wild <mwild1@gmail.com> parents: 11868 diff changeset	295 for r, session in pairs(user.sessions) do
6d06068363aa mod_c2s: Disconnect user sessions on a role change event Matthew Wild <mwild1@gmail.com> parents: 11868 diff changeset	296 if not leave_resource or r ~= resource then
6d06068363aa mod_c2s: Disconnect user sessions on a role change event Matthew Wild <mwild1@gmail.com> parents: 11868 diff changeset	297 session:close(reason);
6d06068363aa mod_c2s: Disconnect user sessions on a role change event Matthew Wild <mwild1@gmail.com> parents: 11868 diff changeset	298 end
8192 4354f556c5db core.usermanager, various modules: Disconnect other resources on password change (thanks waqas) (fixes #512) Kim Alvefur <zash@zash.se> parents: 7955 diff changeset	299 end
4354f556c5db core.usermanager, various modules: Disconnect other resources on password change (thanks waqas) (fixes #512) Kim Alvefur <zash@zash.se> parents: 7955 diff changeset	300 end
4354f556c5db core.usermanager, various modules: Disconnect other resources on password change (thanks waqas) (fixes #512) Kim Alvefur <zash@zash.se> parents: 7955 diff changeset	301 end
11899 6d06068363aa mod_c2s: Disconnect user sessions on a role change event Matthew Wild <mwild1@gmail.com> parents: 11868 diff changeset	302 end
6d06068363aa mod_c2s: Disconnect user sessions on a role change event Matthew Wild <mwild1@gmail.com> parents: 11868 diff changeset	303
6d06068363aa mod_c2s: Disconnect user sessions on a role change event Matthew Wild <mwild1@gmail.com> parents: 11868 diff changeset	304 module:hook_global("user-password-changed", disconnect_user_sessions({ condition = "reset", text = "Password changed" }, true), 200);
12662 07424992d7fc mod_authz_internal, and more: New iteration of role API Matthew Wild <mwild1@gmail.com> parents: 12480 diff changeset	305 module:hook_global("user-role-changed", disconnect_user_sessions({ condition = "reset", text = "Role changed" }), 200);
11899 6d06068363aa mod_c2s: Disconnect user sessions on a role change event Matthew Wild <mwild1@gmail.com> parents: 11868 diff changeset	306 module:hook_global("user-deleted", disconnect_user_sessions({ condition = "not-authorized", text = "Account deleted" }), 200);
12907 d2333b468d07 mod_c2s: Disconnect accounts when they are disabled Kim Alvefur <zash@zash.se> parents: 12808 diff changeset	307 module:hook_global("user-disabled", disconnect_user_sessions({ condition = "not-authorized", text = "Account disabled" }), 200);
8192 4354f556c5db core.usermanager, various modules: Disconnect other resources on password change (thanks waqas) (fixes #512) Kim Alvefur <zash@zash.se> parents: 7955 diff changeset	308
12677 3b9771d496ed mod_smacks: Long overdue cleanup of resumption code, fixes some old TODOs Matthew Wild <mwild1@gmail.com> parents: 12662 diff changeset	309 module:hook_global("c2s-session-updated", function (event)
3b9771d496ed mod_smacks: Long overdue cleanup of resumption code, fixes some old TODOs Matthew Wild <mwild1@gmail.com> parents: 12662 diff changeset	310 sessions[event.session.conn] = event.session;
3b9771d496ed mod_smacks: Long overdue cleanup of resumption code, fixes some old TODOs Matthew Wild <mwild1@gmail.com> parents: 12662 diff changeset	311 local replaced_conn = event.replaced_conn;
3b9771d496ed mod_smacks: Long overdue cleanup of resumption code, fixes some old TODOs Matthew Wild <mwild1@gmail.com> parents: 12662 diff changeset	312 if replaced_conn then
3b9771d496ed mod_smacks: Long overdue cleanup of resumption code, fixes some old TODOs Matthew Wild <mwild1@gmail.com> parents: 12662 diff changeset	313 sessions[replaced_conn] = nil;
13095 1693bd4de283 core.sessionmanager: Delay closing a replaced connection after replacement Kim Alvefur <zash@zash.se> parents: 13093 diff changeset	314 replaced_conn:close();
12677 3b9771d496ed mod_smacks: Long overdue cleanup of resumption code, fixes some old TODOs Matthew Wild <mwild1@gmail.com> parents: 12662 diff changeset	315 end
3b9771d496ed mod_smacks: Long overdue cleanup of resumption code, fixes some old TODOs Matthew Wild <mwild1@gmail.com> parents: 12662 diff changeset	316 end);
8192 4354f556c5db core.usermanager, various modules: Disconnect other resources on password change (thanks waqas) (fixes #512) Kim Alvefur <zash@zash.se> parents: 7955 diff changeset	317
7286 30b9433a9f3e Merge 0.10->trunk Kim Alvefur <zash@zash.se> parents: 7284 diff changeset	318 function runner_callbacks:ready()
11510 d241ca8272fe mod_c2s: Improve code style Kim Alvefur <zash@zash.se> parents: 11509 diff changeset	319 if self.data.conn then
d241ca8272fe mod_c2s: Improve code style Kim Alvefur <zash@zash.se> parents: 11509 diff changeset	320 self.data.conn:resume();
11511 cab64a0aad49 mod_c2s: Log about missing conn on async state changes Kim Alvefur <zash@zash.se> parents: 11510 diff changeset	321 else
cab64a0aad49 mod_c2s: Log about missing conn on async state changes Kim Alvefur <zash@zash.se> parents: 11510 diff changeset	322 (self.data.log or log)("debug", "Session has no connection to resume");
11510 d241ca8272fe mod_c2s: Improve code style Kim Alvefur <zash@zash.se> parents: 11509 diff changeset	323 end
7286 30b9433a9f3e Merge 0.10->trunk Kim Alvefur <zash@zash.se> parents: 7284 diff changeset	324 end
30b9433a9f3e Merge 0.10->trunk Kim Alvefur <zash@zash.se> parents: 7284 diff changeset	325
30b9433a9f3e Merge 0.10->trunk Kim Alvefur <zash@zash.se> parents: 7284 diff changeset	326 function runner_callbacks:waiting()
11510 d241ca8272fe mod_c2s: Improve code style Kim Alvefur <zash@zash.se> parents: 11509 diff changeset	327 if self.data.conn then
d241ca8272fe mod_c2s: Improve code style Kim Alvefur <zash@zash.se> parents: 11509 diff changeset	328 self.data.conn:pause();
11511 cab64a0aad49 mod_c2s: Log about missing conn on async state changes Kim Alvefur <zash@zash.se> parents: 11510 diff changeset	329 else
cab64a0aad49 mod_c2s: Log about missing conn on async state changes Kim Alvefur <zash@zash.se> parents: 11510 diff changeset	330 (self.data.log or log)("debug", "Session has no connection to pause while waiting");
11510 d241ca8272fe mod_c2s: Improve code style Kim Alvefur <zash@zash.se> parents: 11509 diff changeset	331 end
7286 30b9433a9f3e Merge 0.10->trunk Kim Alvefur <zash@zash.se> parents: 7284 diff changeset	332 end
30b9433a9f3e Merge 0.10->trunk Kim Alvefur <zash@zash.se> parents: 7284 diff changeset	333
30b9433a9f3e Merge 0.10->trunk Kim Alvefur <zash@zash.se> parents: 7284 diff changeset	334 function runner_callbacks:error(err)
30b9433a9f3e Merge 0.10->trunk Kim Alvefur <zash@zash.se> parents: 7284 diff changeset	335 (self.data.log or log)("error", "Traceback[c2s]: %s", err);
30b9433a9f3e Merge 0.10->trunk Kim Alvefur <zash@zash.se> parents: 7284 diff changeset	336 end
30b9433a9f3e Merge 0.10->trunk Kim Alvefur <zash@zash.se> parents: 7284 diff changeset	337
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	338 --- Port listener
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	339 function listener.onconnect(conn)
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	340 local session = sm_new_session(conn);
5776 bd0ff8ae98a8 Remove all trailing whitespace Florian Zeitz <florob@babelmonkeys.de> parents: 5773 diff changeset	341
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	342 session.log("info", "Client connected");
5776 bd0ff8ae98a8 Remove all trailing whitespace Florian Zeitz <florob@babelmonkeys.de> parents: 5773 diff changeset	343
11618 8f0fe74ede94 mod_c2s: Update a comment to reflect Direct TLS Kim Alvefur <zash@zash.se> parents: 11614 diff changeset	344 -- Client is using Direct TLS or legacy SSL (otherwise mod_tls sets this flag)
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	345 if conn:ssl() then
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	346 session.secure = true;
5859 e327f2d4e09f mod_c2s, mod_s2s: Set session.encrypted as session.secure does not allways mean encrypted (eg consider_bosh_secure) Kim Alvefur <zash@zash.se> parents: 5802 diff changeset	347 session.encrypted = true;
13280 cf8a6710c91c mod_c2s: Add session.ssl_cfg/ssl_ctx for direct TLS connections Matthew Wild <mwild1@gmail.com> parents: 13230 diff changeset	348 session.ssl_ctx = conn:sslctx();
5228 edabb34417b7 mod_c2s: Check if TLS compression is used Kim Alvefur <zash@zash.se> parents: 5120 diff changeset	349
edabb34417b7 mod_c2s: Check if TLS compression is used Kim Alvefur <zash@zash.se> parents: 5120 diff changeset	350 -- Check if TLS compression is used
12480 7e9ebdc75ce4 net: isolate LuaSec-specifics Jonas Schäfer <jonas@wielicki.name> parents: 12311 diff changeset	351 local info = conn:ssl_info();
11622 a62146353528 mod_c2s: Guard against LuaSec not returning TLS info (thanks Martin) Kim Alvefur <zash@zash.se> parents: 11619 diff changeset	352 if type(info) == "table" then
11619 d629135450ec mod_c2s: Log the same messages for Direct TLS as with starttls Kim Alvefur <zash@zash.se> parents: 11618 diff changeset	353 (session.log or log)("info", "Stream encrypted (%s with %s)", info.protocol, info.cipher);
d629135450ec mod_c2s: Log the same messages for Direct TLS as with starttls Kim Alvefur <zash@zash.se> parents: 11618 diff changeset	354 session.compressed = info.compression;
d629135450ec mod_c2s: Log the same messages for Direct TLS as with starttls Kim Alvefur <zash@zash.se> parents: 11618 diff changeset	355 m_tls_params:with_labels(info.protocol, info.cipher):add(1)
d629135450ec mod_c2s: Log the same messages for Direct TLS as with starttls Kim Alvefur <zash@zash.se> parents: 11618 diff changeset	356 else
d629135450ec mod_c2s: Log the same messages for Direct TLS as with starttls Kim Alvefur <zash@zash.se> parents: 11618 diff changeset	357 (session.log or log)("info", "Stream encrypted");
5228 edabb34417b7 mod_c2s: Check if TLS compression is used Kim Alvefur <zash@zash.se> parents: 5120 diff changeset	358 end
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	359 end
5776 bd0ff8ae98a8 Remove all trailing whitespace Florian Zeitz <florob@babelmonkeys.de> parents: 5773 diff changeset	360
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	361 if opt_keepalives then
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	362 conn:setoption("keepalive", opt_keepalives);
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	363 end
5776 bd0ff8ae98a8 Remove all trailing whitespace Florian Zeitz <florob@babelmonkeys.de> parents: 5773 diff changeset	364
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	365 session.close = session_close;
5776 bd0ff8ae98a8 Remove all trailing whitespace Florian Zeitz <florob@babelmonkeys.de> parents: 5773 diff changeset	366
14152 fed0dd8dda09 mod_c2s,mod_s2s: Introduce separate pre-authentication stanza size limit Kim Alvefur <zash@zash.se> parents: 12311 diff changeset	367 session.stanza_size_limit = unauthed_stanza_size_limit;
fed0dd8dda09 mod_c2s,mod_s2s: Introduce separate pre-authentication stanza size limit Kim Alvefur <zash@zash.se> parents: 12311 diff changeset	368
14154 363a79f54109 mod_c2s, mod_s2s: Add configurable limit for stanza max child elements Matthew Wild <mwild1@gmail.com> parents: 14152 diff changeset	369 local stream = new_xmpp_stream(session, stream_callbacks, session.stanza_size_limit, {
363a79f54109 mod_c2s, mod_s2s: Add configurable limit for stanza max child elements Matthew Wild <mwild1@gmail.com> parents: 14152 diff changeset	370 max_elements = max_child_elements;
363a79f54109 mod_c2s, mod_s2s: Add configurable limit for stanza max child elements Matthew Wild <mwild1@gmail.com> parents: 14152 diff changeset	371 });
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	372 session.stream = stream;
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	373 session.notopen = true;
5776 bd0ff8ae98a8 Remove all trailing whitespace Florian Zeitz <florob@babelmonkeys.de> parents: 5773 diff changeset	374
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	375 function session.reset_stream()
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	376 session.notopen = true;
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	377 session.stream:reset();
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	378 end
5776 bd0ff8ae98a8 Remove all trailing whitespace Florian Zeitz <florob@babelmonkeys.de> parents: 5773 diff changeset	379
13575 750ff9f579e2 mod_c2s, mod_s2s: Support for queuing callbacks to run in session thread Matthew Wild <mwild1@gmail.com> parents: 13504 diff changeset	380 session.thread = runner(function (item)
750ff9f579e2 mod_c2s, mod_s2s: Support for queuing callbacks to run in session thread Matthew Wild <mwild1@gmail.com> parents: 13504 diff changeset	381 if st.is_stanza(item) then
750ff9f579e2 mod_c2s, mod_s2s: Support for queuing callbacks to run in session thread Matthew Wild <mwild1@gmail.com> parents: 13504 diff changeset	382 core_process_stanza(session, item);
750ff9f579e2 mod_c2s, mod_s2s: Support for queuing callbacks to run in session thread Matthew Wild <mwild1@gmail.com> parents: 13504 diff changeset	383 else
750ff9f579e2 mod_c2s, mod_s2s: Support for queuing callbacks to run in session thread Matthew Wild <mwild1@gmail.com> parents: 13504 diff changeset	384 session_events[item.event](session, item);
10811 16bcbd574801 mod_c2s: Run stream open and close events in async thread, fixes #1103 Kim Alvefur <zash@zash.se> parents: 10727 diff changeset	385 end
7286 30b9433a9f3e Merge 0.10->trunk Kim Alvefur <zash@zash.se> parents: 7284 diff changeset	386 end, runner_callbacks, session);
30b9433a9f3e Merge 0.10->trunk Kim Alvefur <zash@zash.se> parents: 7284 diff changeset	387
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	388 local filter = session.filter;
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	389 function session.data(data)
5773 c9a712673d8a mod_c2s: Add session:sleep() and session:wake() to pause a session (e.g. while waiting for an external event). Needs a gallon or two of testing. Matthew Wild <mwild1@gmail.com> parents: 5764 diff changeset	390 -- Parse the data, which will store stanzas in session.pending_stanzas
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	391 if data then
7539 366964dbddb1 mod_c2s: Fix whitespace (why does it keep getting messed up?) Kim Alvefur <zash@zash.se> parents: 7466 diff changeset	392 data = filter("bytes/in", data);
366964dbddb1 mod_c2s: Fix whitespace (why does it keep getting messed up?) Kim Alvefur <zash@zash.se> parents: 7466 diff changeset	393 if data then
366964dbddb1 mod_c2s: Fix whitespace (why does it keep getting messed up?) Kim Alvefur <zash@zash.se> parents: 7466 diff changeset	394 local ok, err = stream:feed(data);
5773 c9a712673d8a mod_c2s: Add session:sleep() and session:wake() to pause a session (e.g. while waiting for an external event). Needs a gallon or two of testing. Matthew Wild <mwild1@gmail.com> parents: 5764 diff changeset	395 if not ok then
10111 0f335815244f plugins: Remove tostring call from logging Kim Alvefur <zash@zash.se> parents: 10017 diff changeset	396 log("debug", "Received invalid XML (%s) %d bytes: %q", err, #data, data:sub(1, 300));
10849 19e7092e062c mod_c2s,mod_s2s: Use a distinct stream error for hitting stanza size limit Kim Alvefur <zash@zash.se> parents: 10811 diff changeset	397 if err == "stanza-too-large" then
11770 d2a9aa1c7ac8 mod_c2s,mod_s2s: Indicate stanza size violation with condition from XEP-0205 (thanks mjk) Kim Alvefur <zash@zash.se> parents: 11747 diff changeset	398 session:close({
d2a9aa1c7ac8 mod_c2s,mod_s2s: Indicate stanza size violation with condition from XEP-0205 (thanks mjk) Kim Alvefur <zash@zash.se> parents: 11747 diff changeset	399 condition = "policy-violation",
d2a9aa1c7ac8 mod_c2s,mod_s2s: Indicate stanza size violation with condition from XEP-0205 (thanks mjk) Kim Alvefur <zash@zash.se> parents: 11747 diff changeset	400 text = "XML stanza is too big",
d2a9aa1c7ac8 mod_c2s,mod_s2s: Indicate stanza size violation with condition from XEP-0205 (thanks mjk) Kim Alvefur <zash@zash.se> parents: 11747 diff changeset	401 extra = st.stanza("stanza-too-big", { xmlns = 'urn:xmpp:errors' }),
d2a9aa1c7ac8 mod_c2s,mod_s2s: Indicate stanza size violation with condition from XEP-0205 (thanks mjk) Kim Alvefur <zash@zash.se> parents: 11747 diff changeset	402 });
10849 19e7092e062c mod_c2s,mod_s2s: Use a distinct stream error for hitting stanza size limit Kim Alvefur <zash@zash.se> parents: 10811 diff changeset	403 else
19e7092e062c mod_c2s,mod_s2s: Use a distinct stream error for hitting stanza size limit Kim Alvefur <zash@zash.se> parents: 10811 diff changeset	404 session:close("not-well-formed");
19e7092e062c mod_c2s,mod_s2s: Use a distinct stream error for hitting stanza size limit Kim Alvefur <zash@zash.se> parents: 10811 diff changeset	405 end
5773 c9a712673d8a mod_c2s: Add session:sleep() and session:wake() to pause a session (e.g. while waiting for an external event). Needs a gallon or two of testing. Matthew Wild <mwild1@gmail.com> parents: 5764 diff changeset	406 end
c9a712673d8a mod_c2s: Add session:sleep() and session:wake() to pause a session (e.g. while waiting for an external event). Needs a gallon or two of testing. Matthew Wild <mwild1@gmail.com> parents: 5764 diff changeset	407 end
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	408 end
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	409 end
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	410
13230 26c30844cac6 plugins: Handle how get_option_period returns "never" Kim Alvefur <zash@zash.se> parents: 13213 diff changeset	411 if c2s_timeout < math.huge then
13384 57ad1dfd8e8b mod_c2s: Make c2s_timeout timer reachable to allow access from other modules Kim Alvefur <zash@zash.se> parents: 13289 diff changeset	412 session.c2s_timeout = add_task(c2s_timeout, function ()
4548 e6e5c76ff009 sessionmanager, mod_c2s: Move timeout logic to mod_c2s Matthew Wild <mwild1@gmail.com> parents: 4543 diff changeset	413 if session.type == "c2s_unauthed" then
11477 c90ef8745779 mod_c2s: Log a debug message before closing due to c2s_timeout Kim Alvefur <zash@zash.se> parents: 11359 diff changeset	414 (session.log or log)("debug", "Connection still not authenticated after c2s_timeout=%gs, closing it", c2s_timeout);
4548 e6e5c76ff009 sessionmanager, mod_c2s: Move timeout logic to mod_c2s Matthew Wild <mwild1@gmail.com> parents: 4543 diff changeset	415 session:close("connection-timeout");
13384 57ad1dfd8e8b mod_c2s: Make c2s_timeout timer reachable to allow access from other modules Kim Alvefur <zash@zash.se> parents: 13289 diff changeset	416 else
57ad1dfd8e8b mod_c2s: Make c2s_timeout timer reachable to allow access from other modules Kim Alvefur <zash@zash.se> parents: 13289 diff changeset	417 session.c2s_timeout = nil;
4548 e6e5c76ff009 sessionmanager, mod_c2s: Move timeout logic to mod_c2s Matthew Wild <mwild1@gmail.com> parents: 4543 diff changeset	418 end
e6e5c76ff009 sessionmanager, mod_c2s: Move timeout logic to mod_c2s Matthew Wild <mwild1@gmail.com> parents: 4543 diff changeset	419 end);
e6e5c76ff009 sessionmanager, mod_c2s: Move timeout logic to mod_c2s Matthew Wild <mwild1@gmail.com> parents: 4543 diff changeset	420 end
e6e5c76ff009 sessionmanager, mod_c2s: Move timeout logic to mod_c2s Matthew Wild <mwild1@gmail.com> parents: 4543 diff changeset	421
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	422 session.dispatch_stanza = stream_callbacks.handlestanza;
10013 62d8689beafb mod_c2s: Associate connection with session last (fixes #1313) Kim Alvefur <zash@zash.se> parents: 9490 diff changeset	423
62d8689beafb mod_c2s: Associate connection with session last (fixes #1313) Kim Alvefur <zash@zash.se> parents: 9490 diff changeset	424 sessions[conn] = session;
14125 863da67a4b51 mod_c2s: Fire a c2s-connected event Matthew Wild <mwild1@gmail.com> parents: 14122 diff changeset	425
863da67a4b51 mod_c2s: Fire a c2s-connected event Matthew Wild <mwild1@gmail.com> parents: 14122 diff changeset	426 module:fire_event("c2s-connected", { conn = conn, session = session });
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	427 end
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	428
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	429 function listener.onincoming(conn, data)
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	430 local session = sessions[conn];
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	431 if session then
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	432 session.data(data);
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	433 end
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	434 end
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	435
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	436 function listener.ondisconnect(conn, err)
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	437 local session = sessions[conn];
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	438 if session then
4964 c9b8ec3eb1e9 mod_c2s: Don't call ondisconnect manually on close, it is now called by net.server. Replace with inline code for destroying the session, and also waiting for a reply </stream:stream> if there is a chance of further data sent by the client. session.send() on a half-closed stream returns false (and does not deliver the data). Matthew Wild <mwild1@gmail.com> parents: 4852 diff changeset	439 (session.log or log)("info", "Client disconnected: %s", err or "connection closed");
14155 ead9e645741a mod_c2s: Remove timers immediately on disconnection Waqas Hussain <waqas20@gmail.com> parents: 14154 diff changeset	440 stop_session_timers(session);
14146 1d028f9473c2 mod_c2s, mod_smacks: Refactor session/connection cleanup Matthew Wild <mwild1@gmail.com> parents: 14135 diff changeset	441 if not session.hibernating then
1d028f9473c2 mod_c2s, mod_smacks: Refactor session/connection cleanup Matthew Wild <mwild1@gmail.com> parents: 14135 diff changeset	442 sm_destroy_session(session, err);
1d028f9473c2 mod_c2s, mod_smacks: Refactor session/connection cleanup Matthew Wild <mwild1@gmail.com> parents: 14135 diff changeset	443 end
7221 56e65b1e54e8 mod_c2s: Remove connection object from session object when connection disconnected to prevent accidental use (see #590) Kim Alvefur <zash@zash.se> parents: 7100 diff changeset	444 session.conn = nil;
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	445 sessions[conn] = nil;
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	446 end
12301 4f1fe6eb1ddb mod_c2s,mod_s2s: Wait for sessions to close before proceeding with shutdown steps Kim Alvefur <zash@zash.se> parents: 12300 diff changeset	447 module:fire_event("c2s-closed", { session = session; conn = conn });
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	448 end
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	449
5638 c5b7f4858014 mod_c2s, mod_c2s: Send a whitespace on read timeout, to prod TCP into detecting if the connection died Kim Alvefur <zash@zash.se> parents: 5571 diff changeset	450 function listener.onreadtimeout(conn)
c5b7f4858014 mod_c2s, mod_c2s: Send a whitespace on read timeout, to prod TCP into detecting if the connection died Kim Alvefur <zash@zash.se> parents: 5571 diff changeset	451 local session = sessions[conn];
c5b7f4858014 mod_c2s, mod_c2s: Send a whitespace on read timeout, to prod TCP into detecting if the connection died Kim Alvefur <zash@zash.se> parents: 5571 diff changeset	452 if session then
5669 9345c161481f mod_c2s, mod_s2s: Fire an event on read timeouts Kim Alvefur <zash@zash.se> parents: 5668 diff changeset	453 return (hosts[session.host] or prosody).events.fire_event("c2s-read-timeout", { session = session });
5638 c5b7f4858014 mod_c2s, mod_c2s: Send a whitespace on read timeout, to prod TCP into detecting if the connection died Kim Alvefur <zash@zash.se> parents: 5571 diff changeset	454 end
c5b7f4858014 mod_c2s, mod_c2s: Send a whitespace on read timeout, to prod TCP into detecting if the connection died Kim Alvefur <zash@zash.se> parents: 5571 diff changeset	455 end
c5b7f4858014 mod_c2s, mod_c2s: Send a whitespace on read timeout, to prod TCP into detecting if the connection died Kim Alvefur <zash@zash.se> parents: 5571 diff changeset	456
9910 7a703af90c9c mod_c2s: Fire an event when outgoing buffers have been emptied Kim Alvefur <zash@zash.se> parents: 9784 diff changeset	457 function listener.ondrain(conn)
7a703af90c9c mod_c2s: Fire an event when outgoing buffers have been emptied Kim Alvefur <zash@zash.se> parents: 9784 diff changeset	458 local session = sessions[conn];
7a703af90c9c mod_c2s: Fire an event when outgoing buffers have been emptied Kim Alvefur <zash@zash.se> parents: 9784 diff changeset	459 if session then
7a703af90c9c mod_c2s: Fire an event when outgoing buffers have been emptied Kim Alvefur <zash@zash.se> parents: 9784 diff changeset	460 return (hosts[session.host] or prosody).events.fire_event("c2s-ondrain", { session = session });
7a703af90c9c mod_c2s: Fire an event when outgoing buffers have been emptied Kim Alvefur <zash@zash.se> parents: 9784 diff changeset	461 end
7a703af90c9c mod_c2s: Fire an event when outgoing buffers have been emptied Kim Alvefur <zash@zash.se> parents: 9784 diff changeset	462 end
7a703af90c9c mod_c2s: Fire an event when outgoing buffers have been emptied Kim Alvefur <zash@zash.se> parents: 9784 diff changeset	463
11742 9c450185bac1 mod_c2s,mod_s2s: Fire event just before writes Kim Alvefur <zash@zash.se> parents: 11622 diff changeset	464 function listener.onpredrain(conn)
9c450185bac1 mod_c2s,mod_s2s: Fire event just before writes Kim Alvefur <zash@zash.se> parents: 11622 diff changeset	465 local session = sessions[conn];
9c450185bac1 mod_c2s,mod_s2s: Fire event just before writes Kim Alvefur <zash@zash.se> parents: 11622 diff changeset	466 if session then
9c450185bac1 mod_c2s,mod_s2s: Fire event just before writes Kim Alvefur <zash@zash.se> parents: 11622 diff changeset	467 return (hosts[session.host] or prosody).events.fire_event("c2s-pre-ondrain", { session = session });
9c450185bac1 mod_c2s,mod_s2s: Fire event just before writes Kim Alvefur <zash@zash.se> parents: 11622 diff changeset	468 end
9c450185bac1 mod_c2s,mod_s2s: Fire event just before writes Kim Alvefur <zash@zash.se> parents: 11622 diff changeset	469 end
9c450185bac1 mod_c2s,mod_s2s: Fire event just before writes Kim Alvefur <zash@zash.se> parents: 11622 diff changeset	470
5669 9345c161481f mod_c2s, mod_s2s: Fire an event on read timeouts Kim Alvefur <zash@zash.se> parents: 5668 diff changeset	471 local function keepalive(event)
7540 e69df8093387 mod_c2s: Don't try to keep alive sessions where the stream is not (yet) open Kim Alvefur <zash@zash.se> parents: 7539 diff changeset	472 local session = event.session;
e69df8093387 mod_c2s: Don't try to keep alive sessions where the stream is not (yet) open Kim Alvefur <zash@zash.se> parents: 7539 diff changeset	473 if not session.notopen then
e69df8093387 mod_c2s: Don't try to keep alive sessions where the stream is not (yet) open Kim Alvefur <zash@zash.se> parents: 7539 diff changeset	474 return event.session.send(' ');
e69df8093387 mod_c2s: Don't try to keep alive sessions where the stream is not (yet) open Kim Alvefur <zash@zash.se> parents: 7539 diff changeset	475 end
5669 9345c161481f mod_c2s, mod_s2s: Fire an event on read timeouts Kim Alvefur <zash@zash.se> parents: 5668 diff changeset	476 end
9345c161481f mod_c2s, mod_s2s: Fire an event on read timeouts Kim Alvefur <zash@zash.se> parents: 5668 diff changeset	477
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	478 function listener.associate_session(conn, session)
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	479 sessions[conn] = session;
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	480 end
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	481
5669 9345c161481f mod_c2s, mod_s2s: Fire an event on read timeouts Kim Alvefur <zash@zash.se> parents: 5668 diff changeset	482 function module.add_host(module)
9345c161481f mod_c2s, mod_s2s: Fire an event on read timeouts Kim Alvefur <zash@zash.se> parents: 5668 diff changeset	483 module:hook("c2s-read-timeout", keepalive, -1);
14152 fed0dd8dda09 mod_c2s,mod_s2s: Introduce separate pre-authentication stanza size limit Kim Alvefur <zash@zash.se> parents: 12311 diff changeset	484 module:hook("authentication-success", function(event)
fed0dd8dda09 mod_c2s,mod_s2s: Introduce separate pre-authentication stanza size limit Kim Alvefur <zash@zash.se> parents: 12311 diff changeset	485 local session = event.session;
fed0dd8dda09 mod_c2s,mod_s2s: Introduce separate pre-authentication stanza size limit Kim Alvefur <zash@zash.se> parents: 12311 diff changeset	486 if session.stream then
fed0dd8dda09 mod_c2s,mod_s2s: Introduce separate pre-authentication stanza size limit Kim Alvefur <zash@zash.se> parents: 12311 diff changeset	487 session.stanza_size_limit = authed_stanza_size_limit;
fed0dd8dda09 mod_c2s,mod_s2s: Introduce separate pre-authentication stanza size limit Kim Alvefur <zash@zash.se> parents: 12311 diff changeset	488 session.stream:set_stanza_size_limit(session.stanza_size_limit);
fed0dd8dda09 mod_c2s,mod_s2s: Introduce separate pre-authentication stanza size limit Kim Alvefur <zash@zash.se> parents: 12311 diff changeset	489 end
fed0dd8dda09 mod_c2s,mod_s2s: Introduce separate pre-authentication stanza size limit Kim Alvefur <zash@zash.se> parents: 12311 diff changeset	490 end);
6380 4220ffb87b22 net.http, net.http.server, mod_c2s, mod_s2s, mod_component, mod_admin_telnet, mod_net_multiplex: Add ondetach to release connection from 'sessions' table (or equivalent) Matthew Wild <mwild1@gmail.com> parents: 6364 diff changeset	491 end
4220ffb87b22 net.http, net.http.server, mod_c2s, mod_s2s, mod_component, mod_admin_telnet, mod_net_multiplex: Add ondetach to release connection from 'sessions' table (or equivalent) Matthew Wild <mwild1@gmail.com> parents: 6364 diff changeset	492
5669 9345c161481f mod_c2s, mod_s2s: Fire an event on read timeouts Kim Alvefur <zash@zash.se> parents: 5668 diff changeset	493 module:hook("c2s-read-timeout", keepalive, -1);
5668 5a9318ac92f6 mod_c2s: Become a shared module and allow being disabled on some virtualhosts Kim Alvefur <zash@zash.se> parents: 5638 diff changeset	494
12302 6a8c680b8677 mod_c2s: Ignore unused event payload [luacheck] Kim Alvefur <zash@zash.se> parents: 12301 diff changeset	495 module:hook("server-stopping", function(event) -- luacheck: ignore 212/event
12298 cb459f8fa740 mod_c2s,mod_s2s: Disable and close port listeners before closing sessions Kim Alvefur <zash@zash.se> parents: 12071 diff changeset	496 -- Close ports
12977 74b9e05af71e plugins: Prefix module imports with prosody namespace Kim Alvefur <zash@zash.se> parents: 12907 diff changeset	497 local pm = require "prosody.core.portmanager";
12298 cb459f8fa740 mod_c2s,mod_s2s: Disable and close port listeners before closing sessions Kim Alvefur <zash@zash.se> parents: 12071 diff changeset	498 for _, netservice in pairs(module.items["net-provider"]) do
cb459f8fa740 mod_c2s,mod_s2s: Disable and close port listeners before closing sessions Kim Alvefur <zash@zash.se> parents: 12071 diff changeset	499 pm.unregister_service(netservice.name, netservice);
cb459f8fa740 mod_c2s,mod_s2s: Disable and close port listeners before closing sessions Kim Alvefur <zash@zash.se> parents: 12071 diff changeset	500 end
12300 fb74ff16620c mod_c2s: Close ports in a separate, earlier event from closing sessions Kim Alvefur <zash@zash.se> parents: 12298 diff changeset	501 end, -80);
12298 cb459f8fa740 mod_c2s,mod_s2s: Disable and close port listeners before closing sessions Kim Alvefur <zash@zash.se> parents: 12071 diff changeset	502
12300 fb74ff16620c mod_c2s: Close ports in a separate, earlier event from closing sessions Kim Alvefur <zash@zash.se> parents: 12298 diff changeset	503 module:hook("server-stopping", function(event)
12311 bc30e1b9ad89 mod_c2s,mod_s2s: Fix error on shutdown (Thanks Martin) Kim Alvefur <zash@zash.se> parents: 12309 diff changeset	504 local wait, done = async.waiter(1, true);
12301 4f1fe6eb1ddb mod_c2s,mod_s2s: Wait for sessions to close before proceeding with shutdown steps Kim Alvefur <zash@zash.se> parents: 12300 diff changeset	505 module:hook("c2s-closed", function ()
4f1fe6eb1ddb mod_c2s,mod_s2s: Wait for sessions to close before proceeding with shutdown steps Kim Alvefur <zash@zash.se> parents: 12300 diff changeset	506 if next(sessions) == nil then done(); end
4f1fe6eb1ddb mod_c2s,mod_s2s: Wait for sessions to close before proceeding with shutdown steps Kim Alvefur <zash@zash.se> parents: 12300 diff changeset	507 end)
4f1fe6eb1ddb mod_c2s,mod_s2s: Wait for sessions to close before proceeding with shutdown steps Kim Alvefur <zash@zash.se> parents: 12300 diff changeset	508
12298 cb459f8fa740 mod_c2s,mod_s2s: Disable and close port listeners before closing sessions Kim Alvefur <zash@zash.se> parents: 12071 diff changeset	509 -- Close sessions
5281 815c689f85ad prosody, mod_c2s, mod_s2s: Move closing of c2s and s2s sessions to respective plugins Kim Alvefur <zash@zash.se> parents: 5228 diff changeset	510 local reason = event.reason;
815c689f85ad prosody, mod_c2s, mod_s2s: Move closing of c2s and s2s sessions to respective plugins Kim Alvefur <zash@zash.se> parents: 5228 diff changeset	511 for _, session in pairs(sessions) do
815c689f85ad prosody, mod_c2s, mod_s2s: Move closing of c2s and s2s sessions to respective plugins Kim Alvefur <zash@zash.se> parents: 5228 diff changeset	512 session:close{ condition = "system-shutdown", text = reason };
815c689f85ad prosody, mod_c2s, mod_s2s: Move closing of c2s and s2s sessions to respective plugins Kim Alvefur <zash@zash.se> parents: 5228 diff changeset	513 end
12301 4f1fe6eb1ddb mod_c2s,mod_s2s: Wait for sessions to close before proceeding with shutdown steps Kim Alvefur <zash@zash.se> parents: 12300 diff changeset	514
4f1fe6eb1ddb mod_c2s,mod_s2s: Wait for sessions to close before proceeding with shutdown steps Kim Alvefur <zash@zash.se> parents: 12300 diff changeset	515 -- Wait for them to close properly if they haven't already
4f1fe6eb1ddb mod_c2s,mod_s2s: Wait for sessions to close before proceeding with shutdown steps Kim Alvefur <zash@zash.se> parents: 12300 diff changeset	516 if next(sessions) ~= nil then
12309 926a6c5d13e7 mod_c2s,mod_s2s: Wrap callback to improve tracebacks Kim Alvefur <zash@zash.se> parents: 12302 diff changeset	517 add_task(stream_close_timeout+1, function () done() end);
12301 4f1fe6eb1ddb mod_c2s,mod_s2s: Wait for sessions to close before proceeding with shutdown steps Kim Alvefur <zash@zash.se> parents: 12300 diff changeset	518 module:log("info", "Waiting for sessions to close");
4f1fe6eb1ddb mod_c2s,mod_s2s: Wait for sessions to close before proceeding with shutdown steps Kim Alvefur <zash@zash.se> parents: 12300 diff changeset	519 wait();
4f1fe6eb1ddb mod_c2s,mod_s2s: Wait for sessions to close before proceeding with shutdown steps Kim Alvefur <zash@zash.se> parents: 12300 diff changeset	520 end
4f1fe6eb1ddb mod_c2s,mod_s2s: Wait for sessions to close before proceeding with shutdown steps Kim Alvefur <zash@zash.se> parents: 12300 diff changeset	521
7100 301d58705667 mod_c2s, mod_s2s: Lower priority of session shutdown to negative, so that plugins hooking at the default priority run first (fixes #601) Kim Alvefur <zash@zash.se> parents: 6380 diff changeset	522 end, -100);
5281 815c689f85ad prosody, mod_c2s, mod_s2s: Move closing of c2s and s2s sessions to respective plugins Kim Alvefur <zash@zash.se> parents: 5228 diff changeset	523
815c689f85ad prosody, mod_c2s, mod_s2s: Move closing of c2s and s2s sessions to respective plugins Kim Alvefur <zash@zash.se> parents: 5228 diff changeset	524
815c689f85ad prosody, mod_c2s, mod_s2s: Move closing of c2s and s2s sessions to respective plugins Kim Alvefur <zash@zash.se> parents: 5228 diff changeset	525
5120 bcabea740c00 mod_{admin_telnet,c2s,component,http,net_multiplex,s2s}: Use module:provides() instead of module:add_item(). Waqas Hussain <waqas20@gmail.com> parents: 5097 diff changeset	526 module:provides("net", {
4610 171051f9dd00 mod_c2s: Use module:add_item() to add the net-provider for portmanager Matthew Wild <mwild1@gmail.com> parents: 4551 diff changeset	527 name = "c2s";
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	528 listener = listener;
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	529 default_port = 5222;
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	530 encryption = "starttls";
4626 9df9e87d0339 mod_c2s: Add missing multiplexed service discovery pattern. Kim Alvefur <zash@zash.se> parents: 4625 diff changeset	531 multiplex = {
10465 09697a673015 mod_net_multiplex: Add support for using ALPN Kim Alvefur <zash@zash.se> parents: 10379 diff changeset	532 protocol = "xmpp-client";
4626 9df9e87d0339 mod_c2s: Add missing multiplexed service discovery pattern. Kim Alvefur <zash@zash.se> parents: 4625 diff changeset	533 pattern = "^<.:stream.%sxmlns%s=%s(['\"])jabber:client%1.*>";
9df9e87d0339 mod_c2s: Add missing multiplexed service discovery pattern. Kim Alvefur <zash@zash.se> parents: 4625 diff changeset	534 };
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	535 });
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	536
5120 bcabea740c00 mod_{admin_telnet,c2s,component,http,net_multiplex,s2s}: Use module:provides() instead of module:add_item(). Waqas Hussain <waqas20@gmail.com> parents: 5097 diff changeset	537 module:provides("net", {
11778 f254fd16218a mod_c2s: Rename Direct TLS listener 'c2s_direct_tls' for clarity Kim Alvefur <zash@zash.se> parents: 11770 diff changeset	538 name = "c2s_direct_tls";
11614 1ac8976f09a9 mod_c2s: Add a Direct TLS listener Kim Alvefur <zash@zash.se> parents: 11608 diff changeset	539 listener = listener;
1ac8976f09a9 mod_c2s: Add a Direct TLS listener Kim Alvefur <zash@zash.se> parents: 11608 diff changeset	540 encryption = "ssl";
1ac8976f09a9 mod_c2s: Add a Direct TLS listener Kim Alvefur <zash@zash.se> parents: 11608 diff changeset	541 multiplex = {
1ac8976f09a9 mod_c2s: Add a Direct TLS listener Kim Alvefur <zash@zash.se> parents: 11608 diff changeset	542 pattern = "^<.:stream.%sxmlns%s=%s(['\"])jabber:client%1.*>";
1ac8976f09a9 mod_c2s: Add a Direct TLS listener Kim Alvefur <zash@zash.se> parents: 11608 diff changeset	543 };
1ac8976f09a9 mod_c2s: Add a Direct TLS listener Kim Alvefur <zash@zash.se> parents: 11608 diff changeset	544 });
1ac8976f09a9 mod_c2s: Add a Direct TLS listener Kim Alvefur <zash@zash.se> parents: 11608 diff changeset	545
1ac8976f09a9 mod_c2s: Add a Direct TLS listener Kim Alvefur <zash@zash.se> parents: 11608 diff changeset	546 -- COMPAT
1ac8976f09a9 mod_c2s: Add a Direct TLS listener Kim Alvefur <zash@zash.se> parents: 11608 diff changeset	547 module:provides("net", {
4610 171051f9dd00 mod_c2s: Use module:add_item() to add the net-provider for portmanager Matthew Wild <mwild1@gmail.com> parents: 4551 diff changeset	548 name = "legacy_ssl";
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	549 listener = listener;
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	550 encryption = "ssl";
4620 e9dc6ae68c69 mod_c2s, mod_s2s: Add multiplex support Matthew Wild <mwild1@gmail.com> parents: 4610 diff changeset	551 multiplex = {
e9dc6ae68c69 mod_c2s, mod_s2s: Add multiplex support Matthew Wild <mwild1@gmail.com> parents: 4610 diff changeset	552 pattern = "^<.:stream.%sxmlns%s=%s(['\"])jabber:client%1.*>";
e9dc6ae68c69 mod_c2s, mod_s2s: Add multiplex support Matthew Wild <mwild1@gmail.com> parents: 4610 diff changeset	553 };
4543 db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	554 });
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	555
db27a4c18b6a mod_c2s, sessionmanager, xmppclient_listener: Move all c2s network and stream logic into a new module, mod_c2s Matthew Wild <mwild1@gmail.com> parents: diff changeset	556

Mercurial > prosody-hg

annotate plugins/mod_c2s.lua @ 14179:25beb66fab38 13.0