Add test to demonstrate indexing and bulk indexing of Json.Net JObject instances

Reference to #1609

Author: russcam

Diff for: src/Elasticsearch.Net/Transport/PostData.cs

@@ -96,7 +96,7 @@ public void Write(Stream writableStream, IConnectionConfigurationValues settings
 					ms = new MemoryStream(WrittenBytes);
 					break;
 				case PostType.LiteralString: 
-					ms = new MemoryStream(_literalString?.Utf8Bytes());
+					ms = !string.IsNullOrEmpty(_literalString) ? new MemoryStream(_literalString.Utf8Bytes()) : null;
 					break;
 				case PostType.EnumerableOfString: 
 					ms = _enumurabeOfStrings.HasAny() ? new MemoryStream((string.Join("\n", _enumurabeOfStrings) + "\n").Utf8Bytes()) : null;

Diff for: src/Tests/Document/Single/Index/IndexApiTests.cs

@@ -4,6 +4,7 @@
 using Elasticsearch.Net;
 using FluentAssertions;
 using Nest;
+using Newtonsoft.Json.Linq;
 using Tests.Framework;
 using Tests.Framework.Integration;
 using Tests.Framework.MockData;
@@ -69,16 +70,19 @@ protected override LazyResponses ClientUsage() => Calls(
 	[Collection(IntegrationContext.Indexing)]
 	public class IndexIntegrationTests : SimpleIntegration
 	{
-		public IndexIntegrationTests(IndexingCluster cluster) : base(cluster) { }
+		public IndexIntegrationTests(IndexingCluster cluster) : base(cluster)
+		{
+		}
 
-		[I] public void OpTypeCreate()
+		[I]
+		public void OpTypeCreate()
 		{
 			var indexName = this.RandomString();
 			var project = Project.Generator.Generate(1).First();
 			var indexResult = this.Client.Index(project, f => f
 				.Index(indexName)
 				.OpType(OpType.Create)
-			);
+				);
 			indexResult.IsValid.Should().BeTrue();
 			indexResult.ApiCall.HttpStatusCode.Should().Be(201);
 			indexResult.Created.Should().BeTrue();
@@ -89,18 +93,19 @@ [I] public void OpTypeCreate()
 			indexResult = this.Client.Index(project, f => f
 				.Index(indexName)
 				.OpType(OpType.Create)
-			);
+				);
 
 			indexResult.IsValid.Should().BeFalse();
 			indexResult.Created.Should().BeFalse();
 			indexResult.ApiCall.HttpStatusCode.Should().Be(409);
 		}
 
-		[I] public void Index()
+		[I]
+		public void Index()
 		{
 			var indexName = this.RandomString();
 			var project = Project.Generator.Generate(1).First();
-			var indexResult = this.Client.Index(project, f => f .Index(indexName));
+			var indexResult = this.Client.Index(project, f => f.Index(indexName));
 			indexResult.IsValid.Should().BeTrue();
 			indexResult.ApiCall.HttpStatusCode.Should().Be(201);
 			indexResult.Created.Should().BeTrue();
@@ -109,13 +114,68 @@ [I] public void Index()
 			indexResult.Id.Should().Be(project.Name);
 			indexResult.Version.Should().Be(1);
 
-			indexResult = this.Client.Index(project, f => f .Index(indexName));
+			indexResult = this.Client.Index(project, f => f.Index(indexName));
 
 			indexResult.IsValid.Should().BeTrue();
 			indexResult.Created.Should().BeFalse();
 			indexResult.ApiCall.HttpStatusCode.Should().Be(200);
 			indexResult.Version.Should().Be(2);
 		}
 
+		[Collection(IntegrationContext.Indexing)]
+		public class IndexJObjectIntegrationTests : SimpleIntegration
+		{
+			public IndexJObjectIntegrationTests(IndexingCluster cluster) : base(cluster){}
+
+			[I]
+			public void Index()
+			{
+				var indexName = this.RandomString();
+
+				var jObjects = Enumerable.Range(1, 1000)
+					.Select(i =>
+						new JObject
+						{
+							{ "id", i },
+							{"name", $"name {i}"},
+							{"value", Math.Pow(i,2) },
+							{"date", new DateTime(2016, 1, 1)},
+							{"child", new JObject
+								{
+									{ "child_name", $"child_name {i}{i}" },
+									{ "child_value", 3 }
+								}
+							}
+						});
+
+				var jObject = jObjects.First();
+
+				var indexResult = this.Client.Index(jObject, f => f
+					.Index(indexName)
+					.Type("example")
+					.Id(jObject["id"].Value<int>())
+				);
+
+				indexResult.IsValid.Should().BeTrue();
+				indexResult.ApiCall.HttpStatusCode.Should().Be(201);
+				indexResult.Created.Should().BeTrue();
+				indexResult.Index.Should().Be(indexName);
+
+				var bulkResponse = this.Client.Bulk(b => b
+					.IndexMany(jObjects.Skip(1), (bi, d) => bi
+						.Document(d)
+						.Id(d["id"].Value<int>())
+						.Index(indexName)
+						.Type("example")
+					)
+				);
+
+				foreach (var response in bulkResponse.Items)
+				{
+					response.IsValid.Should().BeTrue();
+					response.Status.Should().Be(201);
+				}
+			}
+		}
 	}
 }