-module(spectator@internal@api).
-compile([no_auto_import, nowarn_unused_vars, nowarn_unused_function, nowarn_nomatch]).

-export([invert_sort_direction/1, sort_table_list/3, list_processes/0, get_info/1, get_info_list/0, get_details/1, get_status/2, get_state/2, request_otp_data/2, list_ets_tables/0, get_ets_table_info/1, get_raw_ets_data/1, opaque_tuple_to_list/1, get_ets_data/1, sort_process_list/3, format_pid/1, format_port/1, suspend/1, resume/1, ets_insert/2, new_ets_table/1, compare_dynamic_data/2, sort_table_data/3, get_word_size/0, start_tag_manager/0, add_tag/2, get_tag/1]).
-export_type([opaque_tuple/0, sys_state/0, system_primitive/0, table/0, table_data/0, process_otp_status/0, otp_details/0, process_item/0, process_details/0, process_sort_criteria/0, table_sort_criteria/0, sort_direction/0, info/0]).

-type opaque_tuple() :: any().

-type sys_state() :: process_running | process_suspended.

-type system_primitive() :: {process_primitive,
        gleam@erlang@process:pid_(),
        gleam@option:option(gleam@erlang@atom:atom_()),
        gleam@option:option(binary())} |
    {port_primitive,
        gleam@erlang@port:port_(),
        gleam@option:option(gleam@erlang@atom:atom_())} |
    {remote_process_primitive,
        gleam@erlang@atom:atom_(),
        gleam@erlang@atom:atom_()} |
    {nif_resource_primitive, gleam@dynamic:dynamic_()}.

-type table() :: {table,
        gleam@erlang:reference_(),
        gleam@erlang@atom:atom_(),
        gleam@erlang@atom:atom_(),
        integer(),
        integer(),
        gleam@erlang@process:pid_(),
        gleam@erlang@atom:atom_(),
        boolean(),
        boolean()}.

-type table_data() :: {table_data,
        list(list(gleam@dynamic:dynamic_())),
        integer()}.

-type process_otp_status() :: {process_otp_status,
        gleam@erlang@process:pid_(),
        gleam@erlang@atom:atom_(),
        gleam@erlang@process:pid_(),
        sys_state(),
        list(gleam@dynamic:dynamic_())}.

-type otp_details() :: {otp_details,
        gleam@erlang@process:pid_(),
        process_otp_status(),
        gleam@dynamic:dynamic_()}.

-type process_item() :: {process_item, gleam@erlang@process:pid_(), info()}.

-type process_details() :: {process_details,
        list(gleam@dynamic:dynamic_()),
        list(system_primitive()),
        list(system_primitive()),
        list(system_primitive()),
        boolean(),
        gleam@option:option(system_primitive())}.

-type process_sort_criteria() :: sort_by_process_name |
    sort_by_tag |
    sort_by_current_function |
    sort_by_process_memory |
    sort_by_reductions |
    sort_by_message_queue |
    sort_by_process_status.

-type table_sort_criteria() :: sort_by_table_id |
    sort_by_table_name |
    sort_by_table_type |
    sort_by_table_size |
    sort_by_table_memory |
    sort_by_table_owner |
    sort_by_table_protection |
    sort_by_table_read_concurrency |
    sort_by_table_write_concurrency.

-type sort_direction() :: ascending | descending.

-type info() :: {info,
        {gleam@erlang@atom:atom_(), gleam@erlang@atom:atom_(), integer()},
        {gleam@erlang@atom:atom_(), gleam@erlang@atom:atom_(), integer()},
        gleam@option:option(gleam@erlang@atom:atom_()),
        integer(),
        integer(),
        integer(),
        gleam@option:option(binary()),
        gleam@erlang@atom:atom_()}.

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 152).
-spec invert_sort_direction(sort_direction()) -> sort_direction().
invert_sort_direction(Direction) ->
    case Direction of
        ascending ->
            descending;

        descending ->
            ascending
    end.

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 159).
-spec apply_direction(gleam@order:order(), sort_direction()) -> gleam@order:order().
apply_direction(Order, Direction) ->
    case Direction of
        ascending ->
            Order;

        descending ->
            gleam@order:negate(Order)
    end.

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 181).
-spec compare_name(process_item(), process_item()) -> gleam@order:order().
compare_name(A, B) ->
    case {erlang:element(4, erlang:element(3, A)),
        erlang:element(4, erlang:element(3, B))} of
        {{some, A_name}, {some, B_name}} ->
            gleam@string:compare(
                erlang:atom_to_binary(A_name),
                erlang:atom_to_binary(B_name)
            );

        {none, {some, _}} ->
            lt;

        {{some, _}, none} ->
            gt;

        {none, none} ->
            eq
    end.

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 247).
-spec disgustingly_index_into_list_at(list(APIP), integer()) -> {ok, APIP} |
    {error, nil}.
