From 1db6ea33a105caffeef7f461612323882d4d038b Mon Sep 17 00:00:00 2001
From: Cursor Agent <cursoragent@cursor.com>
Date: Mon, 1 Jun 2026 07:59:03 +0000
Subject: [PATCH 1/4] feat(topic-feed): wizard create/edit, input labels, and
 preview

Replace the topic feed create/edit modal with a multi-step wizard page.
Add per-input description fields persisted via inputs[] on the API.
Extract FeedPreviewPanel for reuse when previewing sub-feeds in the editor.

Co-authored-by: Colin <Colin_XKL@outlook.com>
---
 .gitignore                                    |   1 +
 internal/controller/topic_feed.go             |  14 +
 internal/dao/topic.go                         |  61 +-
 internal/dao/topic_test.go                    |  42 +
 web/admin/src/api/topic.ts                    |   6 +
 .../feed-preview/FeedPreviewPanel.vue         | 101 +++
 web/admin/src/locale/en-US/topic.ts           |  21 +
 web/admin/src/locale/zh-CN/topic.ts           |  18 +
 .../src/router/routes/modules/worktable.ts    |  20 +
 .../components/TopicAggregatorEditor.vue      | 227 ++++++
 .../components/TopicInputSourcesEditor.vue    | 284 +++++++
 .../src/views/dashboard/topic_feed/detail.vue |  16 +-
 .../src/views/dashboard/topic_feed/editor.vue | 404 ++++++++++
 .../dashboard/topic_feed/topicInputUtils.ts   | 213 +++++
 .../views/dashboard/topic_feed/topic_feed.vue | 728 +-----------------
 15 files changed, 1439 insertions(+), 717 deletions(-)
 create mode 100644 internal/dao/topic_test.go
 create mode 100644 web/admin/src/components/feed-preview/FeedPreviewPanel.vue
 create mode 100644 web/admin/src/views/dashboard/topic_feed/components/TopicAggregatorEditor.vue
 create mode 100644 web/admin/src/views/dashboard/topic_feed/components/TopicInputSourcesEditor.vue
 create mode 100644 web/admin/src/views/dashboard/topic_feed/editor.vue
 create mode 100644 web/admin/src/views/dashboard/topic_feed/topicInputUtils.ts

diff --git a/.gitignore b/.gitignore
index 44e74a47..093539ac 100644
--- a/.gitignore
+++ b/.gitignore
@@ -152,3 +152,4 @@ db/
 start.sh
 start-full.sh
 .claude/
+.dev-data/
diff --git a/internal/controller/topic_feed.go b/internal/controller/topic_feed.go
index 8e2a6e56..f9fbe679 100644
--- a/internal/controller/topic_feed.go
+++ b/internal/controller/topic_feed.go
@@ -66,12 +66,14 @@ func CreateTopicFeed(c *gin.Context) {
 		c.JSON(http.StatusBadRequest, util.APIResponse[any]{Msg: err.Error()})
 		return
 	}
+	topicData.NormalizeInputs()
 	db := util.GetDatabase()
 
 	if err := dao.CreateTopicFeed(db, &topicData); err != nil {
 		c.JSON(http.StatusInternalServerError, util.APIResponse[any]{Msg: err.Error()})
 		return
 	}
+	topicData.NormalizeInputs()
 
 	c.JSON(http.StatusCreated, util.APIResponse[any]{Data: topicData})
 }
@@ -89,6 +91,7 @@ func GetTopicFeed(c *gin.Context) {
 		c.JSON(http.StatusInternalServerError, util.APIResponse[any]{Msg: err.Error()})
 		return
 	}
+	topicData.NormalizeInputs()
 
 	c.JSON(http.StatusOK, util.APIResponse[any]{Data: topicData})
 }
@@ -101,6 +104,10 @@ func ListTopicFeeds(c *gin.Context) {
 		return
 	}
 
+	for _, topic := range topicList {
+		topic.NormalizeInputs()
+	}
+
 	c.JSON(http.StatusOK, util.APIResponse[any]{Data: topicList})
 }
 
@@ -116,6 +123,7 @@ func UpdateTopicFeed(c *gin.Context) {
 	if id != topicData.ID {
 		topicData.ID = id
 	}
+	topicData.NormalizeInputs()
 
 	db := util.GetDatabase()
 
@@ -133,6 +141,7 @@ func UpdateTopicFeed(c *gin.Context) {
 		c.JSON(http.StatusInternalServerError, util.APIResponse[any]{Msg: err.Error()})
 		return
 	}
+	topicData.NormalizeInputs()
 
 	c.JSON(http.StatusOK, util.APIResponse[any]{Data: topicData})
 }
@@ -159,6 +168,7 @@ func ValidateTopicFeed(c *gin.Context) {
 		c.JSON(http.StatusBadRequest, util.APIResponse[any]{Msg: err.Error()})
 		return
 	}
