fix: extend acs-client for supporting multiple entitites in custom ar…

…guments filter response

package.json

@@ -18,18 +18,18 @@
   ],
   "type": "module",
   "dependencies": {
-    "@bull-board/api": "^5.15.5",
-    "@bull-board/express": "^5.15.5",
-    "@bull-board/koa": "^5.15.5",
-    "@restorecommerce/acs-client": "^1.5.1",
-    "@restorecommerce/chassis-srv": "^1.5.0",
+    "@bull-board/api": "^5.16.0",
+    "@bull-board/express": "^5.16.0",
+    "@bull-board/koa": "^5.16.0",
+    "@restorecommerce/acs-client": "^1.6.0",
+    "@restorecommerce/chassis-srv": "^1.6.0",
     "@restorecommerce/cluster-service": "^1.0.3",
     "@restorecommerce/kafka-client": "^1.2.1",
     "@restorecommerce/logger": "^1.2.10",
     "@restorecommerce/rc-grpc-clients": "^5.1.23",
     "@restorecommerce/scs-jobs": "^0.1.23",
     "@restorecommerce/service-config": "^1.0.12",
-    "bullmq": "^5.7.1",
+    "bullmq": "^5.7.4",
     "cache-manager": "^5.5.1",
     "cache-manager-redis": "^0.6.0",
     "cron-parser": "^4.9.0",

src/schedulingService.ts

@@ -627,6 +627,7 @@ export class SchedulingService implements SchedulingServiceServiceImplementation
 
   private filterByOwnerShip(customArgsObj, result) {
     // applying filter based on custom arguments (filterByOwnerShip)
+    let filteredResult: Job[] = [];
     let customArgs = (customArgsObj)?.custom_arguments;
     if (customArgs?.value) {
       let customArgsFilter;
@@ -638,28 +639,34 @@ export class SchedulingService implements SchedulingServiceServiceImplementation
           message: error.message, stack: error.stack
         });
       }
-      if (!customArgsFilter) {
+      if (customArgsFilter?.length === 0) {
         return [];
       }
-      const ownerIndicatorEntity = customArgsFilter.entity;
-      const ownerValues = customArgsFilter.instance;
-      const ownerIndictaorEntURN = this.cfg.get('authorization:urns:ownerIndicatoryEntity');
-      const ownerInstanceURN = this.cfg.get('authorization:urns:ownerInstance');
-      result = result.filter(job => {
-        if (job?.data?.meta?.owners?.length > 0) {
-          for (let owner of job.data.meta.owners) {
-            if (owner?.id === ownerIndictaorEntURN && owner?.value === ownerIndicatorEntity && owner?.attributes?.length > 0) {
-              for (let ownerInstObj of owner.attributes) {
-                if (ownerInstObj?.id === ownerInstanceURN && ownerInstObj?.value && ownerValues.includes(ownerInstObj.value)) {
-                  return job;
+      for (let customArgObj of customArgsFilter) {
+        const ownerIndicatorEntity = customArgObj?.entity;
+        const ownerValues = customArgObj?.instance;
+        const ownerIndictaorEntURN = this.cfg.get('authorization:urns:ownerIndicatoryEntity');
+        const ownerInstanceURN = this.cfg.get('authorization:urns:ownerInstance');
+        const filteredResp = result.filter(job => {
+          if (job?.data?.meta?.owners?.length > 0) {
+            for (let owner of job.data.meta.owners) {
+              if (owner?.id === ownerIndictaorEntURN && owner?.value === ownerIndicatorEntity && owner?.attributes?.length > 0) {
+                for (let ownerInstObj of owner.attributes) {
+                  if (ownerInstObj?.id === ownerInstanceURN && ownerInstObj?.value && ownerValues.includes(ownerInstObj.value)) {
+                    return job;
+                  }
                 }
               }
             }
           }
-        }
-      });
+        });
+        filteredResult = filteredResult.concat(filteredResp);
+      }
+      return filteredResult;
+    } else {
+      // no custom filters exist, return complete result set
+      return result;
     }
-    return result;
   }
 
   async deleteRedisKey(key: string): Promise<any> {