-module(testcontainer_formulas@rabbitmq).
-compile([no_auto_import, nowarn_unused_vars, nowarn_unused_function, nowarn_nomatch, inline]).
-define(FILEPATH, "src/testcontainer_formulas/rabbitmq.gleam").
-export([new/0, with_image/2, with_version/2, with_username/2, with_password/2, with_secret_password/2, with_vhost/2, with_extra_wait/2, on_network/2, on_network_name/2, with_name/2, formula/1]).
-export_type([rabbit_mq_container/0, rabbit_mq_config/0]).

-if(?OTP_RELEASE >= 27).
-define(MODULEDOC(Str), -moduledoc(Str)).
-define(DOC(Str), -doc(Str)).
-else.
-define(MODULEDOC(Str), -compile([])).
-define(DOC(Str), -compile([])).
-endif.

?MODULEDOC(
    " RabbitMQ formula. Defaults to `rabbitmq:3-management` with guest creds.\n"
    "\n"
    "     use mq <- testcontainer.with_formula(\n"
    "       rabbitmq.new()\n"
    "       |> rabbitmq.with_username(\"app\")\n"
    "       |> rabbitmq.with_password(\"secret\")\n"
    "       |> rabbitmq.formula(),\n"
    "     )\n"
    "\n"
    "     // mq.amqp_url, mq.management_url, mq.host, mq.amqp_port\n"
).

-type rabbit_mq_container() :: {rabbit_mq_container,
        testcontainer@container:container(),
        binary(),
        binary(),
        binary(),
        integer(),
        integer(),
        binary(),
        binary()}.

-opaque rabbit_mq_config() :: {rabbit_mq_config,
        binary(),
        binary(),
        cowl:secret(binary()),
        binary(),
        gleam@option:option(testcontainer@wait:wait_strategy()),
        gleam@option:option(binary()),
        gleam@option:option(binary())}.

-file("src/testcontainer_formulas/rabbitmq.gleam", 52).
?DOC(" Sensible defaults: `rabbitmq:3-management` / `guest` / `guest` / `/`.\n").
-spec new() -> rabbit_mq_config().
new() ->
    {rabbit_mq_config,
        <<"rabbitmq:3-management"/utf8>>,
        <<"guest"/utf8>>,
        cowl:secret(<<"guest"/utf8>>),
        <<"/"/utf8>>,
        none,
        none,
        none}.

-file("src/testcontainer_formulas/rabbitmq.gleam", 65).
?DOC(" Replaces the image entirely.\n").
-spec with_image(rabbit_mq_config(), binary()) -> rabbit_mq_config().
with_image(C, Image) ->
    {rabbit_mq_config,
        Image,
        erlang:element(3, C),
        erlang:element(4, C),
        erlang:element(5, C),
        erlang:element(6, C),
        erlang:element(7, C),
        erlang:element(8, C)}.

-file("src/testcontainer_formulas/rabbitmq.gleam", 70).
?DOC(" Shorthand for `rabbitmq:<version>` (for example `3.13-management`).\n").
-spec with_version(rabbit_mq_config(), binary()) -> rabbit_mq_config().
with_version(C, Version) ->
    {rabbit_mq_config,
        <<"rabbitmq:"/utf8, Version/binary>>,
        erlang:element(3, C),
        erlang:element(4, C),
        erlang:element(5, C),
        erlang:element(6, C),
        erlang:element(7, C),
        erlang:element(8, C)}.

-file("src/testcontainer_formulas/rabbitmq.gleam", 74).
-spec with_username(rabbit_mq_config(), binary()) -> rabbit_mq_config().
with_username(C, User) ->
    {rabbit_mq_config,
        erlang:element(2, C),
        User,
        erlang:element(4, C),
        erlang:element(5, C),
        erlang:element(6, C),
        erlang:element(7, C),
        erlang:element(8, C)}.

-file("src/testcontainer_formulas/rabbitmq.gleam", 78).
-spec with_password(rabbit_mq_config(), binary()) -> rabbit_mq_config().
with_password(C, Pass) ->
    {rabbit_mq_config,
        erlang:element(2, C),
        erlang:element(3, C),
        cowl:secret(Pass),
        erlang:element(5, C),
        erlang:element(6, C),
        erlang:element(7, C),
        erlang:element(8, C)}.

-file("src/testcontainer_formulas/rabbitmq.gleam", 82).
-spec with_secret_password(rabbit_mq_config(), cowl:secret(binary())) -> rabbit_mq_config().
with_secret_password(C, Pass) ->
    {rabbit_mq_config,
        erlang:element(2, C),
        erlang:element(3, C),
        Pass,
        erlang:element(5, C),
        erlang:element(6, C),
        erlang:element(7, C),
        erlang:element(8, C)}.

-file("src/testcontainer_formulas/rabbitmq.gleam", 90).
?DOC(" Sets the default vhost used by RabbitMQ bootstrap.\n").
-spec with_vhost(rabbit_mq_config(), binary()) -> rabbit_mq_config().
with_vhost(C, Vhost) ->
    {rabbit_mq_config,
        erlang:element(2, C),
        erlang:element(3, C),
        erlang:element(4, C),
        Vhost,
        erlang:element(6, C),
        erlang:element(7, C),
        erlang:element(8, C)}.

-file("src/testcontainer_formulas/rabbitmq.gleam", 96).
?DOC(
    " Adds an extra wait strategy on top of the default\n"
    " `all_of([port(5672), log(\"Server startup complete\")])`.\n"
).
-spec with_extra_wait(rabbit_mq_config(), testcontainer@wait:wait_strategy()) -> rabbit_mq_config().
with_extra_wait(C, S) ->
    {rabbit_mq_config,
        erlang:element(2, C),
        erlang:element(3, C),
        erlang:element(4, C),
        erlang:element(5, C),
        {some, S},
        erlang:element(7, C),
        erlang:element(8, C)}.

