Mercurial > prosody-hg

comparison plugins/mod_s2s.lua @ 12977:74b9e05af71e

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
plugins: Prefix module imports with prosody namespace
author Kim Alvefur <zash@zash.se>
date Fri, 24 Mar 2023 13:15:28 +0100
parents ccc0bdad82cc
children 93c68c454cb8
comparison
equal deleted inserted replaced
12976:a187600ec7d6 12977:74b9e05af71e
14 14
15 local tostring, type = tostring, type; 15 local tostring, type = tostring, type;
16 local t_insert = table.insert; 16 local t_insert = table.insert;
17 local traceback = debug.traceback; 17 local traceback = debug.traceback;
18 18
19 local add_task = require "util.timer".add_task; 19 local add_task = require "prosody.util.timer".add_task;
20 local stop_timer = require "util.timer".stop; 20 local stop_timer = require "prosody.util.timer".stop;
21 local st = require "util.stanza"; 21 local st = require "prosody.util.stanza";
22 local initialize_filters = require "util.filters".initialize; 22 local initialize_filters = require "prosody.util.filters".initialize;
23 local nameprep = require "util.encodings".stringprep.nameprep; 23 local nameprep = require "prosody.util.encodings".stringprep.nameprep;
24 local new_xmpp_stream = require "util.xmppstream".new; 24 local new_xmpp_stream = require "prosody.util.xmppstream".new;
25 local s2s_new_incoming = require "core.s2smanager".new_incoming; 25 local s2s_new_incoming = require "prosody.core.s2smanager".new_incoming;
26 local s2s_new_outgoing = require "core.s2smanager".new_outgoing; 26 local s2s_new_outgoing = require "prosody.core.s2smanager".new_outgoing;
27 local s2s_destroy_session = require "core.s2smanager".destroy_session; 27 local s2s_destroy_session = require "prosody.core.s2smanager".destroy_session;
28 local uuid_gen = require "util.uuid".generate; 28 local uuid_gen = require "prosody.util.uuid".generate;
29 local async = require "util.async"; 29 local async = require "prosody.util.async";
30 local runner = async.runner; 30 local runner = async.runner;
31 local connect = require "net.connect".connect; 31 local connect = require "prosody.net.connect".connect;
32 local service = require "net.resolvers.service"; 32 local service = require "prosody.net.resolvers.service";
33 local resolver_chain = require "net.resolvers.chain"; 33 local resolver_chain = require "prosody.net.resolvers.chain";
34 local errors = require "util.error"; 34 local errors = require "prosody.util.error";
35 local set = require "util.set"; 35 local set = require "prosody.util.set";
36 36
37 local connect_timeout = module:get_option_number("s2s_timeout", 90); 37 local connect_timeout = module:get_option_number("s2s_timeout", 90);
38 local stream_close_timeout = module:get_option_number("s2s_close_timeout", 5); 38 local stream_close_timeout = module:get_option_number("s2s_close_timeout", 5);
39 local opt_keepalives = module:get_option_boolean("s2s_tcp_keepalives", module:get_option_boolean("tcp_keepalives", true)); 39 local opt_keepalives = module:get_option_boolean("s2s_tcp_keepalives", module:get_option_boolean("tcp_keepalives", true));
40 local secure_auth = module:get_option_boolean("s2s_secure_auth", false); -- One day... 40 local secure_auth = module:get_option_boolean("s2s_secure_auth", false); -- One day...
1005 1005
1006 module:hook("s2s-check-certificate", check_auth_policy, -1); 1006 module:hook("s2s-check-certificate", check_auth_policy, -1);
1007 1007
1008 module:hook("server-stopping", function(event) 1008 module:hook("server-stopping", function(event)
1009 -- Close ports 1009 -- Close ports
1010 local pm = require "core.portmanager"; 1010 local pm = require "prosody.core.portmanager";
1011 for _, netservice in pairs(module.items["net-provider"]) do 1011 for _, netservice in pairs(module.items["net-provider"]) do
1012 pm.unregister_service(netservice.name, netservice); 1012 pm.unregister_service(netservice.name, netservice);
1013 end 1013 end
1014 1014
1015 -- Stop opening new connections 1015 -- Stop opening new connections