From 6e11ff1f4c796ee80f88a4edd3f726359f0d1fae Mon Sep 17 00:00:00 2001
From: Matthias Ronge <matthias.ronge@mik-center.de>
Date: Thu, 1 Feb 2024 15:17:28 +0100
Subject: [PATCH] Enable debug logging from KitodoRestClient

---
 .../data/elasticsearch/KitodoRestClient.java  | 22 ++++++++++++++-----
 1 file changed, 16 insertions(+), 6 deletions(-)

diff --git a/Kitodo-DataManagement/src/main/java/org/kitodo/data/elasticsearch/KitodoRestClient.java b/Kitodo-DataManagement/src/main/java/org/kitodo/data/elasticsearch/KitodoRestClient.java
index c2825fdf112..e0c82af9f20 100644
--- a/Kitodo-DataManagement/src/main/java/org/kitodo/data/elasticsearch/KitodoRestClient.java
+++ b/Kitodo-DataManagement/src/main/java/org/kitodo/data/elasticsearch/KitodoRestClient.java
@@ -134,7 +134,7 @@ private void initiateClientWithAuth(String host, Integer port, String protocol,
     public String getServerInformation() throws IOException {
         Request request = new Request(HttpMethod.GET, "/");
         request.addParameter("pretty", "true");
-        Response response = client.performRequest(request);
+        Response response = performRequest(request);
         return EntityUtils.toString(response.getEntity());
     }
 
@@ -158,7 +158,7 @@ public String getServerInfo() throws IOException {
     public String getMapping(String mappingType) throws IOException {
         Request request = new Request(HttpMethod.GET, "/" + indexBase + "_" + mappingType + "/_mapping");
         request.addParameter("pretty", "true");
-        Response response = client.performRequest(request);
+        Response response = performRequest(request);
         return EntityUtils.toString(response.getEntity());
     }
 
@@ -188,7 +188,7 @@ public boolean createIndex(String query, String mappingType) throws IOException,
         HttpEntity entity = new NStringEntity(query, ContentType.APPLICATION_JSON);
         Request request = new Request(HttpMethod.PUT, "/" + indexBase + "_" + mappingType);
         request.setEntity(entity);
-        Response indexResponse = client.performRequest(request);
+        Response indexResponse = performRequest(request);
         int statusCode = processStatusCode(indexResponse.getStatusLine());
         return statusCode == 200 || statusCode == 201;
     }
@@ -200,7 +200,7 @@ public boolean createIndex(String query, String mappingType) throws IOException,
      */
     public boolean typeIndexesExist() throws IOException, CustomResponseException {
         for (String mappingType : MAPPING_TYPES) {
-            Response indexResponse = client.performRequest(new Request(HttpMethod.GET, "/" + indexBase + "_" + mappingType));
+            Response indexResponse = performRequest(new Request(HttpMethod.GET, "/" + indexBase + "_" + mappingType));
             int statusCode = processStatusCode(indexResponse.getStatusLine());
             if (statusCode != 200 && statusCode != 201) {
                 return false;
@@ -214,7 +214,7 @@ public boolean typeIndexesExist() throws IOException, CustomResponseException {
      * @param mappingType mapping type
      */
     public void deleteIndex(String mappingType) throws IOException {
-        client.performRequest(new Request(HttpMethod.DELETE, "/" + indexBase + "_" + mappingType));
+        performRequest(new Request(HttpMethod.DELETE, "/" + indexBase + "_" + mappingType));
     }
 
     /**
@@ -222,7 +222,7 @@ public void deleteIndex(String mappingType) throws IOException {
      */
     public void deleteAllIndexes() throws IOException {
         for (String mappingType : MAPPING_TYPES) {
-            client.performRequest(new Request(HttpMethod.DELETE, "/" + indexBase + "_" + mappingType));
+            performRequest(new Request(HttpMethod.DELETE, "/" + indexBase + "_" + mappingType));
         }
     }
 
@@ -287,4 +287,14 @@ private void processStatusCode(int statusCode, Object restStatus) throws CustomR
             throw new CustomResponseException("Server error: " + restStatus.toString());
         }
     }
+    
+    private Response performRequest(Request request) throws IOException {
+        Response response = client.performRequest(request);
+        if (logger.isDebugEnabled()) {
+            logger.debug(logger.isTraceEnabled()
+                    ? response.toString() + System.lineSeparator() + EntityUtils.toString(response.getEntity())
+                    : response.toString());
+        }
+        return response;
+    }
 }