disgustingly_index_into_list_at(List, Index) ->
    case Index >= 0 of
        true ->
            _pipe = List,
            _pipe@1 = gleam@list:drop(_pipe, Index),
            gleam@list:first(_pipe@1);

        false ->
            {error, nil}
    end.

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 287).
-spec sort_table_list(list(table()), table_sort_criteria(), sort_direction()) -> list(table()).
sort_table_list(Input, Criteria, Direction) ->
    case Criteria of
        sort_by_table_id ->
            gleam@list:sort(
                Input,
                fun(A, B) ->
                    _pipe = gleam@string:compare(
                        gleam@string:inspect(erlang:element(2, A)),
                        gleam@string:inspect(erlang:element(2, B))
                    ),
                    apply_direction(_pipe, Direction)
                end
            );

        sort_by_table_name ->
            gleam@list:sort(
                Input,
                fun(A@1, B@1) ->
                    _pipe@1 = gleam@string:compare(
                        erlang:atom_to_binary(erlang:element(3, A@1)),
                        erlang:atom_to_binary(erlang:element(3, B@1))
                    ),
                    apply_direction(_pipe@1, Direction)
                end
            );

        sort_by_table_type ->
            gleam@list:sort(
                Input,
                fun(A@2, B@2) ->
                    _pipe@2 = gleam@string:compare(
                        erlang:atom_to_binary(erlang:element(4, A@2)),
                        erlang:atom_to_binary(erlang:element(4, B@2))
                    ),
                    apply_direction(_pipe@2, Direction)
                end
            );

        sort_by_table_size ->
            gleam@list:sort(
                Input,
                fun(A@3, B@3) ->
                    _pipe@3 = gleam@int:compare(
                        erlang:element(5, A@3),
                        erlang:element(5, B@3)
                    ),
                    apply_direction(_pipe@3, Direction)
                end
            );

        sort_by_table_memory ->
            gleam@list:sort(
                Input,
                fun(A@4, B@4) ->
                    _pipe@4 = gleam@int:compare(
                        erlang:element(6, A@4),
                        erlang:element(6, B@4)
                    ),
                    apply_direction(_pipe@4, Direction)
                end
            );

        sort_by_table_owner ->
            gleam@list:sort(
                Input,
                fun(A@5, B@5) ->
                    _pipe@5 = gleam@string:compare(
                        gleam@string:inspect(erlang:element(7, A@5)),
                        gleam@string:inspect(erlang:element(7, B@5))
                    ),
                    apply_direction(_pipe@5, Direction)
                end
            );

        sort_by_table_protection ->
            gleam@list:sort(
                Input,
                fun(A@6, B@6) ->
                    _pipe@6 = gleam@string:compare(
                        erlang:atom_to_binary(erlang:element(8, A@6)),
                        erlang:atom_to_binary(erlang:element(8, B@6))
                    ),
                    apply_direction(_pipe@6, Direction)
                end
            );

        sort_by_table_read_concurrency ->
            gleam@list:sort(
                Input,
                fun(A@7, B@7) ->
                    _pipe@7 = gleam@bool:compare(
                        erlang:element(9, A@7),
                        erlang:element(9, B@7)
                    ),
                    apply_direction(_pipe@7, Direction)
                end
            );

        sort_by_table_write_concurrency ->
            gleam@list:sort(
                Input,
                fun(A@8, B@8) ->
                    _pipe@8 = gleam@bool:compare(
                        erlang:element(10, A@8),
                        erlang:element(10, B@8)
                    ),
                    apply_direction(_pipe@8, Direction)
                end
            )
    end.

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 369).
-spec list_processes() -> list(gleam@erlang@process:pid_()).
list_processes() ->
    erlang:processes().

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 372).
-spec get_info(gleam@erlang@process:pid_()) -> {ok, info()} |
    {error, gleam@dynamic:dynamic_()}.
get_info(Pid) ->
    spectator_ffi:get_info(Pid).

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 358).
-spec get_info_list() -> list(process_item()).
get_info_list() ->
    _pipe = erlang:processes(),
    gleam@list:filter_map(_pipe, fun(Pid) -> case spectator_ffi:get_info(Pid) of
                {error, E} ->
                    {error, E};

                {ok, Info} ->
                    {ok, {process_item, Pid, Info}}
            end end).

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 377).
-spec get_details(gleam@erlang@process:pid_()) -> {ok, process_details()} |
    {error, gleam@dynamic:dynamic_()}.
get_details(Pid) ->
    spectator_ffi:get_details(Pid).

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 401).
-spec get_status(gleam@erlang@process:pid_(), integer()) -> {ok,
        process_otp_status()} |
    {error, gleam@dynamic:dynamic_()}.
