diff --git a/scripts/eed_web_opencode.py b/scripts/eed_web_opencode.py index 4757abb..d4b10ef 100644 --- a/scripts/eed_web_opencode.py +++ b/scripts/eed_web_opencode.py @@ -2840,17 +2840,14 @@ class Handler(http.server.BaseHTTPRequestHandler): try: self._chunk_end() except Exception: pass - def _stream_opencode(self, message, model, eed_sid, token): - """OpenCode 引擎:opencode run --agent egg -m [-s oc_sid] --format json -- + def _stream_opencode(self, message, model, eed_sid, token, history=None): + """OpenCode 引擎:opencode run --agent egg -m --format json -- 解析 NDJSON 事件流,翻译成前端要的 delta/thinking/tool/tool_result/usage/error。 - 多轮对话靠 OpenCode 自己的 session:后端维护 eed_sid -> oc_sid 映射。""" - oc_sid = None - _oc = OC_SESS.get(eed_sid) - if _oc: - oc_sid = _oc.get("sid") + ★ 记忆统一以「前端完整历史」为准(与 WorkBuddy 共享同一份记忆 · 两边绝对一致): + 每次调用都用 build_prompt 把完整对话历史拼进消息,不依赖 opencode session。""" + if history: + message = build_prompt(history, message) cmd = [OPENCODE, "run", "--agent", AGENT_NAME, "-m", model, "--format", "json", "--auto", "--thinking"] - if oc_sid: - cmd += ["-s", oc_sid] cmd += ["--", message] proc = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.DEVNULL, text=True, bufsize=1, start_new_session=True, cwd=EED_CWD) @@ -2919,29 +2916,22 @@ class Handler(http.server.BaseHTTPRequestHandler): def _stream_workbuddy(self, message, model, eed_sid, token, history=None): """WorkBuddy 免费积分大脑:codebuddy CLI 路径(苍耳 2026-08-04 接入)。 - model 形如 wb/<实际模型id>。多轮会话靠 codebuddy 自己的会话文件续聊: - ① 本场 sid 已在 codebuddy 开过(WB_SESS 有记录)→ --resume 接续记忆; - ② 没开过 → --session-id 开新场,并把前端传来的 history(含 DeepSeek 聊过的内容) - 拼进消息前缀 → WorkBuddy 一上来就知道之前聊过什么(跨大脑记忆共享)。 - (2026-08-04 修复:之前靠猜 jsonl 路径判断 resume,路径不对 → 每次当新会话 → 完全失忆)""" + model 形如 wb/<实际模型id>。 + ★ 记忆统一以「前端完整历史」为准(与 DeepSeek 共享同一份记忆 · 两边绝对一致): + 每次调用都用 build_prompt 把完整对话历史拼进消息。 + session-id 用固定 sid 便于 codebuddy 保持会话文件,但记忆不依赖它。""" # wb/ 前缀剥掉,得到 codebuddy 认识的模型 id(hy3 / glm-5.2 / kimi-k3-1 ...) cb_model = model.split("/", 1)[1] if "/" in model else model # 会话:面板侧 eed_sid 直接当 codebuddy 的 sid 用(稳定的 eed_ 前缀 = 同一场对话) sid = eed_sid if eed_sid and eed_sid.startswith("eed_") else ("eed_" + uuid.uuid4().hex[:12]) + if history: + message = build_prompt(history, message) cmd = [CODEBUDDY, "--print", "--model", cb_model, "--tools", "Read,WebSearch,Bash", "--output-format", "stream-json", - "--system-prompt", EED_SYS] - # 每次都用前端最新的完整历史当权威上下文(DeepSeek/WB 切换后也不丢新增内容), - # codebuddy 会话文件只用来给模型"参考之前自己说过什么"。 - if history: - message = build_prompt(history, message) - if sid in WB_SESS: - return self._stream_cmd(cmd + ["--resume", sid, "-p", message], token) - acc = self._stream_cmd(cmd + ["--session-id", sid, "-p", message], token) - WB_SESS[sid] = {"ts": time.time()} - _save_wb_sess() - return acc + "--system-prompt", EED_SYS, + "--session-id", sid, "-p", message] + return self._stream_cmd(cmd, token) def _stream_cmd(self, cmd, token=""): """跑一次 codebuddy 子进程,边解析边把事件流式推给前端,返回累计文本。""" @@ -3142,7 +3132,8 @@ class Handler(http.server.BaseHTTPRequestHandler): # WorkBuddy 免费积分大脑:走 codebuddy CLI(不花 DeepSeek 余额) acc = self._stream_workbuddy(message, model, sid, token, history) else: - acc = self._stream_opencode(message, model, sid, token) + # DeepSeek 大脑:同样基于前端完整历史(与 WB 共享同一份记忆) + acc = self._stream_opencode(message, model, sid, token, history) if not acc: acc = "(蛋蛋没回话,换个说法试试~)" self._event("done", {"text": acc, "session_id": sid, "compacted": False})