Add stub for recurring system status check job

source/SIL.AppBuilder.Portal/common/BullJobTypes.ts

@@ -8,7 +8,8 @@ export enum ScriptoriaJobType {
   EmailReviewers = 'EmailReviewers',
   PublishProduct = 'PublishProduct',
   CheckBuildProduct = 'CheckBuildProduct',
-  CheckPublishProduct = 'CheckPublishProduct'
+  CheckPublishProduct = 'CheckPublishProduct',
+  CheckSystemStatuses = 'CheckSystemStatuses'
 }
 
 export interface TestJob {
@@ -63,6 +64,10 @@ export interface CheckPublishProductJob {
   releaseId: number;
 }
 
+export interface CheckSystemStatusesJob {
+  type: ScriptoriaJobType.CheckSystemStatuses;
+}
+
 export type ScriptoriaJob = JobTypeMap[keyof JobTypeMap];
 
 export type JobTypeMap = {
@@ -74,5 +79,6 @@ export type JobTypeMap = {
   [ScriptoriaJobType.PublishProduct]: PublishProductJob;
   [ScriptoriaJobType.CheckBuildProduct]: CheckBuildProductJob;
   [ScriptoriaJobType.CheckPublishProduct]: CheckPublishProductJob;
+  [ScriptoriaJobType.CheckSystemStatuses]: CheckSystemStatusesJob;
   // Add more mappings here as needed
 };

source/SIL.AppBuilder.Portal/node-server/BullWorker.ts

@@ -50,6 +50,10 @@ export class ScriptoriaWorker extends BullWorker<BullMQ.ScriptoriaJob, number> {
         return new Executor.CheckPublishProduct().execute(
           job as Job<BullMQ.CheckPublishProductJob, number, string>
         );
+      case BullMQ.ScriptoriaJobType.CheckSystemStatuses:
+        return new Executor.CheckSystemStatuses().execute(
+          job as Job<BullMQ.CheckSystemStatusesJob, number, string>
+        );
     }
   }
 }

source/SIL.AppBuilder.Portal/node-server/dev.ts

@@ -8,7 +8,7 @@ process.env.NODE_ENV = 'development';
 
 const app = express();
 
-import { scriptoriaQueue } from 'sil.appbuilder.portal.common';
+import { BullMQ, scriptoriaQueue } from 'sil.appbuilder.portal.common';
 const serverAdapter = new ExpressAdapter();
 serverAdapter.setBasePath('/');
 createBullBoard({
@@ -18,4 +18,17 @@ createBullBoard({
 app.use(serverAdapter.getRouter());
 app.listen(3000, () => console.log('Dev server started'));
 
+// Recurring job to check the availability of BuildEngine
+scriptoriaQueue.add(
+  'Check System Statuses (Recurring)',
+  {
+    type: BullMQ.ScriptoriaJobType.CheckSystemStatuses
+  },
+  {
+    repeat: {
+      pattern: '*/5 * * * *' // every 5 minutes
+    }
+  }
+);
+
 new ScriptoriaWorker();

source/SIL.AppBuilder.Portal/node-server/index.ts

@@ -72,7 +72,7 @@ app.get('/healthcheck', (req, res) => {
 });
 
 // BullMQ variables
-import { scriptoriaQueue } from 'sil.appbuilder.portal.common';
+import { BullMQ, scriptoriaQueue } from 'sil.appbuilder.portal.common';
 // Running on svelte process right now. Consider putting on new thread
 // Fine like this if majority of job time is waiting for network requests
 // If there is much processing it should be moved to another thread
@@ -96,3 +96,16 @@ const handler = await import('./build/handler.js');
 app.use(handler.handler);
 
 app.listen(3000, () => console.log('Server started!'));
+
+// Recurring job to check the availability of BuildEngine
+scriptoriaQueue.add(
+  'Check System Statuses (Recurring)',
+  {
+    type: BullMQ.ScriptoriaJobType.CheckSystemStatuses
+  },
+  {
+    repeat: {
+      pattern: '*/5 * * * *' // every 5 minutes
+    }
+  }
+);

source/SIL.AppBuilder.Portal/node-server/job-executors/index.ts

@@ -8,3 +8,4 @@ export {
   CheckBuildProduct,
   CheckPublishProduct
 } from './product.js';
+export { CheckSystemStatuses } from './systemStatus.js';

source/SIL.AppBuilder.Portal/node-server/job-executors/systemStatus.ts

@@ -0,0 +1,19 @@
+import { BullMQ, prisma, DatabaseWrites } from 'sil.appbuilder.portal.common';
+import { Job } from 'bullmq';
+import { ScriptoriaJobExecutor } from './base.js';
+
+export class CheckSystemStatuses extends ScriptoriaJobExecutor<BullMQ.ScriptoriaJobType.CheckSystemStatuses> {
+  async execute(job: Job<BullMQ.CheckSystemStatusesJob, number, string>): Promise<number> {
+    // TODO: Do I use the `SystemStatus` table? Why does this table even exist? It mostly duplicates data from `Organizations` but is completely disconnected from `Organizations`. Can these be consolidated?
+    const systems = await prisma.systemStatuses.findMany();
+    job.updateProgress(10);
+    //const timestamp = new Date();
+    systems.forEach((s, i) => {
+      // TODO: Not doing anything here until above TODO is resolved
+      job.updateProgress(10 + (i+1) * 80 / systems.length);
+    });
+    //await prisma.$transaction(systems.map());
+    job.updateProgress(100);
+    return systems.length;
+  }
+}