test: add async test case

Author: dead-horse

.eslintrc

@@ -1,3 +1,6 @@
 {
- "extends": "eslint-config-egg"
+ "extends": "eslint-config-egg",
+ "parserOptions": {
+ "ecmaVersion": 2017
+ }
 }

test/async/_async.js

@@ -0,0 +1,28 @@
+'use strict';
+
+const assert = require('assert');
+const request = require('supertest');
+const mm = require('egg-mock');
+const utils = require('../utils');
+
+describe('test/async.test.js', () => {
+ afterEach(mm.restore);
+ let app;
+ before(async () => {
+ app = utils.app('apps/async-app');
+ await app.ready();
+ assert(app.beforeStartExectuted);
+ assert(app.scheduleExecuted);
+ });
+ after(async () => {
+ await app.close();
+ assert(app.beforeCloseExecuted);
+ });
+
+ it('middleware, controller and service support async functions', async () => {
+ await request(app.callback())
+ .get('/api')
+ .expect(200)
+ .expect([ 'service', 'controller', 'router', 'middleware' ]);
+ });
+});

test/async/index.test.js

@@ -0,0 +1,7 @@
+'use strict';
+
+const nodeVersion = Number(process.version.match(/^v(\d+\.\d)+\./)[1]);
+// only node >= 7.6 support async function without flags
+if (nodeVersion >= 7.6) {
+ require('./_async');
+}

test/fixtures/apps/async-app/app.js

@@ -0,0 +1,14 @@
+'use strict';
+
+module.exports = app => {
+ app.beforeStart(async () => {
+ await Promise.resolve();
+ await app.runSchedule('async');
+ app.beforeStartExectuted = true;
+ });
+
+ app.beforeClose(async () => {
+ await Promise.resolve();
+ app.beforeCloseExecuted = true;
+ });
+};

test/fixtures/apps/async-app/app/controller/api.js

@@ -0,0 +1,11 @@
+'use strict';
+
+module.exports = app => {
+ return class ApiController extends app.Controller {
+ async index() {
+ const result = await this.service.api.getName();
+ this.ctx.body.push(result);
+ this.ctx.body.push('controller');
+ }
+ };
+};

test/fixtures/apps/async-app/app/middleware/async.js

@@ -0,0 +1,9 @@
+'use strict';
+
+module.exports = () => {
+ return async (ctx, next) => {
+ ctx.body = [];
+ await next();
+ ctx.body.push('middleware');
+ };
+};

test/fixtures/apps/async-app/app/middleware/router.js

@@ -0,0 +1,9 @@
+'use strict';
+
+module.exports = () => {
+ return async (ctx, next) => {
+ ctx.body = [];
+ await next();
+ ctx.body.push('router');
+ };
+};

test/fixtures/apps/async-app/app/router.js

@@ -0,0 +1,5 @@
+'use strict';
+
+module.exports = app => {
+ app.get('/api', app.middlewares.router(), 'api.index');
+};

test/fixtures/apps/async-app/app/schedule/async.js

@@ -0,0 +1,11 @@
+'use strict';
+
+exports.schedule = {
+ type: 'worker',
+ interval: 1000000,
+};
+
+exports.task = async (ctx) => {
+ await Promise.resolve();
+ ctx.app.scheduleExecuted = true;
+};

test/fixtures/apps/async-app/app/service/api.js

@@ -0,0 +1,14 @@
+'use strict';
+
+module.exports = app => {
+ return class ApiService extends app.Service {
+ async getName() {
+ await sleep(100);
+ return 'service';
+ }
+ };
+};
+
+function sleep(ms) {
+ return new Promise(resolve => setTimeout(resolve, ms));
+}