MODBULKOPS-334 Added validation

folio-org · Sep 20, 2024 · 5850eb6 · 5850eb6
1 parent 5ecb891
commit 5850eb6
Show file tree

Hide file tree

Showing 3 changed files with 30 additions and 0 deletions.
diff --git a/src/main/java/org/folio/bulkops/processor/AbstractDataProcessor.java b/src/main/java/org/folio/bulkops/processor/AbstractDataProcessor.java
@@ -8,7 +8,9 @@
 import org.folio.bulkops.domain.dto.BulkOperationRuleCollection;
 import org.folio.bulkops.domain.dto.UpdateOptionType;
 import org.folio.bulkops.exception.RuleValidationException;
+import org.folio.bulkops.service.ConsortiaService;
 import org.folio.bulkops.service.ErrorService;
+import org.folio.spring.FolioExecutionContext;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
@@ -19,6 +21,10 @@
 public abstract class AbstractDataProcessor<T extends BulkOperationsEntity> implements DataProcessor<T> {
   @Autowired
   private ErrorService errorService;
+  @Autowired
+  private ConsortiaService consortiaService;
+  @Autowired
+  private FolioExecutionContext folioExecutionContext;
 
   @Override
   public UpdatedEntityHolder process(String identifier, T entity, BulkOperationRuleCollection rules) {
@@ -28,7 +34,19 @@ public UpdatedEntityHolder process(String identifier, T entity, BulkOperationRul
     for (BulkOperationRule rule : rules.getBulkOperationRules()) {
       var details = rule.getRuleDetails();
       var option = details.getOption();
+      var tenantsFromRule = rule.getRuleDetails().getTenants();
+      if (consortiaService.isCurrentTenantCentralTenant(folioExecutionContext.getTenantId()) && !tenantsFromRule.isEmpty() && !tenantsFromRule.contains(entity.getTenant())) {
+        errorService.saveError(rule.getBulkOperationId(), identifier,
+          String.format("%s cannot be updated because the record is associated with %s and %s is not associated with this tenant.",
+            entity.getIdentifier(org.folio.bulkops.domain.dto.IdentifierType.ID), entity.getTenant(), option.getValue()));
+      }
       for (Action action : details.getActions()) {
+        var tenantsFromAction = action.getTenants();
+        if (consortiaService.isCurrentTenantCentralTenant(folioExecutionContext.getTenantId()) && !tenantsFromAction.isEmpty() && !tenantsFromAction.contains(entity.getTenant())) {
+          errorService.saveError(rule.getBulkOperationId(), identifier,
+            String.format("%s cannot be updated because the record is associated with %s and %s is not associated with this tenant.",
+              entity.getIdentifier(org.folio.bulkops.domain.dto.IdentifierType.ID), entity.getTenant(), option.getValue()));
+        }
         try {
           updater(option, action).apply(preview);
           validator(entity).validate(option, action);

diff --git a/src/main/resources/swagger.api/schemas/action.json b/src/main/resources/swagger.api/schemas/action.json
@@ -21,6 +21,12 @@
         "items": {
           "$ref": "action_parameter.json#/Parameter"
         }
+      },
+      "tenants": {
+        "type": "array",
+        "items": {
+          "type": "string"
+        }
       }
     },
     "required": [

diff --git a/src/main/resources/swagger.api/schemas/bulk_operation_rule.json b/src/main/resources/swagger.api/schemas/bulk_operation_rule.json
@@ -22,6 +22,12 @@
             "description": "Option to change",
             "$ref": "update_option_type.json#/UpdateOptionType"
           },
+          "tenants": {
+            "type": "array",
+            "items": {
+              "type": "string"
+            }
+          },
           "actions": {
             "type": "array",
             "items": {