From 97d635fbc744be1dfe704826d2ef604f14bfabfe Mon Sep 17 00:00:00 2001
From: root <root@debian.debian>
Date: Wed, 7 Oct 2026 16:15:23 +0800
Subject: [PATCH] =?UTF-8?q?=E6=A1=8C=E9=9D=A2=E4=B8=8B=E8=BD=BD=E7=AB=AF?=
 =?UTF-8?q?=E6=94=B9=E7=94=A8=E5=85=B1=E4=BA=AB=E6=A0=B8=E5=BF=83=E5=8C=85?=
 =?UTF-8?q?=EF=BC=8C=E5=B9=B6=E4=BF=AE=E4=B8=A4=E5=A4=84=E5=B7=B2=E7=9F=A5?=
 =?UTF-8?q?=E7=BC=BA=E9=99=B7?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- store 改由 createGalleryStore 生成：totalGalleryTask 成为唯一任务源，
  收藏/下载/分类/搜索结果全部由 getter 派生，不再维护三份互相引用的数组
- 排序不再原地修改分类数组；本地搜索记住关键词，任务刷新后结果仍在
- 本地搜索结果补齐翻页入口：此前匹配 25 项却只显示 10 项，其余无法看到
- 取消收藏不再因本地找不到 gid 抛 TypeError
- 删除重复的 taskSocket/progressiveImages/validate/thumbnail，改从共享包导入
- 远端搜索改用共享 fetchGalleries，关键词交给 axios 序列化，翻页按游标转发
- main.js 按需注册 Element Plus，入口 JS 由约 1.14MB 降到约 494KB
- 依赖新增 file:../lionwebsite-frontend-shared

测试：14 项通过；构建成功，入口仍为 /asserts/index/index.js|css。
---
 package-lock.json                |   8 +
 package.json                     |   3 +-
 src/components/DetailPanel.vue   |   2 +-
 src/components/OnlineReader.vue  |   4 +-
 src/components/SearchView.vue    |  59 ++--
 src/components/TaskView.vue      |   2 +-
 src/main.js                      |  13 +-
 src/store/index.js               | 584 +------------------------------
 src/utils/progressiveImages.js   |  23 --
 src/utils/taskSocket.js          |  76 ----
 src/utils/thumbnail.js           |  27 --
 src/utils/validate.js            |   8 -
 tests/progressiveImages.test.mjs |  33 --
 tests/search.test.mjs            |  37 ++
 tests/store.test.mjs             | 186 +++++-----
 tests/taskSocket.test.mjs        |  63 ----
 tests/thumbnail.test.mjs         |  33 --
 17 files changed, 208 insertions(+), 953 deletions(-)
 delete mode 100644 src/utils/progressiveImages.js
 delete mode 100644 src/utils/taskSocket.js
 delete mode 100644 src/utils/thumbnail.js
 delete mode 100644 src/utils/validate.js
 delete mode 100644 tests/progressiveImages.test.mjs
 create mode 100644 tests/search.test.mjs
 delete mode 100644 tests/taskSocket.test.mjs
 delete mode 100644 tests/thumbnail.test.mjs

diff --git a/package-lock.json b/package-lock.json
index 9bcc2fe..f4975c6 100644
--- a/package-lock.json
+++ b/package-lock.json
@@ -10,6 +10,7 @@
       "dependencies": {
         "axios": "^1.0.0",
         "element-plus": "^2.2.0",
+        "lionwebsite-frontend-shared": "file:../lionwebsite-frontend-shared",
         "qs": "^6.11.0",
         "vue": "^3.0.4",
         "vuex": "^4.0.2"
@@ -19,6 +20,9 @@
         "vite": "8.3.0"
       }
     },
+    "../lionwebsite-frontend-shared": {
+      "version": "1.0.0"
+    },
     "node_modules/@babel/helper-string-parser": {
       "version": "7.29.7",
       "resolved": "https://registry.npmjs.org/@babel/helper-string-parser/-/helper-string-parser-7.29.7.tgz",
@@ -1272,6 +1276,10 @@
         "url": "https://opencollective.com/parcel"
       }
     },
