diff --git a/dimos/teleop/README.md b/dimos/teleop/README.md
index e64a7b43ea..fac35ab512 100644
--- a/dimos/teleop/README.md
+++ b/dimos/teleop/README.md
@@ -1,29 +1,33 @@
 # Teleop Stack
 
-Teleoperation modules for DimOS. Currently supports Meta Quest 3 VR controllers.
+Teleoperation modules for DimOS. Supports Meta Quest 3 VR controllers and phone motion sensors.
 
 ## Architecture
 
 ```
-Quest Browser (WebXR)
+Quest/Phone Browser
     │
-    │  PoseStamped + Joy via WebSocket
+    │  LCM-encoded binary via WebSocket
     ▼
-Deno Bridge (teleop_server.ts)
+Embedded FastAPI Server (HTTPS)
     │
-    │  LCM topics
+    │  Fingerprint-based message dispatch
     ▼
-QuestTeleopModule
-    │  WebXR → robot frame transform
-    │  Pose computation + button state packing
+TeleopModule (Quest or Phone)
+    │  Frame transforms + pose/twist computation
     ▼
 PoseStamped / TwistStamped / Buttons outputs
 ```
 
+Each teleop module embeds a `RobotWebInterface` (FastAPI + uvicorn) that:
+- Serves the teleop web app at `/teleop`
+- Accepts WebSocket connections at `/ws`
+- Handles SSL certificate generation for HTTPS (required by mobile sensor APIs)
+
 ## Modules
 
 ### QuestTeleopModule
-Base teleop module. Gets controller data, computes output poses, and publishes them. Default engage: hold primary button (X/A). Subclass to customize.
+Base Quest teleop module. Gets controller data via WebSocket, computes output poses, and publishes them. Default engage: hold primary button (X/A). Subclass to customize.
 
 ### ArmTeleopModule
 Toggle-based engage — press primary button once to engage, press again to disengage.
@@ -34,6 +38,12 @@ Outputs TwistStamped (linear + angular velocity) instead of PoseStamped.
 ### VisualizingTeleopModule
 Adds Rerun visualization for debugging. Extends ArmTeleopModule (toggle engage).
 
+### PhoneTeleopModule
+Base phone teleop module. Receives orientation + gyro data from phone motion sensors, computes velocity commands from orientation deltas.
+
+### SimplePhoneTeleop
+Filters to mobile-base axes (linear.x, linear.y, angular.z) and publishes as `Twist`.
+
 ## Subclassing
 
 `QuestTeleopModule` is designed for extension. Override these methods:
@@ -60,16 +70,14 @@ teleop/
 │   ├── quest_teleop_module.py   # Base Quest teleop module
 │   ├── quest_extensions.py      # ArmTeleop, TwistTeleop, VisualizingTeleop
 │   ├── quest_types.py           # QuestControllerState, Buttons
-│   └── web/                     # Deno bridge + WebXR client
-│       ├── teleop_server.ts
-│       └── static/index.html
+│   └── web/
+│       └── static/index.html    # WebXR client
 ├── phone/
 │   ├── phone_teleop_module.py   # Base Phone teleop module
 │   ├── phone_extensions.py      # SimplePhoneTeleop
 │   ├── blueprints.py            # Pre-wired configurations
-│   └── web/                     # Deno bridge + mobile web app
-│       ├── teleop_server.ts
-│       └── static/index.html
+│   └── web/
+│       └── static/index.html    # Mobile sensor web app
 ├── utils/
 │   ├── teleop_transforms.py     # WebXR → robot frame math
 │   └── teleop_visualization.py  # Rerun visualization helpers
@@ -78,4 +86,11 @@ teleop/
 
 ## Quick Start
 
-See [Quest Web README](quest/web/README.md) for running the Deno bridge and connecting the Quest headset.
+```bash
+dimos run arm-teleop            # Quest arm teleop
+dimos run phone-go2-teleop      # Phone → Go2
+```
+
+Open `https://<host-ip>:<port>/teleop` on device. Accept the self-signed certificate.
+- Quest: port 8443
+- Phone: port 8444
diff --git a/dimos/teleop/phone/README.md b/dimos/teleop/phone/README.md
index dd2af02281..5f8541f602 100644
--- a/dimos/teleop/phone/README.md
+++ b/dimos/teleop/phone/README.md
@@ -5,66 +5,34 @@ Teleoperation via smartphone motion sensors. Tilt to drive.
 ## Architecture
 
 ```
-Phone Browser (DeviceOrientation + DeviceMotion)
-    |
-    |  TwistStamped + Bool via WebSocket
-    v
-Deno Bridge (teleop_server.ts)
-    |
-    |  LCM topics
-    v
-PhoneTeleopModule
-    |  Orientation delta from home pose
-    |  Gains -> velocity commands
-    v
-TwistStamped / Twist outputs
+Phone Browser  ──WebSocket──→  Embedded HTTPS Server  ──→  PhoneTeleopModule
+(sensors + button)              (port 8444)                  (delta → velocity)
 ```
 
-## Modules
+## Running
 
-### PhoneTeleopModule
-Base module. Receives raw sensor data and button state. On engage (button hold), captures home orientation and publishes deltas as TwistStamped. Launches the Deno bridge server automatically.
+```bash
+dimos run phone-go2-teleop     # Go2
+dimos run simple-phone-teleop  # Generic ground robot
+```
 
-### SimplePhoneTeleop
-Filters to mobile-base axes (linear.x, linear.y, angular.z) and publishes as `Twist` on `cmd_vel` for direct autoconnect wiring with any module that has `cmd_vel: In[Twist]`.
+Open `https://<host-ip>:8444/teleop` on phone. Accept cert, allow sensors, connect, hold to drive.
 
 ## Subclassing
 
-Override these methods:
-
 | Method | Purpose |
 |--------|---------|
 | `_handle_engage()` | Customize engage/disengage logic |
-| `_should_publish()` | Add conditions for when to publish |
 | `_publish_msg()` | Change output format |
 
