Sha256: 8a06e271cfb692aa30d88989e3486badab8ecb071a448c405311eb5a90e1bc60
Contents?: true
Size: 1.15 KB
Versions: 14
Compression:
Stored size: 1.15 KB
Contents
-module(cap_internal_api).
-behaviour(bertrpc).
-export([start_link/1]).
-export([init/1, handle_call/3, handle_cast/2,
handle_info/2, terminate/2, code_change/3]).
-record(state, {
user :: binary() | undefined,
services :: [atom()]
}).
-type state() :: #state{} .
-spec start_link([{atom(), atom()}]) -> {ok, pid()} .
start_link(Services) ->
bertrpc:listen_link({local, ?MODULE}, ?MODULE, Services, 6789).
-spec init([{atom(), atom()}]) -> {ok, state()} .
init(Services) ->
{ok, #state{ services = Services }}.
handle_call({M, F, A, I}, From, State) ->
#state { services = Services } = State,
case proplists:get_value(M, Services) of
undefined ->
{reply, {error, service_not_found}, State};
Module ->
Module:handle_call({F, A, I}, From, State)
end.
handle_cast({M, F, A, I}, State) ->
#state { services = Services } = State,
case proplists:get_value(M, Services) of
undefined ->
{noreply, State};
Module ->
Module:handle_cast({F, A, I}, State)
end.
handle_info(_Info, State) ->
{noreply, State}.
terminate(_Reason, _State) ->
ok.
code_change(_OldVsn, State, _Extra) ->
{ok, State}.
Version data entries
14 entries across 14 versions & 1 rubygems