feat:添加文件上传的业务

Author: pedro

.gitignore

@@ -14,4 +14,5 @@ suspect/
 .vscode/
 dist
 learn
-tokens.json
+tokens.json
+app/assets

app/api/cms/file.js

@@ -1,14 +1,17 @@
 'use strict';
 
 const { LinRouter } = require('lin-mizar');
+const { LocalUploader } = require('../../extensions/file/local-uploader');
 
 const file = new LinRouter({
   prefix: '/cms/file'
 });
 
-file.get('/', async ctx => {
-  ctx.type = 'html';
-  ctx.body = 'file';
+file.post('/', async ctx => {
+  const files = await ctx.multipart();
+  const uploader = new LocalUploader('app/assets');
+  await uploader.upload(files);
+  ctx.success();
 });
 
 module.exports = { file };

app/app.js

@@ -31,12 +31,13 @@ async function createApp () {
   applyBodyParse(app);
   applyCors(app);
   config.initApp(app);
-  const { log, error, Lin } = require('lin-mizar');
+  const { log, error, Lin, multipart } = require('lin-mizar');
   app.use(log);
   app.on('error', error);
   const lin = new Lin();
   await lin.initApp(app, true, true, null, null, null);
   indexPage(app);
+  multipart(app);
   return app;
 }
 

app/extensions/file/config.js

@@ -0,0 +1,5 @@
+'use strict';
+
+module.exports = {
+  file_store_dir: 'assets'
+};

app/extensions/file/local-uploader.js

@@ -0,0 +1,18 @@
+const { Uploader } = require('lin-mizar/lin/file');
+const fs = require('fs');
+
+class LocalUploader extends Uploader {
+  /**
+   * 处理文件流
+   * @param {object[]} files 文件流数组
+   */
+  async upload (files) {
+    for (const stream of files) {
+      const filepath = this.getStorePath(stream.filename);
+      const target = fs.createWriteStream(filepath);
+      await stream.pipe(target);
+    }
+  }
+}
+
+module.exports = { LocalUploader };

app/starter.js

@@ -1,12 +1,15 @@
 'use strict';
 
 const { config } = require('lin-mizar/lin/config');
+const fs = require('fs');
 
 // 1. 必须最开始加载配置，因为其他很多扩展依赖于配置
 function applyConfig () {
-  // TODO: 自动加载app/config下的所有配置文件
-  config.getConfigFromFile('app/config/setting.js');
-  config.getConfigFromFile('app/config/secure.js');
+  const cwd = process.cwd();
+  const files = fs.readdirSync(`${cwd}/app/config`);
+  for (const file of files) {
+    config.getConfigFromFile(`app/config/${file}`);
+  }
 }
 
 const run = async () => {