-**Do not acquire `self._lock` in overrides.** The control loop already holds it.
-
-## LCM Topics
-
-| Topic | Type | Description |
-|-------|------|-------------|
-| `/phone_sensors` | TwistStamped | linear=(roll,pitch,yaw) deg, angular=(gyro) deg/s |
-| `/phone_button` | Bool | Teleop engage button (1=held) |
-| `/teleop/twist` | TwistStamped | Output velocity command |
-
-## Running
-
-```bash
-dimos run phone-go2-teleop     # Go2
-dimos run simple-phone-teleop  # Generic ground robot
-```
-
-Server starts on port `8444`. Open `https://<host-ip>:8444` on phone, accept the self-signed certificate, allow sensor permissions, connect, hold button to drive.
+`self._lock` is already held — don't acquire it in overrides.
 
 ## File Structure
 
 ```
 phone/
-├── phone_teleop_module.py   # Base phone teleop module
+├── phone_teleop_module.py   # Base module
 ├── phone_extensions.py      # SimplePhoneTeleop
-├── blueprints.py            # Pre-wired configurations
-└── web/
-    ├── teleop_server.ts     # Deno WSS-to-LCM bridge
-    └── static/index.html    # Mobile web app
+├── blueprints.py
+└── web/static/index.html    # Mobile web app
 ```
diff --git a/dimos/teleop/phone/phone_teleop_module.py b/dimos/teleop/phone/phone_teleop_module.py
index ec33df58eb..4d40b995f3 100644
--- a/dimos/teleop/phone/phone_teleop_module.py
+++ b/dimos/teleop/phone/phone_teleop_module.py
@@ -17,43 +17,48 @@
 Phone Teleoperation Module.
 
 Receives raw sensor data (TwistStamped) and button state (Bool) from the
-phone web app via the Deno LCM bridge.  Computes orientation deltas from
-a initial orientation captured on engage, converts to TwistStamped velocity
-commands via configurable gains, and publishes.
-
+phone web app via an embedded FastAPI WebSocket server.  Computes orientation
+deltas from an initial orientation captured on engage, converts to TwistStamped
+velocity commands via configurable gains, and publishes.
 """
 
 from dataclasses import dataclass
 from pathlib import Path
-import shutil
-import signal
-import subprocess
 import threading
 import time
 from typing import Any
 
-from reactivex.disposable import Disposable
+from dimos_lcm.geometry_msgs import TwistStamped as LCMTwistStamped
+from dimos_lcm.std_msgs import Bool as LCMBool
+from fastapi import WebSocket, WebSocketDisconnect
+from fastapi.responses import HTMLResponse
+from fastapi.staticfiles import StaticFiles
 
 from dimos.core.core import rpc
 from dimos.core.module import Module, ModuleConfig
-from dimos.core.stream import In, Out
+from dimos.core.stream import Out
 from dimos.msgs.geometry_msgs import Twist, TwistStamped, Vector3
 from dimos.msgs.std_msgs.Bool import Bool
 from dimos.utils.logging_config import setup_logger
+from dimos.utils.path_utils import get_project_root
+from dimos.web.robot_web_interface import RobotWebInterface
 
 logger = setup_logger()
 
+STATIC_DIR = Path(__file__).parent / "web" / "static"
+
 
 @dataclass
 class PhoneTeleopConfig(ModuleConfig):
     control_loop_hz: float = 50.0
     linear_gain: float = 1.0 / 30.0  # Gain: maps degrees of tilt to m/s. 30 deg -> 1.0 m/s
     angular_gain: float = 1.0 / 30.0  # Gain: maps gyro deg/s to rad/s. 30 deg/s -> 1.0 rad/s
+    server_port: int = 8444
 
 
 class PhoneTeleopModule(Module[PhoneTeleopConfig]):
     """
-    Receives raw sensor data from the phone web app:
+    Receives raw sensor data from the phone web app via an embedded WebSocket server:
       - TwistStamped: linear=(roll, pitch, yaw) deg, angular=(gyro) deg/s
       - Bool: teleop button state (True = held)
 
@@ -63,9 +68,6 @@ class PhoneTeleopModule(Module[PhoneTeleopConfig]):
 
     default_config = PhoneTeleopConfig
 
-    # Inputs from Deno bridge
-    phone_sensors: In[TwistStamped]
-    phone_button: In[Bool]
     # Output: velocity command to robot
     twist_output: Out[TwistStamped]
 
@@ -86,9 +88,52 @@ def __init__(self, *args: Any, **kwargs: Any) -> None:
         self._control_loop_thread: threading.Thread | None = None
         self._stop_event = threading.Event()
 
-        # Deno bridge server
-        self._server_process: subprocess.Popen[bytes] | None = None
-        self._server_script = Path(__file__).parent / "web" / "teleop_server.ts"
+        # Embedded web server — RobotWebInterface provides FastAPI app + run()/shutdown()
+        self._web_server = RobotWebInterface(port=self.config.server_port)
+        self._web_server_thread: threading.Thread | None = None
+
+        # Fingerprint-based message dispatch table
+        self._decoders: dict[bytes, Any] = {
+            LCMTwistStamped._get_packed_fingerprint(): self._on_sensors_bytes,
+            LCMBool._get_packed_fingerprint(): self._on_button_bytes,
+        }
+
+        self._setup_routes()
+
+    # -------------------------------------------------------------------------
+    # Web Server Routes
+    # -------------------------------------------------------------------------
+
+    def _setup_routes(self) -> None:
+        """Register teleop routes on the embedded web server."""
+
+        @self._web_server.app.get("/teleop", response_class=HTMLResponse)
+        async def teleop_index() -> HTMLResponse:
+            index_path = STATIC_DIR / "index.html"
+            return HTMLResponse(content=index_path.read_text())
+
+        if STATIC_DIR.is_dir():
+            self._web_server.app.mount(
+                "/static", StaticFiles(directory=str(STATIC_DIR)), name="teleop_static"
+            )
+
+        @self._web_server.app.websocket("/ws")
+        async def websocket_endpoint(ws: WebSocket) -> None:
+            await ws.accept()
+            logger.info("Phone client connected")
+            try:
+                while True:
+                    data = await ws.receive_bytes()
+                    fingerprint = data[:8]
+                    decoder = self._decoders.get(fingerprint)
+                    if decoder:
+                        decoder(data)
+                    else:
+                        logger.warning(f"Unknown message fingerprint: {fingerprint.hex()}")
+            except WebSocketDisconnect:
+                logger.info("Phone client disconnected")
+            except Exception:
+                logger.exception("WebSocket error")
 
     # -------------------------------------------------------------------------
     # Lifecycle
