diff options
Diffstat (limited to 'examples/server_demo/src')
-rw-r--r-- | examples/server_demo/src/demo.gleam | 22 | ||||
-rw-r--r-- | examples/server_demo/src/demo/app.gleam | 88 | ||||
-rw-r--r-- | examples/server_demo/src/demo/socket.gleam | 78 | ||||
-rw-r--r-- | examples/server_demo/src/demo/web.gleam | 58 |
4 files changed, 0 insertions, 246 deletions
diff --git a/examples/server_demo/src/demo.gleam b/examples/server_demo/src/demo.gleam deleted file mode 100644 index ebe858a..0000000 --- a/examples/server_demo/src/demo.gleam +++ /dev/null @@ -1,22 +0,0 @@ -// IMPORTS --------------------------------------------------------------------- - -import demo/socket -import demo/web -import gleam/erlang/process -import mist - -// MAIN ------------------------------------------------------------------------ - -pub fn main() { - let assert Ok(_) = - mist.new(fn(req) { - case req.path { - "/ws" -> socket.handle(req) - _ -> web.handle(req) - } - }) - |> mist.port(8000) - |> mist.start_http - - process.sleep_forever() -} diff --git a/examples/server_demo/src/demo/app.gleam b/examples/server_demo/src/demo/app.gleam deleted file mode 100644 index 13d09a8..0000000 --- a/examples/server_demo/src/demo/app.gleam +++ /dev/null @@ -1,88 +0,0 @@ -// IMPORTS --------------------------------------------------------------------- - -import gleam/dict.{type Dict} -import gleam/dynamic.{type Decoder} -import gleam/int -import gleam/json -import gleam/result -import lustre/attribute -import lustre/effect.{type Effect} -import lustre/element.{type Element} -import lustre/element/html -import lustre/event -import lustre/server -import lustre/ui - -// MODEL ----------------------------------------------------------------------- - -pub type Model = - Int - -pub fn init(count: Int) -> #(Model, Effect(Msg)) { - #(count, effect.none()) -} - -// UPDATE ---------------------------------------------------------------------- - -pub opaque type Msg { - Incr - Decr - Reset(Int) -} - -pub fn update(model: Model, msg: Msg) -> #(Model, Effect(Msg)) { - case msg { - Incr -> #(model + 1, effect.none()) - Decr -> #(model - 1, effect.none()) - Reset(count) -> #( - count, - effect.event( - "changed", - json.string("You reset the count to: " <> int.to_string(count)), - ), - ) - } -} - -pub fn on_attribute_change() -> Dict(String, Decoder(Msg)) { - dict.from_list([ - #("count", fn(dyn) { - dyn - |> dynamic.int - |> result.map(Reset) - }), - ]) -} - -// VIEW ------------------------------------------------------------------------ - -pub fn view(model: Model) -> Element(Msg) { - let count = int.to_string(model) - - ui.centre( - [attribute.style([#("width", "100vw"), #("height", "100vh")])], - ui.sequence([], [ - ui.button([event.on_click(Decr)], [element.text("-")]), - ui.centre([], html.span([], [element.text(count)])), - ui.button([event.on_click(Incr)], [element.text("+")]), - ]), - ) - // ui.cluster([], [ - // ui.input([event.on_input(Change), attribute.value(model.input)]), - // html.span([], [element.text(model.input)]), - // ]), - // ui.centre( - // [ - // event.on("mousemove", on_mouse_move), - // server.include(["offsetX", "offsetY"]), - // attribute.style([ - // #("aspect-ratio", "1 / 1 "), - // #("background-color", "var(--element-background)"), - // ]), - // ], - // html.div([], [ - // html.p([], [element.text("x: " <> int.to_string(model.mouse.0))]), - // html.p([], [element.text("y: " <> int.to_string(model.mouse.1))]), - // ]), - // ), -} diff --git a/examples/server_demo/src/demo/socket.gleam b/examples/server_demo/src/demo/socket.gleam deleted file mode 100644 index bc43962..0000000 --- a/examples/server_demo/src/demo/socket.gleam +++ /dev/null @@ -1,78 +0,0 @@ -// IMPORTS --------------------------------------------------------------------- - -import demo/app -import gleam/bit_array -import gleam/erlang/process.{type Subject} -import gleam/function.{identity} -import gleam/http/request.{type Request as HttpRequest} -import gleam/http/response.{type Response as HttpResponse} -import gleam/json -import gleam/option.{Some} -import gleam/otp/actor -import gleam/result -import lustre.{type Action, type ServerComponent} -import lustre/element.{type Patch} -import lustre/server -import mist.{ - type Connection, type ResponseData, type WebsocketConnection, - type WebsocketMessage, -} - -// - -pub fn handle(req: HttpRequest(Connection)) -> HttpResponse(ResponseData) { - mist.websocket(req, update, init, function.constant(Nil)) -} - -type Model(flags, model, msg) { - Model(self: Subject(Patch(msg)), app: Subject(Action(ServerComponent, msg))) -} - -fn init(_) { - let assert Ok(app) = - lustre.component(app.init, app.update, app.view, app.on_attribute_change()) - |> lustre.start_actor(0) - let self = process.new_subject() - let model = Model(self, app) - let selector = process.selecting(process.new_selector(), self, identity) - - actor.send(app, lustre.add_renderer(process.self(), process.send(self, _))) - #(model, Some(selector)) -} - -fn update( - model: Model(flags, model, msg), - conn: WebsocketConnection, - msg: WebsocketMessage(Patch(a)), -) { - case msg { - mist.Text(bits) -> { - let _ = { - use dyn <- json.decode_bits(bits) - use action <- result.try(server.decode_action(dyn)) - - actor.send(model.app, action) - Ok(Nil) - } - - actor.continue(model) - } - mist.Binary(_) -> actor.continue(model) - mist.Closed -> { - actor.send(model.app, lustre.remove_renderer(process.self())) - actor.continue(model) - } - mist.Shutdown -> { - actor.send(model.app, lustre.shutdown()) - actor.Stop(process.Normal) - } - mist.Custom(patch) -> { - element.encode_patch(patch) - |> json.to_string - |> bit_array.from_string - |> mist.send_text_frame(conn, _) - - actor.continue(model) - } - } -} diff --git a/examples/server_demo/src/demo/web.gleam b/examples/server_demo/src/demo/web.gleam deleted file mode 100644 index b8c17e2..0000000 --- a/examples/server_demo/src/demo/web.gleam +++ /dev/null @@ -1,58 +0,0 @@ -// IMPORTS --------------------------------------------------------------------- - -import gleam/http/request.{type Request as HttpRequest} -import gleam/http/response.{type Response as HttpResponse} -import gleam/result -import gleam/string_builder -import lustre/attribute.{attribute} -import lustre/element -import lustre/element/html.{html} -import lustre/server -import lustre/ui/styles -import mist.{type Connection, type ResponseData} -import wisp.{type Request, type Response} - -// - -pub fn handle(req: HttpRequest(Connection)) -> HttpResponse(ResponseData) { - wisp.mist_handler(handler, "")(req) -} - -fn handler(req: Request) -> Response { - use req <- wisp.handle_head(req) - use <- wisp.serve_static(req, under: "/static", from: static_directory()) - - html([attribute("lang", "en")], [ - html.head([], [ - html.meta([attribute("charset", "utf-8")]), - html.meta([ - attribute("name", "viewport"), - attribute("content", "width=device-width, initial-scale=1"), - ]), - styles.elements(), - html.script( - [attribute("type", "module")], - " - import '/static/lustre-server-component.mjs' - - document.addEventListener('DOMContentLoaded', () => { - document - .querySelector('lustre-server-component') - .addEventListener('alert', event => { - console.log(`The server count says: ${event.detail}`) - }) - }) - ", - ), - ]), - html.body([], [server.component([server.route("/ws")])]), - ]) - |> element.to_string_builder - |> string_builder.prepend("<!DOCTYPE html>\n") - |> wisp.html_response(200) -} - -fn static_directory() -> String { - wisp.priv_directory("lustre") - |> result.unwrap("") -} |