(GH-665) Add json serializer settings to couchbase caching provider

Author: johelvisguzman

src/DotNetToolkit.Repository.Caching.Couchbase/CouchbaseCacheOptions.cs

@@ -1,5 +1,6 @@
 namespace DotNetToolkit.Repository.Caching.Couchbase
 {
+    using global::Couchbase.Core.Serialization;
     using JetBrains.Annotations;
     using System;
     using Utility;
@@ -14,6 +15,7 @@ public class CouchbaseCacheOptions
         private string _username;
         private string _password;
         private TimeSpan? _expiry;
+        private Func<ITypeSerializer> _serializer;
 
         /// <summary>
         /// Gets the host.
@@ -40,6 +42,11 @@ public class CouchbaseCacheOptions
         /// </summary>
         public TimeSpan? Expiry { get { return _expiry; } }
 
+        /// <summary>
+        /// Gets the serializer.
+        /// </summary>
+        public Func<ITypeSerializer> Serializer { get { return _serializer; } }
+
         /// <summary>
         /// Adds the giving bucketname to the options.
         /// </summary>
@@ -90,7 +97,7 @@ public CouchbaseCacheOptions WithEndPoint([NotNull] string host, int port)
         /// <summary>
         /// Adds the giving endpoint to the options.
         /// </summary>
-        /// <param name="hostAndPort">The host and port to be added.</param>
+        /// <param name="hostAndPort">The address and the port of the server in the format 'host:port' to be added.</param>
         public CouchbaseCacheOptions WithEndPoint([NotNull] string hostAndPort)
         {
             _host = Guard.NotEmpty(hostAndPort, nameof(hostAndPort));
@@ -108,5 +115,17 @@ public CouchbaseCacheOptions WithExpiry([NotNull] TimeSpan expiry)
 
             return this;
         }
+
+        /// <summary>
+        /// Adds the giving json serializer settings to the options.
+        /// </summary>
+        /// <param name="serializer">The serializer to be added.</param>
+        /// <returns>The new options instance with the given json serializer settings added.</returns>
+        public CouchbaseCacheOptions WithSerializer([NotNull] Func<ITypeSerializer> serializer)
+        {
+            _serializer = Guard.NotNull(serializer, nameof(serializer));
+
+            return this;
+        }
     }
 }

src/DotNetToolkit.Repository.Caching.Couchbase/CouchbaseCacheProvider.cs renamed to src/DotNetToolkit.Repository.Caching.Couchbase/Internal/CouchbaseCacheProvider.cs

@@ -1,8 +1,10 @@
-namespace DotNetToolkit.Repository.Caching.Couchbase
+namespace DotNetToolkit.Repository.Caching.Couchbase.Internal
 {
     using Configuration.Caching;
     using global::Couchbase;
     using global::Couchbase.Configuration.Client;
+    using global::Couchbase.Core.Serialization;
+    using Newtonsoft.Json;
     using System;
     using System.Collections.Generic;
     using Utility;
@@ -24,8 +26,8 @@ internal class CouchbaseCacheProvider : ICacheProvider
 
         #region Constructors
 
-        public CouchbaseCacheProvider(string host, string bucketName, string username, string password, TimeSpan? expiry)
-            : this(GetConfigurationOptions(host, bucketName, username, password), expiry) { }
+        public CouchbaseCacheProvider(string host, string bucketName, string username, string password, TimeSpan? expiry, Func<ITypeSerializer> serializer)
+            : this(GetConfigurationOptions(host, bucketName, username, password, serializer), expiry) { }
 
         private CouchbaseCacheProvider(ClientConfiguration config, TimeSpan? expiry)
         {
@@ -37,7 +39,7 @@ private CouchbaseCacheProvider(ClientConfiguration config, TimeSpan? expiry)
 
         #region Private Methods
 
-        private static ClientConfiguration GetConfigurationOptions(string host, string username, string password, string bucketName)
+        private static ClientConfiguration GetConfigurationOptions(string host, string username, string password, string bucketName, Func<ITypeSerializer> serializer)
         {
             var config = new ClientConfiguration();
             var bucket = !string.IsNullOrEmpty(bucketName) ? bucketName : DefaultBucketName;
@@ -61,6 +63,11 @@ private static ClientConfiguration GetConfigurationOptions(string host, string u
                 }
             };
 
+            if (serializer != null)
+            {
+                config.Serializer = serializer;
+            }
+
             return config;
         }
 

src/DotNetToolkit.Repository.Caching.Couchbase/RepositoryOptionsBuilderExtensions.cs

@@ -1,6 +1,7 @@
 namespace DotNetToolkit.Repository.Caching.Couchbase
 {
     using Configuration.Options;
+    using Internal;
     using JetBrains.Annotations;
     using System;
     using Utility;
@@ -30,7 +31,8 @@ public static RepositoryOptionsBuilder UseCouchbase([NotNull] this RepositoryOpt
                 options.BucketName,
                 options.Username,
                 options.Password,
-                options.Expiry);
+                options.Expiry,
+                options.Serializer);
 
             source.UseCachingProvider(provider);