From 972c822338744c06acd74e5390043508d3cfeff5 Mon Sep 17 00:00:00 2001 From: scorpio Date: Wed, 4 Mar 2026 22:08:56 +0800 Subject: [PATCH] feat: complete remaining features - SkillsPage: skill list, detail view, create new skill - App.tsx: add Skills nav (4 tabs total) - RoomSidebar: agent dropdown multi-select for members - ChatView: workspace file preview modal, load message history on room open - room.go: message history persistence to history/YYYY-MM-DD.md, auto memory update after task - api/server.go: add createSkill, getWorkspaceFile, getMessages endpoints - Clean up unused Vite default files - Update plan.md with completed items and remaining tasks Co-Authored-By: Claude Sonnet 4.6 --- .claude/settings.local.json | 3 +- docs/plans/plan.md | 101 ++++++++++------------------- internal/api/server.go | 76 ++++++++++++++++++++++ internal/room/room.go | 41 ++++++++++++ web/public/vite.svg | 1 - web/src/App.css | 42 ------------ web/src/App.tsx | 3 + web/src/assets/react.svg | 1 - web/src/components/ChatView.tsx | 30 ++++++++- web/src/components/MarketPage.tsx | 2 +- web/src/components/RoomSidebar.tsx | 48 +++++++++++--- web/src/components/SkillsPage.tsx | 82 +++++++++++++++++++++++ web/src/store.ts | 9 ++- 13 files changed, 310 insertions(+), 129 deletions(-) delete mode 100644 web/public/vite.svg delete mode 100644 web/src/App.css delete mode 100644 web/src/assets/react.svg create mode 100644 web/src/components/SkillsPage.tsx diff --git a/.claude/settings.local.json b/.claude/settings.local.json index af8bb62..d82235c 100644 --- a/.claude/settings.local.json +++ b/.claude/settings.local.json @@ -7,7 +7,8 @@ "Bash(go:*)", "Bash(npm create:*)", "Bash(npm install:*)", - "Bash(node:*)" + "Bash(node:*)", + "Bash(npm run:*)" ] } } diff --git a/docs/plans/plan.md b/docs/plans/plan.md index cbce483..c291283 100644 --- a/docs/plans/plan.md +++ b/docs/plans/plan.md @@ -12,87 +12,52 @@ - [x] `internal/llm/client.go` — OpenAI 兼容客户端，支持 DeepSeek/Kimi/Ollama/OpenAI，流式输出 - [x] `internal/agent/agent.go` — AGENT.md frontmatter 解析，SOUL.md 加载，memory 读写，system prompt 构建 - [x] `internal/skill/skill.go` — agentskills.io 标准，skill 发现/加载/XML 生成 -- [x] `internal/room/room.go` — 群配置加载，master orchestration 循环（分配→执行→review→迭代），WebSocket 事件广播 -- [x] `internal/hub/hub.go` — GitHub repo clone，团队包安装（agents/ + skills/） -- [x] `internal/api/server.go` — Echo HTTP 服务，WebSocket hub，全部 REST 接口 -- [x] `cmd/server/main.go` — 入口，读取环境变量启动 +- [x] `internal/room/room.go` — 群配置加载，master orchestration 循环，消息历史持久化，memory 自动更新 +- [x] `internal/hub/hub.go` — GitHub repo clone，团队包安装 +- [x] `internal/api/server.go` — Echo HTTP 服务，WebSocket hub，全部 REST 接口（含 skill 创建、workspace 文件预览、消息历史） +- [x] `cmd/server/main.go` — 入口 ### React 前端 -- [x] Vite + React + TypeScript 项目初始化（`web/`） -- [x] Tailwind CSS v4 + `@tailwindcss/vite` 配置 -- [x] `web/src/types.ts` — 所有类型定义 -- [x] `web/src/store.ts` — Zustand store，WebSocket 连接，消息流式拼接 -- [x] `web/src/App.tsx` — 三栏布局骨架，左侧导航（群聊/Agents/市场） -- [x] `web/src/components/RoomSidebar.tsx` — 群列表，实时状态 badge，创建群表单 -- [x] `web/src/components/ChatView.tsx` — 消息流，角色样式，右侧面板（Members/Tasks/产物），抽屉按钮 -- [x] `web/src/components/AgentsPage.tsx` — Monaco MD 编辑器，AGENT.md/SOUL.md 编辑，创建/删除 agent -- [x] `web/src/components/MarketPage.tsx` — GitHub 一键雇佣，发布说明 +- [x] Vite + React + TypeScript + Tailwind v4 +- [x] `web/src/types.ts` + `store.ts` — 类型定义，Zustand store，WebSocket 流式消息 +- [x] `App.tsx` — 四栏导航（群聊/Agents/Skills/市场） +- [x] `RoomSidebar.tsx` — 群列表，实时状态，创建群（agent 下拉多选） +- [x] `ChatView.tsx` — 消息流，右侧面板，workspace 文件预览 Modal +- [x] `AgentsPage.tsx` — Monaco MD 编辑器，AGENT.md/SOUL.md 编辑 +- [x] `SkillsPage.tsx` — skill 列表，详情查看，新建 skill +- [x] `MarketPage.tsx` — GitHub 一键雇佣，发布说明 -### 配置文件 -- [x] `agents/example-master/AGENT.md` + `SOUL.md` — 示例 master agent -- [x] `skills/example/SKILL.md` — 示例 skill -- [x] `docs/plans/PRD.md` — 完整产品需求文档 -- [x] `README.md` +### 构建验证 +- [x] `go build ./...` 通过 +- [x] `npm run build` 通过（386KB JS bundle） --- ## 待完成 -### 紧急（下次开始先做） +### 下次开始（优先级高） -- [ ] **提交代码到 git** — 所有代码已写好但还未 commit/push - ```bash - git add -A - git commit -m "feat: implement full agent-team platform" - git push - ``` - -- [ ] **前端构建验证** — 确认 Tailwind v4 + Monaco Editor 能正常编译 - ```bash - cd web && npm run build - ``` - -- [ ] **后端编译验证** — 已通过 `go build ./...`，但需要实际运行测试 - ```bash - DEEPSEEK_API_KEY=xxx go run cmd/server/main.go - ``` - -### 功能补全 - -- [ ] **SkillsPage 组件** — skills 列表页面（查看/创建 skill），目前 store 有 `fetchSkills` 但没有对应页面 - - 在 `web/src/components/SkillsPage.tsx` 新建 - - App.tsx 加入 skills 导航入口 - -- [ ] **Agent memory 自动更新** — 任务完成后 master 自动总结经验写入 `agents//memory/` - - 在 `internal/room/room.go` 的 orchestration 循环末尾调用 `agent.SaveMemory()` - - 需要让 master 生成一段经验总结 - -- [ ] **消息历史持久化** — 目前消息只在内存，刷新页面丢失 - - 每条消息追加写入 `rooms//history/YYYY-MM-DD.md` - - 前端启动时通过 REST 接口加载历史 - -- [ ] **右侧面板 Skills tab** — 点击 Skills 抽屉按钮时展示群内可用 skills - - 调用 `GET /api/skills` 获取列表 - -- [ ] **Workspace 文件预览** — 点击产物文件名时展示 MD 内容 - - 新增 `GET /api/rooms/:id/workspace/:filename` 接口 - - 前端弹出 Modal 展示 ReactMarkdown 渲染 - -- [ ] **创建群时成员选择优化** — 目前是手动输入 agent 名，改为下拉多选 - - 调用 `GET /api/agents` 获取列表，渲染 checkbox - -- [ ] **Leader 群的 orchestration** — 目前 room.go 的 Handle 只支持单 master，Leader 群需要广播给多个 master +- [ ] **Leader 群 orchestration** — 目前 room.go 的 Handle 只支持单 master，Leader 群需要广播给多个 master - Leader 群：用户消息广播给所有 master，每个 master 在自己的部门群里处理 + - 需要在 Room 结构里区分 TypeLeader，Handle 时遍历所有 master -- [ ] **环境变量配置页** — 前端提供一个设置页，配置各 provider 的 API Key - - 写入本地 `.env` 文件或通过 `PUT /api/config` 接口 +- [ ] **环境变量配置页** — 前端提供设置页，配置各 provider 的 API Key + - 新增 `web/src/components/SettingsPage.tsx` + - 后端 `PUT /api/config` 写入 `.env` 文件，启动时 `godotenv` 加载 -### 已知问题 +- [ ] **实际测试** — 配置真实 DeepSeek API Key 跑通一次完整流程 + ```bash + export DEEPSEEK_API_KEY=your_key + go run cmd/server/main.go + # 另一个终端 + cd web && npm run dev + ``` -- [ ] `web/src/App.css` 可以删除（Vite 默认生成，已不需要） -- [ ] `web/src/assets/react.svg` 可以删除 -- [ ] `web/public/vite.svg` 可以删除 -- [ ] `main.tsx` 里的 `import './App.css'` 需要删除 +### 后续迭代 + +- [ ] Skill 脚本执行沙箱（scripts/ 目录下的脚本安全执行） +- [ ] 用户认证 +- [ ] 消息搜索 --- diff --git a/internal/api/server.go b/internal/api/server.go index aad005a..80b8916 100644 --- a/internal/api/server.go +++ b/internal/api/server.go @@ -3,10 +3,13 @@ package api import ( "context" "encoding/json" + "fmt" "net/http" "os" "path/filepath" + "strings" "sync" + "time" "github.com/gorilla/websocket" "github.com/labstack/echo/v4" @@ -59,10 +62,13 @@ func (s *Server) routes() { g.DELETE("/agents/:name", s.deleteAgent) g.GET("/skills", s.listSkills) g.GET("/skills/:name", s.getSkill) + g.POST("/skills", s.createSkill) g.POST("/hub/install", s.hubInstall) g.GET("/rooms/:id/workspace", s.listWorkspace) + g.GET("/rooms/:id/workspace/:file", s.getWorkspaceFile) g.GET("/rooms/:id/tasks", s.getTasks) g.GET("/rooms/:id/history", s.listHistory) + g.GET("/rooms/:id/messages", s.getMessages) s.e.GET("/ws/:roomID", s.wsHandler) } @@ -294,3 +300,73 @@ func (s *Server) listHistory(c echo.Context) error { } return c.JSON(200, files) } + +func (s *Server) createSkill(c echo.Context) error { + var body struct { + Name string `json:"name"` + Content string `json:"content"` + } + if err := c.Bind(&body); err != nil { + return err + } + dir := filepath.Join(s.skillsDir, body.Name) + os.MkdirAll(dir, 0755) + content := body.Content + if content == "" { + content = "---\nname: " + body.Name + "\ndescription: \n---\n\n# " + body.Name + "\n\n描述这个 skill 的用途和使用步骤。\n" + } + return os.WriteFile(filepath.Join(dir, "SKILL.md"), []byte(content), 0644) +} + +func (s *Server) getWorkspaceFile(c echo.Context) error { + id := c.Param("id") + file := c.Param("file") + data, err := os.ReadFile(filepath.Join(s.roomsDir, id, "workspace", file)) + if err != nil { + return c.JSON(404, map[string]string{"error": "not found"}) + } + return c.JSON(200, map[string]string{"content": string(data)}) +} + +func (s *Server) getMessages(c echo.Context) error { + id := c.Param("id") + // Read today's history file and parse into messages + historyFile := filepath.Join(s.roomsDir, id, "history", time.Now().Format("2006-01-02")+".md") + data, err := os.ReadFile(historyFile) + if err != nil { + return c.JSON(200, []interface{}{}) + } + type msg struct { + ID string `json:"id"` + Agent string `json:"agent"` + Role string `json:"role"` + Content string `json:"content"` + } + var msgs []msg + lines := strings.Split(string(data), "\n## ") + for i, block := range lines { + if block == "" { + continue + } + // Parse "**[HH:MM:SS] agentName** (role)\n\ncontent" + parts := strings.SplitN(block, "\n\n", 2) + if len(parts) < 2 { + continue + } + header := parts[0] + content := strings.TrimSpace(parts[1]) + // Extract role and agent from header like "**[15:04:05] agentName** (role)" + var agentName, role string + fmt.Sscanf(header, "**[%*s] %s** (%s)", &agentName, &role) + agentName = strings.TrimSuffix(agentName, "**") + role = strings.TrimSuffix(role, ")") + if agentName == "" { + agentName = "unknown" + } + if role == "" { + role = "member" + } + msgs = append(msgs, msg{ID: fmt.Sprintf("%d", i), Agent: agentName, Role: role, Content: content}) + } + return c.JSON(200, msgs) +} diff --git a/internal/room/room.go b/internal/room/room.go index 345b91e..7fa48dd 100644 --- a/internal/room/room.go +++ b/internal/room/room.go @@ -117,8 +117,23 @@ func (r *Room) setStatus(s Status, activeAgent, action string) { r.emit(Event{Type: EvtRoomStatus, Status: s, ActiveAgent: activeAgent, Action: action}) } +// AppendHistory persists a message to today's history file. +func (r *Room) AppendHistory(role, agentName, content string) { + dir := filepath.Join(r.Dir, "history") + os.MkdirAll(dir, 0755) + filename := filepath.Join(dir, time.Now().Format("2006-01-02")+".md") + line := fmt.Sprintf("\n**[%s] %s** (%s)\n\n%s\n", time.Now().Format("15:04:05"), agentName, role, content) + f, err := os.OpenFile(filename, os.O_APPEND|os.O_CREATE|os.O_WRONLY, 0644) + if err != nil { + return + } + defer f.Close() + f.WriteString(line) +} + // Handle processes a user message through master orchestration. func (r *Room) Handle(ctx context.Context, userMsg string) error { + r.AppendHistory("user", "user", userMsg) r.setStatus(StatusThinking, "", "") // Build master context @@ -143,6 +158,7 @@ func (r *Room) Handle(ctx context.Context, userMsg string) error { } reply := masterReply.String() masterMsgs = append(masterMsgs, llm.NewMsg("assistant", reply)) + r.AppendHistory("master", r.master.Config.Name, reply) // Parse assignments assignments := parseAssignments(reply) @@ -177,6 +193,7 @@ func (r *Room) Handle(ctx context.Context, userMsg string) error { } result := memberReply.String() results.WriteString(fmt.Sprintf("[%s] %s\n", memberName, result)) + r.AppendHistory("member", memberName, result) // Save workspace file if member produced a document if strings.Contains(result, "# ") { @@ -199,9 +216,33 @@ func (r *Room) Handle(ctx context.Context, userMsg string) error { } r.setStatus(StatusPending, "", "") + + // Auto-update master memory after task completion + go r.updateMasterMemory(context.Background(), userMsg, masterMsgs) + return nil } +func (r *Room) updateMasterMemory(ctx context.Context, task string, msgs []llm.Message) { + summaryPrompt := fmt.Sprintf("Based on this task: %q\nSummarize key learnings and patterns in 3-5 bullet points for future reference. Be concise.", task) + memMsgs := append(msgs, llm.NewMsg("user", summaryPrompt)) + summary, err := r.master.Chat(ctx, memMsgs, nil) + if err != nil || summary == "" { + return + } + filename := time.Now().Format("2006-01") + ".md" + existing, _ := os.ReadFile(filepath.Join(r.master.Dir, "memory", filename)) + content := string(existing) + fmt.Sprintf("\n## %s — %s\n\n%s\n", time.Now().Format("2006-01-02"), task[:min(50, len(task))], summary) + r.master.SaveMemory(filename, content) +} + +func min(a, b int) int { + if a < b { + return a + } + return b +} + func parseAssignments(text string) map[string]string { result := make(map[string]string) for _, line := range strings.Split(text, "\n") { diff --git a/web/public/vite.svg b/web/public/vite.svg deleted file mode 100644 index e7b8dfb..0000000 --- a/web/public/vite.svg +++ /dev/null @@ -1 +0,0 @@ - \ No newline at end of file diff --git a/web/src/App.css b/web/src/App.css deleted file mode 100644 index b9d355d..0000000 --- a/web/src/App.css +++ /dev/null @@ -1,42 +0,0 @@ -#root { - max-width: 1280px; - margin: 0 auto; - padding: 2rem; - text-align: center; -} - -.logo { - height: 6em; - padding: 1.5em; - will-change: filter; - transition: filter 300ms; -} -.logo:hover { - filter: drop-shadow(0 0 2em #646cffaa); -} -.logo.react:hover { - filter: drop-shadow(0 0 2em #61dafbaa); -} - -@keyframes logo-spin { - from { - transform: rotate(0deg); - } - to { - transform: rotate(360deg); - } -} - -@media (prefers-reduced-motion: no-preference) { - a:nth-of-type(2) .logo { - animation: logo-spin infinite 20s linear; - } -} - -.card { - padding: 2em; -} - -.read-the-docs { - color: #888; -} diff --git a/web/src/App.tsx b/web/src/App.tsx index ca5efca..69edbae 100644 --- a/web/src/App.tsx +++ b/web/src/App.tsx @@ -2,6 +2,7 @@ import { useStore } from './store' import { RoomSidebar } from './components/RoomSidebar' import { ChatView } from './components/ChatView' import { AgentsPage } from './components/AgentsPage' +import { SkillsPage } from './components/SkillsPage' import { MarketPage } from './components/MarketPage' export default function App() { @@ -12,11 +13,13 @@ export default function App() {
setPage('chat')} /> setPage('agents')} /> + setPage('skills')} /> setPage('market')} />
{page === 'chat' && <>} {page === 'agents' && } + {page === 'skills' && } {page === 'market' && } ) diff --git a/web/src/assets/react.svg b/web/src/assets/react.svg deleted file mode 100644 index 6c87de9..0000000 --- a/web/src/assets/react.svg +++ /dev/null @@ -1 +0,0 @@ - \ No newline at end of file diff --git a/web/src/components/ChatView.tsx b/web/src/components/ChatView.tsx index b9458c7..17cee26 100644 --- a/web/src/components/ChatView.tsx +++ b/web/src/components/ChatView.tsx @@ -2,12 +2,15 @@ import { useEffect, useRef, useState } from 'react' import ReactMarkdown from 'react-markdown' import remarkGfm from 'remark-gfm' import { useStore } from '../store' -import { Message } from '../types' +import type { Message } from '../types' + +const API = '/api' export function ChatView() { const { activeRoomId, rooms, messages, tasks, workspace, sendMessage } = useStore() const [input, setInput] = useState('') const [drawer, setDrawer] = useState(null) + const [previewFile, setPreviewFile] = useState<{ name: string; content: string } | null>(null) const bottomRef = useRef(null) const room = rooms.find(r => r.id === activeRoomId) @@ -17,6 +20,11 @@ export function ChatView() { useEffect(() => { bottomRef.current?.scrollIntoView({ behavior: 'smooth' }) }, [msgs]) + const openFile = async (filename: string) => { + const d = await fetch(`${API}/rooms/${activeRoomId}/workspace/${filename}`).then(r => r.json()) + setPreviewFile({ name: filename, content: d.content || '' }) + } + if (!room) return
选择一个群开始
const statusLabel = room.status === 'working' && room.activeAgent @@ -84,7 +92,8 @@ export function ChatView() {

产物

{files.map(f => ( -
+
openFile(f)} + className="flex items-center gap-1 text-xs text-indigo-300 hover:text-indigo-200 cursor-pointer py-0.5"> 📄{f}
))} @@ -111,10 +120,25 @@ export function ChatView() {
{drawer === 'workspace' && files.map(f => ( -
📄 {f}
+
openFile(f)} className="text-sm text-indigo-300 py-1 cursor-pointer hover:text-indigo-200">📄 {f}
))} )} + + {/* File preview modal */} + {previewFile && ( +
setPreviewFile(null)}> +
e.stopPropagation()}> +
+ 📄 {previewFile.name} + +
+
+ {previewFile.content} +
+
+
+ )} ) } diff --git a/web/src/components/MarketPage.tsx b/web/src/components/MarketPage.tsx index 47a6a51..b9f97a5 100644 --- a/web/src/components/MarketPage.tsx +++ b/web/src/components/MarketPage.tsx @@ -1,4 +1,4 @@ -import { useEffect, useState } from 'react' +import { useState } from 'react' import { useStore } from '../store' const API = '/api' diff --git a/web/src/components/RoomSidebar.tsx b/web/src/components/RoomSidebar.tsx index d7bf548..e8b7727 100644 --- a/web/src/components/RoomSidebar.tsx +++ b/web/src/components/RoomSidebar.tsx @@ -4,18 +4,27 @@ import { useStore } from '../store' const API = '/api' export function RoomSidebar() { - const { rooms, activeRoomId, setActiveRoom, fetchRooms, agents } = useStore() + const { rooms, activeRoomId, setActiveRoom, fetchRooms, agents, fetchAgents } = useStore() const [creating, setCreating] = useState(false) - const [form, setForm] = useState({ name: '', type: 'dept', master: '', members: '' }) + const [form, setForm] = useState({ name: '', type: 'dept', master: '', members: [] as string[] }) - useEffect(() => { fetchRooms() }, []) + useEffect(() => { fetchRooms(); fetchAgents() }, []) + + const toggleMember = (name: string) => { + setForm(f => ({ + ...f, + members: f.members.includes(name) ? f.members.filter(m => m !== name) : [...f.members, name] + })) + } const create = async () => { + if (!form.name || !form.master) return await fetch(`${API}/rooms`, { method: 'POST', headers: { 'Content-Type': 'application/json' }, - body: JSON.stringify({ name: form.name, type: form.type, master: form.master, members: form.members.split(',').map(s => s.trim()).filter(Boolean) }) + body: JSON.stringify({ name: form.name, type: form.type, master: form.master, members: form.members }) }) setCreating(false) + setForm({ name: '', type: 'dept', master: '', members: [] }) fetchRooms() } @@ -25,6 +34,8 @@ export function RoomSidebar() { return 'bg-gray-500' } + const availableMembers = agents.filter(a => a.name !== form.master) + return (
@@ -34,14 +45,33 @@ export function RoomSidebar() { {creating && (
- setForm(f => ({ ...f, name: e.target.value }))} /> - setForm(f => ({ ...f, name: e.target.value }))} /> + - setForm(f => ({ ...f, master: e.target.value }))} /> - setForm(f => ({ ...f, members: e.target.value }))} /> - + + {form.type === 'dept' && availableMembers.length > 0 && ( +
+
选择成员：
+ {availableMembers.map(a => ( + + ))} +
+ )} +
+ + +
)} diff --git a/web/src/components/SkillsPage.tsx b/web/src/components/SkillsPage.tsx new file mode 100644 index 0000000..9a997fa --- /dev/null +++ b/web/src/components/SkillsPage.tsx @@ -0,0 +1,82 @@ +import { useEffect, useState } from 'react' +import Editor from '@monaco-editor/react' +import { useStore } from '../store' + +const API = '/api' + +export function SkillsPage() { + const { skills, fetchSkills } = useStore() + const [selected, setSelected] = useState(null) + const [body, setBody] = useState('') + const [creating, setCreating] = useState(false) + const [newName, setNewName] = useState('') + + useEffect(() => { fetchSkills() }, []) + + useEffect(() => { + if (!selected) return + fetch(`${API}/skills/${selected}`).then(r => r.json()).then(d => setBody(d.body || '')) + }, [selected]) + + const create = async () => { + if (!newName.trim()) return + const content = `---\nname: ${newName.trim()}\ndescription: \n---\n\n# ${newName.trim()}\n\n描述这个 skill 的用途和使用步骤。\n` + await fetch(`${API}/agents`, { method: 'POST', headers: { 'Content-Type': 'application/json' }, body: JSON.stringify({ name: newName.trim() }) }) + // Use skill create endpoint + await fetch(`${API}/skills`, { + method: 'POST', headers: { 'Content-Type': 'application/json' }, + body: JSON.stringify({ name: newName.trim(), content }) + }) + setNewName('') + setCreating(false) + fetchSkills() + } + + return ( +
+ {/* Skill list */} +
+
+ {creating ? ( +
+ setNewName(e.target.value)} onKeyDown={e => e.key === 'Enter' && create()} autoFocus /> + + +
+ ) : ( + + )} +
+
+ {(skills || []).map(s => ( +
setSelected(s.name)} + className={`px-3 py-2 cursor-pointer hover:bg-gray-700 ${selected === s.name ? 'bg-gray-700' : ''}`}> +
{s.name}
+
{s.description}
+
+ ))} +
+
+ + {/* Skill detail / editor */} +
+ {selected ? ( + <> +
+ {selected} + SKILL.md +
+
+ setBody(v || '')} + options={{ minimap: { enabled: false }, wordWrap: 'on', fontSize: 13, readOnly: true }} /> +
+ + ) : ( +
选择一个 skill 查看详情
+ )} +
+
+ ) +} diff --git a/web/src/store.ts b/web/src/store.ts index 5921bcb..ed21e50 100644 --- a/web/src/store.ts +++ b/web/src/store.ts @@ -1,5 +1,5 @@ import { create } from 'zustand' -import { Room, Message, AgentInfo, SkillMeta, WsEvent } from './types' +import type { Room, Message, AgentInfo, SkillMeta, WsEvent } from './types' interface AppState { rooms: Room[] @@ -44,6 +44,10 @@ export const useStore = create((set, get) => ({ fetch(`${API}/rooms/${id}/workspace`).then(r => r.json()).then(files => { set(s => ({ workspace: { ...s.workspace, [id]: files || [] } })) }) + // Load message history + fetch(`${API}/rooms/${id}/messages`).then(r => r.json()).then(msgs => { + if (msgs?.length) set(s => ({ messages: { ...s.messages, [id]: msgs } })) + }).catch(() => {}) }, fetchRooms: async () => { @@ -96,8 +100,7 @@ export const useStore = create((set, get) => ({ }, sendMessage: (roomId, content) => { - const { ws, messages } = get() - // Add user message locally + const { ws } = get() const userMsg = { id: Date.now().toString(), agent: 'user', role: 'user' as const, content } set(s => ({ messages: { ...s.messages, [roomId]: [...(s.messages[roomId] || []), userMsg] } })) ws[roomId]?.send(JSON.stringify({ type: 'user_message', content }))