get_status(Pid, Timeout) ->
    spectator_ffi:get_status(Pid, Timeout).

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 407).
-spec get_state(gleam@erlang@process:pid_(), integer()) -> {ok,
        gleam@dynamic:dynamic_()} |
    {error, gleam@dynamic:dynamic_()}.
get_state(Pid, Timeout) ->
    spectator_ffi:get_state(Pid, Timeout).

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 381).
-spec request_otp_data(gleam@erlang@process:pid_(), fun((otp_details()) -> nil)) -> gleam@erlang@process:pid_().
request_otp_data(P, Callback) ->
    gleam@erlang@process:start(fun() -> case spectator_ffi:get_status(P, 100) of
                {error, _} ->
                    nil;

                {ok, Status} ->
                    State = begin
                        _pipe = spectator_ffi:get_state(P, 100),
                        gleam@result:unwrap(_pipe, gleam_stdlib:identity(none))
                    end,
                    Callback({otp_details, P, Status, State})
            end end, false).

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 443).
-spec list_ets_tables() -> {ok, list(table())} | {error, nil}.
list_ets_tables() ->
    spectator_ffi:list_ets_tables().

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 446).
-spec get_ets_table_info(gleam@erlang@atom:atom_()) -> {ok, table()} |
    {error, nil}.
get_ets_table_info(Name) ->
    spectator_ffi:get_ets_table_info(Name).

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 449).
-spec get_raw_ets_data(gleam@erlang:reference_()) -> {ok,
        list(list(opaque_tuple()))} |
    {error, nil}.
get_raw_ets_data(Table) ->
    spectator_ffi:get_ets_data(Table).

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 454).
-spec opaque_tuple_to_list(opaque_tuple()) -> list(gleam@dynamic:dynamic_()).
opaque_tuple_to_list(Tuple) ->
    spectator_ffi:opaque_tuple_to_list(Tuple).

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 419).
-spec process_raw_ets_data(
    list(list(opaque_tuple())),
    list(list(gleam@dynamic:dynamic_())),
    integer()
) -> {ok, table_data()} | {error, nil}.
process_raw_ets_data(Remainder, Accumulator, Max_length) ->
    case Remainder of
        [] ->
            {ok, {table_data, Accumulator, Max_length}};

        [[Tup] | Rest] ->
            Converted = spectator_ffi:opaque_tuple_to_list(Tup),
            process_raw_ets_data(
                Rest,
                [Converted | Accumulator],
                gleam@int:max(Max_length, erlang:length(Converted))
            );

        _ ->
            {error, nil}
    end.

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 414).
-spec get_ets_data(table()) -> {ok, table_data()} | {error, nil}.
get_ets_data(Table) ->
    gleam@result:'try'(
        spectator_ffi:get_ets_data(erlang:element(2, Table)),
        fun(Raw_data) -> process_raw_ets_data(Raw_data, [], 0) end
    ).

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 458).
-spec function_to_string(
    {gleam@erlang@atom:atom_(), gleam@erlang@atom:atom_(), integer()}
) -> binary().
function_to_string(F) ->
    <<<<(erlang:atom_to_binary(erlang:element(1, F)))/binary,
            (erlang:atom_to_binary(erlang:element(2, F)))/binary>>/binary,
        (gleam@int:to_string(erlang:element(3, F)))/binary>>.

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 166).
-spec compare_tag(process_item(), process_item()) -> gleam@order:order().
compare_tag(A, B) ->
    case {erlang:element(8, erlang:element(3, A)),
        erlang:element(8, erlang:element(3, B))} of
        {{some, A_tag}, {some, B_tag}} ->
            gleam@string:compare(A_tag, B_tag);

        {none, {some, _}} ->
            lt;

        {{some, _}, none} ->
            gt;

        {none, none} ->
            gleam@string:compare(
                function_to_string(erlang:element(3, erlang:element(3, A))),
                function_to_string(erlang:element(3, erlang:element(3, B)))
            )
    end.

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 193).
-spec sort_process_list(
    list(process_item()),
    process_sort_criteria(),
    sort_direction()
) -> list(process_item()).
sort_process_list(Input, Criteria, Direction) ->
    case Criteria of
        sort_by_process_memory ->
            gleam@list:sort(
                Input,
                fun(A, B) ->
                    _pipe = gleam@int:compare(
                        erlang:element(5, erlang:element(3, A)),
                        erlang:element(5, erlang:element(3, B))
                    ),
                    apply_direction(_pipe, Direction)
                end
            );

        sort_by_reductions ->
            gleam@list:sort(
                Input,
                fun(A@1, B@1) ->
                    _pipe@1 = gleam@int:compare(
                        erlang:element(7, erlang:element(3, A@1)),
                        erlang:element(7, erlang:element(3, B@1))
                    ),
                    apply_direction(_pipe@1, Direction)
                end
            );

        sort_by_message_queue ->
            gleam@list:sort(
                Input,
                fun(A@2, B@2) ->
                    _pipe@2 = gleam@int:compare(
                        erlang:element(6, erlang:element(3, A@2)),
                        erlang:element(6, erlang:element(3, B@2))
                    ),
                    apply_direction(_pipe@2, Direction)
                end
            );

        sort_by_current_function ->
            gleam@list:sort(
                Input,
                fun(A@3, B@3) ->
                    _pipe@3 = gleam@string:compare(
                        function_to_string(
                            erlang:element(2, erlang:element(3, A@3))
                        ),
                        function_to_string(
                            erlang:element(2, erlang:element(3, B@3))
                        )
                    ),
                    apply_direction(_pipe@3, Direction)
                end
            );

        sort_by_process_name ->
            gleam@list:sort(
                Input,
                fun(A@4, B@4) -> _pipe@4 = compare_name(A@4, B@4),
                    apply_direction(_pipe@4, Direction) end
            );

        sort_by_tag ->
            gleam@list:sort(
                Input,
                fun(A@5, B@5) -> _pipe@5 = compare_tag(A@5, B@5),
                    apply_direction(_pipe@5, Direction) end
            );

        sort_by_process_status ->
            gleam@list:sort(
                Input,
                fun(A@6, B@6) ->
                    _pipe@6 = gleam@string:compare(
                        erlang:atom_to_binary(
                            erlang:element(9, erlang:element(3, A@6))
                        ),
                        erlang:atom_to_binary(
                            erlang:element(9, erlang:element(3, B@6))
                        )
                    ),
                    apply_direction(_pipe@6, Direction)
                end
            )
    end.

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 463).
-spec format_pid(gleam@erlang@process:pid_()) -> binary().
format_pid(Pid) ->
    spectator_ffi:format_pid(Pid).

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 466).
-spec format_port(gleam@erlang@port:port_()) -> binary().
format_port(Port) ->
    spectator_ffi:format_port(Port).

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 471).
-spec suspend(gleam@erlang@process:pid_()) -> nil.
suspend(Pid) ->
    sys:suspend(Pid).

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 474).
-spec resume(gleam@erlang@process:pid_()) -> nil.
resume(Pid) ->
    sys:resume(Pid).

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 477).
-spec ets_insert(gleam@erlang@atom:atom_(), list({any(), any()})) -> nil.
ets_insert(Table, Tuple) ->
    ets:insert(Table, Tuple).

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 480).
-spec new_ets_table(gleam@erlang@atom:atom_()) -> {ok,
        gleam@erlang@atom:atom_()} |
    {error, nil}.
