%%--------------------------------------------------------------------
%% Copyright (c) 2021-2024 EMQ Technologies Co., Ltd. All Rights Reserved.
%%
%% Licensed under the Apache License, Version 2.0 (the "License");
%% you may not use this file except in compliance with the License.
%% You may obtain a copy of the License at
%%
%%     http://www.apache.org/licenses/LICENSE-2.0
%%
%% Unless required by applicable law or agreed to in writing, software
%% distributed under the License is distributed on an "AS IS" BASIS,
%% WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
%% See the License for the specific language governing permissions and
%% limitations under the License.
%%--------------------------------------------------------------------

-module(emqx_gateway_conf_SUITE).

-compile(export_all).
-compile(nowarn_export_all).

-import(
    emqx_gateway_test_utils,
    [
        assert_confs/2,
        maybe_unconvert_listeners/1
    ]
).

-include_lib("eunit/include/eunit.hrl").

%%--------------------------------------------------------------------
%% Setups
%%--------------------------------------------------------------------

all() ->
    emqx_common_test_helpers:all(?MODULE).

init_per_suite(Conf) ->
    emqx_gateway_test_utils:load_all_gateway_apps(),
    emqx_common_test_helpers:load_config(emqx_gateway_schema, <<"gateway {}">>),
    emqx_common_test_helpers:start_apps([emqx_conf, emqx_auth, emqx_auth_mnesia, emqx_gateway]),
    Conf.

end_per_suite(_Conf) ->
    emqx_common_test_helpers:stop_apps([emqx_gateway, emqx_auth, emqx_auth_mnesia, emqx_conf]),
    emqx_config:delete_override_conf_files().

init_per_testcase(_CaseName, Conf) ->
    _ = emqx_gateway_conf:unload_gateway(stomp),
    ct:sleep(500),
    Conf.

%%--------------------------------------------------------------------
%% Cases
%%--------------------------------------------------------------------

-define(SVR_CA, <<
    "-----BEGIN CERTIFICATE-----\n"
    "MIIDUTCCAjmgAwIBAgIJAPPYCjTmxdt/MA0GCSqGSIb3DQEBCwUAMD8xCzAJBgNV\n"
    "BAYTAkNOMREwDwYDVQQIDAhoYW5nemhvdTEMMAoGA1UECgwDRU1RMQ8wDQYDVQQD\n"
    "DAZSb290Q0EwHhcNMjAwNTA4MDgwNjUyWhcNMzAwNTA2MDgwNjUyWjA/MQswCQYD\n"
    "VQQGEwJDTjERMA8GA1UECAwIaGFuZ3pob3UxDDAKBgNVBAoMA0VNUTEPMA0GA1UE\n"
    "AwwGUm9vdENBMIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAzcgVLex1\n"
    "EZ9ON64EX8v+wcSjzOZpiEOsAOuSXOEN3wb8FKUxCdsGrsJYB7a5VM/Jot25Mod2\n"
    "juS3OBMg6r85k2TWjdxUoUs+HiUB/pP/ARaaW6VntpAEokpij/przWMPgJnBF3Ur\n"
    "MjtbLayH9hGmpQrI5c2vmHQ2reRZnSFbY+2b8SXZ+3lZZgz9+BaQYWdQWfaUWEHZ\n"
    "uDaNiViVO0OT8DRjCuiDp3yYDj3iLWbTA/gDL6Tf5XuHuEwcOQUrd+h0hyIphO8D\n"
    "tsrsHZ14j4AWYLk1CPA6pq1HIUvEl2rANx2lVUNv+nt64K/Mr3RnVQd9s8bK+TXQ\n"
    "KGHd2Lv/PALYuwIDAQABo1AwTjAdBgNVHQ4EFgQUGBmW+iDzxctWAWxmhgdlE8Pj\n"
    "EbQwHwYDVR0jBBgwFoAUGBmW+iDzxctWAWxmhgdlE8PjEbQwDAYDVR0TBAUwAwEB\n"
    "/zANBgkqhkiG9w0BAQsFAAOCAQEAGbhRUjpIred4cFAFJ7bbYD9hKu/yzWPWkMRa\n"
    "ErlCKHmuYsYk+5d16JQhJaFy6MGXfLgo3KV2itl0d+OWNH0U9ULXcglTxy6+njo5\n"
    "CFqdUBPwN1jxhzo9yteDMKF4+AHIxbvCAJa17qcwUKR5MKNvv09C6pvQDJLzid7y\n"
    "E2dkgSuggik3oa0427KvctFf8uhOV94RvEDyqvT5+pgNYZ2Yfga9pD/jjpoHEUlo\n"
    "88IGU8/wJCx3Ds2yc8+oBg/ynxG8f/HmCC1ET6EHHoe2jlo8FpU/SgGtghS1YL30\n"
    "IWxNsPrUP+XsZpBJy/mvOhE5QXo6Y35zDqqj8tI7AGmAWu22jg==\n"
    "-----END CERTIFICATE-----\n"
>>).

