(
+ fetchPage: (cursor?: string) => Promise,
+): Promise
{
+ const first = await fetchPage();
+ const items = [...first.items];
+ const seen = new Set();
+ let cursor = first.nextCursor;
+ while (cursor) {
+ if (seen.has(cursor)) throw new ApiRequestError("internal", "分页游标重复，请重试");
+ seen.add(cursor);
+ const page = await fetchPage(cursor);
+ items.push(...page.items);
+ cursor = page.nextCursor;
+ }
+ return { ...first, items, nextCursor: null };
+}
diff --git a/apps/web/app/api/policies.ts b/apps/web/app/api/policies.ts
index a6850ae1..b7dd2fad 100644
--- a/apps/web/app/api/policies.ts
+++ b/apps/web/app/api/policies.ts
@@ -9,6 +9,7 @@ import {
} from "@umt/contracts";
import { api } from "~/lib/api.ts";
import { getParsed, parseOrThrow } from "./library.ts";
+import { fetchAllCursorPages } from "./parse.ts";
// 策略版本:草案 → 预览 → 授权发布 → 版本化 / 回滚(REQ §6.4)
@@ -24,7 +25,8 @@ const Page = cursorPage(PolicyRevision);
export function usePolicyRevisions(filters: PolicyFilters = {}) {
return useQuery({
queryKey: policyKeys.list(filters),
- queryFn: ({ signal }) => getParsed(Page, "/policy-revisions", { ...filters, limit: 200 }, signal),
+ queryFn: ({ signal }) =>
+ fetchAllCursorPages((cursor) => getParsed(Page, "/policy-revisions", { ...filters, limit: 200, cursor }, signal)),
});
}
diff --git a/apps/web/app/api/preferences.ts b/apps/web/app/api/preferences.ts
index bbdb09f7..0af11bf2 100644
--- a/apps/web/app/api/preferences.ts
+++ b/apps/web/app/api/preferences.ts
@@ -11,6 +11,7 @@ import {
} from "@umt/contracts";
import { api } from "~/lib/api.ts";
import { getParsed, parseOrThrow } from "./library.ts";
+import { fetchAllCursorPages } from "./parse.ts";
// 偏好标签与抑制记录(REQ §6.7):停用/删除/语义变更都会留抑制记录,Agent 不得据旧证据自动加回。
@@ -29,7 +30,10 @@ const SupPage = cursorPage(PreferenceSuppression);
export function usePreferenceTags(filters: TagFilters = {}) {
return useQuery({
queryKey: preferenceKeys.tags(filters),
- queryFn: ({ signal }) => getParsed(TagPage, "/preference-tags", { ...filters, limit: 200 }, signal),
+ queryFn: ({ signal }) =>
+ fetchAllCursorPages((cursor) =>
+ getParsed(TagPage, "/preference-tags", { ...filters, limit: 200, cursor }, signal),
+ ),
});
}
@@ -37,11 +41,13 @@ export function useSuppressions(active?: boolean) {
return useQuery({
queryKey: preferenceKeys.suppressions(active),
queryFn: ({ signal }) =>
- getParsed(
- SupPage,
- "/preference-suppressions",
- { active: active === undefined ? undefined : String(active), limit: 200 },
- signal,
+ fetchAllCursorPages((cursor) =>
+ getParsed(
+ SupPage,
+ "/preference-suppressions",
+ { active: active === undefined ? undefined : String(active), limit: 200, cursor },
+ signal,
+ ),
),
});
}
diff --git a/apps/web/app/api/records.ts b/apps/web/app/api/records.ts
index 046368ce..7a7b62a9 100644
--- a/apps/web/app/api/records.ts
+++ b/apps/web/app/api/records.ts
@@ -15,7 +15,7 @@ import {
PublicOrganizationRecord,
} from "@umt/contracts";
import { TTL_SECOND } from "~/lib/api.ts";
-import { apiMutate, apiParsed, cleanParams } from "./parse.ts";
+import { apiMutate, apiParsed, cleanParams, fetchAllCursorPages } from "./parse.ts";
// 整理记录(W2-C:/organization-records;读 organize.read,发起 organize.execute)
@@ -23,6 +23,7 @@ const RecordPage = cursorPage(PublicOrganizationRecord);
export type RecordFilters = {
status?: OrganizationStatus;
+ phase?: "active" | "history";
trigger?: OrganizationTrigger;
mediaEntityId?: string;
q?: string;
@@ -145,6 +146,7 @@ export const TRIGGER_LABEL: Record = { auto: "自
/** 整理方式 / 文件操作(记录的 action) */
export const ACTION_LABEL = {
copy: "复制",
+ in_place: "原地入库",
move: "移动",
rename: "重命名",
relocate: "目录调整",
@@ -174,7 +176,9 @@ export function useLibraryRoots() {
queryKey: ["records", "library-roots"],
staleTime: 5 * 60 * TTL_SECOND,
queryFn: ({ signal }) =>
- apiParsed(cursorPage(LibraryRoot), "/api/v1/library-roots", { params: { limit: 200 }, signal }),
+ fetchAllCursorPages((cursor) =>
+ apiParsed(cursorPage(LibraryRoot), "/api/v1/library-roots", { params: { limit: 200, cursor }, signal }),
+ ),
});
}
diff --git a/apps/web/app/api/releases.ts b/apps/web/app/api/releases.ts
index 3352abfc..159ffda0 100644
--- a/apps/web/app/api/releases.ts
+++ b/apps/web/app/api/releases.ts
@@ -1,5 +1,6 @@
import { keepPreviousData, useInfiniteQuery, useMutation, useQuery, useQueryClient } from "@tanstack/react-query";
import {
+ type ManualAcquisitionRequest,
ManualAcquisitionResult,
type ResolutionStatus,
WorkbenchReleaseDetail,
@@ -81,7 +82,7 @@ export function useRefreshReleaseDetail() {
export function useSubmitRelease() {
const qc = useQueryClient();
return useMutation({
- mutationFn: (body: { sourceReleaseId: string; slotId?: string; entityId?: string; note?: string }) =>
+ mutationFn: (body: ManualAcquisitionRequest) =>
apiMutate("/api/v1/acquisition-plans", { body }).then((d) => ManualAcquisitionResult.parse(d)),
onSuccess: (r) => {
if (r.submitted) void qc.invalidateQueries({ queryKey: ["downloads"] });
diff --git a/apps/web/app/api/rules.ts b/apps/web/app/api/rules.ts
index f38d8e6c..80251fb8 100644
--- a/apps/web/app/api/rules.ts
+++ b/apps/web/app/api/rules.ts
@@ -22,6 +22,7 @@ import {
} from "@umt/contracts";
import { api } from "~/lib/api.ts";
import { getParsed, parseOrThrow } from "./library.ts";
+import { fetchAllCursorPages } from "./parse.ts";
// 规则(W9-D,docs/runbook/rules.md):规则组 = 收录过滤条件 + 偏好标签合一;自定义条件;三套默认链;抑制记录。
// 写入给 ruleString(优先)或 layers;PATCH 带 expectedRevision,不匹配 409。
@@ -53,7 +54,8 @@ const SupPage = cursorPage(PreferenceSuppression);
export function useRuleGroups(filters: RuleGroupFilters = {}) {
return useQuery({
queryKey: ruleKeys.groups(filters),
- queryFn: ({ signal }) => getParsed(GroupPage, "/rules", { ...filters, limit: 200 }, signal),
+ queryFn: ({ signal }) =>
+ fetchAllCursorPages((cursor) => getParsed(GroupPage, "/rules", { ...filters, limit: 200, cursor }, signal)),
placeholderData: keepPreviousData,
});
}
@@ -78,7 +80,8 @@ export function useRuleKeywords() {
export function useRuleAtoms() {
return useQuery({
queryKey: ruleKeys.atoms,
- queryFn: ({ signal }) => getParsed(AtomPage, "/rules/atoms", { limit: 200 }, signal),
+ queryFn: ({ signal }) =>
+ fetchAllCursorPages((cursor) => getParsed(AtomPage, "/rules/atoms", { limit: 200, cursor }, signal)),
});
}
@@ -92,7 +95,8 @@ export function useRuleDefaults() {
export function useRuleSuppressions() {
return useQuery({
queryKey: ruleKeys.suppressions,
- queryFn: ({ signal }) => getParsed(SupPage, "/rules/suppressions", { limit: 200 }, signal),
+ queryFn: ({ signal }) =>
+ fetchAllCursorPages((cursor) => getParsed(SupPage, "/rules/suppressions", { limit: 200, cursor }, signal)),
});
}
diff --git a/apps/web/app/api/sites.ts b/apps/web/app/api/sites.ts
index 38e0aae5..7a29b6f4 100644
--- a/apps/web/app/api/sites.ts
+++ b/apps/web/app/api/sites.ts
@@ -19,7 +19,7 @@ import {
} from "@umt/contracts";
import { z } from "zod";
import { TTL_SECOND } from "~/lib/api.ts";
-import { apiMutate, apiParsed } from "./parse.ts";
+import { apiMutate, apiParsed, fetchAllCursorPages } from "./parse.ts";
// 站点、站点账号、站点快照(W2-B:/sites、/site-accounts、/sites/{id}/snapshot(s))
// 站点中心(W9-A):include=accounts、凭证 PUT、健康检测、刷新登录、用户数据、删除
@@ -41,12 +41,14 @@ export const siteKeys = {
loginHistory: (accountId: string) => ["sites", "login-history", accountId] as const,
};
-/** 站点列表(附账号与整体账号状态,站点页一次请求) */
+/** 站点列表(附账号与整体账号状态,站点页按游标取齐配置) */
export function useSites() {
return useQuery({
queryKey: siteKeys.list(),
queryFn: ({ signal }) =>
- apiParsed(SitePage, "/api/v1/sites", { params: { limit: 200, include: "accounts" }, signal }),
+ fetchAllCursorPages((cursor) =>
+ apiParsed(SitePage, "/api/v1/sites", { params: { limit: 200, include: "accounts", cursor }, signal }),
+ ),
});
}
@@ -62,7 +64,9 @@ export function useSiteAccounts(siteId?: string) {
return useQuery({
queryKey: siteKeys.accounts(siteId),
queryFn: ({ signal }) =>
- apiParsed(AccountPage, "/api/v1/site-accounts", { params: { limit: 200, siteId }, signal }),
+ fetchAllCursorPages((cursor) =>
+ apiParsed(AccountPage, "/api/v1/site-accounts", { params: { limit: 200, siteId, cursor }, signal }),
+ ),
});
}
diff --git a/apps/web/app/api/slots.ts b/apps/web/app/api/slots.ts
index c4069d8b..1c32e321 100644
--- a/apps/web/app/api/slots.ts
+++ b/apps/web/app/api/slots.ts
@@ -8,6 +8,7 @@ import {
} from "@umt/contracts";
import { api } from "~/lib/api.ts";
import { getParsed, parseOrThrow } from "./library.ts";
+import { fetchAllCursorPages } from "./parse.ts";
// 收录目标 Slot:硬条件 / 软偏好 / 回退 / 升级阈值 / 完成条件(REQ §6.1)
@@ -24,7 +25,10 @@ export function useSlots(filters: SlotFilters, enabled = true) {
return useQuery({
queryKey: slotKeys.list(filters),
enabled,
- queryFn: ({ signal }) => getParsed(Page, "/acquisition-slots", { ...filters, limit: 200 }, signal),
+ queryFn: ({ signal }) =>
+ fetchAllCursorPages((cursor) =>
+ getParsed(Page, "/acquisition-slots", { ...filters, limit: 200, cursor }, signal),
+ ),
});
}
diff --git a/apps/web/app/components/agent/agent-session-list.tsx b/apps/web/app/components/agent/agent-session-list.tsx
index 2350fca7..434e92e7 100644
--- a/apps/web/app/components/agent/agent-session-list.tsx
+++ b/apps/web/app/components/agent/agent-session-list.tsx
@@ -1,11 +1,12 @@
import { Bot, ChevronRight } from "lucide-react";
-import { type ReactNode, useEffect, useLayoutEffect, useRef, useState } from "react";
+import { type ReactNode, useLayoutEffect, useRef, useState } from "react";
import { Link } from "react-router";
import { type AgentRunView, TRIGGER_LABEL, useAgentRuns } from "~/api/agent.ts";
import { CHEVRON_CLASS } from "~/components/agentui/disclosure.tsx";
import { EmptyState, ErrorState, LoadingState } from "~/components/console/empty-state.tsx";
-import { Button } from "~/components/ui/button.tsx";
+import { useListPagination } from "~/components/console/use-list-pagination.ts";
import { Input } from "~/components/ui/input.tsx";
+import { Pagination } from "~/components/ui/pagination.tsx";
import { relTime } from "~/components/workbench/release-fields.ts";
import { cn } from "~/lib/utils.ts";
import { contextLabel, RunStatusBadge } from "./agent-conversation.tsx";
@@ -176,10 +177,10 @@ function Row({
}
/**
- * 会话列表:搜索 + 全部 / 等你处理 / 失败 + 游标加载(滚到底自动加载)。
+ * 会话列表:搜索 + 全部 / 等你处理 / 失败 + 按需加载的统一分页。
* - hrefFor:会话页左栏,点一条跳到该会话页。
* - onOpen:抽屉历史弹层,点一条在抽屉内打开;remember 时筛选与滚动位置下次打开时恢复。
- * - limit:历史弹层只列最近 N 条(置顶的算在内),不自动翻页。
+ * - limit:历史弹层的默认每页条数,可调节并翻页查看更早的会话。
*/
export function AgentSessionList({
activeId,
@@ -208,32 +209,29 @@ export function AgentSessionList({
const waiting = useAgentRuns("waiting");
const loaded = runs.data?.pages.flatMap((p) => p.items) ?? [];
const pending = waiting.data?.pages.flatMap((p) => p.items) ?? [];
- const { pinned, rows } = arrangeHistory([...pending.filter(awaitingUser), ...loaded], f, limit);
- const canLoadMore = !limit && !!runs.hasNextPage;
+ const arranged = arrangeHistory([...pending.filter(awaitingUser), ...loaded], f);
+ const loadWaiting = f.view !== "failed" && !!waiting.hasNextPage;
+ const canLoadMore = loadWaiting || !!runs.hasNextPage;
+ const paged = useListPagination([...arranged.pinned, ...arranged.rows], {
+ hasMore: canLoadMore,
+ onLoadMore: () => (loadWaiting ? waiting.fetchNextPage() : runs.fetchNextPage()),
+ loadingMore: waiting.isFetchingNextPage || runs.isFetchingNextPage,
+ error: runs.error ?? (loadWaiting ? waiting.error : undefined),
+ resetKey: JSON.stringify(f),
+ defaultPageSize: limit,
+ });
+ const visible = paged.items ?? [];
+ const pinned = f.view === "all" ? visible.filter((row) => awaitingUser(row.run)) : [];
+ const rows = f.view === "all" ? visible.filter((row) => !awaitingUser(row.run)) : visible;
const filtered = !!f.q.trim() || f.view !== "all";
const scroller = useRef(null);
- const sentinel = useRef(null);
const restored = useRef(!remember);
useLayoutEffect(() => {
if (restored.current || !rows.length || !scroller.current) return;
restored.current = true;
scroller.current.scrollTop = drawerMemory.scroll;
});
- const { fetchNextPage, isFetchingNextPage } = runs;
- useEffect(() => {
- const el = sentinel.current;
- if (!el || !canLoadMore || typeof IntersectionObserver === "undefined") return;
- const io = new IntersectionObserver(
- (es) => {
- if (es.some((e) => e.isIntersecting) && !isFetchingNextPage) void fetchNextPage();
- },
- { root: scroller.current, rootMargin: "120px" },
- );
- io.observe(el);
- return () => io.disconnect();
- }, [canLoadMore, isFetchingNextPage, fetchNextPage]);
-
const rowProps = { activeId, hrefFor, onOpen };
return (
);
}
diff --git a/apps/web/app/components/browser/desktop-view.tsx b/apps/web/app/components/browser/desktop-view.tsx
index 42ece030..1a1ef096 100644
--- a/apps/web/app/components/browser/desktop-view.tsx
+++ b/apps/web/app/components/browser/desktop-view.tsx
@@ -16,6 +16,7 @@ import { apiData, errorMessage } from "~/lib/api.ts";
import { qk } from "~/lib/query-keys.ts";
import { agentActive, controllerLabel, credentialBadge, holderName, waitingText } from "./coords.ts";
import { ReconnectPanel, ReloadNotice, useAutoReconnect } from "./reconnect.tsx";
+import { ResourceDownload } from "./resource-download.tsx";
import { SiteOriginView } from "./site-origin-view.tsx";
// 原站视图桌面模式(docs/design/webtop-remote-browser.md §5.7):iframe 嵌浏览器桌面(Selkies),
@@ -208,6 +209,7 @@ function DesktopView({
return (
+
{conn.text}
diff --git a/apps/web/app/components/browser/resource-download.tsx b/apps/web/app/components/browser/resource-download.tsx
new file mode 100644
index 00000000..05fca16c
--- /dev/null
+++ b/apps/web/app/components/browser/resource-download.tsx
@@ -0,0 +1,88 @@
+import type { BrowserResourceResult, BrowserSessionView } from "@umt/contracts";
+import { Download, Settings2 } from "lucide-react";
+import { useState } from "react";
+import { Link } from "react-router";
+import { toast } from "sonner";
+import { useSubmitRelease } from "~/api/releases.ts";
+import { ManualDownloadDialog } from "~/components/downloads/manual-download-dialog.tsx";
+import { Button } from "~/components/ui/button.tsx";
+import { apiData, errorMessage } from "~/lib/api.ts";
+
+/** 控件位于 iframe/截图外；直接解析当前详情页并交给共同手动下载入口。 */
+export function ResourceDownload({ session }: { session: BrowserSessionView }) {
+ const [busy, setBusy] = useState(false);
+ const [resource, setResource] = useState(null);
+ const [open, setOpen] = useState(false);
+ const [unrecognized, setUnrecognized] = useState(false);
+ const [planId, setPlanId] = useState(null);
+ const submit = useSubmitRelease();
+ const prepare = async (options: boolean) => {
+ setBusy(true);
+ try {
+ const r = await apiData("/browser/sessions/{id}/resource", {
+ method: "POST",
+ pathParams: { id: session.id },
+ body: {},
+ });
+ setResource(r);
+ setUnrecognized(false);
+ if (options) setOpen(true);
+ else {
+ const result = await submit.mutateAsync({
+ sourceReleaseId: r.release.id,
+ importMode: "normal",
+ replacementAssetIds: [],
+ });
+ if (result.requiresConfirmation) {
+ setUnrecognized(true);
+ setOpen(true);
+ } else if (result.submitted) {
+ setPlanId(result.plan?.id ?? null);
+ toast.success("已提交下载");
+ } else toast.warning(result.rejected.map((v) => v.message).join("；") || "没有提交下载");
+ }
+ } catch (e) {
+ toast.error(errorMessage(e));
+ } finally {
+ setBusy(false);
+ }
+ };
+ return (
+ <>
+
+
+
+ {planId ? (
+
+ 查看下载任务
+
+ ) : null}
+
+ {resource ? (
+ submit.mutateAsync({ ...options, sourceReleaseId: resource.release.id })}
+ />
+ ) : null}
+
+ );
+}
diff --git a/apps/web/app/components/browser/site-origin-view.tsx b/apps/web/app/components/browser/site-origin-view.tsx
index 8dd3a7b2..69adc528 100644
--- a/apps/web/app/components/browser/site-origin-view.tsx
+++ b/apps/web/app/components/browser/site-origin-view.tsx
@@ -36,6 +36,7 @@ import { Input } from "~/components/ui/input.tsx";
import { errorMessage } from "~/lib/api.ts";
import { controllerLabel, credentialBadge, holderName, toViewport, waitingText } from "./coords.ts";
import { isBrowserGone, ReconnectPanel, ReloadNotice, useAutoReconnect } from "./reconnect.tsx";
+import { ResourceDownload } from "./resource-download.tsx";
// 原站视图(REQ §4.7.1、§4.7.3):同一个 camofox 会话的定时截图 + 人工输入映射。
// 人工接管前服务端先停掉该会话的自动化输入;交还后 Agent 必须重新读取页面。
@@ -153,6 +154,8 @@ export function SiteOriginView({ site }: { site: SiteListItem }) {
验证码等需本人操作在此完成。
+
+
{conn.text}
diff --git a/apps/web/app/components/console/data-table.test.ts b/apps/web/app/components/console/data-table.test.ts
index 29011569..2aabb010 100644
--- a/apps/web/app/components/console/data-table.test.ts
+++ b/apps/web/app/components/console/data-table.test.ts
@@ -85,6 +85,6 @@ describe("DataTable groupBy:渲染", () => {
rowKey: (r: Row) => r.id,
}),
);
- expect(html).not.toContain("aria-expanded");
+ expect(html).not.toContain('aria-expanded="true"');
});
});
diff --git a/apps/web/app/components/console/data-table.tsx b/apps/web/app/components/console/data-table.tsx
index b105edb3..a5aa1be5 100644
--- a/apps/web/app/components/console/data-table.tsx
+++ b/apps/web/app/components/console/data-table.tsx
@@ -1,9 +1,10 @@
import { ChevronRight, type LucideIcon } from "lucide-react";
import { Fragment, type ReactNode, useEffect, useMemo, useState } from "react";
-import { Button } from "~/components/ui/button.tsx";
+import { Pagination, type PaginationProps } from "~/components/ui/pagination.tsx";
import { cn } from "~/lib/utils.ts";
import { groupRows, readCollapsed, toggleCollapsed, writeCollapsed } from "./data-table-groups.ts";
import { EmptyState, ErrorState, LoadingState } from "./empty-state.tsx";
+import { useListPagination } from "./use-list-pagination.ts";
export type DataColumn = {
/** 列 key(React key 用) */
@@ -33,7 +34,7 @@ const HIDE: Record["hideBelow"]>, string> = {
};
/**
- * 数据表:内置 loading / error / empty 三态与"加载更多"游标翻页。
+ * 数据表:内置 loading / error / empty 三态与统一分页。
* 外层自带 pg-slab 卡片(plain 时不带);表格在卡片内横向滚动,页面本身不溢出。
*
* r.id}
@@ -43,7 +44,7 @@ const HIDE: Record["hideBelow"]>, string> = {
*/
export function DataTable({
columns,
- rows,
+ rows: allRows,
rowKey,
loading = false,
error,
@@ -57,6 +58,8 @@ export function DataTable({
plain = false,
groupBy,
className,
+ pagination = true,
+ paginationKey,
}: {
columns: DataColumn[];
rows: T[] | undefined;
@@ -73,7 +76,17 @@ export function DataTable({
plain?: boolean;
groupBy?: DataGroupBy;
className?: string;
+ pagination?: boolean | PaginationProps;
+ paginationKey?: string;
}) {
+ const paged = useListPagination(allRows, {
+ hasMore: pagination === true && hasMore,
+ onLoadMore,
+ loadingMore,
+ error,
+ resetKey: paginationKey ?? (allRows?.[0] ? rowKey(allRows[0]) : ""),
+ });
+ const rows = pagination === true ? paged.items : allRows;
const storageKey = groupBy?.storageKey;
const [collapsed, setCollapsed] = useState>(() => new Set());
// 折叠态在挂载后读(服务端渲染时没有 localStorage,首屏一律展开)
@@ -217,17 +230,11 @@ export function DataTable({
return (
{body}
- {rows && rows.length > 0 && (hasMore || error) ? (
-
- {error ? (
- {String((error as Error).message ?? error)}
- ) : null}
- {hasMore && onLoadMore ? (
-
- ) : null}
-
+ {error && allRows?.length ? (
+
{String((error as Error).message ?? error)}
+ ) : null}
+ {pagination && allRows ? (
+
) : null}
+
+
待处理
- {total ? {total} : null}
+ {total ? {total} : null}
-
{list.isPending ? (
- 加载中…
+
) : list.isError ? (
- 加载失败，稍后再试
+
) : groups.length === 0 ? (
-
-
- 没有需要处理的事项
-
+
) : (
-
+
{groups.map((g) => (
-
+
{g.items.map((d) => (
@@ -115,14 +115,12 @@ export function InboxBell() {
setOpen(false)}
- className="flex items-start gap-2.5 px-4 py-2 hover:bg-foreground/[0.04]"
+ className="block rounded-lg px-2 py-2 outline-none transition-colors hover:bg-foreground/[0.06] focus-visible:bg-foreground/[0.06] focus-visible:ring-2 focus-visible:ring-ring/50"
>
-
-
- {d.title}
-
- {SEVERITY[d.severity].label} · {formatRelative(d.createdAt)}
-
+ {d.title}
+
+
+ {SEVERITY[d.severity].label} · {formatRelative(d.createdAt)}
diff --git a/apps/web/app/components/console/list-pagination.test.ts b/apps/web/app/components/console/list-pagination.test.ts
new file mode 100644
index 00000000..215a75fe
--- /dev/null
+++ b/apps/web/app/components/console/list-pagination.test.ts
@@ -0,0 +1,47 @@
+import { createElement } from "react";
+import { renderToStaticMarkup } from "react-dom/server";
+import { describe, expect, it } from "vitest";
+import { Pagination, pageNumbers } from "~/components/ui/pagination.tsx";
+import { DataTable } from "./data-table.tsx";
+import { pageWindow } from "./use-list-pagination.ts";
+
+describe("list pagination", () => {
+ it("keeps empty and short final pages in range", () => {
+ expect(pageWindow(0, 20, 8)).toEqual({ page: 1, pages: 1, start: 0, end: 0 });
+ expect(pageWindow(135, 100, 8)).toEqual({ page: 2, pages: 2, start: 100, end: 135 });
+ expect(pageWindow(135, 50, 0)).toEqual({ page: 1, pages: 3, start: 0, end: 50 });
+ });
+ it("shows nearby pages and endpoints without a button for every record page", () => {
+ expect(pageNumbers(50, 100)).toEqual([1, "…", 49, 50, 51, "…", 100]);
+ expect(pageNumbers(1, 2)).toEqual([1, 2]);
+ });
+ it("does not invent a total or last page for cursor results", () => {
+ const html = renderToStaticMarkup(
+ createElement(Pagination, {
+ page: 1,
+ pageSize: 50,
+ total: 50,
+ hasMore: true,
+ onPageChange: () => {},
+ }),
+ );
+ expect(html).toContain("已加载 50 条");
+ expect(html).toContain('aria-label="第 2 页"');
+ expect(html).not.toContain('aria-label="最后一页"');
+ });
+ it("limits table rows and shares the page-size control even for empty lists", () => {
+ const table = (rows: { id: string }[]) =>
+ renderToStaticMarkup(
+ createElement(DataTable<{ id: string }>, {
+ rows,
+ columns: [{ key: "id", header: "ID", cell: (r: { id: string }) => r.id }],
+ rowKey: (r: { id: string }) => r.id,
+ }),
+ );
+ const html = table(Array.from({ length: 135 }, (_, i) => ({ id: `item-${i}` })));
+ expect(html.split("")[1]?.split("")[0]?.match(/");
+ expect(table([])).toContain('aria-label="每页条数"');
+ });
+});
diff --git a/apps/web/app/components/console/paginated-list.tsx b/apps/web/app/components/console/paginated-list.tsx
new file mode 100644
index 00000000..e5b63150
--- /dev/null
+++ b/apps/web/app/components/console/paginated-list.tsx
@@ -0,0 +1,33 @@
+import type { ReactNode } from "react";
+import { useListPagination } from "~/components/console/use-list-pagination.ts";
+import { Pagination } from "~/components/ui/pagination.tsx";
+
+/** Shared paging for custom record lists, keeping row markup and actions with the caller. */
+export function PaginatedList({
+ rows,
+ children,
+ label,
+ resetKey,
+ className,
+ as = "div",
+ compact = false,
+}: {
+ rows: T[];
+ children: (row: T, index: number) => ReactNode;
+ label: string;
+ resetKey?: string;
+ className?: string;
+ as?: "div" | "ul" | "fieldset";
+ compact?: boolean;
+}) {
+ const { items, pagination } = useListPagination(rows, { resetKey });
+ const Container = as;
+ return (
+
+
+ {items?.map((row, index) => children(row, (pagination.page - 1) * pagination.pageSize + index))}
+
+ {!compact || rows.length > 10 ? : null}
+
+ );
+}
diff --git a/apps/web/app/components/console/use-list-pagination.ts b/apps/web/app/components/console/use-list-pagination.ts
new file mode 100644
index 00000000..25b147d2
--- /dev/null
+++ b/apps/web/app/components/console/use-list-pagination.ts
@@ -0,0 +1,100 @@
+import { useCallback, useEffect, useRef, useState, useSyncExternalStore } from "react";
+import type { PaginationProps } from "~/components/ui/pagination.tsx";
+
+export const PAGE_SIZES = [10, 20, 50, 100] as const;
+const SIZE_KEY = "umt.list.page-size";
+const SIZE_EVENT = "umt:list-page-size";
+function readSize() {
+ try {
+ const size = Number(localStorage.getItem(SIZE_KEY));
+ return PAGE_SIZES.some((n) => n === size) ? size : 0;
+ } catch {
+ return 0;
+ }
+}
+function subscribeSize(notify: () => void) {
+ window.addEventListener("storage", notify);
+ window.addEventListener(SIZE_EVENT, notify);
+ return () => {
+ window.removeEventListener("storage", notify);
+ window.removeEventListener(SIZE_EVENT, notify);
+ };
+}
+export function pageWindow(total: number, size: number, requested: number) {
+ const pages = Math.max(1, Math.ceil(total / size));
+ const page = Math.max(1, Math.min(requested, pages));
+ return { page, pages, start: (page - 1) * size, end: Math.min(page * size, total) };
+}
+/** Present cached cursor results as pages; fetch only enough to fill the requested page. */
+export function useListPagination(
+ rows: T[] | undefined,
+ {
+ hasMore = false,
+ onLoadMore,
+ loadingMore = false,
+ error,
+ resetKey = "",
+ defaultPageSize = 50,
+ }: {
+ hasMore?: boolean;
+ onLoadMore?: () => unknown;
+ loadingMore?: boolean;
+ error?: unknown;
+ resetKey?: string;
+ defaultPageSize?: number;
+ } = {},
+) {
+ const storedSize = useSyncExternalStore(subscribeSize, readSize, () => 0);
+ const [localSize, setLocalSize] = useState(null);
+ const pageSize = localSize ?? (storedSize || defaultPageSize);
+ const scope = `${resetKey}|${pageSize}`;
+ const [position, setPosition] = useState({ scope, page: 1 });
+ useEffect(() => {
+ setPosition({ scope, page: 1 });
+ }, [scope]);
+ const requested = position.scope === scope ? position.page : 1;
+ const total = rows?.length ?? 0;
+ const range = pageWindow(total, pageSize, requested);
+ const needsMore = !!rows && hasMore && total < requested * pageSize;
+ const fetching = useRef(false);
+ const load = useCallback(() => {
+ if (!onLoadMore || fetching.current || loadingMore) return;
+ fetching.current = true;
+ Promise.resolve(onLoadMore())
+ .catch(() => {})
+ .finally(() => {
+ fetching.current = false;
+ });
+ }, [onLoadMore, loadingMore]);
+ // biome-ignore lint/correctness/useExhaustiveDependencies: every new cursor chunk must trigger filling the requested page
+ useEffect(() => {
+ if (needsMore && !error) load();
+ }, [needsMore, total, error, load]);
+ const onPageChange = (page: number) => {
+ const next = Math.max(1, Math.min(page, range.pages + (hasMore ? 1 : 0)));
+ setPosition({ scope, page: next });
+ if (hasMore && next * pageSize > total) load();
+ };
+ const onPageSizeChange = (size: number) => {
+ if (!PAGE_SIZES.some((n) => n === size)) return;
+ setLocalSize(size);
+ setPosition({ scope: `${resetKey}|${size}`, page: 1 });
+ try {
+ localStorage.setItem(SIZE_KEY, String(size));
+ window.dispatchEvent(new Event(SIZE_EVENT));
+ setLocalSize(null);
+ } catch {
+ /* selected size still applies to this list */
+ }
+ };
+ const pagination: PaginationProps = {
+ page: range.page,
+ pageSize,
+ total,
+ hasMore,
+ busy: loadingMore || (needsMore && !error),
+ onPageChange,
+ onPageSizeChange,
+ };
+ return { items: rows?.slice(range.start, range.end), pagination };
+}
diff --git a/apps/web/app/components/dashboard/home-runtime.tsx b/apps/web/app/components/dashboard/home-runtime.tsx
new file mode 100644
index 00000000..3e5d4a6a
--- /dev/null
+++ b/apps/web/app/components/dashboard/home-runtime.tsx
@@ -0,0 +1,209 @@
+import { useQuery } from "@tanstack/react-query";
+import { type Dashboard, DownloadBoard, type HealthLevel } from "@umt/contracts";
+import { ArrowRight, Download, HardDrive, type LucideIcon } from "lucide-react";
+import type { ReactNode } from "react";
+import { Link } from "react-router";
+import { apiParsed } from "~/api/parse.ts";
+import { useSystemHealth } from "~/api/system.ts";
+import { EmptyState, ErrorState, LoadingState } from "~/components/console/empty-state.tsx";
+import { consolePath } from "~/components/console/nav.ts";
+import { StatusBadge, type StatusTone } from "~/components/console/status-badge.tsx";
+import { formatRelative } from "~/lib/labels.ts";
+import { cn, formatBytes } from "~/lib/utils.ts";
+
+const LEVEL: Record = {
+ ok: { label: "正常", tone: "success" },
+ warn: { label: "需要关注", tone: "warning" },
+ critical: { label: "需要处理", tone: "destructive" },
+ unknown: { label: "用量未知", tone: "neutral" },
+};
+const SCOPE = { data_dir: "系统数据", library_root: "媒体库", download_dir: "下载目录" };
+
+function OverviewCard({
+ title,
+ icon: Icon,
+ to,
+ children,
+}: {
+ title: string;
+ icon: LucideIcon;
+ to: string;
+ children: ReactNode;
+}) {
+ return (
+
+ );
+}
+
+function StorageOverview() {
+ const q = useSystemHealth(60_000);
+ const mediaDisks = q.data?.disks.filter((d) => d.scope !== "data_dir") ?? [];
+ const disks = mediaDisks.length ? mediaDisks : (q.data?.disks ?? []);
+ return (
+
+ {q.isPending ? (
+
+ ) : q.isError ? (
+ q.refetch()} className="py-6" />
+ ) : !disks.length ? (
+
+ ) : (
+
+ {disks.map((d) => {
+ const pct = d.usedRatio === null ? null : d.usedRatio * 100;
+ const state = LEVEL[d.level];
+ return (
+ -
+
+
+ {d.name !== SCOPE[d.scope] ? (
+ {SCOPE[d.scope]}
+ ) : null}
+ {d.name}
+
+
+ {state.label}
+ {pct === null ? "" : ` · ${Math.round(pct)}%`}
+
+
+
+ 剩余{" "}
+
+ {d.availableBytes === null ? "未知" : formatBytes(d.availableBytes, 1)}
+
+
+ 已用 {d.usedBytes === null ? "未知" : formatBytes(d.usedBytes, 1)}
+ 总量 {d.totalBytes === null ? "未知" : formatBytes(d.totalBytes, 1)}
+
+
+ {d.path}
+
+ {d.error ? 无法读取磁盘用量
: null}
+
+ );
+ })}
+
+ )}
+ {q.data && !q.isError ? (
+ 所在磁盘用量 · 检查于 {formatRelative(q.data.checkedAt)}
+ ) : null}
+
+ );
+}
+
+function DownloaderOverview({ downloaders }: { downloaders?: Dashboard["sources"]["downloaders"] }) {
+ // 首页仅取一条面板记录，速度和计数仍是完整汇总；无需拉取下载任务列表。
+ const q = useQuery({
+ queryKey: ["downloads", "home-overview"],
+ queryFn: ({ signal }) =>
+ apiParsed(DownloadBoard, "/api/v1/download-tasks/board", { params: { state: "active", limit: 1 }, signal }),
+ refetchInterval: 15_000,
+ refetchIntervalInBackground: false,
+ });
+ const board = q.data;
+ const instances = board?.transfer.instances ?? [];
+ const sources =
+ downloaders ??
+ instances.map((d) => ({ id: d.instanceId, name: d.name, enabled: true, health: "unknown", lastSeenAt: null }));
+ return (
+
+ {q.isPending ? (
+
+ ) : q.isError ? (
+ q.refetch()} className="py-6" />
+ ) : !sources.length ? (
+
+ ) : (
+ <>
+
+ {board?.counts.active}
+ 项进行中
+
+
+ {sources.map((d) => {
+ const live = instances.find((i) => i.instanceId === d.id);
+ const state = !d.enabled
+ ? { label: "已停用", tone: "neutral" as const }
+ : !live
+ ? { label: "状态未知", tone: "neutral" as const }
+ : live.reachable
+ ? { label: "在线", tone: "success" as const }
+ : { label: "连接失败", tone: "warning" as const };
+ const readable = d.enabled && live?.reachable;
+ return (
+ -
+
+
+ {d.name}
+
+ {state.label}
+
+ {d.enabled ? (
+
+
+ 下载{" "}
+
+ {readable ? `${formatBytes(live.dlSpeed, 1)}/s` : "未知"}
+
+
+
+ 上传{" "}
+
+ {readable ? `${formatBytes(live.upSpeed, 1)}/s` : "未知"}
+
+
+
+ ) : null}
+
+ );
+ })}
+
+
+ 进行中含等待计划、暂停和异常任务 · 速度含下载器全部任务
+
+ {board?.liveAt ? (
+ 速度采样于 {formatRelative(board.liveAt)}
+ ) : null}
+
+ )}
+
+ );
+}
+
+export function HomeRuntime({ downloaders }: { downloaders?: Dashboard["sources"]["downloaders"] }) {
+ return (
+
+
+
+
+ );
+}
diff --git a/apps/web/app/components/downloads/business-tasks.tsx b/apps/web/app/components/downloads/business-tasks.tsx
index 6a517eb4..3b02d5fc 100644
--- a/apps/web/app/components/downloads/business-tasks.tsx
+++ b/apps/web/app/components/downloads/business-tasks.tsx
@@ -231,6 +231,7 @@ export function BusinessTasks() {
/>
t.id}
diff --git a/apps/web/app/components/downloads/download-detail.tsx b/apps/web/app/components/downloads/download-detail.tsx
index dbd177e4..098a64e6 100644
--- a/apps/web/app/components/downloads/download-detail.tsx
+++ b/apps/web/app/components/downloads/download-detail.tsx
@@ -237,6 +237,7 @@ export function DownloadDetail({ task, live }: { task: DownloadTask; live?: Down
instanceId: task.instanceId,
contentPath: task.contentPath,
name: task.name,
+ tags: task.tags,
}}
onClose={() => setOrganizing(false)}
/>
diff --git a/apps/web/app/components/downloads/manual-download-dialog.tsx b/apps/web/app/components/downloads/manual-download-dialog.tsx
new file mode 100644
index 00000000..9b943a23
--- /dev/null
+++ b/apps/web/app/components/downloads/manual-download-dialog.tsx
@@ -0,0 +1,226 @@
+import type { AssetVersion, ManualAcquisitionRequest, ManualAcquisitionResult } from "@umt/contracts";
+import { Bot, Download } from "lucide-react";
+import { useEffect, useId, useState } from "react";
+import { Link } from "react-router";
+import { toast } from "sonner";
+import { downloaders } from "~/api/instances.ts";
+import { useLibraryVersions } from "~/api/library-versions.ts";
+import { FilterSelect } from "~/components/console/filter-bar.tsx";
+import { Button } from "~/components/ui/button.tsx";
+import {
+ Dialog,
+ DialogContent,
+ DialogDescription,
+ DialogFooter,
+ DialogHeader,
+ DialogTitle,
+} from "~/components/ui/dialog.tsx";
+import { Input } from "~/components/ui/input.tsx";
+import { errorMessage } from "~/lib/api.ts";
+import { formatBytes } from "~/lib/utils.ts";
+
+export type ManualDownloadOptions = Omit;
+export interface ManualDownloadResource {
+ title: string;
+ sizeBytes: number | null;
+ entityId?: string;
+}
+
+/** 搜索、工作台和原站视图共用的一次性下载选项。 */
+export function ManualDownloadDialog({
+ resource,
+ open,
+ onOpenChange,
+ submit,
+ initialUnrecognized = false,
+ onDelegate,
+}: {
+ resource: ManualDownloadResource;
+ open: boolean;
+ onOpenChange: (open: boolean) => void;
+ submit: (options: ManualDownloadOptions) => Promise;
+ initialUnrecognized?: boolean;
+ onDelegate?: () => void;
+}) {
+ const instances = downloaders.useList();
+ const formId = useId();
+ const inventory = useLibraryVersions(open ? resource.entityId : undefined);
+ const [instanceId, setInstanceId] = useState("");
+ const [savePath, setSavePath] = useState("");
+ const [mode, setMode] = useState<"normal" | "replace">("normal");
+ const [selected, setSelected] = useState([]);
+ const [unrecognized, setUnrecognized] = useState(initialUnrecognized);
+ const [busy, setBusy] = useState(false);
+ const [result, setResult] = useState(null);
+ const versions = new Map();
+ for (const v of inventory.data?.movie?.versions ?? []) versions.set(v.assetId, v);
+ for (const season of inventory.data?.seasons ?? [])
+ for (const episode of season.episodes) for (const v of episode.versions) versions.set(v.assetId, v);
+ for (const v of inventory.data?.unplaced ?? []) versions.set(v.assetId, v);
+ const existing = [...versions.values()];
+ const single = existing.length === 1 ? existing[0]!.assetId : null;
+ useEffect(() => {
+ if (mode === "replace" && single) setSelected([single]);
+ }, [mode, single]);
+ useEffect(() => {
+ if (open) {
+ setResult(null);
+ setUnrecognized(initialUnrecognized);
+ }
+ }, [open, initialUnrecognized]);
+ const go = async () => {
+ setBusy(true);
+ try {
+ const r = await submit({
+ ...(resource.entityId ? { entityId: resource.entityId } : {}),
+ ...(instanceId ? { downloaderInstanceId: instanceId } : {}),
+ ...(savePath.trim() ? { savePath: savePath.trim() } : {}),
+ ...(unrecognized ? { allowUnrecognized: true } : {}),
+ importMode: mode,
+ replacementAssetIds: mode === "replace" ? selected : [],
+ });
+ setResult(r);
+ if (r.requiresConfirmation) setUnrecognized(true);
+ if (r.submitted) toast.success("已提交下载");
+ } catch (e) {
+ toast.error(errorMessage(e));
+ } finally {
+ setBusy(false);
+ }
+ };
+ return (
+
+ );
+}
+
+function VersionDescription({ version }: { version: AssetVersion }) {
+ return (
+
+ {version.fileName}
+
+ {[version.resolution, version.source, version.videoCodec, ...version.hdr, version.edition]
+ .filter(Boolean)
+ .join(" · ")}
+
+
+ );
+}
diff --git a/apps/web/app/components/files/dir-picker.tsx b/apps/web/app/components/files/dir-picker.tsx
index 2d18c0a3..f71c67d3 100644
--- a/apps/web/app/components/files/dir-picker.tsx
+++ b/apps/web/app/components/files/dir-picker.tsx
@@ -17,7 +17,7 @@ export function DirPicker({
onChange: (ref: FileRef) => void;
className?: string;
}) {
- const writable = roots.filter((r) => r.writable && r.health !== "offline");
+ const writable = roots.filter((r) => r.kind === "library" && r.writable && r.health !== "offline");
return (
{writable.length ? (
@@ -25,6 +25,7 @@ export function DirPicker({
roots={writable}
current={value}
pickOnly
+ paginate
defaultOpen={value ? [value.root] : writable.slice(0, 1).map((r) => r.id)}
onSelect={onChange}
/>
diff --git a/apps/web/app/components/files/dir-tree.tsx b/apps/web/app/components/files/dir-tree.tsx
index b9bc7174..9f482013 100644
--- a/apps/web/app/components/files/dir-tree.tsx
+++ b/apps/web/app/components/files/dir-tree.tsx
@@ -1,6 +1,8 @@
import { ChevronRight, Download, Folder, FolderOpen, HardDrive, LoaderCircle, TriangleAlert } from "lucide-react";
import { useEffect, useState } from "react";
import { type FileRoot, useDirChildren } from "~/api/files.ts";
+import { useListPagination } from "~/components/console/use-list-pagination.ts";
+import { Pagination } from "~/components/ui/pagination.tsx";
import { healthLabel } from "~/lib/labels.ts";
import { cn } from "~/lib/utils.ts";
import { groupRoots, joinRel, segments } from "./model.ts";
@@ -21,6 +23,7 @@ export function DirTree({
onSelect,
onDropTo,
pickOnly = false,
+ paginate = false,
defaultOpen = [],
className,
}: {
@@ -29,6 +32,8 @@ export function DirTree({
onSelect: (loc: Loc) => void;
onDropTo?: DropHandler;
pickOnly?: boolean;
+ /** 目录选择小窗按页展示子目录;主文件树保持懒展开。 */
+ paginate?: boolean;
/** 初始展开的根 id(目标选择器里默认展开可写根) */
defaultOpen?: string[];
className?: string;
@@ -75,6 +80,7 @@ export function DirTree({
onSelect={onSelect}
onDropTo={onDropTo}
pickOnly={pickOnly}
+ paginate={paginate}
/>
))}
@@ -92,6 +98,7 @@ function RootNode({
onSelect,
onDropTo,
pickOnly,
+ paginate,
}: {
root: FileRoot;
current: Loc | null;
@@ -100,6 +107,7 @@ function RootNode({
onSelect: (loc: Loc) => void;
onDropTo?: DropHandler;
pickOnly: boolean;
+ paginate: boolean;
}) {
const k = nodeKey(root.id, "");
const offline = root.health === "offline";
@@ -162,6 +170,7 @@ function RootNode({
onSelect={onSelect}
onDropTo={onDropTo}
pickOnly={pickOnly}
+ paginate={paginate}
/>
) : null}
@@ -178,6 +187,7 @@ function Children({
onSelect,
onDropTo,
pickOnly,
+ paginate,
}: {
root: FileRoot;
path: string;
@@ -188,8 +198,23 @@ function Children({
onSelect: (loc: Loc) => void;
onDropTo?: DropHandler;
pickOnly: boolean;
+ paginate: boolean;
}) {
const q = useDirChildren(root.id, path, true);
+ const dirs = q.data?.dirs ?? [];
+ const paged = useListPagination(dirs, { resetKey: JSON.stringify({ root: root.id, path }) });
+ const selectedIndex =
+ current?.root === root.id
+ ? dirs.findIndex((dir) => {
+ const childPath = dir.path || joinRel(path, dir.name);
+ return current.path === childPath || current.path.startsWith(`${childPath}/`);
+ })
+ : -1;
+ // biome-ignore lint/correctness/useExhaustiveDependencies: 选中目录改变时定位;手动翻页不改变已有选择
+ useEffect(() => {
+ if (paginate && selectedIndex >= 0)
+ paged.pagination.onPageChange(Math.floor(selectedIndex / paged.pagination.pageSize) + 1);
+ }, [paginate, root.id, path, selectedIndex, paged.pagination.pageSize]);
if (q.isPending)
return (
);
- const dirs = q.data?.dirs ?? [];
if (!dirs.length)
return (
@@ -214,7 +238,7 @@ function Children({
);
return (
- {dirs.map((d) => {
+ {(paginate ? paged.items : dirs)?.map((d) => {
const p = d.path || joinRel(path, d.name);
const k = nodeKey(root.id, p);
const isOpen = open.has(k);
@@ -251,11 +275,13 @@ function Children({
onSelect={onSelect}
onDropTo={onDropTo}
pickOnly={pickOnly}
+ paginate={paginate}
/>
) : null}
);
})}
+ {paginate && dirs.length > 0 ?
: null}
{q.data?.truncated ? (
子目录过多，只列出一部分
diff --git a/apps/web/app/components/files/directory-dialog.test.ts b/apps/web/app/components/files/directory-dialog.test.ts
new file mode 100644
index 00000000..3fc29703
--- /dev/null
+++ b/apps/web/app/components/files/directory-dialog.test.ts
@@ -0,0 +1,13 @@
+import { describe, expect, it } from "vitest";
+import { directorySelectionAllowed } from "./directory-dialog.tsx";
+
+describe("目录选择根保护", () => {
+ it("配置来源与目标默认允许根目录，手动整理只允许子目录", () => {
+ const root = { root: "dl:instance:0", path: "" };
+ expect(directorySelectionAllowed(root)).toBe(true);
+ expect(directorySelectionAllowed(root, false)).toBe(false);
+ expect(directorySelectionAllowed({ ...root, path: "completed/movie" }, false)).toBe(true);
+ expect(directorySelectionAllowed(null)).toBe(false);
+ expect(directorySelectionAllowed({ root: "", path: "movie" })).toBe(false);
+ });
+});
diff --git a/apps/web/app/components/files/directory-dialog.tsx b/apps/web/app/components/files/directory-dialog.tsx
new file mode 100644
index 00000000..779269a7
--- /dev/null
+++ b/apps/web/app/components/files/directory-dialog.tsx
@@ -0,0 +1,138 @@
+import { ArrowUp, File, Folder } from "lucide-react";
+import { useState } from "react";
+import { type FileRef, filesErrorText, useFileList, useFileRoots } from "~/api/files.ts";
+import { useListPagination } from "~/components/console/use-list-pagination.ts";
+import { Button } from "~/components/ui/button.tsx";
+import { Dialog, DialogContent, DialogDescription, DialogHeader, DialogTitle } from "~/components/ui/dialog.tsx";
+import { Pagination } from "~/components/ui/pagination.tsx";
+import { DirTree } from "./dir-tree.tsx";
+
+export const directorySelectionAllowed = (ref: FileRef | null, allowRoot = true): boolean =>
+ !!ref?.root && (allowRoot || ref.path !== "");
+
+/** Source selection intentionally permits readable download roots; targets only permit writable libraries. */
+export function DirectoryDialog({
+ mode,
+ value,
+ onSelect,
+ onClose,
+ allowRoot = true,
+}: {
+ mode: "source" | "target";
+ value?: FileRef | null;
+ allowRoot?: boolean;
+ onSelect: (value: FileRef) => void;
+ onClose: () => void;
+}) {
+ const roots = useFileRoots();
+ const [selected, setSelected] = useState(value ?? null);
+ const available = (roots.data ?? []).filter(
+ (r) => r.health !== "offline" && (mode === "source" || (r.kind === "library" && r.writable)),
+ );
+ const root = available.find((r) => r.id === selected?.root);
+ const listing = useFileList(root && selected ? { root: selected.root, path: selected.path } : null);
+ const entries = listing.data?.pages.flatMap((p) => p.entries) ?? [];
+ const paged = useListPagination(entries, {
+ hasMore: listing.hasNextPage,
+ onLoadMore: () => listing.fetchNextPage(),
+ loadingMore: listing.isFetchingNextPage,
+ error: listing.error,
+ resetKey: JSON.stringify(selected),
+ });
+ return (
+
+ );
+}
diff --git a/apps/web/app/components/files/mock.ts b/apps/web/app/components/files/mock.ts
index d83a6d04..d8e520eb 100644
--- a/apps/web/app/components/files/mock.ts
+++ b/apps/web/app/components/files/mock.ts
@@ -854,7 +854,7 @@ function organize(body: {
season?: number;
episodes?: number[];
}[];
- action: "copy" | "move";
+ action: "copy" | "move" | "in_place";
dryRun: boolean;
onExisting?: "skip" | "conflict" | "replace_with_verify";
naming?: "template" | "keep";
@@ -881,12 +881,15 @@ function organize(body: {
const e = it.episodes?.length ? `E${String(it.episodes[0]).padStart(2, "0")}` : "";
const orig = it.path.split("/").pop() ?? "";
const name = body.naming === "keep" ? orig : tv ? `${dirName} - ${s}${e}.${ext}` : `${dirName}.${ext}`;
- const dst = tv
- ? `${libRoot}/${dirName}/Season ${String(it.season ?? 1).padStart(2, "0")}/${name}`
- : `${libRoot}/${dirName}/${name}`;
+ const dst =
+ body.action === "in_place"
+ ? `${state.roots.find((x) => x.id === it.root)?.hostPath}/${it.path}`
+ : tv
+ ? `${libRoot}/${dirName}/Season ${String(it.season ?? 1).padStart(2, "0")}/${name}`
+ : `${libRoot}/${dirName}/${name}`;
const r = state.roots.find((x) => x.id === it.root);
const { node, parent } = find(it.root, it.path);
- const exists = id === "e-dune";
+ const exists = body.action !== "in_place" && id === "e-dune";
if (exists && onExisting === "conflict") conflict = true;
const main = {
source: `${r?.hostPath}/${it.path}`,
@@ -915,7 +918,10 @@ function organize(body: {
.filter((c) => c !== node && !c.dir && c.name.startsWith(stem.slice(0, 16)) && /\.(srt|ass)$/.test(c.name))
.map((c) => ({
source: `${r?.hostPath}/${join(dirPath, c.name)}`,
- target: dst.replace(/\.[^.]+$/, `.zh.${c.name.split(".").pop()}`),
+ target:
+ body.action === "in_place"
+ ? `${r?.hostPath}/${join(dirPath, c.name)}`
+ : dst.replace(/\.[^.]+$/, `.zh.${c.name.split(".").pop()}`),
kind: "subtitle",
size: c.size,
action: "transfer" as const,
diff --git a/apps/web/app/components/library/identity-aliases.tsx b/apps/web/app/components/library/identity-aliases.tsx
index 963c9361..1ed8959d 100644
--- a/apps/web/app/components/library/identity-aliases.tsx
+++ b/apps/web/app/components/library/identity-aliases.tsx
@@ -198,6 +198,7 @@ export function AliasesPanel() {
{entity ? : null}
a.id}
diff --git a/apps/web/app/components/library/identity-views.tsx b/apps/web/app/components/library/identity-views.tsx
index b80e042b..b7cd9969 100644
--- a/apps/web/app/components/library/identity-views.tsx
+++ b/apps/web/app/components/library/identity-views.tsx
@@ -138,6 +138,7 @@ export function PoolTab() {
r.id}
@@ -238,6 +239,7 @@ export function ExternalTab() {
r.id}
diff --git a/apps/web/app/components/library/versions.tsx b/apps/web/app/components/library/versions.tsx
index 38ed06e8..9c293093 100644
--- a/apps/web/app/components/library/versions.tsx
+++ b/apps/web/app/components/library/versions.tsx
@@ -11,6 +11,7 @@ import { Link } from "react-router";
import { useLibraryVersions } from "~/api/library-versions.ts";
import { type KvItem, KvList } from "~/components/console/kv-list.tsx";
import { consolePath } from "~/components/console/nav.ts";
+import { PaginatedList } from "~/components/console/paginated-list.tsx";
import { TechInfo } from "~/components/console/tech-info.tsx";
import { Panel } from "~/components/library/parts.tsx";
import { cn, formatBytes, formatDateTime } from "~/lib/utils.ts";
@@ -175,6 +176,7 @@ export function VersionList({
match,
initial,
onCollapse,
+ compact = false,
}: {
versions: AssetVersion[];
match?: UnitMatch | undefined;
@@ -182,12 +184,20 @@ export function VersionList({
initial?: string | null;
/** 收起选中版本时回调(剧集用来收回到一行) */
onCollapse?: () => void;
+ compact?: boolean;
}) {
const [selected, setSelected] = useState(initial ?? null);
const tagBest = match?.state === "satisfied" && versions.length > 1;
return (
-
- {versions.map((v) => {
+
+ {(v) => {
const on = selected === v.assetId;
return (
-
@@ -214,8 +224,8 @@ export function VersionList({
{on ? : null}
);
- })}
-
+ }}
+
);
}
@@ -241,7 +251,13 @@ export function EpisodeVersionList({
return (
{open ? (
-
setOpen(false)} />
+ setOpen(false)}
+ />
) : (
+ 已完成 {recordFileProgress(record)?.completed}/{recordFileProgress(record)?.total} 个文件
+ {recordFileProgress(record)?.current ? ` · 当前：${recordFileProgress(record)?.current}` : ""}
+
+ ) : null}
{record?.reason && result ? {record.reason.message}
: null}
{g.warnings.map((w) => (
@@ -245,25 +254,21 @@ export function PreviewList({
titleOf,
roots,
onlyProblems,
- page,
- onPage,
}: {
groups: FilesOrganizeGroup[];
titleOf: GroupTitle;
roots: FileRoot[];
onlyProblems: boolean;
- page: number;
- onPage: (p: number) => void;
}) {
const shown = onlyProblems ? groups.filter(groupHasProblem) : groups;
- const pg = pageOf(shown, page);
+ const { items, pagination } = useListPagination(shown, { resetKey: String(onlyProblems) });
if (!shown.length)
return (
没有问题项。关闭「只看问题」查看全部。
);
return (
- {pg.items.map((g, i) => (
+ {items?.map((g, i) => (
))}
- {pg.pages > 1 ? (
-
-
-
- {pg.page + 1} / {pg.pages}
-
-
-
- ) : null}
+
-
+
+ {record?.match?.title ?? "媒体库刮削"}
+ 刮削
+ {status}
+ {relTime(run.createdAt)}
+
+
+
目标目录 / 文件
+
+ {record ? `${record.root} / ${record.path || "（根目录）"}` : "读取刮削目标中…"}
+
+
+ {scrapeQueueStage(run)}
+ {record ? (
+
+ 已写入 {record.written} · 跳过 {record.skipped} · 失败 {record.failed}
+
+ ) : null}
+
+ 任务详情
+
+ {record?.organizationRecordId ? (
+
+ 关联整理记录
+
+ ) : null}
+
+ {detail.error || scrape.error ? (
+ 刮削详细信息暂时无法读取，任务状态仍会自动刷新。
+ ) : null}
+
+ );
+}
+
+function QueueItem({ run }: { run: EngineRun }) {
+ const detail = useEngineRun(run.id);
+ const input = organizeRunInput(detail.data?.input);
+ const recordId = run.business?.kind === "organization" ? run.business.refId : input.recordId;
+ const downloadId = run.business?.kind === "download" ? run.business.refId : input.downloadTaskId;
+ const related = useRecordsForDownload(downloadId);
+ const matchingRecord =
+ related.data?.items.find((item) => item.status === "queued" || item.status === "running") ??
+ related.data?.items.find((item) => item.createdAt >= run.createdAt);
+ const recordQuery = useRecord(recordId ?? matchingRecord?.id);
+ const download = useDownloadTask(downloadId);
+ const record = recordQuery.data ?? matchingRecord;
+ const progress = record ? recordFileProgress(record) : null;
+ const title = record ? recordTitle(record) : (download.data?.name ?? run.business?.title ?? "核验入库任务");
+ const source = record?.source.path ?? download.data?.contentPath ?? download.data?.savePath;
+ const status = run.status === "pending" ? "排队" : run.status === "sleeping" ? "等待" : "执行中";
+ return (
+ -
+
+ {title}
+ {status}
+ {relTime(run.createdAt)}
+
+
+
+
来源
+
+ {source ??
+ (detail.isFetching || download.isFetching || recordQuery.isFetching
+ ? "读取来源信息中…"
+ : "来源信息暂不可用")}
+
+
+
+
目标
+
{record?.target.path ?? "核验与生成整理计划后确定"}
+
+
+ {organizeQueueStage(run, record)}
+ {record ? {ACTION_LABEL[record.action]} : null}
+ {progress ? (
+
+ 已完成 {progress.completed}/{progress.total} 个文件
+ {progress.current ? ` · 当前：${progress.current.split("/").pop()}` : ""}
+
+ ) : null}
+ {run.attempts > 1 ? 第 {run.attempts} 次尝试 : null}
+
+ 任务详情
+
+ {record ? (
+
+ 整理详情
+
+ ) : null}
+
+ {detail.error || recordQuery.error || related.error || download.error ? (
+ 部分详细信息暂时无法读取，任务状态仍会自动刷新。
+ ) : null}
+
+ );
+}
+
+/** Existing engine workflows are authoritative, including jobs that have not created a record yet. */
+export function OrganizeQueue() {
+ const qc = useQueryClient();
+ const runs = useEngineRuns(
+ { workflowName: "verifyAndImport,scrapeMedia", status: "pending,running,sleeping" },
+ true,
+ 5_000,
+ );
+ useSse(["task.created", "task.status_changed", "organization.changed", "download.status_changed"], () => {
+ void qc.invalidateQueries({ queryKey: qk.all("engine") });
+ void qc.invalidateQueries({ queryKey: ["records"] });
+ });
+ const rows = runs.data?.pages.flatMap((page) => page.items);
+ const paged = useListPagination(rows, {
+ hasMore: runs.hasNextPage,
+ onLoadMore: () => runs.fetchNextPage(),
+ loadingMore: runs.isFetchingNextPage,
+ error: runs.error,
+ resetKey: "organize-queue",
+ });
+ return (
+
+
+
+ 下载核验、手动与自动整理、整理后的 NFO / 图片刮削在此排队。整理完成后进入记录，刮削继续显示到任务结束。
+
+
+
+ {paged.items?.map((run) =>
+ run.workflowName === "scrapeMedia" ? (
+
+ ) : (
+
+ ),
+ )}
+
+ )}
+ {rows ? : null}
+
+ );
+}
diff --git a/apps/web/app/components/organize/organize-scrape-history.tsx b/apps/web/app/components/organize/organize-scrape-history.tsx
new file mode 100644
index 00000000..d589043a
--- /dev/null
+++ b/apps/web/app/components/organize/organize-scrape-history.tsx
@@ -0,0 +1,78 @@
+import { useQuery } from "@tanstack/react-query";
+import { FilesScrapeRecordsResult } from "@umt/contracts";
+import { Link } from "react-router";
+import { apiParsed } from "~/api/parse.ts";
+import { ErrorState, LoadingState } from "~/components/console/empty-state.tsx";
+import { PaginatedList } from "~/components/console/paginated-list.tsx";
+import { StatusBadge } from "~/components/console/status-badge.tsx";
+import { SCRAPE_STATUS, scrapeCounts } from "~/components/library/scrape-panel.tsx";
+import { reasonLine } from "~/lib/reasons.ts";
+import { formatDateTime } from "~/lib/utils.ts";
+
+/** 整理与刮削分别展示结果，避免将刮削失败当作文件搬运失败。 */
+export function OrganizeScrapeHistory({ recordId }: { recordId: string }) {
+ const query = useQuery({
+ queryKey: ["files", "scrape-records", "organization", recordId],
+ queryFn: ({ signal }) =>
+ apiParsed(FilesScrapeRecordsResult, "/files/scrape-records", {
+ params: { organizationRecordId: recordId },
+ signal,
+ }),
+ refetchInterval: 5_000,
+ });
+ return (
+
+ 整理后刮削
+ {query.isPending ? (
+
+ ) : query.error ? (
+ query.refetch()} />
+ ) : query.data?.records.length ? (
+
+ {(record) => (
+ -
+
+ {SCRAPE_STATUS[record.status].label}
+ NFO 与图片
+ {formatDateTime(record.requestedAt)}
+
+
+ {record.match?.title ?? record.path} · {record.path || "/"}
+
+ {scrapeCounts(record) || "等待写入 NFO 与图片"}
+ {record.reason ? {reasonLine(record.reason)}
: null}
+ {record.files.some((file) => file.action === "failed") ? (
+
+ 失败文件
+ file.action === "failed")}
+ label="刮削失败文件"
+ resetKey={record.id}
+ as="ul"
+ className="mt-2 space-y-1"
+ >
+ {(file) => (
+ -
+ {file.path} · {reasonLine(file.reason) || "写入失败"}
+
+ )}
+
+
+ ) : null}
+ {record.taskId ? (
+
+ 查看刮削任务
+
+ ) : null}
+
+ )}
+
+ ) : (
+ 没有关联的刮削记录。
+ )}
+
+ );
+}
diff --git a/apps/web/app/components/organize/queue-model.test.ts b/apps/web/app/components/organize/queue-model.test.ts
new file mode 100644
index 00000000..2f9a2faa
--- /dev/null
+++ b/apps/web/app/components/organize/queue-model.test.ts
@@ -0,0 +1,35 @@
+import { describe, expect, it } from "vitest";
+import { organizeQueueStage, organizeRunInput, scrapeQueueStage } from "./queue-model.ts";
+
+describe("organize queue", () => {
+ it("reads pending workflow references before a record exists", () => {
+ expect(organizeRunInput({ input: { downloadTaskId: "download", taskId: "task" } })).toEqual({
+ downloadTaskId: "download",
+ recordId: undefined,
+ });
+ expect(organizeQueueStage({ status: "pending" })).toBe("等待执行");
+ expect(organizeQueueStage({ status: "running" })).toBe("核验文件与生成整理计划");
+ });
+ it("distinguishes file transfer, plan waiting, and workflow waiting", () => {
+ expect(organizeRunInput({ recordId: "record" }).recordId).toBe("record");
+ expect(organizeQueueStage({ status: "running" }, { status: "queued" })).toContain("等待搬运");
+ expect(organizeQueueStage({ status: "running" }, { status: "running" })).toContain("搬运文件");
+ expect(organizeQueueStage({ status: "sleeping" }, { status: "running" })).toBe("等待继续执行");
+ });
+ it("keeps the independent scrape stage distinct after importing finishes", () => {
+ expect(organizeRunInput({ input: { scrapeRecordId: "scrape" } }).scrapeRecordId).toBe("scrape");
+ expect(scrapeQueueStage({ status: "running" })).toBe("刮削 NFO / 图片");
+ expect(scrapeQueueStage({ status: "pending" })).toContain("等待刮削");
+ });
+ it("原地入库显示核验与登记，不显示搬运", () => {
+ expect(organizeQueueStage({ status: "running" }, { status: "running", action: "in_place" })).toBe(
+ "核验原文件与登记媒体库",
+ );
+ expect(organizeQueueStage({ status: "running" }, { status: "queued", action: "in_place" })).toBe("等待原地登记");
+ });
+ it("does not describe a finished business record as transferring", () => {
+ expect(organizeQueueStage({ status: "running" }, { status: "succeeded" })).toContain("收尾");
+ expect(organizeRunInput(null)).toEqual({});
+ expect(organizeRunInput({ input: { recordId: 5 } })).toEqual({ recordId: undefined, downloadTaskId: undefined });
+ });
+});
diff --git a/apps/web/app/components/organize/queue-model.ts b/apps/web/app/components/organize/queue-model.ts
new file mode 100644
index 00000000..fa1c94ff
--- /dev/null
+++ b/apps/web/app/components/organize/queue-model.ts
@@ -0,0 +1,37 @@
+import type { EngineRun, PublicOrganizationRecord } from "@umt/contracts";
+
+export function organizeRunInput(value: unknown): {
+ recordId?: string;
+ downloadTaskId?: string;
+ scrapeRecordId?: string;
+} {
+ if (!value || typeof value !== "object") return {};
+ const envelope = value as Record;
+ const input =
+ envelope.input && typeof envelope.input === "object" ? (envelope.input as Record) : envelope;
+ return {
+ recordId: typeof input.recordId === "string" ? input.recordId : undefined,
+ downloadTaskId: typeof input.downloadTaskId === "string" ? input.downloadTaskId : undefined,
+ ...(typeof input.scrapeRecordId === "string" ? { scrapeRecordId: input.scrapeRecordId } : {}),
+ };
+}
+
+export function organizeQueueStage(
+ run: Pick,
+ record?: Pick & Partial>,
+) {
+ if (run.status === "sleeping") return "等待继续执行";
+ if (run.status === "pending") return "等待执行";
+ if (!record) return "核验文件与生成整理计划";
+ if (record.action === "in_place" && (record.status === "queued" || record.status === "running"))
+ return record.status === "queued" ? "等待原地登记" : "核验原文件与登记媒体库";
+ if (record.status === "queued") return "整理计划已生成，等待搬运";
+ if (record.status === "running") return "搬运文件与登记媒体库";
+ return "整理已结束，完成任务收尾";
+}
+
+export function scrapeQueueStage(run: Pick) {
+ if (run.status === "pending") return "等待刮削 NFO / 图片";
+ if (run.status === "sleeping") return "等待继续刮削 NFO / 图片";
+ return "刮削 NFO / 图片";
+}
diff --git a/apps/web/app/components/organize/record-parts.test.ts b/apps/web/app/components/organize/record-parts.test.ts
index d1a9ffbb..1b4116d7 100644
--- a/apps/web/app/components/organize/record-parts.test.ts
+++ b/apps/web/app/components/organize/record-parts.test.ts
@@ -1,5 +1,5 @@
import { describe, expect, it } from "vitest";
-import { canReorganize, episodeTag, hasFiles, isRunning, recordTitle } from "./record-parts.ts";
+import { canReorganize, episodeTag, hasFiles, isRunning, recordFileProgress, recordTitle } from "./record-parts.ts";
// HIS-1 整理记录展示小件:标题 / 季集、能否重新整理、能否连文件删除
@@ -52,3 +52,16 @@ describe("整理记录展示", () => {
expect(hasFiles({ action: "move" })).toBe(true);
});
});
+
+describe("文件级进度", () => {
+ it("没有明细时不推算进度；已结束包含成功、失败和跳过", () => {
+ expect(recordFileProgress({ files: null })).toBeNull();
+ expect(recordFileProgress({ files: [] })).toBeNull();
+ const files = ["succeeded", "failed", "skipped", "running", "queued"].map((status, i) => ({
+ status,
+ source: path(`/source/${i}.mkv`),
+ target: path(null),
+ })) as unknown as NonNullable[0]["files"]>;
+ expect(recordFileProgress({ files })).toEqual({ completed: 3, total: 5, current: "/source/3.mkv" });
+ });
+});
diff --git a/apps/web/app/components/organize/record-parts.ts b/apps/web/app/components/organize/record-parts.ts
index 7892d66e..20260ed1 100644
--- a/apps/web/app/components/organize/record-parts.ts
+++ b/apps/web/app/components/organize/record-parts.ts
@@ -23,13 +23,27 @@ export function recordTitle(r: Rec): string {
/** 能重新整理的记录:复制 / 移动 / 硬链接,且已结束 */
export const canReorganize = (r: Pick) =>
- (r.action === "copy" || r.action === "move" || r.action === "hardlink") &&
+ (r.action === "copy" || r.action === "move" || r.action === "in_place" || r.action === "hardlink") &&
r.status !== "queued" &&
r.status !== "running";
/** 有源文件 / 媒体库文件可删的记录(改名、删除、还原类只删记录本身) */
export const hasFiles = (r: Pick) =>
- r.action === "copy" || r.action === "move" || r.action === "hardlink";
+ r.action === "copy" || r.action === "move" || r.action === "in_place" || r.action === "hardlink";
export const isRunning = (r: Pick) =>
r.status === "queued" || r.status === "running";
+
+/** File counts come from record detail, never from elapsed time or transferred bytes. */
+export function recordFileProgress(
+ r: Pick,
+): { completed: number; total: number; current: string | null } | null {
+ if (!r.files?.length) return null;
+ const files = r.files;
+ const current = files.find((f) => f.status === "running");
+ return {
+ completed: files.filter((f) => !["queued", "running"].includes(f.status)).length,
+ total: files.length,
+ current: current?.source.path ?? current?.target.path ?? null,
+ };
+}
diff --git a/apps/web/app/components/organize/source-match.test.ts b/apps/web/app/components/organize/source-match.test.ts
new file mode 100644
index 00000000..f0984051
--- /dev/null
+++ b/apps/web/app/components/organize/source-match.test.ts
@@ -0,0 +1,50 @@
+import type { OrganizeSourceConfig } from "@umt/contracts";
+import { describe, expect, it } from "vitest";
+import { matchingOrganizeSources } from "./source-match.ts";
+
+const profile = (id: string, path: string, root = "dl:one:0"): OrganizeSourceConfig => ({
+ id,
+ name: id,
+ enabled: true,
+ source: { root, path },
+ target: { root: "lib:target", path: "" },
+ mediaType: "all",
+ category: null,
+ action: "copy",
+ trigger: "manual",
+ downloaderInstanceId: null,
+ tag: null,
+ intervalSec: 300,
+});
+const ref = (path: string, root = "dl:one:0") => ({ root, path });
+
+describe("文件管理整理来源匹配", () => {
+ it("根目录来源覆盖根内所选文件，但不跨根", () => {
+ const root = profile("root", "");
+ expect(matchingOrganizeSources([ref(""), ref("movie/a.mkv")], [root])).toEqual([root]);
+ expect(matchingOrganizeSources([ref("movie/a.mkv", "dl:two:0")], [root])).toEqual([]);
+ });
+ it("目录匹配保持分段边界，也可选来源目录本身", () => {
+ const movie = profile("movie", "completed/movie");
+ expect(matchingOrganizeSources([ref("completed/movie"), ref("completed/movie/a.mkv")], [movie])).toEqual([movie]);
+ expect(matchingOrganizeSources([ref("completed/movies/a.mkv")], [movie])).toEqual([]);
+ expect(matchingOrganizeSources([ref("completed")], [movie])).toEqual([]);
+ });
+ it("所有所选文件必须归属同一配置，空选择不匹配", () => {
+ const movie = profile("movie", "movie");
+ expect(matchingOrganizeSources([ref("movie/a.mkv"), ref("tv/b.mkv")], [movie])).toEqual([]);
+ expect(matchingOrganizeSources([ref("movie/a.mkv"), ref("movie/b.mkv", "dl:two:0")], [movie])).toEqual([]);
+ expect(matchingOrganizeSources([], [movie])).toEqual([]);
+ });
+ it("优先最长来源路径，同长度的多个配置全部保留供用户选择", () => {
+ const all = profile("all", "");
+ const completed = profile("completed", "completed");
+ const a = profile("a", "completed/movie");
+ const b = profile("b", "completed/movie");
+ expect(matchingOrganizeSources([ref("completed/movie/a.mkv")], [all, completed, a])).toEqual([a]);
+ expect(matchingOrganizeSources([ref("completed/movie/a.mkv")], [all, a, b])).toEqual([a, b]);
+ expect(
+ matchingOrganizeSources([ref("completed/movie/a.mkv"), ref("completed/tv/b.mkv")], [all, completed, a]),
+ ).toEqual([completed]);
+ });
+});
diff --git a/apps/web/app/components/organize/source-match.ts b/apps/web/app/components/organize/source-match.ts
new file mode 100644
index 00000000..756ab491
--- /dev/null
+++ b/apps/web/app/components/organize/source-match.ts
@@ -0,0 +1,15 @@
+import type { FileRef, OrganizeSourceConfig } from "@umt/contracts";
+
+/** Match every selected item at directory boundaries, then prefer the most specific source. */
+export function matchingOrganizeSources(items: FileRef[], profiles: T[]): T[] {
+ if (!items.length) return [];
+ const matches = profiles.filter((p) =>
+ items.every(
+ (item) =>
+ item.root === p.source.root &&
+ (p.source.path === "" || item.path === p.source.path || item.path.startsWith(`${p.source.path}/`)),
+ ),
+ );
+ const longest = Math.max(-1, ...matches.map((p) => p.source.path.length));
+ return matches.filter((p) => p.source.path.length === longest);
+}
diff --git a/apps/web/app/components/organize/source-selection.tsx b/apps/web/app/components/organize/source-selection.tsx
new file mode 100644
index 00000000..51757404
--- /dev/null
+++ b/apps/web/app/components/organize/source-selection.tsx
@@ -0,0 +1,106 @@
+import type { OrganizeSourceView, OrganizeStockResult } from "@umt/contracts";
+import { useState } from "react";
+import { Link } from "react-router";
+import { toast } from "sonner";
+import { filesErrorText } from "~/api/files.ts";
+import { useOrganizeSources, useOrganizeStock } from "~/api/organize-sources.ts";
+import { PaginatedList } from "~/components/console/paginated-list.tsx";
+import { DirectoryDialog } from "~/components/files/directory-dialog.tsx";
+import type { OrganizeSource } from "~/components/organize-wizard/organize-wizard.tsx";
+import { Button } from "~/components/ui/button.tsx";
+import { Dialog, DialogContent, DialogDescription, DialogHeader, DialogTitle } from "~/components/ui/dialog.tsx";
+
+export function stockWizardSource(profile: OrganizeSourceView, stock: OrganizeStockResult): OrganizeSource {
+ return {
+ kind: "files",
+ items: stock.items,
+ sourceConfigId: profile.id,
+ defaultAction: profile.action,
+ label: `整理存量 · ${profile.name}`,
+ scanSummary: `找到 ${stock.items.length} 个文件，跳过 ${stock.skipped} 个，不可读取 ${stock.unavailable} 个${stock.truncated ? "；扫描已达到上限，仅显示本批结果" : ""}。本次扫描不改变自动整理基线，请先预览再执行。`,
+ };
+}
+export function SourceSelection({
+ onClose,
+ onSelect,
+}: {
+ onClose: () => void;
+ onSelect: (source: OrganizeSource) => void;
+}) {
+ const sources = useOrganizeSources();
+ const stock = useOrganizeStock();
+ const [manual, setManual] = useState(false);
+ if (manual)
+ return (
+ setManual(false)}
+ onSelect={(ref) => onSelect({ kind: "files", items: [ref], label: "手动选择来源目录" })}
+ />
+ );
+ return (
+
+ );
+}
diff --git a/apps/web/app/components/rules/group-list.tsx b/apps/web/app/components/rules/group-list.tsx
index fbcc3d16..e0707a08 100644
--- a/apps/web/app/components/rules/group-list.tsx
+++ b/apps/web/app/components/rules/group-list.tsx
@@ -1,13 +1,16 @@
import type { RuleGroup } from "@umt/contracts";
import { ListChecks, ShieldOff, Tags, Trash2 } from "lucide-react";
+import { useSearchParams } from "react-router";
import { toast } from "sonner";
import { type RuleRefs, useDeleteRuleGroup, useUpdateRuleGroup } from "~/api/rules.ts";
import { ConfirmDialog } from "~/components/console/confirm-dialog.tsx";
import { type DataColumn, DataTable } from "~/components/console/data-table.tsx";
import { EmptyState } from "~/components/console/empty-state.tsx";
import { StatusBadge } from "~/components/console/status-badge.tsx";
+import { useListPagination } from "~/components/console/use-list-pagination.ts";
import { Chip, Panel, relTime } from "~/components/library/parts.tsx";
import { Button } from "~/components/ui/button.tsx";
+import { Pagination } from "~/components/ui/pagination.tsx";
import { Switch } from "~/components/ui/switch.tsx";
import { errorMessage } from "~/lib/api.ts";
import { cn } from "~/lib/utils.ts";
@@ -65,6 +68,7 @@ export function RuleGroupTable({
onOpen: (g: RuleGroup) => void;
onCreate: () => void;
}) {
+ const [params] = useSearchParams();
const { toggle, pending } = useToggle();
const columns: DataColumn[] = [
{
@@ -132,6 +136,7 @@ export function RuleGroupTable({
g.id}
loading={loading}
error={error}
@@ -234,6 +239,8 @@ function RuleTag({ g, onOpen }: { g: RuleGroup; onOpen: () => void }) {
}
export function RuleTags({ rows, onOpen }: { rows: RuleGroup[]; onOpen: (g: RuleGroup) => void }) {
+ const [params] = useSearchParams();
+ const paged = useListPagination(rows, { resetKey: params.toString() });
return (
) : (
- {rows.map((g) => (
+ {paged.items?.map((g) => (
onOpen(g)} />
))}
)}
+ {rows.length > 0 ? : null}
);
}
diff --git a/apps/web/app/components/schedules/auto-task-list.tsx b/apps/web/app/components/schedules/auto-task-list.tsx
index df50122e..46aa313e 100644
--- a/apps/web/app/components/schedules/auto-task-list.tsx
+++ b/apps/web/app/components/schedules/auto-task-list.tsx
@@ -5,7 +5,9 @@ import { Link } from "react-router";
import { toast } from "sonner";
import { useRunScheduleNow, useSkipSchedule, useUpdateSchedule } from "~/api/schedules.ts";
import { StatusBadge } from "~/components/console/status-badge.tsx";
+import { useListPagination } from "~/components/console/use-list-pagination.ts";
import { Button } from "~/components/ui/button.tsx";
+import { Pagination } from "~/components/ui/pagination.tsx";
import { Switch } from "~/components/ui/switch.tsx";
import { errorMessage } from "~/lib/api.ts";
import { formatRelative } from "~/lib/labels.ts";
@@ -228,7 +230,16 @@ export function AutoTaskList({
if (list) list.push(j);
else byGroup.set(j.group, [j]);
}
- const groups = TASK_GROUPS.filter((g) => byGroup.get(g)?.length);
+ const ordered = TASK_GROUPS.flatMap((g) => byGroup.get(g) ?? []);
+ const paged = useListPagination(ordered, { resetKey: "auto-tasks" });
+ const visibleIds = new Set(paged.items?.map((job) => job.id));
+ const groups = TASK_GROUPS.filter((g) => byGroup.get(g)?.some((job) => visibleIds.has(job.id)));
+ const highlightedIndex = ordered.findIndex((job) => job.id === highlightJob);
+ // biome-ignore lint/correctness/useExhaustiveDependencies: 仅在深链目标或每页数量变化时定位所在页
+ useEffect(() => {
+ if (highlightedIndex >= 0)
+ paged.pagination.onPageChange(Math.floor(highlightedIndex / paged.pagination.pageSize) + 1);
+ }, [highlightJob, highlightedIndex, paged.pagination.pageSize]);
// 折叠:有失败 / 运行中 / 被高亮的组默认展开,其余收起;点过的按用户的来并记在本机
const [saved, setSaved] = useState>(() => readCollapseState(COLLAPSE_KEY) ?? {});
const expanded = (g: ScheduleGroup, list: ScheduledJob[]) =>
@@ -284,14 +295,17 @@ export function AutoTaskList({
{open ? (
- {list.map((j) => (
-
- ))}
+ {list
+ .filter((job) => visibleIds.has(job.id))
+ .map((j) => (
+
+ ))}
) : null}
);
})}
+ {ordered.length > 0 ? : null}
);
}
diff --git a/apps/web/app/components/schedules/runs-sheet.tsx b/apps/web/app/components/schedules/runs-sheet.tsx
index 5965f858..8c0617c5 100644
--- a/apps/web/app/components/schedules/runs-sheet.tsx
+++ b/apps/web/app/components/schedules/runs-sheet.tsx
@@ -6,6 +6,8 @@ import { DetailSheet } from "~/components/console/detail-sheet.tsx";
import { EmptyState, ErrorState, LoadingState } from "~/components/console/empty-state.tsx";
import { consolePath } from "~/components/console/nav.ts";
import { StatusBadge } from "~/components/console/status-badge.tsx";
+import { useListPagination } from "~/components/console/use-list-pagination.ts";
+import { Pagination } from "~/components/ui/pagination.tsx";
import { agentRunLabel } from "~/lib/labels.ts";
import { describeSchedule, formatClock, formatMs, RUN_STATUS, TRIGGER_LABEL } from "./labels.ts";
@@ -13,6 +15,7 @@ import { describeSchedule, formatClock, formatMs, RUN_STATUS, TRIGGER_LABEL } fr
export function RunsSheet({ job, onClose }: { job: ScheduledJob | null; onClose: () => void }) {
const runs = useScheduleRuns(job?.id ?? null);
const items = runs.data?.items ?? [];
+ const paged = useListPagination(items, { resetKey: job?.id });
return (
) : (
- {items.map((r) => {
+ {paged.items?.map((r) => {
const s = RUN_STATUS[r.status];
return (
-
@@ -60,6 +63,7 @@ export function RunsSheet({ job, onClose }: { job: ScheduledJob | null; onClose:
})}
)}
+ {items.length > 0 ? : null}
);
}
diff --git a/apps/web/app/components/schedules/schedule-board.tsx b/apps/web/app/components/schedules/schedule-board.tsx
index 73073481..e7c6195b 100644
--- a/apps/web/app/components/schedules/schedule-board.tsx
+++ b/apps/web/app/components/schedules/schedule-board.tsx
@@ -6,7 +6,9 @@ import { useLocation } from "react-router";
import { usePiUpstreamModels, usePiUpstreams } from "~/api/pi.ts";
import { useScheduleBoard } from "~/api/schedules.ts";
import { EmptyState, ErrorState, LoadingState } from "~/components/console/empty-state.tsx";
+import { useListPagination } from "~/components/console/use-list-pagination.ts";
import { Button } from "~/components/ui/button.tsx";
+import { Pagination } from "~/components/ui/pagination.tsx";
import { qk } from "~/lib/query-keys.ts";
import { useSse } from "~/lib/sse.ts";
import { AgentCheckCard, type DefaultUpstream } from "./agent-check-card.tsx";
@@ -105,6 +107,13 @@ export function PlanBoard({ highlightJob }: { highlightJob?: string }) {
const items = data?.items ?? [];
const autoJobs = items.filter((j) => j.kind === "task");
const checks = items.filter((j) => j.kind === "agent_check");
+ const pagedChecks = useListPagination(checks, { resetKey: "agent-checks" });
+ const highlightedIndex = checks.findIndex((job) => job.id === highlightJob);
+ // biome-ignore lint/correctness/useExhaustiveDependencies: 仅在深链目标或每页数量变化时定位所在页
+ useEffect(() => {
+ if (highlightedIndex >= 0)
+ pagedChecks.pagination.onPageChange(Math.floor(highlightedIndex / pagedChecks.pagination.pageSize) + 1);
+ }, [highlightJob, highlightedIndex, pagedChecks.pagination.pageSize]);
const def = upstreams.data?.items.find((u) => u.isDefault);
// 上游没填默认模型时,运行时用模型目录的第一个(packages/agent pi/upstream.ts pickModel),这里同样取目录首个
const catalog = usePiUpstreamModels(def && !def.defaultModel ? def.id : null);
@@ -170,7 +179,7 @@ export function PlanBoard({ highlightJob }: { highlightJob?: string }) {
) : (
- {checks.map((j) => (
+ {pagedChecks.items?.map((j) => (
)}
+ {checks.length > 0 ? : null}
setSearchPaletteOpen(false);
const go = (to: string) => {
+ if (q.trim()) history.add(q);
close();
navigate(to);
};
@@ -183,9 +186,17 @@ function PaletteBody({ initial }: { initial: string }) {
className="min-h-0 flex-1 overflow-y-auto p-2 sm:max-h-[60vh]"
>
{!term ? (
-
- 输入作品名、别名或页面名称。选中作品打开详情页。
-
+
+
{
+ history.add(term);
+ go(searchPagePath(term));
+ }}
+ />
+
+ 输入作品名、别名或页面名称。选中作品打开详情页。
+
+
- {rows.map((r) => (
- setDl(r)} />
+ {paged.items?.map((r) => (
+ setSelected(r)} onDownload={() => setDl(r)} />
))}
)}
- {rows.length > 0 && res.hasNextPage ? (
-
-
-
- ) : null}
+ {rows.length > 0 || res.hasNextPage ? : null}
-
-
{r.title}
+
{promo ? {promo} : null}
{r.hr === true ? H&R : null}
diff --git a/apps/web/app/components/search/search-download-dialog.tsx b/apps/web/app/components/search/search-download-dialog.tsx
index 945c396f..89d062a7 100644
--- a/apps/web/app/components/search/search-download-dialog.tsx
+++ b/apps/web/app/components/search/search-download-dialog.tsx
@@ -1,44 +1,15 @@
-import type { ManualAcquisitionResult, SearchRelease } from "@umt/contracts";
-import { Bot, Download } from "lucide-react";
-import { useState } from "react";
-import { Link } from "react-router";
-import { toast } from "sonner";
+import type { SearchRelease } from "@umt/contracts";
import { usePlanFromSearch } from "~/api/search.ts";
-import { useSlots } from "~/api/slots.ts";
import { openAgentDrawer } from "~/components/agent/agent-store.ts";
-import { FilterSelect } from "~/components/console/filter-bar.tsx";
-import { SLOT_STATUS } from "~/components/library/labels.ts";
-import { Button } from "~/components/ui/button.tsx";
-import {
- Dialog,
- DialogContent,
- DialogDescription,
- DialogFooter,
- DialogHeader,
- DialogTitle,
-} from "~/components/ui/dialog.tsx";
-import { errorMessage } from "~/lib/api.ts";
-import { formatBytes } from "~/lib/utils.ts";
+import { ManualDownloadDialog } from "~/components/downloads/manual-download-dialog.tsx";
-// 与站点工作台同一套下载说明;请求走 POST /search/releases/{siteId}/{siteReleaseId}/plan(同 /acquisition-plans 流程)
-
-const STEPS = [
- "预留收录版本和预算；每个收录版本同时只有一个在途的下载",
- "已有相同资源或相同 hash 的任务时直接接管，不重复提交",
- "缓存卷超过硬阈值或读不到磁盘状态时无法提交",
- "提交前复核免费、做种等易变字段",
-];
-
-/** 委托 Agent:和工作台一样带上资源、作品、站点 */
-export function delegateToAgent(r: SearchRelease) {
+export function delegateToAgent(release: SearchRelease) {
openAgentDrawer({
- label: `资源：${r.title}`,
- releaseId: r.sourceReleaseId ?? undefined,
- entityId: r.entity?.id,
- siteId: r.siteId,
- goal: r.sourceReleaseId
- ? "判断这个资源是否值得下载；合适就按正常流程提交"
- : `判断站点 ${r.siteName} 的资源「${r.title}」是否值得下载；合适就按正常流程提交`,
+ label: `资源：${release.title}`,
+ releaseId: release.sourceReleaseId ?? undefined,
+ entityId: release.entity?.id,
+ siteId: release.siteId,
+ goal: `判断资源「${release.title}」是否值得下载；合适就按手动下载流程提交`,
});
}
@@ -49,124 +20,23 @@ export function SearchDownloadDialog({
}: {
release: SearchRelease;
open: boolean;
- onOpenChange: (o: boolean) => void;
+ onOpenChange: (open: boolean) => void;
}) {
- const plan = usePlanFromSearch();
- const entityId = release.entity?.id;
- const slots = useSlots({ mediaEntityId: entityId }, open && !!entityId);
- const slotList = slots.data?.items ?? [];
- const [slotId, setSlotId] = useState("");
- const [rejected, setRejected] = useState(null);
- const [done, setDone] = useState(null);
- const slotName = (id: string | null) => slotList.find((s) => s.id === id)?.name ?? null;
-
- const go = () =>
- plan.mutate(
- {
- siteId: release.siteId,
- siteReleaseId: release.siteReleaseId,
- ...(slotId ? { slotId } : entityId ? { entityId } : {}),
- },
- {
- onSuccess: (r) => {
- if (r.submitted && r.plan) {
- setRejected(null);
- setDone(r.plan.id);
- toast.success(`已提交${slotName(r.slotId) ? `(${slotName(r.slotId)})` : ""}，进度见「下载面板」`);
- } else {
- setRejected(r.rejected);
- toast.warning("没有下载");
- }
- },
- onError: (e) => toast.error(errorMessage(e)),
- },
- );
-
+ const submit = usePlanFromSearch();
return (
-
+ onDelegate={() => delegateToAgent(release)}
+ submit={(options) =>
+ submit.mutateAsync({ ...options, siteId: release.siteId, siteReleaseId: release.siteReleaseId })
+ }
+ />
);
}
diff --git a/apps/web/app/components/search/search-history.test.ts b/apps/web/app/components/search/search-history.test.ts
new file mode 100644
index 00000000..d7ddaad6
--- /dev/null
+++ b/apps/web/app/components/search/search-history.test.ts
@@ -0,0 +1,20 @@
+import { describe, expect, it } from "vitest";
+import { addHistory, HISTORY_LIMIT, parseHistory } from "./search-history.tsx";
+
+describe("search history", () => {
+ it("ignores malformed storage and non-text entries", () => {
+ expect(parseHistory("invalid json")).toEqual([]);
+ expect(parseHistory('[null,8," ","剧名","剧名"]')).toEqual(["剧名"]);
+ });
+ it("moves repeat searches to the front without saving intermediate typing", () => {
+ expect(addHistory(["Movie", "剧集"], " movie ")).toEqual(["movie", "剧集"]);
+ expect(addHistory(["剧集"], " ")).toEqual(["剧集"]);
+ });
+ it("retains only the latest searches", () => {
+ const history = Array.from({ length: HISTORY_LIMIT }, (_, i) => `query-${i}`);
+ const next = addHistory(history, "新搜索");
+ expect(next).toHaveLength(HISTORY_LIMIT);
+ expect(next[0]).toBe("新搜索");
+ expect(next).not.toContain(history.at(-1));
+ });
+});
diff --git a/apps/web/app/components/search/search-history.tsx b/apps/web/app/components/search/search-history.tsx
new file mode 100644
index 00000000..f3b97db8
--- /dev/null
+++ b/apps/web/app/components/search/search-history.tsx
@@ -0,0 +1,114 @@
+import { History, X } from "lucide-react";
+import { useCallback, useMemo, useSyncExternalStore } from "react";
+import { useSession } from "~/api/auth.ts";
+import { Button } from "~/components/ui/button.tsx";
+
+const EVENT = "umt:search-history";
+export const HISTORY_LIMIT = 30;
+
+export function parseHistory(raw: string): string[] {
+ try {
+ const value: unknown = JSON.parse(raw);
+ if (!Array.isArray(value)) return [];
+ return [
+ ...new Set(value.filter((s): s is string => typeof s === "string" && !!s.trim()).map((s) => s.trim())),
+ ].slice(0, HISTORY_LIMIT);
+ } catch {
+ return [];
+ }
+}
+export function addHistory(history: string[], term: string) {
+ const q = term.trim();
+ return q
+ ? [q, ...history.filter((s) => s.toLocaleLowerCase() !== q.toLocaleLowerCase())].slice(0, HISTORY_LIMIT)
+ : history;
+}
+function subscribe(notify: () => void) {
+ window.addEventListener(EVENT, notify);
+ window.addEventListener("storage", notify);
+ return () => {
+ window.removeEventListener(EVENT, notify);
+ window.removeEventListener("storage", notify);
+ };
+}
+const memory = new Map();
+function read(key: string) {
+ try {
+ return localStorage.getItem(key) ?? "";
+ } catch {
+ return memory.get(key) ?? "";
+ }
+}
+export function useSearchHistory() {
+ const session = useSession();
+ const actor = session.data?.actor;
+ const key = actor ? `umt.search-history.${actor.type}.${actor.id}` : "";
+ const raw = useSyncExternalStore(
+ subscribe,
+ () => (key ? read(key) : ""),
+ () => "",
+ );
+ const entries = useMemo(() => parseHistory(raw), [raw]);
+ const write = useCallback(
+ (next: string[]) => {
+ if (!key) return;
+ const value = JSON.stringify(next);
+ memory.set(key, value);
+ try {
+ localStorage.setItem(key, value);
+ } catch {
+ /* session-only fallback */
+ }
+ window.dispatchEvent(new Event(EVENT));
+ },
+ [key],
+ );
+ return {
+ entries,
+ add: useCallback((term: string) => write(addHistory(parseHistory(key ? read(key) : ""), term)), [key, write]),
+ remove: (term: string) => write(entries.filter((s) => s !== term)),
+ clear: () => write([]),
+ };
+}
+
+export function SearchHistory({ onSearch }: { onSearch: (term: string) => void }) {
+ const history = useSearchHistory();
+ if (!history.entries.length) return null;
+ return (
+
+
+
+
+ 搜索历史
+
+
+
+
+ {history.entries.map((term) => (
+
+
+
+
+ ))}
+
- {works.map((w) => (
+ {paged.items?.map((w) => (
))}
)}
+ {res.data ? : null}
{tmdb && !tmdb.configured ? (
TMDB 未配置，只搜了本地作品。
diff --git a/apps/web/app/components/settings/account-passkeys.tsx b/apps/web/app/components/settings/account-passkeys.tsx
index cb8aae6b..6a6f5c8f 100644
--- a/apps/web/app/components/settings/account-passkeys.tsx
+++ b/apps/web/app/components/settings/account-passkeys.tsx
@@ -11,8 +11,10 @@ import {
useRenamePasskey,
} from "~/api/auth.ts";
import { ConfirmDialog } from "~/components/console/confirm-dialog.tsx";
+import { useListPagination } from "~/components/console/use-list-pagination.ts";
import { Button } from "~/components/ui/button.tsx";
import { Input } from "~/components/ui/input.tsx";
+import { Pagination } from "~/components/ui/pagination.tsx";
import { errorMessage } from "~/lib/api.ts";
import { formatDateTime } from "~/lib/utils.ts";
import { SettingsBlock } from "./settings-block.tsx";
@@ -124,6 +126,7 @@ export function PasskeyBlock({ disabled }: { disabled: boolean }) {
const [name, setName] = useState("");
const supported = passkeySupported();
const items = list.data?.items ?? [];
+ const paged = useListPagination(items, { resetKey: String(disabled) });
const add = async (e: React.FormEvent) => {
e.preventDefault();
@@ -147,13 +150,14 @@ export function PasskeyBlock({ disabled }: { disabled: boolean }) {
读取中…
) : items.length ? (
- {items.map((p) => (
+ {paged.items?.map((p) => (
))}
) : (
还没有登记 Passkey。
)}
+ {items.length > 0 ? : null}
{!supported ? (
这个浏览器用不了 Passkey：需要 HTTPS 或 localhost 访问。
) : adding ? (
diff --git a/apps/web/app/components/settings/library.tsx b/apps/web/app/components/settings/library.tsx
index aca6bd84..b3db685b 100644
--- a/apps/web/app/components/settings/library.tsx
+++ b/apps/web/app/components/settings/library.tsx
@@ -1,5 +1,6 @@
import { LibraryRootsTable } from "./instances.tsx";
import { NamingSection } from "./naming.tsx";
+import { ClassificationSection, OrganizeSourcesSection } from "./organize-sources.tsx";
import { str } from "./resource-section.tsx";
import { SettingsBlock } from "./settings-block.tsx";
import { type CardSpec, SettingsCard, SettingsGate } from "./settings-card.tsx";
@@ -98,6 +99,8 @@ export function LibrarySection() {
{(s) => }
{(s) => }
+
+
);
diff --git a/apps/web/app/components/settings/organize-sources.tsx b/apps/web/app/components/settings/organize-sources.tsx
new file mode 100644
index 00000000..38656809
--- /dev/null
+++ b/apps/web/app/components/settings/organize-sources.tsx
@@ -0,0 +1,470 @@
+import type { FileRef, OrganizeSourceInput, OrganizeSourceView } from "@umt/contracts";
+import { cloneElement, type ReactElement, useId, useState } from "react";
+import { toast } from "sonner";
+import { filesErrorText, useFileRoots } from "~/api/files.ts";
+import { downloaders } from "~/api/instances.ts";
+import {
+ useClassification,
+ useOrganizeSources,
+ useOrganizeStock,
+ useRemoveOrganizeSource,
+ useSaveClassification,
+ useSaveOrganizeSource,
+} from "~/api/organize-sources.ts";
+import { openAgentDrawer } from "~/components/agent/agent-store.ts";
+import { useListPagination } from "~/components/console/use-list-pagination.ts";
+import { DirectoryDialog } from "~/components/files/directory-dialog.tsx";
+import { stockWizardSource } from "~/components/organize/source-selection.tsx";
+import { type OrganizeSource, OrganizeWizard } from "~/components/organize-wizard/organize-wizard.tsx";
+import { Button } from "~/components/ui/button.tsx";
+import { Dialog, DialogContent, DialogDescription, DialogHeader, DialogTitle } from "~/components/ui/dialog.tsx";
+import { Input } from "~/components/ui/input.tsx";
+import { Pagination } from "~/components/ui/pagination.tsx";
+import { Switch } from "~/components/ui/switch.tsx";
+import { Textarea } from "~/components/ui/textarea.tsx";
+import { formatDateTime } from "~/lib/utils.ts";
+import { SaveBar, SettingsBlock } from "./settings-block.tsx";
+
+const selectClass = "w-full rounded-lg border border-border bg-background px-3 py-2 text-caption";
+function Field({ label, children }: { label: string; children: ReactElement<{ id?: string }> }) {
+ const id = useId();
+ return (
+
+ );
+}
+export function ClassificationSection() {
+ const config = useClassification();
+ const save = useSaveClassification();
+ const [draft, setDraft] = useState(null);
+ const yaml = draft ?? config.data?.yaml ?? "";
+ const dirty = draft !== null && draft !== config.data?.yaml;
+ return (
+
+ openAgentDrawer({
+ label: "媒体分类规则",
+ goal: `协助检查和修改媒体分类 YAML，说明调整后的匹配结果。当前规则：\n${yaml}`,
+ })
+ }
+ >
+ 让智能体协助
+
+ }
+ >
+ {config.error ? (
+
+ {filesErrorText(config.error, "读取分类规则失败")}
+
+ ) : null}
+