1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
|
%% This Source Code Form is subject to the terms of the Mozilla Public
%% License, v. 2.0. If a copy of the MPL was not distributed with this
%% file, You can obtain one at https://mozilla.org/MPL/2.0/.
%%
%% Copyright (c) 2007-2020 VMware, Inc. or its affiliates. All rights reserved.
%%
-module(rabbit_auth_mechanism_ssl).
-behaviour(rabbit_auth_mechanism).
-export([description/0, should_offer/1, init/1, handle_response/2]).
-include_lib("rabbit_common/include/rabbit.hrl").
-include_lib("public_key/include/public_key.hrl").
-rabbit_boot_step({?MODULE,
[{description, "external TLS peer verification-based authentication mechanism"},
{mfa, {rabbit_registry, register,
[auth_mechanism, <<"EXTERNAL">>, ?MODULE]}},
{requires, rabbit_registry},
{enables, kernel_ready},
{cleanup, {rabbit_registry, unregister,
[auth_mechanism, <<"EXTERNAL">>]}}]}).
-record(state, {username = undefined}).
description() ->
[{description, <<"TLS peer verification-based authentication plugin. Used in combination with the EXTERNAL SASL mechanism.">>}].
should_offer(Sock) ->
%% SASL EXTERNAL. SASL says EXTERNAL means "use credentials
%% established by means external to the mechanism". The username
%% is extracted from the the client certificate.
case rabbit_net:peercert(Sock) of
nossl -> false;
%% We offer EXTERNAL even if there is no peercert since that leads to
%% a more comprehensible error message: authentication is refused
%% below with "no peer certificate" rather than have the client fail
%% to negotiate an authentication mechanism.
{error, no_peercert} -> true;
{ok, _} -> true
end.
init(Sock) ->
Username = case rabbit_net:peercert(Sock) of
{ok, C} ->
case rabbit_ssl:peer_cert_auth_name(C) of
unsafe -> {refused, none, "TLS configuration is unsafe", []};
not_found -> {refused, none, "no name found", []};
Name -> rabbit_data_coercion:to_binary(Name)
end;
{error, no_peercert} ->
{refused, none, "connection peer presented no TLS (x.509) certificate", []};
nossl ->
{refused, none, "not a TLS-enabled connection", []}
end,
rabbit_log:debug("auth mechanism TLS extracted username '~s' from peer certificate", [Username]),
#state{username = Username}.
handle_response(_Response, #state{username = Username}) ->
case Username of
{refused, _, _, _} = E ->
E;
_ ->
rabbit_access_control:check_user_login(Username, [])
end.
|