[Backport master] Add registered domain ingest processor (#5618)

* Add registered domain processor (#5616)

* Fixup namespace

Co-authored-by: Steve Gordon <[email protected]>

Author: github-actions[bot]

src/Nest/Ingest/ProcessorFormatter.cs

@@ -45,7 +45,8 @@ internal class ProcessorFormatter : IJsonFormatter<IProcessor>
 			{ "uri_parts", 33 },
 			{ "fingerprint", 34 },
 			{ "community_id", 35 },
-			{ "network_direction", 36 }
+			{ "network_direction", 36 },
+			{ "registered_domain", 37 }
 		};
 
 		public IProcessor Deserialize(ref JsonReader reader, IJsonFormatterResolver formatterResolver)
@@ -177,6 +178,9 @@ public IProcessor Deserialize(ref JsonReader reader, IJsonFormatterResolver form
 					case 36:
 						processor = Deserialize<NetworkDirectionProcessor>(ref reader, formatterResolver);
 						break;
+					case 37:
+						processor = Deserialize<RegisteredDomainProcessor>(ref reader, formatterResolver);
+						break;
 				}
 			}
 			else
@@ -309,6 +313,9 @@ public void Serialize(ref JsonWriter writer, IProcessor value, IJsonFormatterRes
 				case "network_direction":
 					Serialize<INetworkDirectionProcessor>(ref writer, value, formatterResolver);
 					break;
+				case "registered_domain":
+					Serialize<IRegisteredDomainProcessor>(ref writer, value, formatterResolver);
+					break;
 				default:
 					var formatter = DynamicObjectResolver.ExcludeNullCamelCase.GetFormatter<IProcessor>();
 					formatter.Serialize(ref writer, value, formatterResolver);

src/Nest/Ingest/Processors/NetworkDirectionProcessor.cs

@@ -1,4 +1,8 @@
-using System;
+// Licensed to Elasticsearch B.V under one or more agreements.
+// Elasticsearch B.V licenses this file to you under the Apache 2.0 License.
+// See the LICENSE file in the project root for more information
+
+using System;
 using System.Collections.Generic;
 using System.Linq.Expressions;
 using System.Runtime.Serialization;

src/Nest/Ingest/Processors/RegisteredDomainProcoessor.cs

@@ -0,0 +1,65 @@
+// Licensed to Elasticsearch B.V under one or more agreements.
+// Elasticsearch B.V licenses this file to you under the Apache 2.0 License.
+// See the LICENSE file in the project root for more information
+
+using System;
+using System.Linq.Expressions;
+using System.Runtime.Serialization;
+using Nest.Utf8Json;
+
+namespace Nest
+{
+	[InterfaceDataContract]
+	public interface IRegisteredDomainProcessor : IProcessor
+	{
+		[DataMember(Name = "field")]
+		Field Field { get; set; }
+
+		[DataMember(Name = "ignore_missing")]
+		bool? IgnoreMissing { get; set; }
+		
+		[DataMember(Name = "target_field")]
+		Field TargetField { get; set; }
+	}
+
+	public class RegisteredDomainProcessor : ProcessorBase, IRegisteredDomainProcessor
+	{
+		protected override string Name => "registered_domain";
+
+		/// <inheritdoc />
+		public Field Field { get; set; }
+		/// <inheritdoc />
+		public bool? IgnoreMissing { get; set; }
+		/// <inheritdoc />
+		public Field TargetField { get; set; }
+	}
+
+	/// <inheritdoc cref="IFingerprintProcessor" />
+	public class RegisteredDomainProcessorDescriptor<T>
+		: ProcessorDescriptorBase<RegisteredDomainProcessorDescriptor<T>, IRegisteredDomainProcessor>, IRegisteredDomainProcessor
+		where T : class
+	{
+		protected override string Name => "registered_domain";
+
+		Field IRegisteredDomainProcessor.Field { get; set; }
+		bool? IRegisteredDomainProcessor.IgnoreMissing { get; set; }
+		Field IRegisteredDomainProcessor.TargetField { get; set; }
+
+		/// <inheritdoc cref="IRegisteredDomainProcessor.Field" />
+		public RegisteredDomainProcessorDescriptor<T> Field(Field field) => Assign(field, (a, v) => a.Field = v);
+
+		/// <inheritdoc cref="IRegisteredDomainProcessor.Field" />
+		public RegisteredDomainProcessorDescriptor<T> Field<TValue>(Expression<Func<T, TValue>> objectPath) =>
+			Assign(objectPath, (a, v) => a.Field = v);
+
+		/// <inheritdoc cref="IRegisteredDomainProcessor.IgnoreMissing" />
+		public RegisteredDomainProcessorDescriptor<T> IgnoreMissing(bool? ignoreMissing = true) => Assign(ignoreMissing, (a, v) => a.IgnoreMissing = v);
+
+		/// <inheritdoc cref="IRegisteredDomainProcessor.TargetField" />
+		public RegisteredDomainProcessorDescriptor<T> TargetField(Field field) => Assign(field, (a, v) => a.TargetField = v);
+
+		/// <inheritdoc cref="IRegisteredDomainProcessor.TargetField" />
+		public RegisteredDomainProcessorDescriptor<T> TargetField<TValue>(Expression<Func<T, TValue>> objectPath) =>
+			Assign(objectPath, (a, v) => a.TargetField = v);
+	}
+}

src/Nest/Ingest/ProcessorsDescriptor.cs

@@ -193,5 +193,9 @@ public ProcessorsDescriptor NetworkCommunityId<T>(Func<NetworkCommunityIdProcess
 		/// <inheritdoc cref="INetworkDirectionProcessor"/>
 		public ProcessorsDescriptor NetworkDirection<T>(Func<NetworkDirectionProcessorDescriptor<T>, INetworkDirectionProcessor> selector) where T : class =>
 			Assign(selector, (a, v) => a.AddIfNotNull(v?.Invoke(new NetworkDirectionProcessorDescriptor<T>())));
+
+		/// <inheritdoc cref="IRegisteredDomainProcessor"/>
+		public ProcessorsDescriptor RegisteredDomain<T>(Func<RegisteredDomainProcessorDescriptor<T>, IRegisteredDomainProcessor> selector) where T : class =>
+			Assign(selector, (a, v) => a.AddIfNotNull(v?.Invoke(new RegisteredDomainProcessorDescriptor<T>())));
 	}
 }

tests/Tests/Ingest/ProcessorAssertions.cs

@@ -850,5 +850,31 @@ public class NetworkDirectionWithField : ProcessorAssertion
 
 			public override string Key => "network_direction";
 		}
+
+		[SkipVersion("<7.13.0", "Register_domain processor added in 7.13.0")]
+		public class RegisteredDomain : ProcessorAssertion
+		{
+			public override ProcFunc Fluent => d => d
+				.RegisteredDomain<Project>(ud => ud
+					.Field(f => f.Name)
+					.TargetField("domain")
+					.IgnoreMissing());
+
+			public override IProcessor Initializer => new RegisteredDomainProcessor
+			{
+				Field = Field<Project>(f => f.Name),
+				TargetField = "domain",
+				IgnoreMissing = true
+			};
+
+			public override object Json => new
+			{
+				field = "name",
+				target_field = "domain",
+				ignore_missing = true
+			};
+
+			public override string Key => "registered_domain";
+		}
 	}
 }