refactor: move qn util to helper

Author: ngot

app/common/upload.js

@@ -7,8 +7,6 @@ const fs = require('fs');
 const awaitWriteStream = require('await-stream-ready').write;
 const sendToWormhole = require('stream-wormhole');
 
-const qnUpload = require('../common/upload');
-
 class TopicController extends Controller {
   /**
    * Topic page
@@ -427,7 +425,7 @@ class TopicController extends Controller {
     // 如果有七牛云的配置,优先上传七牛云
     if (config.qn_access) {
       try {
-        const upload = qnUpload(config.qn_access);
+        const upload = this.ctx.helper.qnUpload(config.qn_access);
         const result = await upload(stream);
         ctx.body = {
           success: true,

app/controller/topic.js

@@ -5,6 +5,8 @@ const validator = require('validator');
 const jsxss = require('xss');
 const moment = require('moment');
 const bcrypt = require('bcryptjs');
+const util = require('util');
+const qn = require('qn');
 
 moment.locale('zh-cn'); // 使用中文
 
@@ -112,3 +114,16 @@ exports.bhash = str => {
 exports.bcompare = (str, hash) => {
   return bcrypt.compareSync(str, hash);
 };
+
+let qnClientUpload;
+
+exports.qnUpload = options => {
+  // 7牛 client
+  if (qnClientUpload) return qnClientUpload;
+  let qnClient;
+  if (options.qn_access && options.qn_access.secretKey !== 'your secret key') {
+    qnClient = qn.create(options.qn_access);
+  }
+  qnClientUpload = util.promisify(qnClient.upload);
+  return qnClientUpload;
+};