@@ -97,11 +142,6 @@ def __init__(self, *args: Any, **kwargs: Any) -> None:
     @rpc
     def start(self) -> None:
         super().start()
-        for stream, handler in (
-            (self.phone_sensors, self._on_sensors),
-            (self.phone_button, self._on_button),
-        ):
-            self._disposables.add(Disposable(stream.subscribe(handler)))  # type: ignore[attr-defined]
         self._start_server()
         self._start_control_loop()
 
@@ -132,73 +172,47 @@ def _disengage(self) -> None:
         logger.info("Phone teleop disengaged")
 
     # -------------------------------------------------------------------------
-    # Callbacks
+    # WebSocket Message Decoders
     # -------------------------------------------------------------------------
 
-    def _on_sensors(self, msg: TwistStamped) -> None:
-        """Callback for raw sensor TwistStamped from the phone"""
+    def _on_sensors_bytes(self, data: bytes) -> None:
+        """Decode raw LCM bytes into TwistStamped and update sensor state."""
+        msg = TwistStamped.lcm_decode(data)
         with self._lock:
             self._current_sensors = msg
 
-    def _on_button(self, msg: Bool) -> None:
-        """Callback for teleop button state."""
+    def _on_button_bytes(self, data: bytes) -> None:
+        """Decode raw LCM bytes into Bool and update button state."""
+        msg = Bool.lcm_decode(data)
         with self._lock:
             self._teleop_button = bool(msg.data)
 
     # -------------------------------------------------------------------------
-    # Deno Bridge Server
+    # Embedded Web Server
     # -------------------------------------------------------------------------
 
     def _start_server(self) -> None:
-        """Launch the Deno WebSocket-to-LCM bridge server as a subprocess."""
-        if self._server_process is not None and self._server_process.poll() is None:
-            logger.warning("Deno bridge already running", pid=self._server_process.pid)
-            return
-
-        if shutil.which("deno") is None:
-            logger.error(
-                "Deno is not installed. Install it with: curl -fsSL https://deno.land/install.sh | sh"
-            )
+        """Start the embedded FastAPI server with HTTPS in a daemon thread."""
+        if self._web_server_thread is not None and self._web_server_thread.is_alive():
+            logger.warning("Web server already running")
             return
 
-        script = str(self._server_script)
-        cmd = [
-            "deno",
-            "run",
-            "--allow-net",
-            "--allow-read",
-            "--allow-run",
-            "--allow-write",
-            "--unstable-net",
-            script,
-        ]
-        try:
-            self._server_process = subprocess.Popen(cmd)
-            logger.info(f"Deno bridge server started (pid {self._server_process.pid})")
-        except OSError as e:
-            logger.error(f"Failed to start Deno bridge: {e}")
+        self._web_server_thread = threading.Thread(
+            target=self._web_server.run,
+            kwargs={"ssl": True, "ssl_certs_dir": get_project_root() / "assets" / "teleop_certs"},
+            daemon=True,
+            name="PhoneTeleopWebServer",
+        )
+        self._web_server_thread.start()
+        logger.info(f"Phone teleop web server started on https://0.0.0.0:{self.config.server_port}")
 
     def _stop_server(self) -> None:
-        """Terminate the Deno bridge server subprocess."""
-        if self._server_process is None or self._server_process.poll() is not None:
-            self._server_process = None
-            return
-
-        logger.info("Stopping Deno bridge server", pid=self._server_process.pid)
-        self._server_process.send_signal(signal.SIGTERM)
-        try:
-            self._server_process.wait(timeout=3)
-        except subprocess.TimeoutExpired:
-            logger.warning(
-                "Deno bridge did not exit, sending SIGKILL", pid=self._server_process.pid
-            )
-            self._server_process.kill()
-            try:
-                self._server_process.wait(timeout=5)
-            except subprocess.TimeoutExpired:
-                logger.error("Deno bridge did not exit after SIGKILL")
-        logger.info("Deno bridge server stopped")
-        self._server_process = None
+        """Shutdown the embedded web server."""
+        self._web_server.shutdown()
+        if self._web_server_thread is not None:
+            self._web_server_thread.join(timeout=3)
+            self._web_server_thread = None
+        logger.info("Phone teleop web server stopped")
 
     # -------------------------------------------------------------------------
     # Control Loop
diff --git a/dimos/teleop/phone/web/static/index.html b/dimos/teleop/phone/web/static/index.html
index 6fad23b6c8..5bad9c727e 100644
--- a/dimos/teleop/phone/web/static/index.html
+++ b/dimos/teleop/phone/web/static/index.html
@@ -165,7 +165,7 @@ <h3>Sensors</h3>
     <button id="teleop-btn">HOLD TO TELEOP</button>
 
     <script type="module">
-        import { encodePacket, geometry_msgs, std_msgs } from "https://esm.sh/jsr/@dimos/msgs@0.1.4";
+        import { geometry_msgs, std_msgs } from "https://esm.sh/jsr/@dimos/msgs@0.1.4";
 
         // ============================================
         // State
@@ -183,11 +183,6 @@ <h3>Sensors</h3>
         let ws = null;
         let wsConnected = false;
         let wsSendInterval = null;
-
-        // LCM channels
-        const SENSOR_CHANNEL = "/phone_sensors#geometry_msgs.TwistStamped";
-        const BUTTON_CHANNEL = "/phone_button#std_msgs.Bool";
-
         // ============================================
         // DOM
         // ============================================
