Packages
nitro
7.4.2
11.4.16
11.4.15
11.4.14
9.9.7
9.9.6
8.2.4
8.2.3
8.2.2
8.2.1
8.2.0
7.12.1
7.10.0
7.9.3
7.9.2
7.9.1
7.9.0
7.8.3
7.8.2
7.8.0
7.7.1
7.7.0
7.6.2
7.6.1
7.6.0
7.5.0
7.4.2
7.4.1
7.4.0
7.2.1
7.2.0
7.1.1
7.1.0
6.12.0
6.11.11
6.11.10
6.11.9
6.11.8
6.11.7
6.11.6
6.11.4
6.11.2
6.11.1
6.10.9
6.10.8
6.10.7
6.10.6
6.10.5
6.10.4
6.10.3
6.10.2
6.10.1
6.9.1
6.6.1
6.5.0
6.4.4
6.4.3
6.4.2
6.4.1
6.4.0
5.12.4
5.12.3
5.12.2
5.12.1
5.12.0
5.11.1
5.11.0
5.9.2
5.9.1
5.8.5
5.8.4
5.8.3
5.8.1
5.8.0
5.6.1
5.5.1
5.4.3
5.4.2
5.4.1
5.3.1
5.3.0
5.2.1
5.1.7
5.1.6
5.1.5
5.1.4
5.1.3
5.1.2
5.1.1
4.12.11
4.12.10
4.12.9
4.12.8
4.12.7
4.12.6
4.12.5
4.12.4
4.12.3
4.12.2
4.12.1
4.12.0
4.11.13
4.11.12
4.11.11
4.11.10
4.11.9
4.11.8
4.11.7
4.11.6
4.11.5
4.11.4
4.11.3
4.11.2
4.11.1
4.11.0
4.10.9
4.10.8
4.10.7
4.10.6
4.10.5
4.10.4
4.10.3
4.10.2
4.10.1
4.10.0
4.7.7
4.7.4
4.7.3
4.7.2
4.7.1
4.7.0
4.4.1
4.4.0
1.4.0
NITRO Nitrogen Web Framework
Current section
Files
Jump to
Current section
Files
src/nitro_n2o.erl
-module(nitro_n2o).
-description('N2O Nitrogen Web Framework Protocol').
-include_lib("nitro/include/n2o.hrl").
-export([info/3,
render_actions/1,
io/1,
io/2,
event/1]).
% Nitrogen pickle handler
info({text, <<"N2O,", Auth/binary>>}, Req, State) ->
info(#init{token = Auth}, Req, State);
info(#init{token = Auth}, Req, State) ->
{'Token', Token} = nitro:authenticate([], Auth),
Sid = case nitro:depickle(Token) of
{{S, _}, _} -> S;
X -> X
end,
New = State#cx{session = Sid, token = Auth},
put(context, New),
{reply,
{bert,
case io(init, State) of
{io, _, {stack, _}} = Io -> Io;
{io, Code, _} -> {io, Code, {'Token', Token}}
end},
Req,
New};
info(#client{data = Message}, Req, State) ->
nitro:actions([]),
{reply,
{bert, io(#client{data = Message}, State)},
Req,
State};
info(#pickle{} = Event, Req, State) ->
nitro:actions([]),
{reply, {bert, html_events(Event, State)}, Req, State};
info(#flush{data = Actions}, Req, State) ->
nitro:actions(Actions),
{reply, {bert, io(<<>>)}, Req, State};
info(#direct{data = Message}, Req, State) ->
nitro:actions([]),
{reply,
{bert,
case io(Message, State) of
{io, _, {stack, _}} = Io -> Io;
{io, Code, Res} -> {io, Code, {direct, Res}}
end},
Req,
State};
info(Message, Req, State) ->
{unknown, Message, Req, State}.
% double render: actions could generate actions
render_actions(Actions) ->
nitro:actions([]),
First = nitro:render(Actions),
Second = nitro:render(nitro:actions()),
nitro:actions([]),
nitro:to_binary([First, Second]).
% n2o events
html_events(#pickle{source = Source, pickled = Pickled,
args = Linked},
State = #cx{token = Token}) ->
Ev = nitro:depickle(Pickled),
L = nitro:prolongate(),
Res = case Ev of
#ev{} when L =:= false ->
render_ev(Ev, Source, Linked, State),
<<>>;
#ev{} ->
render_ev(Ev, Source, Linked, State),
nitro:authenticate([], Token);
_CustomEnvelop -> %?LOG_ERROR("EV expected: ~p~n",[CustomEnvelop]),
{error, "EV expected"}
end,
io(Res).
% calling user code in exception-safe manner
-ifdef(OTP_RELEASE).
render_ev(#ev{module = M, name = F, msg = P,
trigger = T},
_Source, Linked, State) ->
try case F of
api_event -> M:F(P, Linked, State);
event ->
[erlang:put(K, V) || {K, V} <- Linked],
M:F(P);
_ -> M:F(P, T, State)
end
catch
E:R:S ->
?LOG_EXCEPTION(E, R, S),
{stack, S}
end.
io(Event, #cx{module = Module}) ->
try X = Module:event(Event),
{io, render_actions(nitro:actions()), X}
catch
E:R:S ->
?LOG_EXCEPTION(E, R, S),
{io, [], {stack, S}}
end.
io(Data) ->
try {io, render_actions(nitro:actions()), Data} catch
E:R:S ->
?LOG_EXCEPTION(E, R, S),
{io, [], {stack, S}}
end.
-else.
render_ev(#ev{module = M, name = F, msg = P,
trigger = T},
_Source, Linked, State) ->
try case F of
api_event -> M:F(P, Linked, State);
event ->
[erlang:put(K, V) || {K, V} <- Linked],
M:F(P);
_ -> M:F(P, T, State)
end
catch
E:R ->
S = erlang:get_stacktrace(),
?LOG_EXCEPTION(E, R, S),
{stack, S}
end.
io(Event, #cx{module = Module}) ->
try X = Module:event(Event),
{io, render_actions(nitro:actions()), X}
catch
E:R ->
S = erlang:get_stacktrace(),
?LOG_EXCEPTION(E, R, S),
{io, <<>>, {stack, S}}
end.
io(Data) ->
try {io, render_actions(nitro:actions()), Data} catch
E:R ->
S = erlang:get_stacktrace(),
?LOG_EXCEPTION(E, R, S),
{io, <<>>, {stack, S}}
end.
-endif.
% event Nitrogen Web Framework protocol
event(_) -> [].