Packages
lustre
4.2.6
5.7.1
5.7.0
5.6.0
5.5.2
5.5.1
5.5.0
5.4.0
5.3.5
5.3.4
5.3.3
5.3.2
5.3.1
5.3.0
5.2.1
5.2.0
5.1.1
5.1.0
5.0.3
5.0.2
5.0.1
5.0.0
4.6.4
4.6.3
4.6.2
4.6.1
4.6.0
4.5.1
4.5.0
4.4.4
4.4.3
4.4.1
4.4.0
4.3.6
4.3.5
4.3.4
4.3.3
4.3.2
4.3.1
4.3.0
4.2.6
4.2.5
4.2.4
4.2.3
4.2.2
4.2.1
4.2.0
4.1.8
4.1.7
4.1.6
4.1.5
4.1.4
4.1.3
4.1.2
4.1.1
4.1.0
4.0.0
4.0.0-rc1
4.0.0-rc.2
3.1.4
3.1.3
3.1.2
3.1.1
3.1.0
3.0.12
3.0.11
3.0.10
3.0.9
3.0.8
3.0.7
3.0.6
3.0.5
3.0.4
3.0.3
3.0.2
3.0.1
3.0.0
3.0.0-rc.8
3.0.0-rc.7
3.0.0-rc.6
3.0.0-rc.5
3.0.0-rc.4
3.0.0-rc.3
3.0.0-rc.2
3.0.0-rc.1
2.0.1
2.0.0
1.3.0
1.2.0
1.1.0
1.0.0
Create HTML templates, single page applications, Web Components, and real-time server components in Gleam!
Current section
Files
Jump to
Current section
Files
src/lustre@internals@runtime.erl
-module(lustre@internals@runtime).
-compile([no_auto_import, nowarn_unused_vars, nowarn_unused_function, nowarn_nomatch]).
-export([start/4]).
-export_type([state/3, action/2, debug_action/0]).
-type state(OXG, OXH, OXI) :: {state,
gleam@erlang@process:subject(action(OXH, OXI)),
OXG,
fun((OXG, OXH) -> {OXG, lustre@effect:effect(OXH)}),
fun((OXG) -> lustre@internals@vdom:element(OXH)),
lustre@internals@vdom:element(OXH),
gleam@dict:dict(binary(), fun((lustre@internals@patch:patch(OXH)) -> nil)),
gleam@dict:dict(binary(), fun((gleam@dynamic:dynamic_()) -> {ok, OXH} |
{error, list(gleam@dynamic:decode_error())})),
gleam@dict:dict(binary(), fun((gleam@dynamic:dynamic_()) -> {ok, OXH} |
{error, list(gleam@dynamic:decode_error())}))}.
-type action(OXJ, OXK) :: {attrs, list({binary(), gleam@dynamic:dynamic_()})} |
{batch, list(OXJ), lustre@effect:effect(OXJ)} |
{debug, debug_action()} |
{dispatch, OXJ} |
{emit, binary(), gleam@json:json()} |
{event, binary(), gleam@dynamic:dynamic_()} |
{set_selector, gleam@erlang@process:selector(action(OXJ, OXK))} |
shutdown |
{subscribe, binary(), fun((lustre@internals@patch:patch(OXJ)) -> nil)} |
{unsubscribe, binary()}.
-type debug_action() :: {force_model, gleam@dynamic:dynamic_()} |
{model, fun((gleam@dynamic:dynamic_()) -> nil)} |
{view,
fun((lustre@internals@vdom:element(gleam@dynamic:dynamic_())) -> nil)}.
-spec run_renderers(
gleam@dict:dict(any(), fun((lustre@internals@patch:patch(OYP)) -> nil)),
lustre@internals@patch:patch(OYP)
) -> nil.
run_renderers(Renderers, Patch) ->
gleam@dict:fold(Renderers, nil, fun(_, _, Renderer) -> Renderer(Patch) end).
-spec run_effects(
lustre@effect:effect(OYU),
gleam@erlang@process:subject(action(OYU, any()))
) -> nil.
run_effects(Effects, Self) ->
Dispatch = fun(Msg) -> gleam@otp@actor:send(Self, {dispatch, Msg}) end,
Emit = fun(Name, Event) ->
gleam@otp@actor:send(Self, {emit, Name, Event})
end,
lustre@effect:perform(Effects, Dispatch, Emit).
-spec loop(action(OXZ, OYA), state(OYD, OXZ, OYA)) -> gleam@otp@actor:next(action(OXZ, OYA), state(OYD, OXZ, OYA)).
loop(Message, State) ->
case Message of
{attrs, Attrs} ->
_pipe@1 = gleam@list:filter_map(
Attrs,
fun(Attr) ->
case gleam@dict:get(
erlang:element(9, State),
erlang:element(1, Attr)
) of
{error, _} ->
{error, nil};
{ok, Decoder} ->
_pipe = Decoder(erlang:element(2, Attr)),
gleam@result:replace_error(_pipe, nil)
end
end
),
_pipe@2 = {batch, _pipe@1, lustre@effect:none()},
loop(_pipe@2, State);
{batch, [], _} ->
gleam@otp@actor:continue(State);
{batch, [Msg], Other_effects} ->
{Model, Effects} = (erlang:element(4, State))(
erlang:element(3, State),
Msg
),
Html = (erlang:element(5, State))(Model),
Diff = lustre@internals@patch:elements(
erlang:element(6, State),
Html
),
Next = erlang:setelement(
8,
erlang:setelement(6, erlang:setelement(3, State, Model), Html),
erlang:element(5, Diff)
),
run_effects(
lustre@effect:batch([Effects, Other_effects]),
erlang:element(2, State)
),
case lustre@internals@patch:is_empty_element_diff(Diff) of
true ->
nil;
false ->
run_renderers(erlang:element(7, State), {diff, Diff})
end,
gleam@otp@actor:continue(Next);
{batch, [Msg@1 | Rest], Other_effects@1} ->
{Model@1, Effects@1} = (erlang:element(4, State))(
erlang:element(3, State),
Msg@1
),
Html@1 = (erlang:element(5, State))(Model@1),
Diff@1 = lustre@internals@patch:elements(
erlang:element(6, State),
Html@1
),
Next@1 = erlang:setelement(
8,
erlang:setelement(
6,
erlang:setelement(3, State, Model@1),
Html@1
),
erlang:element(5, Diff@1)
),
loop(
{batch, Rest, lustre@effect:batch([Effects@1, Other_effects@1])},
Next@1
);
{debug, {force_model, Model@2}} ->
Model@3 = gleam@dynamic:unsafe_coerce(Model@2),
Html@2 = (erlang:element(5, State))(Model@3),
Diff@2 = lustre@internals@patch:elements(
erlang:element(6, State),
Html@2
),
Next@2 = erlang:setelement(
8,
erlang:setelement(
6,
erlang:setelement(3, State, Model@3),
Html@2
),
erlang:element(5, Diff@2)
),
case lustre@internals@patch:is_empty_element_diff(Diff@2) of
true ->
nil;
false ->
run_renderers(erlang:element(7, State), {diff, Diff@2})
end,
gleam@otp@actor:continue(Next@2);
{debug, {model, Reply}} ->
Reply(gleam@dynamic:from(erlang:element(3, State))),
gleam@otp@actor:continue(State);
{debug, {view, Reply@1}} ->
Reply@1(
lustre@element:map(
erlang:element(6, State),
fun gleam@dynamic:from/1
)
),
gleam@otp@actor:continue(State);
{dispatch, Msg@2} ->
{Model@4, Effects@2} = (erlang:element(4, State))(
erlang:element(3, State),
Msg@2
),
Html@3 = (erlang:element(5, State))(Model@4),
Diff@3 = lustre@internals@patch:elements(
erlang:element(6, State),
Html@3
),
Next@3 = erlang:setelement(
8,
erlang:setelement(
6,
erlang:setelement(3, State, Model@4),
Html@3
),
erlang:element(5, Diff@3)
),
run_effects(Effects@2, erlang:element(2, State)),
case lustre@internals@patch:is_empty_element_diff(Diff@3) of
true ->
nil;
false ->
run_renderers(erlang:element(7, State), {diff, Diff@3})
end,
gleam@otp@actor:continue(Next@3);
{emit, Name, Event} ->
Patch = {emit, Name, Event},
run_renderers(erlang:element(7, State), Patch),
gleam@otp@actor:continue(State);
{event, Name@1, Event@1} ->
case gleam@dict:get(erlang:element(8, State), Name@1) of
{error, _} ->
gleam@otp@actor:continue(State);
{ok, Handler} ->
_pipe@3 = Handler(Event@1),
_pipe@4 = gleam@result:map(
_pipe@3,
fun(Field@0) -> {dispatch, Field@0} end
),
_pipe@5 = gleam@result:map(
_pipe@4,
fun(_capture) ->
gleam@otp@actor:send(
erlang:element(2, State),
_capture
)
end
),
gleam@result:unwrap(_pipe@5, nil),
gleam@otp@actor:continue(State)
end;
{subscribe, Id, Renderer} ->
Renderers = gleam@dict:insert(
erlang:element(7, State),
Id,
Renderer
),
Next@4 = erlang:setelement(7, State, Renderers),
Renderer(
{init,
gleam@dict:keys(erlang:element(9, State)),
erlang:element(6, State)}
),
gleam@otp@actor:continue(Next@4);
{unsubscribe, Id@1} ->
Renderers@1 = gleam@dict:delete(erlang:element(7, State), Id@1),
Next@5 = erlang:setelement(7, State, Renderers@1),
gleam@otp@actor:continue(Next@5);
{set_selector, Selector} ->
{continue, State, {some, Selector}};
shutdown ->
{stop, killed}
end.
-spec start(
{OXL, lustre@effect:effect(OXM)},
fun((OXL, OXM) -> {OXL, lustre@effect:effect(OXM)}),
fun((OXL) -> lustre@internals@vdom:element(OXM)),
gleam@dict:dict(binary(), fun((gleam@dynamic:dynamic_()) -> {ok, OXM} |
{error, list(gleam@dynamic:decode_error())}))
) -> {ok, gleam@erlang@process:subject(action(OXM, any()))} |
{error, gleam@otp@actor:start_error()}.
start(Init, Update, View, On_attribute_change) ->
Timeout = 1000,
Init@1 = fun() ->
Self = gleam@erlang@process:new_subject(),
Html = View(erlang:element(1, Init)),
Handlers = lustre@internals@vdom:handlers(Html),
State = {state,
Self,
erlang:element(1, Init),
Update,
View,
Html,
gleam@dict:new(),
Handlers,
On_attribute_change},
Selector = gleam@erlang@process:selecting(
gleam_erlang_ffi:new_selector(),
Self,
fun(Msg) -> Msg end
),
run_effects(erlang:element(2, Init), Self),
{ready, State, Selector}
end,
gleam@otp@actor:start_spec({spec, Init@1, Timeout, fun loop/2}).