%%% -*-mode:erlang;coding:utf-8;tab-width:4;c-basic-offset:4;indent-tabs-mode:()-*-
%%% ex: set ft=erlang fenc=utf-8 sts=4 ts=4 sw=4 et:
%%%
%%% Copyright 2015 Panagiotis Papadomitsos. All Rights Reserved.
%%% Copyright 2021 Miniclip. All Rights Reserved.
%%%

-module(gen_rpc).
-author("Panagiotis Papadomitsos <pj@ezgr.net>").

%%% Include helpful guard macros
-include("types.hrl").

%%% Library interface
-export([call/3, call/4, call/5, call/6]).

%% Async calls
-export([async_call/3, async_call/4, yield/1, nb_yield/1, nb_yield/2]).

%% Cast and safe_cast
-export([cast/3, cast/4, cast/5]).

%% Parallel evaluation
-export([eval_everywhere/3, eval_everywhere/4, eval_everywhere/5]).

%% Parallel sync call
-export([multicall/3, multicall/4, multicall/5]).

%% Asynchronous broadcast
-export([abcast/2, abcast/3]).

%% Synchronous broadcast
-export([sbcast/2, sbcast/3]).

%% Misc functions
-export([nodes/0]).

-ignore_xref(nb_yield/2).
-ignore_xref(multicall/3).
-ignore_xref(multicall/4).
-ignore_xref(multicall/5).
-ignore_xref(abcast/2).
-ignore_xref(abcast/3).
-ignore_xref(sbcast/2).
-ignore_xref(sbcast/3).
-ignore_xref(async_call/3).
-ignore_xref(async_call/4).
-ignore_xref(call/3).
-ignore_xref(call/4).
-ignore_xref(call/5).
-ignore_xref(call/6).
-ignore_xref(cast/3).
-ignore_xref(cast/4).
-ignore_xref(cast/5).
-ignore_xref(eval_everywhere/3).
-ignore_xref(eval_everywhere/4).
-ignore_xref(eval_everywhere/5).
-ignore_xref(yield/1).
-ignore_xref(nb_yield/1).

%%% ===================================================
%%% Library interface
%%% ===================================================
%% All functions are GUARD-ed in the sender module, no
%% need for the overhead here
-spec async_call(node_or_tuple(), atom() | tuple(), atom()) -> {pid(), reference()}.
async_call(Node, M, F) ->
    gen_rpc_client:async_call(Node, M, F).

-spec async_call(node_or_tuple(), atom() | tuple(), atom(), list()) -> {pid(), reference()}.
async_call(Node, M, F, A) ->
    gen_rpc_client:async_call(Node, M, F, A).

-spec call(node_or_tuple(), atom() | tuple(), atom()) -> term() | {badrpc, term()} | {badtcp | term()}.
call(Node, M, F) ->
    gen_rpc_client:call(Node, M, F).

-spec call(node_or_tuple(), atom() | tuple(), atom(), list()) -> term() | {badrpc, term()} | {badtcp | term()}.
call(Node, M, F, A) ->
    gen_rpc_client:call(Node, M, F, A).

-spec call(node_or_tuple(), atom() | tuple(), atom(), list(), timeout() | undefined) ->
    term() | {badrpc, term()} | {badtcp | term()}.
call(Node, M, F, A, RecvTO) ->
    gen_rpc_client:call(Node, M, F, A, RecvTO).

-spec call(node_or_tuple(), atom() | tuple(), atom(), list(), timeout() | undefined, timeout() | undefined) -> term() | {badrpc, term()} | {badtcp | term()}.
call(Node, M, F, A, RecvTO, SendTO) ->
    gen_rpc_client:call(Node, M, F, A, RecvTO, SendTO).

-spec cast(node_or_tuple(), atom() | tuple(), atom()) -> true.
cast(Node, M, F) ->
    gen_rpc_client:cast(Node, M, F).

-spec cast(node_or_tuple(), atom() | tuple(), atom(), list()) -> true.
cast(Node, M, F, A) ->
    gen_rpc_client:cast(Node, M, F, A).

-spec cast(node_or_tuple(), atom() | tuple(), atom(), list(), timeout() | undefined) -> true.
cast(Node, M, F, A, SendTO) ->
    gen_rpc_client:cast(Node, M, F, A, SendTO).

-spec eval_everywhere([node_or_tuple()], atom() | tuple(), atom()) -> abcast.
eval_everywhere(Nodes, M, F) ->
    gen_rpc_client:eval_everywhere(Nodes, M, F).

-spec eval_everywhere([node_or_tuple()], atom() | tuple(), atom(), list()) -> abcast.
eval_everywhere(Nodes, M, F, A) ->
    gen_rpc_client:eval_everywhere(Nodes, M, F, A).

-spec eval_everywhere([node_or_tuple()], atom() | tuple(), atom(), list(), timeout() | undefined) -> abcast.
eval_everywhere(Nodes, M, F, A, SendTO) ->
    gen_rpc_client:eval_everywhere(Nodes, M, F, A, SendTO).

-spec yield({pid(), reference()}) -> term() | {badrpc, term()}.
yield(Key) ->
    gen_rpc_client:yield(Key).

-spec nb_yield({pid(), reference()}) -> {value, term()} | timeout.
nb_yield(Key) ->
    gen_rpc_client:nb_yield(Key).

-spec nb_yield({pid(), reference()}, timeout()) -> {value, term()} | timeout.
nb_yield(Key, Timeout) ->
    gen_rpc_client:nb_yield(Key, Timeout).

-spec multicall(atom() | tuple(), atom(), list()) -> {list(), list()}.
multicall(M, F, A) ->
    gen_rpc_client:multicall(M, F, A).

-spec multicall([node_or_tuple()] | atom() | tuple(), atom() | tuple(), atom() | list(), list() | timeout()) -> {list(), list()}.
multicall(NodesOrModule, MorF, ForA, AorTimeout) ->
    gen_rpc_client:multicall(NodesOrModule, MorF, ForA, AorTimeout).

-spec multicall([node_or_tuple()], atom() | tuple(), atom(), list(), timeout()) -> {list(), list()}.
multicall(Nodes, M, F, A, Timeout) ->
    gen_rpc_client:multicall(Nodes, M, F, A, Timeout).

-spec abcast(atom(), term()) -> abcast.
abcast(Name, Msg) when is_atom(Name) ->
    gen_rpc_client:abcast(Name, Msg).

-spec abcast(list(), atom(), term()) -> abcast.
abcast(Nodes, Name, Msg) when is_list(Nodes), is_atom(Name) ->
    gen_rpc_client:abcast(Nodes, Name, Msg).

-spec sbcast(atom(), term()) -> {list(), list()}.
sbcast(Name, Msg) when is_atom(Name) ->
    gen_rpc_client:sbcast(Name, Msg).

-spec sbcast(list(), atom(), term()) -> {list(), list()}.
sbcast(Nodes, Name, Msg) when is_list(Nodes), is_atom(Name) ->
    gen_rpc_client:sbcast(Nodes, Name, Msg).

-spec nodes() -> list().
nodes() ->
    gen_rpc_client_sup:nodes().