SemianiakaVY/elsa-core
1
0
Fork 0
Code Issues Pull requests Actions 1 Packages Projects Releases Wiki Activity

issues(4893): try register serializer or skip when already registred 8d23d6

Browse source 
issues(4893): try register serializer or skip when already registred  + clean
This commit is contained in:
BEN AMEUR 2024-02-07 12:45:00 +01:00 committed by Sipke Schoorstra
parent 8d23d695df
commit e64a2eaa17
1 changed files with 17 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
src/modules/Elsa.MongoDb/Features/MongoDbFeature.cs
View file

@ -48,16 +48,16 @@ public class MongoDbFeature : FeatureBase
private static void RegisterSerializers()
{
BsonSerializer.TryRegisterSerializer(typeof(object), new PolymorphicSerializer());
BsonSerializer.TryRegisterSerializer(typeof(Type), new TypeSerializer());
BsonSerializer.TryRegisterSerializer(typeof(Variable), new VariableSerializer());
BsonSerializer.TryRegisterSerializer(typeof(Version), new VersionSerializer());
BsonSerializer.TryRegisterSerializer(typeof(JsonElement), new JsonElementSerializer());
TryRegisterSerializerOrSkipWhenExist(typeof(object), new PolymorphicSerializer());
TryRegisterSerializerOrSkipWhenExist(typeof(Type), new TypeSerializer());
TryRegisterSerializerOrSkipWhenExist(typeof(Variable), new VariableSerializer());
TryRegisterSerializerOrSkipWhenExist(typeof(Version), new VersionSerializer());
TryRegisterSerializerOrSkipWhenExist(typeof(JsonElement), new JsonElementSerializer());
}
private static void RegisterClassMaps()
{
BsonClassMap.RegisterClassMap<StoredBookmark>(cm =>
BsonClassMap.TryRegisterClassMap<StoredBookmark>(cm =>
{
cm.AutoMap(); // Automatically map other properties
cm
@ -66,6 +66,17 @@ public class MongoDbFeature : FeatureBase
});
}
private static void TryRegisterSerializerOrSkipWhenExist(Type type, IBsonSerializer serializer)
{
try
{
BsonSerializer.TryRegisterSerializer(type, serializer);
}
catch (BsonSerializationException ex)
{
}
}
private static IMongoDatabase CreateDatabase(IServiceProvider sp, string connectionString)
{
var options = sp.GetRequiredService<IOptions<MongoDbOptions>>().Value;