ruiling/tachybase_todo
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: stopped state in application (#1543)

Browse Source
This commit is contained in:
ChengLei Shao 2023-03-06 21:19:49 +08:00 committed by GitHub
parent 2e4354fcf3
commit db6d572638
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
packages/core/server/src/application.ts
View File

@ -172,6 +172,8 @@ export class Application<StateT = DefaultState, ContextT = DefaultContext> exten
declare middleware: any; declare middleware: any;
stopped: boolean = false;
constructor(public options: ApplicationOptions) { constructor(public options: ApplicationOptions) {
super(); super();
this.init(); this.init();
@ -434,6 +436,7 @@ export class Application<StateT = DefaultState, ContextT = DefaultContext> exten
} }
await this.emitAsync('afterStart', this, options); await this.emitAsync('afterStart', this, options);
this.stopped = false;
} }
listen(...args): Server { listen(...args): Server {
@ -441,6 +444,11 @@ export class Application<StateT = DefaultState, ContextT = DefaultContext> exten
} }
async stop(options: any = {}) { async stop(options: any = {}) {
if (this.stopped) {
this.log.warn(`Application ${this.name} already stopped`);
return;
}
await this.emitAsync('beforeStop', this, options); await this.emitAsync('beforeStop', this, options);
try { try {
@ -460,6 +468,7 @@ export class Application<StateT = DefaultState, ContextT = DefaultContext> exten
} }
await this.emitAsync('afterStop', this, options); await this.emitAsync('afterStop', this, options);
this.stopped = true;
} }
async destroy(options: any = {}) { async destroy(options: any = {}) {