-define(SVR_CERT, <<
    "-----BEGIN CERTIFICATE-----\n"
    "MIIDEzCCAfugAwIBAgIBAjANBgkqhkiG9w0BAQsFADA/MQswCQYDVQQGEwJDTjER\n"
    "MA8GA1UECAwIaGFuZ3pob3UxDDAKBgNVBAoMA0VNUTEPMA0GA1UEAwwGUm9vdENB\n"
    "MB4XDTIwMDUwODA4MDcwNVoXDTMwMDUwNjA4MDcwNVowPzELMAkGA1UEBhMCQ04x\n"
    "ETAPBgNVBAgMCGhhbmd6aG91MQwwCgYDVQQKDANFTVExDzANBgNVBAMMBlNlcnZl\n"
    "cjCCASIwDQYJKoZIhvcNAQEBBQADggEPADCCAQoCggEBALNeWT3pE+QFfiRJzKmn\n"
    "AMUrWo3K2j/Tm3+Xnl6WLz67/0rcYrJbbKvS3uyRP/stXyXEKw9CepyQ1ViBVFkW\n"
    "Aoy8qQEOWFDsZc/5UzhXUnb6LXr3qTkFEjNmhj+7uzv/lbBxlUG1NlYzSeOB6/RT\n"
    "8zH/lhOeKhLnWYPXdXKsa1FL6ij4X8DeDO1kY7fvAGmBn/THh1uTpDizM4YmeI+7\n"
    "4dmayA5xXvARte5h4Vu5SIze7iC057N+vymToMk2Jgk+ZZFpyXrnq+yo6RaD3ANc\n"
    "lrc4FbeUQZ5a5s5Sxgs9a0Y3WMG+7c5VnVXcbjBRz/aq2NtOnQQjikKKQA8GF080\n"
    "BQkCAwEAAaMaMBgwCQYDVR0TBAIwADALBgNVHQ8EBAMCBeAwDQYJKoZIhvcNAQEL\n"
    "BQADggEBAJefnMZpaRDHQSNUIEL3iwGXE9c6PmIsQVE2ustr+CakBp3TZ4l0enLt\n"
    "iGMfEVFju69cO4oyokWv+hl5eCMkHBf14Kv51vj448jowYnF1zmzn7SEzm5Uzlsa\n"
    "sqjtAprnLyof69WtLU1j5rYWBuFX86yOTwRAFNjm9fvhAcrEONBsQtqipBWkMROp\n"
    "iUYMkRqbKcQMdwxov+lHBYKq9zbWRoqLROAn54SRqgQk6c15JdEfgOOjShbsOkIH\n"
    "UhqcwRkQic7n1zwHVGVDgNIZVgmJ2IdIWBlPEC7oLrRrBD/X1iEEXtKab6p5o22n\n"
    "KB5mN+iQaE+Oe2cpGKZJiJRdM+IqDDQ=\n"
    "-----END CERTIFICATE-----\n"
>>).

-define(SVR_KEY, <<
    "-----BEGIN RSA PRIVATE KEY-----\n"
    "MIIEowIBAAKCAQEAs15ZPekT5AV+JEnMqacAxStajcraP9Obf5eeXpYvPrv/Stxi\n"
    "sltsq9Le7JE/+y1fJcQrD0J6nJDVWIFUWRYCjLypAQ5YUOxlz/lTOFdSdvotevep\n"
    "OQUSM2aGP7u7O/+VsHGVQbU2VjNJ44Hr9FPzMf+WE54qEudZg9d1cqxrUUvqKPhf\n"
    "wN4M7WRjt+8AaYGf9MeHW5OkOLMzhiZ4j7vh2ZrIDnFe8BG17mHhW7lIjN7uILTn\n"
    "s36/KZOgyTYmCT5lkWnJeuer7KjpFoPcA1yWtzgVt5RBnlrmzlLGCz1rRjdYwb7t\n"
    "zlWdVdxuMFHP9qrY206dBCOKQopADwYXTzQFCQIDAQABAoIBAQCuvCbr7Pd3lvI/\n"
    "n7VFQG+7pHRe1VKwAxDkx2t8cYos7y/QWcm8Ptwqtw58HzPZGWYrgGMCRpzzkRSF\n"
    "V9g3wP1S5Scu5C6dBu5YIGc157tqNGXB+SpdZddJQ4Nc6yGHXYERllT04ffBGc3N\n"
    "WG/oYS/1cSteiSIrsDy/91FvGRCi7FPxH3wIgHssY/tw69s1Cfvaq5lr2NTFzxIG\n"
    "xCvpJKEdSfVfS9I7LYiymVjst3IOR/w76/ZFY9cRa8ZtmQSWWsm0TUpRC1jdcbkm\n"
    "ZoJptYWlP+gSwx/fpMYftrkJFGOJhHJHQhwxT5X/ajAISeqjjwkWSEJLwnHQd11C\n"
    "Zy2+29lBAoGBANlEAIK4VxCqyPXNKfoOOi5dS64NfvyH4A1v2+KaHWc7lqaqPN49\n"
    "ezfN2n3X+KWx4cviDD914Yc2JQ1vVJjSaHci7yivocDo2OfZDmjBqzaMp/y+rX1R\n"
    "/f3MmiTqMa468rjaxI9RRZu7vDgpTR+za1+OBCgMzjvAng8dJuN/5gjlAoGBANNY\n"
    "uYPKtearBmkqdrSV7eTUe49Nhr0XotLaVBH37TCW0Xv9wjO2xmbm5Ga/DCtPIsBb\n"
    "yPeYwX9FjoasuadUD7hRvbFu6dBa0HGLmkXRJZTcD7MEX2Lhu4BuC72yDLLFd0r+\n"
    "Ep9WP7F5iJyagYqIZtz+4uf7gBvUDdmvXz3sGr1VAoGAdXTD6eeKeiI6PlhKBztF\n"
    "zOb3EQOO0SsLv3fnodu7ZaHbUgLaoTMPuB17r2jgrYM7FKQCBxTNdfGZmmfDjlLB\n"
    "0xZ5wL8ibU30ZXL8zTlWPElST9sto4B+FYVVF/vcG9sWeUUb2ncPcJ/Po3UAktDG\n"
    "jYQTTyuNGtSJHpad/YOZctkCgYBtWRaC7bq3of0rJGFOhdQT9SwItN/lrfj8hyHA\n"
    "OjpqTV4NfPmhsAtu6j96OZaeQc+FHvgXwt06cE6Rt4RG4uNPRluTFgO7XYFDfitP\n"
    "vCppnoIw6S5BBvHwPP+uIhUX2bsi/dm8vu8tb+gSvo4PkwtFhEr6I9HglBKmcmog\n"
    "q6waEQKBgHyecFBeM6Ls11Cd64vborwJPAuxIW7HBAFj/BS99oeG4TjBx4Sz2dFd\n"
    "rzUibJt4ndnHIvCN8JQkjNG14i9hJln+H3mRss8fbZ9vQdqG+2vOWADYSzzsNI55\n"
    "RFY7JjluKcVkp/zCDeUxTU3O6sS+v6/3VE11Cob6OYQx3lN5wrZ3\n"
    "-----END RSA PRIVATE KEY-----\n"
>>).

