%-*-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 nomod: %%% %%%------------------------------------------------------------------------ %%% @doc %%% ==CloudI Service API Requests== %%% A service that exposes dynamic configuration of CloudI. %%% @end %%% %%% BSD LICENSE %%% %%% Copyright (c) 2011-2014, Michael Truog %%% All rights reserved. %%% %%% Redistribution and use in source and binary forms, with or without %%% modification, are permitted provided that the following conditions are met: %%% %%% * Redistributions of source code must retain the above copyright %%% notice, this list of conditions and the following disclaimer. %%% * Redistributions in binary form must reproduce the above copyright %%% notice, this list of conditions and the following disclaimer in %%% the documentation and/or other materials provided with the %%% distribution. %%% * All advertising materials mentioning features or use of this %%% software must display the following acknowledgment: %%% This product includes software developed by Michael Truog %%% * The name of the author may not be used to endorse or promote %%% products derived from this software without specific prior %%% written permission %%% %%% THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND %%% CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, %%% INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES %%% OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE %%% DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR %%% CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, %%% SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, %%% BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR %%% SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS %%% INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, %%% WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING %%% NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE %%% OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH %%% DAMAGE. %%% %%% @author Michael Truog %%% @copyright 2011-2014 Michael Truog %%% @version 1.4.0 {@date} {@time} %%%------------------------------------------------------------------------ -module(cloudi_service_api_requests). -author('mjtruog [at] gmail (dot) com'). -behaviour(cloudi_service). %% external interface %% cloudi_service callbacks -export([cloudi_service_init/4, cloudi_service_handle_request/11, cloudi_service_handle_info/3, cloudi_service_terminate/3]). -include_lib("cloudi_core/include/cloudi_logger.hrl"). -record(state, { functions, % method -> {function, arity} lookup formats = trie:new([ % new format code paths {"rpc", fun format_rpc/5}, {"rpc.json", fun format_json_rpc/5}, % old format code paths {"erlang", fun format_erlang/5}, {"json_rpc", fun format_json_rpc/5} ]), prefix_length = undefined }). %%%------------------------------------------------------------------------ %%% External interface functions %%%------------------------------------------------------------------------ %%%------------------------------------------------------------------------ %%% Callback functions from cloudi_service %%%------------------------------------------------------------------------ cloudi_service_init([], Prefix, _Timeout, Dispatcher) -> Exports = reltool_util:module_exports(cloudi_service_api), CloudIServiceAPI = lists:foldl(fun({Method, Arity}, Functions) -> MethodName = erlang:atom_to_list(Method), % service names are (prefix)rpc/(method)(format-extension) % (content-type hint as a file extension) FormatMethod = "rpc/" ++ MethodName ++ ".erl", cloudi_service:subscribe(Dispatcher, FormatMethod), F = if Arity == 1 -> cloudi_service:subscribe(Dispatcher, FormatMethod ++ "/get"), fun (Arg1) -> cloudi_service_api_call(Method, Arg1) end; Arity == 2 -> cloudi_service:subscribe(Dispatcher, FormatMethod ++ "/post"), fun (Arg1, Arg2) -> cloudi_service_api_call(Method, Arg1, Arg2) end end, trie:store(MethodName ++ ".erl", {F, Arity}, Functions) end, trie:new(), Exports), % service names for JSON-RPC are: cloudi_service:subscribe(Dispatcher, "rpc.json"), cloudi_service:subscribe(Dispatcher, "rpc.json/post"), {ok, #state{functions = CloudIServiceAPI, prefix_length = erlang:length(Prefix)}}. cloudi_service_handle_request(_Type, Name, _Pattern, _RequestInfo, Request, Timeout, _Priority, _TransId, _Pid, #state{prefix_length = PrefixLength, functions = Functions, formats = Formats} = State, _Dispatcher) -> {Format, Suffix} = cloudi_string:splitl($/, lists:nthtail(PrefixLength, Name), input), FormatF = trie:fetch(Format, Formats), MethodName = if % method-specific service name Format == "rpc" -> cloudi_string:beforel($/, Suffix, input); true -> "" end, FArity = if MethodName == "" -> undefined; true -> trie:fetch(MethodName, Functions) end, Response = FormatF(MethodName, FArity, Request, Timeout, State), {reply, Response, State}. cloudi_service_handle_info(Request, State, _) -> ?LOG_WARN("Unknown info \"~p\"", [Request]), {noreply, State}. cloudi_service_terminate(_Reason, _Timeout, #state{}) -> ok. %%%------------------------------------------------------------------------ %%% Private functions %%%------------------------------------------------------------------------ format_rpc(MethodName, {F, Arity}, Request, Timeout, #state{}) when is_function(F), is_integer(Arity) -> case filename:extension(MethodName) of ".erl" -> format_erlang_f(F, Arity, Request, Timeout); _ -> <<>> end. format_erlang(_, {F, Arity}, Request, Timeout, #state{}) when is_function(F), is_integer(Arity) -> format_erlang_f(F, Arity, Request, Timeout). format_erlang_f(_, _, Request, _) when not is_binary(Request) -> <<>>; format_erlang_f(F, 1, _, Timeout) -> Result = F(Timeout), cloudi_service_api_result(Result, erlang_string); format_erlang_f(F, 2, Request, Timeout) -> Result = F(cloudi_string:binary_to_term(Request), Timeout), cloudi_service_api_result(Result, erlang_string). -spec format_json_rpc(string(), 'undefined', Request :: any(), Timeout :: integer(), State :: #state{}) -> binary(). format_json_rpc(_, undefined, Request, _, _) when not is_binary(Request) -> cloudi_json_rpc:response_to_json(null, null, <<"not_binary">>, 0); format_json_rpc(_, undefined, Request, Timeout, #state{functions = Functions}) -> try cloudi_json_rpc:request_to_term(Request) of {Method, Params, Id} -> case trie:find(erlang:binary_to_list(Method), Functions) of error -> cloudi_json_rpc:response_to_json(null, 1, <<"invalid_method">>, Id); {ok, {F, 1}} when Params == [] -> format_json_rpc_f(F, 1, undefined, Timeout, Id); {ok, {F, 2}} when length(Params) == 1 -> format_json_rpc_f(F, 2, erlang:hd(Params), Timeout, Id); {ok, _} -> cloudi_json_rpc:response_to_json(null, 2, <<"invalid_params">>, Id) end catch _:_ -> cloudi_json_rpc:response_to_json(null, 0, <<"invalid_json_rpc">>, 0) end. format_json_rpc_f(F, 1, _, Timeout, Id) -> Result = F(Timeout), cloudi_json_rpc:response_to_json( cloudi_service_api_result(Result, erlang_string), Id); format_json_rpc_f(_, 2, Param, _, Id) when not is_binary(Param) -> cloudi_json_rpc:response_to_json(null, 3, <<"invalid_param">>, Id); format_json_rpc_f(F, 2, Param, Timeout, Id) -> Result = F(cloudi_string:binary_to_term(Param), Timeout), cloudi_json_rpc:response_to_json( cloudi_service_api_result(Result, erlang_string), Id). cloudi_service_api_call(services = Method, Timeout) -> case cloudi_service_api:Method(Timeout) of {ok, L} -> {ok, [{service_id(UUID), Data} || {UUID, Data} <- L]}; {error, _} = Error -> Error end; cloudi_service_api_call(Method, Timeout) -> cloudi_service_api:Method(Timeout). cloudi_service_api_call(services_search = Method, Input, Timeout) -> case cloudi_service_api:Method(Input, Timeout) of {ok, L} -> {ok, [{service_id(UUID), Data} || {UUID, Data} <- L]}; {error, _} = Error -> Error end; cloudi_service_api_call(services_add = Method, Input, Timeout) -> case cloudi_service_api:Method(Input, Timeout) of {ok, L} -> {ok, [service_id(UUID) || UUID <- L]}; {error, _} = Error -> Error end; cloudi_service_api_call(Method, Input, Timeout) -> cloudi_service_api:Method(Input, Timeout). cloudi_service_api_result({ok, Result}, erlang_string) -> cloudi_string:term_to_binary(Result); cloudi_service_api_result(Result, erlang_string) -> cloudi_string:term_to_binary(Result). service_id(ID) -> uuid:uuid_to_string(ID, list_nodash).