+    "node_modules/lionwebsite-frontend-shared": {
+      "resolved": "../lionwebsite-frontend-shared",
+      "link": true
+    },
     "node_modules/lodash": {
       "version": "4.18.1",
       "resolved": "https://registry.npmjs.org/lodash/-/lodash-4.18.1.tgz",
diff --git a/package.json b/package.json
index 364a549..275618d 100644
--- a/package.json
+++ b/package.json
@@ -13,7 +13,8 @@
     "element-plus": "^2.2.0",
     "qs": "^6.11.0",
     "vue": "^3.0.4",
-    "vuex": "^4.0.2"
+    "vuex": "^4.0.2",
+    "lionwebsite-frontend-shared": "file:../lionwebsite-frontend-shared"
   },
   "devDependencies": {
     "@vitejs/plugin-vue": "6.0.9",
diff --git a/src/components/DetailPanel.vue b/src/components/DetailPanel.vue
index 8c12a91..999fb7c 100644
--- a/src/components/DetailPanel.vue
+++ b/src/components/DetailPanel.vue
@@ -3,7 +3,7 @@ import {computed, ref, watch} from "vue";
 import {ElMessage} from "element-plus";
 import store from "../store/index.js";
 import AppIcon from "./AppIcon.vue";
-import {ehThumbnailUrl, pickDefaultResolution} from "../utils/thumbnail.js";
+import {ehThumbnailUrl, pickDefaultResolution} from "lionwebsite-frontend-shared";
 
 const targetResolution = ref("");
 const isRetrying = ref(false);
diff --git a/src/components/OnlineReader.vue b/src/components/OnlineReader.vue
index 11b0e72..fdd4b90 100644
--- a/src/components/OnlineReader.vue
+++ b/src/components/OnlineReader.vue
@@ -1,9 +1,9 @@
 <script setup>
 import {computed, nextTick, onBeforeUnmount, ref, watch} from "vue";
-import {startImages, settleImage, retryImage} from "../utils/progressiveImages.js";
+import {startImages, settleImage, retryImage} from "lionwebsite-frontend-shared";
 import store from "../store/index.js";
 import AppIcon from "./AppIcon.vue";
-import {ehThumbnailUrl} from "../utils/thumbnail.js";
+import {ehThumbnailUrl} from "lionwebsite-frontend-shared";
 
 const viewer = ref(null);
 const readingGallery = computed(() => store.state.readingGallery);
diff --git a/src/components/SearchView.vue b/src/components/SearchView.vue
index 2c44dca..2263d2f 100644
--- a/src/components/SearchView.vue
+++ b/src/components/SearchView.vue
@@ -5,8 +5,7 @@ import {ElMessage} from "element-plus";
 import store from "../store/index.js";
 import TaskRow from "./TaskRow.vue";
 import AppIcon from "./AppIcon.vue";
-import {validateLink} from "../utils/validate.js";
-import {ehThumbnailUrl} from "../utils/thumbnail.js";
+import {ehThumbnailUrl, fetchGalleries, validateLink} from "lionwebsite-frontend-shared";
 
 const mode = ref("ehentai");
 const localMode = ref("keyword");
@@ -20,8 +19,16 @@ const remoteLoading = ref(false);
 const retryingGids = ref(new Set());
 
 const localResults = computed(() => store.getters.currentTasks || []);
-const localTotal = computed(() => store.state.searchTask.length);
+const localTotal = computed(() => (store.getters.filteredTasks || []).length);
 const isSearching = computed(() => store.state.isSearch);
+const localPage = computed(() => store.state.page);
+const localMin = computed(() => store.getters.min);
+const localMax = computed(() => store.getters.max);
+
+function gotoLocalPage(value) {
+  if (value < localMin.value || value > localMax.value) return;
+  store.commit("_changePage", value);
+}
 
 function runLocalSearch() {
   if (localKeyword.value.trim() === "") {
@@ -37,32 +44,20 @@ function clearLocalSearch() {
   localKeyword.value = "";
 }
 
-function queryGalleries(link) {
-  let keyword;
-  if (link != null) {
-    keyword = new URL(link).search.replace("?f_search=", "");
-  } else {
-    keyword = remoteKeyword.value;
-    if (keyword.trim() === "") {
-      ElMessage("请输入搜索关键词");
-      return;
-    }
+// direction 为 "next"/"prev" 时使用后端返回的翻页游标；href 为空表示新关键词。
+function queryGalleries(href, direction = null) {
+  if (href == null && remoteKeyword.value.trim() === "") {
+    ElMessage("请输入搜索关键词");
+    return;
   }
   remoteLoading.value = true;
-  axios.get("https://downloader.lionwebsite.xyz/query?keyword=" + keyword.replace(" ", "+"))
-      .then(res => {
-        if (res.data.result === "success") {
-          remotePage.value = {
-            first: res.data.first,
-            previous: res.data.previous,
-            next: res.data.next,
-            last: res.data.last,
-          };
-          remoteGalleries.value.splice(0);
-          JSON.parse(res.data.data).forEach(g => remoteGalleries.value.push(g));
-        } else {
-          ElMessage({message: res.data.data, type: "error"});
-        }
+  fetchGalleries(axios, {keyword: remoteKeyword.value, direction, href: href || ""})
+      .then(({galleries, pagination}) => {
+        remotePage.value = pagination;
+        remoteGalleries.value.splice(0, remoteGalleries.value.length, ...galleries);
+      })
+      .catch(error => {
+        ElMessage({message: error.payload || error.message || "搜索失败", type: "error"});
       })
       .finally(() => {
         remoteLoading.value = false;
@@ -159,8 +154,8 @@ async function retryGallery(gallery) {
 
         <div class="pager-row" v-if="remoteGalleries.length">
           <el-button size="small" :disabled="remotePage.first === undefined" @click="queryGalleries(remotePage.first)">首页</el-button>
-          <el-button size="small" :disabled="remotePage.previous === undefined" @click="queryGalleries(remotePage.previous)">上一页</el-button>
-          <el-button size="small" :disabled="remotePage.next === undefined" @click="queryGalleries(remotePage.next)">下一页</el-button>
+          <el-button size="small" :disabled="remotePage.previous === undefined" @click="queryGalleries(remotePage.previous, 'prev')">上一页</el-button>
+          <el-button size="small" :disabled="remotePage.next === undefined" @click="queryGalleries(remotePage.next, 'next')">下一页</el-button>
           <el-button size="small" :disabled="remotePage.last === undefined" @click="queryGalleries(remotePage.last)">尾页</el-button>
         </div>
       </template>
@@ -190,6 +185,12 @@ async function retryGallery(gallery) {
                    @open="store.commit('_selectGallery', $event)"
                    @download="downloadTask"
                    @retry="retryGallery" />
+          <!-- 命中项可能多于每页条数，必须给出翻页入口，否则后面的结果看不到。 -->
+          <div class="pager-row" v-if="localMax > 1">
+            <el-button size="small" :disabled="localPage <= localMin" @click="gotoLocalPage(localPage - 1)">上一页</el-button>
+            <span class="hint">第 {{ localPage }} / {{ localMax }} 页</span>
+            <el-button size="small" :disabled="localPage >= localMax" @click="gotoLocalPage(localPage + 1)">下一页</el-button>
+          </div>
         </template>
         <p v-else class="empty-state">输入关键字或链接在已有任务里查找</p>
       </template>
diff --git a/src/components/TaskView.vue b/src/components/TaskView.vue
index 5f2165c..2344176 100644
--- a/src/components/TaskView.vue
+++ b/src/components/TaskView.vue
@@ -42,7 +42,7 @@ const downloaderFilter = computed({
 // downloader that would filter the visible list down to nothing.
 const downloaderOptions = computed(() => {
   const seen = new Map();
-  ;(store.state.currentTasks || []).forEach(task => {
+  ;(store.getters.categoryGallery || []).forEach(task => {
     if (task.downloaderName && !seen.has(task.downloader))
       seen.set(task.downloader, task.downloaderName);
   });
diff --git a/src/main.js b/src/main.js
index 9e41418..03bd7c2 100644
--- a/src/main.js
+++ b/src/main.js
@@ -1,9 +1,18 @@
 import { createApp } from 'vue'
 import App from './App.vue'
+import {
+    ElButton, ElCheckbox, ElDialog, ElForm, ElFormItem, ElImage, ElInput,
+    ElInputNumber, ElOption, ElProgress, ElScrollbar, ElSelect, ElSwitch,
+} from "element-plus"
 import 'element-plus/dist/index.css'
-import element from "element-plus"
 import "./reset.css"
 import 'element-plus/theme-chalk/dark/css-vars.css'
 import "./styles/theme.css"
 
-createApp(App).use(element).mount('#app')
+// 只注册本仓库用到的组件，避免把整个 Element Plus 打进入口包。
+// ElMessage 是函数式 API，按需在组件里 import 即可。
+const app = createApp(App)
+for (const component of [ElButton, ElCheckbox, ElDialog, ElForm, ElFormItem, ElImage,
+    ElInput, ElInputNumber, ElOption, ElProgress, ElScrollbar, ElSelect, ElSwitch])
+    app.component(component.name, component)
+app.mount('#app')
diff --git a/src/store/index.js b/src/store/index.js
index 6633bc2..a1d5eb7 100644
--- a/src/store/index.js
+++ b/src/store/index.js
@@ -2,11 +2,7 @@ import vuex from "vuex"
 import axios from "axios"
 import {ElMessage} from "element-plus"
 import qs from "qs"
-import {createTaskSocket} from "../utils/taskSocket.js"
-let taskSocket
-let taskRefreshVersion = 0
-const BaseUrl = "https://downloader.lionwebsite.xyz/"
-const GalleryManageUrl = BaseUrl + "GalleryManage"
+import {createGalleryStore} from "lionwebsite-frontend-shared"
 
 // Axios 全局错误处理
 axios.interceptors.response.use(
@@ -17,574 +13,10 @@ axios.interceptors.response.use(
     }
 )
 
-const actions = {
-    reconnect(context) {
-      axios.post(GalleryManageUrl + "/reconnect", null, {
-          params: {
-              AuthCode: context.state.AuthCode
-          }
-      }).then(res => {
-          if (res.data.result === "success") {
-              ElMessage("重连成功")
-          } else {
-              ElMessage("重连失败")
-          }
-      })
-    },
-    updateGalleryTasks(context){
-        const version = ++taskRefreshVersion
-        return axios.get(GalleryManageUrl, {
-            params:{
-                AuthCode: context.state.AuthCode,
-                type: 'all'
-            }
-        }).then((res) => {
-            if(res.data.result === "success" && version === taskRefreshVersion)
-                context.commit("_updateGalleryTasks", JSON.parse(res.data.data))
-        })
-    },
-    postGalleryTask(context, data){
-        return axios.post(GalleryManageUrl + '?' + qs.stringify({
-            AuthCode: context.state.AuthCode,
-            ...data
-        }, {indices:false})).then((res) => {
-            if(res.data.result === "success") {
-                ElMessage("提交成功")
-                context.commit("_setChosenGallery", {gallery: false})
-            }
-            else
-                if(res.data.data)
-                    ElMessage(res.data.data)
-                else
-                    ElMessage("提交失败")
-            // A node timeout can still leave a persisted task; always reload its actual state.
-            return Promise.all([context.dispatch("updateGalleryTasks"), context.dispatch("loadWeekUsedAmount")])
-        })
-    },
-    queryGalleryTask(context, link){
-        axios.get(GalleryManageUrl, {
-            params:{
-                param: link,
-                type: 'link',
-                AuthCode: context.state.AuthCode
-            }
-        }).then((res) => {
-            if(res.data.result === 'success'){
-                let gallery = JSON.parse(res.data.data)
-                if(gallery.status === "下载完成")
-                    gallery.download = buildGalleryDownloadUrl(gallery.gid, context.state.AuthCode)
-                context.commit("_setChosenGallery", {gallery})
-            }
-            else
-                ElMessage("查询失败")
-        })
-    },
-    validate(context, AuthCode){
-        axios.post(BaseUrl + "validate?AuthCode=" + AuthCode).then((res)=>{
-            if(res.data.result === 'success'){
-                let data = JSON.parse(res.data.data);
-                if(!data.isAvailable)
-                    ElMessage({duration:0, message:"节点挂了，不能下也不能看，找狮子处理", type: "error"})
-                context.commit("_authed", {AuthCode, ...data})
-                //初始化
-                context.dispatch("loadWeekUsedAmount").then()
-                context.dispatch("updateGalleryTasks").then(() => confirmCurrentTask(context.state))
-                context.dispatch("initWebsocket").then()
-            }
-            else {
-                context.dispatch("disconnectWebsocket")
-                context.commit("_unAuthed")
-            }
-        })
-    },
-    initWebsocket(context){
-        taskSocket?.stop()
-        taskSocket = createTaskSocket({
-            url: "wss://downloader.lionwebsite.xyz/ws/",
-            onState: status => context.commit("_setConnectionStatus", status),
-            onOpen: () => {
-                // Catch up on every connection, including events missed during an outage.
-                Promise.all([context.dispatch("updateGalleryTasks"), context.dispatch("loadWeekUsedAmount")]).catch(() => {})
-            },
-            onMessage: event => {
-                let message
-                try { message = JSON.parse(event.data) }
-                catch { return }
-                if(message.type === "updateTasks" && Array.isArray(message.data))
-                    context.commit("_updateGalleryTaskProceeding", message.data)
-                else if(message.type === "fullUpdate")
-                    context.dispatch("updateGalleryTasks").catch(() => {})
-            }
-        })
-        taskSocket.start()
-    },
-    disconnectWebsocket(context){
-        taskSocket?.stop()
-        taskSocket = undefined
-        context.commit("_setConnectionStatus", "disconnected")
-    },
-    loadWeekUsedAmount(context){
-        return axios.get(GalleryManageUrl + "/weekUsedAmount", {
-            params: {
-                AuthCode: context.state.AuthCode
-            }
-        }).then((res) => {
-            if(res.data.result === "success"){
-                context.state.weekUsed = JSON.parse(res.data.data)
-            }else
-                ElMessage("查询用量失败")
-        })
-    },
-    collectGallery(context, gid){
-        axios.post(GalleryManageUrl + "/collect?" +qs.stringify( {
-                gid, AuthCode:context.state.AuthCode
-            })).then((res) => {
-            ElMessage(res.data.data)
-            if(res.data.result === 'success')
-                context.commit("_collectGallery", gid)
-        })
-    },
-    disCollectGallery(context, gid){
-        axios.post(GalleryManageUrl + "/disCollect?" + qs.stringify({
-                gid, AuthCode:context.state.AuthCode
-            })).then((res) => {
-            ElMessage(res.data.data)
-            if(res.data.result === 'success')
-                context.commit("_disCollectGallery", gid)
-        })
-    },
-    deleteGallery(context, gid){
-        // Returned so callers can clear a selection once the task is really gone.
-        return axios.delete(GalleryManageUrl, {
-            params:{
-                AuthCode:context.state.AuthCode, gid
-            }}).then((res) => {
-            if(res.data.result === "success"){
-                ElMessage("删除成功")
-                context.commit("_deleteGallery", gid)
-            }
-            else
-                ElMessage(res.data.data)
-        })
-    },
-    retryGallery(context, gid){
-        return axios.post(GalleryManageUrl + "/retry?" + qs.stringify({
-            gid, AuthCode: context.state.AuthCode
-        })).then((res) => {
-            if(res.data.result === "success"){
-                ElMessage({message: "重试结果：" + res.data.data, type: "success"})
-                return context.dispatch("updateGalleryTasks")
-            }
-            ElMessage({message: res.data.data || "重试失败", type: "error"})
-        })
-    },
-    readOnlineGallery(context, gallery){
-        if(gallery.images !== undefined && gallery.images.length !== 0)
-            context.commit("_setReadingGallery", gallery)
-        else
-            return axios.post(GalleryManageUrl + "/cache", null, {
-                params: {url: gallery.link, AuthCode: context.state.AuthCode}
-            }).then((res) => {
-                if (res.data.result === 'success') {
-                    gallery.pages = res.data.data.pages
-                    setTimeout(() => {
-                        context.commit("_setReadingGallery", gallery)
-                    }, 100)
-                } else
-                    ElMessage.error(res.data.data)
-            })
-    },
-    alterAuthCode(context, AuthCode){
-        axios.put(BaseUrl + "AuthCode?" + qs.stringify({'AuthCode': context.state.AuthCode, 'newAuthCode': AuthCode}))
-            .then((res) => {
-                if(res.data.result === 'success') {
-                    ElMessage("修改成功")
-                    if(localStorage.getItem("auth") === context.state.AuthCode)
-                        localStorage.setItem("auth", AuthCode)
-                    context.state.AuthCode = AuthCode
-                }
-                else
-                    ElMessage(res.data.data)
-            })
-    },
-    resetUndone(context){
-        axios.post(GalleryManageUrl + "/reset?AuthCode=" + context.state.AuthCode).then((res) => {
-            ElMessage(res.data.data)
-        })
-    }
-}
-
-const mutations = {
-    _setConnectionStatus(state, status){
-        state.connectionStatus = status
-    },
-    _collectGallery(state, gid){
-        let tasks = state.totalGalleryTask
-        for(let i=0; i< tasks.length; i++){
-            if(!tasks[i].isCollect && tasks[i].gid === gid){
-                tasks[i].isCollect = true
-                state.collectGallery.push(tasks[i])
-            }
-        }
-    },
-    _disCollectGallery(state, gid){
-        let index
-        for(let i=0; i < state.collectGallery.length; i++)
-            if(state.collectGallery[i].gid === gid){
-                index = i
-                break
-            }
-        state.collectGallery[index].isCollect = false
-        state.collectGallery.splice(index, 1)
-    },
-    _updateGalleryTasks(state, tasks){
-        state.totalGalleryTask.splice(0)
-        state.collectGallery.splice(0)
-        state.downloadGallery.splice(0)
-
-        tasks.forEach((task) => {
-            //处理名字
-            task.shortName = getShortname(task.name)
-            if(task.thumb_link.trim() !== '')
-                task.thumb_link = buildGalleryManageUrl("/ehThumbnail", {
-                    path: task.thumb_link,
-                    AuthCode: state.AuthCode
-                })
-            else
-                delete task.thumb_link
-
-            //处理进度相关
-            switch (task.status) {
-                case "已提交":
-                case "等待压缩":
-                case "压缩中":
-                    task.progress = task.status
-                    break;
-                case "下载中":
-                    task.progress = (Math.round((task.proceeding / task.pages) * 100)).toString() + "%"
-                    break;
-                case "下载完成":
-                    task.progress = task.status
-                    task.download = buildGalleryDownloadUrl(task.gid, state.AuthCode)
-                    break;
-            }
-
-            //处理时间戳
-            task.createTimeDisplay = new Date(task.createTime * 1000).toLocaleString("zh")
-
-            //处理是否收藏
-            if('isCollect' in task)
-                state.collectGallery.push(task)
-            else
-                task.isCollect = false
-
-            //处理是否下载
-            if(task.downloader === state.userId)
-                state.downloadGallery.push(task)
-
-            state.totalGalleryTask.push(task)
-        })
-
-        sortTasks(state)
-        if(state.isAuth && !state.loadComplete){
-            state.loadComplete = true
-            ElMessage("加载完成")
-        }
-    },
-    _updateGalleryTaskProceeding(state, tasks){
-        let galleries = Array.from(state.totalGalleryTask)
-        state.totalGalleryTask.splice(0)
-        galleries.forEach((gallery) => {
-            if(gallery.status !== '下载完成')
-                tasks.forEach((task) => {
-                    if(task.gid === gallery.gid){
-                        gallery.status = status[task.status]
-                        gallery.proceeding = task.proceeding
-                        if(gallery.status === '下载中')
-                            gallery.progress = (Math.round((gallery.proceeding / gallery.pages) * 100)).toString() + "%"
-                        else
-                            gallery.progress = gallery.status
-                    }
-                })
-            state.totalGalleryTask.push(gallery)
-        })
-    },
-    _changePage(state, targetPage){
-        state.page = targetPage
-    },
-    _authed(state, data){
-        state.AuthCode = data.AuthCode
-        state.userId = data.userId
-        state.username = data.username
-        state.isAdmin = Boolean(data.isAdmin)
-        state.downloaderFilter = null
-        state.isAuth = true
-        ElMessage("验证成功,加载中")
-    },
-    _unAuthed(state){
-        state.isAuth = false
-        state.AuthCode = ""
-        state.userId = -1
-        state.username = ""
-        ElMessage("授权码错误")
-        localStorage.removeItem("auth")
-    },
-    _searchLocalByLink(state, link){
-        let tasks = state.currentTasks
-        let gid = link.split("/")[4]
-        let name = null
-
-        if(gid === undefined)
-            for (let i = 0; i < tasks.length; i++) {
-                if (tasks[i].link === link) {
-                    state.page = Math.floor(i / state.length) + 1
-                    name = tasks[i].name
-                    break
-                }
-            }
-        else for (let i = 0; i < tasks.length; i++)
-            if (String(tasks[i].gid) === gid) {
-                state.page = Math.floor(i / state.length) + 1
-                name = state.sortType === "shortName" ? tasks[i].shortName: tasks[i].name
-                break
-            }
-
-        if(!name)
-            ElMessage("未找到此任务")
-        else
-            ElMessage("已跳转到该任务所在页数,任务名:" + name)
-    },
-    _searchLocalByKeyword(state, keyword){
-        state.searchTask.splice(0)
-        if(keyword.trim() !== '') {
-            state.page = 1
-            let tasks = state.currentTasks
-            tasks.forEach((task) => {
-                if (task.name.includes(keyword))
-                    state.searchTask.push(task)
-            })
-            if (state.searchTask.length === 0) {
-                ElMessage("未找到该关键字的任务")
-                state.isSearch = false
-            }
-            else {
-                state.isSearch = true
-            }
-        }else {
-            state.isSearch = false
-            confirmCurrentTask(state)
-        }
-    },
-    _deleteGallery(state, gid){
-        let tasks = [state.totalGalleryTask, state.downloadGallery, state.collectGallery]
-        deleteTask(tasks, 'gid', gid)
-    },
-    _setChosenGallery(state,data){
-        state.chosenGallery = data.gallery
-    },
-    _setCategory(state, category){
-        state.category = category
-        // 换分类后旧的下载人筛选可能在新分类里根本不存在，先清掉。
-        state.downloaderFilter = null
-        confirmCurrentTask(state)
-        sortTasks(state)
-    },
-    _setSortType(state, sortType){
-        state.sortType = sortType
-        sortTasks(state)
-    },
-    _setGalleryNameType(state, galleryNameType){
-        state.galleryNameType = galleryNameType
-    },
-    _setShowNameType(state, type){
-        if(type === "shortName")
-            state.length = state.shortLength
-        else
-            state.length = state.defaultLength
-    },
-    _setReadingGallery(state, gallery){
-        if(gallery.images === undefined) {
-            gallery.images = []
-            for(let i=1; i<=gallery.pages; i++)
-                gallery.images.push(buildGalleryManageUrl("/onlineImage/" + i, {
-                    gid: gallery.gid,
-                    AuthCode: state.AuthCode
-                }));
-        }
-        state.readingGallery = gallery
-        state.isReading = true;
-    },
-    _closeReader(state){
-        state.isReading = false;
-    },
-    _setActiveView(state, view){
-        state.activeView = view
-    },
-    _selectGallery(state, gallery){
-        state.selectedGallery = gallery || null
-    },
-    _setDownloaderFilter(state, downloader){
-        state.downloaderFilter = downloader === null || downloader === undefined
-            ? null
-            : Number(downloader)
-        // 筛完可能不足一页，回到第一页避免停在空页上。
-        state.page = 1
-    }
-}
-
-const state = {
-    connectionStatus: "disconnected",          // live task updates
-
-    totalGalleryTask: [],                    //存放数据的数组
-    chosenGallery: false,                    //准备下载
-    collectGallery: [],                      //收藏
-    downloadGallery: [],                     //下载
-    isSearch: false,                         //用于决定是否显示搜索结果
-
-    readingGallery: {'name': '', 'images': []}, //在线看
-    isReading: false,                        //是否正在看
-
-    currentGid: "",                          //当前GID
-    lengthPerPage: 0,                        //在线预览每页图片数量
-
-    page: 1,                                 //当前页数
-    length: 10,                              //每页能有多少个链接
-    defaultLength: 7,                        //默认个数
-    shortLength: 10,                         //简洁个数
-
-    userId: -1,                              //用户id
-    username: "",                            //用户名
-    isAuth: false,                           //是否授权
-    AuthCode: '',                            //授权码
-    loadComplete: false,                     //是否加载完成
-    galleryRefreshTimer: 0,                  //更新计时器id
-
-    isInclude: false,                        //是否搜索到任务
-    searchTask: [],                          //搜索到的任务
-    category: 'myDownload',                  //分类      myDownload myCollect total
-    sortType:'shortName',                    //排序类型   shortName name createTime
-    galleryNameType: 'shortName',            //名字类型   shortName name
-    currentTasks: [],                        //当前任务
-    weekUsed: {},                            //每周用量
-
-    activeView: 'tasks',                     //当前视图   tasks search settings
-    selectedGallery: null,                   //右侧详情面板选中的任务
-    isAdmin: false,                          //管理员（后端 validate 下发）
-    downloaderFilter: null,                  //管理员按下载人筛选，null 表示全部
-}
-
-const getters = {
-    /** 当前筛选条件命中的完整任务列表（未分页），用于计数。 */
-    filteredTasks(state){
-        return activeTaskList(state)
-    },
-    currentTasks(state){
-        const tasks = activeTaskList(state)
-        return tasks.slice((state.page - 1) * state.length, state.page * state.length)
-    },
-    min(){
-        return 1
-    },
-    max(state){
-        let max = 0
-        const tasks = activeTaskList(state)
-
-        if(!tasks)
-            return 1
-
-        max = Math.floor(tasks.length/state.length)
-        if(tasks.length % state.length !== 0 || max === 0)
-            max += 1
-
-        return max
-    }
-}
-
-export default new vuex.Store({
-    actions,
-    mutations,
-    state,
-    getters
-})
-
-/**
- * 当前视图实际要展示的任务。
- * 下载人筛选只在管理员生效，作用于「我的下载/收藏/全部」三种分类的结果。
- */
-function activeTaskList(state){
-    if(state.isSearch)
-        return state.searchTask
-    if(state.isAdmin && state.downloaderFilter !== null)
-        return state.currentTasks.filter(task => task.downloader === state.downloaderFilter)
-    return state.currentTasks
-}
-
-function getShortname(name){
-    if(name === null){
-        console.log(name)
-        return null
-    }
-    if (!name.includes("[")) return name
-
-    // 截取最后一个 [ 之前的部分，然后移除所有 [...] 和 (...) 标签
-    const trimmed = name.substring(0, name.lastIndexOf("["))
-        .replace(/\s*\[[^\]]*\]\s*/g, '')
-        .replace(/\s*\([^\)]*\)\s*/g, '')
-        .trim()
-    // 名字以 [...] 开头时（例如 "[作者] 标题"），截取结果为空，退回原名避免整列空白
-    return trimmed === '' ? name.trim() : trimmed
-}
-
-function buildGalleryDownloadUrl(gid, AuthCode){
-    let params = new URLSearchParams({AuthCode, gid: gid.toString()})
-    return GalleryManageUrl + "/file/" + gid + ".zip?" + params.toString()
-}
-
-function buildGalleryManageUrl(path, params){
-    return GalleryManageUrl + path + "?" + new URLSearchParams(params).toString()
-}
-
-function confirmCurrentTask(state){
-    switch (state.category){
-        case 'myDownload':
-            state.currentTasks = state.downloadGallery
-            break
-        case 'myCollect':
-            state.currentTasks = state.collectGallery
-            break
-        case 'total':
-            state.currentTasks = state.totalGalleryTask
-            break
-    }
-}
-
-function sortTasks(state){
-    switch (state.sortType) {
-        case "name":
-            state.currentTasks = state.currentTasks.sort((before, after) => {
-                return before.name > after.name ? 1: -1
-            })
-            break
-        case "shortName":
-            state.currentTasks = state.currentTasks.sort((before, after) => {
-                return before.shortName > after.shortName ? 1: -1
-            })
-            break
-        case "createTime":
-            state.currentTasks = state.currentTasks.sort((before, after) => {
-                return before.createTime - after.createTime
-            })
-    }
-}
-
-function deleteTask(tasks, key, value){
-    for(let j=0; j < tasks.length; j++)
-        for(let i=0; i<tasks[j].length; i++)
-            if(tasks[j][i][key] === value){
-                tasks[j].splice(i, 1)
-                i--
-                break
-            }
-}
-
-let status = ['已提交', '下载中', '等待压缩', '压缩中', '下载完成']
+// 桌面端与移动端共用同一份任务业务核心，只在分页交互上不同。
+export default new vuex.Store(createGalleryStore({
+    variant: "desktop",
+    axios,
+    qs,
+    Message: ElMessage,
+}))
diff --git a/src/utils/progressiveImages.js b/src/utils/progressiveImages.js
deleted file mode 100644
index b3572bc..0000000
--- a/src/utils/progressiveImages.js
+++ /dev/null
@@ -1,23 +0,0 @@
-function imageItem(url, index) {
-    return {url, src: url, index, attempt: 0, failed: false, settled: false}
-}
-
-export function startImages(urls) {
-    return urls.length ? [imageItem(urls[0], 0)] : []
-}
-
-export function settleImage(items, urls, item, failed = false) {
-    // Ignore events from images removed by a page change or dialog close.
-    if (!items.includes(item)) return
-    item.failed = failed
-    if (item.settled) return
-    item.settled = true
-    if (items.length < urls.length)
-        items.push(imageItem(urls[items.length], items.length))
-}
-
-export function retryImage(item) {
-    item.failed = false
-    item.attempt++
-    item.src = item.url + (item.url.includes('?') ? '&' : '?') + 'retry=' + item.attempt
-}
diff --git a/src/utils/taskSocket.js b/src/utils/taskSocket.js
deleted file mode 100644
index 6d0893a..0000000
--- a/src/utils/taskSocket.js
+++ /dev/null
@@ -1,76 +0,0 @@
-export function createTaskSocket({url, onOpen, onMessage, onState,
-    createSocket = address => new WebSocket(address),
-    setTimer = setTimeout, clearTimer = clearTimeout}) {
-    let socket = null
-    let retryTimer
-    let connectTimer
-    let attempts = 0
-    let stopped = true
-
-    function detach() {
-        clearTimer(connectTimer)
-        connectTimer = undefined
-        if (socket) {
-            const previous = socket
-            socket = null
-            previous.onopen = previous.onclose = previous.onerror = previous.onmessage = null
-            try { previous.close() } catch { /* already closed */ }
-        }
-    }
-
-    function schedule() {
-        if (stopped) return
-        onState('reconnecting')
-        const delay = Math.min(1000 * 2 ** attempts, 30000)
-        attempts = Math.min(attempts + 1, 5)
-        clearTimer(retryTimer)
-        retryTimer = setTimer(connect, delay)
-    }
-
-    function connect() {
-        if (stopped) return
-        clearTimer(retryTimer)
-        retryTimer = undefined
-        onState(attempts ? 'reconnecting' : 'connecting')
-        let current
-        try { current = socket = createSocket(url) }
-        catch { schedule(); return }
-        const retry = () => {
-            if (stopped || socket !== current) return
-            detach()
-            schedule()
-        }
-        current.onopen = () => {
-            if (stopped || socket !== current) return
-            clearTimer(connectTimer)
-            connectTimer = undefined
-            attempts = 0
-            try { current.send('DownloaderWebsocket') }
-            catch { retry(); return }
-            onState('connected')
-            onOpen()
-        }
-        current.onmessage = event => {
-            if (!stopped && socket === current) onMessage(event)
-        }
-        current.onclose = retry
-        current.onerror = retry
-        connectTimer = setTimer(retry, 10000)
-    }
-
-    return {
-        start() {
-            if (!stopped) return
-            stopped = false
-            attempts = 0
-            connect()
-        },
-        stop() {
-            stopped = true
-            clearTimer(retryTimer)
-            retryTimer = undefined
-            detach()
-            onState('disconnected')
-        }
-    }
-}
diff --git a/src/utils/thumbnail.js b/src/utils/thumbnail.js
deleted file mode 100644
index 73c5d0a..0000000
--- a/src/utils/thumbnail.js
+++ /dev/null
@@ -1,27 +0,0 @@
-const BaseUrl = "https://downloader.lionwebsite.xyz/";
-
-// Remote galleries carry a raw thumbnail path; it only resolves through the
-// backend proxy once the active auth code is attached.
-export function ehThumbnailUrl(path, AuthCode) {
-    if (!path) return "";
-    return BaseUrl + "GalleryManage/ehThumbnail?" + new URLSearchParams({path, AuthCode}).toString();
-}
-
-const UNIT_SCALE = {b: 1, k: 1024, m: 1024 ** 2, g: 1024 ** 3, t: 1024 ** 4};
-
-function sizeInBytes(text) {
-    const match = String(text).match(/([\d.]+)\s*([kmgt]?)(?:i?b)/i);
-    if (!match) return 0;
-    const scale = UNIT_SCALE[match[2].toLowerCase()] ?? 1;
-    return Number(match[1]) * scale;
-}
-
-// Prefer the original file; otherwise take whichever entry reports the most bytes.
-export function pickDefaultResolution(availableResolution) {
-    const entries = Object.entries(availableResolution || {});
-    if (entries.length === 0) return "";
-    const original = entries.find(([resolution]) => /original/i.test(resolution));
-    if (original) return original[0];
-    return entries.reduce((best, current) =>
-        sizeInBytes(current[1]) > sizeInBytes(best[1]) ? current : best)[0];
-}
diff --git a/src/utils/validate.js b/src/utils/validate.js
deleted file mode 100644
index d116778..0000000
--- a/src/utils/validate.js
+++ /dev/null
@@ -1,8 +0,0 @@
-export function validateLink(rawLink){
-  if(rawLink.trim() === "")
-    return false
-  if(rawLink.includes("hentai"))
-    return rawLink.includes("/g/")
-  else
-    return false
-}
diff --git a/tests/progressiveImages.test.mjs b/tests/progressiveImages.test.mjs
deleted file mode 100644
index e209e98..0000000
--- a/tests/progressiveImages.test.mjs
+++ /dev/null
@@ -1,33 +0,0 @@
-import test from 'node:test'
-import assert from 'node:assert/strict'
-import {startImages, settleImage, retryImage} from '../src/utils/progressiveImages.js'
-
-test('a failed image does not prevent later pages from loading', () => {
-    const urls = ['first', 'second', 'third']
-    const items = startImages(urls)
-    settleImage(items, urls, items[0], true)
-    assert.equal(items[0].failed, true)
-    assert.equal(items[1].url, 'second')
-    settleImage(items, urls, items[1])
-    assert.equal(items[2].url, 'third')
-})
-
-test('retry does not append a duplicate page and bypasses a failed URL cache', () => {
-    const urls = ['first?gid=1', 'second', 'third']
-    const items = startImages(urls)
-    settleImage(items, urls, items[0], true)
-    retryImage(items[0])
-    assert.equal(items[0].src, 'first?gid=1&retry=1')
-    settleImage(items, urls, items[0])
-    assert.equal(items.length, 2)
-    assert.equal(items[0].failed, false)
-})
-
-test('late image events cannot append content after changing pages', () => {
-    const old = startImages(['old'])[0]
-    const urls = ['new', 'next']
-    const items = startImages(urls)
-    settleImage(items, urls, old)
-    assert.equal(items.length, 1)
-    assert.deepEqual(startImages([]), [])
-})
diff --git a/tests/search.test.mjs b/tests/search.test.mjs
new file mode 100644
index 0000000..d312cb4
--- /dev/null
+++ b/tests/search.test.mjs
@@ -0,0 +1,37 @@
+import test from "node:test"
+import assert from "node:assert/strict"
+import {buildSearchParams, fetchGalleries, readResponse} from "lionwebsite-frontend-shared"
+
+test("keyword request never hand-builds the query string", () => {
+    assert.deepEqual(buildSearchParams({keyword: "cat girl"}), {keyword: "cat girl"})
+})
+
+test("next page forwards the upstream cursor instead of the keyword", () => {
+    const params = buildSearchParams({
+        keyword: "cat girl", direction: "next",
+        href: "https://exhentai.org/?f_search=cat+girl&next=777",
+    })
+    assert.equal(params.next, "777")
+    assert.equal(params.keyword, "cat girl")
+})
+
+test("fetchGalleries decodes object and JSON-string payloads identically", async () => {
+    const asObject = {get: async () => ({data: {result: "success", data: [{gid: 1}], next: "n1"}})}
+    const asString = {get: async () => ({data: {result: "success", data: '[{"gid":1}]', next: "n1"}})}
+    const one = await fetchGalleries(asObject, {keyword: "k"})
+    const two = await fetchGalleries(asString, {keyword: "k"})
+    assert.deepEqual(one.galleries, two.galleries)
+    assert.equal(one.pagination.next, "n1")
+})
+
+test("fetchGalleries surfaces the backend message on failure", async () => {
+    const http = {get: async () => ({data: {result: "failure", data: "没有搜索到结果"}})}
+    await assert.rejects(() => fetchGalleries(http, {keyword: "k"}),
+        error => error.payload === "没有搜索到结果")
+})
+
+test("readResponse keeps all four pagination cursors", () => {
+    const parsed = readResponse({data: {result: "success", data: "[]",
+        first: "f", previous: "p", next: "n", last: "l"}})
+    assert.deepEqual(parsed.pagination, {first: "f", previous: "p", next: "n", last: "l"})
+})
diff --git a/tests/store.test.mjs b/tests/store.test.mjs
index 374864a..b6b512f 100644
--- a/tests/store.test.mjs
+++ b/tests/store.test.mjs
@@ -1,95 +1,125 @@
-import test from 'node:test'
-import assert from 'node:assert/strict'
-import fs from 'node:fs'
-import vm from 'node:vm'
+import test from "node:test"
+import assert from "node:assert/strict"
 
-function fixture() {
-    let code = fs.readFileSync(new URL('../src/store/index.js', import.meta.url), 'utf8')
-        .replace(/^import .*$/gm, '')
-        .replace('export default new vuex.Store(', 'globalThis.store = new vuex.Store(')
-    const messages = []
-    const showMessage = message => messages.push(message)
-    showMessage.error = message => messages.push(message)
-    const axios = {interceptors: {response: {use() {}}}}
-    const context = vm.createContext({axios, vuex: {Store: function (config) {Object.assign(this, config)}},
-        ElMessage: showMessage, URLSearchParams, console,
-        qs: {stringify: () => ''}})
-    vm.runInContext(code, context)
-    const store = context.store
-    const api = {state: store.state,
-        commit: (name, data) => store.mutations[name](store.state, data),
-        dispatch: (name, data) => Promise.resolve(store.actions[name](api, data))}
-    return {store, messages, axios, api}
+// 直接加载真实的 store 模块；在 Node 里 import 到的就是下发到浏览器的那份配置。
+const store = (await import("../src/store/index.js")).default
+
+const tasks = () => [
+    {gid: 1, name: "beta [tag]", status: "下载完成", pages: 10, proceeding: 10,
+        thumb_link: "", createTime: 2, downloader: 7, isCollect: true},
+    {gid: 2, name: "alpha", status: "下载中", pages: 10, proceeding: 5,
+        thumb_link: "", createTime: 1, downloader: 7, isCollect: false},
+    {gid: 3, name: "gamma", status: "已提交", pages: 10, proceeding: 0,
+        thumb_link: "", createTime: 3, downloader: 8, isCollect: false},
+]
+
+function reset() {
+    store.state.AuthCode = "test-auth"
+    store.state.userId = 7
+    store.state.category = "total"
+    store.state.sortType = "createTime"
+    store.state.length = 2
+    store.state.page = 1
+    store.state.isAdmin = false
+    store.state.downloaderFilter = null
+    store.commit("_updateGalleryTasks", tasks())
 }
 
-test('link search matches a numeric gid and jumps to the right page', () => {
-    const {store, messages} = fixture()
-    store.state.currentTasks = [{gid: 1}, {gid: 2}, {gid: 12345, name: 'sample', shortName: 'sample'}]
+test("module exposes one normalized task list plus derived getters", () => {
+    reset()
+    assert.equal(store.state.totalGalleryTask.length, 3)
+    assert.equal("collectGallery" in store.state, false)
+    assert.equal("downloadGallery" in store.state, false)
+    assert.equal(store.getters.downloadGallery.length, 2)
+    assert.equal(store.getters.collectGallery.length, 1)
+})
+
+test("json-string and object payloads decode to the same store result", () => {
+    reset()
+    const fromObjects = store.state.totalGalleryTask.map(task => task.gid)
+    store.state.totalGalleryTask = []
+    store.commit("_updateGalleryTasks", JSON.parse(JSON.stringify(tasks())))
+    assert.deepEqual(store.state.totalGalleryTask.map(task => task.gid), fromObjects)
+})
+
+test("local search keeps every match reachable through the pager", () => {
+    reset()
     store.state.length = 2
-    store.mutations._searchLocalByLink(store.state, 'https://example.org/g/12345/key/')
-    assert.equal(store.state.page, 2)
-    assert.match(messages[0], /已跳转/)
+    store.commit("_searchLocalByKeyword", "a")
+    assert.equal(store.state.isSearch, true)
+    assert.equal(store.getters.filteredTasks.length, 3)
+    assert.equal(store.getters.max, 2)
+    assert.equal(store.getters.currentTasks.length, 2)
+    store.commit("_changePage", 2)
+    assert.equal(store.getters.currentTasks.length, 1)
 })
 
-test('missing gid still reports no match', () => {
-    const {store, messages} = fixture()
-    store.state.currentTasks = [{gid: 12345}]
-    store.mutations._searchLocalByLink(store.state, 'https://example.org/g/999/key/')
-    assert.equal(messages[0], '未找到此任务')
+test("a search matching more than one page exposes every page", () => {
+    store.state.AuthCode = "auth"
+    store.state.userId = 7
+    store.state.category = "total"
+    const many = Array.from({length: 25}, (_, index) => ({
+        gid: index + 1, name: "match " + index, status: "已提交",
+        pages: 1, proceeding: 0, thumb_link: "", createTime: index, downloader: 7,
+    }))
+    store.state.length = 10
+    store.commit("_updateGalleryTasks", many)
+    store.commit("_searchLocalByKeyword", "match")
+    assert.equal(store.getters.filteredTasks.length, 25)
+    assert.equal(store.getters.max, 3)
+    assert.equal(store.getters.currentTasks.length, 10)
+    store.commit("_changePage", 3)
+    assert.equal(store.getters.currentTasks.length, 5)
 })
 
-test('submission reloads persisted status without duplicating a completed task', async () => {
-    const {store, axios, api} = fixture()
-    const gallery = {gid: 123, name: 'sample', status: '下载完成', thumb_link: '', createTime: 1, downloader: 7}
-    store.state.chosenGallery = {...gallery, status: '已提交'}
-    store.state.totalGalleryTask.push(gallery)
-    axios.post = async () => ({data: {result: 'success'}})
-    axios.get = async url => ({data: {result: 'success', data: JSON.stringify(url.endsWith('weekUsedAmount') ? {} : [gallery])}})
-    await store.actions.postGalleryTask(api, {targetResolution: 'original'})
-    assert.equal(store.state.totalGalleryTask.length, 1)
-    assert.equal(store.state.totalGalleryTask[0].status, '下载完成')
-    assert.equal(store.state.chosenGallery, false)
+test("cancelling a collect for a task missing from the list never throws", () => {
+    reset()
+    // 旧实现会在 collectGallery 里找不到 gid 时抛 TypeError。
+    assert.doesNotThrow(() => store.commit("_setCollect", {gid: 999, collect: false}))
+    store.commit("_setCollect", {gid: 1, collect: false})
+    assert.equal(store.getters.collectGallery.length, 0)
+    store.commit("_setCollect", {gid: 1, collect: true})
+    assert.equal(store.getters.collectGallery.length, 1)
 })
 
-test('gallery management subrequests carry the active auth code', async () => {
-    const {store, axios, api} = fixture()
-    store.state.AuthCode = 'test-auth'
-    let call
-    axios.post = async (...args) => {
-        call = args
-        return {data: {result: args[0].endsWith('/cache') ? 'failure' : 'success', data: 'expected test response'}}
-    }
-    await store.actions.reconnect(api)
-    assert.equal(call[0], 'https://downloader.lionwebsite.xyz/GalleryManage/reconnect')
-    assert.equal(call[1], null)
-    assert.equal(call[2].params.AuthCode, 'test-auth')
-
-    await store.actions.readOnlineGallery(api, {link: 'https://example.org/g/1/key/', images: []})
-    assert.equal(call[0], 'https://downloader.lionwebsite.xyz/GalleryManage/cache')
-    assert.equal(call[1], null)
-    assert.deepEqual({...call[2].params}, {
-        url: 'https://example.org/g/1/key/',
-        AuthCode: 'test-auth'
-    })
+test("sorting never reorders the single source array", () => {
+    reset()
+    const before = store.state.totalGalleryTask.map(task => task.gid)
+    store.commit("_setSortType", "name")
+    assert.deepEqual(store.state.totalGalleryTask.map(task => task.gid), before)
+    assert.deepEqual(store.state.currentTasks.map(task => task.name), ["alpha", "beta [tag]", "gamma"])
 })
 
-test('thumbnail and online image URLs carry the active auth code', () => {
-    const {store} = fixture()
-    store.state.AuthCode = 'code with spaces'
-    store.mutations._updateGalleryTasks(store.state, [{
-        gid: 123,
-        name: 'sample',
-        status: '已提交',
-        thumb_link: 'https://example.org/thumb?a=1&b=2',
-        createTime: 1,
-        downloader: 7
+test("admin downloader filter narrows the visible list only for admins", () => {
+    reset()
+    store.commit("_setDownloaderFilter", 8)
+    assert.equal(store.getters.filteredTasks.length, 3)
+    store.state.isAdmin = true
+    store.commit("_setDownloaderFilter", 8)
+    assert.equal(store.getters.filteredTasks.length, 1)
+    assert.equal(store.getters.filteredTasks[0].gid, 3)
+})
+
+test("thumbnail and online image urls carry the active auth code", () => {
+    store.state.AuthCode = "code with spaces"
+    store.commit("_updateGalleryTasks", [{
+        gid: 123, name: "sample", status: "已提交",
+        thumb_link: "https://example.org/thumb?a=1&b=2", createTime: 1, downloader: 7,
     }])
     const thumbnail = new URL(store.state.totalGalleryTask[0].thumb_link)
-    assert.equal(thumbnail.searchParams.get('AuthCode'), 'code with spaces')
-    assert.equal(thumbnail.searchParams.get('path'), 'https://example.org/thumb?a=1&b=2')
+    assert.equal(thumbnail.searchParams.get("AuthCode"), "code with spaces")
+    assert.equal(thumbnail.searchParams.get("path"), "https://example.org/thumb?a=1&b=2")
 
-    store.mutations._setReadingGallery(store.state, {gid: 123, pages: 1})
+    store.commit("_setReadingGallery", {gid: 123, pages: 1})
     const image = new URL(store.state.readingGallery.images[0])
-    assert.equal(image.searchParams.get('gid'), '123')
-    assert.equal(image.searchParams.get('AuthCode'), 'code with spaces')
+    assert.equal(image.searchParams.get("gid"), "123")
+    assert.equal(image.searchParams.get("AuthCode"), "code with spaces")
+})
+
+test("proceeding websocket updates refresh the progress text", () => {
+    reset()
+    store.commit("_updateGalleryTaskProceeding", [{gid: 3, status: 1, proceeding: 5}])
+    const task = store.state.totalGalleryTask.find(item => item.gid === 3)
+    assert.equal(task.status, "下载中")
+    assert.equal(task.progress, "50%")
 })
diff --git a/tests/taskSocket.test.mjs b/tests/taskSocket.test.mjs
deleted file mode 100644
index ce81b48..0000000
--- a/tests/taskSocket.test.mjs
+++ /dev/null
@@ -1,63 +0,0 @@
-import test from 'node:test'
-import assert from 'node:assert/strict'
-import {createTaskSocket} from '../src/utils/taskSocket.js'
-
-function fixture() {
-    const sockets = [], states = [], messages = [], timers = new Map()
-    let id = 0, opens = 0
-    const manager = createTaskSocket({url: 'wss://example.invalid',
-        onOpen: () => opens++, onState: value => states.push(value), onMessage: event => messages.push(event.data),
-        setTimer: (fn, delay) => { timers.set(++id, {fn, delay}); return id },
-        clearTimer: key => timers.delete(key),
-        createSocket: () => {
-            const socket = {sent: [], send(value) { this.sent.push(value) }, close() { this.closed = true }}
-            sockets.push(socket)
-            return socket
-        }
-    })
-    function tick(delay) {
-        const entry = [...timers].find(([, timer]) => timer.delay === delay)
-        assert.ok(entry, `expected timer ${delay}`)
-        timers.delete(entry[0]); entry[1].fn()
-    }
-    return {manager, sockets, states, messages, timers, tick, opens: () => opens}
-}
-
-test('reconnects and refreshes after each successful connection', () => {
-    const f = fixture(); f.manager.start()
-    f.sockets[0].onopen()
-    assert.deepEqual(f.sockets[0].sent, ['DownloaderWebsocket'])
-    f.sockets[0].onclose()
-    f.tick(1000)
-    f.sockets[1].onopen()
-    assert.equal(f.opens(), 2)
-    assert.equal(f.states.at(-1), 'connected')
-    assert.equal(f.timers.size, 0)
-    f.manager.stop()
-})
-
-test('backs off and times out connection attempts', () => {
-    const f = fixture(); f.manager.start()
-    f.tick(10000)
-    assert.equal(f.sockets[0].closed, true)
-    f.tick(1000); f.sockets[1].onerror(); f.tick(2000)
-    f.sockets[2].onerror(); f.tick(4000)
-    assert.equal(f.sockets.length, 4)
-    f.manager.stop()
-})
-
-test('stop cancels timers and ignores callbacks from replaced sockets', () => {
-    const f = fixture(); f.manager.start()
-    const oldOpen = f.sockets[0].onopen, oldMessage = f.sockets[0].onmessage
-    f.sockets[0].onerror()
-    f.manager.stop()
-    assert.equal(f.timers.size, 0)
-    f.manager.start()
-    oldOpen(); oldMessage({data: 'stale'})
-    assert.equal(f.opens(), 0)
-    assert.deepEqual(f.messages, [])
-    f.sockets[1].onopen()
-    f.sockets[1].onmessage({data: 'current'})
-    assert.deepEqual(f.messages, ['current'])
-    f.manager.stop()
-})
diff --git a/tests/thumbnail.test.mjs b/tests/thumbnail.test.mjs
deleted file mode 100644
index 53781d7..0000000
--- a/tests/thumbnail.test.mjs
+++ /dev/null
@@ -1,33 +0,0 @@
-import test from 'node:test'
-import assert from 'node:assert/strict'
-import {pickDefaultResolution, ehThumbnailUrl} from '../src/utils/thumbnail.js'
-
-test('original resolution wins whenever it is offered', () => {
-    assert.equal(pickDefaultResolution({
-        '800x': '37.53MiB',
-        '1280x': '66.57MiB',
-        '2560x': '84.01MiB',
-        'Original': '498.2MiB'
-    }), 'Original')
-})
-
-test('without an original entry the largest file is chosen', () => {
-    // 1920x is bigger than 2560x here, so byte size decides, not the label.
-    assert.equal(pickDefaultResolution({
-        '800x': '37.53MiB',
-        '1920x': '811.1MiB',
-        '2560x': '84.01MiB'
-    }), '1920x')
-})
-
-test('an empty or missing resolution map yields an empty choice', () => {
-    assert.equal(pickDefaultResolution({}), '')
-    assert.equal(pickDefaultResolution(undefined), '')
-})
-
-test('thumbnail urls carry the path and the active auth code', () => {
-    const url = new URL(ehThumbnailUrl('https://example.org/t?a=1&b=2', 'code with spaces'))
-    assert.equal(url.searchParams.get('path'), 'https://example.org/t?a=1&b=2')
-    assert.equal(url.searchParams.get('AuthCode'), 'code with spaces')
-    assert.equal(ehThumbnailUrl('', 'x'), '')
-})