--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/mod_ircd/mod_ircd.lua Wed Dec 23 14:22:02 2009 +0000
@@ -0,0 +1,178 @@
+local irc_listener = { default_port = 6667, default_mode = "*l" };
+
+local sessions = {};
+local commands = {};
+
+local nicks = {};
+
+local st = require "util.stanza";
+
+local conference_server = module:get_option("conference_server") or "conference.jabber.org";
+
+local function irc_close_session(session)
+ session.conn:close();
+end
+
+function irc_listener.onincoming(conn, data)
+ local session = sessions[conn];
+ if not session then
+ session = { conn = conn, host = module.host, reset_stream = function () end,
+ close = irc_close_session, log = logger.init("irc"..(conn.id or "1")),
+ roster = {} };
+ sessions[conn] = session;
+ function session.data(data)
+ module:log("debug", "Received: %s", data);
+ local command, args = data:match("^%s*([^ ]+) *(.*)%s*$");
+ if not command then
+ module:log("warn", "Invalid command: %s", data);
+ return;
+ end
+ command = command:upper();
+ module:log("debug", "Received command: %s", command);
+ if commands[command] then
+ local ret = commands[command](session, args);
+ if ret then
+ session.send(ret.."\r\n");
+ end
+ end
+ end
+ function session.send(data)
+ module:log("debug", "sending: %s", data);
+ return conn:write(data.."\r\n");
+ end
+ end
+ if data then
+ session.data(data);
+ end
+end
+
+function irc_listener.ondisconnect(conn, error)
+ module:log("debug", "Client disconnected");
+ sessions[conn] = nil;
+end
+
+function commands.NICK(session, nick)
+ nick = nick:match("^[%w_]+");
+ if nicks[nick] then
+ session.send(":"..session.host.." 433 * The nickname "..nick.." is already in use");
+ return;
+ end
+ nicks[nick] = session;
+ session.nick = nick;
+ session.full_jid = nick.."@"..module.host.."/ircd";
+ session.type = "c2s";
+ module:log("debug", "Client bound to %s", session.full_jid);
+ session.send(":"..session.host.." 001 "..session.nick.." :Welcome to XMPP via the "..session.host.." gateway "..session.nick);
+end
+
+local joined_mucs = {};
+function commands.JOIN(session, channel)
+ if not joined_mucs[channel] then
+ joined_mucs[channel] = { occupants = {}, sessions = {} };
+ end
+ joined_mucs[channel].sessions[session] = true;
+ local join_stanza = st.presence({ from = session.full_jid, to = channel:gsub("^#", "").."@"..conference_server.."/"..session.nick });
+ core_process_stanza(session, join_stanza);
+ session.send(":"..session.nick.." JOIN :"..channel);
+ session.send(":"..session.host.." 332 "..session.nick.." "..channel.." :Connection in progress...");
+ session.send(":"..session.host.." 353 "..session.nick.." = "..channel.." :"..session.nick);
+ session.send(":"..session.host.." 366 "..session.nick.." "..channel.." :End of /NAMES list.");
+end
+
+function commands.PART(session, channel)
+ local channel, part_message = channel:match("^(%S+) :(.+)$");
+ core_process_stanza(session, st.presence{ type = "unavailable", from = session.full_jid,
+ to = channel:gsub("^#", "").."@"..conference_server.."/"..session.nick }:tag("status"):text(part_message));
+end
+
+function commands.PRIVMSG(session, message)
+ local who, message = message:match("^(%S+) :(.+)$");
+ if joined_mucs[who] then
+ core_process_stanza(session, st.message{to=who:gsub("^#", "").."@"..conference_server, type="groupchat"}:tag("body"):text(message));
+ end
+end
+
+function commands.WHO(session, channel)
+ if joined_mucs[channel] then
+ for nick in pairs(joined_mucs[channel].occupants) do
+ --n=MattJ 91.85.191.50 irc.freenode.net MattJ H :0 Matthew Wild
+ session.send(":"..session.host.." 352 "..session.nick.." "..channel.." "..nick.." "..nick.." "..session.host.." "..nick.." H :0 "..nick);
+ end
+ session.send(":"..session.host.." 315 "..session.nick.." "..channel.. " :End of /WHO list");
+ end
+end
+
+function commands.MODE(session, channel)
+ session.send(":"..session.host.." 324 "..session.nick.." "..channel.." +J");
+end
+
+--- Component (handle stanzas from the server for IRC clients)
+function irc_component(origin, stanza)
+ local from, from_bare = stanza.attr.from, jid.bare(stanza.attr.from);
+ local from_node = "#"..jid.split(stanza.attr.from);
+
+ if joined_mucs[from_node] and from_bare == from then
+ -- From room itself
+ local joined_muc = joined_mucs[from_node];
+ if stanza.name == "message" then
+ local subject = stanza:get_child("subject");
+ if subject then
+ local subject_text = subject:get_text();
+ for session in pairs(joined_muc.sessions) do
+ session.send(":"..session.host.." 332 "..session.nick.." "..from_node.." :"..subject_text);
+ end
+ end
+ end
+ elseif joined_mucs[from_node] then
+ -- From room occupant
+ local joined_muc = joined_mucs[from_node];
+ local nick = select(3, jid.split(from)):gsub(" ", "_");
+ if stanza.name == "presence" then
+ local what;
+ if not stanza.attr.type then
+ if joined_muc.occupants[nick] then
+ return;
+ end
+ joined_muc.occupants[nick] = true;
+ what = "JOIN";
+ else
+ joined_muc.occupants[nick] = nil;
+ what = "PART";
+ end
+ for session in pairs(joined_muc.sessions) do
+ if nick ~= session.nick then
+ session.send(":"..nick.."!"..nick.." "..what.." :"..from_node);
+ end
+ end
+ elseif stanza.name == "message" then
+ local body = stanza:get_child("body");
+ local hasdelay = stanza:get_child("delay", "urn:xmpp:delay");
+ if body then
+ for session in pairs(joined_muc.sessions) do
+ if nick ~= session.nick or hasdelay then
+ session.send(":"..nick.." PRIVMSG "..from_node.." :"..body:get_text());
+ end
+ end
+ end
+ end
+ end
+end
+
+require "core.componentmanager".register_component(module.host, irc_component);
+
+prosody.events.add_handler("server-stopping", function (shutdown)
+ module:log("debug", "Closing IRC connections prior to shutdown");
+ for channel, joined_muc in pairs(joined_mucs) do
+ for session in pairs(joined_muc.sessions) do
+ core_process_stanza(session,
+ st.presence{ type = "unavailable", from = session.full_jid,
+ to = channel:gsub("^#", "").."@"..conference_server.."/"..session.nick }
+ :tag("status")
+ :text("Connection closed: Server is shutting down"..(shutdown.reason and (": "..shutdown.reason) or "")));
+ session:close();
+ end
+ end
+end);
+
+require "net.connlisteners".register("irc", irc_listener);
+require "net.connlisteners".start("irc", { port = module:get_option("port") });