diff options
Diffstat (limited to 'src/mod_irc_connection.erl')
| -rw-r--r-- | src/mod_irc_connection.erl | 1582 |
1 files changed, 1582 insertions, 0 deletions
diff --git a/src/mod_irc_connection.erl b/src/mod_irc_connection.erl new file mode 100644 index 000000000..c37ca7cb4 --- /dev/null +++ b/src/mod_irc_connection.erl @@ -0,0 +1,1582 @@ +%%%---------------------------------------------------------------------- +%%% File : mod_irc_connection.erl +%%% Author : Alexey Shchepin <alexey@process-one.net> +%%% Purpose : +%%% Created : 15 Feb 2003 by Alexey Shchepin <alexey@process-one.net> +%%% +%%% +%%% ejabberd, Copyright (C) 2002-2013 ProcessOne +%%% +%%% This program is free software; you can redistribute it and/or +%%% modify it under the terms of the GNU General Public License as +%%% published by the Free Software Foundation; either version 2 of the +%%% License, or (at your option) any later version. +%%% +%%% This program is distributed in the hope that it will be useful, +%%% but WITHOUT ANY WARRANTY; without even the implied warranty of +%%% MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU +%%% General Public License for more details. +%%% +%%% You should have received a copy of the GNU General Public License +%%% along with this program; if not, write to the Free Software +%%% Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA +%%% 02111-1307 USA +%%% +%%%---------------------------------------------------------------------- + +-module(mod_irc_connection). + +-author('alexey@process-one.net'). + +-behaviour(gen_fsm). + +%% External exports +-export([start_link/8, start/9, route_chan/4, + route_nick/3]). + +%% gen_fsm callbacks +-export([init/1, open_socket/2, wait_for_registration/2, + stream_established/2, handle_event/3, + handle_sync_event/4, handle_info/3, terminate/3, + code_change/4]). + +-include("ejabberd.hrl"). +-include("logger.hrl"). + +-include("jlib.hrl"). + +-define(SETS, gb_sets). + +-record(state, + {socket :: inet:socket(), + encoding = <<"">> :: binary(), + port = 0 :: inet:port_number(), + password = <<"">> :: binary(), + queue = queue:new() :: queue(), + user = #jid{} :: jid(), + host = <<"">> :: binary(), + server = <<"">> :: binary(), + nick = <<"">> :: binary(), + channels = dict:new() :: dict(), + nickchannel :: binary(), + mod = mod_irc :: atom(), + inbuf = <<"">> :: binary(), + outbuf = <<"">> :: binary()}). + +%-define(DBGFSM, true). + +-ifdef(DBGFSM). + +-define(FSMOPTS, [{debug, [trace]}]). + +-else. + +-define(FSMOPTS, []). + +%%%---------------------------------------------------------------------- +%%% API +%%%---------------------------------------------------------------------- +-endif. + +start(From, Host, ServerHost, Server, Username, + Encoding, Port, Password, Mod) -> + Supervisor = gen_mod:get_module_proc(ServerHost, + ejabberd_mod_irc_sup), + supervisor:start_child(Supervisor, + [From, Host, Server, Username, Encoding, Port, + Password, Mod]). + +start_link(From, Host, Server, Username, Encoding, Port, + Password, Mod) -> + gen_fsm:start_link(?MODULE, + [From, Host, Server, Username, Encoding, Port, Password, + Mod], + ?FSMOPTS). + +%%%---------------------------------------------------------------------- +%%% Callback functions from gen_fsm +%%%---------------------------------------------------------------------- + +%%---------------------------------------------------------------------- +%% Func: init/1 +%% Returns: {ok, StateName, StateData} | +%% {ok, StateName, StateData, Timeout} | +%% ignore | +%% {stop, StopReason} +%%---------------------------------------------------------------------- +init([From, Host, Server, Username, Encoding, Port, + Password, Mod]) -> + gen_fsm:send_event(self(), init), + {ok, open_socket, + #state{queue = queue:new(), mod = Mod, + encoding = Encoding, port = Port, password = Password, + user = From, nick = Username, host = Host, + server = Server}}. + +%%---------------------------------------------------------------------- +%% Func: StateName/2 +%% Returns: {next_state, NextStateName, NextStateData} | +%% {next_state, NextStateName, NextStateData, Timeout} | +%% {stop, Reason, NewStateData} +%%---------------------------------------------------------------------- +open_socket(init, StateData) -> + Addr = StateData#state.server, + Port = StateData#state.port, + ?DEBUG("Connecting with IPv6 to ~s:~p", [Addr, Port]), + Connect6 = gen_tcp:connect(binary_to_list(Addr), Port, + [inet6, binary, {packet, 0}]), + Connect = case Connect6 of + {error, _} -> + ?DEBUG("Connection with IPv6 to ~s:~p failed. " + "Now using IPv4.", + [Addr, Port]), + gen_tcp:connect(binary_to_list(Addr), Port, + [inet, binary, {packet, 0}]); + _ -> Connect6 + end, + case Connect of + {ok, Socket} -> + NewStateData = StateData#state{socket = Socket}, + if StateData#state.password /= <<"">> -> + send_text(NewStateData, + io_lib:format("PASS ~s\r\n", + [StateData#state.password])); + true -> true + end, + send_text(NewStateData, + io_lib:format("NICK ~s\r\n", [StateData#state.nick])), + send_text(NewStateData, + io_lib:format("USER ~s ~s ~s :~s\r\n", + [StateData#state.nick, StateData#state.nick, + StateData#state.host, + StateData#state.nick])), + {next_state, wait_for_registration, NewStateData}; + {error, Reason} -> + ?DEBUG("connect return ~p~n", [Reason]), + Text = case Reason of + timeout -> <<"Server Connect Timeout">>; + _ -> <<"Server Connect Failed">> + end, + bounce_messages(Text), + {stop, normal, StateData} + end. + +wait_for_registration(closed, StateData) -> + {stop, normal, StateData}. + +stream_established({xmlstreamend, _Name}, StateData) -> + {stop, normal, StateData}; +stream_established(timeout, StateData) -> + {stop, normal, StateData}; +stream_established(closed, StateData) -> + {stop, normal, StateData}. + +%%---------------------------------------------------------------------- +%% Func: StateName/3 +%% Returns: {next_state, NextStateName, NextStateData} | +%% {next_state, NextStateName, NextStateData, Timeout} | +%% {reply, Reply, NextStateName, NextStateData} | +%% {reply, Reply, NextStateName, NextStateData, Timeout} | +%% {stop, Reason, NewStateData} | +%% {stop, Reason, Reply, NewStateData} +%%---------------------------------------------------------------------- +%state_name(Event, From, StateData) -> +% Reply = ok, +% {reply, Reply, state_name, StateData}. + +%%---------------------------------------------------------------------- +%% Func: handle_event/3 +%% Returns: {next_state, NextStateName, NextStateData} | +%% {next_state, NextStateName, NextStateData, Timeout} | +%% {stop, Reason, NewStateData} +%%---------------------------------------------------------------------- +handle_event(_Event, StateName, StateData) -> + {next_state, StateName, StateData}. + +%%---------------------------------------------------------------------- +%% Func: handle_sync_event/4 +%% Returns: {next_state, NextStateName, NextStateData} | +%% {next_state, NextStateName, NextStateData, Timeout} | +%% {reply, Reply, NextStateName, NextStateData} | +%% {reply, Reply, NextStateName, NextStateData, Timeout} | +%% {stop, Reason, NewStateData} | +%% {stop, Reason, Reply, NewStateData} +%%---------------------------------------------------------------------- +handle_sync_event(_Event, _From, StateName, + StateData) -> + Reply = ok, {reply, Reply, StateName, StateData}. + +code_change(_OldVsn, StateName, StateData, _Extra) -> + {ok, StateName, StateData}. + +-define(SEND(S), + if StateName == stream_established -> + send_text(StateData, S), StateData; + true -> + StateData#state{outbuf = <<(StateData#state.outbuf)/binary, + (iolist_to_binary(S))/binary>>} + end). + +get_password_from_presence(#xmlel{name = <<"presence">>, + children = Els}) -> + case lists:filter(fun (El) -> + case El of + #xmlel{name = <<"x">>, attrs = Attrs} -> + case xml:get_attr_s(<<"xmlns">>, Attrs) of + ?NS_MUC -> true; + _ -> false + end; + _ -> false + end + end, + Els) + of + [ElXMUC | _] -> + case xml:get_subtag(ElXMUC, <<"password">>) of + #xmlel{name = <<"password">>} = PasswordTag -> + {true, xml:get_tag_cdata(PasswordTag)}; + _ -> false + end; + _ -> false + end. + +%%---------------------------------------------------------------------- +%% Func: handle_info/3 +%% Returns: {next_state, NextStateName, NextStateData} | +%% {next_state, NextStateName, NextStateData, Timeout} | +%% {stop, Reason, NewStateData} +%%---------------------------------------------------------------------- +handle_info({route_chan, Channel, Resource, + #xmlel{name = <<"presence">>, attrs = Attrs} = + Presence}, + StateName, StateData) -> + NewStateData = case xml:get_attr_s(<<"type">>, Attrs) of + <<"unavailable">> -> + send_stanza_unavailable(Channel, StateData), + S1 = (?SEND((io_lib:format("PART #~s\r\n", + [Channel])))), + S1#state{channels = + dict:erase(Channel, S1#state.channels)}; + <<"subscribe">> -> StateData; + <<"subscribed">> -> StateData; + <<"unsubscribe">> -> StateData; + <<"unsubscribed">> -> StateData; + <<"error">> -> stop; + _ -> + Nick = case Resource of + <<"">> -> StateData#state.nick; + _ -> Resource + end, + S1 = if Nick /= StateData#state.nick -> + S11 = (?SEND((io_lib:format("NICK ~s\r\n", + [Nick])))), + S11#state{nickchannel = Channel}; + true -> StateData + end, + case dict:is_key(Channel, S1#state.channels) of + true -> S1; + _ -> + case get_password_from_presence(Presence) of + {true, Password} -> + S2 = + (?SEND((io_lib:format("JOIN #~s ~s\r\n", + [Channel, + Password])))); + _ -> + S2 = (?SEND((io_lib:format("JOIN #~s\r\n", + [Channel])))) + end, + S2#state{channels = + dict:store(Channel, (?SETS):new(), + S1#state.channels)} + end + end, + if NewStateData == stop -> {stop, normal, StateData}; + true -> + case dict:fetch_keys(NewStateData#state.channels) of + [] -> {stop, normal, NewStateData}; + _ -> {next_state, StateName, NewStateData} + end + end; +handle_info({route_chan, Channel, Resource, + #xmlel{name = <<"message">>, attrs = Attrs} = El}, + StateName, StateData) -> + NewStateData = case xml:get_attr_s(<<"type">>, Attrs) of + <<"groupchat">> -> + case xml:get_path_s(El, [{elem, <<"subject">>}, cdata]) + of + <<"">> -> + ejabberd_router:route( + jlib:make_jid( + iolist_to_binary([Channel, + <<"%">>, + StateData#state.server]), + StateData#state.host, + StateData#state.nick), + StateData#state.user, El), + Body = xml:get_path_s(El, + [{elem, <<"body">>}, + cdata]), + case Body of + <<"/quote ", Rest/binary>> -> + ?SEND(<<Rest/binary, "\r\n">>); + <<"/msg ", Rest/binary>> -> + ?SEND(<<"PRIVMSG ", Rest/binary, "\r\n">>); + <<"/me ", Rest/binary>> -> + Strings = str:tokens(Rest, <<"\n">>), + Res = iolist_to_binary( + lists:map( + fun (S) -> + io_lib:format( + "PRIVMSG #~s :\001ACTION ~s\001\r\n", + [Channel, S]) + end, + Strings)), + ?SEND(Res); + <<"/ctcp ", Rest/binary>> -> + Words = str:tokens(Rest, <<" ">>), + case Words of + [CtcpDest | _] -> + CtcpCmd = str:to_upper( + str:substr(Rest, + str:str(Rest, + <<" ">>) + + 1)), + Res = + io_lib:format("PRIVMSG ~s :\001~s\001\r\n", + [CtcpDest, + CtcpCmd]), + ?SEND(Res); + _ -> ok + end; + _ -> + Strings = str:tokens(Body, <<"\n">>), + Res = iolist_to_binary( + lists:map( + fun (S) -> + io_lib:format("PRIVMSG #~s :~s\r\n", + [Channel, S]) + end, + Strings)), + ?SEND(Res) + end; + Subject -> + Strings = str:tokens(Subject, <<"\n">>), + Res = iolist_to_binary( + lists:map( + fun (S) -> + io_lib:format("TOPIC #~s :~s\r\n", + [Channel, S]) + end, + Strings)), + ?SEND(Res) + end; + Type + when Type == <<"chat">>; + Type == <<"">>; + Type == <<"normal">> -> + Body = xml:get_path_s(El, [{elem, <<"body">>}, cdata]), + case Body of + <<"/quote ", Rest/binary>> -> + ?SEND(<<Rest/binary, "\r\n">>); + <<"/msg ", Rest/binary>> -> + ?SEND(<<"PRIVMSG ", Rest/binary, "\r\n">>); + <<"/me ", Rest/binary>> -> + Strings = str:tokens(Rest, <<"\n">>), + Res = iolist_to_binary( + lists:map( + fun (S) -> + io_lib:format( + "PRIVMSG ~s :\001ACTION ~s\001\r\n", + [Resource, S]) + end, + Strings)), + ?SEND(Res); + <<"/ctcp ", Rest/binary>> -> + Words = str:tokens(Rest, <<" ">>), + case Words of + [CtcpDest | _] -> + CtcpCmd = str:to_upper( + str:substr(Rest, + str:str(Rest, + <<" ">>) + + 1)), + Res = io_lib:format("PRIVMSG ~s :~s\r\n", + [CtcpDest, + <<"\001", + CtcpCmd/binary, + "\001">>]), + ?SEND(Res); + _ -> ok + end; + _ -> + Strings = str:tokens(Body, <<"\n">>), + Res = iolist_to_binary( + lists:map( + fun (S) -> + io_lib:format( + "PRIVMSG ~s :~s\r\n", + [Resource, S]) + end, + Strings)), + ?SEND(Res) + end; + <<"error">> -> stop; + _ -> StateData + end, + if NewStateData == stop -> {stop, normal, StateData}; + true -> {next_state, StateName, NewStateData} + end; +handle_info({route_chan, Channel, Resource, + #xmlel{name = <<"iq">>} = El}, + StateName, StateData) -> + From = StateData#state.user, + To = jlib:make_jid(iolist_to_binary([Channel, <<"%">>, + StateData#state.server]), + StateData#state.host, StateData#state.nick), + _ = case jlib:iq_query_info(El) of + #iq{xmlns = ?NS_MUC_ADMIN} = IQ -> + iq_admin(StateData, Channel, From, To, IQ); + #iq{xmlns = ?NS_VERSION} -> + Res = io_lib:format("PRIVMSG ~s :\001VERSION\001\r\n", + [Resource]), + _ = (?SEND(Res)), + Err = jlib:make_error_reply(El, + ?ERR_FEATURE_NOT_IMPLEMENTED), + ejabberd_router:route(To, From, Err); + #iq{xmlns = ?NS_TIME} -> + Res = io_lib:format("PRIVMSG ~s :\001TIME\001\r\n", + [Resource]), + _ = (?SEND(Res)), + Err = jlib:make_error_reply(El, + ?ERR_FEATURE_NOT_IMPLEMENTED), + ejabberd_router:route(To, From, Err); + #iq{xmlns = ?NS_VCARD} -> + Res = io_lib:format("WHOIS ~s \r\n", [Resource]), + _ = (?SEND(Res)), + Err = jlib:make_error_reply(El, + ?ERR_FEATURE_NOT_IMPLEMENTED), + ejabberd_router:route(To, From, Err); + #iq{} -> + Err = jlib:make_error_reply(El, + ?ERR_FEATURE_NOT_IMPLEMENTED), + ejabberd_router:route(To, From, Err); + _ -> ok + end, + {next_state, StateName, StateData}; +handle_info({route_chan, _Channel, _Resource, _Packet}, + StateName, StateData) -> + {next_state, StateName, StateData}; +handle_info({route_nick, Nick, + #xmlel{name = <<"message">>, attrs = Attrs} = El}, + StateName, StateData) -> + NewStateData = case xml:get_attr_s(<<"type">>, Attrs) of + <<"chat">> -> + Body = xml:get_path_s(El, [{elem, <<"body">>}, cdata]), + case Body of + <<"/quote ", Rest/binary>> -> + ?SEND(<<Rest/binary, "\r\n">>); + <<"/msg ", Rest/binary>> -> + ?SEND(<<"PRIVMSG ", Rest/binary, "\r\n">>); + <<"/me ", Rest/binary>> -> + Strings = str:tokens(Rest, <<"\n">>), + Res = iolist_to_binary( + lists:map( + fun (S) -> + io_lib:format( + "PRIVMSG ~s :\001ACTION ~s\001\r\n", + [Nick, S]) + end, + Strings)), + ?SEND(Res); + <<"/ctcp ", Rest/binary>> -> + Words = str:tokens(Rest, <<" ">>), + case Words of + [CtcpDest | _] -> + CtcpCmd = str:to_upper( + str:substr(Rest, + str:str(Rest, + <<" ">>) + + 1)), + Res = io_lib:format("PRIVMSG ~s :~s\r\n", + [CtcpDest, + <<"\001", + CtcpCmd/binary, + "\001">>]), + ?SEND(Res); + _ -> ok + end; + _ -> + Strings = str:tokens(Body, <<"\n">>), + Res = iolist_to_binary( + lists:map( + fun (S) -> + io_lib:format( + "PRIVMSG ~s :~s\r\n", + [Nick, S]) + end, + Strings)), + ?SEND(Res) + end; + <<"error">> -> stop; + _ -> StateData + end, + if NewStateData == stop -> {stop, normal, StateData}; + true -> {next_state, StateName, NewStateData} + end; +handle_info({route_nick, _Nick, _Packet}, StateName, + StateData) -> + {next_state, StateName, StateData}; +handle_info({ircstring, + <<$P, $I, $N, $G, $\s, ID/binary>>}, + StateName, StateData) -> + send_text(StateData, <<"PONG ", ID/binary, "\r\n">>), + {next_state, StateName, StateData}; +handle_info({ircstring, <<$:, String/binary>>}, + wait_for_registration, StateData) -> + Words = str:tokens(String, <<" ">>), + {NewState, NewStateData} = case Words of + [_, <<"001">> | _] -> + send_text(StateData, + io_lib:format("CODEPAGE ~s\r\n", + [StateData#state.encoding])), + {stream_established, StateData}; + [_, <<"433">> | _] -> + {error, + {error, + error_nick_in_use(StateData, String), + StateData}}; + [_, <<$4, _, _>> | _] -> + {error, + {error, + error_unknown_num(StateData, String, + <<"cancel">>), + StateData}}; + [_, <<$5, _, _>> | _] -> + {error, + {error, + error_unknown_num(StateData, String, + <<"cancel">>), + StateData}}; + _ -> + ?DEBUG("unknown irc command '~s'~n", + [String]), + {wait_for_registration, StateData} + end, + if NewState == error -> {stop, normal, NewStateData}; + true -> {next_state, NewState, NewStateData} + end; +handle_info({ircstring, <<$:, String/binary>>}, + _StateName, StateData) -> + Words = str:tokens(String, <<" ">>), + NewStateData = case Words of + [_, <<"353">> | Items] -> + process_channel_list(StateData, Items); + [_, <<"332">>, _Nick, <<$#, Chan/binary>> | _] -> + process_channel_topic(StateData, Chan, String), + StateData; + [_, <<"333">>, _Nick, <<$#, Chan/binary>> | _] -> + process_channel_topic_who(StateData, Chan, String), + StateData; + [_, <<"318">>, _, Nick | _] -> + process_endofwhois(StateData, String, Nick), StateData; + [_, <<"311">>, _, Nick, Ident, Irchost | _] -> + process_whois311(StateData, String, Nick, Ident, + Irchost), + StateData; + [_, <<"312">>, _, Nick, Ircserver | _] -> + process_whois312(StateData, String, Nick, Ircserver), + StateData; + [_, <<"319">>, _, Nick | _] -> + process_whois319(StateData, String, Nick), StateData; + [_, <<"433">> | _] -> + process_nick_in_use(StateData, String); + % CODEPAGE isn't standard, so don't complain if it's not there. + [_, <<"421">>, _, <<"CODEPAGE">> | _] -> StateData; + [_, <<$4, _, _>> | _] -> + process_num_error(StateData, String); + [_, <<$5, _, _>> | _] -> + process_num_error(StateData, String); + [From, <<"PRIVMSG">>, <<$#, Chan/binary>> | _] -> + process_chanprivmsg(StateData, Chan, From, String), + StateData; + [From, <<"NOTICE">>, <<$#, Chan/binary>> | _] -> + process_channotice(StateData, Chan, From, String), + StateData; + [From, <<"PRIVMSG">>, Nick, <<":\001VERSION\001">> + | _] -> + process_version(StateData, Nick, From), StateData; + [From, <<"PRIVMSG">>, Nick, <<":\001USERINFO\001">> + | _] -> + process_userinfo(StateData, Nick, From), StateData; + [From, <<"PRIVMSG">>, Nick | _] -> + process_privmsg(StateData, Nick, From, String), + StateData; + [From, <<"NOTICE">>, Nick | _] -> + process_notice(StateData, Nick, From, String), + StateData; + [From, <<"TOPIC">>, <<$#, Chan/binary>> | _] -> + process_topic(StateData, Chan, From, String), + StateData; + [From, <<"PART">>, <<$#, Chan/binary>> | _] -> + process_part(StateData, Chan, From, String); + [From, <<"QUIT">> | _] -> + process_quit(StateData, From, String); + [From, <<"JOIN">>, Chan | _] -> + process_join(StateData, Chan, From, String); + [From, <<"MODE">>, <<$#, Chan/binary>>, <<"+o">>, Nick + | _] -> + process_mode_o(StateData, Chan, From, Nick, + <<"admin">>, <<"moderator">>), + StateData; + [From, <<"MODE">>, <<$#, Chan/binary>>, <<"-o">>, Nick + | _] -> + process_mode_o(StateData, Chan, From, Nick, + <<"member">>, <<"participant">>), + StateData; + [From, <<"KICK">>, <<$#, Chan/binary>>, Nick | _] -> + process_kick(StateData, Chan, From, Nick, String), + StateData; + [From, <<"NICK">>, Nick | _] -> + process_nick(StateData, From, Nick); + _ -> + ?DEBUG("unknown irc command '~s'~n", [String]), + StateData + end, + NewStateData1 = case StateData#state.outbuf of + <<"">> -> NewStateData; + Data -> + send_text(NewStateData, Data), + NewStateData#state{outbuf = <<"">>} + end, + {next_state, stream_established, NewStateData1}; +handle_info({ircstring, + <<$E, $R, $R, $O, $R, _/binary>> = String}, + StateName, StateData) -> + process_error(StateData, String), + {next_state, StateName, StateData}; +handle_info({ircstring, String}, StateName, + StateData) -> + ?DEBUG("unknown irc command '~s'~n", [String]), + {next_state, StateName, StateData}; +handle_info({send_text, Text}, StateName, StateData) -> + send_text(StateData, Text), + {next_state, StateName, StateData}; +handle_info({tcp, _Socket, Data}, StateName, + StateData) -> + Buf = <<(StateData#state.inbuf)/binary, Data/binary>>, + Strings = ejabberd_regexp:split(<< <<C>> + || <<C>> <= Buf, C /= $\r >>, + <<"\n">>), + ?DEBUG("strings=~p~n", [Strings]), + NewBuf = process_lines(StateData#state.encoding, + Strings), + {next_state, StateName, + StateData#state{inbuf = NewBuf}}; +handle_info({tcp_closed, _Socket}, StateName, + StateData) -> + gen_fsm:send_event(self(), closed), + {next_state, StateName, StateData}; +handle_info({tcp_error, _Socket, _Reason}, StateName, + StateData) -> + gen_fsm:send_event(self(), closed), + {next_state, StateName, StateData}. + +%%---------------------------------------------------------------------- +%% Func: terminate/3 +%% Purpose: Shutdown the fsm +%% Returns: any +%%---------------------------------------------------------------------- +terminate(_Reason, _StateName, FullStateData) -> + {Error, StateData} = case FullStateData of + {error, SError, SStateData} -> {SError, SStateData}; + _ -> + {#xmlel{name = <<"error">>, + attrs = [{<<"code">>, <<"502">>}], + children = + [{xmlcdata, + <<"Server Connect Failed">>}]}, + FullStateData} + end, + (FullStateData#state.mod):closed_connection(StateData#state.host, + StateData#state.user, + StateData#state.server), + bounce_messages(<<"Server Connect Failed">>), + lists:foreach(fun (Chan) -> + Stanza = #xmlel{name = <<"presence">>, + attrs = [{<<"type">>, <<"error">>}], + children = [Error]}, + send_stanza(Chan, StateData, Stanza) + end, + dict:fetch_keys(StateData#state.channels)), + case StateData#state.socket of + undefined -> ok; + Socket -> gen_tcp:close(Socket) + end, + ok. + +send_stanza(Chan, StateData, Stanza) -> + ejabberd_router:route( + jlib:make_jid( + iolist_to_binary([Chan, + <<"%">>, + StateData#state.server]), + StateData#state.host, + StateData#state.nick), + StateData#state.user, Stanza). + +send_stanza_unavailable(Chan, StateData) -> + Affiliation = <<"member">>, + Role = <<"none">>, + Stanza = #xmlel{name = <<"presence">>, + attrs = [{<<"type">>, <<"unavailable">>}], + children = + [#xmlel{name = <<"x">>, + attrs = [{<<"xmlns">>, ?NS_MUC_USER}], + children = + [#xmlel{name = <<"item">>, + attrs = + [{<<"affiliation">>, + Affiliation}, + {<<"role">>, Role}], + children = []}, + #xmlel{name = <<"status">>, + attrs = [{<<"code">>, <<"110">>}], + children = []}]}]}, + send_stanza(Chan, StateData, Stanza). + +%%%---------------------------------------------------------------------- +%%% Internal functions +%%%---------------------------------------------------------------------- + +send_text(#state{socket = Socket, encoding = Encoding}, + Text) -> + CText = iconv:convert(<<"utf-8">>, Encoding, iolist_to_binary(Text)), + gen_tcp:send(Socket, CText). + +%send_queue(Socket, Q) -> +% case queue:out(Q) of +% {{value, El}, Q1} -> +% send_element(Socket, El), +% send_queue(Socket, Q1); +% {empty, Q1} -> +% ok +% end. + +bounce_messages(Reason) -> + receive + {send_element, El} -> + #xmlel{attrs = Attrs} = El, + case xml:get_attr_s(<<"type">>, Attrs) of + <<"error">> -> ok; + _ -> + Err = jlib:make_error_reply(El, <<"502">>, Reason), + From = jlib:string_to_jid(xml:get_attr_s(<<"from">>, + Attrs)), + To = jlib:string_to_jid(xml:get_attr_s(<<"to">>, + Attrs)), + ejabberd_router:route(To, From, Err) + end, + bounce_messages(Reason) + after 0 -> ok + end. + +route_chan(Pid, Channel, Resource, Packet) -> + Pid ! {route_chan, Channel, Resource, Packet}. + +route_nick(Pid, Nick, Packet) -> + Pid ! {route_nick, Nick, Packet}. + +process_lines(_Encoding, [S]) -> S; +process_lines(Encoding, [S | Ss]) -> + self() ! + {ircstring, iconv:convert(Encoding, <<"utf-8">>, S)}, + process_lines(Encoding, Ss). + +process_channel_list(StateData, Items) -> + process_channel_list_find_chan(StateData, Items). + +process_channel_list_find_chan(StateData, []) -> + StateData; +process_channel_list_find_chan(StateData, + [<<$#, Chan/binary>> | Items]) -> + process_channel_list_users(StateData, Chan, Items); +process_channel_list_find_chan(StateData, + [_ | Items]) -> + process_channel_list_find_chan(StateData, Items). + +process_channel_list_users(StateData, _Chan, []) -> + StateData; +process_channel_list_users(StateData, Chan, + [User | Items]) -> + NewStateData = process_channel_list_user(StateData, + Chan, User), + process_channel_list_users(NewStateData, Chan, Items). + +process_channel_list_user(StateData, Chan, User) -> + User1 = case User of + <<$:, U1/binary>> -> U1; + _ -> User + end, + {User2, Affiliation, Role} = case User1 of + <<$@, U2/binary>> -> + {U2, <<"admin">>, <<"moderator">>}; + <<$+, U2/binary>> -> + {U2, <<"member">>, <<"participant">>}; + <<$%, U2/binary>> -> + {U2, <<"admin">>, <<"moderator">>}; + <<$&, U2/binary>> -> + {U2, <<"admin">>, <<"moderator">>}; + <<$~, U2/binary>> -> + {U2, <<"admin">>, <<"moderator">>}; + _ -> {User1, <<"member">>, <<"participant">>} + end, + ejabberd_router:route(jlib:make_jid(iolist_to_binary([Chan, + <<"%">>, + StateData#state.server]), + StateData#state.host, User2), + StateData#state.user, + #xmlel{name = <<"presence">>, attrs = [], + children = + [#xmlel{name = <<"x">>, + attrs = + [{<<"xmlns">>, ?NS_MUC_USER}], + children = + [#xmlel{name = <<"item">>, + attrs = + [{<<"affiliation">>, + Affiliation}, + {<<"role">>, + Role}], + children = []}]}]}), + case catch dict:update(Chan, + fun (Ps) -> (?SETS):add_element(User2, Ps) end, + StateData#state.channels) + of + {'EXIT', _} -> StateData; + NS -> StateData#state{channels = NS} + end. + +process_channel_topic(StateData, Chan, String) -> + Msg = ejabberd_regexp:replace(String, <<".*332[^:]*:">>, + <<"">>), + Msg1 = filter_message(Msg), + ejabberd_router:route(jlib:make_jid(iolist_to_binary([Chan, + <<"%">>, + StateData#state.server]), + StateData#state.host, <<"">>), + StateData#state.user, + #xmlel{name = <<"message">>, + attrs = [{<<"type">>, <<"groupchat">>}], + children = + [#xmlel{name = <<"subject">>, attrs = [], + children = [{xmlcdata, Msg1}]}, + #xmlel{name = <<"body">>, attrs = [], + children = + [{xmlcdata, + <<"Topic for #", Chan/binary, + ": ", Msg1/binary>>}]}]}). + +process_channel_topic_who(StateData, Chan, String) -> + Words = str:tokens(String, <<" ">>), + Msg1 = case Words of + [_, <<"333">>, _, _Chan, Whoset, Timeset] -> + {Unixtimeset, _Rest} = str:to_integer(Timeset), + <<"Topic for #", Chan/binary, " set by ", Whoset/binary, + " at ", (unixtime2string(Unixtimeset))/binary>>; + [_, <<"333">>, _, _Chan, Whoset | _] -> + <<"Topic for #", Chan/binary, " set by ", + Whoset/binary>>; + _ -> String + end, + Msg2 = filter_message(Msg1), + ejabberd_router:route(jlib:make_jid(iolist_to_binary([Chan, + <<"%">>, + StateData#state.server]), + StateData#state.host, <<"">>), + StateData#state.user, + #xmlel{name = <<"message">>, + attrs = [{<<"type">>, <<"groupchat">>}], + children = + [#xmlel{name = <<"body">>, attrs = [], + children = [{xmlcdata, Msg2}]}]}). + +error_nick_in_use(_StateData, String) -> + Msg = ejabberd_regexp:replace(String, + <<".*433 +[^ ]* +">>, <<"">>), + Msg1 = filter_message(Msg), + #xmlel{name = <<"error">>, + attrs = + [{<<"code">>, <<"409">>}, {<<"type">>, <<"cancel">>}], + children = + [#xmlel{name = <<"conflict">>, + attrs = [{<<"xmlns">>, ?NS_STANZAS}], children = []}, + #xmlel{name = <<"text">>, + attrs = [{<<"xmlns">>, ?NS_STANZAS}], + children = [{xmlcdata, Msg1}]}]}. + +process_nick_in_use(StateData, String) -> + Error = error_nick_in_use(StateData, String), + case StateData#state.nickchannel of + undefined -> + % Shouldn't happen with a well behaved server + StateData; + Chan -> + ejabberd_router:route(jlib:make_jid(iolist_to_binary([Chan, + <<"%">>, + StateData#state.server]), + StateData#state.host, + StateData#state.nick), + StateData#state.user, + #xmlel{name = <<"presence">>, + attrs = [{<<"type">>, <<"error">>}], + children = [Error]}), + StateData#state{nickchannel = undefined} + end. + +process_num_error(StateData, String) -> + Error = error_unknown_num(StateData, String, + <<"continue">>), + lists:foreach(fun (Chan) -> + ejabberd_router:route( + jlib:make_jid( + iolist_to_binary( + [Chan, + <<"%">>, + StateData#state.server]), + StateData#state.host, + StateData#state.nick), + StateData#state.user, + #xmlel{name = <<"message">>, + attrs = + [{<<"type">>, + <<"error">>}], + children = [Error]}) + end, + dict:fetch_keys(StateData#state.channels)), + StateData. + +process_endofwhois(StateData, _String, Nick) -> + ejabberd_router:route(jlib:make_jid(iolist_to_binary([Nick, + <<"!">>, + StateData#state.server]), + StateData#state.host, <<"">>), + StateData#state.user, + #xmlel{name = <<"message">>, + attrs = [{<<"type">>, <<"chat">>}], + children = + [#xmlel{name = <<"body">>, attrs = [], + children = + [{xmlcdata, + <<"End of WHOIS">>}]}]}). + +process_whois311(StateData, String, Nick, Ident, + Irchost) -> + Fullname = ejabberd_regexp:replace(String, + <<".*311[^:]*:">>, <<"">>), + ejabberd_router:route(jlib:make_jid(iolist_to_binary([Nick, + <<"!">>, + StateData#state.server]), + StateData#state.host, <<"">>), + StateData#state.user, + #xmlel{name = <<"message">>, + attrs = [{<<"type">>, <<"chat">>}], + children = + [#xmlel{name = <<"body">>, attrs = [], + children = + [{xmlcdata, + iolist_to_binary( + [<<"WHOIS: ">>, + Nick, + <<" is ">>, + Ident, + <<"@">>, + Irchost, + <<" : ">>, + Fullname])}]}]}). + +process_whois312(StateData, String, Nick, Ircserver) -> + Ircserverdesc = ejabberd_regexp:replace(String, + <<".*312[^:]*:">>, <<"">>), + ejabberd_router:route(jlib:make_jid(iolist_to_binary([Nick, + <<"!">>, + StateData#state.server]), + StateData#state.host, <<"">>), + StateData#state.user, + #xmlel{name = <<"message">>, + attrs = [{<<"type">>, <<"chat">>}], + children = + [#xmlel{name = <<"body">>, attrs = [], + children = + [{xmlcdata, + iolist_to_binary( + [<<"WHOIS: ">>, + Nick, + <<" use ">>, + Ircserver, + <<" : ">>, + Ircserverdesc])}]}]}). + +process_whois319(StateData, String, Nick) -> + Chanlist = ejabberd_regexp:replace(String, + <<".*319[^:]*:">>, <<"">>), + ejabberd_router:route(jlib:make_jid(iolist_to_binary( + [Nick, + <<"!">>, + StateData#state.server]), + StateData#state.host, <<"">>), + StateData#state.user, + #xmlel{name = <<"message">>, + attrs = [{<<"type">>, <<"chat">>}], + children = + [#xmlel{name = <<"body">>, attrs = [], + children = + [{xmlcdata, + iolist_to_binary( + [<<"WHOIS: ">>, + Nick, + <<" is on ">>, + Chanlist])}]}]}). + +process_chanprivmsg(StateData, Chan, From, String) -> + [FromUser | _] = str:tokens(From, <<"!">>), + Msg = ejabberd_regexp:replace(String, + <<".*PRIVMSG[^:]*:">>, <<"">>), + Msg1 = case Msg of + <<1, $A, $C, $T, $I, $O, $N, $\s, Rest/binary>> -> + <<"/me ", Rest/binary>>; + _ -> Msg + end, + Msg2 = filter_message(Msg1), + ejabberd_router:route(jlib:make_jid(iolist_to_binary( + [Chan, + <<"%">>, + StateData#state.server]), + StateData#state.host, FromUser), + StateData#state.user, + #xmlel{name = <<"message">>, + attrs = [{<<"type">>, <<"groupchat">>}], + children = + [#xmlel{name = <<"body">>, attrs = [], + children = [{xmlcdata, Msg2}]}]}). + +process_channotice(StateData, Chan, From, String) -> + [FromUser | _] = str:tokens(From, <<"!">>), + Msg = ejabberd_regexp:replace(String, + <<".*NOTICE[^:]*:">>, <<"">>), + Msg1 = case Msg of + <<1, $A, $C, $T, $I, $O, $N, $\s, Rest/binary>> -> + <<"/me ", Rest/binary>>; + _ -> <<"/me NOTICE: ", Msg/binary>> + end, + Msg2 = filter_message(Msg1), + ejabberd_router:route(jlib:make_jid(iolist_to_binary( + [Chan, + <<"%">>, + StateData#state.server]), + StateData#state.host, FromUser), + StateData#state.user, + #xmlel{name = <<"message">>, + attrs = [{<<"type">>, <<"groupchat">>}], + children = + [#xmlel{name = <<"body">>, attrs = [], + children = [{xmlcdata, Msg2}]}]}). + +process_privmsg(StateData, _Nick, From, String) -> + [FromUser | _] = str:tokens(From, <<"!">>), + Msg = ejabberd_regexp:replace(String, + <<".*PRIVMSG[^:]*:">>, <<"">>), + Msg1 = case Msg of + <<1, $A, $C, $T, $I, $O, $N, $\s, Rest/binary>> -> + <<"/me ", Rest/binary>>; + _ -> Msg + end, + Msg2 = filter_message(Msg1), + ejabberd_router:route(jlib:make_jid(iolist_to_binary( + [FromUser, + <<"!">>, + StateData#state.server]), + StateData#state.host, <<"">>), + StateData#state.user, + #xmlel{name = <<"message">>, + attrs = [{<<"type">>, <<"chat">>}], + children = + [#xmlel{name = <<"body">>, attrs = [], + children = [{xmlcdata, Msg2}]}]}). + +process_notice(StateData, _Nick, From, String) -> + [FromUser | _] = str:tokens(From, <<"!">>), + Msg = ejabberd_regexp:replace(String, + <<".*NOTICE[^:]*:">>, <<"">>), + Msg1 = case Msg of + <<1, $A, $C, $T, $I, $O, $N, $\s, Rest/binary>> -> + <<"/me ", Rest/binary>>; + _ -> <<"/me NOTICE: ", Msg/binary>> + end, + Msg2 = filter_message(Msg1), + ejabberd_router:route(jlib:make_jid(iolist_to_binary( + [FromUser, + <<"!">>, + StateData#state.server]), + StateData#state.host, <<"">>), + StateData#state.user, + #xmlel{name = <<"message">>, + attrs = [{<<"type">>, <<"chat">>}], + children = + [#xmlel{name = <<"body">>, attrs = [], + children = [{xmlcdata, Msg2}]}]}). + +process_version(StateData, _Nick, From) -> + [FromUser | _] = str:tokens(From, <<"!">>), + send_text(StateData, + io_lib:format("NOTICE ~s :\001VERSION ejabberd IRC " + "transport ~s (c) Alexey Shchepin\001\r\n", + [FromUser, ?VERSION]) + ++ + io_lib:format("NOTICE ~s :\001VERSION http://ejabberd.jabber" + "studio.org/\001\r\n", + [FromUser])). + +process_userinfo(StateData, _Nick, From) -> + [FromUser | _] = str:tokens(From, <<"!">>), + send_text(StateData, + io_lib:format("NOTICE ~s :\001USERINFO xmpp:~s\001\r\n", + [FromUser, + jlib:jid_to_string(StateData#state.user)])). + +process_topic(StateData, Chan, From, String) -> + [FromUser | _] = str:tokens(From, <<"!">>), + Msg = ejabberd_regexp:replace(String, + <<".*TOPIC[^:]*:">>, <<"">>), + Msg1 = filter_message(Msg), + ejabberd_router:route(jlib:make_jid(iolist_to_binary( + [Chan, + <<"%">>, + StateData#state.server]), + StateData#state.host, FromUser), + StateData#state.user, + #xmlel{name = <<"message">>, + attrs = [{<<"type">>, <<"groupchat">>}], + children = + [#xmlel{name = <<"subject">>, attrs = [], + children = [{xmlcdata, Msg1}]}, + #xmlel{name = <<"body">>, attrs = [], + children = + [{xmlcdata, + <<"/me has changed the subject to: ", + Msg1/binary>>}]}]}). + +process_part(StateData, Chan, From, String) -> + [FromUser | FromIdent] = str:tokens(From, <<"!">>), + Msg = ejabberd_regexp:replace(String, + <<".*PART[^:]*:">>, <<"">>), + Msg1 = filter_message(Msg), + ejabberd_router:route(jlib:make_jid(iolist_to_binary( + [Chan, + <<"%">>, + StateData#state.server]), + StateData#state.host, FromUser), + StateData#state.user, + #xmlel{name = <<"presence">>, + attrs = [{<<"type">>, <<"unavailable">>}], + children = + [#xmlel{name = <<"x">>, + attrs = + [{<<"xmlns">>, ?NS_MUC_USER}], + children = + [#xmlel{name = <<"item">>, + attrs = + [{<<"affiliation">>, + <<"member">>}, + {<<"role">>, + <<"none">>}], + children = []}]}, + #xmlel{name = <<"status">>, attrs = [], + children = + [{xmlcdata, + list_to_binary( + [Msg1, " (", + FromIdent, ")"])}]}]}), + case catch dict:update(Chan, + fun (Ps) -> remove_element(FromUser, Ps) end, + StateData#state.channels) + of + {'EXIT', _} -> StateData; + NS -> StateData#state{channels = NS} + end. + +process_quit(StateData, From, String) -> + [FromUser | FromIdent] = str:tokens(From, <<"!">>), + Msg = ejabberd_regexp:replace(String, + <<".*QUIT[^:]*:">>, <<"">>), + Msg1 = filter_message(Msg), + dict:map(fun (Chan, Ps) -> + case (?SETS):is_member(FromUser, Ps) of + true -> + ejabberd_router:route(jlib:make_jid(iolist_to_binary( + [Chan, + <<"%">>, + StateData#state.server]), + StateData#state.host, + FromUser), + StateData#state.user, + #xmlel{name = <<"presence">>, + attrs = + [{<<"type">>, + <<"unavailable">>}], + children = + [#xmlel{name = + <<"x">>, + attrs = + [{<<"xmlns">>, + ?NS_MUC_USER}], + children = + [#xmlel{name + = + <<"item">>, + attrs + = + [{<<"affiliation">>, + <<"member">>}, + {<<"role">>, + <<"none">>}], + children + = + []}]}, + #xmlel{name = + <<"status">>, + attrs = [], + children = + [{xmlcdata, + list_to_binary( + [Msg1, " (", + FromIdent, + ")"])}]}]}), + remove_element(FromUser, Ps); + _ -> Ps + end + end, + StateData#state.channels), + StateData. + +process_join(StateData, Channel, From, _String) -> + [FromUser | FromIdent] = str:tokens(From, <<"!">>), + [Chan | _] = binary:split(Channel, <<":#">>), + ejabberd_router:route(jlib:make_jid(iolist_to_binary( + [Chan, + <<"%">>, + StateData#state.server]), + StateData#state.host, FromUser), + StateData#state.user, + #xmlel{name = <<"presence">>, attrs = [], + children = + [#xmlel{name = <<"x">>, + attrs = + [{<<"xmlns">>, ?NS_MUC_USER}], + children = + [#xmlel{name = <<"item">>, + attrs = + [{<<"affiliation">>, + <<"member">>}, + {<<"role">>, + <<"participant">>}], + children = []}]}, + #xmlel{name = <<"status">>, attrs = [], + children = + [{xmlcdata, + list_to_binary(FromIdent)}]}]}), + case catch dict:update(Chan, + fun (Ps) -> (?SETS):add_element(FromUser, Ps) end, + StateData#state.channels) + of + {'EXIT', _} -> StateData; + NS -> StateData#state{channels = NS} + end. + +process_mode_o(StateData, Chan, _From, Nick, + Affiliation, Role) -> + ejabberd_router:route(jlib:make_jid(iolist_to_binary( + [Chan, + <<"%">>, + StateData#state.server]), + StateData#state.host, Nick), + StateData#state.user, + #xmlel{name = <<"presence">>, attrs = [], + children = + [#xmlel{name = <<"x">>, + attrs = + [{<<"xmlns">>, ?NS_MUC_USER}], + children = + [#xmlel{name = <<"item">>, + attrs = + [{<<"affiliation">>, + Affiliation}, + {<<"role">>, + Role}], + children = []}]}]}). + +process_kick(StateData, Chan, From, Nick, String) -> + Msg = lists:last(str:tokens(String, <<":">>)), + Msg2 = <<Nick/binary, " kicked by ", From/binary, " (", + (filter_message(Msg))/binary, ")">>, + ejabberd_router:route(jlib:make_jid(iolist_to_binary( + [Chan, + <<"%">>, + StateData#state.server]), + StateData#state.host, <<"">>), + StateData#state.user, + #xmlel{name = <<"message">>, + attrs = [{<<"type">>, <<"groupchat">>}], + children = + [#xmlel{name = <<"body">>, attrs = [], + children = [{xmlcdata, Msg2}]}]}), + ejabberd_router:route(jlib:make_jid(iolist_to_binary( + [Chan, + <<"%">>, + StateData#state.server]), + StateData#state.host, Nick), + StateData#state.user, + #xmlel{name = <<"presence">>, + attrs = [{<<"type">>, <<"unavailable">>}], + children = + [#xmlel{name = <<"x">>, + attrs = + [{<<"xmlns">>, ?NS_MUC_USER}], + children = + [#xmlel{name = <<"item">>, + attrs = + [{<<"affiliation">>, + <<"none">>}, + {<<"role">>, + <<"none">>}], + children = []}, + #xmlel{name = <<"status">>, + attrs = + [{<<"code">>, + <<"307">>}], + children = []}]}]}). + +process_nick(StateData, From, NewNick) -> + [FromUser | _] = str:tokens(From, <<"!">>), + [Nick | _] = binary:split(NewNick, <<":">>), + NewChans = dict:map(fun (Chan, Ps) -> + case (?SETS):is_member(FromUser, Ps) of + true -> + ejabberd_router:route(jlib:make_jid( + iolist_to_binary( + [Chan, + <<"%">>, + StateData#state.server]), + StateData#state.host, + FromUser), + StateData#state.user, + #xmlel{name = + <<"presence">>, + attrs = + [{<<"type">>, + <<"unavailable">>}], + children = + [#xmlel{name + = + <<"x">>, + attrs + = + [{<<"xmlns">>, + ?NS_MUC_USER}], + children + = + [#xmlel{name + = + <<"item">>, + attrs + = + [{<<"affiliation">>, + <<"member">>}, + {<<"role">>, + <<"participant">>}, + {<<"nick">>, + Nick}], + children + = + []}, + #xmlel{name + = + <<"status">>, + attrs + = + [{<<"code">>, + <<"303">>}], + children + = + []}]}]}), + ejabberd_router:route(jlib:make_jid( + iolist_to_binary( + [Chan, + <<"%">>, + StateData#state.server]), + StateData#state.host, + Nick), + StateData#state.user, + #xmlel{name = + <<"presence">>, + attrs = [], + children = + [#xmlel{name + = + <<"x">>, + attrs + = + [{<<"xmlns">>, + ?NS_MUC_USER}], + children + = + [#xmlel{name + = + <<"item">>, + attrs + = + [{<<"affiliation">>, + <<"member">>}, + {<<"role">>, + <<"participant">>}], + children + = + []}]}]}), + (?SETS):add_element(Nick, + remove_element(FromUser, + Ps)); + _ -> Ps + end + end, + StateData#state.channels), + if FromUser == StateData#state.nick -> + StateData#state{nick = Nick, nickchannel = undefined, + channels = NewChans}; + true -> StateData#state{channels = NewChans} + end. + +process_error(StateData, String) -> + lists:foreach(fun (Chan) -> + ejabberd_router:route(jlib:make_jid( + iolist_to_binary( + [Chan, + <<"%">>, + StateData#state.server]), + StateData#state.host, + StateData#state.nick), + StateData#state.user, + #xmlel{name = <<"presence">>, + attrs = + [{<<"type">>, + <<"error">>}], + children = + [#xmlel{name = + <<"error">>, + attrs = + [{<<"code">>, + <<"502">>}], + children = + [{xmlcdata, + String}]}]}) + end, + dict:fetch_keys(StateData#state.channels)). + +error_unknown_num(_StateData, String, Type) -> + Msg = ejabberd_regexp:replace(String, + <<".*[45][0-9][0-9] +[^ ]* +">>, <<"">>), + Msg1 = filter_message(Msg), + #xmlel{name = <<"error">>, + attrs = [{<<"code">>, <<"500">>}, {<<"type">>, Type}], + children = + [#xmlel{name = <<"undefined-condition">>, + attrs = [{<<"xmlns">>, ?NS_STANZAS}], children = []}, + #xmlel{name = <<"text">>, + attrs = [{<<"xmlns">>, ?NS_STANZAS}], + children = [{xmlcdata, Msg1}]}]}. + +remove_element(E, Set) -> + case (?SETS):is_element(E, Set) of + true -> (?SETS):del_element(E, Set); + _ -> Set + end. + +iq_admin(StateData, Channel, From, To, + #iq{type = Type, xmlns = XMLNS, sub_el = SubEl} = IQ) -> + case catch process_iq_admin(StateData, Channel, Type, + SubEl) + of + {'EXIT', Reason} -> ?ERROR_MSG("~p", [Reason]); + Res -> + if Res /= ignore -> + ResIQ = case Res of + {result, ResEls} -> + IQ#iq{type = result, + sub_el = + [#xmlel{name = <<"query">>, + attrs = [{<<"xmlns">>, XMLNS}], + children = ResEls}]}; + {error, Error} -> + IQ#iq{type = error, sub_el = [SubEl, Error]} + end, + ejabberd_router:route(To, From, jlib:iq_to_xml(ResIQ)); + true -> ok + end + end. + +process_iq_admin(StateData, Channel, set, SubEl) -> + case xml:get_subtag(SubEl, <<"item">>) of + false -> {error, ?ERR_BAD_REQUEST}; + ItemEl -> + Nick = xml:get_tag_attr_s(<<"nick">>, ItemEl), + Affiliation = xml:get_tag_attr_s(<<"affiliation">>, + ItemEl), + Role = xml:get_tag_attr_s(<<"role">>, ItemEl), + Reason = xml:get_path_s(ItemEl, + [{elem, <<"reason">>}, cdata]), + process_admin(StateData, Channel, Nick, Affiliation, + Role, Reason) + end; +process_iq_admin(_StateData, _Channel, get, _SubEl) -> + {error, ?ERR_FEATURE_NOT_IMPLEMENTED}. + +process_admin(_StateData, _Channel, <<"">>, + _Affiliation, _Role, _Reason) -> + {error, ?ERR_FEATURE_NOT_IMPLEMENTED}; +process_admin(StateData, Channel, Nick, _Affiliation, + <<"none">>, Reason) -> + case Reason of + <<"">> -> + send_text(StateData, + io_lib:format("KICK #~s ~s\r\n", [Channel, Nick])); + _ -> + send_text(StateData, + io_lib:format("KICK #~s ~s :~s\r\n", + [Channel, Nick, Reason])) + end, + {result, []}; +process_admin(_StateData, _Channel, _Nick, _Affiliation, + _Role, _Reason) -> + {error, ?ERR_FEATURE_NOT_IMPLEMENTED}. + +filter_message(Msg) -> + list_to_binary( + lists:filter(fun (C) -> + if (C < 32) and (C /= 9) and (C /= 10) and (C /= 13) -> + false; + true -> true + end + end, + binary_to_list(filter_mirc_colors(Msg)))). + +filter_mirc_colors(Msg) -> + ejabberd_regexp:greplace(Msg, + <<"(\\003[0-9]+)(,[0-9]+)?">>, <<"">>). + +unixtime2string(Unixtime) -> + Secs = Unixtime + + calendar:datetime_to_gregorian_seconds({{1970, 1, 1}, + {0, 0, 0}}), + {{Year, Month, Day}, {Hour, Minute, Second}} = + calendar:universal_time_to_local_time(calendar:gregorian_seconds_to_datetime(Secs)), + iolist_to_binary(io_lib:format("~4..0w-~2..0w-~2..0w ~2..0w:~2..0w:~2..0w", + [Year, Month, Day, Hour, Minute, Second])). |