[DEVEX-222] Added the MessageTypeResolutionStrategyWrapper for caching resolved types

Author: oskardudycz

src/Kurrent.Client/Core/Serialization/MessageTypeResolutionStrategy.cs

@@ -14,12 +14,14 @@ public interface IMessageTypeResolutionStrategy {
 #endif
 }
 
-public class DefaultMessageTypeResolutionStrategy(IMessageTypeMapper messageTypeMapper)
-	: IMessageTypeResolutionStrategy {
+public class MessageTypeResolutionStrategyWrapper(
+	IMessageTypeMapper messageTypeMapper,
+	IMessageTypeResolutionStrategy messageTypeResolutionStrategy
+) : IMessageTypeResolutionStrategy {
 	public string ResolveTypeName(object messageData) {
 		return messageTypeMapper.GetOrAddTypeName(
 			messageData.GetType(),
-			clrType => clrType.FullName!
+			_ => messageTypeResolutionStrategy.ResolveTypeName(messageData)
 		);
 	}
 
@@ -30,18 +32,36 @@ public bool TryResolveClrType(EventRecord messageRecord, [NotNullWhen(true)] out
 #endif
 		type = messageTypeMapper.GetOrAddClrType(
 			messageRecord.EventType,
-			_ => {
-				var serializationMetadata = messageRecord.Metadata.ExtractSerializationMetadata();
+			_ => messageTypeResolutionStrategy.TryResolveClrType(messageRecord, out var resolvedType)
+				? resolvedType
+				: null
+		);
+
+		return type != null;
+	}
+}
 
-				if (!serializationMetadata.IsValid)
-					return null;
+public class DefaultMessageTypeResolutionStrategy
+	: IMessageTypeResolutionStrategy {
+	public string ResolveTypeName(object messageData) =>
+		messageData.GetType().FullName!;
 
-				return Type.GetType(
-					serializationMetadata.MessageTypeAssemblyQualifiedName
-				 ?? serializationMetadata.MessageTypeClrTypeName!
-				);
-			}
-		);
+#if NET48
+	public bool TryResolveClrType(EventRecord messageRecord, out Type? type) {
+#else
+	public bool TryResolveClrType(EventRecord messageRecord, [NotNullWhen(true)] out Type? type) {
+#endif
+		var serializationMetadata = messageRecord.Metadata.ExtractSerializationMetadata();
+
+		if (!serializationMetadata.IsValid) {
+			type = null;
+			return false;
+		}
+
+		type = Type.GetType(serializationMetadata.MessageTypeAssemblyQualifiedName!)
+		    ?? TypeProvider.GetFirstMatchingTypeFromCurrentDomainAssembly(
+			       serializationMetadata.MessageTypeClrTypeName!
+		       );
 
 		return type != null;
 	}

src/Kurrent.Client/Core/Serialization/SchemaRegistry.cs

@@ -39,8 +39,10 @@ public static SchemaRegistry From(KurrentClientSerializationSettings settings) {
 		var jsonSerializer  = settings.JsonSerializer ?? new SystemTextJsonSerializer();
 		var bytesSerializer = settings.BytesSerializer ?? new SystemTextJsonSerializer();
 
-		var messageTypeResolutionStrategy =
-			settings.MessageTypeResolutionStrategy ?? new DefaultMessageTypeResolutionStrategy(MessageTypeMapper.Instance);
+		var messageTypeResolutionStrategy = new MessageTypeResolutionStrategyWrapper(
+			MessageTypeMapper.Instance,
+			settings.MessageTypeResolutionStrategy ?? new DefaultMessageTypeResolutionStrategy()
+		);
 
 		var serializers = new Dictionary<ContentType, MessageSerializer> {
 			{