fix(authorization): jobs not being processed correctly (#841)

ConduitPlatform · Dec 10, 2023 · 80f4e64 · 80f4e64
1 parent d2c957e
commit 80f4e64
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/modules/authorization/src/controllers/queue.controller.ts b/modules/authorization/src/controllers/queue.controller.ts
@@ -33,8 +33,15 @@ export class QueueController {
     const processorFile = path.normalize(
       path.join(__dirname, '../jobs', 'constructRelationIndex.js'),
     );
-    new Worker('authorization-index-queue', processorFile, {
+    const worker = new Worker('authorization-index-queue', processorFile, {
       connection: this.redisConnection,
+      // autorun: true,
+    });
+    worker.on('completed', (job: any) => {
+      ConduitGrpcSdk.Logger.info(`Job ${job.id} completed`);
+    });
+    worker.on('error', (error: any) => {
+      ConduitGrpcSdk.Logger.info(`Job error:`, error);
     });
   }
 

diff --git a/modules/authorization/src/jobs/constructRelationIndex.ts b/modules/authorization/src/jobs/constructRelationIndex.ts
@@ -10,8 +10,9 @@ type ConstructRelationIndexWorkerData = {
 module.exports = async (job: SandboxedJob<ConstructRelationIndexWorkerData>) => {
   const { relations } = job.data;
   if (!process.env.CONDUIT_SERVER) throw new Error('No serverUrl provided!');
-  const grpcSdk = new ConduitGrpcSdk(process.env.CONDUIT_SERVER, 'authorization');
+  const grpcSdk = new ConduitGrpcSdk(process.env.CONDUIT_SERVER, 'authorization', false);
   await grpcSdk.initialize();
+  await grpcSdk.initializeEventBus();
   await grpcSdk.waitForExistence('database');
   ObjectIndex.getInstance(grpcSdk.database!);
   ActorIndex.getInstance(grpcSdk.database!);