feat(state store): refactor di activator (#26)

Co-authored-by: Jonathan Sant <jonathan.sant@live.co.uk>

Orleans.Persistence.Redis/Config/RedisSiloHostBuilderExtensions.cs

@@ -108,30 +108,23 @@ private static IGrainStorage CreateRedisStorage(IServiceProvider services, strin
 		return ActivatorUtilities.CreateInstance<RedisGrainStorage>(services, name, store, connection);
 	}
 
-	private static IGrainStateStore CreateStateStore(IServiceProvider provider, string name)
-	{
-		var connection = provider.GetRequiredServiceByName<DbConnection>(name);
-		var serializer = provider.GetRequiredServiceByName<ISerializer>(name);
-		var humanReadableSerializer = provider.GetServiceByName<IHumanReadableSerializer>(name);
-		var options = provider.GetRequiredService<IOptionsSnapshot<RedisStorageOptions>>();
-		var compress = provider.GetServiceByName<ICompression>(name);
-
-		if (compress != null)
-			return ActivatorUtilities.CreateInstance<GrainStateStore>(
-				provider,
+  private static IGrainStateStore CreateStateStore(IServiceProvider provider, string name)
+  {
+			var connection = provider.GetRequiredServiceByName<DbConnection>(name);
+			var serializer = provider.GetRequiredServiceByName<ISerializer>(name);
+			var humanReadableSerializer = provider.GetServiceByName<IHumanReadableSerializer>(name);
+			var options = provider.GetRequiredService<IOptionsSnapshot<RedisStorageOptions>>();
+			var logger = provider.GetRequiredService<ILogger<GrainStateStore>>();
+
+		return ActivatorUtilities.CreateInstance<GrainStateStore>(
+			provider,
+				name,
 				connection,
 				options.Get(name),
 				serializer,
 				humanReadableSerializer,
-				compress
-			);
-
-		return ActivatorUtilities.CreateInstance<GrainStateStore>(
-			provider,
-			connection,
-			options.Get(name),
-			serializer,
-			humanReadableSerializer
+				logger,
+				provider
 		);
 	}
 

Orleans.Persistence.Redis/Core/GrainStateStore.cs

@@ -4,6 +4,7 @@
 using Orleans.Persistence.Redis.Config;
 using Orleans.Persistence.Redis.Serialization;
 using Orleans.Persistence.Redis.Utils;
+using Orleans.Runtime;
 using Orleans.Storage;
 using StackExchange.Redis;
 using System;
@@ -30,30 +31,21 @@ internal class GrainStateStore : IGrainStateStore
 		private readonly ICompression _compression;
 
 		public GrainStateStore(
-			DbConnection connection,
-			RedisStorageOptions options,
-			ISerializer serializer,
-			IHumanReadableSerializer humanReadableSerializer,
-			ILogger<GrainStateStore> logger
-		) : this(connection, options, serializer, humanReadableSerializer, logger, null)
-		{
-		}
-
-		public GrainStateStore(
+			string name,
 			DbConnection connection,
 			RedisStorageOptions options,
 			ISerializer serializer,
 			IHumanReadableSerializer humanReadableSerializer,
 			ILogger<GrainStateStore> logger,
-			ICompression compression
+			IServiceProvider services
 		)
 		{
 			_connection = connection;
 			_serializer = serializer;
 			_humanReadableSerializer = humanReadableSerializer;
 			_logger = logger;
 			_options = options;
-			_compression = compression;
+			_compression = services.GetServiceByName<ICompression>(name);
 		}
 
 		public async Task<IGrainState<T>> GetGrainState<T>(string grainId, Type stateType)

package.json

@@ -1,6 +1,6 @@
 {
   "name": "sucrose.orleans.persistence.redis",
-  "version": "2.2.0",
+  "version": "2.2.1",
   "description": "Orleans Redis Persistence Provider",
   "solution": "Orleans.Persistence.Redis-build.sln",
   "dependencies": {},