Register TypeInfoProvider explicitly (#527)

Mpdreamz · web-flow · commit 4a96d68dcfff · 2025-08-05T12:22:41.000+02:00
- **Add EcsJsonContext.Default to JsonSerializerOptions**
- **Update JsonSerializerOptions to combine DefaultJsonTypeInfoResolver
with EcsJsonContext**
- **Add JsonSerializable attributes for EcsDocument and Labels in
EcsJsonContext**
diff --git a/examples/playground/Program.cs b/examples/playground/Program.cs
@@ -1,5 +1,6 @@
 ﻿using Elastic.Channels;
 using Elastic.CommonSchema;
+using Elastic.CommonSchema.Serialization;
 using Elastic.Elasticsearch.Ephemeral;
 using Elastic.Ingest.Elasticsearch;
 using Elastic.Ingest.Elasticsearch.CommonSchema;
@@ -116,7 +117,8 @@ EcsDataStreamChannel<EcsDocument> SetupElasticsearchChannel()
 	var c = new EcsDataStreamChannel<EcsDocument>(
 		new DataStreamChannelOptions<EcsDocument>(new DistributedTransport(transportConfiguration))
 		{
-			BufferOptions = bufferOptions
+			BufferOptions = bufferOptions,
+			SerializerContext = EcsJsonContext.Default
 		});
 
 	return c;
diff --git a/src/Elastic.CommonSchema.BenchmarkDotNetExporter/ElasticsearchBenchmarkExporter.cs b/src/Elastic.CommonSchema.BenchmarkDotNetExporter/ElasticsearchBenchmarkExporter.cs
@@ -13,6 +13,7 @@
 using BenchmarkDotNet.Reports;
 using Elastic.Channels;
 using Elastic.CommonSchema.BenchmarkDotNetExporter.Domain;
+using Elastic.CommonSchema.Serialization;
 using Elastic.Ingest.Elasticsearch.CommonSchema;
 using Elastic.Ingest.Elasticsearch.DataStreams;
 using Elastic.Transport;
@@ -69,6 +70,7 @@ public override void ExportToLog(Summary summary, ILogger logger)
 					OutboundBufferMaxSize = benchmarksCount,
 					OutboundBufferMaxLifetime = TimeSpan.FromSeconds(5)
 				},
