fix: upload images error

Author: suemor233

package.json

@@ -76,6 +76,7 @@
     "qiniu": "^7.8.0",
     "reflect-metadata": "^0.1.13",
     "rxjs": "^7.2.0",
+    "url": "^0.11.0",
     "wildcard-match": "^5.1.2",
     "zx-cjs": "7.0.7-0"
   },

pnpm-lock.yaml

@@ -17,6 +17,6 @@ export class UploadController {
   @Auth() // 权限校验
   @UseInterceptors(FileInterceptor('file')) // 处理文件中间件 file 与上传的字段对应
   upload(@UploadedFile() file: Express.Multer.File) {
-    return this.UploadService.upload(file)
+    return this.UploadService.uploadPhoto(file)
   }
 }

src/modules/upload/upload.controller.ts

@@ -1,69 +1,52 @@
 import qiniu from 'qiniu'
+import * as url from 'url'
 
-import {
-  BadRequestException,
-  Injectable,
-  InternalServerErrorException,
-} from '@nestjs/common'
+import { Injectable, InternalServerErrorException } from '@nestjs/common'
 
 import { QINIU_SECRET } from '~/app.config'
 
-const mac = new qiniu.auth.digest.Mac(QINIU_SECRET.qn_ak, QINIU_SECRET.qn_sk)
-const putPolicy = new qiniu.rs.PutPolicy({
-  scope: QINIU_SECRET.qn_scope,
-})
-const uploadToken = putPolicy.uploadToken(mac)
-
-const config = new qiniu.conf.Config()
-const bucketManager = new qiniu.rs.BucketManager(mac, config)
-
 @Injectable()
 export class UploadService {
-  upload(file: Express.Multer.File): Promise<string> {
-    if (!file) {
-      throw new BadRequestException('请传入图片')
-    }
-    const filename = `${Date.now()}-${file.originalname}`
+  async uploadPhoto(file: Express.Multer.File) {
+    const mac = new qiniu.auth.digest.Mac(
+      QINIU_SECRET.qn_ak,
+      QINIU_SECRET.qn_sk,
+    )
+    const putPolicy = new qiniu.rs.PutPolicy({
+      scope: QINIU_SECRET.qn_scope,
+    })
+    const uploadToken = putPolicy.uploadToken(mac)
+
+    // upload
     const formUploader = new qiniu.form_up.FormUploader(
       new qiniu.conf.Config({
         zone: qiniu.zone.Zone_z2,
       }),
     )
-    const putExtra = new qiniu.form_up.PutExtra()
-
-    return new Promise((resolve) => {
+    const img = (await new Promise((_res, _rej) => {
       formUploader.put(
         uploadToken,
-        filename,
+        `${Date.now()}-${file.originalname}`,
         file.buffer,
-        putExtra,
+        new qiniu.form_up.PutExtra(),
         (respErr, respBody, respInfo) => {
           if (respErr) {
+            console.error(respErr)
             throw new InternalServerErrorException(respErr.message)
           }
+
           if (respInfo.statusCode == 200) {
-            resolve(`${QINIU_SECRET.qn_host}/${respBody.key}`)
+            _res({
+              url: new url.URL(respBody.key, QINIU_SECRET.qn_host).href,
+            })
           } else {
-            throw new InternalServerErrorException(respErr.message)
+            console.error(respInfo.statusCode, respBody)
+            throw new InternalServerErrorException(respInfo)
           }
         },
       )
-    })
-  }
+    })) as { url: string }
 
-  remove(fileName: string) {
-    return new Promise((resolve) => {
-      bucketManager.delete(
-        QINIU_SECRET.qn_scope,
-        fileName,
-        (err, respBody, respInfo) => {
-          if (err) {
-            throw new InternalServerErrorException(err.message)
-          } else {
-            resolve('删除成功')
-          }
-        },
-      )
-    })
+    return img.url
   }
 }