feat: add unified torrent management page (MyClient) under Overview

src/entries/messages.ts

@@ -11,7 +11,7 @@ import type {
 import type { ISocialInformation, TSupportSocialSite$1 } from "@ptd/social";
 import type { IMediaServerId, IMediaServerSearchOptions, IMediaServerSearchResult } from "@ptd/mediaServer";
 import type { IBackupData, IBackupFileInfo } from "@ptd/backupServer";
-import type { TorrentClientStatus } from "@ptd/downloader";
+import type { CTorrent, TorrentClientStatus } from "@ptd/downloader";
 
 // 可序列化的种子信息，用于辅种检测
 export interface ITorrentInfoForVerification {
@@ -113,6 +113,11 @@ interface ProtocolMap extends TMessageMap {
   getTorrentDownloadLink(torrent: ITorrent): string;
   getTorrentInfoForVerification(torrent: ITorrent): ITorrentInfoForVerification;
 
+  getClientTorrents(downloaderId: string): CTorrent[];
+  deleteClientTorrent(data: { downloaderId: string; id: any; removeData?: boolean }): boolean;
+  pauseClientTorrent(data: { downloaderId: string; id: any }): boolean;
+  resumeClientTorrent(data: { downloaderId: string; id: any }): boolean;
+
   downloadTorrent(data: IDownloadTorrentOption): IDownloadTorrentResult;
 
   getDownloadHistory(): ITorrentDownloadMetadata[];

src/entries/offscreen/utils/download.ts

@@ -6,6 +6,7 @@ import { isEmpty } from "es-toolkit/compat";
 import {
   getDownloader,
   getRemoteTorrentFile,
+  type CTorrent,
   type CAddTorrentOptions,
   type TorrentClientStatus,
 } from "@ptd/downloader";
@@ -39,6 +40,30 @@ export async function getDownloaderConfig(downloaderId: string) {
   return metadataStore?.downloaders?.[downloaderId] ?? ({} as IDownloaderMetadata);
 }
 
+type DownloaderInstance = Awaited<ReturnType<typeof getDownloader>>;
+
+const downloaderInstanceCache = new Map<string, { configKey: string; instance: DownloaderInstance }>();
+
+function getDownloaderConfigKey(config: IDownloaderMetadata): string {
+  const { id, type, address, username, password, timeout } = config;
+  return JSON.stringify({ id, type, address, username, password, timeout });
+}
+
+export async function getDownloaderInstance(downloaderId: string): Promise<DownloaderInstance | null> {
+  const downloaderConfig = await getDownloaderConfig(downloaderId);
+  if (!downloaderConfig.id) return null;
+
+  const configKey = getDownloaderConfigKey(downloaderConfig);
+  const cached = downloaderInstanceCache.get(downloaderId);
+  if (cached && cached.configKey === configKey) {
+    return cached.instance;
+  }
+
+  const instance = await getDownloader(downloaderConfig);
+  downloaderInstanceCache.set(downloaderId, { configKey, instance });
+  return instance;
+}
+
 onMessage("getDownloaderConfig", async ({ data: downloaderId }) => await getDownloaderConfig(downloaderId));
 
 onMessage("getDownloaderList", async () => {
@@ -56,9 +81,8 @@ onMessage("getDownloaderList", async () => {
 onMessage("getDownloaderVersion", async ({ data: downloaderId }) => {
   let downloaderVersion = "unknown";
 
-  const downloaderConfig = await getDownloaderConfig(downloaderId);
-  if (downloaderConfig.id) {
-    const downloaderInstance = await getDownloader(downloaderConfig);
+  const downloaderInstance = await getDownloaderInstance(downloaderId);
+  if (downloaderInstance) {
     downloaderVersion = await downloaderInstance.getClientVersion();
   }
 
@@ -68,9 +92,8 @@ onMessage("getDownloaderVersion", async ({ data: downloaderId }) => {
 onMessage("getDownloaderStatus", async ({ data: downloaderId }) => {
   let downloaderStatus: TorrentClientStatus = { dlSpeed: 0, upSpeed: 0, dlData: 0, upData: 0 };
 
-  const downloaderConfig = await getDownloaderConfig(downloaderId);
-  if (downloaderConfig.id) {
-    const downloaderInstance = await getDownloader(downloaderConfig);
+  const downloaderInstance = await getDownloaderInstance(downloaderId);
+  if (downloaderInstance) {
     downloaderStatus = await downloaderInstance.getClientStatus();
   }
 
@@ -108,6 +131,44 @@ export async function getTorrentInfoForVerification(torrent: ITorrent) {
 
 onMessage("getTorrentInfoForVerification", async ({ data: torrent }) => await getTorrentInfoForVerification(torrent));
 
+onMessage("getClientTorrents", async ({ data: downloaderId }) => {
+  let downloaderTorrents: CTorrent[] = [];
+  const downloaderInstance = await getDownloaderInstance(downloaderId);
+  if (downloaderInstance) {
+    downloaderTorrents = await downloaderInstance.getAllTorrents();
+  }
+  return downloaderTorrents;
+});
+
+onMessage("deleteClientTorrent", async ({ data: { downloaderId, id, removeData } }) => {
+  let deleteStatus: boolean = false;
+  const downloaderInstance = await getDownloaderInstance(downloaderId);
+  if (downloaderInstance) {
+    deleteStatus = await downloaderInstance.removeTorrent(id, removeData ?? false);
+  }
+  return deleteStatus;
+});
+
+onMessage("pauseClientTorrent", async ({ data: { downloaderId, id } }) => {
+  let pauseStatus: boolean = false;
+  const downloaderInstance = await getDownloaderInstance(downloaderId);
+  if (downloaderInstance) {
+    pauseStatus = await downloaderInstance.pauseTorrent(id);
+  }
+
+  return pauseStatus;
+});
+
+onMessage("resumeClientTorrent", async ({ data: { downloaderId, id } }) => {
+  let resumeStatus: boolean = false;
+  const downloaderInstance = await getDownloaderInstance(downloaderId);
+  if (downloaderInstance) {
+    resumeStatus = await downloaderInstance.resumeTorrent(id);
+  }
+
+  return resumeStatus;
+});
+
 function buildDownloadHistory(downloadOption: IDownloadTorrentOption): ITorrentDownloadMetadata {
   const { torrent = {}, downloaderId = "local" } = downloadOption;
   return {
@@ -298,7 +359,8 @@ async function downloadTorrentToRemote(
 
   const downloaderConfig = await getDownloaderConfig(downloaderId);
   if (downloaderConfig.id && downloaderConfig.enabled) {
-    const downloaderInstance = await getDownloader(downloaderConfig);
+    const downloaderInstance = await getDownloaderInstance(downloaderId);
+    if (!downloaderInstance) return downloadStatus;
     if (addTorrentOptions.localDownload) {
       addTorrentOptions.localDownloadOption = downloadRequestConfig;
     }

src/entries/options/components/DeleteDialog.vue

@@ -37,10 +37,14 @@ async function dialogEnter() {
         {{ t("common.dialog.title.confirmAction") }}
       </v-card-title>
 
-      <v-card-text>
+      <v-card-text class="text-body-1">
         {{ t("common.dialog.deleteText", [toDeleteIds!.length]) }}
+
+        <slot name="append-text" />
       </v-card-text>
 
+      <v-divider />
+
       <v-card-actions>
         <v-spacer />
         <v-btn color="info" prepend-icon="mdi-close-circle" variant="text" @click="showDialog = false">

src/entries/options/components/SentToDownloaderDialog/utils.ts

@@ -54,12 +54,15 @@ export function sendTorrentToDownloader(
       const replaceMap: Record<string, string> = {
         "torrent.title": torrent.title ?? "",
         "torrent.subTitle": torrent.subTitle ?? "",
-        "torrent.site": torrent.site,
-        "torrent.siteName": await metadataStore.getSiteName(torrent.site),
         "torrent.category": (torrent.category as string) ?? "",
         ...baseReplaceMap,
       };
 
+      if (torrent.site) {
+        replaceMap["torrent.site"] = torrent.site;
+        replaceMap["torrent.siteName"] = await metadataStore.getSiteName(torrent.site);
+      }
+
       for (const key of ["savePath", "label"] as (keyof typeof realAddTorrentOptions)[]) {
         if (realAddTorrentOptions[key]) {
           if (realAddTorrentOptions[key] === "") {

src/entries/options/main.scss

@@ -50,3 +50,9 @@ a:not(:hover) {
 .list-item-half-spacer > .v-list-item__prepend > .v-icon ~ .v-list-item__spacer {
   width: 12px;
 }
+
+.status-btn {
+  i.v-icon + i.v-icon {
+    margin-left: 4px;
+  }
+}

src/entries/options/plugins/router.ts

@@ -77,6 +77,12 @@ export const routes: RouteRecordRaw[] = [
         meta: { icon: "mdi-play-network" },
         component: () => import("../views/Overview/MediaServerEntity/Index.vue"),
       },
+      {
+        path: "/my-client",
+        name: "MyClient",
+        meta: { icon: "mdi-download-network" },
+        component: () => import("../views/Overview/MyClient/Index.vue"),
+      },
       {
         path: "/download-history",
         name: "DownloadHistory",

src/entries/options/stores/config.ts

@@ -139,6 +139,22 @@ export const useConfigStore = defineStore("config", {
         itemsPerPage: 10,
         sortBy: [{ key: "enabled", order: "desc" }],
       },
+      MyClient: {
+        itemsPerPage: 25,
+        columns: [
+          "clientId",
+          "name",
+          "totalSize",
+          "progress",
+          "state",
+          "ratio",
+          "uploadSpeed",
+          "downloadSpeed",
+          "dateAdded",
+          "action",
+        ],
+        sortBy: [{ key: "dateAdded", order: "desc" }],
+      },
       SetSearchSolution: {
         itemsPerPage: 10,
       },
@@ -243,7 +259,7 @@ export const useConfigStore = defineStore("config", {
 
     download: {
       saveDownloadHistory: true,
-      startupAutoFetchDownloaderStatus: false,
+      initDownloaderTorrentOnEnter: false,
       saveLastDownloader: false,
       allowDirectSendToClient: false,
       localDownloadMethod: "browser",