mobiler 0.11.0

Build mobile apps in Rust — one core, native UI on Android, iOS, and the web (CLI)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

// Rust app-side usage of the websocket plugin (drop into shared/src/app.rs).
// The streaming receive is modeled as a self-re-issuing `recv` loop: each frame's handler
// kicks off the next recv, until the socket closes (ok:false, output "closed").

use mobiler_core::*;
use serde::{Deserialize, Serialize};

#[derive(Serialize, Deserialize, Clone)]
pub enum Msg {
    Connect,
    WsOpen(PluginResponse),
    SendPing,
    Sent(PluginResponse),
    WsFrame(PluginResponse),
    Disconnect,
    Noop(PluginResponse),
}

#[derive(Default, Serialize, Deserialize)]
pub struct Model {
    pub connected: bool,
    pub log: Vec<String>,
}

impl MyApp {
    fn handle(&self, msg: Msg, model: &mut Model, cx: &mut Cx<Msg>) {
        match msg {
            Msg::Connect => cx.plugin("websocket", "connect", "wss://echo.websocket.org", Msg::WsOpen),
            Msg::WsOpen(resp) => {
                model.connected = resp.ok;
                if resp.ok {
                    model.log.push("connected".into());
                    // Start the receive loop.
                    cx.plugin("websocket", "recv", "", Msg::WsFrame);
                } else {
                    model.log.push(format!("connect failed: {}", resp.output));
                }
            }
            Msg::SendPing => cx.plugin("websocket", "send", "ping", Msg::Sent),
            Msg::Sent(_) => model.log.push("sent: ping".into()),
            Msg::WsFrame(resp) => {
                if resp.ok {
                    model.log.push(format!("recv: {}", resp.output));
                    // Re-issue recv to keep streaming.
                    cx.plugin("websocket", "recv", "", Msg::WsFrame);
                } else {
                    // output == "closed" → stop the loop.
                    model.connected = false;
                    model.log.push("disconnected".into());
                }
            }
            Msg::Disconnect => cx.plugin("websocket", "close", "", Msg::Noop),
            Msg::Noop(_) => {}
        }
    }
}