add bulk invalid version api tests and create.json

Author: Mpdreamz

src/CodeGeneration/ApiGenerator/RestSpecification/Core/create.json

@@ -0,0 +1,75 @@
+{
+  "create": {
+    "documentation": "http://www.elastic.co/guide/en/elasticsearch/reference/master/docs-index_.html",
+    "methods": ["PUT","POST"],
+    "url": {
+      "path": "/{index}/{type}/{id}/_create",
+      "paths": ["/{index}/{type}/{id}/_create"],
+      "parts": {
+        "id": {
+          "type" : "string",
+          "required" : true,
+          "description" : "Document ID"
+        },
+        "index": {
+          "type" : "string",
+          "required" : true,
+          "description" : "The name of the index"
+        },
+        "type": {
+          "type" : "string",
+          "required" : true,
+          "description" : "The type of the document"
+        }
+      },
+      "params": {
+        "wait_for_active_shards": {
+          "type" : "string",
+          "description" : "Sets the number of shard copies that must be active before proceeding with the index operation. Defaults to 1, meaning the primary shard only. Set to `all` for all shard copies, otherwise set to any non-negative value less than or equal to the total number of copies for the shard (number of replicas + 1)"
+        },
+        "parent": {
+          "type" : "string",
+          "description" : "ID of the parent document"
+        },
+        "refresh": {
+          "type" : "enum",
+          "options": ["true", "false", "wait_for"],
+          "description" : "If `true` then refresh the affected shards to make this operation visible to search, if `wait_for` then wait for a refresh to make this operation visible to search, if `false` (the default) then do nothing with refreshes."
+        },
+        "routing": {
+          "type" : "string",
+          "description" : "Specific routing value"
+        },
+        "timeout": {
+          "type" : "time",
+          "description" : "Explicit operation timeout"
+        },
+        "timestamp": {
+          "type" : "time",
+          "description" : "Explicit timestamp for the document"
+        },
+        "ttl": {
+          "type" : "time",
+          "description" : "Expiration time for the document"
+        },
+        "version" : {
+          "type" : "number",
+          "description" : "Explicit version number for concurrency control"
+        },
+        "version_type": {
+          "type" : "enum",
+          "options" : ["internal", "external", "external_gte", "force"],
+          "description" : "Specific version type"
+        },
+        "pipeline" : {
+          "type" : "string",
+          "description" : "The pipeline id to preprocess incoming documents with"
+        }
+      }
+    },
+    "body": {
+      "description" : "The document",
+      "required" : true
+    }
+  }
+}

src/Tests/Document/Multiple/Bulk/BulkInvalidVersionApiTests.cs

@@ -0,0 +1,63 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using Elasticsearch.Net;
+using FluentAssertions;
+using Nest;
+using Tests.Framework;
+using Tests.Framework.Integration;
+using Tests.Framework.MockData;
+using Xunit;
+
+namespace Tests.Document.Multiple.Bulk
+{
+	public class BulkInvalidVersionApiTests : ApiIntegrationTestBase<WritableCluster, IBulkResponse, IBulkRequest, BulkDescriptor, BulkRequest>
+	{
+		public BulkInvalidVersionApiTests(WritableCluster cluster, EndpointUsage usage) : base(cluster, usage) { }
+		protected override LazyResponses ClientUsage() => Calls(
+			fluent: (client, f) => client.Bulk(f),
+			fluentAsync: (client, f) => client.BulkAsync(f),
+			request: (client, r) => client.Bulk(r),
+			requestAsync: (client, r) => client.BulkAsync(r)
+		);
+
+		protected override bool ExpectIsValid => false;
+		protected override int ExpectStatusCode => 400;
+		protected override HttpMethod HttpMethod => HttpMethod.POST;
+		protected override string UrlPath => $"/{CallIsolatedValue}/_bulk";
+
+		protected override bool SupportsDeserialization => false;
+
+		protected override object ExpectJson { get; } = new object[]
+		{
+			new Dictionary<string, object>{ { "index", new { _type="project", _id = Project.Instance.Name } } },
+			Project.InstanceAnonymous,
+			new Dictionary<string, object>{ { "index", new { _type="project", _id = Project.Instance.Name, _version = 0 } } },
+			Project.InstanceAnonymous,
+		};
+
+		protected override void ExpectResponse(IBulkResponse response)
+		{
+			response.IsValid.Should().BeFalse();
+			response.ServerError.Should().NotBeNull();
+			response.ServerError.Status.Should().Be(400);
+			response.ServerError.Error.Type.Should().Be("action_request_validation_exception");
+			response.ServerError.Error.Reason.Should().EndWith("illegal version value [0] for version type [INTERNAL];");
+		}
+
+		protected override Func<BulkDescriptor, IBulkRequest> Fluent => d => d
+			.Index(CallIsolatedValue)
+			.Index<Project>(i => i.Document(Project.Instance))
+			.Index<Project>(i => i.Version(0).Document(Project.Instance));
+
+
+		protected override BulkRequest Initializer => new BulkRequest(CallIsolatedValue)
+		{
+			Operations = new List<IBulkOperation>
+			{
+				new BulkIndexOperation<Project>(Project.Instance),
+				new BulkIndexOperation<Project>(Project.Instance) { Version = 0 }
+			}
+		};
+	}
+}