api_key in header from indexer-queue validation logic added

provider/indexer-ibm/src/main/java/org/opengroup/osdu/indexer/ibm/util/RequestInfoImpl.java

@@ -53,10 +53,14 @@ public class RequestInfoImpl implements IRequestInfo {
 
     @Inject
     private TenantInfo tenantInfo;
-
+    
     @Value("${DEPLOYMENT_ENVIRONMENT}")
     private String DEPLOYMENT_ENVIRONMENT;
 
+    private static final String INDEXER_QUEUE_KEY="x-api-key";
+    
+    @Value("${INDEXER_QUEUE_API_KEY}")
+    private String tokenFromProperty;
 
     @Override
     public DpsHeaders getHeaders() {
@@ -65,9 +69,17 @@ public class RequestInfoImpl implements IRequestInfo {
             // throw to prevent null reference exception below
             throw new AppException(HttpStatus.SC_INTERNAL_SERVER_ERROR, "Invalid Headers", "Headers Map DpsHeaders is null");
         }
-        DpsHeaders headers = this.getCoreServiceHeaders(headersMap.getHeaders());
-        return headers;
-    }
+		DpsHeaders headers = this.getCoreServiceHeaders(headersMap.getHeaders());
+
+		if (headers.getHeaders().containsKey(INDEXER_QUEUE_KEY)) {
+			String apiToken = headers.getHeaders().get(INDEXER_QUEUE_KEY);
+			if (!apiToken.equalsIgnoreCase(tokenFromProperty)) {
+				logger.error("Token in header is mismatched");
+				throw new AppException(HttpStatus.SC_UNAUTHORIZED, "Token in header mismatched.", "Token in header mismatched.");
+			}
+		}
+		return headers;
+	}
 
     @Override
     public String getPartitionId() {
@@ -96,6 +108,7 @@ public class RequestInfoImpl implements IRequestInfo {
     @Override
     public boolean isTaskQueueRequest() {
         //if (!this.dpsHeaders.getHeaders().containsKey(INDEXER_QUEUE_KEY)) return false;
+    	
 
 //        String queueId = this.headersInfo.getHeadersMap().get(AppEngineHeaders.TASK_QUEUE_NAME);
 //        return queueId.endsWith(Constants.INDEXER_QUEUE_IDENTIFIER);

provider/indexer-ibm/src/main/resources/application.properties

@@ -67,4 +67,5 @@ ELASTIC_USER_PASSWORD=REPLACE_ME:REPLACE_ME
 
 #requeue logic
 INDEXER_QUEUE_HOST=""
-ibm.env.prefix=oc-local
\ No newline at end of file
+ibm.env.prefix=oc-local
+INDEXER_QUEUE_API_KEY=abcds
\ No newline at end of file