`,
)
.join("")
@@ -233,10 +521,11 @@ function renderTasks() {
button.addEventListener("click", async () => {
const taskId = button.dataset.taskId;
const action = button.dataset.action;
- await request(`/api/tasks/${taskId}/${action}`, { method: "POST", body: "{}" });
- await loadSession(state.selectedSessionId);
- await loadBootstrap();
- render();
+ await runAction(
+ "更新任务",
+ () => request(`/api/tasks/${taskId}/${action}`, { method: "POST", body: "{}" }),
+ "任务状态已更新。",
+ );
});
});
}
@@ -245,21 +534,41 @@ function renderApprovals() {
const approvals = approvalsForSelectedSession();
elements.approvalList.innerHTML = approvals.length
? approvals
- .map(
- (approval) => `
+ .map((approval) => {
+ const task = findTask(approval.taskId);
+ const followUpText =
+ approval.status === "pending"
+ ? "批准后任务会重新进入队列；拒绝后任务会被取消。"
+ : approval.status === "approved"
+ ? "这条审批已经通过，对应任务可继续执行。"
+ : "这条审批已被拒绝，对应任务已停止。";
+
+ return `
- ${escapeHtml(approval.summary)}
+ ${escapeHtml(task?.title || approval.summary)}
${escapeHtml(approval.status)}
-
risk: ${escapeHtml(approval.riskLevel)}
-
-
-
+
${escapeHtml(approval.summary)}
+
+ 风险等级：${escapeHtml(approval.riskLevel)}
+ 触发类型：${escapeHtml(approval.kind)}
+ 关联任务：${escapeHtml(task?.title || approval.taskId)}
+
${escapeHtml(followUpText)}
+ ${
+ approval.status === "pending"
+ ? `
+
+
+
+
+ `
+ : ""
+ }
- `,
- )
+ `;
+ })
.join("")
: `
当前没有待审批项。
`;
@@ -267,13 +576,15 @@ function renderApprovals() {
button.addEventListener("click", async () => {
const approvalId = button.dataset.approvalId;
const approved = button.dataset.approved === "true";
- await request(`/api/approvals/${approvalId}/respond`, {
- method: "POST",
- body: JSON.stringify({ approved, responder: "web-user" }),
- });
- await loadSession(state.selectedSessionId);
- await loadBootstrap();
- render();
+ await runAction(
+ approved ? "批准审批" : "拒绝审批",
+ () =>
+ request(`/api/approvals/${approvalId}/respond`, {
+ method: "POST",
+ body: JSON.stringify({ approved, responder: "web-user" }),
+ }),
+ approved ? "审批已通过。" : "审批已拒绝。",
+ );
});
});
}
@@ -287,7 +598,7 @@ function renderEvents() {
${escapeHtml(event.type)}
- ${new Date(event.timestamp).toLocaleTimeString()}
+ ${formatClock(event.timestamp)}
${escapeHtml(JSON.stringify(event.payload, null, 2))}
@@ -298,6 +609,9 @@ function renderEvents() {
}
function render() {
+ renderBanner();
+ renderStreamStatus();
+ renderOnboarding();
renderSessions();
renderWorkers();
renderSessionHeader();
@@ -324,27 +638,58 @@ async function loadSession(sessionId) {
if (!sessionId) return;
const details = await request(`/api/sessions/${sessionId}`);
state.sessions = state.sessions.map((session) => (session.id === sessionId ? details.session : session));
- state.messages = [
- ...state.messages.filter((message) => message.sessionId !== sessionId),
- ...details.messages,
- ];
- state.tasks = [
- ...state.tasks.filter((task) => task.sessionId !== sessionId),
- ...details.tasks,
- ];
+ state.messages = [...state.messages.filter((message) => message.sessionId !== sessionId), ...details.messages];
+ state.tasks = [...state.tasks.filter((task) => task.sessionId !== sessionId), ...details.tasks];
state.approvals = [
...state.approvals.filter((approval) => approval.sessionId !== sessionId),
...details.approvals,
];
}
+function startFallbackPolling() {
+ if (fallbackPoll) {
+ return;
+ }
+
+ fallbackPoll = window.setInterval(async () => {
+ try {
+ await loadBootstrap();
+ if (state.selectedSessionId) {
+ await loadSession(state.selectedSessionId);
+ }
+ render();
+ } catch (error) {
+ console.error(error);
+ }
+ }, 5000);
+}
+
+function stopFallbackPolling() {
+ if (!fallbackPoll) {
+ return;
+ }
+ window.clearInterval(fallbackPoll);
+ fallbackPoll = null;
+}
+
elements.createSessionForm.addEventListener("submit", async (event) => {
event.preventDefault();
const title = elements.sessionTitleInput.value.trim();
- const details = await request("/api/sessions", {
- method: "POST",
- body: JSON.stringify({ title }),
- });
+ const details = await runAction(
+ "创建会话",
+ () =>
+ request("/api/sessions", {
+ method: "POST",
+ body: JSON.stringify({ title }),
+ }),
+ "项目会话已创建。",
+ { refreshBootstrap: false, refreshSession: false },
+ );
+
+ if (!details) {
+ return;
+ }
+
state.sessions.unshift(details.session);
state.selectedSessionId = details.session.id;
await loadSession(details.session.id);
@@ -361,14 +706,24 @@ elements.createWorkerForm.addEventListener("submit", async (event) => {
.split(",")
.map((item) => item.trim())
.filter(Boolean);
- await request("/api/workers/register", {
- method: "POST",
- body: JSON.stringify({ name, os, capabilities }),
- });
+
+ const result = await runAction(
+ "注册 worker",
+ () =>
+ request("/api/workers/register", {
+ method: "POST",
+ body: JSON.stringify({ name, os, capabilities }),
+ }),
+ "worker 已注册。",
+ { refreshSession: false },
+ );
+
+ if (!result) {
+ return;
+ }
+
elements.workerName.value = "";
elements.workerCapabilities.value = "terminal";
- await loadBootstrap();
- render();
});
elements.messageForm.addEventListener("submit", async (event) => {
@@ -376,40 +731,78 @@ elements.messageForm.addEventListener("submit", async (event) => {
if (!state.selectedSessionId) return;
const content = elements.messageInput.value.trim();
if (!content) return;
- await request(`/api/sessions/${state.selectedSessionId}/messages`, {
- method: "POST",
- body: JSON.stringify({ content, channel: "web" }),
- });
+
+ const result = await runAction(
+ "发送需求",
+ () =>
+ request(`/api/sessions/${state.selectedSessionId}/messages`, {
+ method: "POST",
+ body: JSON.stringify({ content, channel: "web" }),
+ }),
+ "需求已发送给主控。",
+ );
+
+ if (!result) {
+ return;
+ }
+
elements.messageInput.value = "";
- await loadSession(state.selectedSessionId);
- await loadBootstrap();
- render();
});
elements.archiveSession.addEventListener("click", async () => {
- if (!state.selectedSessionId) return;
- await request(`/api/sessions/${state.selectedSessionId}/archive`, {
- method: "POST",
- body: "{}",
- });
- await loadSession(state.selectedSessionId);
- await loadBootstrap();
- render();
+ const session = selectedSession();
+ if (!session) return;
+
+ const archived = session.status === "archived";
+ await runAction(
+ archived ? "恢复会话" : "归档会话",
+ () =>
+ request(`/api/sessions/${state.selectedSessionId}/${archived ? "restore" : "archive"}`, {
+ method: "POST",
+ body: "{}",
+ }),
+ archived ? "会话已恢复。" : "会话已归档。",
+ );
});
elements.resetDemo.addEventListener("click", async () => {
- await request("/api/demo/reset", { method: "POST", body: "{}" });
+ const result = await runAction(
+ "重置 Demo",
+ () =>
+ request("/api/demo/reset", {
+ method: "POST",
+ body: JSON.stringify({ preserveWorkers: true }),
+ }),
+ "Demo 数据已重置。",
+ { refreshSession: false },
+ );
+
+ if (!result) {
+ return;
+ }
+
state.sessions = [];
state.messages = [];
state.tasks = [];
- state.workers = [];
state.approvals = [];
state.events = [];
state.selectedSessionId = null;
+ await loadBootstrap();
render();
});
const stream = new EventSource("/api/events/stream");
+
+stream.onopen = () => {
+ const wasReconnecting = state.connection === "reconnecting";
+ state.connection = "live";
+ stopFallbackPolling();
+ render();
+ if (wasReconnecting) {
+ setBanner("实时事件流已恢复。", "success");
+ }
+};
+
stream.onmessage = async (event) => {
const payload = JSON.parse(event.data);
state.events.push(payload);
@@ -420,7 +813,24 @@ stream.onmessage = async (event) => {
render();
};
-loadBootstrap().then(render).catch((error) => {
- console.error(error);
- elements.sessionSummary.textContent = error.message;
-});
+stream.onerror = () => {
+ if (state.connection !== "reconnecting") {
+ state.connection = "reconnecting";
+ setBanner("实时事件流暂时断开，正在重连并降级轮询。", "warn", true);
+ startFallbackPolling();
+ render();
+ }
+};
+
+loadBootstrap()
+ .then(async () => {
+ if (state.selectedSessionId) {
+ await loadSession(state.selectedSessionId);
+ }
+ render();
+ })
+ .catch((error) => {
+ console.error(error);
+ setBanner(`初始化失败：${error.message}`, "error", true);
+ render();
+ });
diff --git a/public/favicon.svg b/public/favicon.svg
new file mode 100644
index 0000000..aa0b491
--- /dev/null
+++ b/public/favicon.svg
@@ -0,0 +1,14 @@
+
diff --git a/public/index.html b/public/index.html
index 678cfae..43073c7 100644
--- a/public/index.html
+++ b/public/index.html
@@ -4,6 +4,7 @@
Boss Control Plane
+
@@ -48,17 +49,25 @@
-
-
选择一个项目会话
-
创建会话后，在这里持续对话并观察任务状态。
+
+
+
+