-define(SVR_CERT2, <<
    "-----BEGIN CERTIFICATE-----\n"
    "MIIDEzCCAfugAwIBAgIBATANBgkqhkiG9w0BAQsFADA/MQswCQYDVQQGEwJDTjER\n"
    "MA8GA1UECAwIaGFuZ3pob3UxDDAKBgNVBAoMA0VNUTEPMA0GA1UEAwwGUm9vdENB\n"
    "MB4XDTIwMDUwODA4MDY1N1oXDTMwMDUwNjA4MDY1N1owPzELMAkGA1UEBhMCQ04x\n"
    "ETAPBgNVBAgMCGhhbmd6aG91MQwwCgYDVQQKDANFTVExDzANBgNVBAMMBkNsaWVu\n"
    "dDCCASIwDQYJKoZIhvcNAQEBBQADggEPADCCAQoCggEBAMy4hoksKcZBDbY680u6\n"
    "TS25U51nuB1FBcGMlF9B/t057wPOlxF/OcmbxY5MwepS41JDGPgulE1V7fpsXkiW\n"
    "1LUimYV/tsqBfymIe0mlY7oORahKji7zKQ2UBIVFhdlvQxunlIDnw6F9popUgyHt\n"
    "dMhtlgZK8oqRwHxO5dbfoukYd6J/r+etS5q26sgVkf3C6dt0Td7B25H9qW+f7oLV\n"
    "PbcHYCa+i73u9670nrpXsC+Qc7Mygwa2Kq/jwU+ftyLQnOeW07DuzOwsziC/fQZa\n"
    "nbxR+8U9FNftgRcC3uP/JMKYUqsiRAuaDokARZxVTV5hUElfpO6z6/NItSDvvh3i\n"
    "eikCAwEAAaMaMBgwCQYDVR0TBAIwADALBgNVHQ8EBAMCBeAwDQYJKoZIhvcNAQEL\n"
    "BQADggEBABchYxKo0YMma7g1qDswJXsR5s56Czx/I+B41YcpMBMTrRqpUC0nHtLk\n"
    "M7/tZp592u/tT8gzEnQjZLKBAhFeZaR3aaKyknLqwiPqJIgg0pgsBGITrAK3Pv4z\n"
    "5/YvAJJKgTe5UdeTz6U4lvNEux/4juZ4pmqH4qSFJTOzQS7LmgSmNIdd072rwXBd\n"
    "UzcSHzsJgEMb88u/LDLjj1pQ7AtZ4Tta8JZTvcgBFmjB0QUi6fgkHY6oGat/W4kR\n"
    "jSRUBlMUbM/drr2PVzRc2dwbFIl3X+ZE6n5Sl3ZwRAC/s92JU6CPMRW02muVu6xl\n"
    "goraNgPISnrbpR6KjxLZkVembXzjNNc=\n"
    "-----END CERTIFICATE-----\n"
>>).