@@ -280,7 +275,7 @@ <h3>Sensors</h3>
             if (wsConnected) { disconnectWS(); return; }
 
             const protocol = window.location.protocol === 'https:' ? 'wss:' : 'ws:';
-            const wsUrl = `${protocol}//${window.location.host}`;
+            const wsUrl = `${protocol}//${window.location.host}/ws`;
 
             try {
                 ws = new WebSocket(wsUrl);
@@ -347,11 +342,11 @@ <h3>Sensors</h3>
                     })
                 })
             });
-            ws.send(encodePacket(SENSOR_CHANNEL, twistStamped));
+            ws.send(twistStamped.encode());
 
             // --- Send teleop button as Bool ---
             const boolMsg = new std_msgs.Bool({ data: teleopActive ? 1 : 0 });
-            ws.send(encodePacket(BUTTON_CHANNEL, boolMsg));
+            ws.send(boolMsg.encode());
 
             updateDisplay();
         }
diff --git a/dimos/teleop/phone/web/teleop_server.ts b/dimos/teleop/phone/web/teleop_server.ts
deleted file mode 100755
index 26202cf166..0000000000
--- a/dimos/teleop/phone/web/teleop_server.ts
+++ /dev/null
@@ -1,85 +0,0 @@
-#!/usr/bin/env -S deno run --allow-net --allow-read --allow-run --allow-write --unstable-net
-
-// WebSocket to LCM Bridge for Phone Teleop
-// Forwards twist data from Phone browser to LCM
-
-import { LCM } from "jsr:@dimos/lcm";
-import { dirname, fromFileUrl, join } from "jsr:@std/path";
-
-const PORT = 8444;
-
-// Resolve paths relative to script location
-const scriptDir = dirname(fromFileUrl(import.meta.url));
-const certsDir = join(scriptDir, "../../../../assets/teleop_certs");
-const certPath = join(certsDir, "cert.pem");
-const keyPath = join(certsDir, "key.pem");
-
-// Auto-generate self-signed certificates if they don't exist
-async function ensureCerts(): Promise<{ cert: string; key: string }> {
-  try {
-    const cert = await Deno.readTextFile(certPath);
-    const key = await Deno.readTextFile(keyPath);
-    return { cert, key };
-  } catch {
-    console.log("Generating self-signed certificates...");
-    await Deno.mkdir(certsDir, { recursive: true });
-    const cmd = new Deno.Command("openssl", {
-      args: [
-        "req", "-x509", "-newkey", "rsa:2048",
-        "-keyout", keyPath, "-out", certPath,
-        "-days", "365", "-nodes", "-subj", "/CN=localhost"
-      ],
-    });
-    const { code } = await cmd.output();
-    if (code !== 0) {
-      throw new Error("Failed to generate certificates. Is openssl installed?");
-    }
-    console.log("Certificates generated in assets/teleop_certs/");
-    return {
-      cert: await Deno.readTextFile(certPath),
-      key: await Deno.readTextFile(keyPath),
-    };
-  }
-}
-
-const { cert, key } = await ensureCerts();
-
-const lcm = new LCM();
-await lcm.start();
-
-// Binds to all interfaces so the phone can reach the server over LAN.
-Deno.serve({ port: PORT, cert, key }, async (req) => {
-  const url = new URL(req.url);
-
-  if (req.headers.get("upgrade") === "websocket") {
-    const { socket, response } = Deno.upgradeWebSocket(req);
-    socket.onopen = () => console.log("Phone client connected");
-    socket.onclose = () => console.log("Phone client disconnected");
-
-    // Forward binary LCM packets from browser directly to UDP
-    socket.binaryType = "arraybuffer";
-    socket.onmessage = async (event) => {
-      if (event.data instanceof ArrayBuffer) {
-        const packet = new Uint8Array(event.data);
-        try {
-          await lcm.publishPacket(packet);
-        } catch (e) {
-          console.error("Forward error:", e);
-        }
-      }
-    };
-
-    return response;
-  }
-
-  if (url.pathname === "/" || url.pathname === "/index.html") {
-    const html = await Deno.readTextFile(new URL("./static/index.html", import.meta.url));
-    return new Response(html, { headers: { "content-type": "text/html" } });
-  }
-
-  return new Response("Not found", { status: 404 });
-});
-
-console.log(`Phone Teleop Server: https://localhost:${PORT}`);
-
-await lcm.run();
diff --git a/dimos/teleop/quest/README.md b/dimos/teleop/quest/README.md
new file mode 100644
index 0000000000..0b0e2b8402
--- /dev/null
+++ b/dimos/teleop/quest/README.md
@@ -0,0 +1,49 @@
+# Quest Teleop
+
+Teleoperation via Meta Quest 3 VR controllers. Dual-hand tracking with WebXR.
+
+## Architecture
+
+```
+Quest Browser  ──WebSocket──→  Embedded HTTPS Server  ──→  QuestTeleopModule
+(WebXR poses + Joy)             (port 8443)                  (delta → PoseStamped)
+```
+
+## Running
+
+```bash
+dimos run arm-teleop           # Basic arm teleop
+dimos run arm-teleop-xarm6     # XArm6
+dimos run arm-teleop-piper     # Piper
+dimos run arm-teleop-dual      # Dual arm
+```
+
+Open `https://<host-ip>:8443/teleop` on Quest browser. Accept cert, tap Connect.
+
+## Subclassing
+
+| Method | Purpose |
+|--------|---------|
+| `_handle_engage()` | Customize engage/disengage logic |
+| `_should_publish()` | Add conditions for publishing |
+| `_get_output_pose()` | Customize pose computation |
+| `_publish_msg()` | Change output format |
+
+`self._lock` is already held — don't acquire it in overrides.
+
+## Joy Message Format
+
+**Axes**: thumbstick X, thumbstick Y, trigger (analog), grip (analog)
+
+**Buttons**: trigger, grip, touchpad, thumbstick, X/A, Y/B, menu
+
+## File Structure
+
+```
+quest/
+├── quest_teleop_module.py   # Base module
+├── quest_extensions.py      # ArmTeleop, TwistTeleop, VisualizingTeleop
+├── quest_types.py           # QuestControllerState, Buttons
+├── blueprints.py
+└── web/static/index.html    # WebXR client
+```
diff --git a/dimos/teleop/quest/quest_teleop_module.py b/dimos/teleop/quest/quest_teleop_module.py
index d5a86960fe..f862558424 100644
--- a/dimos/teleop/quest/quest_teleop_module.py
+++ b/dimos/teleop/quest/quest_teleop_module.py
@@ -16,33 +16,39 @@
 """
 Quest Teleoperation Module.
 
-Receives VR controller tracking data via LCM from Deno bridge,
-transforms from WebXR to robot frame, computes deltas, and publishes PoseStamped commands.
+Receives VR controller tracking data from the Quest web app via an embedded
+FastAPI WebSocket server.  Transforms from WebXR to robot frame, computes
+deltas, and publishes PoseStamped commands.
 """
 
 from dataclasses import dataclass
 from enum import IntEnum
 from pathlib import Path