new_ets_table(Name) ->
    spectator_ffi:new_ets_table(Name).

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 485).
-spec compare_dynamic_data(gleam@dynamic:dynamic_(), gleam@dynamic:dynamic_()) -> gleam@order:order().
compare_dynamic_data(A, B) ->
    spectator_ffi:compare_data(A, B).

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 260).
-spec sort_table_data(table_data(), integer(), sort_direction()) -> table_data().
sort_table_data(Input, Sort_column, Sort_direction) ->
    Sorted = gleam@list:sort(
        erlang:element(2, Input),
        fun(A, B) ->
            A_cell = disgustingly_index_into_list_at(A, Sort_column),
            B_cell = disgustingly_index_into_list_at(B, Sort_column),
            case {A_cell, B_cell} of
                {{ok, A@1}, {ok, B@1}} ->
                    _pipe = spectator_ffi:compare_data(A@1, B@1),
                    apply_direction(_pipe, Sort_direction);

                {{ok, _}, {error, _}} ->
                    _pipe@1 = gt,
                    apply_direction(_pipe@1, Sort_direction);

                {{error, _}, {ok, _}} ->
                    lt;

                {{error, _}, {error, _}} ->
                    _pipe@2 = eq,
                    apply_direction(_pipe@2, Sort_direction)
            end
        end
    ),
    erlang:setelement(2, Input, Sorted).

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 491).
-spec get_word_size() -> integer().
get_word_size() ->
    spectator_ffi:get_word_size().

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 496).
-spec start_tag_manager() -> {ok, gleam@erlang@process:pid_()} |
    {error, gleam@dynamic:dynamic_()}.
start_tag_manager() ->
    spectator_tag_manager:start_link().

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 499).
-spec add_tag(gleam@erlang@process:pid_(), binary()) -> nil.
add_tag(Pid, Tag) ->
    spectator_tag_manager:add_tag(Pid, Tag).

-file("/Users/jonas/Projects/spectator/src/spectator/internal/api.gleam", 502).
-spec get_tag(gleam@erlang@process:pid_()) -> gleam@option:option(binary()).
get_tag(Pid) ->
    spectator_tag_manager:get_tag(Pid).