From 45b07260337d3d619fb9acf965a953186007d671 Mon Sep 17 00:00:00 2001
From: MZhu9 <ujr7dj3ljx3fpstxflyytui5kziqgnbscv3po6mrm3ikbn52frqq>
Date: Sun, 11 Jun 2023 23:26:38 -0500
Subject: [PATCH] 1. add new audit event for reindex records API 2. switch from
storage query/records:batch API to query/records API
---
.../opengroup/osdu/indexer/service/StorageServiceImpl.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/StorageServiceImpl.java b/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/StorageServiceImpl.java
index cce0297f2..cfcf8ce96 100644
--- a/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/StorageServiceImpl.java
+++ b/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/StorageServiceImpl.java
@@ -146,7 +146,10 @@ public class StorageServiceImpl implements StorageService {
throw new AppException(HttpStatus.SC_INTERNAL_SERVER_ERROR, "Internal Error", response.getBody());
}
try {
- return this.objectMapper.readValue(response.getBody(), Records.class);
+ Records records = this.objectMapper.readValue(response.getBody(), Records.class);
+ ids.removeAll(records.getRecords().stream().map(Records.Entity::getId).collect(Collectors.toList()));
+ records.setNotFound(ids);
+ return records;
} catch (JsonProcessingException e) {
throw new AppException(RequestStatus.INVALID_RECORD, "Invalid request", "Successful Storage service response with wrong json", e);
}
--
GitLab