mobiler 0.31.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

// Rust app-side usage of the websocket plugin (drop into shared/src/app.rs).
// Rides the streaming primitive: `cx.subscribe` opens the socket and delivers a Msg::Frame per
// incoming frame (no app-driven recv loop); `cx.unsubscribe` closes it.

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

#[derive(Serialize, Deserialize, Clone)]
pub enum Msg {
    Connect,
    Frame(PluginResponse),
    SendPing,
    Sent(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 {
            // Open the socket and stream frames — one Msg::Frame per incoming frame, until close.
            Msg::Connect => {
                model.connected = true;
                cx.subscribe("ws", "websocket", "stream", "wss://echo.websocket.org", Msg::Frame);
            }
            Msg::Frame(resp) => {
                if resp.ok {
                    model.log.push(format!("recv: {}", resp.output));
                } else {
                    // output == "closed" → the socket dropped.
                    model.connected = false;
                    model.log.push("disconnected".into());
                }
            }
            // Send a frame while subscribed (request/response op against the same socket).
            Msg::SendPing => cx.plugin("websocket", "send", "ping", Msg::Sent),
            Msg::Sent(_) => model.log.push("sent: ping".into()),
            // Stop streaming + close the socket.
            Msg::Disconnect => {
                cx.unsubscribe("ws");
                model.connected = false;
            }
            Msg::Noop(_) => {}
        }
    }
}