RoleWeave
+发一条指令
+发给电脑上已打开的 RoleWeave。同一产品地址可一键连接；也可以输入电脑弹窗里的 6 位码。
+正在查看电脑是否在线…
+ + + + + + + +尚未配对。
+ +RoleWeave
+发给电脑上已打开的 RoleWeave。同一产品地址可一键连接；也可以输入电脑弹窗里的 6 位码。
+正在查看电脑是否在线…
+ + + + + + + +尚未配对。
+ +正在读取组织…
+发给电脑上已打开的 RoleWeave。员工在电脑上跑。
+正在查看电脑是否在线…
+ + + +尚未连接。
+ +完整工作台在电脑上。需要时再打开远程桌面。
+ 打开远程桌面 +RoleWeave · 鸿蒙
+正在读取组织…
+发给电脑上已打开的 RoleWeave。员工在电脑上跑。
+正在查看电脑是否在线…
+ + + +尚未连接。
+ +完整工作台在电脑上。需要时再打开远程桌面。
+ 打开远程桌面 +RoleWeave
+正在读取组织…
+发给电脑上已打开的 RoleWeave。员工在电脑上跑，不在手机上跑。
+正在查看电脑是否在线…
+ + + +尚未连接。
+ +完整工作台仍是桌面应用。手机上可以打开远程桌面，但组织与发指令才是给手指用的主路径。
+ 打开远程桌面 +RoleWeave · iOS
+正在读取组织…
+发给电脑上已打开的 RoleWeave。员工在电脑上跑。
+正在查看电脑是否在线…
+ + + +尚未连接。
+ +完整工作台在电脑上。需要时再打开远程桌面。
+ 打开远程桌面 +${escapeHtml(role.description)}
+ +${escapeHtml(role.skillExcerpt || "这份岗位还没有说明书摘录。")}
+
+ `;
+ document.getElementById("talk")?.addEventListener("click", () => selectTab("command"));
+}
+
+function escapeHtml(value) {
+ return String(value)
+ .replaceAll("&", "&")
+ .replaceAll("<", "<")
+ .replaceAll(">", ">")
+ .replaceAll('"', """);
+}
+
+function describeSource(snapshot) {
+ if (snapshot.source === "live") return "电脑当前工作区";
+ if (snapshot.source === "closed") return "电脑未打开工作区";
+ return "示例预览，电脑打开工作区后会换成当前组织";
+}
+
+function setDeviceState(connected) {
+ const state = document.getElementById("device-state");
+ const revoke = document.getElementById("revoke");
+ if (state) state.textContent = connected ? "已连接" : "未连接";
+ if (revoke) revoke.hidden = !connected;
+}
+
+function renderRoles(snapshot) {
+ const sourceEl = document.getElementById("org-source");
+ if (sourceEl) sourceEl.textContent = describeSource(snapshot);
+ if (snapshot.source === "closed") {
+ workspaceName.textContent = "未打开工作区";
+ orgLead.textContent = "在电脑上打开一个工作区后，这里会列出当前员工。";
+ orgLead.classList.remove("error");
+ roleList.replaceChildren();
+ roleDetail.hidden = true;
+ return;
+ }
+ workspaceName.textContent = snapshot.name;
+ orgLead.textContent = snapshot.source === "live"
+ ? (snapshot.description || "这是电脑上正在打开的工作区。")
+ : (snapshot.description || "当前是示例组织的只读预览。选一个岗位，看说明书和预算。");
+ const names = new Map(snapshot.roles.map((role) => [role.id, role.name]));
+ roleList.replaceChildren();
+ for (const role of snapshot.roles) {
+ const item = document.createElement("li");
+ const button = document.createElement("button");
+ button.type = "button";
+ button.className = "role";
+ button.innerHTML = `${escapeHtml(role.name)}${escapeHtml(role.description)}`;
+ button.addEventListener("click", () => {
+ selectedRoleId = role.id;
+ renderDetail(role, names);
+ roleDetail.scrollIntoView({ block: "nearest" });
+ });
+ item.append(button);
+ roleList.append(item);
+ }
+ const initial = snapshot.roles.find((role) => role.id === selectedRoleId) ?? snapshot.roles[0];
+ if (initial) renderDetail(initial, names);
+}
+
+async function loadWorkspace() {
+ try {
+ const response = await fetch("/api/mobile/workspace", { headers: { accept: "application/json" } });
+ if (!response.ok) throw new Error("workspace unavailable");
+ renderRoles(await response.json());
+ } catch {
+ orgLead.textContent = "组织预览暂时读不到。桌面工作台仍可用。";
+ orgLead.classList.add("error");
+ }
+}
+
+function selectTab(id) {
+ for (const panel of document.querySelectorAll(".panel")) {
+ const active = panel.dataset.panel === id;
+ panel.classList.toggle("is-active", active);
+ panel.hidden = !active;
+ }
+ for (const tab of document.querySelectorAll(".tab")) {
+ const active = tab.dataset.tab === id;
+ tab.classList.toggle("is-active", active);
+ if (active) tab.setAttribute("aria-current", "page");
+ else tab.removeAttribute("aria-current");
+ }
+}
+
+function connect() {
+ if (!deviceToken) return;
+ socket?.close();
+ const url = `${location.protocol === "https:" ? "wss" : "ws"}://${location.host}/phone-link/phone`;
+ socket = new WebSocket(url);
+ socket.addEventListener("open", () => {
+ socket.send(JSON.stringify({ v: 1, type: "phone.hello", deviceToken }));
+ });
+ socket.addEventListener("message", (event) => {
+ let message;
+ try {
+ message = JSON.parse(String(event.data));
+ } catch {
+ return;
+ }
+ if (message.type === "phone.accepted") {
+ pairForm.hidden = true;
+ claimForm.hidden = true;
+ commandForm.hidden = false;
+ setDeviceState(true);
+ setCommandStatus("已连上电脑，可以发指令。");
+ return;
+ }
+ if (message.type === "command.status") {
+ const labels = {
+ accepted: "电脑已接到",
+ running: "员工正在处理",
+ completed: "完成",
+ failed: "失败",
+ busy: "该员工正在忙",
+ needs_approval: "请在电脑上确认",
+ };
+ setCommandStatus(labels[message.state] ?? message.state);
+ if (message.summary) showSummary(message.summary);
+ return;
+ }
+ if (message.type === "error") {
+ if (message.code === "unauthorized" || message.code === "revoked") {
+ localStorage.removeItem(storageKey);
+ deviceToken = null;
+ pairForm.hidden = false;
+ claimForm.hidden = false;
+ commandForm.hidden = true;
+ setDeviceState(false);
+ }
+ setCommandStatus(message.message ?? "出错了");
+ }
+ });
+ socket.addEventListener("close", () => {
+ if (deviceToken) setCommandStatus("连接断开，正在重试…");
+ });
+}
+
+async function acceptGrant(body) {
+ if (!body?.deviceToken) return false;
+ deviceToken = body.deviceToken;
+ localStorage.setItem(storageKey, deviceToken);
+ connect();
+ return true;
+}
+
+async function refreshHostStatus() {
+ try {
+ const response = await fetch("/phone-link/v1/status", { headers: { accept: "application/json" } });
+ const body = await response.json();
+ if (body.hostOnline) {
+ hostStatus.textContent = "电脑在线，可以连接。";
+ hostStatus.classList.remove("error");
+ } else {
+ hostStatus.textContent = "电脑还没连上。先打开 RoleWeave 桌面。";
+ hostStatus.classList.add("error");
+ }
+ } catch {
+ hostStatus.textContent = "暂时读不到电脑状态。";
+ hostStatus.classList.add("error");
+ }
+}
+
+claimForm.addEventListener("submit", async (event) => {
+ event.preventDefault();
+ setCommandStatus("正在连接电脑…");
+ const response = await fetch("/phone-link/v1/claim", { method: "POST" });
+ const body = await response.json();
+ if (!response.ok || !(await acceptGrant(body))) {
+ setCommandStatus(body.message ?? "连接失败");
+ }
+});
+
+pairForm.addEventListener("submit", async (event) => {
+ event.preventDefault();
+ const code = document.getElementById("code").value.trim();
+ setCommandStatus("正在配对…");
+ const response = await fetch("/phone-link/v1/pair", {
+ method: "POST",
+ headers: { "content-type": "application/json" },
+ body: JSON.stringify({ code }),
+ });
+ const body = await response.json();
+ if (!response.ok || !(await acceptGrant(body))) {
+ setCommandStatus(body.message ?? "配对失败");
+ }
+});
+
+commandForm.addEventListener("submit", (event) => {
+ event.preventDefault();
+ const text = document.getElementById("text").value.trim();
+ if (!text || !socket || socket.readyState !== WebSocket.OPEN) {
+ setCommandStatus("还没连上电脑");
+ return;
+ }
+ showSummary("");
+ const commandId = crypto.randomUUID();
+ socket.send(JSON.stringify({
+ v: 1,
+ type: "command.submit",
+ commandId,
+ text,
+ ...(selectedRoleId ? { positionId: selectedRoleId } : {}),
+ }));
+ setCommandStatus("已发出，等电脑受理…");
+});
+
+document.querySelector("nav[aria-label='主要功能']")?.addEventListener("click", (event) => {
+ const tab = event.target.closest("[data-tab]");
+ if (tab) selectTab(tab.dataset.tab);
+});
+
+document.getElementById("revoke")?.addEventListener("click", async () => {
+ if (!deviceToken) return;
+ const response = await fetch("/phone-link/v1/revoke", {
+ method: "POST",
+ headers: { "content-type": "application/json" },
+ body: JSON.stringify({ deviceToken }),
+ });
+ localStorage.removeItem(storageKey);
+ deviceToken = null;
+ socket?.close();
+ pairForm.hidden = false;
+ claimForm.hidden = false;
+ commandForm.hidden = true;
+ setDeviceState(false);
+ setCommandStatus(response.ok ? "已断开这台手机。" : "已在本机退出，电脑侧可能仍需确认。");
+});
+
+if (deviceToken) connect();
+else setDeviceState(false);
+void loadWorkspace();
+void refreshHostStatus();
+setInterval(() => {
+ void refreshHostStatus();
+ void loadWorkspace();
+}, 4000);
diff --git a/deploy/web-server.mjs b/deploy/web-server.mjs
new file mode 100644
index 00000000..0fe64166
--- /dev/null
+++ b/deploy/web-server.mjs
@@ -0,0 +1,249 @@
+import { createReadStream } from "node:fs";
+import { stat } from "node:fs/promises";
+import { createServer } from "node:http";
+import net from "node:net";
+import path from "node:path";
+import { fileURLToPath } from "node:url";
+import { WebSocket, WebSocketServer } from "ws";
+import { createPhoneLinkRelay } from "../packages/phone-link/src/index.mjs";
+import {
+ defaultExampleDir,
+ loadWorkspaceSnapshot,
+ previewOrgSnapshot,
+ resolvePublicAsset,
+} from "./mobile-surface.mjs";
+
+const port = Number.parseInt(process.argv[2] ?? "", 10);
+const vncPort = Number.parseInt(process.argv[3] ?? "", 10);
+if (!Number.isInteger(port) || port < 1 || port > 65535 ||
+ !Number.isInteger(vncPort) || vncPort < 1 || vncPort > 65535) {
+ process.stderr.write("usage: node web-server.mjs