feat: integrate WeKnora llmwiki knowledge flow

frontend-web/src/core/agents/types.ts

@@ -61,7 +61,9 @@ export interface Agent {
   /** 会商席位「技能识别强化」开关。作为会商席位运行时，是否把本智能体配置的技能
    * (名称 + SKILL.md 路径 + 必须先 read_file 的硬指令) 拼进本轮任务以补偿弱模型。
    * 与业务链条同名开关取 OR。null/false = 关 (默认)。 */
-  seat_skill_directive?: boolean | null;
+  seat_skill_directive?: boolean | null;
+  /** DeerFlow LLMWiki mapping ids this agent allows conversations to select. */
+  llmwiki_knowledge_base_ids?: string[] | null;
   tags?: Tag[];
   featured_order?: number | null;
   /** Whether the current user has favorited (收藏) this agent. */
@@ -96,7 +98,8 @@ export interface CreateAgentRequest {
   common_questions?: AgentQuestion[] | null;
   template_name?: string | null;
   /** 会商席位「技能识别强化」开关；缺省/false = 关。 */
-  seat_skill_directive?: boolean | null;
+  seat_skill_directive?: boolean | null;
+  llmwiki_knowledge_base_ids?: string[] | null;
 }
 
 export interface UpdateAgentRequest {
@@ -113,5 +116,6 @@ export interface UpdateAgentRequest {
   /** 入库模板名；传空字符串表示清除。 */
   template_name?: string | null;
   /** 会商席位「技能识别强化」开关；缺省/false = 关。 */
-  seat_skill_directive?: boolean | null;
-}
+  seat_skill_directive?: boolean | null;
+  llmwiki_knowledge_base_ids?: string[] | null;
+}

frontend-web/src/core/llmwiki/conversation-deposit.ts

@@ -0,0 +1,66 @@
+import type { Message } from "@langchain/langgraph-sdk";
+
+import { textOfMessage } from "@/core/threads/utils";
+import { createLlmWikiConversationDeposit } from "@/strategy-components/api/llmwiki";
+
+function isHidden(message: Message): boolean {
+  const extra = (message as { additional_kwargs?: Record<string, unknown> })
+    .additional_kwargs;
+  return extra?.hide_from_ui === true;
+}
+
+function messageText(message: Message | undefined): string {
+  return (message ? textOfMessage(message) : "")?.trim() ?? "";
+}
+
+function hasText(message: Message | undefined): message is Message {
+  return !!message && messageText(message).length > 0;
+}
+
+export function queueLlmWikiConversationDeposit({
+  threadId,
+  messages,
+  assistantId,
+  knowledgeBaseIds,
+}: {
+  threadId: string | null | undefined;
+  messages: Message[] | undefined;
+  assistantId?: string | null;
+  knowledgeBaseIds?: string[];
+}) {
+  if (!threadId || !messages?.length) {
+    return;
+  }
+  const visible = messages.filter((message) => !isHidden(message));
+  const assistantIndex = [...visible]
+    .map((message, index) => ({ message, index }))
+    .reverse()
+    .find(({ message }) => message.type === "ai" && hasText(message))?.index;
+  if (assistantIndex === undefined) {
+    return;
+  }
+  const assistantMessage = visible[assistantIndex];
+  const humanMessage = [...visible.slice(0, assistantIndex)]
+    .reverse()
+    .find((message) => message.type === "human" && hasText(message));
+  if (!assistantMessage?.id || !humanMessage) {
+    return;
+  }
+  const question = messageText(humanMessage);
+  const answer = messageText(assistantMessage);
+  if (!question || !answer) {
+    return;
+  }
+
+  void createLlmWikiConversationDeposit({
+    thread_id: threadId,
+    question,
+    answer,
+    human_message_id: humanMessage.id ?? null,
+    assistant_message_id: assistantMessage.id,
+    assistant_id: assistantId ?? null,
+    knowledge_base_ids: knowledgeBaseIds ?? [],
+  }).catch((error) => {
+    console.warn("Failed to queue LLMWiki conversation deposit", error);
+  });
+}

frontend-web/src/core/threads/hooks.ts

@@ -1122,20 +1122,26 @@ export function useThreadStream({
           }),
         );
 
-        const ragModeEnabled =
-          localSettings.display.ragModeEnabled || isThreadRagModeLocked(threadId);
-        if (ragModeEnabled) {
-          lockThreadRagMode(threadId);
-        }
+        const mergedContext = {
+          ...context,
+          ...extraContext,
+        };
+        const selectedLlmWikiIds = Array.isArray(
+          mergedContext.llmwiki_knowledge_base_ids,
+        )
+          ? mergedContext.llmwiki_knowledge_base_ids
+          : [];
+        const ragModeEnabled =
+          localSettings.display.ragModeEnabled ||
+          isThreadRagModeLocked(threadId) ||
+          selectedLlmWikiIds.length > 0;
+        if (ragModeEnabled) {
+          lockThreadRagMode(threadId);
+        }
 
         const contextCompressionEnabled =
           localSettings.display.contextCompressionEnabled ?? false;
 
-        const mergedContext = {
-          ...context,
-          ...extraContext,
-        };
-
         const hiddenContextMessages = normalizeHiddenContextMessages(options);
         const submittedMessages: Message[] = [
           ...hiddenContextMessages.map((item) => ({

frontend-web/src/core/threads/types.ts

@@ -24,7 +24,9 @@ export interface AgentThreadContext extends Record<string, unknown> {
   /** Per-request switch for context compression (上下文压缩). Default off. */
   summarization_enabled?: boolean;
   /** Per-conversation switch for knowledge-base RAG injection (phase 2). */
-  knowledge_rag_enabled?: boolean;
+  knowledge_rag_enabled?: boolean;
+  /** DeerFlow LLMWiki mapping ids selected for this conversation. */
+  llmwiki_knowledge_base_ids?: string[];
   agent_id?: string;
   /** @deprecated kept for reading legacy thread metadata; prefer agent_id */
   agent_name?: string;