fix(authorization): error case in index builds for older environments

ConduitPlatform · Feb 16, 2024 · 88d4ddd · 88d4ddd
1 parent e02674c
commit 88d4ddd
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 1 deletion.
diff --git a/modules/authorization/src/controllers/queue.controller.ts b/modules/authorization/src/controllers/queue.controller.ts
@@ -60,6 +60,11 @@ export class QueueController {
       ConduitGrpcSdk.Logger.error(`Job error:`);
       ConduitGrpcSdk.Logger.error(error);
     });
+
+    worker.on('failed', (job, error) => {
+      ConduitGrpcSdk.Logger.error(`Job error:`);
+      ConduitGrpcSdk.Logger.error(error);
+    });
   }
 
   addConnectionWorker() {
@@ -88,6 +93,10 @@ export class QueueController {
       ConduitGrpcSdk.Logger.error(`Job error:`);
       ConduitGrpcSdk.Logger.error(error);
     });
+    worker.on('failed', (job, error) => {
+      ConduitGrpcSdk.Logger.error(`Job error:`);
+      ConduitGrpcSdk.Logger.error(error);
+    });
   }
 
   async addRelationIndexJob(

diff --git a/modules/authorization/src/jobs/processPossibleConnections.ts b/modules/authorization/src/jobs/processPossibleConnections.ts
@@ -52,7 +52,7 @@ export default async (job: SandboxedJob<ConstructRelationIndexWorkerData>) => {
             permission,
             connection.entity.split('#')[1],
             connection.entity.split('#')[0],
-            [...connection.inheritanceTree, `${subject}#${relation}@${object}`],
+            [...(connection.inheritanceTree ?? []), `${subject}#${relation}@${object}`],
           ),
         );
       }