Add tasks list status and description

Closes #2133

Author: russcam

src/Nest/Cluster/TaskManagement/TasksList/TasksListResponse.cs

@@ -3,6 +3,7 @@
 using System.Linq.Expressions;
 using Newtonsoft.Json;
 using System.Linq;
+using System.Threading.Tasks;
 
 namespace Nest
 {
@@ -25,7 +26,6 @@ public class TasksListResponse : ResponseBase, ITasksListResponse
 		public IEnumerable<Throwable> NodeFailures { get; internal set; }
 	}
 
-
 	public class TaskExecutingNode
 	{
 		[JsonProperty("name")]
@@ -58,6 +58,12 @@ public class TaskState
 		[JsonProperty("action")]
 		public string Action { get; internal set; }
 
+		[JsonProperty("status")]
+		public TaskStatus Status { get; internal set; }
+
+		[JsonProperty("description")]
+		public string Description { get; internal set; }
+
 		[JsonProperty("start_time_in_millis")]
 		public long StartTimeInMilliseconds { get; internal set; }
 
@@ -66,6 +72,29 @@ public class TaskState
 
 		[JsonProperty("parent_task_id")]
 		public TaskId ParentTaskId { get; internal set; }
+	}
+
+	public class TaskStatus
+	{
+		[JsonProperty("total")]
+		public long Total { get; internal set; }
+
+		[JsonProperty("updated")]
+		public long Updated { get; internal set; }
+
+		[JsonProperty("created")]
+		public long Created { get; internal set; }
+
+		[JsonProperty("deleted")]
+		public long Deleted { get; internal set; }
+
+		[JsonProperty("batches")]
+		public long Batches { get; internal set; }
+
+		[JsonProperty("version_conflicts")]
+		public long VersionConflicts { get; internal set; }
 
+		[JsonProperty("noops")]
+		public long Noops { get; internal set; }
 	}
 }

src/Tests/Cluster/TaskManagement/TasksList/TasksListApiTests.cs

@@ -5,6 +5,7 @@
 using Nest;
 using Tests.Framework;
 using Tests.Framework.Integration;
+using Tests.Framework.MockData;
 using Xunit;
 
 namespace Tests.Cluster.TaskManagement.TasksList
@@ -56,8 +57,86 @@ protected override void ExpectResponse(ITasksListResponse response)
 			var parentTask = taskExecutingNode.Tasks[task.ParentTaskId];
 			parentTask.Should().NotBeNull();
 			parentTask.ParentTaskId.Should().BeNull();
+		}
+	}
+
+	[SkipVersion("<2.3.0", "")]
+	public class TasksListDetailedApiTests : ApiIntegrationTestBase<IntrusiveOperationCluster, ITasksListResponse, ITasksListRequest, TasksListDescriptor, TasksListRequest>
+	{
+		private static TaskId _taskId = new TaskId("fakeid:1");
+
+		public TasksListDetailedApiTests(IntrusiveOperationCluster cluster, EndpointUsage usage) : base(cluster, usage) { }
+		protected override LazyResponses ClientUsage() => Calls(
+			fluent: (client, f) => client.TasksList(f),
+			fluentAsync: (client, f) => client.TasksListAsync(f),
+			request: (client, r) => client.TasksList(r),
+			requestAsync: (client, r) => client.TasksListAsync(r)
+		);
+
+		protected override void IntegrationSetup(IElasticClient client, CallUniqueValues values)
+		{
+			var seeder = new Seeder(this.Cluster.Node);
+			seeder.SeedNode();
+
+			// get a suitable load of projects in order to get a decent task status out
+			var bulkResponse = client.IndexMany(Project.Generator.Generate(20000));
+			if (!bulkResponse.IsValid)
+				throw new Exception("failure in setting up integration");
+
+			var response = client.ReindexOnServer(r => r
+				.Source(s => s
+					.Index(Infer.Index<Project>())
+					.Type(typeof(Project))
+				)
+				.Destination(d => d
+					.Index("tasks-list-projects")
+					.OpType(OpType.Create)
+				)
+				.Conflicts(Conflicts.Proceed)
+				.WaitForCompletion(false)
+				.Refresh()
+			);
+
+			_taskId = response.Task;
+		}
+
+		protected override bool ExpectIsValid => true;
+		protected override int ExpectStatusCode => 200;
+		protected override HttpMethod HttpMethod => HttpMethod.GET;
+		protected override string UrlPath => $"/_tasks/{Uri.EscapeDataString(_taskId.ToString())}?detailed=true";
 
+		protected override Func<TasksListDescriptor, ITasksListRequest> Fluent => s => s
+			.TaskId(_taskId)
+			.Detailed();
+
+		protected override TasksListRequest Initializer => new TasksListRequest(_taskId)
+		{
+			Detailed = true
+		};
+
+		protected override void ExpectResponse(ITasksListResponse response)
+		{
+			response.Nodes.Should().NotBeEmpty();
+			var taskExecutingNode = response.Nodes.First().Value;
+			taskExecutingNode.Host.Should().NotBeNullOrWhiteSpace();
+			taskExecutingNode.Ip.Should().NotBeNullOrWhiteSpace();
+			taskExecutingNode.Name.Should().NotBeNullOrWhiteSpace();
+			taskExecutingNode.TransportAddress.Should().NotBeNullOrWhiteSpace();
+			taskExecutingNode.Tasks.Should().NotBeEmpty();
+			taskExecutingNode.Tasks.Count().Should().Be(1);
+
+			var task = taskExecutingNode.Tasks[_taskId];
+			task.Action.Should().NotBeNullOrWhiteSpace();
+			task.Type.Should().NotBeNullOrWhiteSpace();
+			task.Id.Should().BePositive();
+			task.Node.Should().NotBeNullOrWhiteSpace();
+			task.RunningTimeInNanoSeconds.Should().BeGreaterThan(0);
+			task.StartTimeInMilliseconds.Should().BeGreaterThan(0);
 
+			var status = task.Status;
+			status.Should().NotBeNull();
+			status.Total.Should().BeGreaterOrEqualTo(0);
+			status.Batches.Should().BeGreaterOrEqualTo(0);
 		}
 	}
 }