xoq 0.2.1

X-Embodiment over QUIC - P2P and relay communication for robotics
Documentation 
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
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107

<!DOCTYPE html>
<html lang="en">
<head>
  <meta charset="UTF-8">
  <meta name="viewport" content="width=device-width, initial-scale=1.0">
  <title>xoq subscriber</title>
  <style>
    body { font-family: system-ui, sans-serif; max-width: 600px; margin: 2rem auto; padding: 0 1rem; }
    button { font-size: 1rem; padding: 0.5rem 1rem; margin: 0.5rem 0; cursor: pointer; }
    #log { background: #1a1a1a; color: #0f0; padding: 1rem; height: 300px; overflow-y: auto; font-family: monospace; font-size: 0.9rem; }
    .error { color: #f00; }
    .data { color: #0ff; }
  </style>
</head>
<body>
  <h1>xoq subscriber</h1>
  <div>
    <label>URL: <input type="text" id="url" value="https://cdn.moq.dev/anon" /></label>
  </div>
  <div>
    <label>Path: <input type="text" id="path" value="xoq-duplex" /></label>
  </div>
  <button id="start">Start</button>
  <button id="stop" disabled>Stop</button>
  <h3>Log</h3>
  <div id="log"></div>

  <script type="module">
    import * as Moq from "@moq/lite";

    const logEl = document.getElementById("log");
    const startBtn = document.getElementById("start");
    const stopBtn = document.getElementById("stop");

    let connection = null;
    let running = false;
    const decoder = new TextDecoder();

    function log(msg, className = "") {
      const line = document.createElement("div");
      line.textContent = `[${new Date().toLocaleTimeString()}] ${msg}`;
      if (className) line.className = className;
      logEl.appendChild(line);
      logEl.scrollTop = logEl.scrollHeight;
    }

    startBtn.addEventListener("click", async () => {
      try {
        const url = document.getElementById("url").value;
        const path = document.getElementById("path").value;

        startBtn.disabled = true;
        stopBtn.disabled = false;
        running = true;

        log(`Connecting to ${url}...`);
        connection = await Moq.Connection.connect(new URL(url));
        log("Connected!");

        log(`Subscribing to broadcast: ${path}`);
        const broadcast = connection.consume(Moq.Path.from(path));
        log("Got broadcast handle");

        log("Subscribing to track: serial");
        const track = broadcast.subscribe("serial", 0);
        log("Subscribed to track, waiting for data...");

        while (running) {
          log("Waiting for next group...");
          const group = await track.nextGroup();
          if (!group) {
            log("No more groups");
            break;
          }
          log(`Got group ${group.sequence}`);

          while (running) {
            const frame = await group.readFrame();
            if (!frame) {
              log("End of group");
              break;
            }
            log(`Data: ${decoder.decode(frame)}`, "data");
          }
        }

        log("Loop ended");
      } catch (e) {
        log(`Error: ${e.message}`, "error");
        console.error(e);
      } finally {
        startBtn.disabled = false;
        stopBtn.disabled = true;
      }
    });

    stopBtn.addEventListener("click", async () => {
      log("Stopping...");
      running = false;
      await connection?.close();
      connection = null;
      startBtn.disabled = false;
      stopBtn.disabled = true;
    });
  </script>
</body>
</html>