+	topicData.NormalizeInputs()
 
 	result, err := validateTopicConfig(c.Request.Context(), util.GetDatabase(), &topicData)
 	if err != nil {
@@ -182,6 +192,7 @@ func GetTopicFeedDetail(c *gin.Context) {
 		c.JSON(http.StatusInternalServerError, util.APIResponse[any]{Msg: err.Error()})
 		return
 	}
+	topicData.NormalizeInputs()
 
 	health, err := dao.GetResourceHealth(db, dao.ResourceTypeTopic, id)
 	if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) {
@@ -273,6 +284,9 @@ func validateTopicConfig(ctx context.Context, db *gorm.DB, topicData *dao.TopicF
 		Errors:   []TopicValidationIssue{},
 		Warnings: []TopicValidationIssue{},
 	}
+	if topicData != nil {
+		topicData.NormalizeInputs()
+	}
 	if topicData == nil {
 		result.Valid = false
 		result.Errors = append(result.Errors, TopicValidationIssue{
diff --git a/internal/dao/topic.go b/internal/dao/topic.go
index 7d692a1f..39c1c964 100644
--- a/internal/dao/topic.go
+++ b/internal/dao/topic.go
@@ -1,9 +1,17 @@
 package dao
 
 import (
+	"strings"
+
 	"gorm.io/gorm"
 )
 
+// TopicInput is a single upstream source with an optional admin label.
+type TopicInput struct {
+	URI         string `json:"uri"`
+	Description string `json:"description,omitempty"`
+}
+
 // TopicFeed represents the persistence model for a multi-source aggregation node.
 type TopicFeed struct {
 	BaseModelWithoutPK
@@ -11,18 +19,67 @@ type TopicFeed struct {
 	Title       string `json:"title,omitempty"`
 	Description string `json:"description,omitempty"`
 
-	// List of URIs representing inputs.
+	// Inputs carries URI plus optional description for admin display.
+	Inputs []TopicInput `json:"inputs,omitempty" gorm:"serializer:json"`
+
+	// List of URIs representing inputs (derived from Inputs for runtime).
 	// Uses a custom protocol for internal resources to make routing elegant and standard.
 	// Examples:
 	//   - "feedcraft://recipe/my-tech-recipe" (Internal RecipeFeed)
 	//   - "feedcraft://topic/sub-topic-id"    (Nested internal TopicFeed)
 	//   - "https://external.com/rss.xml"      (External raw feed)
-	InputURIs []string `json:"input_uris" binding:"required" gorm:"serializer:json"`
+	InputURIs []string `json:"input_uris" gorm:"serializer:json"`
 
 	// Configuration for the aggregator pipeline
 	AggregatorConfig []AggregatorStep `json:"aggregator_config" gorm:"serializer:json"`
 }
 
+// NormalizeInputs keeps Inputs and InputURIs in sync.
+// When Inputs is provided it becomes the source of truth; otherwise legacy InputURIs are upgraded.
+func (t *TopicFeed) NormalizeInputs() {
+	if t == nil {
+		return
+	}
+
+	if len(t.Inputs) > 0 {
+		uris := make([]string, 0, len(t.Inputs))
+		normalized := make([]TopicInput, 0, len(t.Inputs))
+		for _, item := range t.Inputs {
+			uri := strings.TrimSpace(item.URI)
+			if uri == "" {
+				continue
+			}
+			uris = append(uris, uri)
+			normalized = append(normalized, TopicInput{
+				URI:         uri,
+				Description: strings.TrimSpace(item.Description),
+			})
+		}
+		t.InputURIs = uris
+		t.Inputs = normalized
+		return
+	}
+
+	if len(t.InputURIs) == 0 {
+		t.Inputs = nil
+		return
+	}
+
+	inputs := make([]TopicInput, 0, len(t.InputURIs))
+	for _, uri := range t.InputURIs {
+		uri = strings.TrimSpace(uri)
+		if uri == "" {
+			continue
+		}
+		inputs = append(inputs, TopicInput{URI: uri})
+	}
+	t.Inputs = inputs
+	t.InputURIs = make([]string, 0, len(inputs))
+	for _, item := range inputs {
+		t.InputURIs = append(t.InputURIs, item.URI)
+	}
+}
+
 // AggregatorStep defines a single processing step in an Aggregator pipeline.
 type AggregatorStep struct {
 	Type   string            `json:"type" binding:"required"` // e.g., "deduplicate", "sort", "limit"
diff --git a/internal/dao/topic_test.go b/internal/dao/topic_test.go
new file mode 100644
index 00000000..a932031c
--- /dev/null
+++ b/internal/dao/topic_test.go
@@ -0,0 +1,42 @@
+package dao
+
+import "testing"
+
+func TestTopicFeed_NormalizeInputs_FromInputs(t *testing.T) {
+	topic := &TopicFeed{
+		Inputs: []TopicInput{
+			{URI: "https://example.com/a.xml", Description: "Tech news"},
+			{URI: " feedcraft://recipe/foo ", Description: ""},
+		},
+	}
+
+	topic.NormalizeInputs()
+
+	if len(topic.InputURIs) != 2 {
+		t.Fatalf("expected 2 input URIs, got %d", len(topic.InputURIs))
+	}
+	if topic.InputURIs[0] != "https://example.com/a.xml" {
+		t.Fatalf("unexpected first URI: %q", topic.InputURIs[0])
+	}
+	if topic.InputURIs[1] != "feedcraft://recipe/foo" {
+		t.Fatalf("unexpected second URI: %q", topic.InputURIs[1])
+	}
+	if topic.Inputs[0].Description != "Tech news" {
+		t.Fatalf("unexpected description: %q", topic.Inputs[0].Description)
+	}
+}
+
+func TestTopicFeed_NormalizeInputs_FromLegacyURIs(t *testing.T) {
+	topic := &TopicFeed{
+		InputURIs: []string{"https://example.com/a.xml", "https://example.com/b.xml"},
+	}
+
+	topic.NormalizeInputs()
+
+	if len(topic.Inputs) != 2 {
+		t.Fatalf("expected 2 inputs, got %d", len(topic.Inputs))
+	}
+	if topic.Inputs[0].URI != "https://example.com/a.xml" {
+		t.Fatalf("unexpected first input URI: %q", topic.Inputs[0].URI)
+	}
+}
diff --git a/web/admin/src/api/topic.ts b/web/admin/src/api/topic.ts
index 9f9a996c..23fe6560 100644
--- a/web/admin/src/api/topic.ts
+++ b/web/admin/src/api/topic.ts
@@ -11,10 +11,16 @@ export interface AggregatorStep {
   option: Record<string, string>;
 }
 
+export interface TopicInput {
+  uri: string;
+  description?: string;
+}
+
 export interface TopicFeed {
   id: string;
   title?: string;
   description?: string;
+  inputs?: TopicInput[];
   input_uris: string[];
   aggregator_config: AggregatorStep[];
 }
diff --git a/web/admin/src/components/feed-preview/FeedPreviewPanel.vue b/web/admin/src/components/feed-preview/FeedPreviewPanel.vue
new file mode 100644
index 00000000..f5c7ab0f
--- /dev/null
+++ b/web/admin/src/components/feed-preview/FeedPreviewPanel.vue
@@ -0,0 +1,101 @@
+<template>
+  <div class="feed-preview-panel">
+    <a-spin :loading="loading" style="width: 100%">
+      <a-alert v-if="errorMessage" type="error" class="mb-4" show-icon>
+        {{ errorMessage }}
+      </a-alert>
+      <FeedViewContainer v-if="feedContent" :feed-data="feedContent" />
+      <a-empty
+        v-else-if="!loading && !errorMessage"
+        :description="emptyDescription || t('feedViewer.resultPreview')"
+      />
+    </a-spin>
+  </div>
+</template>
+
+<script lang="ts" setup>
+  import { ref, watch } from 'vue';
+  import { useI18n } from 'vue-i18n';
+  import { previewFeed, type FeedViewerPreview } from '@/api/feed_viewer';
+  import FeedViewContainer from '@/views/dashboard/feed_viewer/feed_view_container.vue';
+
+  const props = withDefaults(
+    defineProps<{
+      inputUri?: string;
+      autoLoad?: boolean;
+      emptyDescription?: string;
+    }>(),
+    {
+      inputUri: '',
+      autoLoad: false,
+      emptyDescription: '',
+    }
+  );
+
+  const { t } = useI18n();
+  const loading = ref(false);
+  const errorMessage = ref('');
+  const feedContent = ref<FeedViewerPreview | null>(null);
+  let requestSeq = 0;
+
+  const resetState = () => {
+    requestSeq += 1;
+    feedContent.value = null;
+    errorMessage.value = '';
+  };
+
+  const loadPreview = async (inputUri = props.inputUri) => {
+    const uri = inputUri?.trim();
+    if (!uri) {
+      resetState();
+      return;
+    }
+
+    const currentSeq = requestSeq + 1;
+    requestSeq = currentSeq;
+    loading.value = true;
+    errorMessage.value = '';
+
+    try {
+      const response = await previewFeed(uri);
+      if (currentSeq !== requestSeq) return;
+      feedContent.value = response.data ?? null;
+      if (!feedContent.value) {
+        errorMessage.value = response.msg || t('topic.inputPreview.failed');
+      }
+    } catch (err: any) {
+      if (currentSeq !== requestSeq) return;
+      feedContent.value = null;
+      errorMessage.value = err.message || t('topic.inputPreview.failed');
+    } finally {
+      if (currentSeq === requestSeq) {
+        loading.value = false;
+      }
+    }
+  };
+
+  watch(
+    () => props.inputUri,
+    (uri) => {
+      if (!props.autoLoad) {
+        resetState();
+        return;
+      }
+      loadPreview(uri);
+    }
+  );
+
+  defineExpose({
+    loadPreview,
+    resetState,
+    loading,
+    feedContent,
+    errorMessage,
+  });
+</script>
+
+<script lang="ts">
+  export default {
+    name: 'FeedPreviewPanel',
+  };
+</script>
diff --git a/web/admin/src/locale/en-US/topic.ts b/web/admin/src/locale/en-US/topic.ts
index ce33d598..9290ab90 100644
--- a/web/admin/src/locale/en-US/topic.ts
+++ b/web/admin/src/locale/en-US/topic.ts
@@ -39,6 +39,27 @@ export default {
     'For External RSS, enter an http/https URL. For Recipe or Topic, pick from the dropdown to use internal FeedCraft resources.',
   'topic.inputPlaceholder': 'For example: feedcraft://recipe/my-recipe',
   'topic.addInput': 'Add Input',
+  'topic.inputDescription.placeholder':
+    'Label for this input (optional, helps you recognize it later)',
+  'topic.inputPreview': 'Preview',
+  'topic.inputPreview.title': 'Input #{index}',
+  'topic.inputPreview.currentUri': 'Preview URI',
+  'topic.inputPreview.empty':
+    'Click Preview to load feed content for this input',
+  'topic.inputPreview.failed': 'Preview failed',
+  'topic.wizard.description':
+    'Configure topic basics, input sources, and aggregation rules step by step.',
+  'topic.wizard.step.basic': 'Basics',
+  'topic.wizard.step.basic.desc': 'ID, title, and description',
+  'topic.wizard.step.inputs': 'Inputs',
+  'topic.wizard.step.inputs.desc': 'Add sub-feeds and preview when needed',
+  'topic.wizard.step.aggregator': 'Aggregation',
+  'topic.wizard.step.aggregator.desc': 'Deduplicate, sort, and limit items',
+  'topic.wizard.step.review': 'Review & Save',
+  'topic.wizard.step.review.desc': 'Validate and submit',
+  'topic.wizard.prev': 'Previous',
+  'topic.wizard.next': 'Next',
+  'topic.wizard.inputsRequired': 'Add at least one valid input source',
   'topic.removeInput': 'Remove',
   'topic.removeStep': 'Remove Rule',
   'topic.sectionInputs': 'Input Sources',
diff --git a/web/admin/src/locale/zh-CN/topic.ts b/web/admin/src/locale/zh-CN/topic.ts
index 094cb07a..4c6fd8d6 100644
--- a/web/admin/src/locale/zh-CN/topic.ts
+++ b/web/admin/src/locale/zh-CN/topic.ts
@@ -38,6 +38,24 @@ export default {
     '外部 RSS 直接填入 http/https 地址；选择 Recipe 或 Topic 可从下拉列表中选取 FeedCraft 内部资源。',
   'topic.inputPlaceholder': '例如 feedcraft://recipe/my-recipe',
   'topic.addInput': '添加输入源',
+  'topic.inputDescription.placeholder': '备注名称，便于识别此输入源（可选）',
+  'topic.inputPreview': '预览',
+  'topic.inputPreview.title': '输入源 #{index}',
+  'topic.inputPreview.currentUri': '当前预览地址',
+  'topic.inputPreview.empty': '点击「预览」查看该输入源的 Feed 内容',
+  'topic.inputPreview.failed': '预览失败',
+  'topic.wizard.description': '按步骤配置主题基本信息、输入源与聚合规则。',
+  'topic.wizard.step.basic': '基本信息',
+  'topic.wizard.step.basic.desc': '设置 ID、标题与描述',
+  'topic.wizard.step.inputs': '输入源',
+  'topic.wizard.step.inputs.desc': '添加子 Feed 并可选预览',
+  'topic.wizard.step.aggregator': '聚合规则',
+  'topic.wizard.step.aggregator.desc': '去重、排序与数量限制',
+  'topic.wizard.step.review': '确认保存',
+  'topic.wizard.step.review.desc': '校验配置并提交',
+  'topic.wizard.prev': '上一步',
+  'topic.wizard.next': '下一步',
+  'topic.wizard.inputsRequired': '请至少添加一个有效的输入源',
   'topic.removeInput': '移除',
   'topic.removeStep': '移除规则',
   'topic.sectionInputs': '输入源',
diff --git a/web/admin/src/router/routes/modules/worktable.ts b/web/admin/src/router/routes/modules/worktable.ts
index 5f7a8c00..d5190d74 100644
--- a/web/admin/src/router/routes/modules/worktable.ts
+++ b/web/admin/src/router/routes/modules/worktable.ts
@@ -21,6 +21,26 @@ const WORKTABLE: AppRouteRecordRaw = {
         locale: 'menu.topicFeed',
       },
     },
+    {
+      path: 'topic_feed/create',
+      name: 'TopicFeedCreate',
+      component: () => import('@/views/dashboard/topic_feed/editor.vue'),
+      meta: {
+        requiresAuth: true,
+        locale: 'menu.topicFeed',
+        hideInMenu: true,
+      },
+    },
+    {
+      path: 'topic_feed/:id/edit',
+      name: 'TopicFeedEdit',
+      component: () => import('@/views/dashboard/topic_feed/editor.vue'),
+      meta: {
+        requiresAuth: true,
+        locale: 'menu.topicFeed',
+        hideInMenu: true,
+      },
+    },
     {
       path: 'topic_feed/:id',
       name: 'TopicFeedDetail',
diff --git a/web/admin/src/views/dashboard/topic_feed/components/TopicAggregatorEditor.vue b/web/admin/src/views/dashboard/topic_feed/components/TopicAggregatorEditor.vue
new file mode 100644
index 00000000..4d526f82
--- /dev/null
+++ b/web/admin/src/views/dashboard/topic_feed/components/TopicAggregatorEditor.vue
@@ -0,0 +1,227 @@
+<template>
+  <div class="steps-container">
+    <div
+      v-for="(step, idx) in modelValue"
+      :key="`step-${idx}`"
+      class="step-card"
+    >
+      <div class="editor-row">
+        <a-select
+          v-model="step.type"
+          style="width: 150px; flex-shrink: 0"
+          @change="resetStepValue(idx)"
+        >
+          <a-option value="deduplicate">
+            {{ t('topic.stepType.deduplicate') }}
+          </a-option>
+          <a-option value="sort">{{ t('topic.stepType.sort') }}</a-option>
+          <a-option value="limit">{{ t('topic.stepType.limit') }}</a-option>
+        </a-select>
+
+        <template v-if="step.type === 'deduplicate'">
+          <a-select
+            v-model="step.value"
+            style="width: 220px; flex-shrink: 0"
+            @change="onDeduplicateStrategyChange(idx)"
+          >
+            <a-option value="by_link">
+              {{ t('topic.stepOption.strategy.by_link') }}
+            </a-option>
+            <a-option value="by_id">
+              {{ t('topic.stepOption.strategy.by_id') }}
+            </a-option>
+            <a-option value="by_title">
+              {{ t('topic.stepOption.strategy.by_title') }}
+            </a-option>
+            <a-option value="by_simhash">
+              {{ t('topic.stepOption.strategy.by_simhash') }}
+            </a-option>
+            <a-option value="by_embedding">
+              {{ t('topic.stepOption.strategy.by_embedding') }}
+            </a-option>
+          </a-select>
+          <a-input-number
+            v-if="step.value === 'by_simhash'"
+            v-model="step.threshold"
+            :min="0"
+            :max="1"
+            :step="0.01"
+            :precision="2"
+            :placeholder="t('topic.stepOption.threshold.simhash')"
+            style="flex: 1; min-width: 120px"
+          />
+          <a-input-number
+            v-else-if="step.value === 'by_embedding'"
+            v-model="step.threshold"
+            :min="0"
+            :max="1"
+            :step="0.01"
+            :precision="2"
+            :placeholder="t('topic.stepOption.threshold.embedding')"
+            style="flex: 1; min-width: 120px"
+          />
+        </template>
+
+        <a-select
+          v-else-if="step.type === 'sort'"
+          v-model="step.value"
+          style="flex: 1; min-width: 150px"
+        >
+          <a-option value="date_desc">
+            {{ t('topic.stepOption.sort.date_desc') }}
+          </a-option>
+          <a-option value="date_asc">
+            {{ t('topic.stepOption.sort.date_asc') }}
+          </a-option>
+          <a-option value="quality_desc">
+            {{ t('topic.stepOption.sort.quality_desc') }}
+          </a-option>
+          <a-option value="quality_asc">
+            {{ t('topic.stepOption.sort.quality_asc') }}
+          </a-option>
+        </a-select>
+
+        <a-input-number
+          v-else
+          v-model="step.value"
+          :min="1"
+          mode="button"
+          style="flex: 1; min-width: 150px"
+        />
+
+        <a-button
+          type="text"
+          status="danger"
+          class="remove-btn"
+          @click="removeStep(idx)"
+        >
+          <template #icon>
+            <icon-delete />
+          </template>
+          {{ t('topic.removeStep') }}
+        </a-button>
+      </div>
+      <p
+        v-if="
+          step.type === 'deduplicate' &&
+          (step.value === 'by_simhash' || step.value === 'by_embedding')
+        "
+        class="step-hint"
+      >
+        {{ t(`topic.stepOption.strategy.${step.value}.hint`) }}
+      </p>
+    </div>
+
+    <a-button type="dashed" long class="add-btn" @click="addStep">
+      <template #icon>
+        <icon-plus />
+      </template>
+      {{ t('topic.addStep') }}
+    </a-button>
+  </div>
+</template>
+
+<script lang="ts" setup>
+  import { useI18n } from 'vue-i18n';
+  import {
+    type StepFormItem,
+    type StepType,
+    createDefaultStep,
+    defaultThreshold,
+  } from '../topicInputUtils';
+
+  const props = defineProps<{
+    modelValue: StepFormItem[];
+  }>();
+
+  const emit = defineEmits<{
+    (event: 'update:modelValue', value: StepFormItem[]): void;
+  }>();
+
+  const { t } = useI18n();
+
+  const updateSteps = (steps: StepFormItem[]) => {
+    emit('update:modelValue', steps);
+  };
+
+  const addStep = () => {
+    updateSteps([...props.modelValue, createDefaultStep()]);
+  };
+
+  const removeStep = (idx: number) => {
+    const next = [...props.modelValue];
+    next.splice(idx, 1);
+    updateSteps(next);
+  };
+
+  const resetStepValue = (idx: number) => {
+    const currentType = props.modelValue[idx].type as StepType;
+    const next = [...props.modelValue];
+    next[idx] = createDefaultStep(currentType);
+    updateSteps(next);
+  };
+
+  const onDeduplicateStrategyChange = (idx: number) => {
+    const next = [...props.modelValue];
+    const strategy = String(next[idx].value);
+    next[idx] = {
+      ...next[idx],
+      threshold: defaultThreshold(strategy),
+    };
+    updateSteps(next);
+  };
+</script>
+
+<script lang="ts">
+  export default {
+    name: 'TopicAggregatorEditor',
+  };
+</script>
+
+<style scoped>
+  .steps-container {
+    display: flex;
+    flex-direction: column;
+    gap: 12px;
+    width: 100%;
+  }
+
+  .step-card {
+    display: flex;
+    flex-direction: column;
+    gap: 8px;
+    background-color: var(--color-fill-1);
+    border: 1px solid var(--color-border-1);
+    border-radius: 6px;
+    padding: 12px 16px;
+    transition: all 0.2s ease;
+  }
+
+  .step-card:hover {
+    border-color: var(--color-border-3);
+    background-color: var(--color-fill-2);
+  }
+
+  .editor-row {
+    display: flex;
+    gap: 12px;
+    align-items: center;
+    width: 100%;
+  }
+
+  .step-hint {
+    margin: 4px 0 0 0;
+    padding-left: 4px;
+    font-size: 12px;
+    color: var(--color-text-3);
+    line-height: 1.5;
+  }
+
+  .remove-btn {
+    flex-shrink: 0;
+  }
+
+  .add-btn {
+    margin-top: 4px;
+  }
+</style>
diff --git a/web/admin/src/views/dashboard/topic_feed/components/TopicInputSourcesEditor.vue b/web/admin/src/views/dashboard/topic_feed/components/TopicInputSourcesEditor.vue
new file mode 100644
index 00000000..f889ef2e
--- /dev/null
+++ b/web/admin/src/views/dashboard/topic_feed/components/TopicInputSourcesEditor.vue
@@ -0,0 +1,284 @@
+<template>
+  <div class="input-sources-container">
+    <div
+      v-for="(source, idx) in modelValue"
+      :key="`source-${idx}`"
+      class="input-source-card"
+    >
+      <div class="source-header">
+        <a-radio-group
+          :model-value="source.sourceType"
+          type="button"
+          @change="(value: SourceType) => onSourceTypeChange(idx, value)"
+        >
+          <a-radio value="external">{{
+            t('topic.sourceType.external')
+          }}</a-radio>
+          <a-radio value="recipe">Recipe</a-radio>
+          <a-radio value="topic">Topic</a-radio>
+        </a-radio-group>
+        <a-space>
+          <a-button
+            size="small"
+            :disabled="!canPreviewSource(source)"
+            :loading="previewingIndex === idx"
+            @click="openPreview(idx)"
+          >
+            {{ t('topic.inputPreview') }}
+          </a-button>
+          <a-button
+            type="text"
+            status="danger"
+            class="remove-btn"
+            @click="removeSource(idx)"
+          >
+            <template #icon>
+              <icon-delete />
+            </template>
+            {{ t('topic.removeInput') }}
+          </a-button>
+        </a-space>
+      </div>
+
+      <a-input
+        v-if="source.sourceType === 'external'"
+        v-model="source.externalUrl"
+        :placeholder="t('topic.sourceUrl.placeholder')"
+        allow-clear
+      />
+      <a-select
+        v-else-if="source.sourceType === 'recipe'"
+        v-model="source.resourceId"
+        :loading="pickerLoading"
+        allow-search
+        allow-clear
+        :placeholder="t('topic.sourceSelect.placeholder.recipe')"
+      >
+        <a-option
+          v-for="r in availableRecipes"
+          :key="r.id"
+          :value="r.id"
+          :label="r.description ? `${r.id} — ${r.description}` : r.id"
+        >
+          <span class="option-id">{{ r.id }}</span>
+          <span v-if="r.description" class="option-desc">
+            — {{ r.description }}
+          </span>
+        </a-option>
+      </a-select>
+      <a-select
+        v-else
+        v-model="source.resourceId"
+        :loading="pickerLoading"
+        allow-search
+        allow-clear
+        :placeholder="t('topic.sourceSelect.placeholder.topic')"
+      >
+        <a-option
+          v-for="tp in pickerTopics"
+          :key="tp.id"
+          :value="tp.id"
+          :label="tp.title ? `${tp.id} — ${tp.title}` : tp.id"
+        >
+          <span class="option-id">{{ tp.id }}</span>
+          <span v-if="tp.title" class="option-desc"> — {{ tp.title }}</span>
+        </a-option>
+      </a-select>
+
+      <a-input
+        v-model="source.description"
+        :placeholder="t('topic.inputDescription.placeholder')"
+        allow-clear
+      />
+    </div>
+
+    <a-button type="dashed" long class="add-btn" @click="addSource">
+      <template #icon>
+        <icon-plus />
+      </template>
+      {{ t('topic.addInput') }}
+    </a-button>
+
+    <a-drawer
+      v-model:visible="previewDrawerVisible"
+      :title="previewDrawerTitle"
+      :width="720"
+      unmount-on-close
+    >
+      <a-alert
+        v-if="previewInputUri"
+        type="info"
+        class="mb-4"
+        show-icon
+        :title="t('topic.inputPreview.currentUri')"
+      >
+        {{ previewInputUri }}
+      </a-alert>
+      <FeedPreviewPanel
+        ref="previewPanelRef"
+        :empty-description="t('topic.inputPreview.empty')"
+      />
+    </a-drawer>
+  </div>
+</template>
+
+<script lang="ts" setup>
+  import { computed, nextTick, ref } from 'vue';
+  import { useI18n } from 'vue-i18n';
+  import type { CustomRecipe } from '@/api/custom_recipe';
+  import type { TopicFeed } from '@/api/topic';
+  import FeedPreviewPanel from '@/components/feed-preview/FeedPreviewPanel.vue';
+  import {
+    type InputSourceItem,
+    type SourceType,
+    sourceToUri,
+  } from '../topicInputUtils';
+
+  const props = defineProps<{
+    modelValue: InputSourceItem[];
+    availableRecipes: CustomRecipe[];
+    availableTopics: TopicFeed[];
+    pickerLoading?: boolean;
+    excludeTopicId?: string;
+  }>();
+
+  const emit = defineEmits<{
+    (event: 'update:modelValue', value: InputSourceItem[]): void;
+  }>();
+
+  const { t } = useI18n();
+  const previewDrawerVisible = ref(false);
+  const previewInputUri = ref('');
+  const previewDrawerTitle = ref('');
+  const previewingIndex = ref<number | null>(null);
+  const previewPanelRef = ref<InstanceType<typeof FeedPreviewPanel> | null>(
+    null
+  );
+
+  const pickerTopics = computed(() => {
+    if (!props.excludeTopicId) return props.availableTopics;
+    return props.availableTopics.filter((tp) => tp.id !== props.excludeTopicId);
+  });
+
+  const updateSources = (sources: InputSourceItem[]) => {
+    emit('update:modelValue', sources);
+  };
+
+  const canPreviewSource = (source: InputSourceItem) => {
+    return sourceToUri(source) !== '';
+  };
+
+  const addSource = () => {
+    updateSources([
+      ...props.modelValue,
+      {
+        sourceType: 'external',
+        externalUrl: '',
+        resourceId: '',
+        description: '',
+      },
+    ]);
+  };
+
+  const removeSource = (idx: number) => {
+    const next = [...props.modelValue];
+    next.splice(idx, 1);
+    if (next.length === 0) {
+      next.push({
+        sourceType: 'external',
+        externalUrl: '',
+        resourceId: '',
+        description: '',
+      });
+    }
+    updateSources(next);
+  };
+
+  const onSourceTypeChange = (idx: number, sourceType: SourceType) => {
+    const next = [...props.modelValue];
+    next[idx] = {
+      sourceType,
+      externalUrl: '',
+      resourceId: '',
+      description: next[idx]?.description || '',
+    };
+    updateSources(next);
+  };
+
+  const openPreview = async (idx: number) => {
+    const source = props.modelValue[idx];
+    const uri = sourceToUri(source);
+    if (!uri) return;
+
+    previewingIndex.value = idx;
+    previewInputUri.value = uri;
+    previewDrawerTitle.value =
+      source.description.trim() ||
+      t('topic.inputPreview.title', { index: idx + 1 });
+    previewDrawerVisible.value = true;
+
+    await nextTick();
+    try {
+      await previewPanelRef.value?.loadPreview(uri);
+    } finally {
+      previewingIndex.value = null;
+    }
+  };
+</script>
+
+<script lang="ts">
+  export default {
+    name: 'TopicInputSourcesEditor',
+  };
+</script>
+
+<style scoped>
+  .input-sources-container {
+    display: flex;
+    flex-direction: column;
+    gap: 12px;
+    width: 100%;
+  }
+
+  .input-source-card {
+    display: flex;
+    flex-direction: column;
+    gap: 12px;
+    background-color: var(--color-fill-1);
+    border: 1px solid var(--color-border-1);
+    border-radius: 6px;
+    padding: 12px 16px;
+    transition: all 0.2s ease;
+  }
+
+  .input-source-card:hover {
+    border-color: var(--color-border-3);
+    background-color: var(--color-fill-2);
+  }
+
+  .source-header {
+    display: flex;
+    justify-content: space-between;
+    align-items: center;
+    gap: 12px;
+    flex-wrap: wrap;
+  }
+
+  .remove-btn {
+    flex-shrink: 0;
+  }
+
+  .add-btn {
+    margin-top: 4px;
+  }
+
+  .option-id {
+    font-weight: 500;
+  }
+
+  .option-desc {
+    color: var(--color-text-3);
+    margin-left: 2px;
+    font-size: 12px;
+  }
+</style>
diff --git a/web/admin/src/views/dashboard/topic_feed/detail.vue b/web/admin/src/views/dashboard/topic_feed/detail.vue
index b0cd8f9f..1b7a51f5 100644
--- a/web/admin/src/views/dashboard/topic_feed/detail.vue
+++ b/web/admin/src/views/dashboard/topic_feed/detail.vue
@@ -82,10 +82,13 @@
               <div class="section-label">{{ t('topic.inputs') }}</div>
               <a-list bordered>
                 <a-list-item
-                  v-for="(uri, idx) in detail.topic.input_uris"
-                  :key="`${uri}-${idx}`"
+                  v-for="(input, idx) in topicInputs"
+                  :key="`${input.uri}-${idx}`"
                 >
-                  {{ uri }}
+                  <a-list-item-meta
+                    :title="input.description || input.uri"
+                    :description="input.description ? input.uri : undefined"
+                  />
                 </a-list-item>
               </a-list>
             </a-col>
@@ -319,6 +322,13 @@
     detail.value ? buildPublicFeedUrl(detail.value.public_url) : ''
   );
 
+  const topicInputs = computed(() => {
+    if (!detail.value) return [];
+    const { topic } = detail.value;
+    if (topic.inputs?.length) return topic.inputs;
+    return topic.input_uris.map((uri) => ({ uri, description: '' }));
+  });
+
   const formatTime = (value?: string) => {
     if (!value) return '-';
     return new Date(value).toLocaleString();
diff --git a/web/admin/src/views/dashboard/topic_feed/editor.vue b/web/admin/src/views/dashboard/topic_feed/editor.vue
new file mode 100644
index 00000000..a788b221
--- /dev/null
+++ b/web/admin/src/views/dashboard/topic_feed/editor.vue
@@ -0,0 +1,404 @@
+<template>
+  <div class="py-8 px-16">
+    <Breadcrumb
+      :items="['menu.worktable', 'menu.topicFeed', breadcrumbActionLabel]"
+    />
+    <x-header :title="pageTitle" :description="t('topic.wizard.description')" />
+
+    <a-card class="wizard-card">
+      <a-steps :current="currentStep" class="mb-8">
+        <a-step
+          :title="t('topic.wizard.step.basic')"
+          :description="t('topic.wizard.step.basic.desc')"
+        />
+        <a-step
+          :title="t('topic.wizard.step.inputs')"
+          :description="t('topic.wizard.step.inputs.desc')"
+        />
+        <a-step
+          :title="t('topic.wizard.step.aggregator')"
+          :description="t('topic.wizard.step.aggregator.desc')"
+        />
+        <a-step
+          :title="t('topic.wizard.step.review')"
+          :description="t('topic.wizard.step.review.desc')"
+        />
+      </a-steps>
+
+      <a-spin :loading="pageLoading" style="width: 100%">
+        <a-form ref="formRef" :model="formData" layout="vertical">
+          <div v-show="currentStep === 1" class="step-content">
+            <a-form-item
+              field="id"
+              :label="t('topic.id')"
+              required
+              :rules="getRecipeIdRules(t('topic.idRequired'))"
+            >
+              <a-input
+                v-model="formData.id"
+                :disabled="isEdit"
+                :placeholder="t('topic.id')"
+              />
+            </a-form-item>
+            <a-form-item field="title" :label="t('topic.title')">
+              <a-input
+                v-model="formData.title"
+                :placeholder="t('topic.title')"
+              />
+            </a-form-item>
+            <a-form-item
+              field="description"
+              :label="t('topic.descriptionLabel')"
+            >
+              <a-textarea
+                v-model="formData.description"
+                :placeholder="t('topic.descriptionLabel')"
+              />
+            </a-form-item>
+          </div>
+
+          <div v-show="currentStep === 2" class="step-content">
+            <a-alert type="info" class="mb-4" show-icon>
+              {{ t('topic.inputsHelp') }}
+            </a-alert>
+            <TopicInputSourcesEditor
+              v-model="formData.inputSources"
+              :available-recipes="availableRecipes"
+              :available-topics="availableTopics"
+              :picker-loading="pickerLoading"
+              :exclude-topic-id="isEdit ? formData.id : undefined"
+            />
+          </div>
+
+          <div v-show="currentStep === 3" class="step-content">
+            <a-alert type="info" class="mb-4" show-icon>
+              {{ t('topic.aggregatorHelp') }}
+            </a-alert>
+            <TopicAggregatorEditor v-model="formData.aggregator_config" />
+          </div>
+
+          <div v-show="currentStep === 4" class="step-content">
+            <a-descriptions :column="1" bordered>
+              <a-descriptions-item :label="t('topic.id')">
+                {{ formData.id || '-' }}
+              </a-descriptions-item>
+              <a-descriptions-item :label="t('topic.title')">
+                {{ formData.title || '-' }}
+              </a-descriptions-item>
+              <a-descriptions-item :label="t('topic.descriptionLabel')">
+                {{ formData.description || '-' }}
+              </a-descriptions-item>
+              <a-descriptions-item :label="t('topic.inputCount')">
+                {{ configuredInputCount }}
+              </a-descriptions-item>
+              <a-descriptions-item :label="t('topic.aggregator')">
+                {{
+                  formatAggregatorSummary(
+                    normalizeTopicPayload(formData).aggregator_config,
+                    t
+                  )
+                }}
+              </a-descriptions-item>
+            </a-descriptions>
+
+            <div class="section-label mt-4">{{ t('topic.inputs') }}</div>
+            <a-list bordered class="mb-4">
+              <a-list-item
+                v-for="(source, idx) in reviewInputs"
+                :key="`review-input-${idx}`"
+              >
+                <a-list-item-meta
+                  :title="source.description || source.uri"
+                  :description="source.description ? source.uri : undefined"
+                />
+              </a-list-item>
+            </a-list>
+
+            <a-alert v-if="validationErrors.length > 0" type="error">
+              <template #title>{{ t('topic.validationSummary') }}</template>
+              <div
+                v-for="issue in validationErrors"
+                :key="`${issue.field}-${issue.message}`"
+                class="validation-item"
+              >
+                <strong>{{ issue.field }}</strong
+                >: {{ issue.message }}
+              </div>
+            </a-alert>
+            <a-alert
+              v-if="validationWarnings.length > 0"
+              type="warning"
+              style="margin-top: 12px"
+            >
+              <template #title>{{ t('topic.validationWarnings') }}</template>
+              <div
+                v-for="issue in validationWarnings"
+                :key="`${issue.field}-${issue.message}`"
+                class="validation-item"
+              >
+                <strong>{{ issue.field }}</strong
+                >: {{ issue.message }}
+              </div>
+            </a-alert>
+          </div>
+        </a-form>
+      </a-spin>
+
+      <div class="wizard-footer">
+        <a-space>
+          <a-button @click="goBackToList">{{ t('topic.cancel') }}</a-button>
+          <a-button v-if="currentStep > 1" @click="prevStep">
+            {{ t('topic.wizard.prev') }}
+          </a-button>
+          <a-button
+            v-if="currentStep < 4"
+            type="primary"
+            :loading="stepValidating"
+            @click="nextStep"
+          >
+            {{ t('topic.wizard.next') }}
+          </a-button>
+          <template v-else>
+            <a-button :loading="validating" @click="handleValidate">
+              {{ t('topic.validate') }}
+            </a-button>
+            <a-button
+              type="primary"
+              :loading="submitting"
+              @click="handleSubmit"
+            >
+              {{ t('topic.save') }}
+            </a-button>
+          </template>
+        </a-space>
+      </div>
+    </a-card>
+  </div>
+</template>
+
+<script lang="ts" setup>
+  import { computed, onMounted, ref } from 'vue';
+  import { Message } from '@arco-design/web-vue';
+  import { useI18n } from 'vue-i18n';
+  import { useRoute, useRouter } from 'vue-router';
+  import { CustomRecipe, getCustomRecipes } from '@/api/custom_recipe';
+  import {
+    TopicFeed,
+    TopicValidationIssue,
+    createTopicFeed,
+    getTopicFeed,
+    listTopicFeeds,
+    updateTopicFeed,
+    validateTopicFeed,
+  } from '@/api/topic';
+  import XHeader from '@/components/header/x-header.vue';
+  import { getRecipeIdRules } from '@/utils/slug';
+  import TopicAggregatorEditor from './components/TopicAggregatorEditor.vue';
+  import TopicInputSourcesEditor from './components/TopicInputSourcesEditor.vue';
+  import {
+    defaultFormData,
+    formatAggregatorSummary,
+    normalizeTopicPayload,
+    sourceToUri,
+    topicFeedToFormData,
+    type TopicFormData,
+  } from './topicInputUtils';
+
+  const { t } = useI18n();
+  const route = useRoute();
+  const router = useRouter();
+
+  const isEdit = computed(() => Boolean(route.params.id));
+  const pageTitle = computed(() =>
+    isEdit.value ? t('topic.edit') : t('topic.create')
+  );
+  const breadcrumbActionLabel = computed(() =>
+    isEdit.value ? t('topic.edit') : t('topic.create')
+  );
+
+  const currentStep = ref(1);
+  const pageLoading = ref(false);
+  const stepValidating = ref(false);
+  const submitting = ref(false);
+  const validating = ref(false);
+  const formRef = ref();
+  const formData = ref<TopicFormData>(defaultFormData());
+  const validationErrors = ref<TopicValidationIssue[]>([]);
+  const validationWarnings = ref<TopicValidationIssue[]>([]);
+  const availableRecipes = ref<CustomRecipe[]>([]);
+  const availableTopics = ref<TopicFeed[]>([]);
+  const pickerLoading = ref(false);
+
+  const configuredInputCount = computed(
+    () =>
+      formData.value.inputSources.filter((source) => sourceToUri(source) !== '')
+        .length
+  );
+
+  const reviewInputs = computed(
+    () => normalizeTopicPayload(formData.value).inputs || []
+  );
+
+  const loadPickerData = async () => {
+    pickerLoading.value = true;
+    try {
+      const [recipesRes, topicsRes] = await Promise.all([
+        getCustomRecipes(),
+        listTopicFeeds(),
+      ]);
+      availableRecipes.value = recipesRes.data ?? [];
+      availableTopics.value = topicsRes.data ?? [];
+    } finally {
+      pickerLoading.value = false;
+    }
+  };
+
+  const loadTopic = async () => {
+    if (!isEdit.value) return;
+    pageLoading.value = true;
+    try {
+      const res = await getTopicFeed(String(route.params.id));
+      if (!res.data) {
+        Message.error(t('topic.detail.notFound'));
+        goBackToList();
+        return;
+      }
+      formData.value = topicFeedToFormData(res.data);
+    } catch (err: any) {
+      Message.error(err.message || t('topic.fetchFailed'));
+      goBackToList();
+    } finally {
+      pageLoading.value = false;
+    }
+  };
+
+  const goBackToList = () => {
+    router.push({ name: 'TopicFeed' });
+  };
+
+  const prevStep = () => {
+    currentStep.value = Math.max(1, currentStep.value - 1);
+  };
+
+  const validateCurrentStep = async () => {
+    if (currentStep.value === 1) {
+      const result = await formRef.value?.validateField('id');
+      return !result;
+    }
+    if (currentStep.value === 2) {
+      if (configuredInputCount.value === 0) {
+        Message.warning(t('topic.wizard.inputsRequired'));
+        return false;
+      }
+      return true;
+    }
+    return true;
+  };
+
+  const nextStep = async () => {
+    stepValidating.value = true;
+    try {
+      const ok = await validateCurrentStep();
+      if (!ok) return;
+      currentStep.value = Math.min(4, currentStep.value + 1);
+    } finally {
+      stepValidating.value = false;
+    }
+  };
+
+  const runValidation = async () => {
+    const payload = normalizeTopicPayload(formData.value);
+    const res = await validateTopicFeed(payload);
+    validationErrors.value = res.data?.errors || [];
+    validationWarnings.value = res.data?.warnings || [];
+    return res.data;
+  };
+
+  const handleValidate = async () => {
+    validating.value = true;
+    try {
+      const result = await runValidation();
+      if (result?.valid) {
+        Message.success(t('topic.validateSuccess'));
+      } else {
+        Message.error(t('topic.validateFailed'));
+      }
+    } catch (err: any) {
+      Message.error(err.message || t('topic.validateFailed'));
+    } finally {
+      validating.value = false;
+    }
+  };
+
+  const handleSubmit = async () => {
+    const formResult = await formRef.value?.validate();
+    if (formResult) return;
+
+    if (configuredInputCount.value === 0) {
+      Message.warning(t('topic.wizard.inputsRequired'));
+      currentStep.value = 2;
+      return;
+    }
+
+    submitting.value = true;
+    try {
+      const result = await runValidation();
+      if (!result?.valid) {
+        Message.error(t('topic.validateFailed'));
+        return;
+      }
+
+      const payload = normalizeTopicPayload(formData.value);
+      if (isEdit.value) {
+        await updateTopicFeed(payload.id, payload);
+        Message.success(t('topic.updateSuccess'));
+      } else {
+        await createTopicFeed(payload);
+        Message.success(t('topic.createSuccess'));
+      }
+      goBackToList();
+    } catch (err: any) {
+      Message.error(err.message || t('topic.saveFailed'));
+    } finally {
+      submitting.value = false;
+    }
+  };
+
+  onMounted(async () => {
+    await Promise.all([loadPickerData(), loadTopic()]);
+  });
+</script>
+
+<script lang="ts">
+  export default {
+    name: 'TopicFeedEditor',
+  };
+</script>
+
+<style scoped>
+  .wizard-card {
+    margin-top: 8px;
+  }
+
+  .step-content {
+    max-width: 920px;
+    margin: 0 auto;
+  }
+
+  .wizard-footer {
+    margin-top: 24px;
+    padding-top: 16px;
+    border-top: 1px solid var(--color-border-2);
+    display: flex;
+    justify-content: flex-end;
+  }
+
+  .section-label {
+    margin-bottom: 12px;
+    font-weight: 600;
+  }
+
+  .validation-item {
+    margin-top: 6px;
+  }
+</style>
diff --git a/web/admin/src/views/dashboard/topic_feed/topicInputUtils.ts b/web/admin/src/views/dashboard/topic_feed/topicInputUtils.ts
new file mode 100644
index 00000000..0005b0fa
--- /dev/null
+++ b/web/admin/src/views/dashboard/topic_feed/topicInputUtils.ts
@@ -0,0 +1,213 @@
+import type { AggregatorStep, TopicFeed, TopicInput } from '@/api/topic';
+
+export type StepType = 'deduplicate' | 'sort' | 'limit';
+export type SourceType = 'external' | 'recipe' | 'topic';
+
+export const STRATEGIES_WITH_THRESHOLD = [
+  'by_simhash',
+  'by_embedding',
+] as const;
+
+export interface InputSourceItem {
+  sourceType: SourceType;
+  externalUrl: string;
+  resourceId: string;
+  description: string;
+}
+
+export interface StepFormItem {
+  type: StepType;
+  value: string | number;
+  threshold?: number;
+}
+
+export interface TopicFormData {
+  id: string;
+  title: string;
+  description: string;
+  inputSources: InputSourceItem[];
+  aggregator_config: StepFormItem[];
+}
+
+export const defaultThreshold = (strategy: string): number | undefined => {
+  if (strategy === 'by_simhash') return 0.05;
+  if (strategy === 'by_embedding') return 0.1;
+  return undefined;
+};
+
+export const createDefaultStep = (type: StepType = 'limit'): StepFormItem => {
+  if (type === 'deduplicate') return { type, value: 'by_link' };
+  if (type === 'sort') return { type, value: 'date_desc' };
+  return { type, value: 50 };
+};
+
+export const defaultFormData = (): TopicFormData => ({
+  id: '',
+  title: '',
+  description: '',
+  inputSources: [
+    {
+      sourceType: 'external',
+      externalUrl: '',
+      resourceId: '',
+      description: '',
+    },
+  ],
+  aggregator_config: [],
+});
+
+export const parseUriToSource = (
+  input: TopicInput | string
+): InputSourceItem => {
+  const uri = typeof input === 'string' ? input : input.uri;
+  const description =
+    typeof input === 'string' ? '' : input.description?.trim() || '';
+
+  if (uri.startsWith('feedcraft://recipe/')) {
+    return {
+      sourceType: 'recipe',
+      externalUrl: '',
+      resourceId: uri.slice('feedcraft://recipe/'.length),
+      description,
+    };
+  }
+  if (uri.startsWith('feedcraft://topic/')) {
+    return {
+      sourceType: 'topic',
+      externalUrl: '',
+      resourceId: uri.slice('feedcraft://topic/'.length),
+      description,
+    };
+  }
+  return {
+    sourceType: 'external',
+    externalUrl: uri,
+    resourceId: '',
+    description,
+  };
+};
+
+export const sourceToUri = (source: InputSourceItem): string => {
+  if (source.sourceType === 'recipe') {
+    return `feedcraft://recipe/${source.resourceId}`;
+  }
+  if (source.sourceType === 'topic') {
+    return `feedcraft://topic/${source.resourceId}`;
+  }
+  return source.externalUrl.trim();
+};
+
+export const topicFeedToFormData = (record: TopicFeed): TopicFormData => {
+  const inputs =
+    record.inputs && record.inputs.length > 0
+      ? record.inputs
+      : record.input_uris.map((uri) => ({ uri, description: '' }));
+
+  return {
+    id: record.id,
+    title: record.title || '',
+    description: record.description || '',
+    inputSources:
+      inputs.length > 0
+        ? inputs.map(parseUriToSource)
+        : [
+            {
+              sourceType: 'external',
+              externalUrl: '',
+              resourceId: '',
+              description: '',
+            },
+          ],
+    aggregator_config: (record.aggregator_config || []).map((step) => {
+      if (step.type === 'deduplicate') {
+        const strategy = step.option?.strategy || 'by_link';
+        const item: StepFormItem = { type: 'deduplicate', value: strategy };
+        if (
+          step.option?.threshold !== undefined &&
+          STRATEGIES_WITH_THRESHOLD.includes(
+            strategy as (typeof STRATEGIES_WITH_THRESHOLD)[number]
+          )
+        ) {
+          item.threshold = Number(step.option.threshold);
+        } else {
+          item.threshold = defaultThreshold(strategy);
+        }
+        return item;
+      }
+      if (step.type === 'sort') {
+        return { type: 'sort', value: step.option?.by || 'date_desc' };
+      }
+      return { type: 'limit', value: Number(step.option?.max || 50) };
+    }),
+  };
+};
+
+export const normalizeTopicPayload = (formData: TopicFormData): TopicFeed => {
+  const inputs: TopicInput[] = formData.inputSources
+    .map((source) => ({
+      uri: sourceToUri(source),
+      description: source.description.trim(),
+    }))
+    .filter((item) => item.uri !== '');
+
+  return {
+    id: formData.id.trim(),
+    title: formData.title.trim(),
+    description: formData.description.trim(),
+    inputs,
+    input_uris: inputs.map((item) => item.uri),
+    aggregator_config: formData.aggregator_config.map((step) => {
+      const option: Record<string, string> = {};
+      if (step.type === 'deduplicate') {
+        option.strategy = String(step.value);
+        if (
+          step.threshold !== undefined &&
+          STRATEGIES_WITH_THRESHOLD.includes(
+            step.value as (typeof STRATEGIES_WITH_THRESHOLD)[number]
+          )
+        ) {
+          option.threshold = String(step.threshold);
+        }
+      }
+      if (step.type === 'sort') option.by = String(step.value);
+      if (step.type === 'limit') option.max = String(step.value);
+      return {
+        type: step.type,
+        option,
+      };
+    }),
+  };
+};
+
+export const formatAggregatorSummary = (
+  steps: AggregatorStep[],
+  t: (key: string) => string
+): string => {
+  if (!steps || steps.length === 0) return t('topic.noAggregator');
+  return steps
+    .map((step) => {
+      if (step.type === 'deduplicate') {
+        const strategy = step.option?.strategy || 'by_link';
+        const label = t(`topic.stepOption.strategy.${strategy}`);
+        if (
+          (strategy === 'by_simhash' || strategy === 'by_embedding') &&
+          step.option?.threshold
+        ) {
+          return `${t('topic.stepType.deduplicate')} · ${label} (${
+            step.option.threshold
+          })`;
+        }
+        return `${t('topic.stepType.deduplicate')} · ${label}`;
+      }
+      if (step.type === 'sort') {
+        return `${t('topic.stepType.sort')} · ${t(
+          `topic.stepOption.sort.${step.option?.by || 'date_desc'}`
+        )}`;
+      }
+      if (step.type === 'limit') {
+        return `${t('topic.stepType.limit')} · ${step.option?.max || '-'}`;
+      }
+      return step.type;
+    })
+    .join(' / ');
+};
diff --git a/web/admin/src/views/dashboard/topic_feed/topic_feed.vue b/web/admin/src/views/dashboard/topic_feed/topic_feed.vue
index 24a344be..7171277a 100644
--- a/web/admin/src/views/dashboard/topic_feed/topic_feed.vue
+++ b/web/admin/src/views/dashboard/topic_feed/topic_feed.vue
@@ -41,13 +41,13 @@
           />
           <a-table-column :title="t('topic.inputCount')">
             <template #cell="{ record }">
-              <a-tag color="arcoblue">{{ record.input_uris.length }}</a-tag>
+              <a-tag color="arcoblue">{{ inputCount(record) }}</a-tag>
             </template>
           </a-table-column>
           <a-table-column :title="t('topic.aggregator')">
             <template #cell="{ record }">
               <span>{{
-                formatAggregatorSummary(record.aggregator_config)
+                formatAggregatorSummary(record.aggregator_config, t)
               }}</span>
             </template>
           </a-table-column>
@@ -68,7 +68,11 @@
                 >
                   {{ t('topic.preview') }}
                 </a-button>
-                <a-button type="text" size="small" @click="handleEdit(record)">
+                <a-button
+                  type="text"
+                  size="small"
+                  @click="handleEdit(record.id)"
+                >
                   {{ t('topic.editAction') }}
                 </a-button>
                 <a-link :href="buildTopicFeedUrl(record.id)" target="_blank">
@@ -93,504 +97,27 @@
         :description="t('topic.noTopics')"
       />
     </a-card>
-
-    <a-modal
-      v-model:visible="modalVisible"
-      :title="isEdit ? t('topic.edit') : t('topic.create')"
-      width="860px"
-      :mask-closable="false"
-      :ok-button-props="{ disabled: submitting }"
-      :cancel-button-props="{ disabled: submitting || validating }"
-      @cancel="modalVisible = false"
-    >
-      <a-form ref="formRef" :model="formData" layout="vertical">
-        <a-form-item
-          field="id"
-          :label="t('topic.id')"
-          required
-          :rules="getRecipeIdRules(t('topic.idRequired'))"
-        >
-          <a-input
-            v-model="formData.id"
-            :disabled="isEdit"
-            :placeholder="t('topic.id')"
-          />
-        </a-form-item>
-        <a-form-item field="title" :label="t('topic.title')">
-          <a-input v-model="formData.title" :placeholder="t('topic.title')" />
-        </a-form-item>
-        <a-form-item field="description" :label="t('topic.descriptionLabel')">
-          <a-textarea
-            v-model="formData.description"
-            :placeholder="t('topic.descriptionLabel')"
-          />
-        </a-form-item>
-
-        <a-divider
-          orientation="left"
-          style="margin-top: 4px; margin-bottom: 4px"
-        >
-          {{ t('topic.sectionInputs') }}
-        </a-divider>
-        <a-form-item>
-          <template #help>{{ t('topic.inputsHelp') }}</template>
-          <div class="input-sources-container">
-            <div
-              v-for="(source, idx) in formData.inputSources"
-              :key="`source-${idx}`"
-              class="input-source-card"
-            >
-              <a-radio-group
-                v-model="source.sourceType"
-                type="button"
-                @change="resetSourceValue(idx)"
-              >
-                <a-radio value="external">{{
-                  t('topic.sourceType.external')
-                }}</a-radio>
-                <a-radio value="recipe">Recipe</a-radio>
-                <a-radio value="topic">Topic</a-radio>
-              </a-radio-group>
-              <a-input
-                v-if="source.sourceType === 'external'"
-                v-model="source.externalUrl"
-                :placeholder="t('topic.sourceUrl.placeholder')"
-                allow-clear
-              />
-              <a-select
-                v-else-if="source.sourceType === 'recipe'"
-                v-model="source.resourceId"
-                :loading="pickerLoading"
-                allow-search
-                allow-clear
-                :placeholder="t('topic.sourceSelect.placeholder.recipe')"
-              >
-                <a-option
-                  v-for="r in availableRecipes"
-                  :key="r.id"
-                  :value="r.id"
-                  :label="r.description ? `${r.id} — ${r.description}` : r.id"
-                >
-                  <span class="option-id">{{ r.id }}</span>
-                  <span v-if="r.description" class="option-desc">
-                    — {{ r.description }}
-                  </span>
-                </a-option>
-              </a-select>
-              <a-select
-                v-else
-                v-model="source.resourceId"
-                :loading="pickerLoading"
-                allow-search
-                allow-clear
-                :placeholder="t('topic.sourceSelect.placeholder.topic')"
-              >
-                <a-option
-                  v-for="tp in pickerTopics"
-                  :key="tp.id"
-                  :value="tp.id"
-                  :label="tp.title ? `${tp.id} — ${tp.title}` : tp.id"
-                >
-                  <span class="option-id">{{ tp.id }}</span>
-                  <span v-if="tp.title" class="option-desc">
-                    — {{ tp.title }}</span
-                  >
-                </a-option>
-              </a-select>
-              <a-button
-                type="text"
-                status="danger"
-                class="remove-btn"
-                @click="removeSource(idx)"
-              >
-                <template #icon>
-                  <icon-delete />
-                </template>
-                {{ t('topic.removeInput') }}
-              </a-button>
-            </div>
-            <a-button type="dashed" long class="add-btn" @click="addSource">
-              <template #icon>
-                <icon-plus />
-              </template>
-              {{ t('topic.addInput') }}
-            </a-button>
-          </div>
-        </a-form-item>
-
-        <a-divider
-          orientation="left"
-          style="margin-top: 4px; margin-bottom: 4px"
-        >
-          {{ t('topic.sectionAggregator') }}
-        </a-divider>
-        <a-form-item>
-          <template #help>{{ t('topic.aggregatorHelp') }}</template>
-          <div class="steps-container">
-            <div
-              v-for="(step, idx) in formData.aggregator_config"
-              :key="`step-${idx}`"
-              class="step-card"
-            >
-              <div class="editor-row">
-                <a-select
-                  v-model="step.type"
-                  style="width: 150px; flex-shrink: 0"
-                  @change="resetStepValue(idx)"
-                >
-                  <a-option value="deduplicate">
-                    {{ t('topic.stepType.deduplicate') }}
-                  </a-option>
-                  <a-option value="sort">{{
-                    t('topic.stepType.sort')
-                  }}</a-option>
-                  <a-option value="limit">{{
-                    t('topic.stepType.limit')
-                  }}</a-option>
-                </a-select>
-
-                <template v-if="step.type === 'deduplicate'">
-                  <a-select
-                    v-model="step.value"
-                    style="width: 220px; flex-shrink: 0"
-                    @change="onDeduplicateStrategyChange(idx)"
-                  >
-                    <a-option value="by_link">
-                      {{ t('topic.stepOption.strategy.by_link') }}
-                    </a-option>
-                    <a-option value="by_id">
-                      {{ t('topic.stepOption.strategy.by_id') }}
-                    </a-option>
-                    <a-option value="by_title">
-                      {{ t('topic.stepOption.strategy.by_title') }}
-                    </a-option>
-                    <a-option value="by_simhash">
-                      {{ t('topic.stepOption.strategy.by_simhash') }}
-                    </a-option>
-                    <a-option value="by_embedding">
-                      {{ t('topic.stepOption.strategy.by_embedding') }}
-                    </a-option>
-                  </a-select>
-                  <a-input-number
-                    v-if="step.value === 'by_simhash'"
-                    v-model="step.threshold"
-                    :min="0"
-                    :max="1"
-                    :step="0.01"
-                    :precision="2"
-                    :placeholder="t('topic.stepOption.threshold.simhash')"
-                    style="flex: 1; min-width: 120px"
-                  />
-                  <a-input-number
-                    v-else-if="step.value === 'by_embedding'"
-                    v-model="step.threshold"
-                    :min="0"
-                    :max="1"
-                    :step="0.01"
-                    :precision="2"
-                    :placeholder="t('topic.stepOption.threshold.embedding')"
-                    style="flex: 1; min-width: 120px"
-                  />
-                </template>
-
-                <a-select
-                  v-else-if="step.type === 'sort'"
-                  v-model="step.value"
-                  style="flex: 1; min-width: 150px"
-                >
-                  <a-option value="date_desc">
-                    {{ t('topic.stepOption.sort.date_desc') }}
-                  </a-option>
-                  <a-option value="date_asc">
-                    {{ t('topic.stepOption.sort.date_asc') }}
-                  </a-option>
-                  <a-option value="quality_desc">
-                    {{ t('topic.stepOption.sort.quality_desc') }}
-                  </a-option>
-                  <a-option value="quality_asc">
-                    {{ t('topic.stepOption.sort.quality_asc') }}
-                  </a-option>
-                </a-select>
-
-                <a-input-number
-                  v-else
-                  v-model="step.value"
-                  :min="1"
-                  mode="button"
-                  style="flex: 1; min-width: 150px"
-                />
-
-                <a-button
-                  type="text"
-                  status="danger"
-                  class="remove-btn"
-                  @click="removeStep(idx)"
-                >
-                  <template #icon>
-                    <icon-delete />
-                  </template>
-                  {{ t('topic.removeStep') }}
-                </a-button>
-              </div>
-              <p
-                v-if="
-                  step.type === 'deduplicate' &&
-                  (step.value === 'by_simhash' || step.value === 'by_embedding')
-                "
-                class="step-hint"
-              >
-                {{ t(`topic.stepOption.strategy.${step.value}.hint`) }}
-              </p>
-            </div>
-
-            <a-button type="dashed" long class="add-btn" @click="addStep">
-              <template #icon>
-                <icon-plus />
-              </template>
-              {{ t('topic.addStep') }}
-            </a-button>
-          </div>
-        </a-form-item>
-
-        <a-alert v-if="validationErrors.length > 0" type="error">
-          <template #title>{{ t('topic.validationSummary') }}</template>
-          <div
-            v-for="issue in validationErrors"
-            :key="`${issue.field}-${issue.message}`"
-            class="validation-item"
-          >
-            <strong>{{ issue.field }}</strong
-            >: {{ issue.message }}
-          </div>
-        </a-alert>
-        <a-alert
-          v-if="validationWarnings.length > 0"
-          type="warning"
-          style="margin-top: 12px"
-        >
-          <template #title>{{ t('topic.validationWarnings') }}</template>
-          <div
-            v-for="issue in validationWarnings"
-            :key="`${issue.field}-${issue.message}`"
-            class="validation-item"
-          >
-            <strong>{{ issue.field }}</strong
-            >: {{ issue.message }}
-          </div>
-        </a-alert>
-      </a-form>
-
-      <template #footer>
-        <a-space>
-          <a-button @click="modalVisible = false">{{
-            t('topic.cancel')
-          }}</a-button>
-          <a-button :loading="validating" @click="handleValidate">
-            {{ t('topic.validate') }}
-          </a-button>
-          <a-button type="primary" :loading="submitting" @click="handleSubmit">
-            {{ t('topic.save') }}
-          </a-button>
-        </a-space>
-      </template>
-    </a-modal>
   </div>
 </template>
 
 <script lang="ts" setup>
-  import { computed, onMounted, ref } from 'vue';
+  import { onMounted, ref } from 'vue';
   import { Message } from '@arco-design/web-vue';
   import { useI18n } from 'vue-i18n';
   import { useRouter } from 'vue-router';
-  import { CustomRecipe, getCustomRecipes } from '@/api/custom_recipe';
   import XHeader from '@/components/header/x-header.vue';
   import buildPublicFeedUrl from '@/utils/publicFeedUrl';
-  import { getRecipeIdRules } from '@/utils/slug';
-  import {
-    AggregatorStep,
-    TopicFeed,
-    TopicValidationIssue,
-    createTopicFeed,
-    deleteTopicFeed,
-    listTopicFeeds,
-    updateTopicFeed,
-    validateTopicFeed,
-  } from '@/api/topic';
-
-  type StepType = 'deduplicate' | 'sort' | 'limit';
-
-  type SourceType = 'external' | 'recipe' | 'topic';
-
-  const STRATEGIES_WITH_THRESHOLD = ['by_simhash', 'by_embedding'] as const;
-
-  interface InputSourceItem {
-    sourceType: SourceType;
-    externalUrl: string;
-    resourceId: string;
-  }
-
-  interface StepFormItem {
-    type: StepType;
-    value: string | number;
-    /** Deduplication threshold: Hamming distance for by_simhash, cosine similarity for by_embedding */
-    threshold?: number;
-  }
-
-  interface TopicFormData {
-    id: string;
-    title: string;
-    description: string;
-    inputSources: InputSourceItem[];
-    aggregator_config: StepFormItem[];
-  }
+  import { TopicFeed, deleteTopicFeed, listTopicFeeds } from '@/api/topic';
+  import { formatAggregatorSummary } from './topicInputUtils';
 
   const { t } = useI18n();
   const router = useRouter();
   const topics = ref<TopicFeed[]>([]);
   const loading = ref(false);
-  const formRef = ref();
-  const modalVisible = ref(false);
-  const isEdit = ref(false);
-  const submitting = ref(false);
-  const validating = ref(false);
-  const validationErrors = ref<TopicValidationIssue[]>([]);
-  const validationWarnings = ref<TopicValidationIssue[]>([]);
-  const availableRecipes = ref<CustomRecipe[]>([]);
-  const availableTopics = ref<TopicFeed[]>([]);
-  const pickerLoading = ref(false);
-
-  const defaultThreshold = (strategy: string): number | undefined => {
-    if (strategy === 'by_simhash') return 0.05;
-    if (strategy === 'by_embedding') return 0.1;
-    return undefined;
-  };
-
-  const createDefaultStep = (type: StepType = 'limit'): StepFormItem => {
-    if (type === 'deduplicate') return { type, value: 'by_link' };
-    if (type === 'sort') return { type, value: 'date_desc' };
-    return { type, value: 50 };
-  };
-
-  const defaultFormData = (): TopicFormData => ({
-    id: '',
-    title: '',
-    description: '',
-    inputSources: [{ sourceType: 'external', externalUrl: '', resourceId: '' }],
-    aggregator_config: [],
-  });
-
-  const parseUriToSource = (uri: string): InputSourceItem => {
-    if (uri.startsWith('feedcraft://recipe/')) {
-      return {
-        sourceType: 'recipe',
-        externalUrl: '',
-        resourceId: uri.slice('feedcraft://recipe/'.length),
-      };
-    }
-    if (uri.startsWith('feedcraft://topic/')) {
-      return {
-        sourceType: 'topic',
-        externalUrl: '',
-        resourceId: uri.slice('feedcraft://topic/'.length),
-      };
-    }
-    return { sourceType: 'external', externalUrl: uri, resourceId: '' };
-  };
-
-  const sourceToUri = (source: InputSourceItem): string => {
-    if (source.sourceType === 'recipe') {
-      return `feedcraft://recipe/${source.resourceId}`;
-    }
-    if (source.sourceType === 'topic') {
-      return `feedcraft://topic/${source.resourceId}`;
-    }
-    return source.externalUrl.trim();
-  };
-
-  const loadPickerData = async () => {
-    pickerLoading.value = true;
-    try {
-      const [recipesRes, topicsRes] = await Promise.all([
-        getCustomRecipes(),
-        listTopicFeeds(),
-      ]);
-      availableRecipes.value = recipesRes.data ?? [];
-      availableTopics.value = topicsRes.data ?? [];
-    } catch {
-      // non-fatal: picker continues with empty lists
-    } finally {
-      pickerLoading.value = false;
-    }
-  };
-
-  const formData = ref<TopicFormData>(defaultFormData());
-
-  const pickerTopics = computed(() => {
-    if (!isEdit.value) return availableTopics.value;
-    return availableTopics.value.filter((tp) => tp.id !== formData.value.id);
-  });
-
-  const normalizeTopicPayload = (): TopicFeed => ({
-    id: formData.value.id.trim(),
-    title: formData.value.title.trim(),
-    description: formData.value.description.trim(),
-    input_uris: formData.value.inputSources
-      .map(sourceToUri)
-      .filter((uri) => uri !== ''),
-    aggregator_config: formData.value.aggregator_config.map((step) => {
-      const option: Record<string, string> = {};
-      if (step.type === 'deduplicate') {
-        option.strategy = String(step.value);
-        if (
-          step.threshold !== undefined &&
-          STRATEGIES_WITH_THRESHOLD.includes(
-            step.value as (typeof STRATEGIES_WITH_THRESHOLD)[number]
-          )
-        ) {
-          option.threshold = String(step.threshold);
-        }
-      }
-      if (step.type === 'sort') option.by = String(step.value);
-      if (step.type === 'limit') option.max = String(step.value);
-      return {
-        type: step.type,
-        option,
-      };
-    }),
-  });
-
-  const formatDeduplicateStrategy = (step: AggregatorStep): string => {
-    const strategy = step.option?.strategy || 'by_link';
-    const label = t(`topic.stepOption.strategy.${strategy}`);
-    if (strategy === 'by_simhash' && step.option?.threshold) {
-      return `${label} (${step.option.threshold})`;
-    }
-    if (strategy === 'by_embedding' && step.option?.threshold) {
-      return `${label} (${step.option.threshold})`;
-    }
-    return label;
-  };
 
-  const formatAggregatorSummary = (steps: AggregatorStep[]) => {
-    if (!steps || steps.length === 0) return t('topic.noAggregator');
-    return steps
-      .map((step) => {
-        if (step.type === 'deduplicate') {
-          return `${t(
-            'topic.stepType.deduplicate'
-          )} · ${formatDeduplicateStrategy(step)}`;
-        }
-        if (step.type === 'sort') {
-          return `${t('topic.stepType.sort')} · ${t(
-            `topic.stepOption.sort.${step.option?.by || 'date_desc'}`
-          )}`;
-        }
-        if (step.type === 'limit') {
-          return `${t('topic.stepType.limit')} · ${step.option?.max || '-'}`;
-        }
-        return step.type;
-      })
-      .join(' / ');
+  const inputCount = (record: TopicFeed) => {
+    if (record.inputs?.length) return record.inputs.length;
+    return record.input_uris.length;
   };
 
   const fetchTopics = async () => {
@@ -605,14 +132,6 @@
     }
   };
 
-  const openModal = () => {
-    formRef.value?.resetFields();
-    validationErrors.value = [];
-    validationWarnings.value = [];
-    loadPickerData();
-    modalVisible.value = true;
-  };
-
   const buildTopicFeedUrl = (id: string) => buildPublicFeedUrl(`/topic/${id}`);
 
   const previewTopic = (id: string) => {
@@ -623,44 +142,11 @@
   };
 
   const handleAdd = () => {
-    isEdit.value = false;
-    formData.value = defaultFormData();
-    openModal();
+    router.push({ name: 'TopicFeedCreate' });
   };
 
-  const handleEdit = (record: TopicFeed) => {
-    isEdit.value = true;
-    formData.value = {
-      id: record.id,
-      title: record.title || '',
-      description: record.description || '',
-      inputSources:
-        record.input_uris.length > 0
-          ? record.input_uris.map(parseUriToSource)
-          : [{ sourceType: 'external', externalUrl: '', resourceId: '' }],
-      aggregator_config: (record.aggregator_config || []).map((step) => {
-        if (step.type === 'deduplicate') {
-          const strategy = step.option?.strategy || 'by_link';
-          const item: StepFormItem = { type: 'deduplicate', value: strategy };
-          if (
-            step.option?.threshold !== undefined &&
-            STRATEGIES_WITH_THRESHOLD.includes(
-              strategy as (typeof STRATEGIES_WITH_THRESHOLD)[number]
-            )
-          ) {
-            item.threshold = Number(step.option.threshold);
-          } else {
-            item.threshold = defaultThreshold(strategy);
-          }
-          return item;
-        }
-        if (step.type === 'sort') {
-          return { type: 'sort', value: step.option?.by || 'date_desc' };
-        }
-        return { type: 'limit', value: Number(step.option?.max || 50) };
-      }),
-    };
-    openModal();
+  const handleEdit = (id: string) => {
+    router.push({ name: 'TopicFeedEdit', params: { id } });
   };
 
   const handleDelete = async (id: string) => {
@@ -673,108 +159,6 @@
     }
   };
 
-  const addSource = () => {
-    formData.value.inputSources.push({
-      sourceType: 'external',
-      externalUrl: '',
-      resourceId: '',
-    });
-  };
-
-  const removeSource = (idx: number) => {
-    formData.value.inputSources.splice(idx, 1);
-    if (formData.value.inputSources.length === 0) {
-      formData.value.inputSources.push({
-        sourceType: 'external',
-        externalUrl: '',
-        resourceId: '',
-      });
-    }
-  };
-
-  const resetSourceValue = (idx: number) => {
-    const { sourceType } = formData.value.inputSources[idx];
-    formData.value.inputSources[idx] = {
-      sourceType,
-      externalUrl: '',
-      resourceId: '',
-    };
-  };
-
-  const addStep = () => {
-    formData.value.aggregator_config.push(createDefaultStep());
-  };
-
-  const removeStep = (idx: number) => {
-    formData.value.aggregator_config.splice(idx, 1);
-  };
-
-  const resetStepValue = (idx: number) => {
-    const currentType = formData.value.aggregator_config[idx].type;
-    formData.value.aggregator_config[idx] = createDefaultStep(currentType);
-  };
-
-  const onDeduplicateStrategyChange = (idx: number) => {
-    const strategy = String(formData.value.aggregator_config[idx].value);
-    formData.value.aggregator_config[idx].threshold =
-      defaultThreshold(strategy);
-  };
-
-  const runValidation = async () => {
-    const payload = normalizeTopicPayload();
-    const res = await validateTopicFeed(payload);
-    validationErrors.value = res.data?.errors || [];
-    validationWarnings.value = res.data?.warnings || [];
-    return res.data;
-  };
-
-  const handleValidate = async () => {
-    validating.value = true;
-    try {
-      const result = await runValidation();
-      if (result?.valid) {
-        Message.success(t('topic.validateSuccess'));
-      } else {
-        Message.error(t('topic.validateFailed'));
-      }
-    } catch (err: any) {
-      Message.error(err.message || t('topic.validateFailed'));
-    } finally {
-      validating.value = false;
-    }
-  };
-
-  const handleSubmit = async () => {
-    const res = await formRef.value?.validate();
-    if (res) {
-      return;
-    }
-
-    submitting.value = true;
-    try {
-      const result = await runValidation();
-      if (!result?.valid) {
-        Message.error(t('topic.validateFailed'));
-        return;
-      }
-
-      const payload = normalizeTopicPayload();
-      if (isEdit.value) {
-        await updateTopicFeed(payload.id, payload);
-        Message.success(t('topic.updateSuccess'));
-      } else {
-        await createTopicFeed(payload);
-        Message.success(t('topic.createSuccess'));
-      }
-      modalVisible.value = false;
-      await fetchTopics();
-    } catch (err: any) {
-      Message.error(err.message || t('topic.saveFailed'));
-    } finally {
-      submitting.value = false;
-    }
-  };
-
   const goToDetail = (id: string) => {
     router.push({ name: 'TopicFeedDetail', params: { id } });
   };
@@ -789,83 +173,3 @@
     name: 'TopicFeed',
   };
 </script>
-
-<style scoped>
-  .input-sources-container,
-  .steps-container {
-    display: flex;
-    flex-direction: column;
-    gap: 12px;
-    width: 100%;
-  }
-
-  .input-source-card,
-  .step-card {
-    background-color: var(--color-fill-1);
-    border: 1px solid var(--color-border-1);
-    border-radius: 6px;
-    padding: 12px 16px;
-    transition: all 0.2s ease;
-  }
-
-  .input-source-card:hover,
-  .step-card:hover {
-    border-color: var(--color-border-3);
-    background-color: var(--color-fill-2);
-  }
-
-  .input-source-card {
-    display: grid;
-    grid-template-columns: auto 1fr auto;
-    gap: 12px;
-    align-items: center;
-  }
-
-  .input-source-card :deep(.arco-radio-group) {
-    white-space: nowrap;
-    flex-shrink: 0;
-  }
-
-  .step-card {
-    display: flex;
-    flex-direction: column;
-    gap: 8px;
-  }
-
-  .editor-row {
-    display: flex;
-    gap: 12px;
-    align-items: center;
-    width: 100%;
-  }
-
-  .step-hint {
-    margin: 4px 0 0 0;
-    padding-left: 4px;
-    font-size: 12px;
-    color: var(--color-text-3);
-    line-height: 1.5;
-  }
-
-  .remove-btn {
-    flex-shrink: 0;
-  }
-
-  .add-btn {
-    margin-top: 4px;
-  }
-
-  .option-id {
-    font-weight: 500;
-  }
-
-  .option-desc {
-    color: var(--color-text-3);
-    margin-left: 2px;
-    font-size: 12px;
-  }
-
-  .validation-item {
-    margin-top: 6px;
-  }
-</style>

From 0e2b9d02bfdf14fb11082b40f40014283b6d929e Mon Sep 17 00:00:00 2001
From: Cursor Agent <cursoragent@cursor.com>
Date: Mon, 1 Jun 2026 08:01:45 +0000
Subject: [PATCH 2/4] feat(topic-feed): add disabled flag for sub-feed inputs

Persist optional disabled on each input; runtime uses only enabled URIs.
Detail page supports toggling disable without opening the full editor.

Co-authored-by: Colin <Colin_XKL@outlook.com>
---
 internal/controller/topic_feed.go             |  16 +-
 internal/dao/topic.go                         |   9 +-
 internal/dao/topic_test.go                    |  24 +++
 web/admin/src/api/topic.ts                    |   1 +
 web/admin/src/locale/en-US/topic.ts           |   8 +
 web/admin/src/locale/zh-CN/topic.ts           |   7 +
 .../components/TopicInputSourcesEditor.vue    |  62 ++++++--
 .../src/views/dashboard/topic_feed/detail.vue | 144 +++++++++++++++---
 .../src/views/dashboard/topic_feed/editor.vue |  13 +-
 .../dashboard/topic_feed/topicInputUtils.ts   |  20 ++-
 10 files changed, 260 insertions(+), 44 deletions(-)

diff --git a/internal/controller/topic_feed.go b/internal/controller/topic_feed.go
index f9fbe679..34b1679e 100644
--- a/internal/controller/topic_feed.go
+++ b/internal/controller/topic_feed.go
@@ -222,9 +222,9 @@ func GetTopicFeedDetail(c *gin.Context) {
 		return
 	}
 
-	subFeedHealth := make([]feedruntime.SubFeedHealth, 0, len(topicData.InputURIs))
-	for _, uri := range topicData.InputURIs {
-		subFeedHealth = append(subFeedHealth, feedruntime.GetSubFeedHealth(uri))
+	subFeedHealth := make([]feedruntime.SubFeedHealth, 0, len(topicData.Inputs))
+	for _, input := range topicData.Inputs {
+		subFeedHealth = append(subFeedHealth, feedruntime.GetSubFeedHealth(input.URI))
 	}
 
 	detail := TopicDetailResponse{
@@ -308,16 +308,16 @@ func validateTopicConfig(ctx context.Context, db *gorm.DB, topicData *dao.TopicF
 	if len(topicData.InputURIs) == 0 {
 		result.Valid = false
 		result.Errors = append(result.Errors, TopicValidationIssue{
-			Field:   "input_uris",
-			Message: "At least one input source is required",
+			Field:   "inputs",
+			Message: "At least one enabled input source is required",
 		})
 	}
 
-	for idx, uri := range topicData.InputURIs {
-		if strings.TrimSpace(uri) == "" {
+	for idx, input := range topicData.Inputs {
+		if strings.TrimSpace(input.URI) == "" {
 			result.Valid = false
 			result.Errors = append(result.Errors, TopicValidationIssue{
-				Field:   fmt.Sprintf("input_uris[%d]", idx),
+				Field:   fmt.Sprintf("inputs[%d].uri", idx),
 				Message: "Input URI cannot be empty",
 			})
 		}
diff --git a/internal/dao/topic.go b/internal/dao/topic.go
index 39c1c964..ed6b4ff0 100644
--- a/internal/dao/topic.go
+++ b/internal/dao/topic.go
@@ -6,10 +6,12 @@ import (
 	"gorm.io/gorm"
 )
 
-// TopicInput is a single upstream source with an optional admin label.
+// TopicInput is a single upstream source with optional admin metadata.
 type TopicInput struct {
 	URI         string `json:"uri"`
 	Description string `json:"description,omitempty"`
+	// Disabled excludes this input from topic aggregation when true.
+	Disabled bool `json:"disabled,omitempty"`
 }
 
 // TopicFeed represents the persistence model for a multi-source aggregation node.
@@ -49,10 +51,13 @@ func (t *TopicFeed) NormalizeInputs() {
 			if uri == "" {
 				continue
 			}
-			uris = append(uris, uri)
+			if !item.Disabled {
+				uris = append(uris, uri)
+			}
 			normalized = append(normalized, TopicInput{
 				URI:         uri,
 				Description: strings.TrimSpace(item.Description),
+				Disabled:    item.Disabled,
 			})
 		}
 		t.InputURIs = uris
diff --git a/internal/dao/topic_test.go b/internal/dao/topic_test.go
index a932031c..9c2f1ad4 100644
--- a/internal/dao/topic_test.go
+++ b/internal/dao/topic_test.go
@@ -26,6 +26,30 @@ func TestTopicFeed_NormalizeInputs_FromInputs(t *testing.T) {
 	}
 }
 
+func TestTopicFeed_NormalizeInputs_SkipsDisabled(t *testing.T) {
+	topic := &TopicFeed{
+		Inputs: []TopicInput{
+			{URI: "https://example.com/enabled.xml"},
+			{URI: "https://example.com/disabled.xml", Disabled: true},
+		},
+	}
+
+	topic.NormalizeInputs()
+
+	if len(topic.InputURIs) != 1 {
+		t.Fatalf("expected 1 enabled URI, got %d", len(topic.InputURIs))
+	}
+	if topic.InputURIs[0] != "https://example.com/enabled.xml" {
+		t.Fatalf("unexpected enabled URI: %q", topic.InputURIs[0])
+	}
+	if len(topic.Inputs) != 2 {
+		t.Fatalf("expected 2 inputs retained, got %d", len(topic.Inputs))
+	}
+	if !topic.Inputs[1].Disabled {
+		t.Fatal("expected second input to stay disabled")
+	}
+}
+
 func TestTopicFeed_NormalizeInputs_FromLegacyURIs(t *testing.T) {
 	topic := &TopicFeed{
 		InputURIs: []string{"https://example.com/a.xml", "https://example.com/b.xml"},
diff --git a/web/admin/src/api/topic.ts b/web/admin/src/api/topic.ts
index 23fe6560..892d196a 100644
--- a/web/admin/src/api/topic.ts
+++ b/web/admin/src/api/topic.ts
@@ -14,6 +14,7 @@ export interface AggregatorStep {
 export interface TopicInput {
   uri: string;
   description?: string;
+  disabled?: boolean;
 }
 
 export interface TopicFeed {
diff --git a/web/admin/src/locale/en-US/topic.ts b/web/admin/src/locale/en-US/topic.ts
index 9290ab90..fb4a6d05 100644
--- a/web/admin/src/locale/en-US/topic.ts
+++ b/web/admin/src/locale/en-US/topic.ts
@@ -41,6 +41,14 @@ export default {
   'topic.addInput': 'Add Input',
   'topic.inputDescription.placeholder':
     'Label for this input (optional, helps you recognize it later)',
+  'topic.inputDisabled.label': 'Disabled',
+  'topic.inputDisabled.badge': 'Disabled',
+  'topic.inputDisabled.hint':
+    'Disabled inputs are excluded from aggregation but kept in config. You can re-enable them anytime.',
+  'topic.inputDisabled.lastEnabled':
+    'At least one input source must stay enabled',
+  'topic.inputDisabled.disabledSuccess': 'Input source disabled',
+  'topic.inputDisabled.enabledSuccess': 'Input source enabled',
   'topic.inputPreview': 'Preview',
   'topic.inputPreview.title': 'Input #{index}',
   'topic.inputPreview.currentUri': 'Preview URI',
diff --git a/web/admin/src/locale/zh-CN/topic.ts b/web/admin/src/locale/zh-CN/topic.ts
index 4c6fd8d6..0b9f7064 100644
--- a/web/admin/src/locale/zh-CN/topic.ts
+++ b/web/admin/src/locale/zh-CN/topic.ts
@@ -39,6 +39,13 @@ export default {
   'topic.inputPlaceholder': '例如 feedcraft://recipe/my-recipe',
   'topic.addInput': '添加输入源',
   'topic.inputDescription.placeholder': '备注名称，便于识别此输入源（可选）',
+  'topic.inputDisabled.label': '禁用',
+  'topic.inputDisabled.badge': '已禁用',
+  'topic.inputDisabled.hint':
+    '禁用后该子 Feed 不会参与聚合输出，配置仍保留，可随时重新启用。',
+  'topic.inputDisabled.lastEnabled': '至少需要保留一个启用的输入源',
+  'topic.inputDisabled.disabledSuccess': '已禁用该输入源',
+  'topic.inputDisabled.enabledSuccess': '已重新启用该输入源',
   'topic.inputPreview': '预览',
   'topic.inputPreview.title': '输入源 #{index}',
   'topic.inputPreview.currentUri': '当前预览地址',
diff --git a/web/admin/src/views/dashboard/topic_feed/components/TopicInputSourcesEditor.vue b/web/admin/src/views/dashboard/topic_feed/components/TopicInputSourcesEditor.vue
index f889ef2e..50f2c405 100644
--- a/web/admin/src/views/dashboard/topic_feed/components/TopicInputSourcesEditor.vue
+++ b/web/admin/src/views/dashboard/topic_feed/components/TopicInputSourcesEditor.vue
@@ -4,6 +4,7 @@
       v-for="(source, idx) in modelValue"
       :key="`source-${idx}`"
       class="input-source-card"
+      :class="{ 'input-source-card--disabled': source.disabled }"
     >
       <div class="source-header">
         <a-radio-group
@@ -17,10 +18,20 @@
           <a-radio value="recipe">Recipe</a-radio>
           <a-radio value="topic">Topic</a-radio>
         </a-radio-group>
-        <a-space>
+        <a-space wrap>
+          <div v-if="showDisabledToggle" class="disable-toggle">
+            <span class="disable-toggle-label">{{
+              t('topic.inputDisabled.label')
+            }}</span>
+            <a-switch
+              :model-value="source.disabled"
+              size="small"
+              @change="(value: boolean) => setDisabled(idx, value)"
+            />
+          </div>
           <a-button
             size="small"
-            :disabled="!canPreviewSource(source)"
+            :disabled="!canPreviewSource(source) || source.disabled"
             :loading="previewingIndex === idx"
             @click="openPreview(idx)"
           >
@@ -134,13 +145,19 @@
     sourceToUri,
   } from '../topicInputUtils';
 
-  const props = defineProps<{
-    modelValue: InputSourceItem[];
-    availableRecipes: CustomRecipe[];
-    availableTopics: TopicFeed[];
-    pickerLoading?: boolean;
-    excludeTopicId?: string;
-  }>();
+  const props = withDefaults(
+    defineProps<{
+      modelValue: InputSourceItem[];
+      availableRecipes: CustomRecipe[];
+      availableTopics: TopicFeed[];
+      pickerLoading?: boolean;
+      excludeTopicId?: string;
+      showDisabledToggle?: boolean;
+    }>(),
+    {
+      showDisabledToggle: true,
+    }
+  );
 
   const emit = defineEmits<{
     (event: 'update:modelValue', value: InputSourceItem[]): void;
@@ -176,10 +193,17 @@
         externalUrl: '',
         resourceId: '',
         description: '',
+        disabled: false,
       },
     ]);
   };
 
+  const setDisabled = (idx: number, disabled: boolean) => {
+    const next = [...props.modelValue];
+    next[idx] = { ...next[idx], disabled };
+    updateSources(next);
+  };
+
   const removeSource = (idx: number) => {
     const next = [...props.modelValue];
     next.splice(idx, 1);
@@ -189,6 +213,7 @@
         externalUrl: '',
         resourceId: '',
         description: '',
+        disabled: false,
       });
     }
     updateSources(next);
@@ -196,11 +221,13 @@
 
   const onSourceTypeChange = (idx: number, sourceType: SourceType) => {
     const next = [...props.modelValue];
+    const current = next[idx];
     next[idx] = {
       sourceType,
       externalUrl: '',
       resourceId: '',
-      description: next[idx]?.description || '',
+      description: current?.description || '',
+      disabled: current?.disabled || false,
     };
     updateSources(next);
   };
@@ -256,6 +283,21 @@
     background-color: var(--color-fill-2);
   }
 
+  .input-source-card--disabled {
+    opacity: 0.72;
+  }
+
+  .disable-toggle {
+    display: inline-flex;
+    align-items: center;
+    gap: 8px;
+  }
+
+  .disable-toggle-label {
+    font-size: 12px;
+    color: var(--color-text-3);
+  }
+
   .source-header {
     display: flex;
     justify-content: space-between;
diff --git a/web/admin/src/views/dashboard/topic_feed/detail.vue b/web/admin/src/views/dashboard/topic_feed/detail.vue
index 1b7a51f5..9e1194c8 100644
--- a/web/admin/src/views/dashboard/topic_feed/detail.vue
+++ b/web/admin/src/views/dashboard/topic_feed/detail.vue
@@ -24,10 +24,14 @@
               </a-statistic>
             </a-col>
             <a-col :span="8">
-              <a-statistic
-                :title="t('topic.inputCount')"
-                :value="detail.topic.input_uris.length"
-              />
+              <a-statistic :title="t('topic.inputCount')">
+                <template #value>
+                  {{ enabledInputCount }}
+                  <span v-if="disabledInputCount > 0" class="input-count-muted">
+                    / {{ topicInputs.length }}
+                  </span>
+                </template>
+              </a-statistic>
             </a-col>
             <a-col :span="8">
               <a-statistic
@@ -80,17 +84,60 @@
           <a-row :gutter="16">
             <a-col :span="12">
               <div class="section-label">{{ t('topic.inputs') }}</div>
-              <a-list bordered>
-                <a-list-item
-                  v-for="(input, idx) in topicInputs"
-                  :key="`${input.uri}-${idx}`"
-                >
-                  <a-list-item-meta
-                    :title="input.description || input.uri"
-                    :description="input.description ? input.uri : undefined"
-                  />
-                </a-list-item>
-              </a-list>
+              <a-alert
+                type="info"
+                class="mb-3"
+                :title="t('topic.inputDisabled.hint')"
+              />
+              <a-table
+                :data="topicInputs"
+                :pagination="false"
+                row-key="uri"
+                size="small"
+              >
+                <template #columns>
+                  <a-table-column
+                    :title="t('topic.inputDescription.placeholder')"
+                    :ellipsis="true"
+                  >
+                    <template #cell="{ record }">
+                      <span :class="{ 'input-disabled': record.disabled }">
+                        {{ record.description || record.uri }}
+                      </span>
+                    </template>
+                  </a-table-column>
+                  <a-table-column
+                    :title="t('topic.detail.subFeedHealth.uri')"
+                    :ellipsis="true"
+                  >
+                    <template #cell="{ record }">
+                      <span
+                        class="sub-feed-uri"
+                        :class="{ 'input-disabled': record.disabled }"
+                        :title="record.uri"
+                      >
+                        {{ record.uri }}
+                      </span>
+                    </template>
+                  </a-table-column>
+                  <a-table-column
+                    :title="t('topic.inputDisabled.label')"
+                    :width="100"
+                    align="center"
+                  >
+                    <template #cell="{ record }">
+                      <a-switch
+                        :model-value="record.disabled"
+                        :loading="inputToggleSavingUri === record.uri"
+                        @change="
+                          (value: boolean) =>
+                            toggleInputDisabled(record.uri, value)
+                        "
+                      />
+                    </template>
+                  </a-table-column>
+                </template>
+              </a-table>
             </a-col>
             <a-col :span="12">
               <div class="section-label">{{ t('topic.aggregatorConfig') }}</div>
@@ -308,7 +355,9 @@
     AggregatorStep,
     SubFeedHealth,
     TopicDetail,
+    TopicInput,
     getTopicFeedDetail,
+    updateTopicFeed,
   } from '@/api/topic';
 
   const { t } = useI18n();
@@ -318,17 +367,67 @@
   const detail = ref<TopicDetail | null>(null);
   const detailsModalVisible = ref(false);
   const selectedExecutionDetails = ref('');
+  const inputToggleSavingUri = ref('');
   const publicUrl = computed(() =>
     detail.value ? buildPublicFeedUrl(detail.value.public_url) : ''
   );
 
-  const topicInputs = computed(() => {
+  const topicInputs = computed((): TopicInput[] => {
     if (!detail.value) return [];
     const { topic } = detail.value;
     if (topic.inputs?.length) return topic.inputs;
-    return topic.input_uris.map((uri) => ({ uri, description: '' }));
+    return topic.input_uris.map((uri) => ({
+      uri,
+      description: '',
+      disabled: false,
+    }));
   });
 
+  const enabledInputCount = computed(
+    () => topicInputs.value.filter((input) => !input.disabled).length
+  );
+
+  const disabledInputCount = computed(
+    () => topicInputs.value.filter((input) => input.disabled).length
+  );
+
+  const toggleInputDisabled = async (uri: string, disabled: boolean) => {
+    if (!detail.value) return;
+
+    const nextInputs = topicInputs.value.map((input) =>
+      input.uri === uri ? { ...input, disabled } : input
+    );
+    const enabledCount = nextInputs.filter((input) => !input.disabled).length;
+    if (enabledCount === 0) {
+      Message.warning(t('topic.inputDisabled.lastEnabled'));
+      return;
+    }
+
+    const { topic } = detail.value;
+    const payload = {
+      ...topic,
+      inputs: nextInputs,
+      input_uris: nextInputs
+        .filter((input) => !input.disabled)
+        .map((input) => input.uri),
+    };
+
+    inputToggleSavingUri.value = uri;
+    try {
+      await updateTopicFeed(topic.id, payload);
+      Message.success(
+        disabled
+          ? t('topic.inputDisabled.disabledSuccess')
+          : t('topic.inputDisabled.enabledSuccess')
+      );
+      await fetchDetail();
+    } catch (err: any) {
+      Message.error(err.message || t('topic.saveFailed'));
+    } finally {
+      inputToggleSavingUri.value = '';
+    }
+  };
+
   const formatTime = (value?: string) => {
     if (!value) return '-';
     return new Date(value).toLocaleString();
@@ -496,4 +595,15 @@
     color: var(--color-danger-6, #f53f3f);
     font-size: 12px;
   }
+
+  .input-count-muted {
+    font-size: 14px;
+    color: var(--color-text-3);
+    font-weight: normal;
+  }
+
+  .input-disabled {
+    color: var(--color-text-3);
+    text-decoration: line-through;
+  }
 </style>
diff --git a/web/admin/src/views/dashboard/topic_feed/editor.vue b/web/admin/src/views/dashboard/topic_feed/editor.vue
index a788b221..c511e1db 100644
--- a/web/admin/src/views/dashboard/topic_feed/editor.vue
+++ b/web/admin/src/views/dashboard/topic_feed/editor.vue
@@ -111,6 +111,11 @@
                   :title="source.description || source.uri"
                   :description="source.description ? source.uri : undefined"
                 />
+                <template #actions>
+                  <a-tag v-if="source.disabled" color="gray">
+                    {{ t('topic.inputDisabled.badge') }}
+                  </a-tag>
+                </template>
               </a-list-item>
             </a-list>
 
@@ -198,8 +203,8 @@
   import {
     defaultFormData,
     formatAggregatorSummary,
+    countEnabledInputs,
     normalizeTopicPayload,
-    sourceToUri,
     topicFeedToFormData,
     type TopicFormData,
   } from './topicInputUtils';
@@ -229,10 +234,8 @@
   const availableTopics = ref<TopicFeed[]>([]);
   const pickerLoading = ref(false);
 
-  const configuredInputCount = computed(
-    () =>
-      formData.value.inputSources.filter((source) => sourceToUri(source) !== '')
-        .length
+  const configuredInputCount = computed(() =>
+    countEnabledInputs(formData.value.inputSources)
   );
 
   const reviewInputs = computed(
diff --git a/web/admin/src/views/dashboard/topic_feed/topicInputUtils.ts b/web/admin/src/views/dashboard/topic_feed/topicInputUtils.ts
index 0005b0fa..eb4a4d5c 100644
--- a/web/admin/src/views/dashboard/topic_feed/topicInputUtils.ts
+++ b/web/admin/src/views/dashboard/topic_feed/topicInputUtils.ts
@@ -13,6 +13,7 @@ export interface InputSourceItem {
   externalUrl: string;
   resourceId: string;
   description: string;
+  disabled: boolean;
 }
 
 export interface StepFormItem {
@@ -51,6 +52,7 @@ export const defaultFormData = (): TopicFormData => ({
       externalUrl: '',
       resourceId: '',
       description: '',
+      disabled: false,
     },
   ],
   aggregator_config: [],
@@ -62,6 +64,7 @@ export const parseUriToSource = (
   const uri = typeof input === 'string' ? input : input.uri;
   const description =
     typeof input === 'string' ? '' : input.description?.trim() || '';
+  const disabled = typeof input === 'string' ? false : Boolean(input.disabled);
 
   if (uri.startsWith('feedcraft://recipe/')) {
     return {
@@ -69,6 +72,7 @@ export const parseUriToSource = (
       externalUrl: '',
       resourceId: uri.slice('feedcraft://recipe/'.length),
       description,
+      disabled,
     };
   }
   if (uri.startsWith('feedcraft://topic/')) {
@@ -77,6 +81,7 @@ export const parseUriToSource = (
       externalUrl: '',
       resourceId: uri.slice('feedcraft://topic/'.length),
       description,
+      disabled,
     };
   }
   return {
@@ -84,6 +89,7 @@ export const parseUriToSource = (
     externalUrl: uri,
     resourceId: '',
     description,
+    disabled,
   };
 };
 
@@ -97,11 +103,19 @@ export const sourceToUri = (source: InputSourceItem): string => {
   return source.externalUrl.trim();
 };
 
+export const countEnabledInputs = (sources: InputSourceItem[]): number =>
+  sources.filter((source) => sourceToUri(source) !== '' && !source.disabled)
+    .length;
+
 export const topicFeedToFormData = (record: TopicFeed): TopicFormData => {
   const inputs =
     record.inputs && record.inputs.length > 0
       ? record.inputs
-      : record.input_uris.map((uri) => ({ uri, description: '' }));
+      : record.input_uris.map((uri) => ({
+          uri,
+          description: '',
+          disabled: false,
+        }));
 
   return {
     id: record.id,
@@ -116,6 +130,7 @@ export const topicFeedToFormData = (record: TopicFeed): TopicFormData => {
               externalUrl: '',
               resourceId: '',
               description: '',
+              disabled: false,
             },
           ],
     aggregator_config: (record.aggregator_config || []).map((step) => {
@@ -147,6 +162,7 @@ export const normalizeTopicPayload = (formData: TopicFormData): TopicFeed => {
     .map((source) => ({
       uri: sourceToUri(source),
       description: source.description.trim(),
+      disabled: source.disabled,
     }))
     .filter((item) => item.uri !== '');
 
@@ -155,7 +171,7 @@ export const normalizeTopicPayload = (formData: TopicFormData): TopicFeed => {
     title: formData.title.trim(),
     description: formData.description.trim(),
     inputs,
-    input_uris: inputs.map((item) => item.uri),
+    input_uris: inputs.filter((item) => !item.disabled).map((item) => item.uri),
     aggregator_config: formData.aggregator_config.map((step) => {
       const option: Record<string, string> = {};
       if (step.type === 'deduplicate') {

From b2e2a1283a0554deac74518079728ed2adc931fe Mon Sep 17 00:00:00 2001
From: Cursor Agent <cursoragent@cursor.com>
Date: Mon, 1 Jun 2026 11:23:47 +0000
Subject: [PATCH 3/4] refactor(topic-feed): persist only structured inputs

Co-authored-by: Colin <Colin_XKL@outlook.com>
---
 internal/controller/feed_viewer_test.go       |  2 +-
 internal/controller/topic_feed.go             |  2 +-
 internal/controller/topic_feed_public_test.go | 28 +++----
 internal/dao/migrate.go                       | 56 ++++++++++++++
 internal/dao/topic.go                         | 66 ++++++-----------
 internal/dao/topic_test.go                    | 74 ++++++++++++++-----
 internal/feedruntime/builder.go               |  5 +-
 internal/feedruntime/builder_test.go          | 20 ++---
 web/admin/src/api/topic.ts                    |  3 +-
 .../src/views/dashboard/topic_feed/detail.vue | 13 +---
 .../dashboard/topic_feed/topicInputUtils.ts   | 10 +--
 .../views/dashboard/topic_feed/topic_feed.vue |  3 +-
 12 files changed, 170 insertions(+), 112 deletions(-)

diff --git a/internal/controller/feed_viewer_test.go b/internal/controller/feed_viewer_test.go
index 0c18fc16..809cc23a 100644
--- a/internal/controller/feed_viewer_test.go
+++ b/internal/controller/feed_viewer_test.go
@@ -158,7 +158,7 @@ func TestPreviewFeedViewerSupportsTopicURI(t *testing.T) {
 		ID:          topicID,
 		Title:       "Preview Topic",
 		Description: "Topic preview",
-		InputURIs:   []string{"feedcraft://recipe/" + recipeID},
+		Inputs:      []dao.TopicInput{{URI: "feedcraft://recipe/" + recipeID}},
 	})
 
 	recorder := performFeedViewerPreviewRequest(t, http.MethodGet, "feedcraft://topic/"+topicID)
diff --git a/internal/controller/topic_feed.go b/internal/controller/topic_feed.go
index 34b1679e..3fb37723 100644
--- a/internal/controller/topic_feed.go
+++ b/internal/controller/topic_feed.go
@@ -305,7 +305,7 @@ func validateTopicConfig(ctx context.Context, db *gorm.DB, topicData *dao.TopicF
 		return result, nil
 	}
 
-	if len(topicData.InputURIs) == 0 {
+	if len(topicData.EnabledInputURIs()) == 0 {
 		result.Valid = false
 		result.Errors = append(result.Errors, TopicValidationIssue{
 			Field:   "inputs",
diff --git a/internal/controller/topic_feed_public_test.go b/internal/controller/topic_feed_public_test.go
index 2918f2e1..696e3cb6 100644
--- a/internal/controller/topic_feed_public_test.go
+++ b/internal/controller/topic_feed_public_test.go
@@ -76,7 +76,7 @@ func TestPublicTopicFeed(t *testing.T) {
 			ID:          topicID,
 			Title:       "My Topic",
 			Description: "Topic description",
-			InputURIs:   []string{"feedcraft://recipe/" + recipeID},
+			Inputs:      []dao.TopicInput{{URI: "feedcraft://recipe/" + recipeID}},
 		})
 
 		req, err := http.NewRequest(http.MethodGet, "/topic/"+topicID, nil)
@@ -105,9 +105,9 @@ func TestPublicTopicFeed(t *testing.T) {
 	t.Run("returns 500 when topic build fails", func(t *testing.T) {
 		topicID := uniqueTestID("topic-invalid")
 		createTopicTestTopic(t, db, &dao.TopicFeed{
-			ID:        topicID,
-			Title:     "Broken Topic",
-			InputURIs: []string{"feedcraft://broken/abc"},
+			ID:     topicID,
+			Title:  "Broken Topic",
+			Inputs: []dao.TopicInput{{URI: "feedcraft://broken/abc"}},
 		})
 
 		req, err := http.NewRequest(http.MethodGet, "/topic/"+topicID, nil)
@@ -125,9 +125,9 @@ func TestPublicTopicFeed(t *testing.T) {
 		topicID := uniqueTestID("topic-partial")
 		createTopicTestRecipe(t, db, recipeID)
 		createTopicTestTopic(t, db, &dao.TopicFeed{
-			ID:        topicID,
-			Title:     "Partial Topic",
-			InputURIs: []string{"feedcraft://recipe/" + recipeID, "http://127.0.0.1:1/unreachable.xml"},
+			ID:     topicID,
+			Title:  "Partial Topic",
+			Inputs: []dao.TopicInput{{URI: "feedcraft://recipe/" + recipeID}, {URI: "http://127.0.0.1:1/unreachable.xml"}},
 		})
 
 		req, err := http.NewRequest(http.MethodGet, "/topic/"+topicID, nil)
@@ -144,9 +144,9 @@ func TestPublicTopicFeed(t *testing.T) {
 	t.Run("returns 500 when all upstreams fail", func(t *testing.T) {
 		topicID := uniqueTestID("topic-all-failed")
 		createTopicTestTopic(t, db, &dao.TopicFeed{
-			ID:        topicID,
-			Title:     "Failed Topic",
-			InputURIs: []string{"http://127.0.0.1:1/a.xml", "http://127.0.0.1:1/b.xml"},
+			ID:     topicID,
+			Title:  "Failed Topic",
+			Inputs: []dao.TopicInput{{URI: "http://127.0.0.1:1/a.xml"}, {URI: "http://127.0.0.1:1/b.xml"}},
 		})
 
 		req, err := http.NewRequest(http.MethodGet, "/topic/"+topicID, nil)
@@ -182,7 +182,7 @@ func TestTopicFeedAdminEndpoints(t *testing.T) {
 		body := `{
 			"id":"` + uniqueTestID("topic-validate-ok") + `",
 			"title":"Tech Topic",
-			"input_uris":["feedcraft://recipe/` + recipeID + `"],
+			"inputs":[{"uri":"feedcraft://recipe/` + recipeID + `"}],
 			"aggregator_config":[{"type":"limit","option":{"max":"10"}}]
 		}`
 
@@ -206,7 +206,7 @@ func TestTopicFeedAdminEndpoints(t *testing.T) {
 		body := `{
 			"id":"` + uniqueTestID("topic-invalid-step") + `",
 			"title":"Broken Step Topic",
-			"input_uris":["feedcraft://recipe/` + recipeID + `"],
+			"inputs":[{"uri":"feedcraft://recipe/` + recipeID + `"}],
 			"aggregator_config":[{"type":"limit","option":{"max":"0"}}]
 		}`
 
@@ -230,7 +230,7 @@ func TestTopicFeedAdminEndpoints(t *testing.T) {
 		body := `{
 			"id":"` + topicID + `",
 			"title":"Cycle Topic",
-			"input_uris":["feedcraft://topic/` + topicID + `"],
+			"inputs":[{"uri":"feedcraft://topic/` + topicID + `"}],
 			"aggregator_config":[{"type":"limit","option":{"max":"10"}}]
 		}`
 
@@ -255,7 +255,7 @@ func TestTopicFeedAdminEndpoints(t *testing.T) {
 			ID:          topicID,
 			Title:       "Detail Topic",
 			Description: "detail description",
-			InputURIs:   []string{"https://example.com/feed.xml"},
+			Inputs:      []dao.TopicInput{{URI: "https://example.com/feed.xml"}},
 			AggregatorConfig: []dao.AggregatorStep{
 				{Type: "limit", Option: map[string]string{"max": "20"}},
 			},
diff --git a/internal/dao/migrate.go b/internal/dao/migrate.go
index a5176c28..330838de 100644
--- a/internal/dao/migrate.go
+++ b/internal/dao/migrate.go
@@ -35,6 +35,7 @@ func MigrateDatabases() {
 
 	// Perform data migration from custom_recipes to custom_recipes_v2
 	migrateRecipesToV2(db)
+	migrateTopicFeedInputs(db)
 
 	logrus.Info("migrate database done.")
 
@@ -98,6 +99,61 @@ func migrateRecipesToV2(db *gorm.DB) {
 	logrus.Info("recipe migration to v2 completed.")
 }
 
+func migrateTopicFeedInputs(db *gorm.DB) {
+	if !db.Migrator().HasTable(&TopicFeed{}) {
+		return
+	}
+	if !db.Migrator().HasColumn("topic_feeds", "input_uris") {
+		return
+	}
+
+	type legacyTopicInputRow struct {
+		ID        string
+		Inputs    string
+		InputURIs string
+	}
+
+	var rows []legacyTopicInputRow
+	if err := db.Table("topic_feeds").Select("id, inputs, input_uris").Scan(&rows).Error; err != nil {
+		logrus.Errorf("failed to scan topic feed input_uris migration rows: %v", err)
+		return
+	}
+
+	for _, row := range rows {
+		if row.InputURIs == "" || row.InputURIs == "null" || row.InputURIs == "[]" {
+			continue
+		}
+		if row.Inputs != "" && row.Inputs != "null" && row.Inputs != "[]" {
+			continue
+		}
+
+		var uris []string
+		if err := json.Unmarshal([]byte(row.InputURIs), &uris); err != nil {
+			logrus.Errorf("failed to unmarshal legacy input_uris for topic %s: %v", row.ID, err)
+			continue
+		}
+
+		inputs := make([]TopicInput, 0, len(uris))
+		for _, uri := range uris {
+			inputs = append(inputs, TopicInput{URI: uri})
+		}
+		inputsJSON, err := json.Marshal(inputs)
+		if err != nil {
+			logrus.Errorf("failed to marshal migrated inputs for topic %s: %v", row.ID, err)
+			continue
+		}
+		if err := db.Table("topic_feeds").Where("id = ?", row.ID).Update("inputs", string(inputsJSON)).Error; err != nil {
+			logrus.Errorf("failed to migrate topic inputs for topic %s: %v", row.ID, err)
+		}
+	}
+
+	if err := db.Exec("ALTER TABLE topic_feeds DROP COLUMN input_uris").Error; err != nil {
+		logrus.Errorf("failed to drop legacy topic input_uris column: %v", err)
+		return
+	}
+	logrus.Info("topic feed input_uris migration completed.")
+}
+
 var defaultAdminUsername = "admin"
 var defaultPassword = "adminadmin" // default defaultPassword string
 
diff --git a/internal/dao/topic.go b/internal/dao/topic.go
index ed6b4ff0..bdb8da69 100644
--- a/internal/dao/topic.go
+++ b/internal/dao/topic.go
@@ -24,65 +24,45 @@ type TopicFeed struct {
 	// Inputs carries URI plus optional description for admin display.
 	Inputs []TopicInput `json:"inputs,omitempty" gorm:"serializer:json"`
 
-	// List of URIs representing inputs (derived from Inputs for runtime).
-	// Uses a custom protocol for internal resources to make routing elegant and standard.
-	// Examples:
-	//   - "feedcraft://recipe/my-tech-recipe" (Internal RecipeFeed)
-	//   - "feedcraft://topic/sub-topic-id"    (Nested internal TopicFeed)
-	//   - "https://external.com/rss.xml"      (External raw feed)
-	InputURIs []string `json:"input_uris" gorm:"serializer:json"`
-
 	// Configuration for the aggregator pipeline
 	AggregatorConfig []AggregatorStep `json:"aggregator_config" gorm:"serializer:json"`
 }
 
-// NormalizeInputs keeps Inputs and InputURIs in sync.
-// When Inputs is provided it becomes the source of truth; otherwise legacy InputURIs are upgraded.
+// NormalizeInputs trims input metadata and removes blank URIs.
 func (t *TopicFeed) NormalizeInputs() {
 	if t == nil {
 		return
 	}
 
-	if len(t.Inputs) > 0 {
-		uris := make([]string, 0, len(t.Inputs))
-		normalized := make([]TopicInput, 0, len(t.Inputs))
-		for _, item := range t.Inputs {
-			uri := strings.TrimSpace(item.URI)
-			if uri == "" {
-				continue
-			}
-			if !item.Disabled {
-				uris = append(uris, uri)
-			}
-			normalized = append(normalized, TopicInput{
-				URI:         uri,
-				Description: strings.TrimSpace(item.Description),
-				Disabled:    item.Disabled,
-			})
+	normalized := make([]TopicInput, 0, len(t.Inputs))
+	for _, item := range t.Inputs {
+		uri := strings.TrimSpace(item.URI)
+		if uri == "" {
+			continue
 		}
-		t.InputURIs = uris
-		t.Inputs = normalized
-		return
+		normalized = append(normalized, TopicInput{
+			URI:         uri,
+			Description: strings.TrimSpace(item.Description),
+			Disabled:    item.Disabled,
+		})
 	}
+	t.Inputs = normalized
+}
 
-	if len(t.InputURIs) == 0 {
-		t.Inputs = nil
-		return
+// EnabledInputURIs returns input URIs that participate in topic aggregation.
+func (t *TopicFeed) EnabledInputURIs() []string {
+	if t == nil {
+		return nil
 	}
-
-	inputs := make([]TopicInput, 0, len(t.InputURIs))
-	for _, uri := range t.InputURIs {
-		uri = strings.TrimSpace(uri)
-		if uri == "" {
+	uris := make([]string, 0, len(t.Inputs))
+	for _, item := range t.Inputs {
+		uri := strings.TrimSpace(item.URI)
+		if uri == "" || item.Disabled {
 			continue
 		}
-		inputs = append(inputs, TopicInput{URI: uri})
-	}
-	t.Inputs = inputs
-	t.InputURIs = make([]string, 0, len(inputs))
-	for _, item := range inputs {
-		t.InputURIs = append(t.InputURIs, item.URI)
+		uris = append(uris, uri)
 	}
+	return uris
 }
 
 // AggregatorStep defines a single processing step in an Aggregator pipeline.
diff --git a/internal/dao/topic_test.go b/internal/dao/topic_test.go
index 9c2f1ad4..c683de03 100644
--- a/internal/dao/topic_test.go
+++ b/internal/dao/topic_test.go
@@ -1,6 +1,11 @@
 package dao
 
-import "testing"
+import (
+	"testing"
+
+	"github.com/glebarez/sqlite"
+	"gorm.io/gorm"
+)
 
 func TestTopicFeed_NormalizeInputs_FromInputs(t *testing.T) {
 	topic := &TopicFeed{
@@ -12,14 +17,15 @@ func TestTopicFeed_NormalizeInputs_FromInputs(t *testing.T) {
 
 	topic.NormalizeInputs()
 
-	if len(topic.InputURIs) != 2 {
-		t.Fatalf("expected 2 input URIs, got %d", len(topic.InputURIs))
+	enabled := topic.EnabledInputURIs()
+	if len(enabled) != 2 {
+		t.Fatalf("expected 2 enabled input URIs, got %d", len(enabled))
 	}
-	if topic.InputURIs[0] != "https://example.com/a.xml" {
-		t.Fatalf("unexpected first URI: %q", topic.InputURIs[0])
+	if enabled[0] != "https://example.com/a.xml" {
+		t.Fatalf("unexpected first URI: %q", enabled[0])
 	}
-	if topic.InputURIs[1] != "feedcraft://recipe/foo" {
-		t.Fatalf("unexpected second URI: %q", topic.InputURIs[1])
+	if enabled[1] != "feedcraft://recipe/foo" {
+		t.Fatalf("unexpected second URI: %q", enabled[1])
 	}
 	if topic.Inputs[0].Description != "Tech news" {
 		t.Fatalf("unexpected description: %q", topic.Inputs[0].Description)
@@ -36,11 +42,12 @@ func TestTopicFeed_NormalizeInputs_SkipsDisabled(t *testing.T) {
 
 	topic.NormalizeInputs()
 
-	if len(topic.InputURIs) != 1 {
-		t.Fatalf("expected 1 enabled URI, got %d", len(topic.InputURIs))
+	enabled := topic.EnabledInputURIs()
+	if len(enabled) != 1 {
+		t.Fatalf("expected 1 enabled URI, got %d", len(enabled))
 	}
-	if topic.InputURIs[0] != "https://example.com/enabled.xml" {
-		t.Fatalf("unexpected enabled URI: %q", topic.InputURIs[0])
+	if enabled[0] != "https://example.com/enabled.xml" {
+		t.Fatalf("unexpected enabled URI: %q", enabled[0])
 	}
 	if len(topic.Inputs) != 2 {
 		t.Fatalf("expected 2 inputs retained, got %d", len(topic.Inputs))
@@ -50,17 +57,50 @@ func TestTopicFeed_NormalizeInputs_SkipsDisabled(t *testing.T) {
 	}
 }
 
-func TestTopicFeed_NormalizeInputs_FromLegacyURIs(t *testing.T) {
-	topic := &TopicFeed{
-		InputURIs: []string{"https://example.com/a.xml", "https://example.com/b.xml"},
+func TestMigrateTopicFeedInputs_FromLegacyInputURIs(t *testing.T) {
+	db, err := gorm.Open(sqlite.Open(":memory:"), &gorm.Config{})
+	if err != nil {
+		t.Fatalf("open sqlite: %v", err)
 	}
 
-	topic.NormalizeInputs()
+	if err := db.Exec(`
+		CREATE TABLE topic_feeds (
+			id TEXT PRIMARY KEY,
+			title TEXT,
+			input_uris TEXT,
+			aggregator_config TEXT,
+			created_at DATETIME,
+			updated_at DATETIME
+		)
+	`).Error; err != nil {
+		t.Fatalf("create legacy topic_feeds table: %v", err)
+	}
+	if err := db.Exec(
+		`INSERT INTO topic_feeds (id, title, input_uris, aggregator_config) VALUES (?, ?, ?, ?)`,
+		"legacy-topic",
+		"Legacy Topic",
+		`["https://example.com/a.xml","feedcraft://recipe/foo"]`,
+		`[]`,
+	).Error; err != nil {
+		t.Fatalf("insert legacy topic feed: %v", err)
+	}
 
+	if err := db.AutoMigrate(&TopicFeed{}); err != nil {
+		t.Fatalf("auto migrate topic feed: %v", err)
+	}
+	migrateTopicFeedInputs(db)
+
+	var topic TopicFeed
+	if err := db.First(&topic, "id = ?", "legacy-topic").Error; err != nil {
+		t.Fatalf("load migrated topic feed: %v", err)
+	}
 	if len(topic.Inputs) != 2 {
-		t.Fatalf("expected 2 inputs, got %d", len(topic.Inputs))
+		t.Fatalf("expected 2 migrated inputs, got %d", len(topic.Inputs))
 	}
 	if topic.Inputs[0].URI != "https://example.com/a.xml" {
-		t.Fatalf("unexpected first input URI: %q", topic.Inputs[0].URI)
+		t.Fatalf("unexpected first migrated input URI: %q", topic.Inputs[0].URI)
+	}
+	if db.Migrator().HasColumn("topic_feeds", "input_uris") {
+		t.Fatal("expected legacy input_uris column to be dropped")
 	}
 }
diff --git a/internal/feedruntime/builder.go b/internal/feedruntime/builder.go
index 3cda31d4..a3ac0d9e 100644
--- a/internal/feedruntime/builder.go
+++ b/internal/feedruntime/builder.go
@@ -152,8 +152,9 @@ func (b *Builder) BuildTopic(ctx context.Context, topic *dao.TopicFeed, stack []
 		return nil, err
 	}
 
-	inputs := make([]engine.FeedProvider, 0, len(topic.InputURIs))
-	for _, inputURI := range topic.InputURIs {
+	enabledInputURIs := topic.EnabledInputURIs()
+	inputs := make([]engine.FeedProvider, 0, len(enabledInputURIs))
+	for _, inputURI := range enabledInputURIs {
 		spec := InputSpec{
 			Kind: InputKindURI,
 			URI:  inputURI,
diff --git a/internal/feedruntime/builder_test.go b/internal/feedruntime/builder_test.go
index b7cfb024..d6320296 100644
--- a/internal/feedruntime/builder_test.go
+++ b/internal/feedruntime/builder_test.go
@@ -363,14 +363,14 @@ func TestDeduplicate_ByEmbedding_ThresholdOutOfRange(t *testing.T) {
 func TestBuildTopicProvider_NestedTopics(t *testing.T) {
 	db := newTestDB(t)
 	require.NoError(t, db.Create(&dao.TopicFeed{
-		ID:        "child",
-		Title:     "Child Topic",
-		InputURIs: []string{"https://example.com/feed.xml"},
+		ID:     "child",
+		Title:  "Child Topic",
+		Inputs: []dao.TopicInput{{URI: "https://example.com/feed.xml"}},
 	}).Error)
 	require.NoError(t, db.Create(&dao.TopicFeed{
-		ID:        "parent",
-		Title:     "Parent Topic",
-		InputURIs: []string{"feedcraft://topic/child"},
+		ID:     "parent",
+		Title:  "Parent Topic",
+		Inputs: []dao.TopicInput{{URI: "feedcraft://topic/child"}},
 		AggregatorConfig: []dao.AggregatorStep{
 			{Type: "limit", Option: map[string]string{"max": "5"}},
 		},
@@ -401,12 +401,12 @@ func TestBuildTopicProvider_NestedTopics(t *testing.T) {
 func TestBuildTopicProvider_CycleDetection(t *testing.T) {
 	db := newTestDB(t)
 	require.NoError(t, db.Create(&dao.TopicFeed{
-		ID:        "A",
-		InputURIs: []string{"feedcraft://topic/B"},
+		ID:     "A",
+		Inputs: []dao.TopicInput{{URI: "feedcraft://topic/B"}},
 	}).Error)
 	require.NoError(t, db.Create(&dao.TopicFeed{
-		ID:        "B",
-		InputURIs: []string{"feedcraft://topic/A"},
+		ID:     "B",
+		Inputs: []dao.TopicInput{{URI: "feedcraft://topic/A"}},
 	}).Error)
 
 	builder := NewBuilder(db)
diff --git a/web/admin/src/api/topic.ts b/web/admin/src/api/topic.ts
index 892d196a..e3329c00 100644
--- a/web/admin/src/api/topic.ts
+++ b/web/admin/src/api/topic.ts
@@ -21,8 +21,7 @@ export interface TopicFeed {
   id: string;
   title?: string;
   description?: string;
-  inputs?: TopicInput[];
-  input_uris: string[];
+  inputs: TopicInput[];
   aggregator_config: AggregatorStep[];
 }
 
diff --git a/web/admin/src/views/dashboard/topic_feed/detail.vue b/web/admin/src/views/dashboard/topic_feed/detail.vue
index 9e1194c8..abdb81ec 100644
--- a/web/admin/src/views/dashboard/topic_feed/detail.vue
+++ b/web/admin/src/views/dashboard/topic_feed/detail.vue
@@ -375,12 +375,7 @@
   const topicInputs = computed((): TopicInput[] => {
     if (!detail.value) return [];
     const { topic } = detail.value;
-    if (topic.inputs?.length) return topic.inputs;
-    return topic.input_uris.map((uri) => ({
-      uri,
-      description: '',
-      disabled: false,
-    }));
+    return topic.inputs || [];
   });
 
   const enabledInputCount = computed(
@@ -407,9 +402,6 @@
     const payload = {
       ...topic,
       inputs: nextInputs,
-      input_uris: nextInputs
-        .filter((input) => !input.disabled)
-        .map((input) => input.uri),
     };
 
     inputToggleSavingUri.value = uri;
@@ -509,8 +501,7 @@
     try {
       await navigator.clipboard.writeText(publicUrl.value);
       Message.success(t('topic.copyLink'));
-    } catch (err) {
-      console.error(err);
+    } catch {
       Message.error(t('topic.copyLinkFailed'));
     }
   };
diff --git a/web/admin/src/views/dashboard/topic_feed/topicInputUtils.ts b/web/admin/src/views/dashboard/topic_feed/topicInputUtils.ts
index eb4a4d5c..97ff02e1 100644
--- a/web/admin/src/views/dashboard/topic_feed/topicInputUtils.ts
+++ b/web/admin/src/views/dashboard/topic_feed/topicInputUtils.ts
@@ -108,14 +108,7 @@ export const countEnabledInputs = (sources: InputSourceItem[]): number =>
     .length;
 
 export const topicFeedToFormData = (record: TopicFeed): TopicFormData => {
-  const inputs =
-    record.inputs && record.inputs.length > 0
-      ? record.inputs
-      : record.input_uris.map((uri) => ({
-          uri,
-          description: '',
-          disabled: false,
-        }));
+  const inputs = record.inputs || [];
 
   return {
     id: record.id,
@@ -171,7 +164,6 @@ export const normalizeTopicPayload = (formData: TopicFormData): TopicFeed => {
     title: formData.title.trim(),
     description: formData.description.trim(),
     inputs,
-    input_uris: inputs.filter((item) => !item.disabled).map((item) => item.uri),
     aggregator_config: formData.aggregator_config.map((step) => {
       const option: Record<string, string> = {};
       if (step.type === 'deduplicate') {
diff --git a/web/admin/src/views/dashboard/topic_feed/topic_feed.vue b/web/admin/src/views/dashboard/topic_feed/topic_feed.vue
index 7171277a..546f6421 100644
--- a/web/admin/src/views/dashboard/topic_feed/topic_feed.vue
+++ b/web/admin/src/views/dashboard/topic_feed/topic_feed.vue
@@ -116,8 +116,7 @@
   const loading = ref(false);
 
   const inputCount = (record: TopicFeed) => {
-    if (record.inputs?.length) return record.inputs.length;
-    return record.input_uris.length;
+    return record.inputs?.length || 0;
   };
 
   const fetchTopics = async () => {

From 49535aff71f4d051e86e1d423ccc2b1770ba8d24 Mon Sep 17 00:00:00 2001
From: Cursor Agent <cursoragent@cursor.com>
Date: Mon, 1 Jun 2026 12:31:11 +0000
Subject: [PATCH 4/4] refactor(topic-feed): clean redundant NormalizeInputs
 calls

Remove GORM BeforeSave hook.
Explicitly normalize inputs before Write/Update DB operations in Controller.
Strip redundant read-path normalizations.

Co-authored-by: Colin <Colin_XKL@outlook.com>
---
 internal/controller/topic_feed.go | 13 ++-----------
 1 file changed, 2 insertions(+), 11 deletions(-)

diff --git a/internal/controller/topic_feed.go b/internal/controller/topic_feed.go
index 3fb37723..c9e47f63 100644
--- a/internal/controller/topic_feed.go
+++ b/internal/controller/topic_feed.go
@@ -66,14 +66,13 @@ func CreateTopicFeed(c *gin.Context) {
 		c.JSON(http.StatusBadRequest, util.APIResponse[any]{Msg: err.Error()})
 		return
 	}
-	topicData.NormalizeInputs()
 	db := util.GetDatabase()
 
+	topicData.NormalizeInputs()
 	if err := dao.CreateTopicFeed(db, &topicData); err != nil {
 		c.JSON(http.StatusInternalServerError, util.APIResponse[any]{Msg: err.Error()})
 		return
 	}
-	topicData.NormalizeInputs()
 
 	c.JSON(http.StatusCreated, util.APIResponse[any]{Data: topicData})
 }
@@ -91,7 +90,6 @@ func GetTopicFeed(c *gin.Context) {
 		c.JSON(http.StatusInternalServerError, util.APIResponse[any]{Msg: err.Error()})
 		return
 	}
-	topicData.NormalizeInputs()
 
 	c.JSON(http.StatusOK, util.APIResponse[any]{Data: topicData})
 }
@@ -104,10 +102,6 @@ func ListTopicFeeds(c *gin.Context) {
 		return
 	}
 
-	for _, topic := range topicList {
-		topic.NormalizeInputs()
-	}
-
 	c.JSON(http.StatusOK, util.APIResponse[any]{Data: topicList})
 }
 
@@ -123,7 +117,6 @@ func UpdateTopicFeed(c *gin.Context) {
 	if id != topicData.ID {
 		topicData.ID = id
 	}
-	topicData.NormalizeInputs()
 
 	db := util.GetDatabase()
 
@@ -137,11 +130,11 @@ func UpdateTopicFeed(c *gin.Context) {
 		return
 	}
 
+	topicData.NormalizeInputs()
 	if err := dao.UpdateTopicFeed(db, &topicData); err != nil {
 		c.JSON(http.StatusInternalServerError, util.APIResponse[any]{Msg: err.Error()})
 		return
 	}
-	topicData.NormalizeInputs()
 
 	c.JSON(http.StatusOK, util.APIResponse[any]{Data: topicData})
 }
@@ -168,7 +161,6 @@ func ValidateTopicFeed(c *gin.Context) {
 		c.JSON(http.StatusBadRequest, util.APIResponse[any]{Msg: err.Error()})
 		return
 	}
-	topicData.NormalizeInputs()
 
 	result, err := validateTopicConfig(c.Request.Context(), util.GetDatabase(), &topicData)
 	if err != nil {
@@ -192,7 +184,6 @@ func GetTopicFeedDetail(c *gin.Context) {
 		c.JSON(http.StatusInternalServerError, util.APIResponse[any]{Msg: err.Error()})
 		return
 	}
-	topicData.NormalizeInputs()
 
 	health, err := dao.GetResourceHealth(db, dao.ResourceTypeTopic, id)
 	if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) {