Software `/` code `/` prosody

Annotate

plugins/mod_component.lua @ 11540:1937b3c3efb5 0.11

mod_c2s, mod_s2s, mod_component, mod_bosh, mod_websockets: Set default stanza size limits c2s/bosh/ws streams will default to 256KB, s2s and components to 512KB. These values are aligned with ejabberd's default settings, which should reduce issues related to inconsistent size limits between servers on the XMPP network. The previous default (10MB) is excessive for any production server, and allows significant memory usage by even unauthenticated sessions.

author	Matthew Wild <mwild1@gmail.com>
date	Fri, 07 May 2021 17:03:49 +0100
parent	9562:acf74ad0b795
child	11560:3bbb1af92514

rev	line source
1523 841d61be198f Remove version number from copyright headers Matthew Wild <mwild1@gmail.com> parents: 1405 diff changeset	1 -- Prosody IM
2923 b7049746bd29 Update copyright headers for 2010 Matthew Wild <mwild1@gmail.com> parents: 2490 diff changeset	2 -- Copyright (C) 2008-2010 Matthew Wild
b7049746bd29 Update copyright headers for 2010 Matthew Wild <mwild1@gmail.com> parents: 2490 diff changeset	3 -- Copyright (C) 2008-2010 Waqas Hussain
5776 bd0ff8ae98a8 Remove all trailing whitespace Florian Zeitz <florob@babelmonkeys.de> parents: 5728 diff changeset	4 --
902 00daf63c129e Add initial mod_component for XEP-0114 support. Albert, where are you? Matthew Wild <mwild1@gmail.com> parents: diff changeset	5 -- This project is MIT/X11 licensed. Please see the
00daf63c129e Add initial mod_component for XEP-0114 support. Albert, where are you? Matthew Wild <mwild1@gmail.com> parents: diff changeset	6 -- COPYING file in the source package for more information.
00daf63c129e Add initial mod_component for XEP-0114 support. Albert, where are you? Matthew Wild <mwild1@gmail.com> parents: diff changeset	7 --
00daf63c129e Add initial mod_component for XEP-0114 support. Albert, where are you? Matthew Wild <mwild1@gmail.com> parents: diff changeset	8
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	9 module:set_global();
902 00daf63c129e Add initial mod_component for XEP-0114 support. Albert, where are you? Matthew Wild <mwild1@gmail.com> parents: diff changeset	10
00daf63c129e Add initial mod_component for XEP-0114 support. Albert, where are you? Matthew Wild <mwild1@gmail.com> parents: diff changeset	11 local t_concat = table.concat;
9562 acf74ad0b795 Many things: switch from hacky multi-arg xpcall implementations to a standard util.xpcall Matthew Wild <mwild1@gmail.com> parents: 8888 diff changeset	12 local tostring, type = tostring, type;
acf74ad0b795 Many things: switch from hacky multi-arg xpcall implementations to a standard util.xpcall Matthew Wild <mwild1@gmail.com> parents: 8888 diff changeset	13 local xpcall = require "util.xpcall".xpcall;
5724 a49f32e3d73b mod_component: xpcall() stanza processing, as per other listeners, preventing potentially harmful 'top-level errors' Matthew Wild <mwild1@gmail.com> parents: 5370 diff changeset	14 local traceback = debug.traceback;
902 00daf63c129e Add initial mod_component for XEP-0114 support. Albert, where are you? Matthew Wild <mwild1@gmail.com> parents: diff changeset	15
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	16 local logger = require "util.logger";
902 00daf63c129e Add initial mod_component for XEP-0114 support. Albert, where are you? Matthew Wild <mwild1@gmail.com> parents: diff changeset	17 local sha1 = require "util.hashes".sha1;
1042 a3d77353c18a mod_: Fix a load of global accesses Matthew Wild <mwild1@gmail.com>* parents: 981 diff changeset	18 local st = require "util.stanza";
902 00daf63c129e Add initial mod_component for XEP-0114 support. Albert, where are you? Matthew Wild <mwild1@gmail.com> parents: diff changeset	19
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	20 local jid_split = require "util.jid".split;
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	21 local new_xmpp_stream = require "util.xmppstream".new;
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	22 local uuid_gen = require "util.uuid".generate;
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	23
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: 4993 diff changeset	24 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: 5316 diff changeset	25 local hosts = prosody.hosts;
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	26
902 00daf63c129e Add initial mod_component for XEP-0114 support. Albert, where are you? Matthew Wild <mwild1@gmail.com> parents: diff changeset	27 local log = module._log;
00daf63c129e Add initial mod_component for XEP-0114 support. Albert, where are you? Matthew Wild <mwild1@gmail.com> parents: diff changeset	28
5953 1c08d6cca552 mod_component: Enable TCP keepalives on component streams Kim Alvefur <zash@zash.se> parents: 5952 diff changeset	29 local opt_keepalives = module:get_option_boolean("component_tcp_keepalives", module:get_option_boolean("tcp_keepalives", true));
11540 1937b3c3efb5 mod_c2s, mod_s2s, mod_component, mod_bosh, mod_websockets: Set default stanza size limits Matthew Wild <mwild1@gmail.com> parents: 9562 diff changeset	30 local stanza_size_limit = module:get_option_number("component_stanza_size_limit", module:get_option_number("s2s_stanza_size_limit", 1024*512));
5953 1c08d6cca552 mod_component: Enable TCP keepalives on component streams Kim Alvefur <zash@zash.se> parents: 5952 diff changeset	31
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	32 local sessions = module:shared("sessions");
3581 3f3f8227ba76 mod_component: Updated to use events for hooking stanzas instead of the component stanza handler, and the on_destroy callback. Waqas Hussain <waqas20@gmail.com> parents: 3579 diff changeset	33
7886 679746cdf3cc mod_component: Add read timeout handler (same behaviour as c2s and s2s) Kim Alvefur <zash@zash.se> parents: 7873 diff changeset	34 local function keepalive(event)
679746cdf3cc mod_component: Add read timeout handler (same behaviour as c2s and s2s) Kim Alvefur <zash@zash.se> parents: 7873 diff changeset	35 local session = event.session;
679746cdf3cc mod_component: Add read timeout handler (same behaviour as c2s and s2s) Kim Alvefur <zash@zash.se> parents: 7873 diff changeset	36 if not session.notopen then
679746cdf3cc mod_component: Add read timeout handler (same behaviour as c2s and s2s) Kim Alvefur <zash@zash.se> parents: 7873 diff changeset	37 return event.session.send(' ');
679746cdf3cc mod_component: Add read timeout handler (same behaviour as c2s and s2s) Kim Alvefur <zash@zash.se> parents: 7873 diff changeset	38 end
679746cdf3cc mod_component: Add read timeout handler (same behaviour as c2s and s2s) Kim Alvefur <zash@zash.se> parents: 7873 diff changeset	39 end
679746cdf3cc mod_component: Add read timeout handler (same behaviour as c2s and s2s) Kim Alvefur <zash@zash.se> parents: 7873 diff changeset	40
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	41 function module.add_host(module)
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	42 if module:get_host_type() ~= "component" then
7359 a5a080c12c96 Update every link to the documentation to use HTTPS Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 7301 diff changeset	43 error("Don't load mod_component manually, it should be for a component, please see https://prosody.im/doc/components", 0);
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	44 end
7873 8d1ebb9a9b44 mod_component: Trim trailing whitespace Kim Alvefur <zash@zash.se> parents: 7665 diff changeset	45
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	46 local env = module.environment;
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	47 env.connected = false;
6913 c7a0d5299933 mod_component: Add config option for deciding what happens if a component connects while already connected (fixes #525) Kim Alvefur <zash@zash.se> parents: 6774 diff changeset	48 env.session = false;
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	49
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	50 local send;
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	51
7301 995777582044 mod_component: Some cleanup [luacheck] Matthew Wild <mwild1@gmail.com> parents: 7300 diff changeset	52 local function on_destroy(session, err) --luacheck: ignore 212/err
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	53 env.connected = false;
6913 c7a0d5299933 mod_component: Add config option for deciding what happens if a component connects while already connected (fixes #525) Kim Alvefur <zash@zash.se> parents: 6774 diff changeset	54 env.session = false;
3581 3f3f8227ba76 mod_component: Updated to use events for hooking stanzas instead of the component stanza handler, and the on_destroy callback. Waqas Hussain <waqas20@gmail.com> parents: 3579 diff changeset	55 send = nil;
3f3f8227ba76 mod_component: Updated to use events for hooking stanzas instead of the component stanza handler, and the on_destroy callback. Waqas Hussain <waqas20@gmail.com> parents: 3579 diff changeset	56 session.on_destroy = nil;
3f3f8227ba76 mod_component: Updated to use events for hooking stanzas instead of the component stanza handler, and the on_destroy callback. Waqas Hussain <waqas20@gmail.com> parents: 3579 diff changeset	57 end
7873 8d1ebb9a9b44 mod_component: Trim trailing whitespace Kim Alvefur <zash@zash.se> parents: 7665 diff changeset	58
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	59 -- Handle authentication attempts by component
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	60 local function handle_component_auth(event)
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	61 local session, stanza = event.origin, event.stanza;
7873 8d1ebb9a9b44 mod_component: Trim trailing whitespace Kim Alvefur <zash@zash.se> parents: 7665 diff changeset	62
4806 27a99c289b90 mod_component: Allow unauthenticated components to authenticate (thanks Maranda) Matthew Wild <mwild1@gmail.com> parents: 4805 diff changeset	63 if session.type ~= "component_unauthed" then return; end
7873 8d1ebb9a9b44 mod_component: Trim trailing whitespace Kim Alvefur <zash@zash.se> parents: 7665 diff changeset	64
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	65 if (not session.host) or #stanza.tags > 0 then
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	66 (session.log or log)("warn", "Invalid component handshake for host: %s", session.host);
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	67 session:close("not-authorized");
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	68 return true;
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	69 end
7873 8d1ebb9a9b44 mod_component: Trim trailing whitespace Kim Alvefur <zash@zash.se> parents: 7665 diff changeset	70
8134 b87e281a7d59 mod_component: Use typed config API Kim Alvefur <zash@zash.se> parents: 7886 diff changeset	71 local secret = module:get_option_string("component_secret");
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	72 if not secret then
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	73 (session.log or log)("warn", "Component attempted to identify as %s, but component_secret is not set", session.host);
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	74 session:close("not-authorized");
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	75 return true;
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	76 end
7873 8d1ebb9a9b44 mod_component: Trim trailing whitespace Kim Alvefur <zash@zash.se> parents: 7665 diff changeset	77
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	78 local supplied_token = t_concat(stanza);
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	79 local calculated_token = sha1(session.streamid..secret, true);
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	80 if supplied_token:lower() ~= calculated_token:lower() then
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	81 module:log("info", "Component authentication failed for %s", session.host);
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	82 session:close{ condition = "not-authorized", text = "Given token does not match calculated token" };
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	83 return true;
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	84 end
7873 8d1ebb9a9b44 mod_component: Trim trailing whitespace Kim Alvefur <zash@zash.se> parents: 7665 diff changeset	85
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	86 if env.connected then
6913 c7a0d5299933 mod_component: Add config option for deciding what happens if a component connects while already connected (fixes #525) Kim Alvefur <zash@zash.se> parents: 6774 diff changeset	87 local policy = module:get_option_string("component_conflict_resolve", "kick_new");
c7a0d5299933 mod_component: Add config option for deciding what happens if a component connects while already connected (fixes #525) Kim Alvefur <zash@zash.se> parents: 6774 diff changeset	88 if policy == "kick_old" then
c7a0d5299933 mod_component: Add config option for deciding what happens if a component connects while already connected (fixes #525) Kim Alvefur <zash@zash.se> parents: 6774 diff changeset	89 env.session:close{ condition = "conflict", text = "Replaced by a new connection" };
c7a0d5299933 mod_component: Add config option for deciding what happens if a component connects while already connected (fixes #525) Kim Alvefur <zash@zash.se> parents: 6774 diff changeset	90 else -- kick_new
c7a0d5299933 mod_component: Add config option for deciding what happens if a component connects while already connected (fixes #525) Kim Alvefur <zash@zash.se> parents: 6774 diff changeset	91 module:log("error", "Second component attempted to connect, denying connection");
c7a0d5299933 mod_component: Add config option for deciding what happens if a component connects while already connected (fixes #525) Kim Alvefur <zash@zash.se> parents: 6774 diff changeset	92 session:close{ condition = "conflict", text = "Component already connected" };
c7a0d5299933 mod_component: Add config option for deciding what happens if a component connects while already connected (fixes #525) Kim Alvefur <zash@zash.se> parents: 6774 diff changeset	93 return true;
c7a0d5299933 mod_component: Add config option for deciding what happens if a component connects while already connected (fixes #525) Kim Alvefur <zash@zash.se> parents: 6774 diff changeset	94 end
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	95 end
7873 8d1ebb9a9b44 mod_component: Trim trailing whitespace Kim Alvefur <zash@zash.se> parents: 7665 diff changeset	96
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	97 env.connected = true;
6913 c7a0d5299933 mod_component: Add config option for deciding what happens if a component connects while already connected (fixes #525) Kim Alvefur <zash@zash.se> parents: 6774 diff changeset	98 env.session = session;
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	99 send = session.send;
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	100 session.on_destroy = on_destroy;
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	101 session.component_validate_from = module:get_option_boolean("validate_from_addresses", true);
4805 1aeece2cc814 mod_component: Components start out as component_unauthed until successful authentication (thanks xnyhps) Matthew Wild <mwild1@gmail.com> parents: 4803 diff changeset	102 session.type = "component";
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	103 module:log("info", "External component successfully authenticated");
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	104 session.send(st.stanza("handshake"));
6773 ef22c17cc24d mod_component: Fire an event on successful component authentication (For Goffi) Kim Alvefur <zash@zash.se> parents: 6380 diff changeset	105 module:fire_event("component-authenticated", { session = session });
7873 8d1ebb9a9b44 mod_component: Trim trailing whitespace Kim Alvefur <zash@zash.se> parents: 7665 diff changeset	106
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	107 return true;
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	108 end
5952 31b800964dfb mod_component: Decrease priority of component auth hook Kim Alvefur <zash@zash.se> parents: 5728 diff changeset	109 module:hook("stanza/jabber:component:accept:handshake", handle_component_auth, -1);
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	110
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	111 -- Handle stanzas addressed to this component
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	112 local function handle_stanza(event)
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	113 local stanza = event.stanza;
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	114 if send then
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	115 stanza.attr.xmlns = nil;
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	116 send(stanza);
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	117 else
5059 246ba539a5cd mod_component: For disconnected external components, if a name is specified in config, return it in disco#info replies. Waqas Hussain <waqas20@gmail.com> parents: 5013 diff changeset	118 if stanza.name == "iq" and stanza.attr.type == "get" and stanza.attr.to == module.host then
246ba539a5cd mod_component: For disconnected external components, if a name is specified in config, return it in disco#info replies. Waqas Hussain <waqas20@gmail.com> parents: 5013 diff changeset	119 local query = stanza.tags[1];
246ba539a5cd mod_component: For disconnected external components, if a name is specified in config, return it in disco#info replies. Waqas Hussain <waqas20@gmail.com> parents: 5013 diff changeset	120 local node = query.attr.node;
246ba539a5cd mod_component: For disconnected external components, if a name is specified in config, return it in disco#info replies. Waqas Hussain <waqas20@gmail.com> parents: 5013 diff changeset	121 if query.name == "query" and query.attr.xmlns == "http://jabber.org/protocol/disco#info" and (not node or node == "") then
246ba539a5cd mod_component: For disconnected external components, if a name is specified in config, return it in disco#info replies. Waqas Hussain <waqas20@gmail.com> parents: 5013 diff changeset	122 local name = module:get_option_string("name");
246ba539a5cd mod_component: For disconnected external components, if a name is specified in config, return it in disco#info replies. Waqas Hussain <waqas20@gmail.com> parents: 5013 diff changeset	123 if name then
8886 9aa35cb939ac mod_component: Fix a wrongly-placed closing parenthesis, fixes #1164. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 8508 diff changeset	124 local reply = st.reply(stanza):tag("query", { xmlns = "http://jabber.org/protocol/disco#info" })
9aa35cb939ac mod_component: Fix a wrongly-placed closing parenthesis, fixes #1164. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 8508 diff changeset	125 :tag("identity", { category = "component", type = "generic", name = module:get_option_string("name", "Prosody") }):up()
9aa35cb939ac mod_component: Fix a wrongly-placed closing parenthesis, fixes #1164. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 8508 diff changeset	126 :tag("feature", { var = "http://jabber.org/protocol/disco#info" }):up();
9aa35cb939ac mod_component: Fix a wrongly-placed closing parenthesis, fixes #1164. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 8508 diff changeset	127 event.origin.send(reply);
5059 246ba539a5cd mod_component: For disconnected external components, if a name is specified in config, return it in disco#info replies. Waqas Hussain <waqas20@gmail.com> parents: 5013 diff changeset	128 return true;
246ba539a5cd mod_component: For disconnected external components, if a name is specified in config, return it in disco#info replies. Waqas Hussain <waqas20@gmail.com> parents: 5013 diff changeset	129 end
246ba539a5cd mod_component: For disconnected external components, if a name is specified in config, return it in disco#info replies. Waqas Hussain <waqas20@gmail.com> parents: 5013 diff changeset	130 end
246ba539a5cd mod_component: For disconnected external components, if a name is specified in config, return it in disco#info replies. Waqas Hussain <waqas20@gmail.com> parents: 5013 diff changeset	131 end
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	132 module:log("warn", "Component not connected, bouncing error for: %s", stanza:top_tag());
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	133 if stanza.attr.type ~= "error" and stanza.attr.type ~= "result" then
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	134 event.origin.send(st.error_reply(stanza, "wait", "service-unavailable", "Component unavailable"));
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	135 end
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	136 end
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	137 return true;
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	138 end
7873 8d1ebb9a9b44 mod_component: Trim trailing whitespace Kim Alvefur <zash@zash.se> parents: 7665 diff changeset	139
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	140 module:hook("iq/bare", handle_stanza, -1);
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	141 module:hook("message/bare", handle_stanza, -1);
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	142 module:hook("presence/bare", handle_stanza, -1);
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	143 module:hook("iq/full", handle_stanza, -1);
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	144 module:hook("message/full", handle_stanza, -1);
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	145 module:hook("presence/full", handle_stanza, -1);
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	146 module:hook("iq/host", handle_stanza, -1);
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	147 module:hook("message/host", handle_stanza, -1);
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	148 module:hook("presence/host", handle_stanza, -1);
7886 679746cdf3cc mod_component: Add read timeout handler (same behaviour as c2s and s2s) Kim Alvefur <zash@zash.se> parents: 7873 diff changeset	149
679746cdf3cc mod_component: Add read timeout handler (same behaviour as c2s and s2s) Kim Alvefur <zash@zash.se> parents: 7873 diff changeset	150 module:hook("component-read-timeout", keepalive, -1);
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	151 end
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	152
7886 679746cdf3cc mod_component: Add read timeout handler (same behaviour as c2s and s2s) Kim Alvefur <zash@zash.se> parents: 7873 diff changeset	153 module:hook("component-read-timeout", keepalive, -1);
679746cdf3cc mod_component: Add read timeout handler (same behaviour as c2s and s2s) Kim Alvefur <zash@zash.se> parents: 7873 diff changeset	154
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	155 --- Network and stream part ---
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	156
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	157 local xmlns_component = 'jabber:component:accept';
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	158
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	159 local listener = {};
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	160
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	161 --- Callbacks/data for xmppstream to handle streams for us ---
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	162
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	163 local stream_callbacks = { default_ns = xmlns_component };
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	164
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	165 local xmlns_xmpp_streams = "urn:ietf:params:xml:ns:xmpp-streams";
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	166
7301 995777582044 mod_component: Some cleanup [luacheck] Matthew Wild <mwild1@gmail.com> parents: 7300 diff changeset	167 function stream_callbacks.error(session, error, data)
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	168 if session.destroyed then return; end
4993 5243b74a4cbb Hopefully inert commit to clean up logging across a number of modules, removing all cases of concatenation when building log messages Matthew Wild <mwild1@gmail.com> parents: 4806 diff changeset	169 module:log("warn", "Error processing component stream: %s", tostring(error));
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	170 if error == "no-stream" then
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	171 session:close("invalid-namespace");
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	172 elseif error == "parse-error" then
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	173 session.log("warn", "External component %s XML parse error: %s", tostring(session.host), tostring(data));
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	174 session:close("not-well-formed");
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	175 elseif error == "stream-error" then
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	176 local condition, text = "undefined-condition";
8233 4e7269c53659 mod_component, mod_s2s: Iterate over child tags instead of child nodes (can include text) in stream error (same as 176b7f4e4ac9) Kim Alvefur <zash@zash.se> parents: 6773 diff changeset	177 for child in data:childtags(nil, xmlns_xmpp_streams) do
4e7269c53659 mod_component, mod_s2s: Iterate over child tags instead of child nodes (can include text) in stream error (same as 176b7f4e4ac9) Kim Alvefur <zash@zash.se> parents: 6773 diff changeset	178 if child.name ~= "text" then
4e7269c53659 mod_component, mod_s2s: Iterate over child tags instead of child nodes (can include text) in stream error (same as 176b7f4e4ac9) Kim Alvefur <zash@zash.se> parents: 6773 diff changeset	179 condition = child.name;
4e7269c53659 mod_component, mod_s2s: Iterate over child tags instead of child nodes (can include text) in stream error (same as 176b7f4e4ac9) Kim Alvefur <zash@zash.se> parents: 6773 diff changeset	180 else
4e7269c53659 mod_component, mod_s2s: Iterate over child tags instead of child nodes (can include text) in stream error (same as 176b7f4e4ac9) Kim Alvefur <zash@zash.se> parents: 6773 diff changeset	181 text = child:get_text();
4e7269c53659 mod_component, mod_s2s: Iterate over child tags instead of child nodes (can include text) in stream error (same as 176b7f4e4ac9) Kim Alvefur <zash@zash.se> parents: 6773 diff changeset	182 end
4e7269c53659 mod_component, mod_s2s: Iterate over child tags instead of child nodes (can include text) in stream error (same as 176b7f4e4ac9) Kim Alvefur <zash@zash.se> parents: 6773 diff changeset	183 if condition ~= "undefined-condition" and text then
4e7269c53659 mod_component, mod_s2s: Iterate over child tags instead of child nodes (can include text) in stream error (same as 176b7f4e4ac9) Kim Alvefur <zash@zash.se> parents: 6773 diff changeset	184 break;
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	185 end
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	186 end
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	187 text = condition .. (text and (" ("..text..")") or "");
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	188 session.log("info", "Session closed by remote with error: %s", text);
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	189 session:close(nil, text);
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	190 end
3581 3f3f8227ba76 mod_component: Updated to use events for hooking stanzas instead of the component stanza handler, and the on_destroy callback. Waqas Hussain <waqas20@gmail.com> parents: 3579 diff changeset	191 end
3f3f8227ba76 mod_component: Updated to use events for hooking stanzas instead of the component stanza handler, and the on_destroy callback. Waqas Hussain <waqas20@gmail.com> parents: 3579 diff changeset	192
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	193 function stream_callbacks.streamopened(session, attr)
4655 9159546cb2f3 mod_component: Handle component connecting to non-existent host Matthew Wild <mwild1@gmail.com> parents: 4650 diff changeset	194 if not hosts[attr.to] or not hosts[attr.to].modules.component then
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	195 session:close{ condition = "host-unknown", text = tostring(attr.to).." does not match any configured external components" };
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	196 return;
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	197 end
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	198 session.host = attr.to;
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	199 session.streamid = uuid_gen();
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	200 session.notopen = nil;
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	201 -- Return stream header
6063 e626ee2fe106 mod_c2s, mod_s2s, mod_component, util.xmppstream: Move all session:open_stream() functions to util.xmppstream Kim Alvefur <zash@zash.se> parents: 5954 diff changeset	202 session:open_stream();
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	203 end
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	204
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	205 function stream_callbacks.streamclosed(session)
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	206 session.log("debug", "Received </stream:stream>");
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	207 session:close();
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	208 end
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	209
5724 a49f32e3d73b mod_component: xpcall() stanza processing, as per other listeners, preventing potentially harmful 'top-level errors' Matthew Wild <mwild1@gmail.com> parents: 5370 diff changeset	210 local function handleerr(err) log("error", "Traceback[component]: %s", traceback(tostring(err), 2)); end
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	211 function stream_callbacks.handlestanza(session, stanza)
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	212 -- Namespaces are icky.
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	213 if not stanza.attr.xmlns and stanza.name == "handshake" then
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	214 stanza.attr.xmlns = xmlns_component;
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	215 end
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	216 if not stanza.attr.xmlns or stanza.attr.xmlns == "jabber:client" then
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	217 local from = stanza.attr.from;
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	218 if from then
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	219 if session.component_validate_from then
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	220 local _, domain = jid_split(stanza.attr.from);
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	221 if domain ~= session.host then
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	222 -- Return error
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	223 session.log("warn", "Component sent stanza with missing or invalid 'from' address");
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	224 session:close{
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	225 condition = "invalid-from";
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	226 text = "Component tried to send from address <"..tostring(from)
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	227 .."> which is not in domain <"..tostring(session.host)..">";
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	228 };
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	229 return;
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	230 end
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	231 end
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	232 else
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	233 stanza.attr.from = session.host; -- COMPAT: Strictly we shouldn't allow this
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	234 end
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	235 if not stanza.attr.to then
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	236 session.log("warn", "Rejecting stanza with no 'to' address");
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	237 session.send(st.error_reply(stanza, "modify", "bad-request", "Components MUST specify a 'to' address on stanzas"));
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	238 return;
3581 3f3f8227ba76 mod_component: Updated to use events for hooking stanzas instead of the component stanza handler, and the on_destroy callback. Waqas Hussain <waqas20@gmail.com> parents: 3579 diff changeset	239 end
3f3f8227ba76 mod_component: Updated to use events for hooking stanzas instead of the component stanza handler, and the on_destroy callback. Waqas Hussain <waqas20@gmail.com> parents: 3579 diff changeset	240 end
5724 a49f32e3d73b mod_component: xpcall() stanza processing, as per other listeners, preventing potentially harmful 'top-level errors' Matthew Wild <mwild1@gmail.com> parents: 5370 diff changeset	241
a49f32e3d73b mod_component: xpcall() stanza processing, as per other listeners, preventing potentially harmful 'top-level errors' Matthew Wild <mwild1@gmail.com> parents: 5370 diff changeset	242 if stanza then
9562 acf74ad0b795 Many things: switch from hacky multi-arg xpcall implementations to a standard util.xpcall Matthew Wild <mwild1@gmail.com> parents: 8888 diff changeset	243 return xpcall(core_process_stanza, handleerr, session, stanza);
5724 a49f32e3d73b mod_component: xpcall() stanza processing, as per other listeners, preventing potentially harmful 'top-level errors' Matthew Wild <mwild1@gmail.com> parents: 5370 diff changeset	244 end
3581 3f3f8227ba76 mod_component: Updated to use events for hooking stanzas instead of the component stanza handler, and the on_destroy callback. Waqas Hussain <waqas20@gmail.com> parents: 3579 diff changeset	245 end
3f3f8227ba76 mod_component: Updated to use events for hooking stanzas instead of the component stanza handler, and the on_destroy callback. Waqas Hussain <waqas20@gmail.com> parents: 3579 diff changeset	246
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	247 --- Closing a component connection
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	248 local stream_xmlns_attr = {xmlns='urn:ietf:params:xml:ns:xmpp-streams'};
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	249 local default_stream_attr = { ["xmlns:stream"] = "http://etherx.jabber.org/streams", xmlns = stream_callbacks.default_ns, version = "1.0", id = "" };
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	250 local function session_close(session, reason)
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	251 if session.destroyed then return; end
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	252 if session.conn then
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	253 if session.notopen then
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	254 session.send("<?xml version='1.0'?>");
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	255 session.send(st.stanza("stream:stream", default_stream_attr):top_tag());
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	256 end
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	257 if reason then
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	258 if type(reason) == "string" then -- assume stream error
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	259 module:log("info", "Disconnecting component, <stream:error> is: %s", reason);
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	260 session.send(st.stanza("stream:error"):tag(reason, {xmlns = 'urn:ietf:params:xml:ns:xmpp-streams' }));
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	261 elseif type(reason) == "table" then
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	262 if reason.condition then
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	263 local stanza = st.stanza("stream:error"):tag(reason.condition, stream_xmlns_attr):up();
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	264 if reason.text then
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	265 stanza:tag("text", stream_xmlns_attr):text(reason.text):up();
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	266 end
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	267 if reason.extra then
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	268 stanza:add_child(reason.extra);
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	269 end
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	270 module:log("info", "Disconnecting component, <stream:error> is: %s", tostring(stanza));
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	271 session.send(stanza);
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	272 elseif reason.name then -- a stanza
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	273 module:log("info", "Disconnecting component, <stream:error> is: %s", tostring(reason));
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	274 session.send(reason);
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	275 end
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	276 end
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	277 end
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	278 session.send("</stream:stream>");
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	279 session.conn:close();
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	280 listener.ondisconnect(session.conn, "stream error");
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	281 end
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	282 end
3581 3f3f8227ba76 mod_component: Updated to use events for hooking stanzas instead of the component stanza handler, and the on_destroy callback. Waqas Hussain <waqas20@gmail.com> parents: 3579 diff changeset	283
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	284 --- Component connlistener
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	285
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	286 function listener.onconnect(conn)
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	287 local _send = conn.write;
4805 1aeece2cc814 mod_component: Components start out as component_unauthed until successful authentication (thanks xnyhps) Matthew Wild <mwild1@gmail.com> parents: 4803 diff changeset	288 local session = { type = "component_unauthed", conn = conn, send = function (data) return _send(conn, tostring(data)); end };
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	289
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	290 -- Logging functions --
5306 10bc0e2aa55e s2smanager: Generate session names used for logging the same way everywhere Kim Alvefur <zash@zash.se> parents: 5298 diff changeset	291 local conn_name = "jcp"..tostring(session):match("[a-f0-9]+$");
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	292 session.log = logger.init(conn_name);
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	293 session.close = session_close;
5953 1c08d6cca552 mod_component: Enable TCP keepalives on component streams Kim Alvefur <zash@zash.se> parents: 5952 diff changeset	294
1c08d6cca552 mod_component: Enable TCP keepalives on component streams Kim Alvefur <zash@zash.se> parents: 5952 diff changeset	295 if opt_keepalives then
1c08d6cca552 mod_component: Enable TCP keepalives on component streams Kim Alvefur <zash@zash.se> parents: 5952 diff changeset	296 conn:setoption("keepalive", opt_keepalives);
1c08d6cca552 mod_component: Enable TCP keepalives on component streams Kim Alvefur <zash@zash.se> parents: 5952 diff changeset	297 end
7873 8d1ebb9a9b44 mod_component: Trim trailing whitespace Kim Alvefur <zash@zash.se> parents: 7665 diff changeset	298
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	299 session.log("info", "Incoming Jabber component connection");
7873 8d1ebb9a9b44 mod_component: Trim trailing whitespace Kim Alvefur <zash@zash.se> parents: 7665 diff changeset	300
11540 1937b3c3efb5 mod_c2s, mod_s2s, mod_component, mod_bosh, mod_websockets: Set default stanza size limits Matthew Wild <mwild1@gmail.com> parents: 9562 diff changeset	301 local stream = new_xmpp_stream(session, stream_callbacks, stanza_size_limit);
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	302 session.stream = stream;
7873 8d1ebb9a9b44 mod_component: Trim trailing whitespace Kim Alvefur <zash@zash.se> parents: 7665 diff changeset	303
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	304 session.notopen = true;
7873 8d1ebb9a9b44 mod_component: Trim trailing whitespace Kim Alvefur <zash@zash.se> parents: 7665 diff changeset	305
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	306 function session.reset_stream()
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	307 session.notopen = true;
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	308 session.stream:reset();
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	309 end
3531 f41e1cfe92f4 mod_component: Updated to use the new events API. Waqas Hussain <waqas20@gmail.com> parents: 3503 diff changeset	310
7301 995777582044 mod_component: Some cleanup [luacheck] Matthew Wild <mwild1@gmail.com> parents: 7300 diff changeset	311 function session.data(_, data)
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	312 local ok, err = stream:feed(data);
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	313 if ok then return; end
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	314 module:log("debug", "Received invalid XML (%s) %d bytes: %s", tostring(err), #data, data:sub(1, 300):gsub("[\r\n]+", " "):gsub("[%z\1-\31]", "_"));
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	315 session:close("not-well-formed");
902 00daf63c129e Add initial mod_component for XEP-0114 support. Albert, where are you? Matthew Wild <mwild1@gmail.com> parents: diff changeset	316 end
7873 8d1ebb9a9b44 mod_component: Trim trailing whitespace Kim Alvefur <zash@zash.se> parents: 7665 diff changeset	317
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	318 session.dispatch_stanza = stream_callbacks.handlestanza;
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	319
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	320 sessions[conn] = session;
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	321 end
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	322 function listener.onincoming(conn, data)
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	323 local session = sessions[conn];
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	324 session.data(conn, data);
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	325 end
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	326 function listener.ondisconnect(conn, err)
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	327 local session = sessions[conn];
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	328 if session then
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	329 (session.log or log)("info", "component disconnected: %s (%s)", tostring(session.host), tostring(err));
7665 2e553f80aedd mod_component: Fire 'component-disconnected' event on host, to maintain consistency - sessions with no host never authenticated. Fixes #737 Matthew Wild <mwild1@gmail.com> parents: 7301 diff changeset	330 if session.host then
2e553f80aedd mod_component: Fire 'component-disconnected' event on host, to maintain consistency - sessions with no host never authenticated. Fixes #737 Matthew Wild <mwild1@gmail.com> parents: 7301 diff changeset	331 module:context(session.host):fire_event("component-disconnected", { session = session, reason = err });
2e553f80aedd mod_component: Fire 'component-disconnected' event on host, to maintain consistency - sessions with no host never authenticated. Fixes #737 Matthew Wild <mwild1@gmail.com> parents: 7301 diff changeset	332 end
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	333 if session.on_destroy then session:on_destroy(err); end
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	334 sessions[conn] = nil;
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	335 for k in pairs(session) do
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	336 if k ~= "log" and k ~= "close" then
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	337 session[k] = nil;
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	338 end
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	339 end
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	340 session.destroyed = true;
902 00daf63c129e Add initial mod_component for XEP-0114 support. Albert, where are you? Matthew Wild <mwild1@gmail.com> parents: diff changeset	341 end
00daf63c129e Add initial mod_component for XEP-0114 support. Albert, where are you? Matthew Wild <mwild1@gmail.com> parents: diff changeset	342 end
00daf63c129e Add initial mod_component for XEP-0114 support. Albert, where are you? Matthew Wild <mwild1@gmail.com> parents: diff changeset	343
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: 5953 diff changeset	344 function listener.ondetach(conn)
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: 5953 diff changeset	345 sessions[conn] = nil;
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: 5953 diff changeset	346 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: 5953 diff changeset	347
7886 679746cdf3cc mod_component: Add read timeout handler (same behaviour as c2s and s2s) Kim Alvefur <zash@zash.se> parents: 7873 diff changeset	348 function listener.onreadtimeout(conn)
679746cdf3cc mod_component: Add read timeout handler (same behaviour as c2s and s2s) Kim Alvefur <zash@zash.se> parents: 7873 diff changeset	349 local session = sessions[conn];
679746cdf3cc mod_component: Add read timeout handler (same behaviour as c2s and s2s) Kim Alvefur <zash@zash.se> parents: 7873 diff changeset	350 if session then
679746cdf3cc mod_component: Add read timeout handler (same behaviour as c2s and s2s) Kim Alvefur <zash@zash.se> parents: 7873 diff changeset	351 return (hosts[session.host] or prosody).events.fire_event("component-read-timeout", { session = session });
679746cdf3cc mod_component: Add read timeout handler (same behaviour as c2s and s2s) Kim Alvefur <zash@zash.se> parents: 7873 diff changeset	352 end
679746cdf3cc mod_component: Add read timeout handler (same behaviour as c2s and s2s) Kim Alvefur <zash@zash.se> parents: 7873 diff changeset	353 end
679746cdf3cc mod_component: Add read timeout handler (same behaviour as c2s and s2s) Kim Alvefur <zash@zash.se> parents: 7873 diff changeset	354
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: 5059 diff changeset	355 module:provides("net", {
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	356 name = "component";
5298 6d34ed9fce69 mod_component: Make listener private (thanks Ge0rG) Kim Alvefur <zash@zash.se> parents: 5120 diff changeset	357 private = true;
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	358 listener = listener;
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	359 default_port = 5347;
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	360 multiplex = {
5316 310c7e5bb906 mod_component: Look for the correct xmlns (thanks NebuK) Kim Alvefur <zash@zash.se> parents: 5306 diff changeset	361 pattern = "^<.:stream.%sxmlns%s=%s(['\"])jabber:component:accept%1.*>";
4650 464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	362 };
464ca74ddf6a mod_component: Make a shared module, and move the xmppcomponent_listener into it ('port'ing over to portmanager). Ha ha. Matthew Wild <mwild1@gmail.com> parents: 4464 diff changeset	363 });

prosody

1937b3c3efb5

plugins/mod_component.lua

Software / code / prosody

Annotate

plugins/mod_component.lua @ 11540:1937b3c3efb5 0.11

Software `/` code `/` prosody