Support allow_duplicates on append processor (#5208)

* Support allow_duplicates on append processor

Related to elastic/elasticsearch#61916

Author: stevejgordon

src/Nest/Ingest/Processors/AppendProcessor.cs

@@ -20,12 +20,17 @@ public interface IAppendProcessor : IProcessor
 
 		[DataMember(Name ="value")]
 		IEnumerable<object> Value { get; set; }
+
+		[DataMember(Name = "allow_duplicates")]
+		bool? AllowDuplicates { get; set; }
 	}
 
 	public class AppendProcessor : ProcessorBase, IAppendProcessor
 	{
 		public Field Field { get; set; }
 		public IEnumerable<object> Value { get; set; }
+		public bool? AllowDuplicates { get; set; }
+
 		protected override string Name => "append";
 	}
 
@@ -35,6 +40,7 @@ public class AppendProcessorDescriptor<T> : ProcessorDescriptorBase<AppendProces
 		protected override string Name => "append";
 		Field IAppendProcessor.Field { get; set; }
 		IEnumerable<object> IAppendProcessor.Value { get; set; }
+		bool? IAppendProcessor.AllowDuplicates { get; set; }
 
 		public AppendProcessorDescriptor<T> Field(Field field) => Assign(field, (a, v) => a.Field = v);
 
@@ -49,5 +55,7 @@ public AppendProcessorDescriptor<T> Value<TValue>(params TValue[] values) => Ass
 				a.Value = (v.First() as IEnumerable)?.Cast<object>();
 			else a.Value = v?.Cast<object>();
 		});
+
+		public AppendProcessorDescriptor<T> AllowDuplicates(bool? allowDuplicates = true) => Assign(allowDuplicates, (a, v) => a.AllowDuplicates = v);
 	}
 }

tests/Tests/Ingest/ProcessorAssertions.cs

@@ -9,6 +9,7 @@
 using Elastic.Elasticsearch.Xunit.XunitPlumbing;
 using Nest;
 using Tests.Core.Client;
+using Tests.Core.Extensions;
 using Tests.Core.Xunit;
 using Tests.Domain;
 
@@ -56,22 +57,33 @@ public static IPromise<IList<IProcessor>> Fluent(ProcessorsDescriptor d)
 			foreach (var a in All) a.Fluent(d);
 			return d;
 		}
-
+		
 		public class Append : ProcessorAssertion
 		{
-			public override Func<ProcessorsDescriptor, IPromise<IList<IProcessor>>> Fluent => d => d
-				.Append<Project>(a => a
-					.Field(p => p.State)
-					.Value(StateOfBeing.Stable, StateOfBeing.VeryActive)
-				);
+			public override Func<ProcessorsDescriptor, IPromise<IList<IProcessor>>> Fluent =>
+				d => d.Append<Project>(a => a.Field(p => p.State).Value(StateOfBeing.Stable, StateOfBeing.VeryActive));
 
-			public override IProcessor Initializer => new AppendProcessor
+			public override IProcessor Initializer => new AppendProcessor { Field = "state", Value = new object[] { StateOfBeing.Stable, StateOfBeing.VeryActive }};
+
+			public override object Json => new
 			{
-				Field = "state",
-				Value = new object[] { StateOfBeing.Stable, StateOfBeing.VeryActive }
+				field = "state",
+				value = new[] { "Stable", "VeryActive" }
 			};
 
-			public override object Json => new { field = "state", value = new[] { "Stable", "VeryActive" } };
+			public override string Key => "append";
+		}
+
+		[SkipVersion("<7.11.0", "Allow duplicates added in 7.11")]
+		public class AppendWithAllowDuplicates : ProcessorAssertion
+		{
+			public override Func<ProcessorsDescriptor, IPromise<IList<IProcessor>>> Fluent =>
+				d => d.Append<Project>(a => a.Field(p => p.State).Value(StateOfBeing.Stable, StateOfBeing.VeryActive).AllowDuplicates(false));
+
+			public override IProcessor Initializer => new AppendProcessor { Field = "state", Value = new object[] { StateOfBeing.Stable, StateOfBeing.VeryActive }, AllowDuplicates = false };
+
+			public override object Json => new { field = "state", value = new[] { "Stable", "VeryActive" }, allow_duplicates = false };
+
 			public override string Key => "append";
 		}