Add test case

and remove inner case statement since we only want
rabbit_amqqueue:declare/6 to be protected.

Author: ansd

deps/rabbit/src/rabbit_amqp_management.erl

@@ -126,6 +126,7 @@ handle_http_req(HttpMethod = <<"PUT">>,
     ok = prohibit_reserved_amq(QName),
     PermCache1 = check_resource_access(QName, configure, User, PermCache0),
     rabbit_core_metrics:queue_declared(QName),
+
     {Q1, NumMsgs, NumConsumers, StatusCode, PermCache} =
     case rabbit_amqqueue:with(
            QName,
@@ -146,36 +147,34 @@ handle_http_req(HttpMethod = <<"PUT">>,
             Result;
         {error, not_found} ->
             PermCache2 = check_dead_letter_exchange(QName, QArgs, User, PermCache1),
-            try case rabbit_amqqueue:declare(
-              QName, Durable, AutoDelete, QArgs, Owner, Username) of
-                  {new, Q} ->
+            try rabbit_amqqueue:declare(
+                  QName, Durable, AutoDelete, QArgs, Owner, Username) of
+                {new, Q} ->
                     rabbit_core_metrics:queue_created(QName),
                     {Q, 0, 0, <<"201">>, PermCache2};
-                  {owner_died, Q} ->
+                {owner_died, Q} ->
                     %% Presumably our own days are numbered since the
                     %% connection has died. Pretend the queue exists though,
                     %% just so nothing fails.
                     {Q, 0, 0, <<"201">>, PermCache2};
-                  {absent, Q, Reason} ->
+                {absent, Q, Reason} ->
                     absent(Q, Reason);
-                  {existing, _Q} ->
+                {existing, _Q} ->
                     %% Must have been created in the meantime. Loop around again.
                     handle_http_req(HttpMethod, PathSegments, Query, ReqPayload,
-                      Vhost, User, ConnPid, {PermCache2, TopicPermCache});
-                  {error, queue_limit_exceeded, Reason, ReasonArgs} ->
+                                    Vhost, User, ConnPid, {PermCache2, TopicPermCache});
+                {error, queue_limit_exceeded, Reason, ReasonArgs} ->
                     throw(<<"403">>,
-                      Reason,
-                      ReasonArgs);
-                  {protocol_error, _ErrorType, Reason, ReasonArgs} ->
+                          Reason,
+                          ReasonArgs);
+                {protocol_error, _ErrorType, Reason, ReasonArgs} ->
                     throw(<<"400">>, Reason, ReasonArgs)
-                end
             catch exit:#amqp_error{name = precondition_failed,
-                explanation = Expl} ->
-                throw(<<"409">>, Expl, []);
-              exit:#amqp_error{explanation = Expl} ->
-                throw(<<"400">>, Expl, [])
+                                   explanation = Expl} ->
+                      throw(<<"409">>, Expl, []);
+                  exit:#amqp_error{explanation = Expl} ->
+                      throw(<<"400">>, Expl, [])
             end;
-
         {error, {absent, Q, Reason}} ->
             absent(Q, Reason)
     end,

deps/rabbitmq_amqp_client/test/management_SUITE.erl

@@ -59,6 +59,7 @@ groups() ->
        declare_queue_inequivalent_fields,
        declare_queue_inequivalent_exclusive,
        declare_queue_invalid_field,
+       declare_queue_invalid_arg,
        declare_default_exchange,
        declare_exchange_amq_prefix,
        declare_exchange_line_feed,
@@ -528,6 +529,20 @@ declare_queue_invalid_field(Config) ->
        amqp10_msg:body(Resp)),
     ok = cleanup(Init).
 
+declare_queue_invalid_arg(Config) ->
+    Init = {_, LinkPair} = init(Config),
+    QName = <<"👌"/utf8>>,
+    QProps = #{arguments => #{<<"x-queue-type">> => {utf8, <<"stream">>},
+                              <<"x-dead-letter-exchange">> => {utf8, <<"dlx is invalid for stream">>}}},
+    {error, Resp} = rabbitmq_amqp_client:declare_queue(LinkPair, QName, QProps),
+    ?assertMatch(#{subject := <<"409">>}, amqp10_msg:properties(Resp)),
+    ?assertEqual(
+       #'v1_0.amqp_value'{
+          content = {utf8, <<"invalid arg 'x-dead-letter-exchange' for queue '", QName/binary,
+                             "' in vhost '/' of queue type rabbit_stream_queue">>}},
+       amqp10_msg:body(Resp)),
+    ok = cleanup(Init).
+
 declare_default_exchange(Config) ->
     Init = {_, LinkPair} = init(Config),
     {error, Resp} = rabbitmq_amqp_client:declare_exchange(LinkPair, ?DEFAULT_EXCHANGE, #{}),