-file("src/testcontainer_formulas/rabbitmq.gleam", 103).
-spec on_network(rabbit_mq_config(), testcontainer@network:network()) -> rabbit_mq_config().
on_network(C, Net) ->
    {rabbit_mq_config,
        erlang:element(2, C),
        erlang:element(3, C),
        erlang:element(4, C),
        erlang:element(5, C),
        erlang:element(6, C),
        {some, testcontainer@network:name(Net)},
        erlang:element(8, C)}.

-file("src/testcontainer_formulas/rabbitmq.gleam", 108).
?DOC(" Same as `on_network/2` when you already have the Docker network name.\n").
-spec on_network_name(rabbit_mq_config(), binary()) -> rabbit_mq_config().
on_network_name(C, Net) ->
    {rabbit_mq_config,
        erlang:element(2, C),
        erlang:element(3, C),
        erlang:element(4, C),
        erlang:element(5, C),
        erlang:element(6, C),
        {some, Net},
        erlang:element(8, C)}.

-file("src/testcontainer_formulas/rabbitmq.gleam", 112).
-spec with_name(rabbit_mq_config(), binary()) -> rabbit_mq_config().
with_name(C, N) ->
    {rabbit_mq_config,
        erlang:element(2, C),
        erlang:element(3, C),
        erlang:element(4, C),
        erlang:element(5, C),
        erlang:element(6, C),
        erlang:element(7, C),
        {some, N}}.

-file("src/testcontainer_formulas/rabbitmq.gleam", 118).
?DOC(
    " Builds the `Formula(RabbitMqContainer)` ready to pass to\n"
    " `testcontainer.with_formula/2`.\n"
).
-spec formula(rabbit_mq_config()) -> testcontainer@formula:formula(rabbit_mq_container()).
formula(C) ->
    Amqp_port = testcontainer@port:tcp(5672),
    Management_port = testcontainer@port:tcp(15672),
    Base_wait = testcontainer@wait:all_of(
        [testcontainer@wait:port(5672),
            testcontainer@wait:log(<<"Server startup complete"/utf8>>)]
    ),
    Wait_strategy = case erlang:element(6, C) of
        none ->
            Base_wait;

        {some, Extra} ->
            testcontainer@wait:all_of([Base_wait, Extra])
    end,
    With_creds = begin
        _pipe = testcontainer@container:new(erlang:element(2, C)),
        _pipe@1 = testcontainer@container:expose_port(_pipe, Amqp_port),
        _pipe@2 = testcontainer@container:expose_port(_pipe@1, Management_port),
        _pipe@3 = testcontainer@container:with_env(
            _pipe@2,
            <<"RABBITMQ_DEFAULT_USER"/utf8>>,
            erlang:element(3, C)
        ),
        _pipe@4 = testcontainer@container:with_secret_env(
            _pipe@3,
            <<"RABBITMQ_DEFAULT_PASS"/utf8>>,
            erlang:element(4, C)
        ),
        _pipe@5 = testcontainer@container:with_env(
            _pipe@4,
            <<"RABBITMQ_DEFAULT_VHOST"/utf8>>,
            erlang:element(5, C)
        ),
        testcontainer@container:wait_for(_pipe@5, Wait_strategy)
    end,
    With_net = case erlang:element(7, C) of
        none ->
            With_creds;

        {some, N} ->
            _pipe@6 = With_creds,
            testcontainer@container:on_network(_pipe@6, N)
    end,
    Final_spec = case erlang:element(8, C) of
        none ->
            With_net;

        {some, N@1} ->
            _pipe@7 = With_net,
            testcontainer@container:with_name(_pipe@7, N@1)
    end,
    testcontainer@formula:new(
        Final_spec,
        fun(Running) ->
            gleam@result:'try'(
                testcontainer@container:host_port(Running, Amqp_port),
                fun(Mapped_amqp) ->
                    gleam@result:'try'(
                        testcontainer@container:host_port(
                            Running,
                            Management_port
                        ),
                        fun(Mapped_management) ->
                            Host = testcontainer@container:host(Running),
                            Pass = cowl:reveal(erlang:element(4, C)),
                            {ok,
                                {rabbit_mq_container,
                                    Running,
                                    <<<<<<<<<<<<<<<<<<"amqp://"/utf8,
                                                                        (gleam_stdlib:percent_encode(
                                                                            erlang:element(
                                                                                3,
                                                                                C
                                                                            )
                                                                        ))/binary>>/binary,
                                                                    ":"/utf8>>/binary,
                                                                (gleam_stdlib:percent_encode(
                                                                    Pass
                                                                ))/binary>>/binary,
                                                            "@"/utf8>>/binary,
                                                        Host/binary>>/binary,
                                                    ":"/utf8>>/binary,
                                                (erlang:integer_to_binary(
                                                    Mapped_amqp
                                                ))/binary>>/binary,
                                            "/"/utf8>>/binary,
                                        (gleam_stdlib:percent_encode(
                                            erlang:element(5, C)
                                        ))/binary>>,
                                    <<<<<<"http://"/utf8, Host/binary>>/binary,
                                            ":"/utf8>>/binary,
                                        (erlang:integer_to_binary(
                                            Mapped_management
                                        ))/binary>>,
                                    Host,
                                    Mapped_amqp,
                                    Mapped_management,
                                    erlang:element(3, C),
                                    erlang:element(5, C)}}
                        end
                    )
                end
            )
        end
    ).