-import shutil
-import signal
-import subprocess
 import threading
 import time
 from typing import Any
 
-from reactivex.disposable import Disposable
+from dimos_lcm.geometry_msgs import PoseStamped as LCMPoseStamped
+from dimos_lcm.sensor_msgs import Joy as LCMJoy
+from fastapi import WebSocket, WebSocketDisconnect
+from fastapi.responses import HTMLResponse
+from fastapi.staticfiles import StaticFiles
 
 from dimos.core.core import rpc
 from dimos.core.module import Module, ModuleConfig
-from dimos.core.stream import In, Out
+from dimos.core.stream import Out
 from dimos.msgs.geometry_msgs import PoseStamped
 from dimos.msgs.sensor_msgs import Joy
 from dimos.teleop.quest.quest_types import Buttons, QuestControllerState
 from dimos.teleop.utils.teleop_transforms import webxr_to_robot
 from dimos.utils.logging_config import setup_logger
+from dimos.utils.path_utils import get_project_root
+from dimos.web.robot_web_interface import RobotWebInterface
 
 logger = setup_logger()
 
+STATIC_DIR = Path(__file__).parent / "web" / "static"
+
 
 class Hand(IntEnum):
     """Controller hand index."""
@@ -67,13 +73,15 @@ class QuestTeleopConfig(ModuleConfig):
     """Configuration for Quest Teleoperation Module."""
 
     control_loop_hz: float = 50.0
