Fix unit test

Author: MarcialRosales

deps/rabbitmq_auth_backend_oauth2/src/rabbit_oauth2_resource_server.erl

@@ -8,6 +8,7 @@
 -module(rabbit_oauth2_resource_server).
 
 -include("oauth2.hrl").
+-include_lib("kernel/include/logger.hrl").
 
 -export([
     resolve_resource_server_from_audience/1,
@@ -166,12 +167,27 @@ find_audience(Audience, ResourceIdList) when is_binary(Audience) ->
     AudList = binary:split(Audience, <<" ">>, [global, trim_all]),
     find_audience(AudList, ResourceIdList);
 find_audience(AudList, ResourceIdList) when is_list(AudList) ->
-    case intersection(AudList, ResourceIdList) of
+    ?LOG_DEBUG("find_audience ~p -> ~p vs ~p", [AudList, 
+        normalize_to_binary_list(AudList), ResourceIdList]),
+    case intersection(normalize_to_binary_list(AudList), ResourceIdList) of
         [One] -> {ok, One};
         [_One|_Tail] -> {error, aud_matched_many_resource_servers_only_one_allowed};
         [] -> {error, no_matching_aud_found}
     end.
 
+-spec normalize_to_binary_list(binary() | string() | [binary()]) -> [binary()].
+normalize_to_binary_list(Input) when is_list(Input) ->
+    case Input of
+        [H | _] when is_binary(H) ->
+            Input; 
+        _ when is_list(Input) ->
+            [unicode:characters_to_binary(Part) || Part <- string:tokens(Input, " ")];
+        _ ->
+            []
+    end;
+normalize_to_binary_list(Input) when is_binary(Input) ->
+    binary:split(Input, <<" ">>, [global]).
+
 -spec translate_error_if_any(
     {ok, resource_server()} |
     {error, not_found} |

deps/rabbitmq_auth_backend_oauth2/test/introspect_http_handler.erl

@@ -12,11 +12,16 @@ init(Req, State) ->
                 <<"401">> -> 
                     {ok, cowboy_req:reply(401, #{}, [], Req), State};
                 <<"active">> -> 
-                    Body = rabbit_json:encode([{"active", true}, {"scope", "rabbitmq.configure:*/* rabbitmq.write:*/* rabbitmq.read:*/*"}]),
+                    Body = rabbit_json:encode([
+                        {"active", true}, 
+                        {"aud", <<"rabbitmq">>},
+                        {"scope", <<"rabbitmq.configure:*/* rabbitmq.write:*/* rabbitmq.read:*/*">>}]),
                     {ok, cowboy_req:reply(200, #{<<"content-type">> => <<"application/json">>}, 
                         Body, Req), State};
                 <<"inactive">> -> 
-                    Body = rabbit_json:encode([{"active", false}, {"scope", "rabbitmq.configure:*/* rabbitmq.write:*/* rabbitmq.read:*/*"}]),
+                    Body = rabbit_json:encode([
+                        {"active", false}, 
+                        {"scope", <<"rabbitmq.configure:*/* rabbitmq.write:*/* rabbitmq.read:*/*">>}]),
                     {ok, cowboy_req:reply(200, #{<<"content-type">> => <<"application/json">>}, 
                         Body, Req), State}
             end;