MODSOURMAN-1203 Add additional validation before marc bib record saving

NEWS.md

@@ -10,6 +10,7 @@
 * [MODSOURMAN-783](https://folio-org.atlassian.net/browse/MODSOURCE-783) Extend MARC-MARC search query to account for qualifiers
 * [MODSOURCE-752](https://folio-org.atlassian.net/browse/MODSOURCE-752) Emit Domain Events For Source Records
 * [MODSOURCE-795](https://folio-org.atlassian.net/browse/MODSOURCE-795) Upgrade Spring 5 to 6 by 2024-08-31
+* [MODSOURMAN-1203](https://folio-org.atlassian.net/browse/MODSOURMAN-1203) Add validation on MARC_BIB record save
 
 ## 2024-03-20 5.8.0
 * [MODSOURCE-733](https://issues.folio.org/browse/MODSOURCE-733) Reduce Memory Allocation of Strings

mod-source-record-storage-server/src/main/java/org/folio/services/RecordServiceImpl.java

@@ -16,14 +16,13 @@
 import static org.folio.dao.util.SnapshotDaoUtil.SNAPSHOT_NOT_STARTED_MESSAGE_TEMPLATE;
 import static org.folio.rest.util.OkapiConnectionParams.OKAPI_TENANT_HEADER;
 import static org.folio.rest.util.QueryParamUtil.toRecordType;
-import static org.folio.services.util.AdditionalFieldsUtil.TAG_999;
-import static org.folio.services.util.AdditionalFieldsUtil.addFieldToMarcRecord;
-import static org.folio.services.util.AdditionalFieldsUtil.getFieldFromMarcRecord;
+import static org.folio.services.util.AdditionalFieldsUtil.*;
 
 import io.reactivex.Flowable;
 import io.vertx.core.AsyncResult;
 import io.vertx.core.Future;
 import io.vertx.core.Promise;
+import io.vertx.core.json.Json;
 import io.vertx.core.json.JsonArray;
 import io.vertx.core.json.JsonObject;
 import io.vertx.pgclient.PgException;
@@ -96,8 +95,10 @@ public class RecordServiceImpl implements RecordService {
   private static final String NOT_FOUND_MESSAGE = "%s with id '%s' was not found";
   private static final Character DELETED_LEADER_RECORD_STATUS = 'd';
   public static final String UPDATE_RECORD_DUPLICATE_EXCEPTION = "Incoming record could be a duplicate, incoming record generation should not be the same as matched record generation and the execution of job should be started after of creating the previous record generation";
+  public static final String EXTERNAL_IDS_MISSING_ERROR = "MARC_BIB records must contain external instance and hr id's and 001 field into parsed record";
   public static final char SUBFIELD_S = 's';
   public static final char INDICATOR = 'f';
+  private static final String TAG_001 = "001";
 
   private final RecordDao recordDao;
 
@@ -128,6 +129,10 @@ public Future<Record> saveRecord(Record record, Map<String, String> okapiHeaders
     LOG.debug("saveRecord:: Saving record with id: {} for tenant: {}", record.getId(), tenantId);
     ensureRecordHasId(record);
     ensureRecordHasSuppressDiscovery(record);
+    if (!isRecordContainsRequiredField(record)) {
+      LOG.error("saveRecord:: Record '{}' has invalid externalIdHolder or missing 001 field into parsed record", record.getId());
+      return Future.failedFuture(new BadRequestException(EXTERNAL_IDS_MISSING_ERROR));
+    }
     return recordDao.executeInTransaction(txQE -> SnapshotDaoUtil.findById(txQE, record.getSnapshotId())
         .map(optionalSnapshot -> optionalSnapshot
           .orElseThrow(() -> new NotFoundException(format(SNAPSHOT_NOT_FOUND_TEMPLATE, record.getSnapshotId()))))
@@ -523,4 +528,17 @@ private static void update005field(Record targetRecord) {
     }
   }
 
+  private boolean isRecordContainsRequiredField(Record record) {
+    if (record.getRecordType() == Record.RecordType.MARC_BIB) {
+      var idsHolder = record.getExternalIdsHolder();
+      if (Objects.isNull(idsHolder) || StringUtils.isEmpty(getValueFromControlledField(record, TAG_001))) {
+        return false;
+      }
+      if (StringUtils.isEmpty(idsHolder.getInstanceId()) || StringUtils.isEmpty(idsHolder.getInstanceHrid())) {
+        return false;
+      }
+    }
+    return true;
+  }
+
 }