1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
|
pcall(require, "luarocks.require")
local server = require "net.server"
require "lxp"
require "socket"
require "ssl"
function log(type, area, message)
print(type, area, message);
end
dofile "lxmppd.cfg"
-- Maps connections to sessions --
sessions = {};
hosts = {};
if config.hosts and #config.hosts > 0 then
for _, host in pairs(config.hosts) do
hosts[host] = {type = "local", connected = true, sessions = {}};
end
else error("No hosts defined in the configuration file"); end
-- Load and initialise core modules --
require "util.import"
require "core.xmlhandlers"
require "core.rostermanager"
require "core.offlinemessage"
require "core.modulemanager"
require "core.usermanager"
require "core.sessionmanager"
require "core.stanza_router"
local start = require "net.connlisteners".start;
require "util.stanza"
require "util.jid"
------------------------------------------------------------------------
-- Initialise modules
if config.modules and #config.modules > 0 then
for _, module in pairs(config.modules) do
modulemanager.load(module);
end
else error("No modules enabled in the configuration file"); end
-- setup error handling
setmetatable(_G, { __index = function (t, k) print("WARNING: ATTEMPT TO READ A NIL GLOBAL!!!", k); error("Attempt to read a non-existent global. Naughty boy.", 2); end, __newindex = function (t, k, v) print("ATTEMPT TO SET A GLOBAL!!!!", tostring(k).." = "..tostring(v)); error("Attempt to set a global. Naughty boy.", 2); end }) --]][][[]][];
local protected_handler = function (conn, data, err) local success, ret = pcall(handler, conn, data, err); if not success then print("ERROR on "..tostring(conn)..": "..ret); conn:close(); end end;
local protected_disconnect = function (conn, err) local success, ret = pcall(disconnect, conn, err); if not success then print("ERROR on "..tostring(conn).." disconnect: "..ret); conn:close(); end end;
-- start listening on sockets
start("xmppclient", { ssl = config.ssl_ctx })
start("xmppserver", { ssl = config.ssl_ctx })
server.loop();
|
