1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
|
%% An example JSON-RPC service
%%---------------------------------------------------------------------------
%% Copyright (c) 2007-2010 Tony Garnock-Jones <tonygarnockjones@gmail.com>
%% Copyright (c) 2007-2010 LShift Ltd. <query@lshift.net>
%%
%% Permission is hereby granted, free of charge, to any person
%% obtaining a copy of this software and associated documentation
%% files (the "Software"), to deal in the Software without
%% restriction, including without limitation the rights to use, copy,
%% modify, merge, publish, distribute, sublicense, and/or sell copies
%% of the Software, and to permit persons to whom the Software is
%% furnished to do so, subject to the following conditions:
%%
%% The above copyright notice and this permission notice shall be
%% included in all copies or substantial portions of the Software.
%%
%% THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
%% EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
%% MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
%% NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
%% BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
%% ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
%% CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
%% SOFTWARE.
%%---------------------------------------------------------------------------
-module(test_jsonrpc_inets).
-include("rfc4627_jsonrpc.hrl").
-behaviour(gen_server).
-export([start/0, start_httpd/0]).
-export([init/1, terminate/2, code_change/3, handle_call/3, handle_cast/2, handle_info/2]).
start() ->
{ok, Pid} = gen_server:start(?MODULE, [], []),
rfc4627_jsonrpc:register_service
(Pid,
rfc4627_jsonrpc:service(<<"test">>,
<<"urn:uuid:afe1b4b5-23b0-4964-a74a-9168535c96b2">>,
<<"1.0">>,
[#service_proc{name = <<"test_proc">>,
idempotent = true,
params = [#service_proc_param{name = <<"value">>,
type = <<"str">>}]},
#service_proc{name = <<"crash">>,
idempotent = false,
params = []}])).
start_httpd() ->
ok = case rfc4627_jsonrpc:start() of
{ok, _JsonrpcPid} -> ok;
{error, {already_started, _JsonrpcPid}} -> ok
end,
ok = inets:start(),
{ok, _HttpdPid} = inets:start(httpd, [{file, "test/server_root/conf/httpd.conf"}]),
start().
%---------------------------------------------------------------------------
init(_Args) ->
{ok, no_state}.
terminate(_Reason, _State) ->
ok.
code_change(_OldVsn, State, _Extra) ->
{ok, State}.
handle_call({jsonrpc, <<"test_proc">>, _ModData, [Value]}, _From, State) ->
{reply, {result, <<"ErlangServer: ", Value/binary>>}, State};
handle_call({jsonrpc, <<"crash">>, _ModData, []}, _From, _State) ->
exit(deliberate_crash).
handle_cast(Request, State) ->
error_logger:error_msg("Unhandled cast in test_jsonrpc: ~p", [Request]),
{noreply, State}.
handle_info(Info, State) ->
error_logger:error_msg("Unhandled info in test_jsonrpc: ~p", [Info]),
{noreply, State}.
|
