Update addons.xml versions and fix RestClient CompletableResponseListener

Author: acetousk

framework/src/main/groovy/org/moqui/impl/context/ElasticFacadeImpl.groovy

@@ -394,6 +394,7 @@ class ElasticFacadeImpl implements ElasticFacade {
 
             RestClient.RestResponse response = bulkResponse(index, actionSourceList, refresh)
             checkResponse(response, "Bulk operations", index)
+            checkBulkResponseErrors(response, "Bulk index", index)
         }
 
         @Override
@@ -742,6 +743,33 @@ class ElasticFacadeImpl implements ElasticFacade {
         throw new BaseException(msg)
     }
 
+    static void checkBulkResponseErrors(RestClient.RestResponse response, String operation, String index) {
+        if (response == null) return
+        try {
+            Map responseMap = (Map) jsonToObject(response.text())
+            if (responseMap.errors == true) {
+                List<Map> items = (List<Map>) responseMap.items
+                List<String> errorMessages = []
+                for (Map item in items) {
+                    Map itemMap = (Map) item.values().first()
+                    if (itemMap.error) {
+                        String errorMsg = "Doc ${itemMap._id ?: 'unknown'}: ${itemMap.error}"
+                        errorMessages.add(errorMsg)
+                        if (errorMessages.size() >= 10) break
+                    }
+                }
+                String msg = "${operation}${index ? ' on index ' + index : ''} had ${items?.size() ?: 0} items with errors"
+                if (errorMessages) msg += ":\n  " + errorMessages.join("\n  ")
+                logger.error("ElasticSearch ${msg}")
+                throw new BaseException(msg)
+            }
+        } catch (BaseException be) {
+            throw be
+        } catch (Throwable t) {
+            logger.error("Error checking bulk response for errors: ${t.toString()}")
+        }
+    }
+
     static String objectToJson(Object jsonObject) {
         if (jsonObject instanceof String) return (String) jsonObject
         return jacksonMapper.writeValueAsString(jsonObject)