Merge pull request #219 from cnblogs/revert-217-use-mongodb-bson

Revert "refactor: use MongoDB.Bson instead of Newtonsoft.Json.Bson"

Author: cnblogs-dudu

src/Enyim.Caching/Enyim.Caching.csproj

@@ -20,11 +20,11 @@
 
   <ItemGroup>
       <FrameworkReference Include="Microsoft.AspNetCore.App" />
+      <PackageReference Include="Newtonsoft.Json.Bson" Version="1.0.2" />
   </ItemGroup>
 
   <ItemGroup>
     <PackageReference Include="MessagePack" Version="2.5.140" />
-    <PackageReference Include="MongoDB.Bson" Version="2.24.0" />
   </ItemGroup>
 
   <ItemGroup>

src/Enyim.Caching/Memcached/Transcoders/DataContractTranscoder.cs

@@ -1,10 +1,43 @@
+using System;
+using System.IO;
+using System.Runtime.Serialization;
+using System.Text;
+using Newtonsoft.Json;
+using Newtonsoft.Json.Bson;
+
 namespace Enyim.Caching.Memcached
 {
     /// <summary>
     /// Default <see cref="T:Enyim.Caching.Memcached.ITranscoder"/> implementation. Primitive types are manually serialized, the rest is serialized using <see cref="T:System.Runtime.Serialization.NetDataContractSerializer"/>.
     /// </summary>
     public class DataContractTranscoder : DefaultTranscoder
-    { }
+    {
+        protected override object DeserializeObject(ArraySegment<byte> value)
+        {
+            using (var ms = new MemoryStream(value.Array, value.Offset, value.Count))
+            {
+                using (var reader = new BsonDataReader(ms))
+                {
+                    JsonSerializer serializer = new JsonSerializer();
+                    return serializer.Deserialize(reader);
+                }
+            }
+        }
+
+        protected override ArraySegment<byte> SerializeObject(object value)
+        {
+            using (var ms = new MemoryStream())
+            {
+                using (var writer = new BsonDataWriter(ms))
+                {
+                    JsonSerializer serializer = new JsonSerializer();
+                    serializer.Serialize(writer, value);
+                }
+
+                return new ArraySegment<byte>(ms.ToArray(), 0, (int)ms.Length);
+            }
+        }
+    }
 }
 
 #region [ License information          ]

src/Enyim.Caching/Memcached/Transcoders/DefaultTranscoder.cs

@@ -1,7 +1,10 @@
-using MongoDB.Bson;
-using MongoDB.Bson.Serialization;
-using MongoDB.Bson.Serialization.Serializers;
+using Newtonsoft.Json;
+using Newtonsoft.Json.Bson;
 using System;
+using System.Collections;
+using System.IO;
+using System.Linq;
+using System.Reflection;
 using System.Text;
 
 namespace Enyim.Caching.Memcached
@@ -14,12 +17,6 @@ public class DefaultTranscoder : ITranscoder
         public const uint RawDataFlag = 0xfa52;
         private static readonly ArraySegment<byte> NullArray = new([]);
 
-        static DefaultTranscoder()
-        {
-            var objectSerializer = new ObjectSerializer(ObjectSerializer.AllAllowedTypes);
-            BsonSerializer.RegisterSerializer(objectSerializer);
-        }
-
         CacheItem ITranscoder.Serialize(object value)
         {
             return Serialize(value);
@@ -52,7 +49,14 @@ public virtual T Deserialize<T>(CacheItem item)
                 }
             }
 
-            return BsonSerializer.Deserialize<T>(item.Data.ToArray());
+            using var ms = new MemoryStream(item.Data.ToArray());
+            using var reader = new BsonDataReader(ms);
+            if (typeof(T).GetTypeInfo().ImplementedInterfaces.Contains(typeof(IEnumerable)))
+            {
+                reader.ReadRootValueAsArray = true;
+            }
+            var serializer = new JsonSerializer();
+            return serializer.Deserialize<T>(reader);
         }
 
         protected virtual CacheItem Serialize(object value)
@@ -257,8 +261,15 @@ protected virtual ArraySegment<byte> SerializeSingle(Single value)
 
         protected virtual ArraySegment<byte> SerializeObject(object value)
         {
-            var bson = value.ToBson();
-            return new ArraySegment<byte>(bson, 0, bson.Length);
+            using (var ms = new MemoryStream())
+            {
+                using (var writer = new BsonDataWriter(ms))
+                {
+                    var serializer = new JsonSerializer();
+                    serializer.Serialize(writer, value);
+                    return new ArraySegment<byte>(ms.ToArray(), 0, (int)ms.Length);
+                }
+            }
         }
 
         #endregion
@@ -336,7 +347,14 @@ protected virtual sbyte DeserializeSByte(ArraySegment<byte> data)
 
         protected virtual object DeserializeObject(ArraySegment<byte> value)
         {
-            return BsonSerializer.Deserialize<object>(value.Array);
+            using (var ms = new MemoryStream(value.Array, value.Offset, value.Count))
+            {
+                using (var reader = new BsonDataReader(ms))
+                {
+                    JsonSerializer serializer = new JsonSerializer();
+                    return serializer.Deserialize(reader);
+                }
+            }
         }
 
         #endregion

src/Enyim.Caching/Memcached/Transcoders/MessagePackTranscoder.cs

@@ -1,6 +1,16 @@
 using MessagePack;
 using MessagePack.Resolvers;
+using Microsoft.Extensions.Options;
+using Newtonsoft.Json.Bson;
+using Newtonsoft.Json.Linq;
 using System;
+using System.Collections;
+using System.Collections.Generic;
+using System.Collections.Immutable;
+using System.IO;
+using System.Reflection;
+using System.Runtime.CompilerServices;
+using System.Text;
 
 namespace Enyim.Caching.Memcached.Transcoders
 {