{activeTab.title}
{activeTab.context.project} 中的 248 个 Session · 4 个实时更新
正在加载任务…
;
+ if (!tasks.length) return 暂无任务
;
+ return {tasks.map((task) => )}
;
+}
+
+export function TaskTimeline({ task }: { readonly task: Task }) {
+ return - 已提交 {task.state !== "PENDING" &&
- {taskLabels[task.state] ?? task.state} }
{entries.length ? entries.map((entry) =>
{entry.text}{entry.redacted && 已脱敏}
) : 尚无输出}选择任务以查看详情
;
+ return {task.capability_id}
{task.task_id}- 持续时间
- {taskDuration(task)}
- 固定上下文
- {task.server_id} / {task.project_id} / {task.session_id}
{JSON.stringify(task.result, null, 2)}} { if (event.target === event.currentTarget) onClose(); }}>
;
+}
+
+export function EventFilters({ value, knownTypes, onChange }: { readonly value: EventFiltersValue; readonly knownTypes: readonly string[]; readonly onChange: (value: EventFiltersValue) => void }) {
+ return ;
+}
+
+export function EventStream({ events, follow, onFollowChange, onSelect, loading = false }: { readonly events: readonly Event[]; readonly follow: boolean; readonly onFollowChange?: (follow: boolean) => void; readonly onSelect?: (event: Event) => void; readonly loading?: boolean }) {
+ const endRef = useRef { if (event.key === "Escape") onClose(); }}>
确认取消任务？
断开连接不会取消任务；只有此次明确确认才会发送取消请求。
- Teamserver
- {task.server_id}
- Project
- {task.project_id}
- Session
- {task.session_id}
- Task
- {task.task_id}
{error}
}正在同步事件…
: !events.length ? 暂无匹配事件
: {events.map((event, index) => )}
}选择事件以查看详情
;
+ return {event.type}
- 事件 ID
- {event.event_id}
- 序号 / 游标
- {event.sequence ?? "—"} / {event.cursor}
- 上下文
- {event.context.server_id} / {event.context.project_id ?? "—"} / {event.context.session_id ?? "—"}
{JSON.stringify(event.payload, null, 2)}{gap?.message ?? messages[phase] ?? phase}{(phase === "recovery_failed" || phase === "degraded") && }
;
+}
diff --git a/src/features/activity/index.ts b/src/features/activity/index.ts
new file mode 100644
index 0000000..ac08999
--- /dev/null
+++ b/src/features/activity/index.ts
@@ -0,0 +1,4 @@
+export * from "./types";
+export * from "./state";
+export * from "./memoryAdapter";
+export * from "./components";
diff --git a/src/features/activity/memoryAdapter.test.ts b/src/features/activity/memoryAdapter.test.ts
new file mode 100644
index 0000000..53a2bd3
--- /dev/null
+++ b/src/features/activity/memoryAdapter.test.ts
@@ -0,0 +1,30 @@
+import { describe, expect, it, vi } from "vitest";
+import type { CapabilityId, Cursor, Event, EventId, ProjectId, ServerId, SessionId, Task, TaskId, Timestamp } from "../../protocol/model";
+import { MemoryActivityAdapter } from "./memoryAdapter";
+
+const scope = { server_id: "s" as ServerId, project_id: "p" as ProjectId, session_id: "x" as SessionId };
+const event: Event = { event_id: "e" as EventId, type: "TASK_UPDATED", timestamp: "2026-01-01T00:00:00Z" as Timestamp, cursor: "current" as Cursor, context: scope, payload: {} };
+const task: Task = { ...scope, task_id: "t" as TaskId, capability_id: "c" as CapabilityId, state: "RUNNING", cancellable: true, created_at: event.timestamp, updated_at: event.timestamp };
+
+describe("MemoryActivityAdapter", () => {
+ it("从有效游标之后恢复标准事件", async () => {
+ const received = vi.fn();
+ new MemoryActivityAdapter([event]).subscribe(scope, undefined, received, vi.fn());
+ await Promise.resolve();
+ expect(received).toHaveBeenCalledWith(event);
+ });
+
+ it("游标失效时报告缺口但继续恢复", async () => {
+ const phase = vi.fn();
+ new MemoryActivityAdapter([event]).subscribe(scope, "expired" as Cursor, vi.fn(), phase);
+ await Promise.resolve();
+ expect(phase).toHaveBeenCalledWith("streaming", expect.objectContaining({ requested_cursor: "expired", resumed_cursor: "current" }));
+ });
+
+ it("断开订阅不会取消任务，取消必须显式调用", async () => {
+ const adapter = new MemoryActivityAdapter([event], [task]);
+ adapter.subscribe(scope, undefined, vi.fn(), vi.fn()).close();
+ await expect(adapter.cancelTask(task)).resolves.toMatchObject({ state: "CANCELLED", cancellable: false });
+ await expect(adapter.cancelTask({ ...task, state: "SUCCEEDED" })).rejects.toThrow("不可取消");
+ });
+});
diff --git a/src/features/activity/memoryAdapter.ts b/src/features/activity/memoryAdapter.ts
new file mode 100644
index 0000000..112cbdf
--- /dev/null
+++ b/src/features/activity/memoryAdapter.ts
@@ -0,0 +1,34 @@
+import type { Cursor, Event, Task, Timestamp } from "../../protocol/model";
+import type { ActivityAdapter, ActivityScope, ActivitySubscription, ResumeGap, StreamPhase } from "./types";
+
+export class MemoryActivityAdapter implements ActivityAdapter {
+ readonly #events: readonly Event[];
+ readonly #tasks = new Map