-define(SVR_KEY2, <<
    "-----BEGIN RSA PRIVATE KEY-----\n"
    "MIIEpAIBAAKCAQEAzLiGiSwpxkENtjrzS7pNLblTnWe4HUUFwYyUX0H+3TnvA86X\n"
    "EX85yZvFjkzB6lLjUkMY+C6UTVXt+mxeSJbUtSKZhX+2yoF/KYh7SaVjug5FqEqO\n"
    "LvMpDZQEhUWF2W9DG6eUgOfDoX2milSDIe10yG2WBkryipHAfE7l1t+i6Rh3on+v\n"
    "561LmrbqyBWR/cLp23RN3sHbkf2pb5/ugtU9twdgJr6Lve73rvSeulewL5BzszKD\n"
    "BrYqr+PBT5+3ItCc55bTsO7M7CzOIL99BlqdvFH7xT0U1+2BFwLe4/8kwphSqyJE\n"
    "C5oOiQBFnFVNXmFQSV+k7rPr80i1IO++HeJ6KQIDAQABAoIBAGWgvPjfuaU3qizq\n"
    "uti/FY07USz0zkuJdkANH6LiSjlchzDmn8wJ0pApCjuIE0PV/g9aS8z4opp5q/gD\n"
    "UBLM/a8mC/xf2EhTXOMrY7i9p/I3H5FZ4ZehEqIw9sWKK9YzC6dw26HabB2BGOnW\n"
    "5nozPSQ6cp2RGzJ7BIkxSZwPzPnVTgy3OAuPOiJytvK+hGLhsNaT+Y9bNDvplVT2\n"
    "ZwYTV8GlHZC+4b2wNROILm0O86v96O+Qd8nn3fXjGHbMsAnONBq10bZS16L4fvkH\n"
    "5G+W/1PeSXmtZFppdRRDxIW+DWcXK0D48WRliuxcV4eOOxI+a9N2ZJZZiNLQZGwg\n"
    "w3A8+mECgYEA8HuJFrlRvdoBe2U/EwUtG74dcyy30L4yEBnN5QscXmEEikhaQCfX\n"
    "Wm6EieMcIB/5I5TQmSw0cmBMeZjSXYoFdoI16/X6yMMuATdxpvhOZGdUGXxhAH+x\n"
    "xoTUavWZnEqW3fkUU71kT5E2f2i+0zoatFESXHeslJyz85aAYpP92H0CgYEA2e5A\n"
    "Yozt5eaA1Gyhd8SeptkEU4xPirNUnVQHStpMWUb1kzTNXrPmNWccQ7JpfpG6DcYl\n"
    "zUF6p6mlzY+zkMiyPQjwEJlhiHM2NlL1QS7td0R8ewgsFoyn8WsBI4RejWrEG9td\n"
    "EDniuIw+pBFkcWthnTLHwECHdzgquToyTMjrBB0CgYEA28tdGbrZXhcyAZEhHAZA\n"
    "Gzog+pKlkpEzeonLKIuGKzCrEKRecIK5jrqyQsCjhS0T7ZRnL4g6i0s+umiV5M5w\n"
    "fcc292pEA1h45L3DD6OlKplSQVTv55/OYS4oY3YEJtf5mfm8vWi9lQeY8sxOlQpn\n"
    "O+VZTdBHmTC8PGeTAgZXHZUCgYA6Tyv88lYowB7SN2qQgBQu8jvdGtqhcs/99GCr\n"
    "H3N0I69LPsKAR0QeH8OJPXBKhDUywESXAaEOwS5yrLNP1tMRz5Vj65YUCzeDG3kx\n"
    "gpvY4IMp7ArX0bSRvJ6mYSFnVxy3k174G3TVCfksrtagHioVBGQ7xUg5ltafjrms\n"
    "n8l55QKBgQDVzU8tQvBVqY8/1lnw11Vj4fkE/drZHJ5UkdC1eenOfSWhlSLfUJ8j\n"
    "ds7vEWpRPPoVuPZYeR1y78cyxKe1GBx6Wa2lF5c7xjmiu0xbRnrxYeLolce9/ntp\n"
    "asClqpnHT8/VJYTD7Kqj0fouTTZf0zkig/y+2XERppd8k+pSKjUCPQ==\n"
    "-----END RSA PRIVATE KEY-----\n"
>>).

-define(CONF_STOMP_BAISC_1, #{
    <<"idle_timeout">> => <<"10s">>,
    <<"mountpoint">> => <<"t/">>,
    <<"frame">> =>
        #{
            <<"max_headers">> => 20,
            <<"max_headers_length">> => 2000,
            <<"max_body_length">> => 2000
        }
}).
-define(CONF_STOMP_BAISC_2, #{
    <<"idle_timeout">> => <<"20s">>,
    <<"mountpoint">> => <<"t2/">>,
    <<"frame">> =>
        #{
            <<"max_headers">> => 30,
            <<"max_headers_length">> => 3000,
            <<"max_body_length">> => 3000
        }
}).
-define(CONF_STOMP_LISTENER_1, #{<<"bind">> => <<"61613">>}).
-define(CONF_STOMP_LISTENER_2, #{<<"bind">> => <<"61614">>}).
-define(CONF_STOMP_LISTENER_SSL, #{
    <<"bind">> => <<"61614">>,
    <<"ssl_options">> =>
        #{
            <<"cacertfile">> => ?SVR_CA,
            <<"certfile">> => ?SVR_CERT,
            <<"keyfile">> => ?SVR_KEY
        }
}).
-define(CONF_STOMP_LISTENER_SSL_2, #{
    <<"bind">> => <<"61614">>,
    <<"ssl_options">> =>
        #{
            <<"cacertfile">> => ?SVR_CA,
            <<"certfile">> => ?SVR_CERT2,
            <<"keyfile">> => ?SVR_KEY2
        }
}).
-define(CERTS_PATH(CertName), filename:join(["../../lib/emqx/etc/certs/", CertName])).
-define(CONF_STOMP_LISTENER_SSL_PATH, #{
    <<"bind">> => <<"61614">>,
    <<"ssl_options">> =>
        #{
            <<"cacertfile">> => ?CERTS_PATH("cacert.pem"),
            <<"certfile">> => ?CERTS_PATH("cert.pem"),
            <<"keyfile">> => ?CERTS_PATH("key.pem")
        }
}).
-define(CONF_STOMP_AUTHN_1, #{
    <<"mechanism">> => <<"password_based">>,
    <<"backend">> => <<"built_in_database">>,
    <<"user_id_type">> => <<"clientid">>
}).
-define(CONF_STOMP_AUTHN_2, #{
    <<"mechanism">> => <<"password_based">>,
    <<"backend">> => <<"built_in_database">>,
    <<"user_id_type">> => <<"username">>
}).

