]> granicus.if.org Git - ejabberd/commitdiff
Use xmpp:try_subtag/2 wherever possible
authorEvgeniy Khramtsov <ekhramtsov@process-one.net>
Mon, 11 Dec 2017 06:46:26 +0000 (09:46 +0300)
committerEvgeniy Khramtsov <ekhramtsov@process-one.net>
Mon, 11 Dec 2017 06:46:26 +0000 (09:46 +0300)
src/mod_legacy_auth.erl
src/mod_muc_room.erl
src/mod_multicast.erl
src/mod_privilege.erl
src/mod_register.erl

index 722a057380f430474fb97654d6d1f168f2f176a3..0ae3253c96b82d37835d22bf69576dc83b8e9a3d 100644 (file)
@@ -61,11 +61,16 @@ mod_opt_type(_) ->
       c2s_state() | {stop, c2s_state()}.
 c2s_unauthenticated_packet(State, #iq{type = T, sub_els = [_]} = IQ)
   when T == get; T == set ->
-    case xmpp:get_subtag(IQ, #legacy_auth{}) of
+    try xmpp:try_subtag(IQ, #legacy_auth{}) of
        #legacy_auth{} = Auth ->
            {stop, authenticate(State, xmpp:set_els(IQ, [Auth]))};
        false ->
            State
+    catch _:{xmpp_codec, Why} ->
+           Txt = xmpp:io_format_error(Why),
+           Lang = maps:get(lang, State),
+           Err = xmpp:make_error(IQ, xmpp:error_bad_request(Txt, Lang)),
+           {stop, ejabberd_c2s:send(State, Err)}
     end;
 c2s_unauthenticated_packet(State, _) ->
     State.
index 271e49b456fc160012f79085c2efd881373ede8a..e8d61dacb28b4949bce10d1e79dd4d9c67e21453 100644 (file)
@@ -4006,7 +4006,7 @@ route_invitation(From, Invitation, Lang, StateData) ->
 %% Otherwise, an error message is sent to the sender.
 -spec handle_roommessage_from_nonparticipant(message(), state(), jid()) -> ok.
 handle_roommessage_from_nonparticipant(Packet, StateData, From) ->
-    case xmpp:get_subtag(Packet, #muc_user{}) of
+    try xmpp:try_subtag(Packet, #muc_user{}) of
        #muc_user{decline = #muc_decline{to = #jid{} = To} = Decline} = XUser ->
            NewDecline = Decline#muc_decline{to = undefined, from = From},
            NewXUser = XUser#muc_user{decline = NewDecline},
@@ -4018,6 +4018,10 @@ handle_roommessage_from_nonparticipant(Packet, StateData, From) ->
                        "to the conference">>,
            Err = xmpp:err_not_acceptable(ErrText, xmpp:get_lang(Packet)),
            ejabberd_router:route_error(Packet, Err)
+    catch _:{xmpp_codec, Why} ->
+           Txt = xmpp:io_format_error(Why),
+           Err = xmpp:err_bad_request(Txt, xmpp:get_lang(Packet)),
+           ejabberd_router:route_error(Packet, Err)
     end.
 
 %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
index 7b772521d1d1c6b3df594caa2704d2045f3ed8b5..fa9e19aefbf9bb51ff5969988f5bc637b9f6bbda 100644 (file)
@@ -402,7 +402,7 @@ strip_addresses_element(Packet) ->
        #addresses{list = Addrs} ->
            PacketStripped = xmpp:remove_subtag(Packet, #addresses{}),
            {ok, PacketStripped, Addrs};
-       undefined ->
+       false ->
            throw(eadsele)
     end.
 
index dab7a619b3aa7da11975c1e2944dfa876a09f0c8..def0977398ed5367e696a4cfea64bac2cde77b28 100644 (file)
@@ -274,7 +274,7 @@ get_permissions(ServerHost) ->
 forward_message(#message{to = To} = Msg) ->
     ServerHost = To#jid.lserver,
     Lang = xmpp:get_lang(Msg),
-    case xmpp:get_subtag(Msg, #privilege{}) of
+    try xmpp:try_subtag(Msg, #privilege{}) of
        #privilege{forwarded = #forwarded{xml_els = [SubEl]}} ->
            try xmpp:decode(SubEl, ?NS_CLIENT, [ignore_els]) of
                #message{} = NewMsg ->
@@ -297,7 +297,11 @@ forward_message(#message{to = To} = Msg) ->
                    ejabberd_router:route_error(Msg, Err)
            end;
        _ ->
-           Txt = <<"Invalid <forwarded/> element">>,
+           Txt = <<"No <forwarded/> element found">>,
+           Err = xmpp:err_bad_request(Txt, Lang),
+           ejabberd_router:route_error(Msg, Err)
+    catch _:{xmpp_codec, Why} ->
+           Txt = xmpp:io_format_error(Why),
            Err = xmpp:err_bad_request(Txt, Lang),
            ejabberd_router:route_error(Msg, Err)
     end.
index 77557ee0b6dd5f8a4a4f0182a16cbb4a2170de93..c74d99d384c20934927ec937100a6dbefc3560b4 100644 (file)
@@ -95,7 +95,7 @@ stream_feature_register(Acc, Host) ->
 c2s_unauthenticated_packet(#{ip := IP, server := Server} = State,
                           #iq{type = T, sub_els = [_]} = IQ)
   when T == set; T == get ->
-    case xmpp:get_subtag(IQ, #register{}) of
+    try xmpp:try_subtag(IQ, #register{}) of
        #register{} = Register ->
            {Address, _} = IP,
            IQ1 = xmpp:set_els(IQ, [Register]),
@@ -105,6 +105,11 @@ c2s_unauthenticated_packet(#{ip := IP, server := Server} = State,
            {stop, ejabberd_c2s:send(State, ResIQ1)};
        false ->
            State
+    catch _:{xmpp_codec, Why} ->
+           Txt = xmpp:io_format_error(Why),
+           Lang = maps:get(lang, State),
+           Err = xmpp:make_error(IQ, xmpp:error_bad_request(Txt, Lang)),
+           {stop, ejabberd_c2s:send(State, Err)}
     end;
 c2s_unauthenticated_packet(State, _) ->
     State.