Added new types managed from serdes (#80)

src/net/KEFCore/Storage/Internal/EntityTypeDataStorage.cs

@@ -0,0 +1,174 @@
+/*
+* Copyright 2023 MASES s.r.l.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+* Refer to LICENSE for more information.
+*/
+
+#nullable enable
+
+using System.Text.Json;
+using System.Text.Json.Serialization;
+
+namespace MASES.EntityFrameworkCore.KNet.Storage.Internal;
+
+/// <summary>
+/// This is an internal API that supports the Entity Framework Core infrastructure and not subject to
+/// the same compatibility standards as public APIs. It may be changed or removed without notice in
+/// any release. You should only use it directly in your code with extreme caution and knowing that
+/// doing so can result in application failures when updating to a new Entity Framework Core release.
+/// </summary>
+[JsonSerializable(typeof(ObjectType))]
+public class ObjectType : IJsonOnDeserialized
+{
+ public ObjectType()
+ {
+
+ }
+
+ public ObjectType(IProperty typeName, object value)
+ {
+ TypeName = typeName.ClrType?.FullName;
+ PropertyName = typeName.Name;
+ Value = value;
+ }
+
+ public void OnDeserialized()
+ {
+ if (Value is JsonElement elem)
+ {
+ switch (elem.ValueKind)
+ {
+ case JsonValueKind.String:
+ Value = elem.GetString()!;
+ if (TypeName != typeof(string).FullName)
+ {
+ try
+ {
+ Value = Convert.ChangeType(Value, Type.GetType(TypeName!)!);
+ }
+ catch (InvalidCastException)
+ {
+ // failed conversion, try with other methods for known types
+ if (TypeName == typeof(Guid).FullName)
+ {
+ Value = elem.GetGuid();
+ }
+ else if (TypeName == typeof(DateTime).FullName)
+ {
+ Value = elem.GetDateTime();
+ }
+ else if (TypeName == typeof(DateTimeOffset).FullName)
+ {
+ Value = elem.GetDateTimeOffset();
+ }
+ else
+ {
+ Value = elem.GetString()!;
+ }
+ }
+ }
+ break;
+ case JsonValueKind.Number:
+ var tmp = elem.GetInt64();
+ Value = Convert.ChangeType(tmp, Type.GetType(TypeName!)!);
+ break;
+ case JsonValueKind.True:
+ Value = true;
+ break;
+ case JsonValueKind.False:
+ Value = false;
+ break;
+ case JsonValueKind.Null:
+ Value = null;
+ break;
+ case JsonValueKind.Object:
+ case JsonValueKind.Array:
+ case JsonValueKind.Undefined:
+ default:
+ throw new InvalidOperationException($"Failed to deserialize {PropertyName}, ValueKind is {elem.ValueKind}");
+ }
+ }
+ else
+ {
+ Value = Convert.ChangeType(Value, Type.GetType(TypeName!)!);
+ }
+ }
+
+ public string? TypeName { get; set; }
+
+ public string? PropertyName { get; set; }
+
+ public object Value { get; set; }
+}
+
+/// <summary>
+/// This is an internal API that supports the Entity Framework Core infrastructure and not subject to
+/// the same compatibility standards as public APIs. It may be changed or removed without notice in
+/// any release. You should only use it directly in your code with extreme caution and knowing that
+/// doing so can result in application failures when updating to a new Entity Framework Core release.
+/// </summary>
+[JsonSerializable(typeof(EntityTypeDataStorage<>))]
+public class EntityTypeDataStorage<TKey> : IEntityTypeData
+{
+ public EntityTypeDataStorage() { }
+
+ public EntityTypeDataStorage(IEntityType tName, IProperty[] properties, object[] rData)
+ {
+ TypeName = tName.Name;
+ Data = new Dictionary<int, ObjectType>();
+ for (int i = 0; i < properties.Length; i++)
+ {
+ Data.Add(properties[i].GetIndex(), new ObjectType(properties[i], rData[i]));
+ }
+ }
+
+ public string TypeName { get; set; }
+
+ public Dictionary<int, ObjectType> Data { get; set; }
+
+ public void GetData(IEntityType tName, ref object[] array)
+ {
+#if DEBUG_PERFORMANCE
+ Stopwatch fullSw = new Stopwatch();
+ Stopwatch newSw = new Stopwatch();
+ Stopwatch iterationSw = new Stopwatch();
+ try
+ {
+ fullSw.Start();
+#endif
+ if (Data == null) { return; }
+#if DEBUG_PERFORMANCE
+ newSw.Start();
+#endif
+ array = new object[Data.Count];
+#if DEBUG_PERFORMANCE
+ newSw.Stop();
+ iterationSw.Start();
+#endif
+ for (int i = 0; i < Data.Count; i++)
+ {
+ array[i] = Data[i].Value;
+ }
+#if DEBUG_PERFORMANCE
+ iterationSw.Stop();
+ fullSw.Stop();
+ }
+ finally
+ {
+ Trace.WriteLine($"Time to GetData with length {Data.Count}: {fullSw.Elapsed} - new array took: {newSw.Elapsed} - Iteration took: {iterationSw.Elapsed}");
+ }
+#endif
+ }
+}