Build DebugInformation uri and method from Request or ApiCallDetails (#4077)

* Build DebugInformation uri and method from Request or ApiCallDetails

This commit changes how DebugInformation is built in ElasticsearchClientException to use either Request
or ApiCallDetails to retrieve the Uri and method of the request. There are some usages of ElasticsearchClientException
where the Request property is not set, such as Throw() method in BulkAllObservable.

Fixes #3687

(cherry picked from commit 4787e27)

Author: russcam

src/Elasticsearch.Net/Exceptions/ElasticsearchClientException.cs

@@ -2,6 +2,7 @@
 using System.Collections.Generic;
 using System.Linq;
 using System.Text;
+using static Elasticsearch.Net.ResponseStatics;
 
 namespace Elasticsearch.Net
 {
@@ -30,26 +31,46 @@ public string DebugInformation
 				var failureReason = FailureReason.GetStringValue();
 				if (FailureReason == PipelineFailure.Unexpected && AuditTrail.HasAny())
 					failureReason = "Unrecoverable/Unexpected " + AuditTrail.Last().Event.GetStringValue();
-				var path = Request.Uri != null
-					? Request.Uri.ToString()
-					: Request.PathAndQuery + " on an empty node, likely a node predicate on ConnectionSettings not matching ANY nodes";
 
-				sb.AppendLine($"# FailureReason: {failureReason} while attempting {Request.Method.GetStringValue()} on {path}");
+				sb.Append("# FailureReason: ")
+					.Append(failureReason)
+					.Append(" while attempting ");
+
+				if (Request != null)
+				{
+					sb.Append(Request.Method.GetStringValue()).Append(" on ");
+					if (Request.Uri != null)
+						sb.AppendLine(Request.Uri.ToString());
+					else
+						sb.Append(Request.PathAndQuery)
+							.AppendLine(" on an empty node, likely a node predicate on ConnectionSettings not matching ANY nodes");
+				}
+				else if (Response != null)
+				{
+					sb.Append(Response.HttpMethod.GetStringValue())
+						.Append(" on ")
+						.AppendLine(Response.Uri.ToString());
+				}
+				else
+					sb.AppendLine("a request");
+
 				if (Response != null)
-					ResponseStatics.DebugInformationBuilder(Response, sb);
+					DebugInformationBuilder(Response, sb);
 				else
 				{
-					ResponseStatics.DebugAuditTrail(AuditTrail, sb);
-					ResponseStatics.DebugAuditTrailExceptions(AuditTrail, sb);
+					DebugAuditTrail(AuditTrail, sb);
+					DebugAuditTrailExceptions(AuditTrail, sb);
 				}
+
 				if (InnerException != null)
 				{
-					sb.AppendLine($"# Inner Exception: {InnerException.Message}");
-					sb.AppendLine(InnerException.ToString());
+					sb.Append("# Inner Exception: ")
+						.AppendLine(InnerException.Message)
+						.AppendLine(InnerException.ToString());
 				}
-				sb.AppendLine($"# Exception:");
-				sb.AppendLine(ToString());
 
+				sb.AppendLine("# Exception:")
+					.AppendLine(ToString());
 				return sb.ToString();
 			}
 		}

src/Elasticsearch.Net/Responses/ResponseStatics.cs

@@ -37,6 +37,8 @@ public static string DebugInformationBuilder(IApiCallDetails r, StringBuilder sb
 
 		public static void DebugAuditTrailExceptions(List<Audit> auditTrail, StringBuilder sb)
 		{
+			if (auditTrail == null) return;
+
 			var auditExceptions = auditTrail.Select((audit, i) => new { audit, i }).Where(a => a.audit.Exception != null);
 			foreach (var a in auditExceptions)
 				sb.AppendLine($"# Audit exception in step {a.i + 1} {a.audit.Event.GetStringValue()}:\r\n{a.audit.Exception}");

src/Elasticsearch.Net/Transport/Pipeline/RequestPipeline.cs

@@ -212,7 +212,7 @@ public ElasticsearchClientException CreateClientException<TResponse>(
 				: $"Status code {statusCode} from: {callDetails.HttpMethod} {callDetails.Uri.PathAndQuery}";
 
 
-			var exceptionMessage = innerException?.Message ?? $"Request failed to execute";
+			var exceptionMessage = innerException?.Message ?? "Request failed to execute";
 
 			var pipelineFailure = data.OnFailurePipelineFailure;
 			if (pipelineExceptions.HasAny())

src/Nest/Document/Multiple/BulkAll/BulkAllObservable.cs

@@ -176,20 +176,20 @@ private void HandleDroppedDocuments(List<Tuple<IBulkResponseItem, T>> droppedDoc
 
 			foreach (var dropped in droppedDocuments) _droppedDocumentCallBack(dropped.Item1, dropped.Item2);
 			if (!_partitionedBulkRequest.ContinueAfterDroppedDocuments)
-				throw ThrowOnBadBulk(response, $"BulkAll halted after receiving failures that can not be retried from _bulk");
+				throw ThrowOnBadBulk(response, $"{nameof(BulkAll)} halted after receiving failures that can not be retried from _bulk");
 		}
 
 		private async Task<IBulkAllResponse> HandleBulkRequest(IList<T> buffer, long page, int backOffRetries, IBulkResponse response)
 		{
 			var clientException = response.ApiCall.OriginalException as ElasticsearchClientException;
-			var failureReason = clientException?.FailureReason;
+			var failureReason = clientException?.FailureReason; 
 			var reason = failureReason?.GetStringValue() ?? nameof(PipelineFailure.BadRequest);
 			switch (failureReason)
 			{
 				case PipelineFailure.MaxRetriesReached:
 					//TODO move this to its own PipelineFailure classification in 7.0
 					if (response.ApiCall.AuditTrail.Last().Event == AuditEvent.FailedOverAllNodes)
-						throw ThrowOnBadBulk(response, $"BulkAll halted after attempted bulk failed over all the active nodes");
+						throw ThrowOnBadBulk(response, $"{nameof(BulkAll)} halted after attempted bulk failed over all the active nodes");
 
 					ThrowOnExhaustedRetries();
 					return await RetryDocuments(page, ++backOffRetries, buffer).ConfigureAwait(false);
@@ -198,7 +198,7 @@ private async Task<IBulkAllResponse> HandleBulkRequest(IList<T> buffer, long pag
 				case PipelineFailure.NoNodesAttempted:
 				case PipelineFailure.SniffFailure:
 				case PipelineFailure.Unexpected:
-					throw ThrowOnBadBulk(response, $"BulkAll halted after {nameof(PipelineFailure)}.{reason} from _bulk");
+					throw ThrowOnBadBulk(response, $"{nameof(BulkAll)} halted after {nameof(PipelineFailure)}.{reason} from _bulk");
 				default:
 					ThrowOnExhaustedRetries();
 					return await RetryDocuments(page, ++backOffRetries, buffer).ConfigureAwait(false);
@@ -209,7 +209,7 @@ void ThrowOnExhaustedRetries()
 				if (_partitionedBulkRequest.ContinueAfterDroppedDocuments || backOffRetries < _backOffRetries) return;
 
 				throw ThrowOnBadBulk(response,
-					$"BulkAll halted after {nameof(PipelineFailure)}.{reason} from _bulk and exhausting retries ({backOffRetries})"
+					$"{nameof(BulkAll)} halted after {nameof(PipelineFailure)}.{reason} from _bulk and exhausting retries ({backOffRetries})"
 				);
 			}
 		}