1 |
|
%%%---------------------------------------------------------------------- |
2 |
|
%%% File : mod_event_pusher_http.erl |
3 |
|
%%% Author : Baibossynv Valery <baibossynov.valery@gmail.com> |
4 |
|
%%% Purpose : Message passing via http |
5 |
|
%%% Created : 16 Dec 2015 by Baibossynv Valery <baibossynov.valery@gmail.com> |
6 |
|
%%%---------------------------------------------------------------------- |
7 |
|
|
8 |
|
-module(mod_event_pusher_http). |
9 |
|
-author("baibossynov.valery@gmail.com"). |
10 |
|
|
11 |
|
-ignore_xref([behaviour_info/1]). |
12 |
|
|
13 |
|
-behaviour(gen_mod). |
14 |
|
-behaviour(mod_event_pusher). |
15 |
|
-behaviour(mongoose_module_metrics). |
16 |
|
|
17 |
|
-callback should_make_req(Acc :: mongoose_acc:t(), |
18 |
|
Dir :: in | out, |
19 |
|
Packet :: exml:element(), |
20 |
|
From :: jid:jid(), |
21 |
|
To :: jid:jid(), |
22 |
|
Opts :: [{atom(), term()}]) -> boolean(). |
23 |
|
-callback prepare_headers(Acc :: mongoose_acc:t(), |
24 |
|
Dir :: in | out, |
25 |
|
Host :: jid:lserver(), |
26 |
|
Message :: binary(), |
27 |
|
Sender :: jid:luser(), |
28 |
|
Receiver :: jid:luser(), |
29 |
|
Opts :: [{atom(), term()}]) -> [{binary(), binary()}]. |
30 |
|
-callback prepare_body(Acc :: mongoose_acc:t(), |
31 |
|
Dir :: in | out, |
32 |
|
Host :: jid:lserver(), |
33 |
|
Message :: binary(), |
34 |
|
Sender :: jid:luser(), |
35 |
|
Receiver :: jid:luser(), |
36 |
|
Opts :: [{atom(), term()}]) -> binary(). |
37 |
|
|
38 |
|
-include("mod_event_pusher_events.hrl"). |
39 |
|
-include("jlib.hrl"). |
40 |
|
|
41 |
|
%% API |
42 |
|
-export([start/2, stop/1, config_spec/0, push_event/3]). |
43 |
|
|
44 |
|
-include("mongoose.hrl"). |
45 |
|
-include("jlib.hrl"). |
46 |
|
-include("mongoose_config_spec.hrl"). |
47 |
|
|
48 |
|
-define(DEFAULT_POOL_NAME, http_pool). |
49 |
|
-define(DEFAULT_PATH, ""). |
50 |
|
|
51 |
|
-define(SENT_METRIC, [mod_event_pusher_http, sent]). |
52 |
|
-define(FAILED_METRIC, [mod_event_pusher_http, failed]). |
53 |
|
-define(RESPONSE_METRIC, [mod_event_pusher_http, response_time]). |
54 |
|
|
55 |
|
start(Host, _Opts) -> |
56 |
:-( |
ensure_metrics(Host), |
57 |
:-( |
ok. |
58 |
|
|
59 |
|
stop(_Host) -> |
60 |
:-( |
ok. |
61 |
|
|
62 |
|
config_spec() -> |
63 |
146 |
#section{ |
64 |
|
items = #{<<"pool_name">> => #option{type = atom, |
65 |
|
validate = pool_name}, |
66 |
|
<<"path">> => #option{type = string}, |
67 |
|
<<"callback_module">> => #option{type = atom, |
68 |
|
validate = module} |
69 |
|
} |
70 |
|
}. |
71 |
|
|
72 |
|
push_event(Acc, _Host, #chat_event{direction = Dir, from = From, to = To, packet = Packet}) -> |
73 |
:-( |
lists:map(fun(Opts) -> push_event(Acc, Dir, From, To, Packet, Opts) end, |
74 |
|
gen_mod:get_module_opt(From#jid.lserver, ?MODULE, configs, [])), |
75 |
:-( |
Acc; |
76 |
|
push_event(Acc, _Host, _Event) -> |
77 |
:-( |
Acc. |
78 |
|
|
79 |
|
push_event(Acc, Dir, From, To, Packet, Opts) -> |
80 |
:-( |
Body = exml_query:path(Packet, [{element, <<"body">>}, cdata], <<>>), |
81 |
:-( |
Mod = get_callback_module(Opts), |
82 |
:-( |
case Mod:should_make_req(Acc, Dir, Packet, From, To, Opts) of |
83 |
|
true -> |
84 |
:-( |
make_req(Acc, Dir, From#jid.lserver, From#jid.luser, To#jid.luser, Body, Opts); |
85 |
|
_ -> |
86 |
:-( |
ok |
87 |
|
end, |
88 |
:-( |
Acc. |
89 |
|
|
90 |
|
%%%=================================================================== |
91 |
|
%%% Internal functions |
92 |
|
%%%=================================================================== |
93 |
|
|
94 |
|
get_callback_module(Opts) -> |
95 |
:-( |
proplists:get_value(callback_module, Opts, mod_event_pusher_http_defaults). |
96 |
|
|
97 |
|
make_req(Acc, Dir, Host, Sender, Receiver, Message, Opts) -> |
98 |
:-( |
Path = fix_path(list_to_binary(proplists:get_value(path, Opts, ?DEFAULT_PATH))), |
99 |
:-( |
PoolName = proplists:get_value(pool_name, Opts, ?DEFAULT_POOL_NAME), |
100 |
:-( |
Mod = get_callback_module(Opts), |
101 |
:-( |
Body = Mod:prepare_body(Acc, Dir, Host, Message, Sender, Receiver, Opts), |
102 |
:-( |
Headers = Mod:prepare_headers(Acc, Dir, Host, Message, Sender, Receiver, Opts), |
103 |
:-( |
LogMeta = #{what => event_pusher_http_req, |
104 |
|
text => <<"mod_event_pusher_http makes an external HTTP call">>, |
105 |
|
path => Path, body => Body, headers => Headers, |
106 |
|
sender => Sender, receiver => Receiver, direction => Dir, |
107 |
|
server => Host, pool_name => PoolName, acc => Acc}, |
108 |
:-( |
?LOG_INFO(LogMeta), |
109 |
:-( |
T0 = os:timestamp(), |
110 |
:-( |
{Res, Elapsed} = case mongoose_http_client:post(Host, PoolName, Path, Headers, Body) of |
111 |
|
{ok, _} -> |
112 |
:-( |
{ok, timer:now_diff(os:timestamp(), T0)}; |
113 |
|
{error, Reason} -> |
114 |
:-( |
{{error, Reason}, 0} |
115 |
|
end, |
116 |
:-( |
record_result(Host, Res, Elapsed, LogMeta), |
117 |
:-( |
ok. |
118 |
|
|
119 |
|
ensure_metrics(Host) -> |
120 |
:-( |
mongoose_metrics:ensure_metric(Host, ?SENT_METRIC, spiral), |
121 |
:-( |
mongoose_metrics:ensure_metric(Host, ?FAILED_METRIC, spiral), |
122 |
:-( |
mongoose_metrics:ensure_metric(Host, ?RESPONSE_METRIC, histogram), |
123 |
:-( |
ok. |
124 |
|
|
125 |
|
record_result(Host, ok, Elapsed, _LogMeta) -> |
126 |
:-( |
mongoose_metrics:update(Host, ?SENT_METRIC, 1), |
127 |
:-( |
mongoose_metrics:update(Host, ?RESPONSE_METRIC, Elapsed), |
128 |
:-( |
ok; |
129 |
|
record_result(Host, {error, Reason}, _, LogMeta) -> |
130 |
:-( |
mongoose_metrics:update(Host, ?FAILED_METRIC, 1), |
131 |
:-( |
?LOG_WARNING(LogMeta#{what => event_pusher_http_req_failed, |
132 |
|
text => <<"mod_event_pusher_http HTTP call failed">>, |
133 |
|
reason => Reason |
134 |
:-( |
}), |
135 |
:-( |
ok. |
136 |
|
|
137 |
|
%% @doc Strip initial slash (it is added by mongoose_http_client) |
138 |
|
fix_path(<<"/", R/binary>>) -> |
139 |
:-( |
R; |
140 |
|
fix_path(R) -> |
141 |
:-( |
R. |