From 74dcb767e66e85519d325fa4e95a87b1f58ab1bf Mon Sep 17 00:00:00 2001
From: vec <vec@torzo.club>
Date: Sun, 7 Jan 2024 15:10:24 +0800
Subject: [PATCH] [add] better refresh thumb api

---
 dashboard/.eslintrc.js                        |   2 +-
 dashboard/package-lock.json                   |  23 +++-
 dashboard/package.json                        |   1 +
 dashboard/src/api/image.js                    |  14 +-
 .../dashboard/components/refresh-thumbs.vue   | 120 ++++++++++++++++++
 dashboard/src/views/dashboard/index.vue       |  80 ++++++------
 dashboard/src/views/member/detail.vue         |   4 +-
 server/app/controller/admin/image.js          |  65 +++++++---
 server/app/middleware/error-handler.js        |   8 +-
 server/app/router.js                          |   3 +-
 server/app/service/image.js                   |  47 ++++++-
 server/app/service/photo.js                   |   4 +-
 server/test/common.js                         |  14 ++
 server/test/image-upload.test.js              |  99 ++++++---------
 14 files changed, 349 insertions(+), 135 deletions(-)
 create mode 100644 dashboard/src/views/dashboard/components/refresh-thumbs.vue

diff --git a/dashboard/.eslintrc.js b/dashboard/.eslintrc.js
index ce1911c..8185f95 100755
--- a/dashboard/.eslintrc.js
+++ b/dashboard/.eslintrc.js
@@ -90,7 +90,7 @@ module.exports = {
     'no-extend-native': 2,
     'no-extra-bind': 2,
     'no-extra-boolean-cast': 2,
-    'no-extra-parens': [2, 'functions'],
+    'no-extra-parens': [0],
     'no-fallthrough': 2,
     'no-floating-decimal': 2,
     'no-func-assign': 2,
diff --git a/dashboard/package-lock.json b/dashboard/package-lock.json
index 15611d6..331c466 100644
--- a/dashboard/package-lock.json
+++ b/dashboard/package-lock.json
@@ -14286,6 +14286,14 @@
         "tough-cookie": "~2.5.0",
         "tunnel-agent": "^0.6.0",
         "uuid": "^3.3.2"
+      },
+      "dependencies": {
+        "uuid": {
+          "version": "3.4.0",
+          "resolved": "https://registry.npmjs.org/uuid/-/uuid-3.4.0.tgz",
+          "integrity": "sha512-HjSDRw6gZE5JMggctHBcjVak08+KEVhSIiDzFnT9S9aegmp85S/bReBVTb4QTFaRNptJ9kuYaNhnbNEOkbKb/A==",
+          "dev": true
+        }
       }
     },
     "request-promise-core": {
@@ -17237,10 +17245,9 @@
       "dev": true
     },
     "uuid": {
-      "version": "3.4.0",
-      "resolved": "https://registry.npmjs.org/uuid/-/uuid-3.4.0.tgz",
-      "integrity": "sha512-HjSDRw6gZE5JMggctHBcjVak08+KEVhSIiDzFnT9S9aegmp85S/bReBVTb4QTFaRNptJ9kuYaNhnbNEOkbKb/A==",
-      "dev": true
+      "version": "9.0.1",
+      "resolved": "https://registry.npmjs.org/uuid/-/uuid-9.0.1.tgz",
+      "integrity": "sha512-b+1eJOlsR9K8HJpow9Ok3fiWOWSIcIzXodvv0rQjVoOVNpWMpxf1wZNpt4y9h10odCNrqnYp1OBzRktckBe3sA=="
     },
     "validate-npm-package-license": {
       "version": "3.0.4",
@@ -18199,6 +18206,14 @@
       "requires": {
         "ansi-colors": "^3.0.0",
         "uuid": "^3.3.2"
+      },
+      "dependencies": {
+        "uuid": {
+          "version": "3.4.0",
+          "resolved": "https://registry.npmjs.org/uuid/-/uuid-3.4.0.tgz",
+          "integrity": "sha512-HjSDRw6gZE5JMggctHBcjVak08+KEVhSIiDzFnT9S9aegmp85S/bReBVTb4QTFaRNptJ9kuYaNhnbNEOkbKb/A==",
+          "dev": true
+        }
       }
     },
     "webpack-merge": {
diff --git a/dashboard/package.json b/dashboard/package.json
index ff6d714..5cf940e 100644
--- a/dashboard/package.json
+++ b/dashboard/package.json
@@ -21,6 +21,7 @@
     "nprogress": "0.2.0",
     "pad-left": "^2.1.0",
     "path-to-regexp": "2.4.0",
+    "uuid": "^9.0.1",
     "vue": "2.6.10",
     "vue-router": "3.0.6",
     "vuex": "3.1.0"
diff --git a/dashboard/src/api/image.js b/dashboard/src/api/image.js
index e46a7e1..394a5a5 100644
--- a/dashboard/src/api/image.js
+++ b/dashboard/src/api/image.js
@@ -1,8 +1,18 @@
 import request from '@/utils/request'
 
-export const refreshThumbs = () =>
+export const __AVATAR_THUMB_SIZE__ = 128
+
+export const refreshThumb = (src, thumb_size) =>
+  request({
+    url: `admin/image/refresh-thumb`,
+    method: 'POST',
+    timeout: 0,
+    data: { src, thumb_size },
+  })
+
+export const getAllAvailablePhoto = () =>
   request({
-    url: 'admin/image/refresh-thumb',
+    url: `admin/image/available-photo`,
     method: 'GET',
     timeout: 0,
   })
diff --git a/dashboard/src/views/dashboard/components/refresh-thumbs.vue b/dashboard/src/views/dashboard/components/refresh-thumbs.vue
new file mode 100644
index 0000000..8c3c255
--- /dev/null
+++ b/dashboard/src/views/dashboard/components/refresh-thumbs.vue
@@ -0,0 +1,120 @@
+<template>
+  <div>
+    <ElButton
+      size="small"
+      type="primary"
+      icon="el-icon-refresh"
+      @click="processing || refreshThumbsConfirm()"
+    >刷新缩略图</ElButton>
+    <ElProgress
+      v-if="show_progress"
+      :percentage="percentage"
+      :color="color"
+    />
+  </div>
+</template>
+
+<script>
+import { refreshThumb, getAllAvailablePhoto, __AVATAR_THUMB_SIZE__ } from '@/api/image'
+import { getList as getMemberList } from '@/api/member'
+
+const initProgress = () => ({ total: 0, success: 0, failure: 0 })
+
+export default {
+  data: () => ({
+    ...initProgress(),
+    processing: false,
+    show_progress: false,
+  }),
+
+  computed: {
+    color() { return (this.failure > 0) ? '#e6a23c' : '#409eff' },
+    current() { return this.success + this.failure },
+    percentage() {
+      return (this.total === 0) ? 0 : Math.ceil(
+        100 * (this.current / this.total)
+      )
+    },
+  },
+
+  watch: {
+    processing(val) {
+      if (val === true) {
+        this.show_progress = true
+      }
+    }
+  },
+
+  methods: {
+    async refreshThumbs() {
+      Object.assign(this, initProgress())
+
+      const [photos, members] = await Promise.all([
+        getAllAvailablePhoto(), getMemberList()
+      ])
+
+      const task_list = [
+        ...photos.map(p => (
+          [`相片(id=${p.id})`, p.src]
+        )),
+        ...members.map(m => (
+          [`成员头像(id=${m.id})`, m.avatar_src, __AVATAR_THUMB_SIZE__]
+        ))
+      ]
+
+      this.total = task_list.length
+
+      for (const [name, ...args] of task_list) {
+        try {
+          await refreshThumb(...args)
+          this.success = this.success + 1
+        } catch (err) {
+          this.failure = this.failure + 1
+          this.$emit('warning', `${name}的缩略图生成失败`, err)
+        }
+      }
+    },
+    async refreshThumbsConfirm() {
+      const confirm = await this.confirm('', `你确定要刷新吗？`, {
+        confirmButtonClass: 'el-button--warning',
+      })
+      if (!confirm) { return }
+      try {
+        this.processing = true
+        await this.refreshThumbs()
+        if (this.failure === 0) {
+          this.$emit('success', `所有缩略图已刷新`)
+        }
+      } catch (err) {
+        this.$emit('error', '刷新缓存失败', err)
+      } finally {
+        this.processing = false
+      }
+    },
+
+    async confirm(title, content, appendOpt = {}) {
+      const opt = Object.assign({
+        confirmButtonText: '确定',
+        cancelButtonText: '取消',
+        confirmButtonClass: 'el-button--warning',
+        showClose: false,
+      }, appendOpt)
+      return this.$confirm(content, title, opt)
+        .then(() => true)
+        .catch(() => false)
+    },
+  }
+}
+</script>
+
+<style lang="scss" scoped>
+.dashboard {
+  &-container {
+    margin: 30px;
+  }
+  &-text {
+    font-size: 30px;
+    line-height: 46px;
+  }
+}
+</style>
diff --git a/dashboard/src/views/dashboard/index.vue b/dashboard/src/views/dashboard/index.vue
index 70d58b2..fdb2692 100755
--- a/dashboard/src/views/dashboard/index.vue
+++ b/dashboard/src/views/dashboard/index.vue
@@ -1,64 +1,58 @@
 <template>
   <ElContainer
     v-loading="loading"
-    style="padding-top: 20px; width: 1180px"
+    style="padding-top: 20px; width: 640px"
     direction="vertical"
   >
-    <ElHeader height="2em">
-      torzo gallery dashboard beta
-    </ElHeader>
-
     <ElMain>
-      <ElButton size="small" type="primary" icon="el-icon-refresh" @click="refreshThumbs">刷新缩略图</ElButton>
+      <ElAlert v-for="alert in alerts" :key="alert.id" :type="alert.type" :title="alert.title" style="margin-bottom: 10px;" />
+      <RefreshThumbs @error="handleError" @warning="handleWarning" @success="handleSuccess" @info="handleInfo" />
     </ElMain>
   </ElContainer>
 </template>
 
 <script>
-import { mapGetters } from 'vuex'
-import { refreshThumbs as refreshThumbsApi } from '@/api/image'
+import RefreshThumbs from './components/refresh-thumbs.vue'
+import { v4 as uuidv4 } from 'uuid'
+
+function ConsolePrint(alert_type) {
+  switch (alert_type) {
+    default: return console.log
+    case 'error': return console.error
+    case 'warning': return console.warn
+  }
+}
+
+function HandleAlertEvent(alert_type) {
+  const consolePrint = ConsolePrint(alert_type).bind(console)
+  return function(title, err) {
+    if (err) {
+      consolePrint(`${title}`, err)
+      this.addAlert(alert_type, `${title}: ${err.message}`)
+    } else {
+      this.addAlert(alert_type, title)
+    }
+  }
+}
 
 export default {
-  name: 'Dashboard',
+  name: 'DashboardHome',
+
+  components: { RefreshThumbs },
+
   data: () => ({
     loading: false,
+    alerts: [],
   }),
-  computed: {
-    ...mapGetters([
-      'name'
-    ])
-  },
-  methods: {
-    confirm(title, content, appendOpt = {}) {
-      const opt = Object.assign({
-        confirmButtonText: '确定',
-        cancelButtonText: '取消',
-        confirmButtonClass: 'el-button--warning',
-        showClose: false,
-      }, appendOpt)
-      return this.$confirm(content, title, opt)
-        .then(() => true)
-        .catch(() => false)
-    },
 
-    async refreshThumbs() {
-      const confirm = await this.confirm('', `你确定要刷新吗？`, {
-        confirmButtonClass: 'el-button--warning',
-      })
-      if (!confirm) {
-        return
-      }
-      try {
-        this.loading = true
-        await refreshThumbsApi()
-        this.$message.success(`缩略图已刷新`)
-      } catch (err) {
-        console.error('刷新失败', err)
-        this.$message.error(`刷新失败: ${err.message}`)
-      } finally {
-        this.loading = false
-      }
+  methods: {
+    addAlert(type, title) {
+      this.alerts = [...this.alerts, { id: uuidv4(), type, title }]
     },
+    handleError: HandleAlertEvent('error'),
+    handleWarning: HandleAlertEvent('warning'),
+    handleSuccess: HandleAlertEvent('success'),
+    handleInfo: HandleAlertEvent('info'),
   }
 }
 </script>
diff --git a/dashboard/src/views/member/detail.vue b/dashboard/src/views/member/detail.vue
index ddae164..9acd156 100644
--- a/dashboard/src/views/member/detail.vue
+++ b/dashboard/src/views/member/detail.vue
@@ -20,7 +20,7 @@
         >
           <UploadImageBox
             ref="UploadImageBox"
-            :thumb-size="128"
+            :thumb-size="avatar_thumb_size"
             :preview-url="preview_url"
             @upload-success="uploadSuccess"
           />
@@ -44,6 +44,7 @@
 </template>
 
 <script>
+  import { __AVATAR_THUMB_SIZE__ } from '@/api/image'
   import { getDetail, create, update } from '@/api/member'
 
   import UploadImageBox from '@/components/UploadImageBox'
@@ -54,6 +55,7 @@
     },
 
     data: () => ({
+      avatar_thumb_size: __AVATAR_THUMB_SIZE__,
       loading: false,
       preview_url: '',
       form: {
diff --git a/server/app/controller/admin/image.js b/server/app/controller/admin/image.js
index 6aad5cd..f6cc814 100644
--- a/server/app/controller/admin/image.js
+++ b/server/app/controller/admin/image.js
@@ -1,10 +1,11 @@
 'use strict';
 
 const sendToWormhole = require('stream-wormhole');
+const path = require('path');
 
 module.exports = app => {
   class ImageController extends app.Controller {
-    thumbSize(size_raw) {
+    checkThumbSize(size_raw) {
       const default_size = app.config.default_image_thumb_size;
       if (size_raw === undefined) {
         return default_size;
@@ -22,7 +23,7 @@ module.exports = app => {
 
     async upload(ctx) {
       const stream = await ctx.getFileStream();
-      const thumb_size = this.thumbSize(ctx.query.thumb_size);
+      const thumb_size = this.checkThumbSize(ctx.query.thumb_size);
       try {
         const {
           imagePath, imageThumbPath, src, thumb,
@@ -41,10 +42,15 @@ module.exports = app => {
       }
     }
 
-    async refreshThumb(ctx) {
-      const gallerys = await app.model.Gallery.findAll();
+    async getAllAvailablePhoto(ctx) {
+      const list = await ctx.app.model.Gallery.findAll({
+        order: [
+          [ 'index', 'DESC' ],
+        ],
+      });
+
       const photos_list = await Promise.all(
-        gallerys.map(gallery => {
+        list.map(gallery => {
           return gallery.getPhotos({
             order: [
               [ 'index', 'ASC' ],
@@ -53,23 +59,48 @@ module.exports = app => {
         })
       );
 
-      const photos_list_flated = photos_list.flat();
+      ctx.backData(200, photos_list.flat());
+    }
+
+    async refreshThumb(ctx) {
+      ctx.validate({
+        src: { type: 'string', required: true },
+        thumb_size: { type: 'integer', required: false },
+      }, ctx.request.body);
+      const { src, thumb_size } = ctx.request.body;
+
+      const { name, ext } = path.parse(src);
+
+      const result = await app.serviceClasses.image.generateThumb(
+        `${name}${ext}`,
+        { thumb_size: this.checkThumbSize(thumb_size) }
+      );
+
+      ctx.backData(200, result);
+    }
 
-      const members_p = app.model.Member.findAll();
+    async refreshMemberThumb(ctx) {
+      ctx.validate({
+        member_id: { type: 'id', required: true },
+      }, ctx.params);
 
-      await ctx.service.image.removeAllThumbs();
+      const member = await ctx.service.member.findById(ctx.params.member_id);
 
-      const src_list = [
-        ...photos_list_flated.map(p => p.src),
-        ...(await members_p).map(m => m.avatar_src),
-      ];
+      await app.serviceClasses.image.removeThumb(member.avatar_thumb);
+      const result = await app.serviceClasses.image.generateThumb(member.avatar_thumb);
+      ctx.backData(200, result);
+    }
 
-      const [ successes, failures ] = await ctx.service.image.generateThumbs(src_list);
+    async refreshPhotoThumb(ctx) {
+      ctx.validate({
+        photo_id: { type: 'id', required: true },
+      }, ctx.params);
 
-      ctx.backData(200, {
-        successes,
-        failures,
-      });
+      const photo = await ctx.service.photo.findById(ctx.params.photo_id);
+
+      await app.serviceClasses.image.removeThumb(photo.thumb);
+      const result = await app.serviceClasses.image.generateThumb(photo.thumb);
+      ctx.backData(200, result);
     }
   }
 
diff --git a/server/app/middleware/error-handler.js b/server/app/middleware/error-handler.js
index 3c22a63..2474dda 100644
--- a/server/app/middleware/error-handler.js
+++ b/server/app/middleware/error-handler.js
@@ -32,9 +32,7 @@ module.exports = () =>
         return;
       }
 
-      const { WarningError } = ctx.app;
-
-      if (err instanceof WarningError) {
+      if (err instanceof ctx.app.WarningError) {
         const status = err.status || 500;
 
         ctx.backData(status, {
@@ -42,6 +40,10 @@ module.exports = () =>
           message: err.message,
         });
 
+        if (ctx.app.config.env === 'unitest') {
+          ctx.app.logger.debug(err);
+        }
+
         return;
       }
 
diff --git a/server/app/router.js b/server/app/router.js
index 5b8fe0a..51f085d 100644
--- a/server/app/router.js
+++ b/server/app/router.js
@@ -25,7 +25,8 @@ module.exports = app => {
   setRouter('post', 'admin/login', controller.admin.auth.login);
 
   setAdminRouter('post', 'image/upload', controller.admin.image.upload);
-  setAdminRouter('get', 'image/refresh-thumb', controller.admin.image.refreshThumb);
+  setAdminRouter('post', 'image/refresh-thumb', controller.admin.image.refreshThumb);
+  setAdminRouter('get', 'image/available-photo', controller.admin.image.getAllAvailablePhoto);
 
   {
     const { create, remove, get, show, edit } = controller.admin.gallery;
diff --git a/server/app/service/image.js b/server/app/service/image.js
index cfa0996..54cca97 100644
--- a/server/app/service/image.js
+++ b/server/app/service/image.js
@@ -10,10 +10,56 @@ function urlPathnameJoin(url, append_path) {
   return u.toString();
 }
 
+async function fileExists(filename) {
+  try {
+    await fs.promises.access(filename);
+    return true;
+  } catch (err) {
+    if (err.code === 'ENOENT') {
+      return false;
+    } else {
+      throw err;
+    }
+  }
+}
+
 const { Service } = require('egg');
 
 module.exports = app =>
   class ImageService extends Service {
+    static allFilename(src) {
+      const src_without_ext = path.parse(src).name;
+      return app.config.supported_formats.map(format => {
+        return `${src_without_ext}.${format}`;
+      });
+    }
+
+    static async removeSrc(src) {
+      const file_list = ImageService.allFilename(src);
+      const removed = [];
+      for (const file of file_list) {
+        const file_path = ImageService.toSrcSavePath(file);
+        if (await fileExists(file_path)) {
+          await fs.promises.unlink(file_path);
+          removed.push(file_path);
+        }
+      }
+      return removed;
+    }
+
+    static async removeThumb(thumb) {
+      const file_list = ImageService.allFilename(thumb);
+      const removed = [];
+      for (const file of file_list) {
+        const file_path = ImageService.toThumbSavePath(file);
+        if (await fileExists(file_path)) {
+          await fs.promises.unlink(file_path);
+          removed.push(file_path);
+        }
+      }
+      return removed;
+    }
+
     static toSrcSavePath(filename) {
       return path.join(app.config.imageSavePath, filename);
     }
@@ -95,7 +141,6 @@ module.exports = app =>
       extname = format,
       format_options,
     }) {
-
       const src_path = ImageService.toSrcSavePath(src_filename);
       const sharp_p = sharp(src_path);
 
diff --git a/server/app/service/photo.js b/server/app/service/photo.js
index 89e9cb8..ae30390 100644
--- a/server/app/service/photo.js
+++ b/server/app/service/photo.js
@@ -313,7 +313,9 @@ module.exports = app =>
 
     removeById(id) {
       return this.app.model.transaction(async transaction => {
-        return await this.destroyById(parseInt(id), { transaction });
+        const transactionOptions = { transaction, lock: transaction.LOCK.UPDATE };
+        // const photo = await this.findById(id, transactionOptions);
+        return await this.destroyById(parseInt(id), transactionOptions);
       });
     }
 
diff --git a/server/test/common.js b/server/test/common.js
index a53d40c..8283a53 100644
--- a/server/test/common.js
+++ b/server/test/common.js
@@ -45,6 +45,7 @@ module.exports = {
   editSubmissionPhoto,
   submissionPhoto,
   cancelMySubmission,
+  adminRefreshThumb,
 };
 
 let globalApp;
@@ -378,3 +379,16 @@ async function cancelMySubmission(app, {
 
   return body;
 }
+
+async function adminRefreshThumb(app, token, {
+  src, thumb_size,
+}) {
+  const res = await app.httpRequest()
+    .post('/admin/image/refresh-thumb')
+    .set('Authorization', token)
+    .type('json')
+    .send({ src, thumb_size })
+    .expect(200);
+
+  return res.body;
+}
diff --git a/server/test/image-upload.test.js b/server/test/image-upload.test.js
index 6643b83..23cff15 100644
--- a/server/test/image-upload.test.js
+++ b/server/test/image-upload.test.js
@@ -19,11 +19,15 @@ const {
   submissionPhoto,
   default_upload_image_path,
   cancelMySubmission,
+  removePhotoById,
+  adminRefreshThumb,
+  test_avatar_image_width,
 } = require('./common');
 
 describe('controller/admin/image', function () {
   this.slow(500);
   this.timeout(300000); // 5 min
+
   const pixel_rotated_image_path = `${__dirname}/static/temp.jpg`;
   const ori6_image_path = `${__dirname}/static/test-ori-6.jpg`
 
@@ -35,9 +39,9 @@ describe('controller/admin/image', function () {
       .toFile(ori6_image_path)
   })
 
-  async function downloadImage(app, imagePath, src) {
+  async function downloadImage(app, url_path) {
     const down_res = await app.httpRequest()
-      .get(path.join(imagePath, src))
+      .get(path.join(url_path))
       .expect('Content-Type', /image/)
       .expect(200)
 
@@ -50,7 +54,7 @@ describe('controller/admin/image', function () {
   }
 
   async function loadImage(app, imagePath, src) {
-    const buffer = await downloadImage(app, imagePath, src)
+    const buffer = await downloadImage(app, path.join(imagePath, src))
     return [await loadMetadataByBuffer(buffer), buffer]
   }
 
@@ -173,13 +177,13 @@ describe('controller/admin/image', function () {
     assert(img_meta.width === spec_width)
   })
 
-  // 图片有两种旋转的方式
-  // 一种是位图层面的旋转，就是像素的重新排列
-  // 另一种就是不改动位图（像素重新排列）而只改动 EXIF 信息中的 Orientation 字段
-  // 毕竟是原图嘛，相册程序不会对用户上传的图片进行任何的处理，直接保存下来
-  // 但这样就会有个问题了：
-  // 第二种方式旋转过的图片，用 sharp 读取的时候不会得到正确的宽度和高度，而是没有改动的位图的宽高
-  // 这就需要处理了
+// 图片有两种旋转的方式
+// 一种是位图层面的旋转，就是像素的重新排列
+// 另一种就是不改动位图（像素重新排列）而只改动 EXIF 信息中的 Orientation 字段
+// 毕竟是原图嘛，相册程序不会对用户上传的图片进行任何的处理，直接保存下来
+// 但这样就会有个问题了：
+// 第二种方式旋转过的图片，用 sharp 读取的时候不会得到正确的宽度和高度，而是没有改动的位图的宽高
+// 这就需要处理了
   it('should correctly handle rotated image(rotate by exif Orientation)', async () => {
     const { app, token } = await constructPlainEnvironment(true)
 
@@ -193,14 +197,14 @@ describe('controller/admin/image', function () {
       src: ori6_backdata.src,
     })
 
-    // 测试图像显示起来就是宽度小于高度的图片
+  // 测试图像显示起来就是宽度小于高度的图片
     assert(created_photo.width < created_photo.height)
   })
 
-  // 前面说的 exif 旋转的问题，
-  // 用 exif 旋转的图片所生成的缩略图也还是显示成没有旋转的样子
-  // 这也需要处理
-  // 因为缩略图需要经过重新压缩，所以直接从第二种旋转方式转为使用第一种旋转方式即可
+// 前面说的 exif 旋转的问题，
+// 用 exif 旋转的图片所生成的缩略图也还是显示成没有旋转的样子
+// 这也需要处理
+// 因为缩略图需要经过重新压缩，所以直接从第二种旋转方式转为使用第一种旋转方式即可
   it('should correctly handle rotated thumb image(rotate by exif Orientation)', async () => {
     const { app, token } = await constructPlainEnvironment(true)
 
@@ -214,13 +218,15 @@ describe('controller/admin/image', function () {
     const { width, height } = await sharp(down_res.body).metadata()
     assert(typeof width === 'number')
     assert(typeof height === 'number')
-    assert(width < height) // 因为 ori6_image_path 显示起来就是宽度小于高度的图片，因此其缩略图也必定是宽度小于高度
+  // 因为 ori6_image_path 显示起来就是宽度小于高度的图片，
+  // 因此其缩略图也必定是宽度小于高度
+    assert(width < height)
   })
 
   it('should successfully refresh thumb image', async () => {
     const { app, token } = await constructPlainEnvironment(true)
 
-    const u_img = await uploadImage(token, app)
+    const u_img = await uploadImage(token, app, test_avatar_image_path)
 
     const thumb_path = app.serviceClasses.image.toDefaultThumbSavePath(u_img.src)
 
@@ -240,51 +246,22 @@ describe('controller/admin/image', function () {
       src: u_img.src,
     })
 
-    const res = await app.httpRequest()
-      .get('/admin/image/refresh-thumb')
-      .set('Authorization', token)
-      .expect(200)
-
-    const { successes, failures } = res.body
-
-    assert(Array.isArray(successes))
-    assert(successes.length === 2) // 创建了一张照片和一位用户的头像
-    assert(Array.isArray(failures))
-    assert(failures.length === 0)
-    assert(fs.existsSync(thumb_path) === true)
-
     {
-      fs.unlinkSync(path.join(app.config.imageSavePath, created_photo.src))
-      const res = await app.httpRequest()
-        .get('/admin/image/refresh-thumb')
-        .set('Authorization', token)
-        .expect(200)
-
-      const { successes, failures } = res.body
-      assert(successes.length === 1)
-      assert(failures.length === 1)
+      const res = await adminRefreshThumb(app, token, { src: u_img.src })
+      assert(res.src_filename === u_img.src)
+      assert(fs.existsSync(thumb_path) === true)
+
+      const meta = await loadMetadataByBuffer(
+        await downloadImage(app, created_photo.thumb_urlpath)
+      )
+      assert(meta.width === test_avatar_image_width)
+    }
+    {
+      const res = await adminRefreshThumb(app, token, { src: u_img.src, thumb_size: 16 })
+      const meta = await loadMetadataByBuffer(
+        await downloadImage(app, created_photo.thumb_urlpath)
+      )
+      assert(meta.width === 16)
     }
   })
-
-  // it('check unuse image after refresh thumb', async () => {
-  //   const unuse_img = await uploadImage(token, app, test_image_path)
-  //   const img = await uploadImage(token, app, test_image_path)
-  //   const member = await createMember(token, app, { qq_num: 22222 })
-  //   const gallery = await commonCreateGallery(token, app, {})
-  //   const created_photo = await createPhoto(token, app, {
-  //     gallery_id: gallery.id,
-  //     member_id: member.id,
-  //     src: img.src,
-  //   })
-
-  //   const unuse_img_path = app.serviceClasses.image.toSrcSavePath(unuse_img.src)
-  //   assert(fs.existsSync(unuse_img_path) === true)
-
-  //   await app.httpRequest()
-  //     .get('/admin/image/refresh-thumb')
-  //     .set('Authorization', token)
-  //     .expect(200)
-
-  //   assert(fs.existsSync(unuse_img_path) === false)
-  // })
 })