From 8593e40021932b9405a285e0c64f5946c19d75c1 Mon Sep 17 00:00:00 2001
From: KyokoMiki <161209740+KyokoMiki@users.noreply.github.com>
Date: Mon, 29 Jul 2024 11:03:37 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E6=94=AF=E6=8C=81Deluge?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

feat: 新增 rss 规格克隆
---
 app/libs/client/de.js               | 61 +++++++++++++++++++++++++++++
 webui/src/pages/base/Downloader.vue |  3 +-
 webui/src/pages/rule/Rss.vue        |  5 +++
 3 files changed, 68 insertions(+), 1 deletion(-)

diff --git a/app/libs/client/de.js b/app/libs/client/de.js
index e351fe9a..6a5b9f2e 100644
--- a/app/libs/client/de.js
+++ b/app/libs/client/de.js
@@ -1,4 +1,5 @@
 const util = require('../util');
+const fs = require('fs');
 
 exports.login = async function (username, clientUrl, password) {
   const message = {
@@ -84,6 +85,65 @@ exports.addTorrent = async function (clientUrl, cookie, torrentUrl, isSkipChecki
   return res;
 };
 
+exports.addTorrentByTorrentFile = async function (clientUrl, cookie, filepath, isSkipChecking, uploadLimit, downloadLimit, savePath, label) {
+  let message = {
+    url: clientUrl + '/upload',
+    method: 'POST',
+    headers: {
+      cookie
+    },
+    formData: {
+      file: fs.createReadStream(filepath)
+    }
+  };
+  let res = await util.requestPromise(message);
+  const torrentPath = JSON.parse(res.body).files[0];
+  message = {
+    method: 'POST',
+    url: clientUrl + '/json',
+    json: true,
+    gzip: true,
+    body: {
+      id: 0,
+      method: 'web.add_torrents',
+      params: [
+        [
+          {
+            path: torrentPath,
+            options: {
+              file_priorities: [
+                1
+              ],
+              add_paused: false,
+              sequential_download: false,
+              pre_allocate_storage: false,
+              move_completed: false,
+              max_connections: -1,
+              max_download_speed: downloadLimit,
+              max_upload_slots: -1,
+              max_upload_speed: uploadLimit,
+              prioritize_first_last_pieces: false,
+              seed_mode: isSkipChecking,
+              super_seeding: false
+            }
+          }
+        ]
+      ]
+    },
+    headers: {
+      cookie
+    }
+  };
+  if (savePath) {
+    message.body.params[0][0].options.download_location = savePath;
+  }
+  if (label) {
+    message.body.params[0][0].options.label = label;
+  }
+  res = await util.requestPromise(message);
+  return res;
+};
+
 exports.getMaindata = async function (clientUrl, cookie) {
   const option = {
     method: 'POST',
@@ -148,6 +208,7 @@ exports.getMaindata = async function (clientUrl, cookie) {
     }
     torrent.progress = torrent.progress / 100;
     if (+torrent.progress === -1) torrent.progress = 0;
+    torrent.originProp = { ...res.torrents[k] };
     torrent.completedTime = Math.max(Date.now() / 1000 - torrent.seedingTime, torrent.addedTime);
     maindata.torrents.push(torrent);
   }
diff --git a/webui/src/pages/base/Downloader.vue b/webui/src/pages/base/Downloader.vue
index 65dec215..ea931101 100644
--- a/webui/src/pages/base/Downloader.vue
+++ b/webui/src/pages/base/Downloader.vue
@@ -90,11 +90,12 @@
         <a-form-item
           label="下载器类型"
           name="type"
-          extra="下载器类型, 目前仅支持 qBittorrent 与 Transmission"
+          extra="下载器类型, 目前完整支持 qBittorrent, Deluge 和 Transmission 不完全支持"
           :rules="[{ required: true, message: '${label}不可为空! ' }]">
           <a-select size="small" v-model:value="downloader.type"  >
             <a-select-option value="qBittorrent">qBittorrent</a-select-option>
             <a-select-option value="Transmission">Transmission</a-select-option>
+            <a-select-option value="deluge">Deluge</a-select-option>
           </a-select>
         </a-form-item>
         <a-form-item
diff --git a/webui/src/pages/rule/Rss.vue b/webui/src/pages/rule/Rss.vue
index 49001a58..7996d9e6 100644
--- a/webui/src/pages/rule/Rss.vue
+++ b/webui/src/pages/rule/Rss.vue
@@ -26,6 +26,8 @@
         </template>
         <template v-if="column.title === '操作'">
           <span>
+            <a @click="cloneClick(record)">克隆</a>
+            <a-divider type="vertical" />
             <a @click="modifyClick(record)">编辑</a>
             <a-divider type="vertical" />
             <a-popover title="删除?" trigger="click" :overlayStyle="{ width: '84px', overflow: 'hidden' }">
@@ -280,6 +282,9 @@ export default {
     modifyClick (row) {
       this.rssRule = { ...row };
     },
+    cloneClick (row) {
+      this.rssRule = { ...row, id: undefined };
+    },
     async deleteRssRule (row) {
       if (row.used) {
         this.$message().error('组件被占用, 取消占用后删除');