From 6412c08e87edfccb3edf2caba17f15b7edf49c87 Mon Sep 17 00:00:00 2001
From: Bharathwaj G <bharath78910@gmail.com>
Date: Wed, 31 Aug 2022 10:59:28 +0530
Subject: [PATCH] addressing review comment

Signed-off-by: Bharathwaj G <bharath78910@gmail.com>
---
 .../action/search/GetAllPitNodesResponse.java       | 13 ++++++++-----
 .../action/search/TransportDeletePitAction.java     |  6 +++++-
 2 files changed, 13 insertions(+), 6 deletions(-)

diff --git a/server/src/main/java/org/opensearch/action/search/GetAllPitNodesResponse.java b/server/src/main/java/org/opensearch/action/search/GetAllPitNodesResponse.java
index 98feb4a30f764..091447798cf5f 100644
--- a/server/src/main/java/org/opensearch/action/search/GetAllPitNodesResponse.java
+++ b/server/src/main/java/org/opensearch/action/search/GetAllPitNodesResponse.java
@@ -52,6 +52,14 @@ public GetAllPitNodesResponse(
         );
     }
 
+    /**
+     * Copy constructor that explicitly sets the list pit infos
+     */
+    public GetAllPitNodesResponse(List<ListPitInfo> listPitInfos, GetAllPitNodesResponse response) {
+        super(response.getClusterName(), response.getNodes(), response.failures());
+        pitInfos.addAll(listPitInfos);
+    }
+
     @Override
     public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
         builder.startObject();
@@ -77,9 +85,4 @@ public void writeNodesTo(StreamOutput out, List<GetAllPitNodeResponse> nodes) th
     public List<ListPitInfo> getPitInfos() {
         return Collections.unmodifiableList(new ArrayList<>(pitInfos));
     }
-
-    public void clearAndSetPitInfos(List<ListPitInfo> listPitInfos) {
-        pitInfos.clear();
-        pitInfos.addAll(listPitInfos);
-    }
 }
diff --git a/server/src/main/java/org/opensearch/action/search/TransportDeletePitAction.java b/server/src/main/java/org/opensearch/action/search/TransportDeletePitAction.java
index f9e36c479dd54..19abe2361290d 100644
--- a/server/src/main/java/org/opensearch/action/search/TransportDeletePitAction.java
+++ b/server/src/main/java/org/opensearch/action/search/TransportDeletePitAction.java
@@ -57,7 +57,11 @@ public TransportDeletePitAction(
     @Override
     protected void doExecute(Task task, DeletePitRequest request, ActionListener<DeletePitResponse> listener) {
         List<String> pitIds = request.getPitIds();
-        if (pitIds.size() == 1 && "_all".equals(pitIds.get(0))) {
+        // when security plugin intercepts the request, if PITs are not present in the cluster the PIT IDs in request will be empty
+        // and in this case return empty response
+        if (pitIds.isEmpty()) {
+            listener.onResponse(new DeletePitResponse(new ArrayList<>()));
+        } else if (pitIds.size() == 1 && "_all".equals(pitIds.get(0))) {
             deleteAllPits(listener);
         } else {
             deletePits(listener, request);