t_load_unload_gateway(_) ->
    StompConf1 = compose(
        ?CONF_STOMP_BAISC_1,
        ?CONF_STOMP_AUTHN_1,
        ?CONF_STOMP_LISTENER_1
    ),
    StompConf2 = compose(
        ?CONF_STOMP_BAISC_2,
        ?CONF_STOMP_AUTHN_1,
        ?CONF_STOMP_LISTENER_1
    ),
    {ok, _} = emqx_gateway_conf:load_gateway(stomp, StompConf1),
    ?assertMatch(
        {error, {badres, #{reason := already_exist}}},
        emqx_gateway_conf:load_gateway(stomp, StompConf1)
    ),
    assert_confs(StompConf1, emqx:get_raw_config([gateway, stomp])),

    {ok, _} = emqx_gateway_conf:update_gateway(stomp, StompConf2),
    assert_confs(StompConf2, emqx:get_raw_config([gateway, stomp])),

    ok = emqx_gateway_conf:unload_gateway(stomp),
    ok = emqx_gateway_conf:unload_gateway(stomp),

    ?assertMatch(
        {error, {badres, #{reason := not_found}}},
        emqx_gateway_conf:update_gateway(stomp, StompConf2)
    ),

    ?assertException(
        error,
        {config_not_found, [<<"gateway">>, stomp]},
        emqx:get_raw_config([gateway, stomp])
    ),
    %% test update([gateway], Conf)
    Raw0 = emqx:get_raw_config([gateway]),
    #{<<"listeners">> := StompConfL1} = StompConf1,
    StompConf11 = StompConf1#{
        <<"listeners">> => emqx_gateway_conf:unconvert_listeners(StompConfL1)
    },
    #{<<"listeners">> := StompConfL2} = StompConf2,
    StompConf22 = StompConf2#{
        <<"listeners">> => emqx_gateway_conf:unconvert_listeners(StompConfL2)
    },
    Raw1 = Raw0#{<<"stomp">> => StompConf11},
    Raw2 = Raw0#{<<"stomp">> => StompConf22},
    ?assertMatch({ok, _}, emqx:update_config([gateway], Raw1)),
    assert_confs(StompConf1, emqx:get_raw_config([gateway, stomp])),
    ?assertMatch(
        #{
            config := #{
                authentication := #{backend := built_in_database, enable := true},
                listeners := #{tcp := #{default := #{bind := 61613}}},
                mountpoint := <<"t/">>,
                idle_timeout := 10000
            }
        },
        emqx_gateway:lookup('stomp')
    ),
    ?assertMatch({ok, _}, emqx:update_config([gateway], Raw2)),
    assert_confs(StompConf2, emqx:get_raw_config([gateway, stomp])),
    ?assertMatch(
        #{
            config :=
                #{
                    authentication := #{backend := built_in_database, enable := true},
                    listeners := #{tcp := #{default := #{bind := 61613}}},
                    idle_timeout := 20000,
                    mountpoint := <<"t2/">>
                }
        },
        emqx_gateway:lookup('stomp')
    ),
    %% reset
    ?assertMatch({ok, _}, emqx:update_config([gateway], Raw0)),
    ?assertEqual(undefined, emqx_gateway:lookup('stomp')),
    ok.

