HPCC-32699 Encode all ALA response data

- Encodes all response log data from ALA Signed-off-by: Rodrigo Pastrana <rodrigo.pastrana@lexisnexisrisk.com>
hpcc-systems · Sep 20, 2024 · ba5a269 · ba5a269
1 parent d23810d
commit ba5a269
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/system/logaccess/Azure/LogAnalytics/CurlClient/AzureLogAnalyticsCurlClient.cpp b/system/logaccess/Azure/LogAnalytics/CurlClient/AzureLogAnalyticsCurlClient.cpp
@@ -947,7 +947,10 @@ unsigned AzureLogAnalyticsCurlClient::processHitsJsonResp(IPropertyTreeIterator
                 ForEach(*fields)
                 {
                     const char * fieldName = header.item(idx++);
-                    returnbuf.appendf("<%s>%s</%s>", fieldName, fields->query().queryProp("."), fieldName);
+                    StringBuffer encodedValue;
+                    encodeXML(fields->query().queryProp("."), encodedValue);
+
+                    returnbuf.appendf("<%s>%s</%s>", fieldName, encodedValue.str(), fieldName);
                 }
                 returnbuf.append("</line>");
                 recsProcessed++;
@@ -976,7 +979,10 @@ unsigned AzureLogAnalyticsCurlClient::processHitsJsonResp(IPropertyTreeIterator
                     if (!firstField)
                         hitchildjson.append(", ");
 
-                    hitchildjson.appendf("\"%s\":\"%s\"", header.item(idx++), fields->query().queryProp("."));
+                    StringBuffer encodedValue;
+                    encodeJSON(encodedValue, fields->query().queryProp("."));
+
+                    hitchildjson.appendf("\"%s\":\"%s\"", header.item(idx++), encodedValue.str());
 
                     firstField = false;
                 }
@@ -1020,7 +1026,7 @@ unsigned AzureLogAnalyticsCurlClient::processHitsJsonResp(IPropertyTreeIterator
                     else
                         first = false;
 
-                    fieldElementsItr->query().getProp(nullptr, returnbuf); // commas in data should be escaped
+                    encodeCSVColumn(returnbuf, fieldElementsItr->query().queryProp("."));
                 }
                 returnbuf.newline();
                 recsProcessed++;