fix: optimize backgroud output (#47)

* fix: optimize backgroud output

* fix: lint

* fix: lint

Co-authored-by: wanghx <whx89768@antgroup.com>

Author: whxaxes

plugin/tegg/lib/EggAppLoader.ts

@@ -1,5 +1,5 @@
 import { Application } from 'egg';
-import { Loader } from '@eggjs/tegg-metadata';
+import { Loader, TeggError } from '@eggjs/tegg-metadata';
 import {
   AccessLevel,
   EggProtoImplClass, InitTypeQualifierAttribute, LoadUnitNameQualifierAttribute,
@@ -46,6 +46,11 @@ export class EggAppLoader implements Loader {
   private buildCtxClazz(name: string): EggProtoImplClass {
     const temp = {
       [name]: function(ctx) {
+        if (!ctx) {
+          // ctx has been destroyed, throw humanize error info
+          throw TeggError.create(`Can not read property \`${name}\` because egg ctx has been destroyed`, 'read_after_ctx_destroyed');
+        }
+
         return ctx[name];
       } as any,
     };

plugin/tegg/test/BackgroundTask.test.ts

@@ -3,8 +3,10 @@ import assert from 'assert';
 import path from 'path';
 import { CountService } from './fixtures/apps/background-app/modules/multi-module-background/CountService';
 import sleep from 'mz-modules/sleep';
+import fs from 'fs';
 
 describe('test/BackgroundTask.test.ts', () => {
+  const appDir = path.join(__dirname, 'fixtures/apps/background-app');
   let app;
 
   after(async () => {
@@ -21,7 +23,7 @@ describe('test/BackgroundTask.test.ts', () => {
       return path.join(__dirname, '..');
     });
     app = mm.app({
-      baseDir: path.join(__dirname, 'fixtures/apps/background-app'),
+      baseDir: appDir,
       framework: require.resolve('egg'),
     });
     await app.ready();
@@ -38,4 +40,15 @@ describe('test/BackgroundTask.test.ts', () => {
     await sleep(1000);
     assert(countService.count === 1);
   });
+
+  it('background timeout with humanize error info', async () => {
+    app.mockCsrf();
+    await app.httpRequest()
+      .get('/backgroudTimeout')
+      .expect(200);
+
+    await sleep(7000);
+    const errorLog = fs.readFileSync(path.resolve(appDir, 'logs/egg-app/common-error.log'), 'utf-8');
+    assert(errorLog.includes('Can not read property `testObj` because egg ctx has been destroyed ['));
+  });
 });

plugin/tegg/test/fixtures/apps/background-app/app/controller/app.ts

@@ -8,4 +8,11 @@ export default class App extends Controller {
     this.ctx.status = 200;
     this.ctx.body = 'done';
   }
+
+  async backgroudTimeout() {
+    const backgroundService = await this.ctx.getEggObject(BackgroundService);
+    await backgroundService.backgroundAdd(6000);
+    this.ctx.status = 200;
+    this.ctx.body = 'done';
+  }
 }

plugin/tegg/test/fixtures/apps/background-app/app/extend/context.ts

@@ -0,0 +1,5 @@
+export default {
+  testObj: {
+    ok: true,
+  },
+};

plugin/tegg/test/fixtures/apps/background-app/app/router.ts

@@ -2,4 +2,5 @@ import { Application } from 'egg';
 
 module.exports = (app: Application) => {
   app.router.get('/background', app.controller.app.background);
+  app.router.get('/backgroudTimeout', app.controller.app.backgroudTimeout);
 };

plugin/tegg/test/fixtures/apps/background-app/modules/multi-module-background/BackgroundService.ts

@@ -2,6 +2,7 @@ import { AccessLevel, ContextProto, Inject } from '@eggjs/tegg';
 import { BackgroundTaskHelper } from '@eggjs/tegg-background-task';
 import { CountService } from './CountService';
 import sleep from 'mz-modules/sleep';
+import assert from 'assert';
 
 @ContextProto({
   accessLevel: AccessLevel.PUBLIC,
@@ -10,12 +11,16 @@ export default class BackgroundService {
   @Inject()
   private readonly backgroundTaskHelper:BackgroundTaskHelper;
 
+  @Inject()
+  testObj: any;
+
   @Inject()
   private readonly countService: CountService;
 
-  async backgroundAdd() {
+  async backgroundAdd(delay = 1000) {
     this.backgroundTaskHelper.run(async () => {
-      await sleep(1000);
+      await sleep(delay);
+      assert(this.testObj.ok);
       this.countService.count += 1;
     });
   }