+				SerializerContext = EcsJsonContext.Default,
 				ExportExceptionCallback = e => observedException ??= e,
 				ExportResponseCallback = (response, _) =>
 				{
diff --git a/src/Elastic.CommonSchema.NLog/EcsLayout.cs b/src/Elastic.CommonSchema.NLog/EcsLayout.cs
@@ -16,19 +16,10 @@
 
 namespace Elastic.CommonSchema.NLog
 {
-	internal class NlogEcsDocumentCreationOptions : IEcsDocumentCreationOptions
-	{
-		public static NlogEcsDocumentCreationOptions Default { get; } = new();
-		public bool IncludeHost { get; set; } = true;
-		public bool IncludeProcess { get; set; } = false;
-		public bool IncludeUser { get; set; } = false;
-		public bool IncludeActivityData { get; set; } = false;
-	}
-
 	/// <summary> An NLOG layout implementation that renders logs as ECS json</summary>
 	[Layout(Name)]
 	[ThreadAgnostic]
-	public class EcsLayout : Layout
+	public partial class EcsLayout : Layout
 	{
 		/// <summary> An NLOG layout implementation that renders logs as ECS json</summary>
 		public const string Name = nameof(EcsLayout);
@@ -569,7 +560,7 @@ private Process GetProcess(LogEventInfo logEventInfo)
 			var processExecutable = ProcessExecutable?.Render(logEventInfo);
 			var processThreadId = ProcessThreadId?.Render(logEventInfo);
 			var processThreadName = ProcessThreadName?.Render(logEventInfo);
-			
+
 			var previousProcess = _previousProcess;
 			if (string.IsNullOrEmpty(processThreadId) && string.IsNullOrEmpty(processThreadName))
 			{
diff --git a/src/Elastic.CommonSchema.NLog/NLogEcsJsonContext.cs b/src/Elastic.CommonSchema.NLog/NLogEcsJsonContext.cs
@@ -0,0 +1,10 @@
+using System.Text.Json.Serialization;
+
+namespace Elastic.CommonSchema.NLog;
+
+/// <summary>
+///
+/// </summary>
+[JsonSerializable(typeof(EcsLayout.NLogEcsDocument))]
+[JsonSourceGenerationOptions(DefaultIgnoreCondition = JsonIgnoreCondition.WhenWritingNull)]
+public partial class NLogEcsJsonContext : JsonSerializerContext { }
diff --git a/src/Elastic.CommonSchema.NLog/NlogEcsDocumentCreationOptions.cs b/src/Elastic.CommonSchema.NLog/NlogEcsDocumentCreationOptions.cs
@@ -0,0 +1,10 @@
+namespace Elastic.CommonSchema.NLog;
+
+internal class NlogEcsDocumentCreationOptions : IEcsDocumentCreationOptions
+{
+	public static NlogEcsDocumentCreationOptions Default { get; } = new();
+	public bool IncludeHost { get; set; } = true;
+	public bool IncludeProcess { get; set; } = false;
+	public bool IncludeUser { get; set; } = false;
+	public bool IncludeActivityData { get; set; } = false;
+}
diff --git a/src/Elastic.CommonSchema/EcsDocument.Serialization.cs b/src/Elastic.CommonSchema/EcsDocument.Serialization.cs
@@ -63,7 +63,7 @@ protected internal virtual void WriteAdditionalProperties(Action<string, object>
 		public static EcsDocument? Deserialize(Stream stream) => EcsSerializerFactory<EcsDocument>.Deserialize(stream);
 
 		// ReSharper disable once UnusedMember.Global
-		/// <summary> Deserialize asynchronously a stream to <see cref="EcsDocument"/> </summary>
+		/// <summary> Asynchronously deserialize a stream to <see cref="EcsDocument"/> </summary>
 		public static ValueTask<EcsDocument?> DeserializeAsync(Stream stream, CancellationToken ctx = default) =>
 			EcsSerializerFactory<EcsDocument>.DeserializeAsync(stream, ctx);
 
diff --git a/src/Elastic.CommonSchema/Serialization/EcsJsonContext.Generated.cs b/src/Elastic.CommonSchema/Serialization/EcsJsonContext.Generated.cs
@@ -6,14 +6,17 @@
 /*
 IMPORTANT NOTE
 ==============
-This file has been generated. 
+This file has been generated.
 If you wish to submit a PR please modify the original csharp file and submit the PR with that change. Thanks!
 */
 
 using System.Text.Json.Serialization;
 
 namespace Elastic.CommonSchema.Serialization;
 
+/// An implementation of <see cref="JsonSerializerContext"/> that could be used to be combined with user data
+[JsonSerializable(typeof(EcsDocument))]
+[JsonSerializable(typeof(Labels))]
 [JsonSerializable(typeof(Agent))]
 [JsonSerializable(typeof(As))]
 [JsonSerializable(typeof(Client))]
@@ -64,7 +67,7 @@ namespace Elastic.CommonSchema.Serialization;
 [JsonSerializable(typeof(Volume))]
 [JsonSerializable(typeof(Vulnerability))]
 [JsonSerializable(typeof(X509))]
-[JsonSerializable(typeof(LogEntityJsonConverter.LogOriginInvalid))]
-[JsonSerializable(typeof(LogEntityJsonConverter.LogFileOriginInvalid))]
+[JsonSerializable(typeof(ParserIntermediary.LogOriginInvalid))]
+[JsonSerializable(typeof(ParserIntermediary.LogFileOriginInvalid))]
 [JsonSourceGenerationOptions(DefaultIgnoreCondition = JsonIgnoreCondition.WhenWritingNull)]
-internal partial class EcsJsonContext : JsonSerializerContext { }
+public partial class EcsJsonContext : JsonSerializerContext { }
diff --git a/src/Elastic.CommonSchema/Serialization/JsonConfiguration.cs b/src/Elastic.CommonSchema/Serialization/JsonConfiguration.cs
@@ -6,6 +6,7 @@
 using System.Text.Encodings.Web;
 using System.Text.Json;
 using System.Text.Json.Serialization;
+using System.Text.Json.Serialization.Metadata;
 
 namespace Elastic.CommonSchema.Serialization
 {
@@ -19,6 +20,7 @@ public static class EcsJsonConfiguration
 			NumberHandling = JsonNumberHandling.AllowNamedFloatingPointLiterals,
 			Encoder = JavaScriptEncoder.UnsafeRelaxedJsonEscaping,
 			PropertyNamingPolicy = new SnakeCaseJsonNamingPolicy(),
+			TypeInfoResolver = JsonTypeInfoResolver.Combine(new DefaultJsonTypeInfoResolver(), EcsJsonContext.Default),
 			Converters =
 			{
 				new EcsDocumentJsonConverterFactory(),
diff --git a/src/Elastic.CommonSchema/Serialization/PropertiesReaderJsonConverterBase.cs b/src/Elastic.CommonSchema/Serialization/PropertiesReaderJsonConverterBase.cs
@@ -57,29 +57,41 @@ internal partial class EcsEntityJsonConverter
 	private partial bool ReadProperty(ref Utf8JsonReader reader, string propertyName, Ecs ecsEvent, JsonSerializerOptions options) => false;
 }
 
-internal partial class LogEntityJsonConverter
+
+/// intermediary parser objects, not meant for direct consumption
+public class ParserIntermediary
 {
-	internal class LogFileOriginInvalid
+	/// intermediary parser for log data in a different format
+	public class LogFileOriginInvalid
 	{
+		/// <inheritdoc cref="LogFieldSet.OriginFileName"/>
 		[JsonPropertyName("name"), DataMember(Name = "name")]
 		public string? Name { get; set; }
 
+		/// <inheritdoc cref="LogFieldSet.OriginFileLine"/>
 		[JsonPropertyName("line"), DataMember(Name = "line")]
 		public int? Line { get; set; }
 	}
-	internal class LogOriginInvalid
+
+	/// intermediary parser for log data in a different format
+	public class LogOriginInvalid
 	{
+		/// <inheritdoc cref="LogFieldSet.OriginFunction"/>
 		[JsonPropertyName("function"), DataMember(Name = "function")]
 		public string? Function { get; set; }
 
+		/// <inheritdoc cref="LogFieldSet.FilePath"/>
 		[JsonPropertyName("file"), DataMember(Name = "file")]
 		public LogFileOriginInvalid? File { get; set; }
 	}
+}
 
+internal partial class LogEntityJsonConverter
+{
 	private partial bool ReadProperty(ref Utf8JsonReader reader, string propertyName, Log ecsEvent, JsonSerializerOptions options) =>
 		propertyName switch
 		{
-			"origin" => ReadProp<LogOriginInvalid>(ref reader, "origin", ecsEvent, (b, v) =>
+			"origin" => ReadProp<ParserIntermediary.LogOriginInvalid>(ref reader, "origin", ecsEvent, (b, v) =>
 			{
 				if (v == null) return;
 				b.OriginFunction = v.Function;
diff --git a/src/Elastic.Extensions.Logging.Common/LogEvent.cs b/src/Elastic.Extensions.Logging.Common/LogEvent.cs
@@ -81,4 +81,5 @@ protected override void WriteAdditionalProperties(Action<string, object> write)
 			if (Scopes != null) write(ScopesPropertyName, Scopes);
 		}
 	}
+
 }
diff --git a/src/Elastic.Extensions.Logging.Common/LogEventJsonContext.cs b/src/Elastic.Extensions.Logging.Common/LogEventJsonContext.cs
@@ -0,0 +1,10 @@
+using System.Text.Json.Serialization;
+
+namespace Elastic.Extensions.Logging.Common;
+
+/// <summary>
+///
+/// </summary>
+[JsonSerializable(typeof(LogEvent))]
+[JsonSourceGenerationOptions(DefaultIgnoreCondition = JsonIgnoreCondition.WhenWritingNull)]
+public partial class LogEventJsonContext : JsonSerializerContext { }
diff --git a/src/Elastic.Extensions.Logging/ElasticsearchLoggerOptionsSetup.cs b/src/Elastic.Extensions.Logging/ElasticsearchLoggerOptionsSetup.cs
@@ -6,13 +6,7 @@
 using Microsoft.Extensions.Logging.Configuration;
 using Microsoft.Extensions.Options;
 
-namespace Elastic.Extensions.Logging
-{
-	internal class ElasticsearchLoggerOptionsSetup : ConfigureFromConfigurationOptions<ElasticsearchLoggerOptions>
-	{
-		public ElasticsearchLoggerOptionsSetup(
-			ILoggerProviderConfiguration<ElasticsearchLoggerProvider> providerConfiguration
-		)
-			: base(providerConfiguration.Configuration) { }
-	}
-}
+namespace Elastic.Extensions.Logging;
+
+internal class ElasticsearchLoggerOptionsSetup(ILoggerProviderConfiguration<ElasticsearchLoggerProvider> providerConfiguration)
+	: ConfigureFromConfigurationOptions<ElasticsearchLoggerOptions>(providerConfiguration.Configuration);
diff --git a/src/Elastic.Extensions.Logging/ElasticsearchLoggerProvider.cs b/src/Elastic.Extensions.Logging/ElasticsearchLoggerProvider.cs
@@ -6,10 +6,13 @@
 using System.Collections.Generic;
 using System.IO;
 using System.Linq;
+using System.Text.Json.Serialization.Metadata;
 using System.Threading;
 using System.Threading.Tasks;
 using Elastic.Channels;
 using Elastic.Channels.Diagnostics;
+using Elastic.CommonSchema.Serialization;
+using Elastic.Extensions.Logging.Common;
 using Elastic.Extensions.Logging.Options;
 using Elastic.Ingest.Elasticsearch;
 using Elastic.Ingest.Elasticsearch.CommonSchema;
@@ -189,6 +192,7 @@ private IBufferedChannel<LogEvent> CreatIngestChannel(ElasticsearchLoggerOptions
 					IndexFormat = loggerOptions.Index.Format,
 					IndexOffset = loggerOptions.Index.IndexOffset,
 					TimestampLookup = l => l.Timestamp,
+					SerializerContexts = [LogEventJsonContext.Default, EcsJsonContext.Default]
 				};
 				SetupChannelOptions(_channelConfigurations, indexChannelOptions);
 				return new EcsIndexChannel<LogEvent>(indexChannelOptions);
@@ -200,7 +204,8 @@ private IBufferedChannel<LogEvent> CreatIngestChannel(ElasticsearchLoggerOptions
 				var indexChannelOptions = new DataStreamChannelOptions<LogEvent>(transport)
 				{
 					DataStream = new DataStreamName(dataStreamNameOptions.Type, dataStreamNameOptions.DataSet, dataStreamNameOptions.Namespace),
-					EventWriter = LogEventWriterInstance
+					EventWriter = LogEventWriterInstance,
+					SerializerContexts = [LogEventJsonContext.Default, EcsJsonContext.Default]
 				};
 
 				SetupChannelOptions(_channelConfigurations, indexChannelOptions);
diff --git a/src/Elastic.Ingest.Elasticsearch.CommonSchema/Elastic.Ingest.Elasticsearch.CommonSchema.csproj b/src/Elastic.Ingest.Elasticsearch.CommonSchema/Elastic.Ingest.Elasticsearch.CommonSchema.csproj
@@ -10,7 +10,7 @@
   </ItemGroup>
 
   <ItemGroup>
-    <PackageReference Include="Elastic.Ingest.Elasticsearch" Version="0.12.1" />
+    <PackageReference Include="Elastic.Ingest.Elasticsearch" Version="0.12.3" />
   </ItemGroup>
 
 </Project>
diff --git a/src/Elastic.NLog.Targets/ElasticsearchTarget.cs b/src/Elastic.NLog.Targets/ElasticsearchTarget.cs
@@ -1,10 +1,12 @@
 using System;
 using System.Collections.Generic;
 using System.Linq;
+using System.Text.Json.Serialization.Metadata;
 using Elastic.Channels;
 using Elastic.Channels.Buffers;
 using Elastic.Channels.Diagnostics;
 using Elastic.CommonSchema.NLog;
+using Elastic.CommonSchema.Serialization;
 using Elastic.Ingest.Elasticsearch;
 using Elastic.Ingest.Elasticsearch.CommonSchema;
 using Elastic.Ingest.Elasticsearch.DataStreams;
@@ -223,13 +225,9 @@ protected override void InitializeTarget()
 
 			var transport = new DistributedTransport<ITransportConfiguration>(config);
 			if (!string.IsNullOrEmpty(indexFormat))
-			{
 				_channel = CreateIndexChannel(transport, indexFormat, indexOffset, IndexOperation);
-			}
 			else
-			{
 				_channel = CreateDataStreamChannel(transport);
-			}
 		}
 
 		private void SetupChannelOptions(ElasticsearchChannelOptionsBase<NLogEcsDocument> channelOptions)
@@ -255,7 +253,8 @@ private EcsDataStreamChannel<NLogEcsDocument> CreateDataStreamChannel(Distribute
 			var dataStreamNamespace = DataStreamNamespace?.Render(LogEventInfo.CreateNullEvent()) ?? string.Empty;
 			var channelOptions = new DataStreamChannelOptions<NLogEcsDocument>(transport)
 			{
-				DataStream = new DataStreamName(dataStreamType, dataStreamSet, dataStreamNamespace)
+				DataStream = new DataStreamName(dataStreamType, dataStreamSet, dataStreamNamespace),
+				SerializerContexts = [EcsJsonContext.Default, Elastic.CommonSchema.NLog.NLogEcsJsonContext.Default]
 			};
 			SetupChannelOptions(channelOptions);
 			var channel = new EcsDataStreamChannel<NLogEcsDocument>(channelOptions, new[] { new InternalLoggerCallbackListener<NLogEcsDocument>() });
@@ -270,13 +269,11 @@ private EcsIndexChannel<NLogEcsDocument> CreateIndexChannel(DistributedTransport
 				IndexFormat = indexFormat,
 				IndexOffset = indexOffset,
 				TimestampLookup = l => l.Timestamp,
-				OperationMode = indexOperation
+				OperationMode = indexOperation,
+				SerializerContexts = [EcsJsonContext.Default, Elastic.CommonSchema.NLog.NLogEcsJsonContext.Default]
 			};
 
-			if (_hasIndexEventId)
-			{
-				indexChannelOptions.BulkOperationIdLookup = (logEvent) => (logEvent.Event?.Id)!;
-			}
+			if (_hasIndexEventId) indexChannelOptions.BulkOperationIdLookup = (logEvent) => (logEvent.Event?.Id)!;
 
 			SetupChannelOptions(indexChannelOptions);
 			return new EcsIndexChannel<NLogEcsDocument>(indexChannelOptions);
@@ -296,9 +293,7 @@ protected override void Write(NLog.Common.AsyncLogEventInfo logEvent)
 			{
 				var ecsDoc = _layout.RenderEcsDocument(logEvent.LogEvent);
 				if (_channel?.TryWrite(ecsDoc) == true)
-				{
 					logEvent.Continuation(null);
-				}
 				else
 				{
 					NLog.Common.InternalLogger.Error("ElasticSearch - Failed writing to Elastic channel (Buffer full)");
@@ -415,8 +410,10 @@ public InternalLoggerCallbackListener()
 				if (response.Items?.Count > 0)
 				{
 					foreach (var itemResult in response.Items)
+					{
 						if (itemResult?.Status >= 300)
 							NLog.Common.InternalLogger.Error("ElasticSearch - Export Item failed to {0} document status {1} - {2}", itemResult.Action, itemResult.Status, itemResult.Error);
+					}
 				}
 			};
 		}
diff --git a/src/Elastic.Serilog.Sinks/ElasticsearchSink.cs b/src/Elastic.Serilog.Sinks/ElasticsearchSink.cs
@@ -5,6 +5,7 @@
 using Elastic.Channels.Buffers;
 using Elastic.Channels.Diagnostics;
 using Elastic.CommonSchema;
+using Elastic.CommonSchema.Serialization;
 using Elastic.CommonSchema.Serilog;
 using Elastic.Ingest.Elasticsearch;
 using Elastic.Ingest.Elasticsearch.CommonSchema;
@@ -137,10 +138,7 @@ public ElasticsearchSink(ElasticsearchSinkOptions<TEcsDocument> options)
 			{
 				DataStream = options.DataStream,
 				ExportMaxRetriesCallback = EmitExportFailures,
-				ExportExceptionCallback = _ =>
-				{
-
-				}
+				SerializerContext = EcsJsonContext.Default,
 			};
 			options.ConfigureChannel?.Invoke(channelOptions);
 			_channel = new EcsDataStreamChannel<TEcsDocument>(channelOptions, new [] { new SelfLogCallbackListener<TEcsDocument>(options)});
diff --git a/tests-integration/Elastic.Ingest.Elasticsearch.CommonSchema.IntegrationTests/DataStreamIngestionTests.cs b/tests-integration/Elastic.Ingest.Elasticsearch.CommonSchema.IntegrationTests/DataStreamIngestionTests.cs
@@ -6,6 +6,7 @@
 using Elastic.Channels;
 using Elastic.Clients.Elasticsearch.IndexManagement;
 using Elastic.CommonSchema;
+using Elastic.CommonSchema.Serialization;
 using Elastic.Ingest.Elasticsearch.DataStreams;
 using Elastic.Transport;
 using FluentAssertions;
@@ -32,6 +33,7 @@ public async Task EnsureDocumentsEndUpInDataStream()
 		{
 			DataStream = targetDataStream,
 			BufferOptions = new BufferOptions { WaitHandle = slim, OutboundBufferMaxSize = 1 },
+			SerializerContext = EcsJsonContext.Default,
 		};
 		var channel = new EcsDataStreamChannel<TimeSeriesDocument>(options);
 
@@ -80,7 +82,8 @@ public async Task UseCustomEventWriter()
 		{
 			DataStream = targetDataStream,
 			BufferOptions = new BufferOptions { WaitHandle = slim, OutboundBufferMaxSize = 1 },
-			EventWriter = new CustomEventWriter<TimeSeriesDocument>()
+			EventWriter = new CustomEventWriter<TimeSeriesDocument>(),
+			SerializerContext = EcsJsonContext.Default,
 		};
 		var channel = new EcsDataStreamChannel<TimeSeriesDocument>(options);
 
diff --git a/tests-integration/Elastic.Ingest.Elasticsearch.CommonSchema.IntegrationTests/IndexIngestionTests.cs b/tests-integration/Elastic.Ingest.Elasticsearch.CommonSchema.IntegrationTests/IndexIngestionTests.cs
diff --git a/tests-integration/Elasticsearch.IntegrationDefaults/Elasticsearch.IntegrationDefaults.csproj b/tests-integration/Elasticsearch.IntegrationDefaults/Elasticsearch.IntegrationDefaults.csproj
diff --git a/tools/Elastic.CommonSchema.Generator/Views/EcsJsonContext.Generated.cshtml b/tools/Elastic.CommonSchema.Generator/Views/EcsJsonContext.Generated.cshtml

Original file line number	Diff line number	Diff line change
`@@ -6,6 +6,7 @@`
`6`	`6`	`using System.Text.Encodings.Web;`
`7`	`7`	`using System.Text.Json;`
`8`	`8`	`using System.Text.Json.Serialization;`
	`9`	`+using System.Text.Json.Serialization.Metadata;`
`9`	`10`
`10`	`11`	`namespace Elastic.CommonSchema.Serialization`
`11`	`12`	`{`
`@@ -19,6 +20,7 @@ public static class EcsJsonConfiguration`
`19`	`20`	`NumberHandling = JsonNumberHandling.AllowNamedFloatingPointLiterals,`
`20`	`21`	`Encoder = JavaScriptEncoder.UnsafeRelaxedJsonEscaping,`
`21`	`22`	`PropertyNamingPolicy = new SnakeCaseJsonNamingPolicy(),`
	`23`	`+ TypeInfoResolver = JsonTypeInfoResolver.Combine(new DefaultJsonTypeInfoResolver(), EcsJsonContext.Default),`
`22`	`24`	`Converters =`
`23`	`25`	`{`
`24`	`26`	`new EcsDocumentJsonConverterFactory(),`
Original file line number	Diff line number	Diff line change
`@@ -57,29 +57,41 @@ internal partial class EcsEntityJsonConverter`
`57`	`57`	`private partial bool ReadProperty(ref Utf8JsonReader reader, string propertyName, Ecs ecsEvent, JsonSerializerOptions options) => false;`
`58`	`58`	`}`
`59`	`59`
`60`		`-internal partial class LogEntityJsonConverter`
	`60`	`+`
	`61`	`+/// intermediary parser objects, not meant for direct consumption`
	`62`	`+public class ParserIntermediary`
`61`	`63`	`{`
`62`		`- internal class LogFileOriginInvalid`
	`64`	`+ /// intermediary parser for log data in a different format`
	`65`	`+ public class LogFileOriginInvalid`
`63`	`66`	`{`
	`67`	`+ /// <inheritdoc cref="LogFieldSet.OriginFileName"/>`
`64`	`68`	`[JsonPropertyName("name"), DataMember(Name = "name")]`
`65`	`69`	`public string? Name { get; set; }`
`66`	`70`
	`71`	`+ /// <inheritdoc cref="LogFieldSet.OriginFileLine"/>`
`67`	`72`	`[JsonPropertyName("line"), DataMember(Name = "line")]`
`68`	`73`	`public int? Line { get; set; }`
`69`	`74`	`}`
`70`		`- internal class LogOriginInvalid`
	`75`	`+`
	`76`	`+ /// intermediary parser for log data in a different format`
	`77`	`+ public class LogOriginInvalid`
`71`	`78`	`{`
	`79`	`+ /// <inheritdoc cref="LogFieldSet.OriginFunction"/>`
`72`	`80`	`[JsonPropertyName("function"), DataMember(Name = "function")]`
`73`	`81`	`public string? Function { get; set; }`
`74`	`82`
	`83`	`+ /// <inheritdoc cref="LogFieldSet.FilePath"/>`
`75`	`84`	`[JsonPropertyName("file"), DataMember(Name = "file")]`
`76`	`85`	`public LogFileOriginInvalid? File { get; set; }`
`77`	`86`	`}`
	`87`	`+}`
`78`	`88`
	`89`	`+internal partial class LogEntityJsonConverter`
	`90`	`+{`
`79`	`91`	`private partial bool ReadProperty(ref Utf8JsonReader reader, string propertyName, Log ecsEvent, JsonSerializerOptions options) =>`
`80`	`92`	`propertyName switch`
`81`	`93`	`{`
`82`		`- "origin" => ReadProp<LogOriginInvalid>(ref reader, "origin", ecsEvent, (b, v) =>`
	`94`	`+ "origin" => ReadProp<ParserIntermediary.LogOriginInvalid>(ref reader, "origin", ecsEvent, (b, v) =>`
`83`	`95`	`{`
`84`	`96`	`if (v == null) return;`
`85`	`97`	`b.OriginFunction = v.Function;`
Original file line number	Diff line number	Diff line change
`@@ -81,4 +81,5 @@ protected override void WriteAdditionalProperties(Action<string, object> write)`
`81`	`81`	`if (Scopes != null) write(ScopesPropertyName, Scopes);`
`82`	`82`	`}`
`83`	`83`	`}`
	`84`	`+`
`84`	`85`	`}`