t_load_remove_authn(_) ->
    StompConf = compose_listener(?CONF_STOMP_BAISC_1, ?CONF_STOMP_LISTENER_1),

    {ok, _} = emqx_gateway_conf:load_gateway(<<"stomp">>, StompConf),
    assert_confs(StompConf, emqx:get_raw_config([gateway, stomp])),
    ct:sleep(500),

    {ok, _} = emqx_gateway_conf:add_authn(<<"stomp">>, ?CONF_STOMP_AUTHN_1),
    assert_confs(
        maps:put(<<"authentication">>, ?CONF_STOMP_AUTHN_1, StompConf),
        emqx:get_raw_config([gateway, stomp])
    ),

    {ok, _} = emqx_gateway_conf:update_authn(<<"stomp">>, ?CONF_STOMP_AUTHN_2),
    assert_confs(
        maps:put(<<"authentication">>, ?CONF_STOMP_AUTHN_2, StompConf),
        emqx:get_raw_config([gateway, stomp])
    ),

    ok = emqx_gateway_conf:remove_authn(<<"stomp">>),

    ?assertMatch(
        {error, {badres, #{reason := not_found}}},
        emqx_gateway_conf:update_authn(<<"stomp">>, ?CONF_STOMP_AUTHN_2)
    ),

    ?assertException(
        error,
        {config_not_found, [<<"gateway">>, stomp, authentication]},
        emqx:get_raw_config([gateway, stomp, authentication])
    ),
    %% test update([gateway], Conf)
    Raw0 = emqx:get_raw_config([gateway]),
    #{<<"listeners">> := StompConfL} = StompConf,
    StompConf1 = StompConf#{
        <<"listeners">> => emqx_gateway_conf:unconvert_listeners(StompConfL),
        <<"authentication">> => ?CONF_STOMP_AUTHN_1
    },
    Raw1 = maps:put(<<"stomp">>, StompConf1, Raw0),
    ?assertMatch({ok, _}, emqx:update_config([gateway], Raw1)),
    assert_confs(StompConf1, emqx:get_raw_config([gateway, stomp])),
    ?assertMatch(
        #{
            stomp :=
                #{
                    authn := <<"password_based:built_in_database">>,
                    listeners := [#{authn := <<"undefined">>, type := tcp}],
                    num_clients := 0
                }
        },
        emqx_gateway:get_basic_usage_info()
    ),
    %% reset(remove authn)
    ?assertMatch({ok, _}, emqx:update_config([gateway], Raw0)),
    ?assertMatch(
        #{
            stomp :=
                #{
                    authn := <<"undefined">>,
                    listeners := [#{authn := <<"undefined">>, type := tcp}],
                    num_clients := 0
                }
        },
        emqx_gateway:get_basic_usage_info()
    ),
    ok.

t_load_remove_listeners(_) ->
    StompConf = compose_authn(?CONF_STOMP_BAISC_1, ?CONF_STOMP_AUTHN_1),

    {ok, _} = emqx_gateway_conf:load_gateway(<<"stomp">>, StompConf),
    assert_confs(StompConf, emqx:get_raw_config([gateway, stomp])),
    ct:sleep(500),

    {ok, _} = emqx_gateway_conf:add_listener(
        <<"stomp">>,
        {<<"tcp">>, <<"default">>},
        ?CONF_STOMP_LISTENER_1
    ),

    assert_confs(
        maps:merge(StompConf, listener(?CONF_STOMP_LISTENER_1)),
        emqx:get_raw_config([gateway, stomp])
    ),

    {ok, _} = emqx_gateway_conf:update_listener(
        <<"stomp">>,
        {<<"tcp">>, <<"default">>},
        ?CONF_STOMP_LISTENER_2
    ),
    assert_confs(
        maps:merge(StompConf, listener(?CONF_STOMP_LISTENER_2)),
        emqx:get_raw_config([gateway, stomp])
    ),

    ok = emqx_gateway_conf:remove_listener(
        <<"stomp">>, {<<"tcp">>, <<"default">>}
    ),

    ?assertMatch(
        {error, {badres, #{reason := not_found}}},
        emqx_gateway_conf:update_listener(
            <<"stomp">>, {<<"tcp">>, <<"default">>}, ?CONF_STOMP_LISTENER_2
        )
    ),

    ?assertException(
        error,
        {config_not_found, [<<"gateway">>, stomp, listeners, tcp, default]},
        emqx:get_raw_config([gateway, stomp, listeners, tcp, default])
    ),
    %% test update([gateway], Conf)
    Raw0 = emqx:get_raw_config([gateway]),
    Raw1 = emqx_utils_maps:deep_put(
        [<<"stomp">>, <<"listeners">>, <<"tcp">>, <<"default">>], Raw0, ?CONF_STOMP_LISTENER_1
    ),
    ?assertMatch({ok, _}, emqx:update_config([gateway], Raw1)),
    assert_confs(
        maps:merge(StompConf, listener(?CONF_STOMP_LISTENER_1)),
        emqx:get_raw_config([gateway, stomp])
    ),
    ?assertMatch(
        #{
            stomp :=
                #{
                    authn := <<"password_based:built_in_database">>,
                    listeners := [#{authn := <<"undefined">>, type := tcp}],
                    num_clients := 0
                }
        },
        emqx_gateway:get_basic_usage_info()
    ),
    Raw2 = emqx_utils_maps:deep_put(
        [<<"stomp">>, <<"listeners">>, <<"tcp">>, <<"default">>], Raw0, ?CONF_STOMP_LISTENER_2
    ),
    ?assertMatch({ok, _}, emqx:update_config([gateway], Raw2)),
    assert_confs(
        maps:merge(StompConf, listener(?CONF_STOMP_LISTENER_2)),
        emqx:get_raw_config([gateway, stomp])
    ),
    ?assertMatch(
        #{
            stomp :=
                #{
                    authn := <<"password_based:built_in_database">>,
                    listeners := [#{authn := <<"undefined">>, type := tcp}],
                    num_clients := 0
                }
        },
        emqx_gateway:get_basic_usage_info()
    ),
    %% reset(remove listener)
    ?assertMatch({ok, _}, emqx:update_config([gateway], Raw0)),
    ?assertMatch(
        #{
            stomp :=
                #{
                    authn := <<"password_based:built_in_database">>,
                    listeners := [],
                    num_clients := 0
                }
        },
        emqx_gateway:get_basic_usage_info()
    ),
    ok.

