fix(terminus): fix events emitted by terminus

Closes: #2086
tsedio · Sep 15, 2022 · 7cdc748 · 7cdc748
1 parent 70a88fe
commit 7cdc748
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 1 deletion.
diff --git a/packages/third-parties/terminus/src/TerminusModule.spec.ts b/packages/third-parties/terminus/src/TerminusModule.spec.ts
@@ -13,6 +13,8 @@ class MyService {
   redis() {
     return Promise.resolve("OK");
   }
+
+  $beforeShutdown() {}
 }
 
 describe("TerminusModule", () => {
@@ -71,4 +73,17 @@ describe("TerminusModule", () => {
 
     await props.onSignal();
   });
+
+  it("should emit event", async () => {
+    const terminusModule = PlatformTest.get<TerminusModule>(TerminusModule);
+    const service = PlatformTest.get<MyService>(MyService);
+
+    jest.spyOn(service, "$beforeShutdown");
+
+    const {beforeShutdown} = terminusModule.getConfiguration();
+
+    await beforeShutdown();
+
+    expect(service.$beforeShutdown).toHaveBeenCalledWith();
+  });
 });
diff --git a/packages/third-parties/terminus/src/TerminusModule.ts b/packages/third-parties/terminus/src/TerminusModule.ts
@@ -143,7 +143,7 @@ export class TerminusModule implements OnInit {
 
   private createEmitter(name: string) {
     return async (...args: any[]) => {
-      return this.injector.emit(`$${name}`, ...args);
+      return this.injector.emit(name, ...args);
     };
   }
 }