auto-added claus
const ok = await appendFinalAssistant(payload.message, chatStream);
if (!ok) _markStreamTerminal("error", "aborted");
chatStream = "";
+ streamTextBuffer = "";
chatRunId = null;
chatStreamSegments = [];
return;
@@ -3196,6 +3191,7 @@ ${autoLimit ? `auto-added claus
_stopDynamicStreamStatus();
_markStreamTerminal("error", String(payload.errorMessage || "chat error"));
chatStream = "";
+ streamTextBuffer = "";
chatRunId = null;
chatStreamSegments = [];
statusBar.textContent = `${t("chat.error")}: ${String(payload.errorMessage || "chat error")}`;
diff --git a/interfaces/admin/static/styles.css b/interfaces/admin/static/styles.css
index 9413cf93..3a4d4d4c 100644
--- a/interfaces/admin/static/styles.css
+++ b/interfaces/admin/static/styles.css
@@ -174,6 +174,21 @@ body {
.card { background: rgba(15,23,42,0.9); border: 1px solid rgba(148,163,184,0.18); border-radius: 14px; padding: 14px; margin-bottom: 12px; }
.card__title { font-weight: 650; margin-bottom: 10px; }
.row { display: flex; gap: 10px; flex-wrap: wrap; align-items: center; }
+.section-card .row {
+ width: 100%;
+ flex-wrap: nowrap;
+ align-items: center;
+}
+.section-card .row > label:first-child {
+ min-width: 170px;
+}
+.section-card .row > .input,
+.section-card .row > textarea.input,
+.section-card .row > select.input {
+ width: 100%;
+ max-width: 100%;
+ min-width: 0;
+}
.chat-login-fields {
display: flex;
flex-direction: column;
@@ -213,7 +228,60 @@ body {
flex: 0 0 auto;
}
.kv { font-family: ui-monospace, SFMono-Regular, Menlo, Monaco, Consolas, "Liberation Mono", "Courier New", monospace; font-size: 12px; background: rgba(148,163,184,0.08); border: 1px solid rgba(148,163,184,0.14); padding: 6px 8px; border-radius: 10px; }
+.section-card .kv {
+ display: flex;
+ align-items: center;
+ gap: 8px;
+ width: 100%;
+ box-sizing: border-box;
+}
.input { background: rgba(2,6,23,0.65); border: 1px solid rgba(148,163,184,0.25); color: #e2e8f0; border-radius: 10px; padding: 8px 10px; min-width: 240px; }
+
+/* Unified switch style for admin/chat checkboxes */
+input[type="checkbox"],
+.switch-input {
+ appearance: none;
+ -webkit-appearance: none;
+ width: 40px;
+ height: 22px;
+ border-radius: 999px;
+ border: 1px solid rgba(148,163,184,0.35);
+ background: rgba(15,23,42,0.75);
+ position: relative;
+ cursor: pointer;
+ transition: background .18s ease, border-color .18s ease;
+}
+input[type="checkbox"]::before,
+.switch-input::before {
+ content: "";
+ position: absolute;
+ width: 16px;
+ height: 16px;
+ left: 2px;
+ top: 2px;
+ border-radius: 50%;
+ background: #cbd5e1;
+ transition: transform .18s ease;
+}
+input[type="checkbox"]:checked,
+.switch-input:checked {
+ background: rgba(34,197,94,0.45);
+ border-color: rgba(34,197,94,0.85);
+}
+input[type="checkbox"]:checked::before,
+.switch-input:checked::before {
+ transform: translateX(18px);
+ background: #ffffff;
+}
+.switch-wrap {
+ display: inline-flex;
+ align-items: center;
+ gap: 8px;
+ cursor: pointer;
+}
+.switch-slider {
+ display: none;
+}
.input--compact {
min-width: 0;
padding: 6px 8px;
diff --git a/runtime/workspaces/experts.py b/runtime/workspaces/experts.py
index b8e02b06..ee8974c9 100644
--- a/runtime/workspaces/experts.py
+++ b/runtime/workspaces/experts.py
@@ -1,6 +1,7 @@
from __future__ import annotations
import copy
+import json
import threading
from pathlib import Path
from typing import Any
@@ -11,6 +12,8 @@ _REQUIRED_FILES: tuple[str, ...] = ("SOUL.md",)
_OPTIONAL_FILES: tuple[str, ...] = ("ROLE_SYSTEM.md",)
_ALL_FILES: tuple[str, ...] = (*_REQUIRED_FILES, *_OPTIONAL_FILES)
_RESERVED_IDS: frozenset[str] = frozenset({"main"})
+_META_FILE = "META.json"
+_ROLE_OPTIONS: frozenset[str] = frozenset({"system", "expert"})
_CACHE_LOCK = threading.Lock()
_LIST_CACHE_SIGNATURE: tuple[Any, ...] | None = None
_LIST_CACHE_ROWS: list[dict[str, Any]] = []
@@ -37,6 +40,46 @@ def is_builtin_expert(expert_id: str) -> bool:
return normalize_expert_id(expert_id) in _RESERVED_IDS
+def _default_role_for_expert(eid: str) -> str:
+ return "system" if eid in _RESERVED_IDS else "expert"
+
+
+def _is_noise_workspace_id(eid: str) -> bool:
+ sid = normalize_expert_id(eid)
+ return sid in {"pycache", "__pycache__"} or sid.endswith("pycache")
+
+
+def _read_meta(expert_dir: Path) -> dict[str, str]:
+ p = expert_dir / _META_FILE
+ if not p.exists() or not p.is_file():
+ return {}
+ try:
+ raw = json.loads(p.read_text(encoding="utf-8"))
+ except Exception:
+ return {}
+ obj = raw if isinstance(raw, dict) else {}
+ role = str(obj.get("role") or "").strip().lower()
+ if role not in _ROLE_OPTIONS:
+ role = ""
+ return {
+ "display_name_en": str(obj.get("display_name_en") or "").strip(),
+ "display_name_zh": str(obj.get("display_name_zh") or "").strip(),
+ "role": role,
+ }
+
+
+def _write_meta(expert_dir: Path, *, display_name_en: str | None, display_name_zh: str | None, role: str | None) -> None:
+ role_norm = str(role or "").strip().lower()
+ if role_norm and role_norm not in _ROLE_OPTIONS:
+ raise ValueError("invalid_role")
+ payload = {
+ "display_name_en": str(display_name_en or "").strip(),
+ "display_name_zh": str(display_name_zh or "").strip(),
+ "role": role_norm,
+ }
+ (expert_dir / _META_FILE).write_text(f"{json.dumps(payload, ensure_ascii=False, indent=2)}\n", encoding="utf-8")
+
+
def _workspace_signature() -> tuple[Any, ...]:
root = workspaces_root()
if not root.exists() or not root.is_dir():
@@ -50,6 +93,8 @@ def _workspace_signature() -> tuple[Any, ...]:
eid = normalize_expert_id(item.name)
if not eid:
continue
+ if _is_noise_workspace_id(eid):
+ continue
for name in _ALL_FILES:
p = item / name
if not p.exists() or not p.is_file():
@@ -109,6 +154,8 @@ def list_experts() -> list[dict[str, Any]]:
eid = normalize_expert_id(item.name)
if not eid:
continue
+ if _is_noise_workspace_id(eid):
+ continue
files: dict[str, str] = {}
for name in _ALL_FILES:
p = item / name
@@ -119,12 +166,19 @@ def list_experts() -> list[dict[str, Any]]:
files[name] = p.read_text(encoding="utf-8")
except Exception:
files[name] = ""
+ meta = _read_meta(item)
+ role = _default_role_for_expert(eid)
+ if str(meta.get("role") or "").strip() in _ROLE_OPTIONS:
+ role = str(meta.get("role") or "").strip()
out.append(
{
"id": eid,
"path": str(item),
"builtin": is_builtin_expert(eid),
"has_required_soul": bool(str(files.get("SOUL.md") or "").strip()),
+ "display_name_en": str(meta.get("display_name_en") or ""),
+ "display_name_zh": str(meta.get("display_name_zh") or ""),
+ "role": role,
"files": files,
}
)
@@ -227,7 +281,14 @@ def _workspace_dir(expert_id: str) -> Path:
return (workspaces_root() / eid).resolve()
-def create_expert(*, expert_id: str, files: dict[str, Any]) -> dict[str, Any]:
+def create_expert(
+ *,
+ expert_id: str,
+ files: dict[str, Any],
+ display_name_en: str | None = None,
+ display_name_zh: str | None = None,
+ role: str | None = None,
+) -> dict[str, Any]:
eid = normalize_expert_id(expert_id)
if not eid or eid in _RESERVED_IDS:
raise ValueError("invalid_expert_id")
@@ -238,8 +299,9 @@ def create_expert(*, expert_id: str, files: dict[str, Any]) -> dict[str, Any]:
raise ValueError("expert_exists")
clean_files = _normalize_supported_files(files)
soul = str(clean_files.get("SOUL.md") or "").strip()
- if not soul:
- raise ValueError("soul_required")
+ role_system = str(clean_files.get("ROLE_SYSTEM.md") or "").strip()
+ if not soul and not role_system:
+ raise ValueError("soul_or_role_system_required")
target.mkdir(parents=True, exist_ok=False)
for name in _ALL_FILES:
body = str(clean_files.get(name) or "")
@@ -248,7 +310,15 @@ def create_expert(*, expert_id: str, files: dict[str, Any]) -> dict[str, Any]:
if body:
(target / name).write_text(body.strip() + "\n", encoding="utf-8")
if not (target / "SOUL.md").exists():
- (target / "SOUL.md").write_text(soul + "\n", encoding="utf-8")
+ if soul:
+ (target / "SOUL.md").write_text(soul + "\n", encoding="utf-8")
+ role_save = str(role or "").strip().lower() or _default_role_for_expert(eid)
+ _write_meta(
+ target,
+ display_name_en=display_name_en,
+ display_name_zh=display_name_zh,
+ role=role_save,
+ )
_clear_experts_cache()
return {"id": eid, "path": str(target)}
@@ -268,8 +338,8 @@ def update_expert_files(*, expert_id: str, files: dict[str, Any]) -> dict[str, A
else:
p = target / name
next_files[name] = p.read_text(encoding="utf-8") if p.exists() and p.is_file() else ""
- if not str(next_files.get("SOUL.md") or "").strip():
- raise ValueError("soul_required")
+ if not str(next_files.get("SOUL.md") or "").strip() and not str(next_files.get("ROLE_SYSTEM.md") or "").strip():
+ raise ValueError("soul_or_role_system_required")
for name in _ALL_FILES:
p = target / name
body = str(next_files.get(name) or "")
@@ -281,6 +351,30 @@ def update_expert_files(*, expert_id: str, files: dict[str, Any]) -> dict[str, A
return {"id": eid, "path": str(target)}
+def update_expert_meta(
+ *,
+ expert_id: str,
+ display_name_en: str | None = None,
+ display_name_zh: str | None = None,
+ role: str | None = None,
+) -> dict[str, Any]:
+ eid = normalize_expert_id(expert_id)
+ if not eid:
+ raise ValueError("invalid_expert_id")
+ target = _workspace_dir(eid)
+ if not target.exists() or not target.is_dir():
+ raise ValueError("expert_not_found")
+ role_save = str(role or "").strip().lower() or _default_role_for_expert(eid)
+ _write_meta(
+ target,
+ display_name_en=display_name_en,
+ display_name_zh=display_name_zh,
+ role=role_save,
+ )
+ _clear_experts_cache()
+ return {"id": eid, "path": str(target)}
+
+
def delete_expert(expert_id: str) -> None:
eid = normalize_expert_id(expert_id)
if not eid:
@@ -308,6 +402,7 @@ __all__ = [
"is_builtin_expert",
"list_experts",
"normalize_expert_id",
+ "update_expert_meta",
"update_expert_files",
"warm_expert_workspace_cache",
"workspaces_root",