Adjust testing runtime use

dbos-inc · Oct 23, 2024 · db2d0f0 · db2d0f0
1 parent 7949298
commit db2d0f0
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 10 deletions.
diff --git a/packages/dbos-dbtriggers/tests/dbtriggers_seq.test.ts b/packages/dbos-dbtriggers/tests/dbtriggers_seq.test.ts
@@ -17,11 +17,6 @@ const testTableName = "dbos_test_trig_seq";
 
 type KnexTransactionContext = TransactionContext<Knex>;
 
-interface TestingRuntimeImpl {
-    destroyEventReceivers() : Promise<void>;
-    initEventReceivers(): Promise<void>;
-}
-
 class DBOSTestNoClass {
 
 }
@@ -140,7 +135,7 @@ describe("test-db-triggers", () => {
         expect(DBOSTriggerTestClassSN.tsRecordMap.get(2)?.status).toBe("Ordered");
 
         // Take down
-        await (testRuntime as unknown as TestingRuntimeImpl).destroyEventReceivers();
+        //await testRuntime.deactivateEventReceivers();
 
         // Do more stuff
         // Invalid record, won't show up because it is well out of sequence
@@ -155,7 +150,7 @@ describe("test-db-triggers", () => {
         console.log("************************************************** Restart *****************************************************");
         DBOSTriggerTestClassSN.reset();
 
-        await (testRuntime as unknown as TestingRuntimeImpl).initEventReceivers();
+        //await testRuntime.initEventReceivers();
 
         console.log("************************************************** Restarted *****************************************************");
         DBOSTriggerTestClassSN.reset();

diff --git a/src/testing/testing_runtime.ts b/src/testing/testing_runtime.ts
@@ -78,6 +78,7 @@ export interface TestingRuntime {
 
   destroy(): Promise<void>; // Release resources after tests.
   deactivateEventReceivers(): Promise<void>; // Deactivate event receivers.
+  initEventReceivers(): Promise<void>; // Init / reactivate event receivers.
 }
 
 /**
@@ -113,9 +114,6 @@ export class TestingRuntimeImpl implements TestingRuntime {
     await this.#dbosExec.init(userClasses);
     this.#server = new DBOSHttpServer(this.#dbosExec);
     await this.initEventReceivers();
-    this.#scheduler = new DBOSScheduler(this.#dbosExec);
-    this.#scheduler.initScheduler();
-    this.#wfQueueRunner = wfQueueRunner.dispatchLoop(this.#dbosExec);
     this.#applicationConfig = this.#dbosExec.config.application ?? {};
     this.#isInitialized = true;
   }
@@ -124,6 +122,9 @@ export class TestingRuntimeImpl implements TestingRuntime {
     for (const evtRcvr of this.#dbosExec!.eventReceivers) {
       await evtRcvr.initialize(this.#dbosExec!);
     }
+    this.#scheduler = new DBOSScheduler(this.#dbosExec!);
+    this.#scheduler.initScheduler();
+    this.#wfQueueRunner = wfQueueRunner.dispatchLoop(this.#dbosExec!);
   }
 
   /**