+    server_port: int = 8443
 
 
 class QuestTeleopModule(Module[QuestTeleopConfig]):
     """Quest Teleoperation Module for Meta Quest controllers.
 
-    Gets controller data from Deno bridge, computes output poses, and publishes them. Subclass to customize pose
-    computation, output format, and engage behavior.
+    Receives controller data from the Quest web app via an embedded WebSocket
+    server, computes output poses, and publishes them.  Subclass to customize
+    pose computation, output format, and engage behavior.
 
     Outputs:
         - left_controller_output: PoseStamped (output pose for left hand)
@@ -83,12 +91,6 @@ class QuestTeleopModule(Module[QuestTeleopConfig]):
 
     default_config = QuestTeleopConfig
 
-    # Inputs from Deno bridge
-    vr_left_pose: In[PoseStamped]
-    vr_right_pose: In[PoseStamped]
-    vr_left_joy: In[Joy]
-    vr_right_joy: In[Joy]
-
     # Outputs: delta poses for each controller
     left_controller_output: Out[PoseStamped]
     right_controller_output: Out[PoseStamped]
@@ -115,9 +117,52 @@ def __init__(self, *args: Any, **kwargs: Any) -> None:
         self._control_loop_thread: threading.Thread | None = None
         self._stop_event = threading.Event()
 
-        # Deno bridge server
-        self._server_process: subprocess.Popen[bytes] | None = None
-        self._server_script = Path(__file__).parent / "web" / "teleop_server.ts"
+        # Embedded web server — RobotWebInterface provides FastAPI app + run()/shutdown()
+        self._web_server = RobotWebInterface(port=self.config.server_port)
+        self._web_server_thread: threading.Thread | None = None
+
+        # Fingerprint-based message dispatch table
+        self._decoders: dict[bytes, Any] = {
+            LCMPoseStamped._get_packed_fingerprint(): self._on_pose_bytes,
+            LCMJoy._get_packed_fingerprint(): self._on_joy_bytes,
+        }
+
+        self._setup_routes()
+
+    # -------------------------------------------------------------------------
+    # Web Server Routes
+    # -------------------------------------------------------------------------
+
+    def _setup_routes(self) -> None:
+        """Register teleop routes on the embedded web server."""
+
+        @self._web_server.app.get("/teleop", response_class=HTMLResponse)
+        async def teleop_index() -> HTMLResponse:
+            index_path = STATIC_DIR / "index.html"
+            return HTMLResponse(content=index_path.read_text())
+
+        if STATIC_DIR.is_dir():
+            self._web_server.app.mount(
+                "/static", StaticFiles(directory=str(STATIC_DIR)), name="teleop_static"
+            )
+
+        @self._web_server.app.websocket("/ws")
+        async def websocket_endpoint(ws: WebSocket) -> None:
+            await ws.accept()
+            logger.info("Quest client connected")
+            try:
+                while True:
+                    data = await ws.receive_bytes()
+                    fingerprint = data[:8]
+                    decoder = self._decoders.get(fingerprint)
+                    if decoder:
+                        decoder(data)
+                    else:
+                        logger.warning(f"Unknown message fingerprint: {fingerprint.hex()}")
+            except WebSocketDisconnect:
+                logger.info("Quest client disconnected")
+            except Exception:
+                logger.exception("WebSocket error")
 
     # -------------------------------------------------------------------------
     # Lifecycle
@@ -126,24 +171,6 @@ def __init__(self, *args: Any, **kwargs: Any) -> None:
     @rpc
     def start(self) -> None:
         super().start()
-
-        input_streams = {
-            "vr_left_pose": (self.vr_left_pose, lambda msg: self._on_pose(Hand.LEFT, msg)),
-            "vr_right_pose": (self.vr_right_pose, lambda msg: self._on_pose(Hand.RIGHT, msg)),
-            "vr_left_joy": (self.vr_left_joy, lambda msg: self._on_joy(Hand.LEFT, msg)),
-            "vr_right_joy": (self.vr_right_joy, lambda msg: self._on_joy(Hand.RIGHT, msg)),
-        }
-        connected = []
-        for name, (stream, handler) in input_streams.items():
-            if not (stream and stream.transport):  # type: ignore[attr-defined]
-                logger.warning(f"Stream '{name}' has no transport — skipping")
-                continue
-            self._disposables.add(Disposable(stream.subscribe(handler)))  # type: ignore[attr-defined]
-            connected.append(name)
-
-        if connected:
-            logger.info(f"Subscribed to: {', '.join(connected)}")
-
         self._start_server()
         self._start_control_loop()
         logger.info("Quest Teleoperation Module started")
@@ -191,83 +218,65 @@ def get_status(self) -> QuestTeleopStatus:
             )
 
     # -------------------------------------------------------------------------
-    # Callbacks and Control Loop
+    # WebSocket Message Decoders
     # -------------------------------------------------------------------------
 
-    def _on_pose(self, hand: Hand, pose_stamped: PoseStamped) -> None:
-        """Callback for controller pose, converting WebXR to robot frame."""
-        is_left = hand == Hand.LEFT
-        robot_pose_stamped = webxr_to_robot(pose_stamped, is_left_controller=is_left)
+    @staticmethod
+    def _resolve_hand(frame_id: str) -> Hand:
+        if frame_id == "left":
+            return Hand.LEFT
+        elif frame_id == "right":
+            return Hand.RIGHT
+        raise ValueError(f"Unexpected frame_id: {frame_id!r}, expected 'left' or 'right'")
+
+    def _on_pose_bytes(self, data: bytes) -> None:
+        """Decode LCM bytes into PoseStamped, transform to robot frame."""
+        msg = PoseStamped.lcm_decode(data)
+        hand = self._resolve_hand(msg.frame_id)
+        robot_pose = webxr_to_robot(msg, is_left_controller=(hand == Hand.LEFT))
         with self._lock:
-            self._current_poses[hand] = robot_pose_stamped
+            self._current_poses[hand] = robot_pose
 
-    def _on_joy(self, hand: Hand, joy: Joy) -> None:
-        """Callback for Joy message, parsing into QuestControllerState."""
-        is_left = hand == Hand.LEFT
+    def _on_joy_bytes(self, data: bytes) -> None:
+        """Decode LCM bytes into Joy, parse into QuestControllerState."""
+        msg = Joy.lcm_decode(data)
+        hand = Hand.LEFT if msg.frame_id == "left" else Hand.RIGHT
         try:
-            controller = QuestControllerState.from_joy(joy, is_left=is_left)
+            controller = QuestControllerState.from_joy(msg, is_left=(hand == Hand.LEFT))
         except ValueError:
             logger.warning(
-                f"Malformed Joy for {hand.name}: axes={len(joy.axes or [])}, buttons={len(joy.buttons or [])}"
+                f"Malformed Joy for {hand.name}: axes={len(msg.axes or [])}, buttons={len(msg.buttons or [])}"
             )
             return
         with self._lock:
             self._controllers[hand] = controller
 
     # -------------------------------------------------------------------------
-    # Deno Bridge Server
+    # Embedded Web Server
     # -------------------------------------------------------------------------
 
     def _start_server(self) -> None:
-        """Launch the Deno WebSocket-to-LCM bridge server as a subprocess."""
-        if self._server_process is not None and self._server_process.poll() is None:
-            logger.warning("Deno bridge already running", pid=self._server_process.pid)
+        """Start the embedded FastAPI server with HTTPS in a daemon thread."""
+        if self._web_server_thread is not None and self._web_server_thread.is_alive():
+            logger.warning("Web server already running")
             return
 
-        if shutil.which("deno") is None:
-            logger.error(
-                "Deno is not installed. Install it with: curl -fsSL https://deno.land/install.sh | sh"
-            )
-            return
-
-        script = str(self._server_script)
-        cmd = [
-            "deno",
-            "run",
-            "--allow-net",
-            "--allow-read",
-            "--allow-run",
-            "--allow-write",
-            "--unstable-net",
-            script,
-        ]
-        try:
-            self._server_process = subprocess.Popen(cmd)
-            logger.info(f"Deno bridge server started (pid {self._server_process.pid})")
-        except OSError as e:
-            logger.error(f"Failed to start Deno bridge: {e}")
+        self._web_server_thread = threading.Thread(
+            target=self._web_server.run,
+            kwargs={"ssl": True, "ssl_certs_dir": get_project_root() / "assets" / "teleop_certs"},
+            daemon=True,
+            name="QuestTeleopWebServer",
+        )
+        self._web_server_thread.start()
+        logger.info(f"Quest teleop web server started on https://0.0.0.0:{self.config.server_port}")
 
     def _stop_server(self) -> None:
-        """Terminate the Deno bridge server subprocess."""
-        if self._server_process is None or self._server_process.poll() is not None:
-            self._server_process = None
-            return
-
-        logger.info("Stopping Deno bridge server", pid=self._server_process.pid)
-        self._server_process.send_signal(signal.SIGTERM)
-        try:
-            self._server_process.wait(timeout=3)
-        except subprocess.TimeoutExpired:
-            logger.warning(
-                "Deno bridge did not exit, sending SIGKILL", pid=self._server_process.pid
-            )
-            self._server_process.kill()
-            try:
-                self._server_process.wait(timeout=5)
-            except subprocess.TimeoutExpired:
-                logger.error("Deno bridge did not exit after SIGKILL")
-        logger.info("Deno bridge server stopped")
-        self._server_process = None
+        """Shutdown the embedded web server."""
+        self._web_server.shutdown()
+        if self._web_server_thread is not None:
+            self._web_server_thread.join(timeout=3)
+            self._web_server_thread = None
+        logger.info("Quest teleop web server stopped")
 
     def _start_control_loop(self) -> None:
         """Start the control loop thread."""
diff --git a/dimos/teleop/quest/web/README.md b/dimos/teleop/quest/web/README.md
deleted file mode 100644
index 9a7afbfe03..0000000000
--- a/dimos/teleop/quest/web/README.md
+++ /dev/null
@@ -1,69 +0,0 @@
-# Quest Teleop Web
-
-WebXR client and server for Quest 3 VR teleoperation.
-
-## Components
-
-### teleop_server.ts
-
-Deno server that bridges WebSocket and LCM:
-- Serves WebXR client over HTTPS (required for Quest)
-- Forwards controller data from browser to LCM
-
-### static/index.html
-
-WebXR client running on Quest 3:
-- Captures controller poses at ~80Hz
-- Sends PoseStamped and Joy messages via WebSocket
-- Requires internet connection (loads `@dimos/msgs` from CDN at runtime)
-
-## Running
-
-From the repository root (`dimos/`):
-
-```bash
-./dimos/teleop/quest/web/teleop_server.ts
-```
-
-Server starts at `https://localhost:8443`
-
-SSL certificates are generated automatically on first run in `assets/teleop_certs/`.
-
-## Message Flow
-
-```
-Quest Browser                    Deno Server                    Python
-    │                                │                             │
-    │── PoseStamped (left) ────────→ │── vr_left_pose ───────────→ │
-    │── PoseStamped (right) ───────→ │── vr_right_pose ──────────→ │
-    │── Joy (left controller) ─────→ │── vr_left_joy ────────────→ │
-    │── Joy (right controller) ────→ │── vr_right_joy ───────────→ │
-```
-
-## LCM Topics
-
-| Topic | Type | Description |
-|-------|------|-------------|
-| `vr_left_pose` | PoseStamped | Left controller pose (WebXR frame) |
-| `vr_right_pose` | PoseStamped | Right controller pose (WebXR frame) |
-| `vr_left_joy` | Joy | Left controller buttons/axes |
-| `vr_right_joy` | Joy | Right controller buttons/axes |
-
-## Joy Message Format
-
-Quest controller data is packed into Joy messages:
-
-**Axes** (indices 0-3):
-- 0: thumbstick X (-1.0 to 1.0)
-- 1: thumbstick Y (-1.0 to 1.0)
-- 2: trigger (analog 0.0-1.0)
-- 3: grip (analog 0.0-1.0)
-
-**Buttons** (indices 0-6, digital 0 or 1):
-- 0: trigger (pressed)
-- 1: grip (pressed)
-- 2: touchpad
-- 3: thumbstick press
-- 4: X/A (primary)
-- 5: Y/B (secondary)
-- 6: menu
diff --git a/dimos/teleop/quest/web/static/index.html b/dimos/teleop/quest/web/static/index.html
index 507d493011..8d31289f88 100644
--- a/dimos/teleop/quest/web/static/index.html
+++ b/dimos/teleop/quest/web/static/index.html
@@ -116,7 +116,7 @@ <h1>DimOS Quest-3 Teleop</h1>
             document.getElementById('status').textContent = `Error: ${msg}`;
         };
 
-        import { encodePacket, geometry_msgs, std_msgs, sensor_msgs } from "https://esm.sh/jsr/@dimos/msgs@0.1.4";
+        import { geometry_msgs, std_msgs, sensor_msgs } from "https://esm.sh/jsr/@dimos/msgs@0.1.4";
 
         // WebSocket and VR state
         let ws = null;
@@ -141,7 +141,7 @@ <h1>DimOS Quest-3 Teleop</h1>
         function setupWebSocket() {
             return new Promise((resolve, reject) => {
                 const protocol = window.location.protocol === 'https:' ? 'wss:' : 'ws:';
-                const wsUrl = `${protocol}//${window.location.host}`;
+                const wsUrl = `${protocol}//${window.location.host}/ws`;
 
                 setStatus('Connecting to server...');
                 ws = new WebSocket(wsUrl);
@@ -202,7 +202,7 @@ <h1>DimOS Quest-3 Teleop</h1>
                 const poseStamped = new geometry_msgs.PoseStamped({
                     header: new std_msgs.Header({
                         stamp: new std_msgs.Time({ sec: Math.floor(nowMs / 1000), nsec: (nowMs % 1000) * 1_000_000 }),
-                        frame_id: "vr_origin"
+                        frame_id: handedness
                     }),
                     pose: new geometry_msgs.Pose({
                         position: new geometry_msgs.Point({ x: pos.x, y: pos.y, z: pos.z }),
@@ -210,14 +210,8 @@ <h1>DimOS Quest-3 Teleop</h1>
                     })
                 });
 
-                const channel = handedness === 'left'
-                    ? "/vr_left_pose#geometry_msgs.PoseStamped"
-                    : "/vr_right_pose#geometry_msgs.PoseStamped";
-
-                const packet = encodePacket(channel, poseStamped);
-
                 if (ws && ws.readyState === WebSocket.OPEN) {
-                    ws.send(packet);
+                    ws.send(poseStamped.encode());
                 }
 
                 // Send Joy message with all buttons and axes
@@ -259,13 +253,8 @@ <h1>DimOS Quest-3 Teleop</h1>
                         buttons: buttons
                     });
 
-                    const joyChannel = handedness === 'left'
-                        ? "/vr_left_joy#sensor_msgs.Joy"
-                        : "/vr_right_joy#sensor_msgs.Joy";
-                    const joyPacket = encodePacket(joyChannel, joyMsg);
-
                     if (ws && ws.readyState === WebSocket.OPEN) {
-                        ws.send(joyPacket);
+                        ws.send(joyMsg.encode());
                     }
                 }
             }
diff --git a/dimos/teleop/quest/web/teleop_server.ts b/dimos/teleop/quest/web/teleop_server.ts
deleted file mode 100755
index 2bff24b34f..0000000000
--- a/dimos/teleop/quest/web/teleop_server.ts
+++ /dev/null
@@ -1,84 +0,0 @@
-#!/usr/bin/env -S deno run --allow-net --allow-read --allow-run --allow-write --unstable-net
-
-// WebSocket to LCM Bridge for Quest VR Teleop
-// Forwards controller data from browser to LCM
-
-import { LCM } from "jsr:@dimos/lcm";
-import { dirname, fromFileUrl, join } from "jsr:@std/path";
-
-const PORT = 8443;
-
-// Resolve paths relative to script location
-const scriptDir = dirname(fromFileUrl(import.meta.url));
-const certsDir = join(scriptDir, "../../../../assets/teleop_certs");
-const certPath = join(certsDir, "cert.pem");
-const keyPath = join(certsDir, "key.pem");
-
-// Auto-generate self-signed certificates if they don't exist
-async function ensureCerts(): Promise<{ cert: string; key: string }> {
-  try {
-    const cert = await Deno.readTextFile(certPath);
-    const key = await Deno.readTextFile(keyPath);
-    return { cert, key };
-  } catch {
-    console.log("Generating self-signed certificates...");
-    await Deno.mkdir(certsDir, { recursive: true });
-    const cmd = new Deno.Command("openssl", {
-      args: [
-        "req", "-x509", "-newkey", "rsa:2048",
-        "-keyout", keyPath, "-out", certPath,
-        "-days", "365", "-nodes", "-subj", "/CN=localhost"
-      ],
-    });
-    const { code } = await cmd.output();
-    if (code !== 0) {
-      throw new Error("Failed to generate certificates. Is openssl installed?");
-    }
-    console.log("Certificates generated in assets/teleop_certs/");
-    return {
-      cert: await Deno.readTextFile(certPath),
-      key: await Deno.readTextFile(keyPath),
-    };
-  }
-}
-
-const { cert, key } = await ensureCerts();
-
-const lcm = new LCM();
-await lcm.start();
-
-Deno.serve({ port: PORT, cert, key }, async (req) => {
-  const url = new URL(req.url);
-
-  if (req.headers.get("upgrade") === "websocket") {
-    const { socket, response } = Deno.upgradeWebSocket(req);
-    socket.onopen = () => console.log("Client connected");
-    socket.onclose = () => console.log("Client disconnected");
-
-    // Forward binary LCM packets from browser directly to UDP
-    socket.binaryType = "arraybuffer";
-    socket.onmessage = async (event) => {
-      if (event.data instanceof ArrayBuffer) {
-        const packet = new Uint8Array(event.data);
-        try {
-          await lcm.publishPacket(packet);
-        } catch (e) {
-          console.error("Forward error:", e);
-        }
-      }
-    };
-
-    return response;
-  }
-
-  if (url.pathname === "/" || url.pathname === "/index.html") {
-    const html = await Deno.readTextFile(new URL("./static/index.html", import.meta.url));
-    return new Response(html, { headers: { "content-type": "text/html" } });
-  }
-
-  return new Response("Not found", { status: 404 });
-});
-
-console.log(`Server: https://localhost:${PORT}`);
-
-await lcm.run();
diff --git a/dimos/web/dimos_interface/api/server.py b/dimos/web/dimos_interface/api/server.py
index 7f7bdc23b8..f77f9ac4a7 100644
--- a/dimos/web/dimos_interface/api/server.py
+++ b/dimos/web/dimos_interface/api/server.py
@@ -31,6 +31,7 @@
 import io
 from pathlib import Path
 from queue import Empty, Queue
+import subprocess
 from threading import Lock
 import time
 
@@ -350,12 +351,56 @@ async def text_stream(key: str):  # type: ignore[no-untyped-def]
         for key in self.streams:
             self.app.get(f"/video_feed/{key}")(self.create_video_feed_route(key))  # type: ignore[no-untyped-call]
 
-    def run(self) -> None:
+    @staticmethod
+    def _ensure_certs(certs_dir: Path) -> tuple[str, str]:
+        """Return (cert_path, key_path), generating self-signed certs if needed.
+        HTTPS is required by browsers for sensor APIs (DeviceOrientation)"""
+        cert_path = certs_dir / "cert.pem"
+        key_path = certs_dir / "key.pem"
+
+        if cert_path.exists() and key_path.exists():
+            return str(cert_path), str(key_path)
+
+        certs_dir.mkdir(parents=True, exist_ok=True)
+        result = subprocess.run(
+            [
+                "openssl",
+                "req",
+                "-x509",
+                "-newkey",
+                "rsa:2048",
+                "-keyout",
+                str(key_path),
+                "-out",
+                str(cert_path),
+                "-days",
+                "365",
+                "-nodes",
+                "-subj",
+                "/CN=localhost",
+            ],
+            capture_output=True,
+        )
+        if result.returncode != 0:
+            raise RuntimeError(f"Failed to generate certificates: {result.stderr.decode()}")
+        return str(cert_path), str(key_path)
+
+    def run(self, ssl: bool = False, ssl_certs_dir: Path | str | None = None) -> None:
+        ssl_certfile = None
+        ssl_keyfile = None
+
+        if ssl:
+            if ssl_certs_dir is None:
+                raise ValueError("ssl_certs_dir is required when ssl=True")
+            ssl_certfile, ssl_keyfile = self._ensure_certs(Path(ssl_certs_dir))
+
         config = uvicorn.Config(
             self.app,
             host=self.host,
             port=self.port,
             log_level="error",  # Reduce verbosity
+            ssl_certfile=ssl_certfile,
+            ssl_keyfile=ssl_keyfile,
         )
         self._server = uvicorn.Server(config)
         self._server.run()