mirror of
https://github.com/Youzini-afk/ST-Bionic-Memory-Ecology.git
synced 2026-05-15 22:30:38 +08:00
381 lines
12 KiB
JavaScript
381 lines
12 KiB
JavaScript
export async function onViewGraphController(runtime) {
|
||
const graph = runtime.getCurrentGraph();
|
||
if (!graph) {
|
||
runtime.toastr.warning("当前没有加载的图谱");
|
||
return;
|
||
}
|
||
|
||
const stats = runtime.getGraphStats(graph);
|
||
const statsText = [
|
||
`节点: ${stats.activeNodes} 活跃 / ${stats.archivedNodes} 归档`,
|
||
`边: ${stats.totalEdges}`,
|
||
`最后处理楼层: ${stats.lastProcessedSeq}`,
|
||
`类型分布: ${
|
||
Object.entries(stats.typeCounts)
|
||
.map(([k, v]) => `${k}=${v}`)
|
||
.join(", ") || "(空)"
|
||
}`,
|
||
].join("\n");
|
||
|
||
runtime.toastr.info(statsText, "ST-BME 图谱状态", { timeOut: 10000 });
|
||
}
|
||
|
||
export async function onTestEmbeddingController(runtime) {
|
||
const config = runtime.getEmbeddingConfig();
|
||
const validation = runtime.validateVectorConfig(config);
|
||
if (!validation.valid) {
|
||
runtime.toastr.warning(validation.error);
|
||
return;
|
||
}
|
||
|
||
runtime.toastr.info("正在测试 Embedding API 连通性...");
|
||
const result = await runtime.testVectorConnection(config, runtime.getCurrentChatId());
|
||
|
||
if (result.success) {
|
||
runtime.toastr.success(`连接成功！向量维度: ${result.dimensions}`);
|
||
} else {
|
||
runtime.toastr.error(`连接失败: ${result.error}`);
|
||
}
|
||
}
|
||
|
||
export async function onTestMemoryLLMController(runtime) {
|
||
runtime.toastr.info("正在测试记忆 LLM 连通性...");
|
||
const result = await runtime.testLLMConnection();
|
||
|
||
if (result.success) {
|
||
runtime.toastr.success(`连接成功！模式: ${result.mode}`);
|
||
} else {
|
||
runtime.toastr.error(`连接失败: ${result.error}`);
|
||
}
|
||
}
|
||
|
||
export async function onFetchMemoryLLMModelsController(runtime) {
|
||
runtime.toastr.info("正在拉取记忆 LLM 模型列表...");
|
||
const result = await runtime.fetchMemoryLLMModels();
|
||
|
||
if (result.success) {
|
||
runtime.toastr.success(`已拉取 ${result.models.length} 个记忆 LLM 模型`);
|
||
} else {
|
||
runtime.toastr.error(`拉取失败: ${result.error}`);
|
||
}
|
||
|
||
return result;
|
||
}
|
||
|
||
export async function onFetchEmbeddingModelsController(runtime, mode = null) {
|
||
const config = runtime.getEmbeddingConfig(mode);
|
||
const targetMode = mode || config?.mode || "direct";
|
||
const validation = runtime.validateVectorConfig(config);
|
||
if (!validation.valid) {
|
||
runtime.toastr.warning(validation.error);
|
||
return { success: false, models: [], error: validation.error };
|
||
}
|
||
|
||
runtime.toastr.info("正在拉取 Embedding 模型列表...");
|
||
const result = await runtime.fetchAvailableEmbeddingModels(config);
|
||
|
||
if (result.success) {
|
||
const modeLabel = targetMode === "backend" ? "后端" : "直连";
|
||
runtime.toastr.success(
|
||
`已拉取 ${result.models.length} 个${modeLabel} Embedding 模型`,
|
||
);
|
||
} else {
|
||
runtime.toastr.error(`拉取失败: ${result.error}`);
|
||
}
|
||
|
||
return result;
|
||
}
|
||
|
||
export async function onManualCompressController(runtime) {
|
||
const graph = runtime.getCurrentGraph();
|
||
if (!graph) return;
|
||
if (!runtime.ensureGraphMutationReady("手动压缩")) return;
|
||
|
||
const beforeSnapshot = runtime.cloneGraphSnapshot(graph);
|
||
const result = await runtime.compressAll(
|
||
graph,
|
||
runtime.getSchema(),
|
||
runtime.getEmbeddingConfig(),
|
||
false,
|
||
undefined,
|
||
undefined,
|
||
runtime.getSettings(),
|
||
);
|
||
await runtime.recordGraphMutation({
|
||
beforeSnapshot,
|
||
artifactTags: ["compression"],
|
||
});
|
||
|
||
runtime.toastr.info(`压缩完成: 新建 ${result.created}, 归档 ${result.archived}`);
|
||
}
|
||
|
||
export async function onExportGraphController(runtime) {
|
||
const graph = runtime.getCurrentGraph();
|
||
if (!graph) return;
|
||
|
||
const json = runtime.exportGraph(graph);
|
||
const blob = new Blob([json], { type: "application/json" });
|
||
const url = URL.createObjectURL(blob);
|
||
const a = runtime.document.createElement("a");
|
||
a.href = url;
|
||
a.download = `st-bme-graph-${Date.now()}.json`;
|
||
a.click();
|
||
URL.revokeObjectURL(url);
|
||
|
||
runtime.toastr.success("图谱已导出");
|
||
}
|
||
|
||
export async function onViewLastInjectionController(runtime) {
|
||
const content = runtime.getLastInjectionContent();
|
||
if (!content) {
|
||
runtime.toastr.info("暂无注入内容");
|
||
return;
|
||
}
|
||
|
||
const popup = runtime.document.createElement("div");
|
||
popup.style.cssText =
|
||
"position:fixed;top:50%;left:50%;transform:translate(-50%,-50%);background:#1a1a2e;color:#eee;padding:24px;border-radius:12px;max-width:80vw;max-height:80vh;overflow:auto;z-index:99999;white-space:pre-wrap;font-size:13px;box-shadow:0 8px 32px rgba(0,0,0,0.5);";
|
||
popup.textContent = content;
|
||
|
||
const close = runtime.document.createElement("button");
|
||
close.textContent = "关闭";
|
||
close.style.cssText =
|
||
"position:absolute;top:8px;right:12px;background:#e94560;color:white;border:none;padding:4px 12px;border-radius:4px;cursor:pointer;";
|
||
close.onclick = () => popup.remove();
|
||
popup.appendChild(close);
|
||
|
||
runtime.document.body.appendChild(popup);
|
||
}
|
||
|
||
export async function onRebuildController(runtime) {
|
||
if (!runtime.confirm("确定要从当前聊天重建图谱？这将清除现有图谱数据。")) {
|
||
return;
|
||
}
|
||
if (!runtime.ensureGraphMutationReady("重建图谱")) return;
|
||
|
||
const context = runtime.getContext();
|
||
const chat = context?.chat;
|
||
if (!Array.isArray(chat)) {
|
||
runtime.toastr.warning("当前聊天上下文不可用，无法重建");
|
||
return;
|
||
}
|
||
|
||
const previousGraphSnapshot = runtime.getCurrentGraph()
|
||
? runtime.cloneGraphSnapshot(runtime.getCurrentGraph())
|
||
: runtime.cloneGraphSnapshot(
|
||
runtime.normalizeGraphRuntimeState(
|
||
runtime.createEmptyGraph(),
|
||
runtime.getCurrentChatId(),
|
||
),
|
||
);
|
||
const previousUiState = runtime.snapshotRuntimeUiState();
|
||
const settings = runtime.getSettings();
|
||
runtime.setRuntimeStatus(
|
||
"图谱重建中",
|
||
`当前聊天 ${Array.isArray(chat) ? chat.length : 0} 条消息`,
|
||
"running",
|
||
);
|
||
|
||
const nextGraph = runtime.normalizeGraphRuntimeState(
|
||
runtime.createEmptyGraph(),
|
||
runtime.getCurrentChatId(),
|
||
);
|
||
nextGraph.batchJournal = [];
|
||
runtime.setCurrentGraph(nextGraph);
|
||
runtime.clearInjectionState();
|
||
|
||
try {
|
||
await runtime.prepareVectorStateForReplay(true);
|
||
const replayedBatches = await runtime.replayExtractionFromHistory(chat, settings);
|
||
runtime.clearHistoryDirty(
|
||
runtime.getCurrentGraph(),
|
||
runtime.buildRecoveryResult("full-rebuild", {
|
||
fromFloor: 0,
|
||
batches: replayedBatches,
|
||
path: "full-rebuild",
|
||
detectionSource: "manual-rebuild",
|
||
affectedBatchCount: runtime.getCurrentGraph().batchJournal?.length || 0,
|
||
replayedBatchCount: replayedBatches,
|
||
reason: "用户手动触发全量重建",
|
||
}),
|
||
);
|
||
runtime.saveGraphToChat({ reason: "manual-rebuild-complete" });
|
||
runtime.setLastExtractionStatus(
|
||
"图谱重建完成",
|
||
`已回放 ${replayedBatches} 批提取`,
|
||
"success",
|
||
{
|
||
syncRuntime: false,
|
||
},
|
||
);
|
||
|
||
if (runtime.getCurrentGraph().vectorIndexState?.lastWarning) {
|
||
runtime.setRuntimeStatus(
|
||
"图谱重建完成",
|
||
`已回放 ${replayedBatches} 批，但向量仍待修复`,
|
||
"warning",
|
||
);
|
||
runtime.toastr.warning(
|
||
`图谱已重建，但向量索引仍待修复: ${runtime.getCurrentGraph().vectorIndexState.lastWarning}`,
|
||
);
|
||
} else {
|
||
runtime.setRuntimeStatus(
|
||
"图谱重建完成",
|
||
`已回放 ${replayedBatches} 批，图谱与向量索引已刷新`,
|
||
"success",
|
||
);
|
||
runtime.toastr.success("图谱与向量索引已按当前聊天全量重建");
|
||
}
|
||
} catch (error) {
|
||
runtime.setCurrentGraph(
|
||
runtime.normalizeGraphRuntimeState(
|
||
previousGraphSnapshot,
|
||
runtime.getCurrentChatId(),
|
||
),
|
||
);
|
||
runtime.restoreRuntimeUiState(previousUiState);
|
||
runtime.saveGraphToChat({ reason: "manual-rebuild-restore-previous" });
|
||
runtime.setLastExtractionStatus("图谱重建失败", error?.message || String(error), "error", {
|
||
syncRuntime: true,
|
||
});
|
||
throw new Error(
|
||
`图谱重建失败，已恢复到重建前状态: ${error?.message || error}`,
|
||
);
|
||
} finally {
|
||
runtime.refreshPanelLiveState();
|
||
}
|
||
}
|
||
|
||
export async function onImportGraphController(runtime) {
|
||
if (!runtime.ensureGraphMutationReady("导入图谱")) {
|
||
return { cancelled: true };
|
||
}
|
||
|
||
const input = runtime.document.createElement("input");
|
||
input.type = "file";
|
||
input.accept = ".json";
|
||
|
||
return await new Promise((resolve, reject) => {
|
||
let settled = false;
|
||
let focusTimer = null;
|
||
|
||
const cleanup = () => {
|
||
if (focusTimer) {
|
||
runtime.clearTimeout(focusTimer);
|
||
focusTimer = null;
|
||
}
|
||
input.onchange = null;
|
||
runtime.window.removeEventListener("focus", onWindowFocus, true);
|
||
};
|
||
|
||
const finish = (value, isError = false) => {
|
||
if (settled) return;
|
||
settled = true;
|
||
cleanup();
|
||
if (isError) {
|
||
reject(value);
|
||
} else {
|
||
resolve(value);
|
||
}
|
||
};
|
||
|
||
const onWindowFocus = () => {
|
||
focusTimer = setTimeout(() => {
|
||
if (!settled) {
|
||
finish({ cancelled: true });
|
||
}
|
||
}, 180);
|
||
};
|
||
|
||
runtime.window.addEventListener("focus", onWindowFocus, true);
|
||
input.addEventListener(
|
||
"cancel",
|
||
() => {
|
||
finish({ cancelled: true });
|
||
},
|
||
{ once: true },
|
||
);
|
||
|
||
input.onchange = async (event) => {
|
||
const file = event.target.files?.[0];
|
||
if (!file) {
|
||
finish({ cancelled: true });
|
||
return;
|
||
}
|
||
|
||
try {
|
||
const text = await file.text();
|
||
const importedGraph = runtime.normalizeGraphRuntimeState(
|
||
runtime.importGraph(text),
|
||
runtime.getCurrentChatId(),
|
||
);
|
||
runtime.setCurrentGraph(importedGraph);
|
||
runtime.markVectorStateDirty("导入图谱后需要重建向量索引");
|
||
runtime.setExtractionCount(0);
|
||
runtime.setLastExtractedItems([]);
|
||
runtime.updateLastRecalledItems(importedGraph.lastRecallResult || []);
|
||
runtime.clearInjectionState();
|
||
runtime.saveGraphToChat({ reason: "graph-import-complete" });
|
||
runtime.toastr.success("图谱已导入");
|
||
finish({ imported: true, handledToast: true });
|
||
} catch (err) {
|
||
const error =
|
||
err instanceof Error ? err : new Error(String(err || "导入失败"));
|
||
runtime.toastr.error(`导入失败: ${error.message}`);
|
||
error._stBmeToastHandled = true;
|
||
finish(error, true);
|
||
}
|
||
};
|
||
|
||
input.click();
|
||
});
|
||
}
|
||
|
||
export async function onRebuildVectorIndexController(runtime, range = null) {
|
||
if (!runtime.ensureGraphMutationReady(range ? "范围重建向量" : "重建向量")) return;
|
||
runtime.ensureCurrentGraphRuntimeState();
|
||
|
||
const config = runtime.getEmbeddingConfig();
|
||
const validation = runtime.validateVectorConfig(config);
|
||
if (!validation.valid) {
|
||
runtime.toastr.warning(validation.error);
|
||
return;
|
||
}
|
||
|
||
const vectorController = runtime.beginStageAbortController("vector");
|
||
try {
|
||
const result = await runtime.syncVectorState({
|
||
force: true,
|
||
purge: runtime.isBackendVectorConfig(config) && !range,
|
||
range,
|
||
signal: vectorController.signal,
|
||
});
|
||
|
||
runtime.saveGraphToChat({ reason: "vector-rebuild-complete" });
|
||
if (result?.aborted) {
|
||
return;
|
||
}
|
||
if (result?.error) {
|
||
throw new Error(result.error);
|
||
}
|
||
runtime.toastr.success(
|
||
range
|
||
? `范围向量重建完成：indexed=${result.stats.indexed}, pending=${result.stats.pending}`
|
||
: `当前聊天向量重建完成：indexed=${result.stats.indexed}, pending=${result.stats.pending}`,
|
||
);
|
||
} finally {
|
||
runtime.finishStageAbortController("vector", vectorController);
|
||
runtime.refreshPanelLiveState();
|
||
}
|
||
}
|
||
|
||
export async function onReembedDirectController(runtime) {
|
||
const config = runtime.getEmbeddingConfig();
|
||
if (!runtime.isDirectVectorConfig(config)) {
|
||
runtime.toastr.info("当前不是直连模式，无需执行重嵌");
|
||
return;
|
||
}
|
||
|
||
await runtime.onRebuildVectorIndex();
|
||
}
|