Packages
nitro
5.9.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/n2o_nitro.erl
-module(n2o_nitro).
-description('N2O Nitrogen Web Framework Protocol').
-include_lib("nitro/include/n2o.hrl").
-include_lib("nitro/include/nitro.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} = n2o_session:authenticate([], Auth),
Sid = case n2o: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=#wire{actions=Actions}}, Req, State) ->
io:format("flush ~p~n", [length(Actions)]),
{reply,{bert,{io, Actions, <<>>}},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 = n2o:depickle(Pickled),
L = n2o_session:prolongate(),
Res = case Ev of
#ev{} when L =:= false -> render_ev(Ev,Source,Linked,State), <<>>;
#ev{} -> render_ev(Ev,Source,Linked,State), n2o_session: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(_) -> [].