telega

-module(telega@adapters@wisp).
-compile([no_auto_import, nowarn_unused_vars, nowarn_unused_function, nowarn_nomatch]).

-export([handle_bot/3]).

-spec is_bot_request(
    telega:telega(any()),
    gleam@http@request:request(wisp:connection())
) -> boolean().
is_bot_request(Telega, Req) ->
    case fun gleam@http@request:path_segments/1(Req) of
        [Segment] ->
            case telega:is_webhook_path(Telega, Segment) of
                true ->
                    true;

                false ->
                    false
            end;

        _ ->
            false
    end.

-spec is_secret_token_valid(
    telega:telega(any()),
    gleam@http@request:request(wisp:connection())
) -> boolean().
is_secret_token_valid(Telega, Req) ->
    Secret_header_value = begin
        _pipe = gleam@http@request:get_header(
            Req,
            <<"x-relegram-bot-api-secret-token"/utf8>>
        ),
        gleam@result:unwrap(_pipe, <<""/utf8>>)
    end,
    telega:is_secret_token_valid(Telega, Secret_header_value).

-spec handle_bot(
    gleam@http@request:request(wisp:connection()),
    telega:telega(any()),
    fun(() -> gleam@http@response:response(wisp:body()))
) -> gleam@http@response:response(wisp:body()).
handle_bot(Req, Telega, Handler) ->
    gleam@bool:lazy_guard(
        not is_bot_request(Telega, Req),
        fun() -> Handler() end,
        fun() ->
            telega@log:info(<<"Received request from Telegram API"/utf8>>),
            wisp:require_json(
                Req,
                fun(Json) -> case telega@update:decode(Json) of
                        {ok, Message} ->
                            gleam@bool:lazy_guard(
                                is_secret_token_valid(Telega, Req),
                                fun() -> {response, 401, [], empty} end,
                                fun() ->
                                    case telega:handle_update(Telega, Message) of
                                        {ok, _} ->
                                            wisp:ok();

                                        {error, Error} ->
                                            telega@log:error(
                                                <<"Failed to handle message: "/utf8,
                                                    Error/binary>>
                                            ),
                                            wisp:internal_server_error()
                                    end
                                end
                            );

                        {error, Error@1} ->
                            telega@log:error(
                                <<"Failed to decode message:\n"/utf8,
                                    Error@1/binary>>
                            ),
                            wisp:internal_server_error()
                    end end
            )
        end
    ).