added failing tests and made them succeed for issue #732

Author: Mpdreamz

src/Nest/DSL/Bulk/BulkUpdateDescriptor.cs

@@ -5,16 +5,17 @@
 
 namespace Nest
 {
-	public interface IBulkUpdateOperation<TDocument, TPartialUpdate> : IBulkOperation
+	public interface IBulkUpdateOperation<TDocument, TPartialDocument> : IBulkOperation
 		where TDocument : class
-		where TPartialUpdate : class
+		where TPartialDocument : class
 	{
-		TDocument Document { get; set; }
+		TDocument InferFrom { get; set; }
+
 		TDocument Upsert { get; set; }
 
-		TPartialUpdate PartialUpdate { get; set; }
+		TPartialDocument PartialDocument { get; set; }
 
-		bool? DocAsUpsert { get; set; }
+		bool? PartialDocumentAsUpsert { get; set; }
 
 		string Lang { get; set; }
 
@@ -23,18 +24,19 @@ public interface IBulkUpdateOperation<TDocument, TPartialUpdate> : IBulkOperatio
 		Dictionary<string, object> Params { get; set; }
 	}
 
-	public class BulkUpdateOperation<TDocument, TPartialUpdate> 
-		: BulkOperationBase, IBulkUpdateOperation<TDocument, TPartialUpdate>
+	public class BulkUpdateOperation<TDocument, TPartialDocument> : BulkOperationBase, IBulkUpdateOperation<TDocument, TPartialDocument>
 		where TDocument : class
-		where TPartialUpdate : class
+		where TPartialDocument : class
 	{
-
-
-		public BulkUpdateOperation() {} 
-		public BulkUpdateOperation(TDocument document, TPartialUpdate update) : this()
+		
+		public BulkUpdateOperation(TDocument inferFrom) 
+		{
+			this.InferFrom = inferFrom;
+		}
+		public BulkUpdateOperation(TDocument inferFrom, TPartialDocument update) 
 		{
-			this.PartialUpdate = update;
-			this.Document = document;
+			this.InferFrom = inferFrom;
+			this.PartialDocument = update;
 		}
 
 
@@ -44,71 +46,76 @@ public BulkUpdateOperation(TDocument document, TPartialUpdate update) : this()
 
 		public override string GetIdForOperation(ElasticInferrer inferrer)
 		{
-			return this.Id ?? inferrer.Id(this.Document);
+			return this.Id ?? inferrer.Id(this.InferFrom);
 		}
 
 		public override object GetBody()
 		{
-			return new BulkUpdateBody<TDocument, TPartialUpdate>
+			return new BulkUpdateBody<TDocument, TPartialDocument>
 			{
-				_PartialUpdate = this.PartialUpdate,
+				_PartialUpdate = this.PartialDocument,
 				_Script = this.Script,
 				_Lang = this.Lang,
 				_Params = this.Params,
 				_Upsert = this.Upsert,
-				_DocAsUpsert = this.DocAsUpsert
+				_DocAsUpsert = this.PartialDocumentAsUpsert
 			};
 		}
 
-		public TDocument Document { get; set; }
+		public TDocument InferFrom { get; set; }
 		public TDocument Upsert { get; set; }
-		public TPartialUpdate PartialUpdate { get; set; }
-		public bool? DocAsUpsert { get; set; }
+		public TPartialDocument PartialDocument { get; set; }
+		public bool? PartialDocumentAsUpsert { get; set; }
 		public string Lang { get; set; }
 		public string Script { get; set; }
 		public Dictionary<string, object> Params { get; set; }
 	}
 
-	public class BulkUpdateDescriptor<TDocument, TPartialUpdate>
-		: BulkOperationDescriptorBase, IBulkUpdateOperation<TDocument, TPartialUpdate>
+	public class BulkUpdateDescriptor<TDocument, TPartialDocument> : BulkOperationDescriptorBase, IBulkUpdateOperation<TDocument, TPartialDocument>
 		where TDocument : class
-		where TPartialUpdate : class
+		where TPartialDocument : class
 	{
-		private IBulkUpdateOperation<TDocument, TPartialUpdate> Self { get { return this; } }
+		private IBulkUpdateOperation<TDocument, TPartialDocument> Self { get { return this; } }
 
 		protected override string BulkOperationType { get { return "update"; } }
 		protected override Type BulkOperationClrType { get { return typeof(TDocument); } }
 
-		TDocument IBulkUpdateOperation<TDocument, TPartialUpdate>.Document { get; set; }
-		TDocument IBulkUpdateOperation<TDocument, TPartialUpdate>.Upsert { get; set; }
-		TPartialUpdate IBulkUpdateOperation<TDocument, TPartialUpdate>.PartialUpdate { get; set; }
-		bool? IBulkUpdateOperation<TDocument, TPartialUpdate>.DocAsUpsert { get; set; }
-		string IBulkUpdateOperation<TDocument, TPartialUpdate>.Lang { get; set; }
-		string IBulkUpdateOperation<TDocument, TPartialUpdate>.Script { get; set; }
-		Dictionary<string, object> IBulkUpdateOperation<TDocument, TPartialUpdate>.Params { get; set; }
+		TDocument IBulkUpdateOperation<TDocument, TPartialDocument>.InferFrom { get; set; }
+
+		TDocument IBulkUpdateOperation<TDocument, TPartialDocument>.Upsert { get; set; }
+
+		TPartialDocument IBulkUpdateOperation<TDocument, TPartialDocument>.PartialDocument { get; set; }
+
+		bool? IBulkUpdateOperation<TDocument, TPartialDocument>.PartialDocumentAsUpsert { get; set; }
+
+		string IBulkUpdateOperation<TDocument, TPartialDocument>.Lang { get; set; }
+
+		string IBulkUpdateOperation<TDocument, TPartialDocument>.Script { get; set; }
+
+		Dictionary<string, object> IBulkUpdateOperation<TDocument, TPartialDocument>.Params { get; set; }
 
 		protected override object GetBulkOperationBody()
 		{
-			return new BulkUpdateBody<TDocument, TPartialUpdate>
+			return new BulkUpdateBody<TDocument, TPartialDocument>
 			{
-				_PartialUpdate = Self.PartialUpdate,
+				_PartialUpdate = Self.PartialDocument,
 				_Script = Self.Script,
 				_Lang = Self.Lang,
 				_Params = Self.Params,
 				_Upsert = Self.Upsert,
-				_DocAsUpsert = Self.DocAsUpsert
+				_DocAsUpsert = Self.PartialDocumentAsUpsert
 			};
 		}
 
 		protected override string GetIdForOperation(ElasticInferrer inferrer)
 		{
-			return Self.Id ?? inferrer.Id(Self.Document);
+			return Self.Id ?? inferrer.Id(Self.InferFrom) ?? inferrer.Id(Self.Upsert);
 		}
 
 		/// <summary>
 		/// Manually set the index, default to the default index or the fixed index set on the bulk operation
 		/// </summary>
-		public BulkUpdateDescriptor<TDocument, TPartialUpdate> Index(string index)
+		public BulkUpdateDescriptor<TDocument, TPartialDocument> Index(string index)
 		{
 			index.ThrowIfNullOrEmpty("indices");
 			Self.Index = index;
@@ -118,7 +125,7 @@ public BulkUpdateDescriptor<TDocument, TPartialUpdate> Index(string index)
 		/// Manualy set the type to get the object from, default to whatever
 		/// T will be inferred to if not passed or the fixed type set on the parent bulk operation
 		/// </summary>
-		public BulkUpdateDescriptor<TDocument, TPartialUpdate> Type(string type)
+		public BulkUpdateDescriptor<TDocument, TPartialDocument> Type(string type)
 		{
 			type.ThrowIfNullOrEmpty("type");
 			Self.Type = type;
@@ -128,7 +135,7 @@ public BulkUpdateDescriptor<TDocument, TPartialUpdate> Type(string type)
 		/// <summary>
 		/// Manually set the type of which a typename will be inferred
 		/// </summary>
-		public BulkUpdateDescriptor<TDocument, TPartialUpdate> Type(Type type)
+		public BulkUpdateDescriptor<TDocument, TPartialDocument> Type(Type type)
 		{
 			type.ThrowIfNull("type");
 			Self.Type = type;
@@ -138,15 +145,15 @@ public BulkUpdateDescriptor<TDocument, TPartialUpdate> Type(Type type)
 		/// <summary>
 		/// Manually set the id for the newly created object
 		/// </summary>
-		public BulkUpdateDescriptor<TDocument, TPartialUpdate> Id(long id)
+		public BulkUpdateDescriptor<TDocument, TPartialDocument> Id(long id)
 		{
 			return this.Id(id.ToString(CultureInfo.InvariantCulture));
 		}
 
 		/// <summary>
 		/// Manually set the id for the newly created object
 		/// </summary>
-		public BulkUpdateDescriptor<TDocument, TPartialUpdate> Id(string id)
+		public BulkUpdateDescriptor<TDocument, TPartialDocument> Id(string id)
 		{
 			Self.Id = id;
 			return this;
@@ -156,91 +163,92 @@ public BulkUpdateDescriptor<TDocument, TPartialUpdate> Id(string id)
 		/// The object to update, if id is not manually set it will be inferred from the object.
 		/// Used ONLY to infer the ID see Document() to apply a partial object merge.
 		/// </summary>
-		public BulkUpdateDescriptor<TDocument, TPartialUpdate> Document(TDocument @object)
+		public BulkUpdateDescriptor<TDocument, TPartialDocument> InferFrom(TDocument @object, bool useAsUpsert = false)
 		{
-			Self.Document = @object;
+			Self.InferFrom = @object;
+			if (useAsUpsert) return this.Upsert(@object);
 			return this;
 		}
 		/// <summary>
 		/// A document to upsert when the specified document to be updated is not found
 		/// </summary>
-		public BulkUpdateDescriptor<TDocument, TPartialUpdate> Upsert(TDocument @object)
+		public BulkUpdateDescriptor<TDocument, TPartialDocument> Upsert(TDocument @object)
 		{
 			Self.Upsert = @object;
 			return this;
 		}
 		/// <summary>
 		/// The partial update document to be merged on to the existing object.
 		/// </summary>
-		public BulkUpdateDescriptor<TDocument, TPartialUpdate> PartialUpdate(TPartialUpdate @object)
+		public BulkUpdateDescriptor<TDocument, TPartialDocument> PartialDocument(TPartialDocument @object)
 		{
-			Self.PartialUpdate = @object;
+			Self.PartialDocument = @object;
 			return this;
 		}
 
-		public BulkUpdateDescriptor<TDocument, TPartialUpdate> DocAsUpsert(bool docAsUpsert = true)
+		public BulkUpdateDescriptor<TDocument, TPartialDocument> PartialDocumentAsUpsert(bool partialDocumentAsUpsert = true)
 		{
-			Self.DocAsUpsert = docAsUpsert;
+			Self.PartialDocumentAsUpsert = partialDocumentAsUpsert;
 			return this;
 		}
 
-		public BulkUpdateDescriptor<TDocument, TPartialUpdate> Lang(string lang)
+		public BulkUpdateDescriptor<TDocument, TPartialDocument> Lang(string lang)
 		{
 			Self.Lang = lang;
 			return this;
 		}
 
-		public BulkUpdateDescriptor<TDocument, TPartialUpdate> Script(string script)
+		public BulkUpdateDescriptor<TDocument, TPartialDocument> Script(string script)
 		{
 			script.ThrowIfNull("script");
 			Self.Script = script;
 			return this;
 		}
 
-		public BulkUpdateDescriptor<TDocument, TPartialUpdate> Params(Func<FluentDictionary<string, object>, FluentDictionary<string, object>> paramDictionary)
+		public BulkUpdateDescriptor<TDocument, TPartialDocument> Params(Func<FluentDictionary<string, object>, FluentDictionary<string, object>> paramDictionary)
 		{
 			paramDictionary.ThrowIfNull("paramDictionary");
 			Self.Params = paramDictionary(new FluentDictionary<string, object>());
 			return this;
 		}
 
-		public BulkUpdateDescriptor<TDocument, TPartialUpdate> Version(string version)
+		public BulkUpdateDescriptor<TDocument, TPartialDocument> Version(string version)
 		{
 			Self.Version = version; 
 			return this;
 		}
 
 
-		public BulkUpdateDescriptor<TDocument, TPartialUpdate> VersionType(VersionType versionType)
+		public BulkUpdateDescriptor<TDocument, TPartialDocument> VersionType(VersionType versionType)
 		{
 			Self.VersionType = versionType;
 			return this;
 		}
 
-		public BulkUpdateDescriptor<TDocument, TPartialUpdate> Routing(string routing)
+		public BulkUpdateDescriptor<TDocument, TPartialDocument> Routing(string routing)
 		{
 			Self.Routing = routing; 
 			return this;
 		}
 
-		public BulkUpdateDescriptor<TDocument, TPartialUpdate> Parent(string parent)		{
+		public BulkUpdateDescriptor<TDocument, TPartialDocument> Parent(string parent)		{
 			Self.Parent = parent; 
 			return this;
 		}
 
-		public BulkUpdateDescriptor<TDocument, TPartialUpdate> Timestamp(long timestamp)
+		public BulkUpdateDescriptor<TDocument, TPartialDocument> Timestamp(long timestamp)
 		{
 			Self.Timestamp = timestamp; 
 			return this;
 		}
 
-		public BulkUpdateDescriptor<TDocument, TPartialUpdate> Ttl(string ttl)
+		public BulkUpdateDescriptor<TDocument, TPartialDocument> Ttl(string ttl)
 		{
 			Self.Ttl = ttl; 
 			return this;
 		}
 
-		public BulkUpdateDescriptor<TDocument, TPartialUpdate> RetriesOnConflict(int retriesOnConflict)
+		public BulkUpdateDescriptor<TDocument, TPartialDocument> RetriesOnConflict(int retriesOnConflict)
 		{
 			Self.RetriesOnConflict = retriesOnConflict;
 			return this;

src/Nest/DSL/Paths/DocumentOptionalPathDescriptor.cs

@@ -152,7 +152,7 @@ public TDescriptor Type<TAlternative>() where TAlternative : class
 		}
 		public TDescriptor Id(long id)
 		{
-			return this.Id(id.ToString());
+			return this.Id(id.ToString(CultureInfo.InvariantCulture));
 		}
 		public TDescriptor Id(string id)
 		{