From 0e278d6f3511d0c39f693c64705cdc864e198f18 Mon Sep 17 00:00:00 2001
From: NThakur4 <nthakur4@slb.com>
Date: Mon, 27 Sep 2021 15:30:18 -0500
Subject: [PATCH] refresh auth token on long running reindex request
---
.../indexer/azure/util/IndexerQueueTaskBuilderAzure.java | 7 +++++++
1 file changed, 7 insertions(+)
diff --git a/provider/indexer-azure/src/main/java/org/opengroup/osdu/indexer/azure/util/IndexerQueueTaskBuilderAzure.java b/provider/indexer-azure/src/main/java/org/opengroup/osdu/indexer/azure/util/IndexerQueueTaskBuilderAzure.java
index 914fba0a1..f36df01e3 100644
--- a/provider/indexer-azure/src/main/java/org/opengroup/osdu/indexer/azure/util/IndexerQueueTaskBuilderAzure.java
+++ b/provider/indexer-azure/src/main/java/org/opengroup/osdu/indexer/azure/util/IndexerQueueTaskBuilderAzure.java
@@ -46,6 +46,8 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
+import static org.opengroup.osdu.core.common.model.http.DpsHeaders.AUTHORIZATION;
+
@Log
@Component
@RequestScope
@@ -68,6 +70,9 @@ public class IndexerQueueTaskBuilderAzure extends IndexerQueueTaskBuilder {
@Inject
private StorageService storageService;
+ @Inject
+ private RequestInfoImpl requestInfo;
+
@Override
public void createWorkerTask(String payload, DpsHeaders headers) {
createTask(payload, headers);
@@ -103,6 +108,8 @@ public class IndexerQueueTaskBuilderAzure extends IndexerQueueTaskBuilder {
try {
do {
+ headers.put(AUTHORIZATION, this.requestInfo.checkOrGetAuthorizationHeader());
+
if (recordQueryResponse != null) {
recordReindexRequest = RecordReindexRequest.builder().cursor(recordQueryResponse.getCursor()).kind(recordKind).build();
}
--
GitLab