Packages
lustre
4.6.2
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(QFM, QFN, QFO) :: {state,
gleam@erlang@process:subject(action(QFN, QFO)),
gleam@erlang@process:selector(action(QFN, QFO)),
QFM,
fun((QFM, QFN) -> {QFM, lustre@effect:effect(QFN)}),
fun((QFM) -> lustre@internals@vdom:element(QFN)),
lustre@internals@vdom:element(QFN),
gleam@dict:dict(binary(), fun((lustre@internals@patch:patch(QFN)) -> nil)),
gleam@dict:dict(binary(), fun((gleam@dynamic:dynamic_()) -> {ok, QFN} |
{error, list(gleam@dynamic:decode_error())})),
gleam@dict:dict(binary(), fun((gleam@dynamic:dynamic_()) -> {ok, QFN} |
{error, list(gleam@dynamic:decode_error())}))}.
-type action(QFP, QFQ) :: {attrs, list({binary(), gleam@dynamic:dynamic_()})} |
{batch, list(QFP), lustre@effect:effect(QFP)} |
{debug, debug_action()} |
{dispatch, QFP} |
{emit, binary(), gleam@json:json()} |
{event, binary(), gleam@dynamic:dynamic_()} |
{set_selector, gleam@erlang@process:selector(QFP)} |
shutdown |
{subscribe, binary(), fun((lustre@internals@patch:patch(QFP)) -> nil)} |
{unsubscribe, binary()} |
{gleam_phantom, QFQ}.
-type debug_action() :: {force_model, gleam@dynamic:dynamic_()} |
{model, fun((gleam@dynamic:dynamic_()) -> nil)} |
{view,
fun((lustre@internals@vdom:element(gleam@dynamic:dynamic_())) -> nil)}.
-file("/home/runner/work/lustre/lustre/src/lustre/internals/runtime.gleam", 234).
-spec run_renderers(
gleam@dict:dict(any(), fun((lustre@internals@patch:patch(QGV)) -> nil)),
lustre@internals@patch:patch(QGV)
) -> nil.
run_renderers(Renderers, Patch) ->
gleam@dict:fold(Renderers, nil, fun(_, _, Renderer) -> Renderer(Patch) end).
-file("/home/runner/work/lustre/lustre/src/lustre/internals/runtime.gleam", 243).
-spec run_effects(
lustre@effect:effect(QHA),
gleam@erlang@process:subject(action(QHA, 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,
Select = fun(Selector) ->
gleam@otp@actor:send(Self, {set_selector, Selector})
end,
Root = lustre_escape_ffi:coerce(nil),
lustre@effect:perform(Effects, Dispatch, Emit, Select, Root).
-file("/home/runner/work/lustre/lustre/src/lustre/internals/runtime.gleam", 94).
-spec loop(action(QGF, QGG), state(QGJ, QGF, QGG)) -> gleam@otp@actor:next(action(QGF, QGG), state(QGJ, QGF, QGG)).
loop(Message, State) ->
case Message of
{attrs, Attrs} ->
_pipe@1 = gleam@list:filter_map(
Attrs,
fun(Attr) ->
case gleam@dict:get(
erlang:element(10, 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(5, State))(
erlang:element(4, State),
Msg
),
Html = (erlang:element(6, State))(Model),
Diff = lustre@internals@patch:elements(
erlang:element(7, State),
Html
),
Next = erlang:setelement(
9,
erlang:setelement(7, erlang:setelement(4, 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(8, State), {diff, Diff})
end,
gleam@otp@actor:continue(Next);
{batch, [Msg@1 | Rest], Other_effects@1} ->
{Model@1, Effects@1} = (erlang:element(5, State))(
erlang:element(4, State),
Msg@1
),
Html@1 = (erlang:element(6, State))(Model@1),
Diff@1 = lustre@internals@patch:elements(
erlang:element(7, State),
Html@1
),
Next@1 = erlang:setelement(
9,
erlang:setelement(
7,
erlang:setelement(4, 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 = lustre_escape_ffi:coerce(Model@2),
Html@2 = (erlang:element(6, State))(Model@3),
Diff@2 = lustre@internals@patch:elements(
erlang:element(7, State),
Html@2
),
Next@2 = erlang:setelement(
9,
erlang:setelement(
7,
erlang:setelement(4, 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(8, State), {diff, Diff@2})
end,
gleam@otp@actor:continue(Next@2);
{debug, {model, Reply}} ->
Reply(gleam_stdlib:identity(erlang:element(4, State))),
gleam@otp@actor:continue(State);
{debug, {view, Reply@1}} ->
Reply@1(
lustre@element:map(
erlang:element(7, State),
fun gleam_stdlib:identity/1
)
),
gleam@otp@actor:continue(State);
{dispatch, Msg@2} ->
{Model@4, Effects@2} = (erlang:element(5, State))(
erlang:element(4, State),
Msg@2
),
Html@3 = (erlang:element(6, State))(Model@4),
Diff@3 = lustre@internals@patch:elements(
erlang:element(7, State),
Html@3
),
Next@3 = erlang:setelement(
9,
erlang:setelement(
7,
erlang:setelement(4, 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(8, State), {diff, Diff@3})
end,
gleam@otp@actor:continue(Next@3);
{emit, Name, Event} ->
Patch = {emit, Name, Event},
run_renderers(erlang:element(8, State), Patch),
gleam@otp@actor:continue(State);
{event, Name@1, Event@1} ->
case gleam@dict:get(erlang:element(9, 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(8, State),
Id,
Renderer
),
Next@4 = erlang:setelement(8, State, Renderers),
Renderer(
{init,
gleam@dict:keys(erlang:element(10, State)),
erlang:element(7, State)}
),
gleam@otp@actor:continue(Next@4);
{unsubscribe, Id@1} ->
Renderers@1 = gleam@dict:delete(erlang:element(8, State), Id@1),
Next@5 = erlang:setelement(8, State, Renderers@1),
gleam@otp@actor:continue(Next@5);
{set_selector, Selector} ->
New_selector = gleam_erlang_ffi:merge_selector(
erlang:element(3, State),
gleam_erlang_ffi:map_selector(
Selector,
fun(Field@0) -> {dispatch, Field@0} end
)
),
{continue,
erlang:setelement(3, State, New_selector),
{some, New_selector}};
shutdown ->
{stop, killed}
end.
-file("/home/runner/work/lustre/lustre/src/lustre/internals/runtime.gleam", 60).
-spec start(
{QFR, lustre@effect:effect(QFS)},
fun((QFR, QFS) -> {QFR, lustre@effect:effect(QFS)}),
fun((QFR) -> lustre@internals@vdom:element(QFS)),
gleam@dict:dict(binary(), fun((gleam@dynamic:dynamic_()) -> {ok, QFS} |
{error, list(gleam@dynamic:decode_error())}))
) -> {ok, gleam@erlang@process:subject(action(QFS, 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),
Selector = gleam@erlang@process:selecting(
gleam_erlang_ffi:new_selector(),
Self,
fun(Msg) -> Msg end
),
State = {state,
Self,
Selector,
erlang:element(1, Init),
Update,
View,
Html,
gleam@dict:new(),
Handlers,
On_attribute_change},
run_effects(erlang:element(2, Init), Self),
{ready, State, Selector}
end,
gleam@otp@actor:start_spec({spec, Init@1, Timeout, fun loop/2}).