%%%---------------------------------------------------------------------- %%% File : ejabberd_c2s.erl %%% Author : Alexey Shchepin %%% Purpose : Serve C2S connection %%% Created : 16 Nov 2002 by Alexey Shchepin %%% Id : $Id$ %%%---------------------------------------------------------------------- -module(ejabberd_c2s). -author('alexey@sevcom.net'). -vsn('$Revision$ '). -behaviour(gen_fsm). %% External exports -export([start/2, start_link/2, send_text/2, send_element/2, get_presence/1]). %% gen_fsm callbacks -export([init/1, wait_for_stream/2, wait_for_auth/2, wait_for_feature_request/2, wait_for_bind/2, wait_for_session/2, wait_for_sasl_response/2, session_established/2, handle_event/3, handle_sync_event/4, code_change/4, handle_info/3, terminate/3]). -include("ejabberd.hrl"). -include("jlib.hrl"). -define(SETS, gb_sets). -record(state, {socket, receiver, sockmod, streamid, sasl_state, access, shaper, tls = false, tls_required = false, tls_enabled = false, tls_options = [], authentificated = false, jid, user = "", server = ?MYNAME, resource = "", pres_t = ?SETS:new(), pres_f = ?SETS:new(), pres_a = ?SETS:new(), pres_i = ?SETS:new(), pres_last, pres_pri, pres_timestamp, pres_invis = false, privacy_list = none, lang}). %-define(DBGFSM, true). -ifdef(DBGFSM). -define(FSMOPTS, [{debug, [trace]}]). -else. -define(FSMOPTS, []). -endif. -define(STREAM_HEADER, "" "" ). -define(STREAM_TRAILER, ""). -define(INVALID_NS_ERR, xml:element_to_string(?SERR_INVALID_NAMESPACE)). -define(INVALID_XML_ERR, xml:element_to_string(?SERR_XML_NOT_WELL_FORMED)). -define(POLICY_VIOLATION_ERR(Lang, Text), xml:element_to_string(?SERRT_POLICY_VIOLATION(Lang, Text))). %%%---------------------------------------------------------------------- %%% API %%%---------------------------------------------------------------------- start(SockData, Opts) -> supervisor:start_child(ejabberd_c2s_sup, [SockData, Opts]). start_link(SockData, Opts) -> gen_fsm:start_link(ejabberd_c2s, [SockData, Opts], ?FSMOPTS). %% Return Username, Resource and presence information get_presence(FsmRef) -> gen_fsm:sync_send_all_state_event(FsmRef, {get_presence}, 1000). %%%---------------------------------------------------------------------- %%% Callback functions from gen_fsm %%%---------------------------------------------------------------------- %%---------------------------------------------------------------------- %% Func: init/1 %% Returns: {ok, StateName, StateData} | %% {ok, StateName, StateData, Timeout} | %% ignore | %% {stop, StopReason} %%---------------------------------------------------------------------- init([{SockMod, Socket}, Opts]) -> Access = case lists:keysearch(access, 1, Opts) of {value, {_, A}} -> A; _ -> all end, Shaper = case lists:keysearch(shaper, 1, Opts) of {value, {_, S}} -> S; _ -> none end, StartTLS = lists:member(starttls, Opts), StartTLSRequired = lists:member(starttls_required, Opts), TLSEnabled = lists:member(tls, Opts), TLS = StartTLS orelse StartTLSRequired orelse TLSEnabled, TLSOpts = lists:filter(fun({certfile, _}) -> true; (_) -> false end, Opts), {SockMod1, Socket1, ReceiverPid} = if TLSEnabled -> {ok, TLSSocket} = tls:tcp_to_tls(Socket, TLSOpts), RecPid = ejabberd_receiver:start(TLSSocket, tls, none), {tls, TLSSocket, RecPid}; true -> RecPid = ejabberd_receiver:start(Socket, SockMod, none), {SockMod, Socket, RecPid} end, {ok, wait_for_stream, #state{socket = Socket1, sockmod = SockMod1, receiver = ReceiverPid, tls = TLS, tls_required = StartTLSRequired, tls_enabled = TLSEnabled, tls_options = TLSOpts, streamid = new_id(), access = Access, shaper = Shaper}}. %%---------------------------------------------------------------------- %% Func: StateName/2 %% Returns: {next_state, NextStateName, NextStateData} | %% {next_state, NextStateName, NextStateData, Timeout} | %% {stop, Reason, NewStateData} %%---------------------------------------------------------------------- wait_for_stream({xmlstreamstart, _Name, Attrs}, StateData) -> DefaultLang = case ?MYLANG of undefined -> " xml:lang='en'"; DL -> " xml:lang='" ++ DL ++ "'" end, case xml:get_attr_s("xmlns:stream", Attrs) of ?NS_STREAM -> Lang = xml:get_attr_s("xml:lang", Attrs), case xml:get_attr_s("version", Attrs) of "1.0" -> Header = io_lib:format(?STREAM_HEADER, [StateData#state.streamid, ?MYNAME, " version='1.0'", DefaultLang]), send_text(StateData, Header), case StateData#state.authentificated of false -> SASLState = cyrsasl:server_new("jabber", ?MYNAME, "", []), Mechs = lists:map( fun(S) -> {xmlelement, "mechanism", [], [{xmlcdata, S}]} end, cyrsasl:listmech()), TLS = StateData#state.tls, TLSEnabled = StateData#state.tls_enabled, TLSRequired = StateData#state.tls_required, SockMod = StateData#state.sockmod, TLSFeature = case (TLS == true) andalso (TLSEnabled == false) andalso (SockMod == gen_tcp) of true -> case TLSRequired of true -> [{xmlelement, "starttls", [{"xmlns", ?NS_TLS}], [{xmlelement, "required", [], []}]}]; _ -> [{xmlelement, "starttls", [{"xmlns", ?NS_TLS}], []}] end; false -> [] end, send_element(StateData, {xmlelement, "stream:features", [], TLSFeature ++ [{xmlelement, "mechanisms", [{"xmlns", ?NS_SASL}], Mechs}, {xmlelement, "register", [{"xmlns", ?NS_FEATURE_IQREGISTER}], []}]}), {next_state, wait_for_feature_request, StateData#state{sasl_state = SASLState, lang = Lang}}; _ -> case StateData#state.resource of "" -> send_element( StateData, {xmlelement, "stream:features", [], [{xmlelement, "bind", [{"xmlns", ?NS_BIND}], []}, {xmlelement, "session", [{"xmlns", ?NS_SESSION}], []}]}), {next_state, wait_for_bind, StateData#state{lang = Lang}}; _ -> send_element( StateData, {xmlelement, "stream:features", [], []}), {next_state, wait_for_session, StateData#state{lang = Lang}} end end; _ -> Header = io_lib:format( ?STREAM_HEADER, [StateData#state.streamid, ?MYNAME, "", DefaultLang]), send_text(StateData, Header), {next_state, wait_for_auth, StateData#state{lang = Lang}} end; _ -> Header = io_lib:format( ?STREAM_HEADER, [StateData#state.streamid, ?MYNAME, "", ""]), send_text(StateData, Header ++ ?INVALID_NS_ERR ++ ?STREAM_TRAILER), {stop, normal, StateData} end; wait_for_stream({xmlstreamerror, _}, StateData) -> Header = io_lib:format(?STREAM_HEADER, ["none", ?MYNAME, " version='1.0'", ""]), send_text(StateData, Header ++ ?INVALID_XML_ERR ++ ?STREAM_TRAILER), {stop, normal, StateData}; wait_for_stream(closed, StateData) -> {stop, normal, StateData}. wait_for_auth({xmlstreamelement, El}, StateData) -> case is_auth_packet(El) of {auth, _ID, get, {"", _, _, _}} -> Err = jlib:make_error_reply(El, ?ERR_BAD_REQUEST), send_element(StateData, Err), {next_state, wait_for_auth, StateData}; {auth, _ID, get, {U, _, _, _}} -> {xmlelement, Name, Attrs, _Els} = jlib:make_result_iq_reply(El), Res = case ejabberd_auth:plain_password_required() of false -> {xmlelement, Name, Attrs, [{xmlelement, "query", [{"xmlns", ?NS_AUTH}], [{xmlelement, "username", [], [{xmlcdata, U}]}, {xmlelement, "password", [], []}, {xmlelement, "digest", [], []}, {xmlelement, "resource", [], []} ]}]}; true -> {xmlelement, Name, Attrs, [{xmlelement, "query", [{"xmlns", ?NS_AUTH}], [{xmlelement, "username", [], [{xmlcdata, U}]}, {xmlelement, "password", [], []}, {xmlelement, "resource", [], []} ]}]} end, send_element(StateData, Res), {next_state, wait_for_auth, StateData}; {auth, _ID, set, {U, P, D, ""}} -> Err = jlib:make_error_reply( El, ?ERR_AUTH_NO_RESOURCE_PROVIDED(StateData#state.lang)), send_element(StateData, Err), {next_state, wait_for_auth, StateData}; {auth, _ID, set, {U, P, D, R}} -> io:format("AUTH: ~p~n", [{U, P, D, R}]), JID = jlib:make_jid(U, StateData#state.server, R), case (JID /= error) andalso (acl:match_rule(StateData#state.access, JID) == allow) of true -> case ejabberd_auth:check_password( U, P, StateData#state.streamid, D) of true -> ?INFO_MSG( "(~w) Accepted legacy authentication for ~s", [StateData#state.socket, jlib:jid_to_string(JID)]), ejabberd_sm:open_session(U, R), Res1 = jlib:make_result_iq_reply(El), Res = setelement(4, Res1, []), send_element(StateData, Res), change_shaper(StateData, JID), {Fs, Ts} = ejabberd_hooks:run_fold( roster_get_subscription_lists, {[], []}, [U]), LJID = jlib:jid_tolower( jlib:jid_remove_resource(JID)), Fs1 = [LJID | Fs], Ts1 = [LJID | Ts], PrivList = case catch mod_privacy:get_user_list(U) of {'EXIT', _} -> none; PL -> PL end, {next_state, session_established, StateData#state{user = U, resource = R, jid = JID, pres_f = ?SETS:from_list(Fs1), pres_t = ?SETS:from_list(Ts1), privacy_list = PrivList}}; _ -> ?INFO_MSG( "(~w) Failed legacy authentication for ~s", [StateData#state.socket, jlib:jid_to_string(JID)]), Err = jlib:make_error_reply( El, ?ERR_NOT_AUTHORIZED), send_element(StateData, Err), {next_state, wait_for_auth, StateData} end; _ -> if JID == error -> ?INFO_MSG( "(~w) Forbidden legacy authentication for " "username '~s' with resource '~s'", [StateData#state.socket, U, R]), Err = jlib:make_error_reply(El, ?ERR_JID_MALFORMED), send_element(StateData, Err), {next_state, wait_for_auth, StateData}; true -> ?INFO_MSG( "(~w) Forbidden legacy authentication for ~s", [StateData#state.socket, jlib:jid_to_string(JID)]), Err = jlib:make_error_reply(El, ?ERR_NOT_ALLOWED), send_element(StateData, Err), {next_state, wait_for_auth, StateData} end end; _ -> case jlib:iq_query_info(El) of #iq{xmlns = ?NS_REGISTER} = IQ -> ResIQ = mod_register:process_iq( {"", "", ""}, {"", ?MYNAME, ""}, IQ), Res1 = jlib:replace_from_to({"", ?MYNAME, ""}, {"", "", ""}, jlib:iq_to_xml(ResIQ)), Res = jlib:remove_attr("to", Res1), send_element(StateData, Res), {next_state, wait_for_auth, StateData}; _ -> {next_state, wait_for_auth, StateData} end end; wait_for_auth({xmlstreamend, _Name}, StateData) -> send_text(StateData, ?STREAM_TRAILER), {stop, normal, StateData}; wait_for_auth({xmlstreamerror, _}, StateData) -> send_text(StateData, ?INVALID_XML_ERR ++ ?STREAM_TRAILER), {stop, normal, StateData}; wait_for_auth(closed, StateData) -> {stop, normal, StateData}. wait_for_feature_request({xmlstreamelement, El}, StateData) -> {xmlelement, Name, Attrs, Els} = El, TLS = StateData#state.tls, TLSEnabled = StateData#state.tls_enabled, TLSRequired = StateData#state.tls_required, SockMod = StateData#state.sockmod, case {xml:get_attr_s("xmlns", Attrs), Name} of {?NS_SASL, "auth"} when not ((SockMod == gen_tcp) and TLSRequired) -> Mech = xml:get_attr_s("mechanism", Attrs), ClientIn = jlib:decode_base64(xml:get_cdata(Els)), case cyrsasl:server_start(StateData#state.sasl_state, Mech, ClientIn) of {ok, Props} -> ejabberd_receiver:reset_stream(StateData#state.receiver), send_element(StateData, {xmlelement, "success", [{"xmlns", ?NS_SASL}], []}), U = xml:get_attr_s(username, Props), ?INFO_MSG("(~w) Accepted authentication for ~s", [StateData#state.socket, U]), {next_state, wait_for_stream, StateData#state{streamid = new_id(), authentificated = true, user = U }}; {continue, ServerOut, NewSASLState} -> send_element(StateData, {xmlelement, "challenge", [{"xmlns", ?NS_SASL}], [{xmlcdata, jlib:encode_base64(ServerOut)}]}), {next_state, wait_for_sasl_response, StateData#state{sasl_state = NewSASLState}}; {error, Error} -> send_element(StateData, {xmlelement, "failure", [{"xmlns", ?NS_SASL}], [{xmlelement, Error, [], []}]}), {next_state, wait_for_feature_request, StateData} end; {?NS_TLS, "starttls"} when TLS == true, TLSEnabled == false, SockMod == gen_tcp -> Socket = StateData#state.socket, TLSOpts = StateData#state.tls_options, {ok, TLSSocket} = tls:tcp_to_tls(Socket, TLSOpts), ejabberd_receiver:starttls(StateData#state.receiver, TLSSocket), send_element(StateData, {xmlelement, "proceed", [{"xmlns", ?NS_TLS}], []}), {next_state, wait_for_stream, StateData#state{sockmod = tls, socket = TLSSocket, streamid = new_id(), tls_enabled = true }}; _ -> if (SockMod == gen_tcp) and TLSRequired -> Lang = StateData#state.lang, send_text(StateData, ?POLICY_VIOLATION_ERR( Lang, "Use of STARTTLS required") ++ ?STREAM_TRAILER), {stop, normal, StateData}; true -> case jlib:iq_query_info(El) of #iq{xmlns = ?NS_REGISTER} = IQ -> ResIQ = mod_register:process_iq( {"", "", ""}, {"", ?MYNAME, ""}, IQ), Res1 = jlib:replace_from_to({"", ?MYNAME, ""}, {"", "", ""}, jlib:iq_to_xml(ResIQ)), Res = jlib:remove_attr("to", Res1), send_element(StateData, Res), {next_state, wait_for_feature_request, StateData}; _ -> {next_state, wait_for_feature_request, StateData} end end end; wait_for_feature_request({xmlstreamend, _Name}, StateData) -> send_text(StateData, ?STREAM_TRAILER), {stop, normal, StateData}; wait_for_feature_request({xmlstreamerror, _}, StateData) -> send_text(StateData, ?INVALID_XML_ERR ++ ?STREAM_TRAILER), {stop, normal, StateData}; wait_for_feature_request(closed, StateData) -> {stop, normal, StateData}. wait_for_sasl_response({xmlstreamelement, El}, StateData) -> {xmlelement, Name, Attrs, Els} = El, case {xml:get_attr_s("xmlns", Attrs), Name} of {?NS_SASL, "response"} -> ClientIn = jlib:decode_base64(xml:get_cdata(Els)), case cyrsasl:server_step(StateData#state.sasl_state, ClientIn) of {ok, Props} -> ejabberd_receiver:reset_stream(StateData#state.receiver), send_element(StateData, {xmlelement, "success", [{"xmlns", ?NS_SASL}], []}), U = xml:get_attr_s(username, Props), ?INFO_MSG("(~w) Accepted authentication for ~s", [StateData#state.socket, U]), {next_state, wait_for_stream, StateData#state{streamid = new_id(), authentificated = true, user = U }}; {continue, ServerOut, NewSASLState} -> send_element(StateData, {xmlelement, "challenge", [{"xmlns", ?NS_SASL}], [{xmlcdata, jlib:encode_base64(ServerOut)}]}), {next_state, wait_for_sasl_response, StateData#state{sasl_state = NewSASLState}}; {error, Error} -> send_element(StateData, {xmlelement, "failure", [{"xmlns", ?NS_SASL}], [{xmlelement, Error, [], []}]}), {next_state, wait_for_feature_request, StateData} end; _ -> case jlib:iq_query_info(El) of #iq{xmlns = ?NS_REGISTER} = IQ -> ResIQ = mod_register:process_iq( {"", "", ""}, {"", ?MYNAME, ""}, IQ), Res1 = jlib:replace_from_to({"", ?MYNAME, ""}, {"", "", ""}, jlib:iq_to_xml(ResIQ)), Res = jlib:remove_attr("to", Res1), send_element(StateData, Res), {next_state, wait_for_feature_request, StateData}; _ -> {next_state, wait_for_feature_request, StateData} end end; wait_for_sasl_response({xmlstreamend, _Name}, StateData) -> send_text(StateData, ?STREAM_TRAILER), {stop, normal, StateData}; wait_for_sasl_response({xmlstreamerror, _}, StateData) -> send_text(StateData, ?INVALID_XML_ERR ++ ?STREAM_TRAILER), {stop, normal, StateData}; wait_for_sasl_response(closed, StateData) -> {stop, normal, StateData}. wait_for_bind({xmlstreamelement, El}, StateData) -> case jlib:iq_query_info(El) of #iq{type = set, xmlns = ?NS_BIND, sub_el = SubEl} = IQ -> U = StateData#state.user, R1 = xml:get_path_s(SubEl, [{elem, "resource"}, cdata]), R = case jlib:resourceprep(R1) of error -> error; "" -> lists:concat( [randoms:get_string() | tuple_to_list(now())]); Resource -> Resource end, case R of error -> Err = jlib:make_error_reply(El, ?ERR_BAD_REQUEST), send_element(StateData, Err), {next_state, wait_for_bind, StateData}; _ -> JID = jlib:make_jid(U, StateData#state.server, R), Res = IQ#iq{type = result, sub_el = [{xmlelement, "bind", [{"xmlns", ?NS_BIND}], [{xmlelement, "jid", [], [{xmlcdata, jlib:jid_to_string(JID)}]}]}]}, send_element(StateData, jlib:iq_to_xml(Res)), {next_state, wait_for_session, StateData#state{resource = R, jid = JID}} end; _ -> {next_state, wait_for_bind, StateData} end; wait_for_bind({xmlstreamend, _Name}, StateData) -> send_text(StateData, ?STREAM_TRAILER), {stop, normal, StateData}; wait_for_bind({xmlstreamerror, _}, StateData) -> send_text(StateData, ?INVALID_XML_ERR ++ ?STREAM_TRAILER), {stop, normal, StateData}; wait_for_bind(closed, StateData) -> {stop, normal, StateData}. wait_for_session({xmlstreamelement, El}, StateData) -> case jlib:iq_query_info(El) of #iq{type = set, xmlns = ?NS_SESSION} -> U = StateData#state.user, R = StateData#state.resource, io:format("SASLAUTH: ~p~n", [{U, R}]), JID = StateData#state.jid, case acl:match_rule(StateData#state.access, JID) of allow -> ?INFO_MSG("(~w) Opened session for ~s", [StateData#state.socket, jlib:jid_to_string(JID)]), ejabberd_sm:open_session(U, R), Res = jlib:make_result_iq_reply(El), send_element(StateData, Res), change_shaper(StateData, JID), {Fs, Ts} = ejabberd_hooks:run_fold( roster_get_subscription_lists, {[], []}, [U]), LJID = jlib:jid_tolower(jlib:jid_remove_resource(JID)), Fs1 = [LJID | Fs], Ts1 = [LJID | Ts], PrivList = case catch mod_privacy:get_user_list(U) of {'EXIT', _} -> none; PL -> PL end, {next_state, session_established, StateData#state{pres_f = ?SETS:from_list(Fs1), pres_t = ?SETS:from_list(Ts1), privacy_list = PrivList}}; _ -> ?INFO_MSG("(~w) Forbidden session for ~s", [StateData#state.socket, jlib:jid_to_string(JID)]), Err = jlib:make_error_reply(El, ?ERR_NOT_ALLOWED), send_element(StateData, Err), {next_state, wait_for_session, StateData} end; _ -> {next_state, wait_for_session, StateData} end; wait_for_session({xmlstreamend, _Name}, StateData) -> send_text(StateData, ?STREAM_TRAILER), {stop, normal, StateData}; wait_for_session({xmlstreamerror, _}, StateData) -> send_text(StateData, ?INVALID_XML_ERR ++ ?STREAM_TRAILER), {stop, normal, StateData}; wait_for_session(closed, StateData) -> {stop, normal, StateData}. session_established({xmlstreamelement, El}, StateData) -> {xmlelement, Name, Attrs, _Els} = El, User = StateData#state.user, Server = StateData#state.server, % TODO: check 'from' attribute in stanza FromJID = StateData#state.jid, To = xml:get_attr_s("to", Attrs), ToJID = case To of "" -> jlib:make_jid(User, Server, ""); _ -> jlib:string_to_jid(To) end, NewEl = case xml:get_attr_s("xml:lang", Attrs) of "" -> case StateData#state.lang of "" -> El; Lang -> xml:replace_tag_attr("xml:lang", Lang, El) end; _ -> El end, NewState = case ToJID of error -> case xml:get_attr_s("type", Attrs) of "error" -> StateData; "result" -> StateData; _ -> Err = jlib:make_error_reply(NewEl, ?ERR_JID_MALFORMED), send_element(StateData, Err), StateData end; _ -> case Name of "presence" -> case ToJID of #jid{user = User, server = Server, resource = ""} -> ?DEBUG("presence_update(~p,~n\t~p,~n\t~p)", [FromJID, NewEl, StateData]), presence_update(FromJID, NewEl, StateData); _ -> presence_track(FromJID, ToJID, NewEl, StateData) end; "iq" -> case StateData#state.privacy_list of none -> ejabberd_router:route(FromJID, ToJID, NewEl), StateData; _PrivList -> case jlib:iq_query_info(NewEl) of #iq{xmlns = ?NS_PRIVACY} = IQ -> process_privacy_iq( FromJID, ToJID, IQ, StateData); _ -> ejabberd_hooks:run( user_send_packet, [FromJID, ToJID, NewEl]), ejabberd_router:route( FromJID, ToJID, NewEl), StateData end end; "message" -> ejabberd_hooks:run(user_send_packet, [FromJID, ToJID, NewEl]), ejabberd_router:route(FromJID, ToJID, NewEl), StateData; _ -> StateData end end, {next_state, session_established, NewState}; session_established({xmlstreamend, _Name}, StateData) -> send_text(StateData, ?STREAM_TRAILER), {stop, normal, StateData}; session_established({xmlstreamerror, _}, StateData) -> send_text(StateData, ?INVALID_XML_ERR ++ ?STREAM_TRAILER), {stop, normal, StateData}; session_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({get_presence}, _From, StateName, StateData) -> User = StateData#state.user, PresLast = StateData#state.pres_last, Show = get_showtag(PresLast), Status = get_statustag(PresLast), Resource = StateData#state.resource, Reply = {User, Resource, Show, Status}, {reply, Reply, StateName, StateData}; handle_sync_event(_Event, _From, StateName, StateData) -> Reply = ok, {reply, Reply, StateName, StateData}. code_change(_OldVsn, StateName, StateData, _Extra) -> {ok, StateName, StateData}. %%---------------------------------------------------------------------- %% Func: handle_info/3 %% Returns: {next_state, NextStateName, NextStateData} | %% {next_state, NextStateName, NextStateData, Timeout} | %% {stop, Reason, NewStateData} %%---------------------------------------------------------------------- handle_info({send_text, Text}, StateName, StateData) -> send_text(StateData, Text), {next_state, StateName, StateData}; handle_info(replaced, _StateName, StateData) -> % TODO %send_text(StateData#state.sender, Text), {stop, normal, StateData#state{authentificated = replaced}}; handle_info({route, From, To, Packet}, StateName, StateData) -> {xmlelement, Name, Attrs, Els} = Packet, {Pass, NewAttrs, NewState} = case Name of "presence" -> case xml:get_attr_s("type", Attrs) of "probe" -> process_presence_probe(From, To, StateData), {false, Attrs, StateData}; "error" -> NewA = remove_element(jlib:jid_tolower(From), StateData#state.pres_a), {true, Attrs, StateData#state{pres_a = NewA}}; "invisible" -> Attrs1 = lists:keydelete("type", 1, Attrs), {true, [{"type", "unavailable"} | Attrs1], StateData}; "subscribe" -> {true, Attrs, StateData}; "subscribed" -> {true, Attrs, StateData}; "unsubscribe" -> {true, Attrs, StateData}; "unsubscribed" -> {true, Attrs, StateData}; _ -> %-ifdef(PRIVACY_SUPPORT). case catch mod_privacy:check_packet( StateData#state.user, StateData#state.privacy_list, {From, To, Packet}, in) of {'EXIT', _Reason} -> {true, Attrs, StateData}; allow -> {true, Attrs, StateData}; deny -> {false, Attrs, StateData} end %-elseif. % {true, Attrs, StateData} %-endif. end; "broadcast" -> ?DEBUG("broadcast~n~p~n", [Els]), case Els of [{item, IJID, ISubscription}] -> {false, Attrs, roster_change(IJID, ISubscription, StateData)}; [{exit, Reason}] -> {exit, Attrs, Reason}; [{privacy_list, PrivList}] -> {false, Attrs, case catch mod_privacy:updated_list( StateData#state.privacy_list, PrivList) of {'EXIT', _} -> {false, Attrs, StateData}; NewPL -> StateData#state{privacy_list = NewPL} end}; _ -> {false, Attrs, StateData} end; "iq" -> IQ = jlib:iq_query_info(Packet), case IQ of #iq{xmlns = ?NS_VCARD} -> ResIQ = mod_vcard:process_sm_iq(From, To, IQ), ejabberd_router:route(To, From, jlib:iq_to_xml(ResIQ)), {false, Attrs, StateData}; %-ifdef(PRIVACY_SUPPORT). #iq{} -> case catch mod_privacy:check_packet( StateData#state.user, StateData#state.privacy_list, {From, To, Packet}, in) of {'EXIT', _Reason} -> {true, Attrs, StateData}; allow -> {true, Attrs, StateData}; deny -> Err = jlib:make_error_reply( Packet, ?ERR_FEATURE_NOT_IMPLEMENTED), ejabberd_router:route(To, From, Err), {false, Attrs, StateData} end; %-endif. _ -> {true, Attrs, StateData} end; %-ifdef(PRIVACY_SUPPORT). "message" -> case catch mod_privacy:check_packet( StateData#state.user, StateData#state.privacy_list, {From, To, Packet}, in) of {'EXIT', _Reason} -> {true, Attrs, StateData}; allow -> {true, Attrs, StateData}; deny -> {false, Attrs, StateData} end; %-endif. _ -> {true, Attrs, StateData} end, if Pass == exit -> {stop, normal, StateData}; Pass -> Attrs2 = jlib:replace_from_to_attrs(jlib:jid_to_string(From), jlib:jid_to_string(To), NewAttrs), FixedPacket = {xmlelement, Name, Attrs2, Els}, Text = xml:element_to_string(FixedPacket), send_text(StateData, Text), ejabberd_hooks:run(user_receive_packet, [StateData#state.jid, From, To, FixedPacket]), {next_state, StateName, NewState}; true -> {next_state, StateName, NewState} end. %%---------------------------------------------------------------------- %% Func: terminate/3 %% Purpose: Shutdown the fsm %% Returns: any %%---------------------------------------------------------------------- terminate(_Reason, StateName, StateData) -> case StateName of session_established -> case StateData#state.authentificated of replaced -> ?INFO_MSG("(~w) Replaced session for ~s", [StateData#state.socket, jlib:jid_to_string(StateData#state.jid)]), From = StateData#state.jid, Packet = {xmlelement, "presence", [{"type", "unavailable"}], [{xmlelement, "status", [], [{xmlcdata, "Replaced by new connection"}]}]}, ejabberd_sm:unset_presence(StateData#state.user, StateData#state.resource, "Replaced by new connection"), presence_broadcast( StateData, From, StateData#state.pres_a, Packet), presence_broadcast( StateData, From, StateData#state.pres_i, Packet); _ -> ?INFO_MSG("(~w) Close session for ~s", [StateData#state.socket, jlib:jid_to_string(StateData#state.jid)]), ejabberd_sm:close_session(StateData#state.user, StateData#state.resource), Tmp = ?SETS:new(), case StateData of #state{pres_last = undefined, pres_a = Tmp, pres_i = Tmp, pres_invis = false} -> ok; _ -> From = StateData#state.jid, Packet = {xmlelement, "presence", [{"type", "unavailable"}], []}, ejabberd_sm:unset_presence(StateData#state.user, StateData#state.resource, ""), presence_broadcast( StateData, From, StateData#state.pres_a, Packet), presence_broadcast( StateData, From, StateData#state.pres_i, Packet) end end; _ -> ok end, (StateData#state.sockmod):close(StateData#state.socket), ok. %%%---------------------------------------------------------------------- %%% Internal functions %%%---------------------------------------------------------------------- change_shaper(StateData, JID) -> Shaper = acl:match_rule(StateData#state.shaper, JID), ejabberd_receiver:change_shaper(StateData#state.receiver, Shaper). send_text(StateData, Text) -> (StateData#state.sockmod):send(StateData#state.socket, Text). send_element(StateData, El) -> send_text(StateData, xml:element_to_string(El)). new_id() -> randoms:get_string(). is_auth_packet(El) -> case jlib:iq_query_info(El) of #iq{id = ID, type = Type, xmlns = ?NS_AUTH, sub_el = SubEl} -> {xmlelement, _, _, Els} = SubEl, {auth, ID, Type, get_auth_tags(Els, "", "", "", "")}; _ -> false end. get_auth_tags([{xmlelement, Name, _Attrs, Els}| L], U, P, D, R) -> CData = xml:get_cdata(Els), case Name of "username" -> get_auth_tags(L, CData, P, D, R); "password" -> get_auth_tags(L, U, CData, D, R); "digest" -> get_auth_tags(L, U, P, CData, R); "resource" -> get_auth_tags(L, U, P, D, CData); _ -> get_auth_tags(L, U, P, D, R) end; get_auth_tags([_ | L], U, P, D, R) -> get_auth_tags(L, U, P, D, R); get_auth_tags([], U, P, D, R) -> {U, P, D, R}. process_presence_probe(From, To, StateData) -> LFrom = jlib:jid_tolower(From), LBFrom = setelement(3, LFrom, ""), case StateData#state.pres_last of undefined -> ok; _ -> Cond1 = (not StateData#state.pres_invis) andalso (?SETS:is_element(LFrom, StateData#state.pres_f) orelse ((LFrom /= LBFrom) andalso ?SETS:is_element(LBFrom, StateData#state.pres_f))) andalso (not (?SETS:is_element(LFrom, StateData#state.pres_i) orelse ((LFrom /= LBFrom) andalso ?SETS:is_element(LBFrom, StateData#state.pres_i)))), Cond2 = StateData#state.pres_invis andalso ?SETS:is_element(LFrom, StateData#state.pres_f) andalso ?SETS:is_element(LFrom, StateData#state.pres_a), if Cond1 -> Packet = StateData#state.pres_last, %-ifdef(PRIVACY_SUPPORT). case catch mod_privacy:check_packet( StateData#state.user, StateData#state.privacy_list, {To, From, Packet}, out) of deny -> ok; _ -> %-endif. ejabberd_router:route(To, From, Packet) %-ifdef(PRIVACY_SUPPORT). end; %-endif. Cond2 -> ejabberd_router:route(To, From, {xmlelement, "presence", [], []}); true -> ok end end. presence_update(From, Packet, StateData) -> {xmlelement, _Name, Attrs, _Els} = Packet, case xml:get_attr_s("type", Attrs) of "unavailable" -> Status = case xml:get_subtag(Packet, "status") of false -> ""; StatusTag -> xml:get_tag_cdata(StatusTag) end, ejabberd_sm:unset_presence(StateData#state.user, StateData#state.resource, Status), presence_broadcast(StateData, From, StateData#state.pres_a, Packet), presence_broadcast(StateData, From, StateData#state.pres_i, Packet), StateData#state{pres_last = undefined, pres_a = ?SETS:new(), pres_i = ?SETS:new(), pres_invis = false}; "invisible" -> NewState = if not StateData#state.pres_invis -> presence_broadcast(StateData, From, StateData#state.pres_a, Packet), presence_broadcast(StateData, From, StateData#state.pres_i, Packet), S1 = StateData#state{pres_last = undefined, pres_a = ?SETS:new(), pres_i = ?SETS:new(), pres_invis = true}, presence_broadcast_first(From, S1, Packet); true -> StateData end, NewState; "error" -> StateData; "probe" -> StateData; "subscribe" -> StateData; "subscribed" -> StateData; "unsubscribe" -> StateData; "unsubscribed" -> StateData; _ -> update_priority(xml:get_subtag(Packet, "priority"), StateData), FromUnavail = (StateData#state.pres_last == undefined) or StateData#state.pres_invis, ?DEBUG("from unavail = ~p~n", [FromUnavail]), NewState = if FromUnavail -> ejabberd_hooks:run(user_available_hook, [StateData#state.jid]), resend_offline_messages(StateData), presence_broadcast_first( From, StateData#state{pres_last = Packet, pres_invis = false }, Packet); true -> presence_broadcast_to_trusted(StateData, From, StateData#state.pres_f, StateData#state.pres_a, Packet), StateData#state{pres_last = Packet, pres_invis = false } end, NewState end. presence_track(From, To, Packet, StateData) -> {xmlelement, _Name, Attrs, _Els} = Packet, LTo = jlib:jid_tolower(To), User = StateData#state.user, case xml:get_attr_s("type", Attrs) of "unavailable" -> ejabberd_router:route(From, To, Packet), I = remove_element(LTo, StateData#state.pres_i), A = remove_element(LTo, StateData#state.pres_a), StateData#state{pres_i = I, pres_a = A}; "invisible" -> ejabberd_router:route(From, To, Packet), I = ?SETS:add_element(LTo, StateData#state.pres_i), A = remove_element(LTo, StateData#state.pres_a), StateData#state{pres_i = I, pres_a = A}; "subscribe" -> ejabberd_router:route(jlib:jid_remove_resource(From), To, Packet), ejabberd_hooks:run(roster_out_subscription, [User, To, subscribe]), StateData; "subscribed" -> ejabberd_router:route(jlib:jid_remove_resource(From), To, Packet), ejabberd_hooks:run(roster_out_subscription, [User, To, subscribed]), StateData; "unsubscribe" -> ejabberd_router:route(jlib:jid_remove_resource(From), To, Packet), ejabberd_hooks:run(roster_out_subscription, [User, To, unsubscribe]), StateData; "unsubscribed" -> ejabberd_router:route(jlib:jid_remove_resource(From), To, Packet), ejabberd_hooks:run(roster_out_subscription, [User, To, unsubscribed]), StateData; "error" -> ejabberd_router:route(From, To, Packet), StateData; "probe" -> ejabberd_router:route(From, To, Packet), StateData; _ -> %-ifdef(PRIVACY_SUPPORT). case catch mod_privacy:check_packet( StateData#state.user, StateData#state.privacy_list, {From, To, Packet}, out) of deny -> ok; _ -> %-endif. ejabberd_router:route(From, To, Packet) %-ifdef(PRIVACY_SUPPORT). end, %-endif. I = remove_element(LTo, StateData#state.pres_i), A = ?SETS:add_element(LTo, StateData#state.pres_a), StateData#state{pres_i = I, pres_a = A} end. presence_broadcast(StateData, From, JIDSet, Packet) -> lists:foreach(fun(JID) -> FJID = jlib:make_jid(JID), %-ifdef(PRIVACY_SUPPORT). case catch mod_privacy:check_packet( StateData#state.user, StateData#state.privacy_list, {From, FJID, Packet}, out) of deny -> ok; _ -> %-endif. ejabberd_router:route(From, FJID, Packet) %-ifdef(PRIVACY_SUPPORT). end %-endif. end, ?SETS:to_list(JIDSet)). presence_broadcast_to_trusted(StateData, From, T, A, Packet) -> lists:foreach( fun(JID) -> case ?SETS:is_element(JID, T) of true -> FJID = jlib:make_jid(JID), %-ifdef(PRIVACY_SUPPORT). case catch mod_privacy:check_packet( StateData#state.user, StateData#state.privacy_list, {From, FJID, Packet}, out) of deny -> ok; _ -> %-endif. ejabberd_router:route(From, FJID, Packet) %-ifdef(PRIVACY_SUPPORT). end; %-endif. _ -> ok end end, ?SETS:to_list(A)). presence_broadcast_first(From, StateData, Packet) -> ?SETS:fold(fun(JID, X) -> ejabberd_router:route( From, jlib:make_jid(JID), {xmlelement, "presence", [{"type", "probe"}], []}), X end, [], StateData#state.pres_t), if StateData#state.pres_invis -> StateData; true -> As = ?SETS:fold( fun(JID, A) -> FJID = jlib:make_jid(JID), %-ifdef(PRIVACY_SUPPORT). case catch mod_privacy:check_packet( StateData#state.user, StateData#state.privacy_list, {From, FJID, Packet}, out) of deny -> ok; _ -> %-endif. ejabberd_router:route(From, FJID, Packet) %-ifdef(PRIVACY_SUPPORT). end, %-endif. ?SETS:add_element(JID, A) end, StateData#state.pres_a, StateData#state.pres_f), StateData#state{pres_a = As} end. remove_element(E, Set) -> case ?SETS:is_element(E, Set) of true -> ?SETS:del_element(E, Set); _ -> Set end. roster_change(IJID, ISubscription, StateData) -> LIJID = jlib:jid_tolower(IJID), IsFrom = (ISubscription == both) or (ISubscription == from), IsTo = (ISubscription == both) or (ISubscription == to), FSet = if IsFrom -> ?SETS:add_element(LIJID, StateData#state.pres_f); true -> remove_element(LIJID, StateData#state.pres_f) end, TSet = if IsTo -> ?SETS:add_element(LIJID, StateData#state.pres_t); true -> remove_element(LIJID, StateData#state.pres_t) end, case StateData#state.pres_last of undefined -> StateData#state{pres_f = FSet, pres_t = TSet}; P -> ?DEBUG("roster changed for ~p~n", [StateData#state.user]), From = StateData#state.jid, Cond1 = (not StateData#state.pres_invis) and IsFrom, Cond2 = (not IsFrom) and (?SETS:is_element(LIJID, StateData#state.pres_a) or ?SETS:is_element(LIJID, StateData#state.pres_i)), if Cond1 -> ?DEBUG("C1: ~p~n", [LIJID]), ejabberd_router:route(From, jlib:make_jid(IJID), P), A = ?SETS:add_element(LIJID, StateData#state.pres_a), StateData#state{pres_a = A, pres_f = FSet, pres_t = TSet}; Cond2 -> ?DEBUG("C2: ~p~n", [LIJID]), ejabberd_router:route(From, jlib:make_jid(IJID), {xmlelement, "presence", [{"type", "unavailable"}], []}), I = remove_element(LIJID, StateData#state.pres_i), A = remove_element(LIJID, StateData#state.pres_a), StateData#state{pres_i = I, pres_a = A, pres_f = FSet, pres_t = TSet}; true -> StateData#state{pres_f = FSet, pres_t = TSet} end end. update_priority(El, StateData) -> Pri = case El of false -> 0; _ -> case catch list_to_integer(xml:get_tag_cdata(El)) of P when is_integer(P) -> P; _ -> 0 end end, ejabberd_sm:set_presence(StateData#state.user, StateData#state.resource, Pri). process_privacy_iq(From, To, #iq{type = Type, sub_el = SubEl} = IQ, StateData) -> {Res, NewStateData} = case Type of get -> case catch mod_privacy:process_iq_get( From, To, IQ, StateData#state.privacy_list) of {'EXIT', _} -> {{error, ?ERR_FEATURE_NOT_IMPLEMENTED}, StateData}; R -> {R, StateData} end; set -> case catch mod_privacy:process_iq_set( From, To, IQ) of {'EXIT', _} -> {{error, ?ERR_FEATURE_NOT_IMPLEMENTED}, StateData}; {result, R, NewPrivList} -> {{result, R}, StateData#state{privacy_list = NewPrivList}}; R -> {R, StateData} end end, IQRes = case Res of {result, Result} -> IQ#iq{type = result, sub_el = Result}; {error, Error} -> IQ#iq{type = error, sub_el = [SubEl, Error]} end, ejabberd_router:route( To, From, jlib:iq_to_xml(IQRes)), NewStateData. resend_offline_messages(#state{user = User, privacy_list = PrivList} = StateData) -> case ejabberd_hooks:run_fold(resend_offline_messages_hook, [], [User]) of Rs when list(Rs) -> lists:foreach( fun({route, From, To, {xmlelement, Name, Attrs, Els} = Packet}) -> Pass = case catch mod_privacy:check_packet( User, PrivList, {From, To, Packet}, in) of {'EXIT', _Reason} -> true; allow -> true; deny -> false end, if Pass -> Attrs2 = jlib:replace_from_to_attrs( jlib:jid_to_string(From), jlib:jid_to_string(To), Attrs), send_element(StateData, {xmlelement, Name, Attrs2, Els}); true -> ok end end, Rs) end. get_showtag(undefined) -> "unavailable"; get_showtag(Presence) -> case xml:get_path_s(Presence, [{elem, "show"}, cdata]) of "" -> "available"; ShowTag -> ShowTag end. get_statustag(undefined) -> ""; get_statustag(Presence) -> case xml:get_path_s(Presence, [{elem, "status"}, cdata]) of ShowTag -> ShowTag end.