2 local st = require "util.stanza";
3 local send = require "core.sessionmanager".send_to_session;
4 local sm_bind_resource = require "core.sessionmanager".bind_resource;
6 local usermanager_validate_credentials = require "core.usermanager".validate_credentials;
7 local t_concat, t_insert = table.concat, table.insert;
8 local tostring = tostring;
10 local log = require "util.logger".init("mod_saslauth");
12 local xmlns_sasl ='urn:ietf:params:xml:ns:xmpp-sasl';
13 local xmlns_bind ='urn:ietf:params:xml:ns:xmpp-bind';
14 local xmlns_stanzas ='urn:ietf:params:xml:ns:xmpp-stanzas';
16 local new_sasl = require "util.sasl".new;
18 add_handler("c2s_unauthed", "auth", xmlns_sasl,
19 function (session, stanza)
20 if not session.sasl_handler then
21 session.sasl_handler = new_sasl(stanza.attr.mechanism,
22 function (username, password)
24 require "core.usermanager"
25 if usermanager_validate_credentials(session.host, username, password) then
32 local success, err = sessionmanager.make_authenticated(session, username);
34 sessionmanager.destroy_session(session);
37 session.sasl_handler = nil;
38 session:reset_stream();
42 log("debug", "SASL failure, reason: %s", reason);
46 log("debug", "SASL writes: %s", tostring(stanza));
47 send(session, stanza);
50 session.sasl_handler:feed(stanza);
52 error("Client tried to negotiate SASL again", 0);
57 add_event_hook("stream-features",
58 function (session, features)
59 if not session.username then
60 t_insert(features, "<mechanisms xmlns='urn:ietf:params:xml:ns:xmpp-sasl'>");
61 t_insert(features, "<mechanism>PLAIN</mechanism>");
62 t_insert(features, "</mechanisms>");
64 t_insert(features, "<bind xmlns='urn:ietf:params:xml:ns:xmpp-bind'><required/></bind>");
65 t_insert(features, "<session xmlns='urn:ietf:params:xml:ns:xmpp-session'/>");
67 --send [[<register xmlns="http://jabber.org/features/iq-register"/> ]]
70 add_iq_handler("c2s", "urn:ietf:params:xml:ns:xmpp-bind",
71 function (session, stanza)
72 log("debug", "Client tried to bind to a resource");
74 if stanza.attr.type == "set" then
75 local bind = stanza.tags[1];
77 if bind and bind.attr.xmlns == xmlns_bind then
78 resource = bind:child_with_name("resource");
80 resource = resource[1];
84 local success, err = sm_bind_resource(session, resource);
86 local reply = st.reply(stanza);
87 reply.attr.type = "error";
88 if err == "conflict" then
89 reply:tag("error", { type = "modify" })
90 :tag("conflict", { xmlns = xmlns_stanzas });
91 elseif err == "constraint" then
92 reply:tag("error", { type = "cancel" })
93 :tag("resource-constraint", { xmlns = xmlns_stanzas });
94 elseif err == "auth" then
95 reply:tag("error", { type = "cancel" })
96 :tag("not-allowed", { xmlns = xmlns_stanzas });
100 local reply = st.reply(stanza);
101 reply:tag("bind", { xmlns = xmlns_bind})
102 :tag("jid"):text(session.full_jid);
103 send(session, reply);
107 add_iq_handler("c2s", "urn:ietf:params:xml:ns:xmpp-session",
108 function (session, stanza)
109 log("debug", "Client tried to bind to a resource");
110 send(session, st.reply(stanza));