(feature) test running job

backend/src/index.ts

@@ -42,6 +42,7 @@ import {
   list_connections,
   update_connection,
 } from "./api/connections";
+import runAllTests from "services/testing/runAllTests";
 
 dotenv.config();
 
@@ -117,6 +118,7 @@ const main = async () => {
     app.listen(port, () => {
       console.log(`⚡️[server]: Server is running at http://localhost:${port}`);
     });
+    runAllTests();
   } catch (err) {
     console.error(`CatchBlockInsideMain: ${err}`);
   }

backend/src/jobs.ts

@@ -1,6 +1,7 @@
 import schedule from "node-schedule";
 import { AppDataSource } from "data-source";
 import { JobsService } from "services/jobs";
+import runAllTests from "services/testing/runAllTests";
 
 const main = async () => {
   const datasource = await AppDataSource.initialize();
@@ -15,6 +16,11 @@ const main = async () => {
     JobsService.generateEndpointsFromTraces();
   });
 
+  schedule.scheduleJob("30 * * * *", () => {
+    console.log("Running Tests...");
+    runAllTests();
+  });
+
   process.on("SIGINT", () => {
     schedule.gracefulShutdown().then(() => process.exit(0));
   });

backend/src/services/testing/runAllTests.ts

@@ -0,0 +1,21 @@
+import { AppDataSource } from "data-source";
+import { ApiEndpointTest } from "models";
+import { runTest } from "./runTests";
+
+export const runAllTests = async (): Promise<void> => {
+  const testRepository = AppDataSource.getRepository(ApiEndpointTest);
+  const allTests = await testRepository.find();
+  const results = await Promise.all(allTests.map(runTest));
+  await Promise.all(
+    allTests.map((test, testIdx) => {
+      const runResult = results[testIdx];
+      test.requests = test.requests.map((e, i) => ({
+        ...e,
+        result: runResult[i],
+      }));
+      return testRepository.save(test);
+    })
+  );
+};
+
+export default runAllTests;