Software /
code /
prosody
Comparison
net/connlisteners.lua @ 99:ba08b8a4eeef
Abstract connections with "connection listeners"
- Added connlistener for xmppclient
- SASL/TLS now use a new session:reset_stream() method
- main.lua on its way to being a bit neater
author | Matthew Wild <mwild1@gmail.com> |
---|---|
date | Wed, 22 Oct 2008 17:36:21 +0100 |
child | 127:93f3c6b94c75 |
comparison
equal
deleted
inserted
replaced
98:3a2d327c4856 | 99:ba08b8a4eeef |
---|---|
1 | |
2 local server_add = require "net.server".add; | |
3 local log = require "util.logger".init("connlisteners"); | |
4 | |
5 local dofile, pcall, error = | |
6 dofile, pcall, error | |
7 | |
8 module "connlisteners" | |
9 | |
10 local listeners = {}; | |
11 | |
12 function register(name, listener) | |
13 if listeners[name] and listeners[name] ~= listener then | |
14 log("warning", "Listener %s is already registered, not registering any more", name); | |
15 return false; | |
16 end | |
17 listeners[name] = listener; | |
18 log("info", "Registered connection listener %s", name); | |
19 return true; | |
20 end | |
21 | |
22 function deregister(name) | |
23 listeners[name] = nil; | |
24 end | |
25 | |
26 function start(name, udata) | |
27 local h = listeners[name] | |
28 if not h then | |
29 pcall(dofile, "net/"..name:gsub("[^%w%-]", "_").."_listener.lua"); | |
30 h = listeners[name]; | |
31 if not h then | |
32 error("No such connection module: "..name, 0); | |
33 end | |
34 end | |
35 return server_add(h, | |
36 udata.port or h.default_port or error("Can't start listener "..name.." because no port was specified, and it has no default port", 0), | |
37 udata.interface or "*", udata.mode or h.default_mode or 1, udata.ssl ); | |
38 end | |
39 | |
40 return _M; |