t_load_remove_listener_authn(_) ->
    StompConf = compose_listener(
        ?CONF_STOMP_BAISC_1,
        ?CONF_STOMP_LISTENER_1
    ),
    StompConf1 = compose_listener_authn(
        ?CONF_STOMP_BAISC_1,
        ?CONF_STOMP_LISTENER_1,
        ?CONF_STOMP_AUTHN_1
    ),
    StompConf2 = compose_listener_authn(
        ?CONF_STOMP_BAISC_1,
        ?CONF_STOMP_LISTENER_1,
        ?CONF_STOMP_AUTHN_2
    ),

    {ok, _} = emqx_gateway_conf:load_gateway(<<"stomp">>, StompConf),
    assert_confs(StompConf, emqx:get_raw_config([gateway, stomp])),
    ct:sleep(500),

    {ok, _} = emqx_gateway_conf:add_authn(
        <<"stomp">>, {<<"tcp">>, <<"default">>}, ?CONF_STOMP_AUTHN_1
    ),
    assert_confs(StompConf1, emqx:get_raw_config([gateway, stomp])),

    {ok, _} = emqx_gateway_conf:update_authn(
        <<"stomp">>, {<<"tcp">>, <<"default">>}, ?CONF_STOMP_AUTHN_2
    ),
    assert_confs(StompConf2, emqx:get_raw_config([gateway, stomp])),

    ok = emqx_gateway_conf:remove_authn(
        <<"stomp">>, {<<"tcp">>, <<"default">>}
    ),

    ?assertMatch(
        {error, {badres, #{reason := not_found}}},
        emqx_gateway_conf:update_authn(
            <<"stomp">>, {<<"tcp">>, <<"default">>}, ?CONF_STOMP_AUTHN_2
        )
    ),

    Path = [gateway, stomp, listeners, tcp, default, authentication],
    ?assertException(
        error,
        {config_not_found, [<<"gateway">>, stomp, listeners, tcp, default, authentication]},
        emqx:get_raw_config(Path)
    ),
    ok.

t_load_gateway_with_certs_content(_) ->
    StompConf = compose_ssl_listener(
        ?CONF_STOMP_BAISC_1,
        ?CONF_STOMP_LISTENER_SSL
    ),
    {ok, _} = emqx_gateway_conf:load_gateway(<<"stomp">>, StompConf),
    assert_confs(StompConf, emqx:get_raw_config([gateway, stomp])),
    SslConf = emqx_utils_maps:deep_get(
        [<<"listeners">>, <<"ssl">>, <<"default">>, <<"ssl_options">>],
        emqx:get_raw_config([gateway, stomp])
    ),
    assert_ssl_confs_files_exist(SslConf),
    ok = emqx_gateway_conf:unload_gateway(<<"stomp">>),
    assert_ssl_confs_files_deleted(SslConf),
    ?assertException(
        error,
        {config_not_found, [<<"gateway">>, stomp]},
        emqx:get_raw_config([gateway, stomp])
    ),
    %% test update([gateway], Conf)
    Raw0 = emqx:get_raw_config([gateway]),
    #{<<"listeners">> := StompConfL} = StompConf,
    StompConf1 = StompConf#{
        <<"listeners">> => emqx_gateway_conf:unconvert_listeners(StompConfL)
    },
    Raw1 = emqx_utils_maps:deep_put([<<"stomp">>], Raw0, StompConf1),
    ?assertMatch({ok, _}, emqx:update_config([gateway], Raw1)),
    assert_ssl_confs_files_exist(SslConf),
    ?assertEqual(
        SslConf,
        emqx_utils_maps:deep_get(
            [<<"listeners">>, <<"ssl">>, <<"default">>, <<"ssl_options">>],
            emqx:get_raw_config([gateway, stomp])
        )
    ),
    %% reset
    ?assertMatch({ok, _}, emqx:update_config([gateway], Raw0)),
    assert_ssl_confs_files_deleted(SslConf),
    ok.

%% TODO: Comment out this test case for now, because emqx_tls_lib
%% will delete the configured certificate file.

%t_load_gateway_with_certs_path(_) ->
%    StompConf = compose_ssl_listener(
%                  ?CONF_STOMP_BAISC_1,
%                  ?CONF_STOMP_LISTENER_SSL_PATH
%                 ),
%    {ok, _} = emqx_gateway_conf:load_gateway(<<"stomp">>, StompConf),
%    assert_confs(StompConf, emqx:get_raw_config([gateway, stomp])),
%    SslConf = emqx_utils_maps:deep_get(
%                [<<"listeners">>, <<"ssl">>, <<"default">>, <<"ssl_options">>],
%                emqx:get_raw_config([gateway, stomp])
%               ),
%    ok = emqx_gateway_conf:unload_gateway(<<"stomp">>),
%    assert_ssl_confs_files_deleted(SslConf),
%    ?assertException(error, {config_not_found, [gateway, stomp]},
%                     emqx:get_raw_config([gateway, stomp])),
%    ok.

t_add_listener_with_certs_content(_) ->
    StompConf = ?CONF_STOMP_BAISC_1,
    {ok, _} = emqx_gateway_conf:load_gateway(<<"stomp">>, StompConf),
    assert_confs(StompConf, emqx:get_raw_config([gateway, stomp])),

    {ok, _} = emqx_gateway_conf:add_listener(
        <<"stomp">>,
        {<<"ssl">>, <<"default">>},
        ?CONF_STOMP_LISTENER_SSL
    ),
    assert_confs(
        maps:merge(StompConf, ssl_listener(?CONF_STOMP_LISTENER_SSL)),
        emqx:get_raw_config([gateway, stomp])
    ),

    {ok, _} = emqx_gateway_conf:update_listener(
        <<"stomp">>,
        {<<"ssl">>, <<"default">>},
        ?CONF_STOMP_LISTENER_SSL_2
    ),
    assert_confs(
        maps:merge(StompConf, ssl_listener(?CONF_STOMP_LISTENER_SSL_2)),
        emqx:get_raw_config([gateway, stomp])
    ),

    SslConf = emqx_utils_maps:deep_get(
        [<<"listeners">>, <<"ssl">>, <<"default">>, <<"ssl_options">>],
        emqx:get_raw_config([gateway, stomp])
    ),
    assert_ssl_confs_files_exist(SslConf),
    ok = emqx_gateway_conf:remove_listener(
        <<"stomp">>, {<<"ssl">>, <<"default">>}
    ),
    assert_ssl_confs_files_deleted(SslConf),

    ?assertMatch(
        {error, {badres, #{reason := not_found}}},
        emqx_gateway_conf:update_listener(
            <<"stomp">>, {<<"ssl">>, <<"default">>}, ?CONF_STOMP_LISTENER_SSL_2
        )
    ),

    ?assertException(
        error,
        {config_not_found, [<<"gateway">>, stomp, listeners, ssl, default]},
        emqx:get_raw_config([gateway, stomp, listeners, ssl, default])
    ),

    %% test update([gateway], Conf)
    Raw0 = emqx:get_raw_config([gateway]),
    Raw1 = emqx_utils_maps:deep_put(
        [<<"stomp">>, <<"listeners">>, <<"ssl">>, <<"default">>], Raw0, ?CONF_STOMP_LISTENER_SSL
    ),
    ?assertMatch({ok, _}, emqx:update_config([gateway], Raw1)),
    SslConf1 = emqx_utils_maps:deep_get(
        [<<"listeners">>, <<"ssl">>, <<"default">>, <<"ssl_options">>],
        emqx:get_raw_config([gateway, stomp])
    ),
    assert_ssl_confs_files_exist(SslConf1),
    %% update
    Raw2 = emqx_utils_maps:deep_put(
        [<<"stomp">>, <<"listeners">>, <<"ssl">>, <<"default">>], Raw0, ?CONF_STOMP_LISTENER_SSL_2
    ),
    ?assertMatch({ok, _}, emqx:update_config([gateway], Raw2)),
    SslConf2 =
        emqx_utils_maps:deep_get(
            [<<"listeners">>, <<"ssl">>, <<"default">>, <<"ssl_options">>],
            emqx:get_raw_config([gateway, stomp])
        ),
    assert_ssl_confs_files_exist(SslConf2),
    %% reset
    ?assertMatch({ok, _}, emqx:update_config([gateway], Raw0)),
    assert_ssl_confs_files_deleted(SslConf),
    assert_ssl_confs_files_deleted(SslConf1),
    assert_ssl_confs_files_deleted(SslConf2),
    ok.

assert_ssl_confs_files_deleted(SslConf) when is_map(SslConf) ->
    {ok, _} = emqx_tls_certfile_gc:force(),
    Ks = [<<"cacertfile">>, <<"certfile">>, <<"keyfile">>],
    lists:foreach(
        fun(K) ->
            Path = maps:get(K, SslConf),
            {error, enoent} = file:read_file(Path)
        end,
        Ks
    ).
assert_ssl_confs_files_exist(SslConf) when is_map(SslConf) ->
    Ks = [<<"cacertfile">>, <<"certfile">>, <<"keyfile">>],
    lists:foreach(
        fun(K) ->
            Path = maps:get(K, SslConf),
            {ok, _} = file:read_file(Path)
        end,
        Ks
    ).

%%--------------------------------------------------------------------
%% Utils

compose(Basic, Authn, Listener) ->
    maps:merge(
        maps:merge(Basic, #{<<"authentication">> => Authn}),
        listener(Listener)
    ).

compose_listener(Basic, Listener) ->
    maps:merge(Basic, listener(Listener)).

compose_ssl_listener(Basic, Listener) ->
    maps:merge(Basic, ssl_listener(Listener)).

compose_authn(Basic, Authn) ->
    maps:merge(Basic, #{<<"authentication">> => Authn}).

compose_listener_authn(Basic, Listener, Authn) ->
    maps:merge(
        Basic,
        listener(maps:put(<<"authentication">>, Authn, Listener))
    ).

listener(L) ->
    #{
        <<"listeners">> => [
            L#{
                <<"type">> => <<"tcp">>,
                <<"name">> => <<"default">>
            }
        ]
    }.

ssl_listener(L) ->
    #{
        <<"listeners">> => [
            L#{
                <<"type">> => <<"ssl">>,
                <<"name">> => <<"default">>
            }
        ]
    }.