glitch

-module(glitch@api@chat).
-compile([no_auto_import, nowarn_unused_vars, nowarn_unused_function, nowarn_nomatch]).

-export([message_from_json/1, send_message/2]).
-export_type([message/0, send_message_request/0]).

-type message() :: {message, binary(), boolean()}.

-type send_message_request() :: {send_message_request,
        binary(),
        binary(),
        binary(),
        gleam@option:option(binary())}.

-spec message_decoder() -> fun((gleam@dynamic:dynamic_()) -> {ok, message()} |
    {error, list(gleam@dynamic:decode_error())}).
message_decoder() ->
    gleam@dynamic:decode2(
        fun(Field@0, Field@1) -> {message, Field@0, Field@1} end,
        gleam@dynamic:field(<<"message_id"/utf8>>, fun gleam@dynamic:string/1),
        gleam@dynamic:field(<<"is_sent"/utf8>>, fun gleam@dynamic:bool/1)
    ).

-spec message_from_json(binary()) -> {ok, message()} |
    {error, gleam@json:decode_error()}.
message_from_json(Json_string) ->
    gleam@json:decode(Json_string, message_decoder()).

-spec send_message_request_to_json(send_message_request()) -> binary().
send_message_request_to_json(Request) ->
    _pipe = gleam@json:object(
        [{<<"broadcaster_id"/utf8>>,
                gleam@json:string(erlang:element(2, Request))},
            {<<"sender_id"/utf8>>,
                gleam@json:string(erlang:element(3, Request))},
            {<<"message"/utf8>>, gleam@json:string(erlang:element(4, Request))},
            {<<"reply_parent_message_id"/utf8>>,
                glitch@extended@json_ext:option(
                    erlang:element(5, Request),
                    fun gleam@json:string/1
                )}]
    ),
    gleam@json:to_string(_pipe).

-spec send_message(glitch@api@client:client(), send_message_request()) -> {ok,
        list(message())} |
    {error, glitch@error:twitch_error()}.
send_message(Client, Request) ->
    Api_req = begin
        _pipe = glitch@api@api_request:new_helix_request(),
        _pipe@1 = glitch@api@api_request:set_body(
            _pipe,
            send_message_request_to_json(Request)
        ),
        glitch@api@api_request:set_path(_pipe@1, <<"chat/messages"/utf8>>)
    end,
    gleam@result:'try'(
        glitch@api@client:post(Client, Api_req),
        fun(Response) ->
            glitch@api@api_response:get_list_data(Response, message_decoder())
        end
    ).