BREAKING: Update MongoDB provider with support for object derivatives

Fixes #552

src/persistence/Elsa.Persistence.MongoDb/Serializers/JsonSerializer.cs → src/persistence/Elsa.Persistence.MongoDb/Serializers/JObjectSerializer.cs

@@ -7,9 +7,9 @@
 
 namespace Elsa.Persistence.MongoDb.Serializers
 {
-    public class JsonSerializer : IBsonSerializer<JObject>
+    public class JObjectSerializer : IBsonSerializer<JObject>
     {
-        public static JsonSerializer Instance { get; } = new();
+        public static JObjectSerializer Instance { get; } = new();
 
         private readonly JsonSerializerSettings _serializerSettings = new JsonSerializerSettings
         {

src/persistence/Elsa.Persistence.MongoDb/Serializers/ObjectSerializer.cs

@@ -0,0 +1,37 @@
+using System;
+using MongoDB.Bson.Serialization;
+using Newtonsoft.Json;
+using Newtonsoft.Json.Linq;
+using NodaTime;
+using NodaTime.Serialization.JsonNet;
+
+namespace Elsa.Persistence.MongoDb.Serializers
+{
+    public class ObjectSerializer : IBsonSerializer<object>
+    {
+        public static ObjectSerializer Instance { get; } = new();
+
+        private readonly JsonSerializerSettings _serializerSettings = new JsonSerializerSettings
+        {
+            NullValueHandling = NullValueHandling.Ignore,
+            TypeNameAssemblyFormatHandling = TypeNameAssemblyFormatHandling.Simple,
+            TypeNameHandling = TypeNameHandling.Auto,
+        }.ConfigureForNodaTime(DateTimeZoneProviders.Tzdb);
+
+        public Type ValueType => typeof(object);
+
+        public void Serialize(BsonSerializationContext context, BsonSerializationArgs args, object value)
+        {
+            var json = JsonConvert.SerializeObject(value, _serializerSettings);
+            context.Writer.WriteString(json);
+        }
+
+        object IBsonSerializer.Deserialize(BsonDeserializationContext context, BsonDeserializationArgs args) => Deserialize(context, args);
+
+        public object Deserialize(BsonDeserializationContext context, BsonDeserializationArgs args)
+        {
+            var text = context.Reader.ReadString();
+            return JsonConvert.DeserializeObject<object>(text, _serializerSettings)!;
+        }
+    }
+}

src/persistence/Elsa.Persistence.MongoDb/Services/DatabaseRegister.cs

@@ -6,15 +6,15 @@
 
 namespace Elsa.Persistence.MongoDb.Services
 {
-    public static class DatabaseRegister 
-    {        
+    public static class DatabaseRegister
+    {
         public static void RegisterMapsAndSerializers()
         {
             // In unit tests, the method is called several times, which throws an exception because the entity is already registered
             // If an error is thrown, the remaining registrations are no longer processed
             var firstPass = Map();
-            
-            if(firstPass == false)
+
+            if (firstPass == false)
                 return;
 
             RegisterSerializers();
@@ -33,18 +33,13 @@ private static bool Map()
                     cm.MapIdProperty(x => x.Id);
                 });
 
-                BsonClassMap.RegisterClassMap<WorkflowDefinition>(cm =>
-                {
-                    cm.AutoMap();                  
-                });
-
-                BsonClassMap.RegisterClassMap<WorkflowInstance>(cm =>
-                {
-                    cm.AutoMap();                   
-                });
-
+                BsonClassMap.RegisterClassMap<WorkflowDefinition>(cm => cm.AutoMap());
+                BsonClassMap.RegisterClassMap<WorkflowInstance>(cm => cm.AutoMap());
+                BsonClassMap.RegisterClassMap<Bookmark>(cm => cm.AutoMap());
+                BsonClassMap.RegisterClassMap<WorkflowExecutionLogRecord>(cm => cm.AutoMap());
             }
-            catch (Exception) {
+            catch (Exception)
+            {
                 return false;
             }
 
@@ -53,8 +48,9 @@ private static bool Map()
 
         private static void RegisterSerializers()
         {
-            BsonSerializer.RegisterSerializer(JsonSerializer.Instance);
+            BsonSerializer.RegisterSerializer(JObjectSerializer.Instance);
+            BsonSerializer.RegisterSerializer(ObjectSerializer.Instance);
             BsonSerializer.RegisterSerializer(new InstantSerializer());
         }
     }
-}
+}