nimiq_rpc

-module(nimiq_rpc@network).
-compile([no_auto_import, nowarn_unused_vars, nowarn_unused_function, nowarn_nomatch, inline]).
-define(FILEPATH, "src/nimiq_rpc/network.gleam").
-export([get_peer_id/1, get_peer_count/1, get_peer_list/1]).

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

-file("src/nimiq_rpc/network.gleam", 9).
?DOC(" Returns the peer ID for our local peer.\n").
-spec get_peer_id(
    gleam@erlang@process:subject(nimiq_rpc@internal@fiber@src@fiber@backend:message())
) -> {ok, binary()} | {error, binary()}.
get_peer_id(Client) ->
    _pipe = nimiq_rpc@internal@fiber@src@fiber@request:new(<<"getPeerId"/utf8>>),
    _pipe@1 = nimiq_rpc@internal@fiber@src@fiber@request:with_decoder(
        _pipe,
        nimiq_rpc@internal@utils:unwrap_data(
            {decoder, fun gleam@dynamic@decode:decode_string/1}
        )
    ),
    nimiq_rpc@internal@utils:call(Client, _pipe@1).

-file("src/nimiq_rpc/network.gleam", 16).
?DOC(" Returns the number of peers.\n").
-spec get_peer_count(
    gleam@erlang@process:subject(nimiq_rpc@internal@fiber@src@fiber@backend:message())
) -> {ok, integer()} | {error, binary()}.
get_peer_count(Client) ->
    _pipe = nimiq_rpc@internal@fiber@src@fiber@request:new(
        <<"getPeerCount"/utf8>>
    ),
    _pipe@1 = nimiq_rpc@internal@fiber@src@fiber@request:with_decoder(
        _pipe,
        nimiq_rpc@internal@utils:unwrap_data(
            {decoder, fun gleam@dynamic@decode:decode_int/1}
        )
    ),
    nimiq_rpc@internal@utils:call(Client, _pipe@1).

-file("src/nimiq_rpc/network.gleam", 23).
?DOC(" Returns a list with the IDs of all our peers.\n").
-spec get_peer_list(
    gleam@erlang@process:subject(nimiq_rpc@internal@fiber@src@fiber@backend:message())
) -> {ok, list(binary())} | {error, binary()}.
get_peer_list(Client) ->
    _pipe = nimiq_rpc@internal@fiber@src@fiber@request:new(
        <<"getPeerList"/utf8>>
    ),
    _pipe@1 = nimiq_rpc@internal@fiber@src@fiber@request:with_decoder(
        _pipe,
        nimiq_rpc@internal@utils:unwrap_data(
            gleam@dynamic@decode:list(
                {decoder, fun gleam@dynamic@decode:decode_string/1}
            )
        )
    ),
    nimiq_rpc@internal@utils:call(Client, _pipe@1).