Add if_seq_no and if_primary_term to bulk updates (#4015)

Author: codebrain

src/Nest/Document/Multiple/Bulk/BulkOperation/BulkIndex.cs

@@ -60,6 +60,7 @@ public class BulkIndexDescriptor<T> : BulkOperationDescriptorBase<BulkIndexDescr
 		string IBulkIndexOperation<T>.Percolate { get; set; }
 		string IBulkIndexOperation<T>.Pipeline { get; set; }
 		long? IBulkIndexOperation<T>.IfSequenceNumber { get; set; }
+
 		long? IBulkIndexOperation<T>.IfPrimaryTerm { get; set; }
 
 		protected override object GetBulkOperationBody() => Self.Document;

src/Nest/Document/Multiple/Bulk/BulkOperation/BulkOperationBase.cs

@@ -54,7 +54,6 @@ public abstract class BulkOperationDescriptorBase<TDescriptor, TInterface>
 		/// <summary>
 		/// Only used for bulk update operations but in the future might come in handy for other complex bulk ops.
 		/// </summary>
-		/// <returns></returns>
 		object IBulkOperation.GetBody() => GetBulkOperationBody();
 
 		Id IBulkOperation.GetIdForOperation(Inferrer inferrer) => GetIdForOperation(inferrer);

src/Nest/Document/Multiple/Bulk/BulkOperation/BulkOperationsCollection.cs

@@ -62,7 +62,6 @@ public TOperation this[int index]
 
 		bool ICollection.IsSynchronized => true;
 
-
 		object IList.this[int index]
 		{
 			get => this[index];

src/Nest/Document/Multiple/Bulk/BulkOperation/BulkUpdate.cs

@@ -43,6 +43,10 @@ public interface IBulkUpdateOperation<TDocument, TPartialDocument> : IBulkOperat
 		/// A document to upsert when the specified document to be updated is not found
 		/// </summary>
 		TDocument Upsert { get; set; }
+
+		long? IfSequenceNumber { get; set; }
+
+		long? IfPrimaryTerm { get; set; }
 	}
 
 	[DataContract]
@@ -112,6 +116,10 @@ public BulkUpdateOperation(TDocument idFrom, TPartialDocument update, bool useId
 		/// </summary>
 		public TDocument Upsert { get; set; }
 
+		public long? IfSequenceNumber { get; set; }
+
+		public long? IfPrimaryTerm { get; set; }
+
 		protected override Type ClrType => typeof(TDocument);
 
 		protected override string Operation => "update";
@@ -140,7 +148,9 @@ protected override object GetBody() =>
 				Script = Script,
 				Upsert = Upsert,
 				DocAsUpsert = DocAsUpsert,
-				ScriptedUpsert = ScriptedUpsert
+				ScriptedUpsert = ScriptedUpsert,
+				IfPrimaryTerm = IfPrimaryTerm,
+				IfSequenceNumber = IfSequenceNumber
 			};
 	}
 
@@ -161,14 +171,20 @@ public class BulkUpdateDescriptor<TDocument, TPartialDocument>
 		bool? IBulkUpdateOperation<TDocument, TPartialDocument>.ScriptedUpsert { get; set; }
 		TDocument IBulkUpdateOperation<TDocument, TPartialDocument>.Upsert { get; set; }
 
+		long? IBulkUpdateOperation<TDocument, TPartialDocument>.IfSequenceNumber { get; set; }
+
+		long? IBulkUpdateOperation<TDocument, TPartialDocument>.IfPrimaryTerm { get; set; }
+
 		protected override object GetBulkOperationBody() =>
 			new BulkUpdateBody<TDocument, TPartialDocument>
 			{
 				PartialUpdate = Self.Doc,
 				Script = Self.Script,
 				Upsert = Self.Upsert,
 				DocAsUpsert = Self.DocAsUpsert,
-				ScriptedUpsert = Self.ScriptedUpsert
+				ScriptedUpsert = Self.ScriptedUpsert,
+				IfPrimaryTerm = Self.IfPrimaryTerm,
+				IfSequenceNumber = Self.IfSequenceNumber
 			};
 
 		protected override Id GetIdForOperation(Inferrer inferrer) =>
@@ -236,5 +252,17 @@ public BulkUpdateDescriptor<TDocument, TPartialDocument> Script(Func<ScriptDescr
 		/// </summary>
 		public BulkUpdateDescriptor<TDocument, TPartialDocument> RetriesOnConflict(int? retriesOnConflict) =>
 			Assign(retriesOnConflict, (a, v) => a.RetriesOnConflict = v);
+
+		/// <summary>
+		/// Operations can be made conditional and only be performed if the last modification to the document was assigned the sequence number.
+		/// </summary>
+		public BulkUpdateDescriptor<TDocument, TPartialDocument> IfSequenceNumber(long? seqNo) =>
+			Assign(seqNo, (a, v) => a.IfSequenceNumber = v);
+
+		/// <summary>
+		/// Operations can be made conditional and only be performed if the last modification to the document was assigned the primary term.
+		/// </summary>
+		public BulkUpdateDescriptor<TDocument, TPartialDocument> IfPrimaryTerm(long? primaryTerm) =>
+			Assign(primaryTerm, (a, v) => a.IfSequenceNumber = v);
 	}
 }

src/Nest/Document/Multiple/Bulk/BulkOperation/BulkUpdateBody.cs

@@ -24,5 +24,11 @@ internal class BulkUpdateBody<TDocument, TPartialUpdate>
 		[DataMember(Name ="upsert")]
 		[JsonFormatter(typeof(CollapsedSourceFormatter<>))]
 		internal TDocument Upsert { get; set; }
+
+		[DataMember(Name = "if_seq_no")]
+		internal long? IfSequenceNumber { get; set; }
+
+		[DataMember(Name = "if_primary_term")]
+		internal long? IfPrimaryTerm { get; set; }
 	}
 }