Add session timeout parameter for redis

Author: sjuarezgx

dotnet/src/dotnetcore/GxClasses/Services/Session/GXSessionFactory.cs

@@ -15,14 +15,15 @@ public class GXSessionServiceFactory
 		static string SESSION_PASSWORD = "SESSION_PROVIDER_PASSWORD";
 		static string SESSION_SCHEMA = "SESSION_PROVIDER_SCHEMA";
 		static string SESSION_TABLE_NAME = "SESSION_PROVIDER_TABLE_NAME";
+		static string SESSION_TIMEOUT = "SESSION_PROVIDER_SESSION_TIMEOUT";
 		public static ISessionService GetProvider()
 		{
 			var instance = GXServices.Instance?.Get(GXServices.SESSION_SERVICE);
 			if (instance != null)
 			{
 				if (instance.Name.Equals(REDIS, StringComparison.OrdinalIgnoreCase))
 				{
-					return new GxRedisSession(instance.Properties.Get(SESSION_ADDRESS), CryptoImpl.Decrypt(instance.Properties.Get(SESSION_PASSWORD)), instance.Properties.Get(SESSION_INSTANCE));
+					return new GxRedisSession(instance.Properties.Get(SESSION_ADDRESS), CryptoImpl.Decrypt(instance.Properties.Get(SESSION_PASSWORD)), instance.Properties.Get(SESSION_INSTANCE), int.Parse(instance.Properties.Get(SESSION_TIMEOUT)));
 				}
 				else if (instance.Name.Equals(DATABASE, StringComparison.OrdinalIgnoreCase))
 				{
@@ -36,17 +37,19 @@ public static ISessionService GetProvider()
 	}
 	public class GxRedisSession : ISessionService
 	{
-		public GxRedisSession(string host, string password, string instanceName)
+		public GxRedisSession(string host, string password, string instanceName, int sessionTimeout)
 		{
 			ConnectionString = $"{host}";
 			if (!string.IsNullOrEmpty(password))
 			{
 				ConnectionString += $",password={password}";
 			}
 			InstanceName = instanceName;
+			SessionTimeout = sessionTimeout;
 		}
 		public string ConnectionString { get; }
 		public string InstanceName { get; }
+		public int SessionTimeout { get; }
 
 		public string Schema => throw new NotImplementedException();
 
@@ -71,6 +74,8 @@ public GxDatabaseSession(string host, string password, string schema, string tab
 		public string TableName { get; }
 
 		public string InstanceName => throw new NotImplementedException();
+
+		public int SessionTimeout => throw new NotImplementedException();
 	}
 
 	public interface ISessionService
@@ -79,5 +84,6 @@ public interface ISessionService
 		string Schema { get; }
 		string TableName { get; }
 		string InstanceName { get; }
+		int SessionTimeout { get; }
 	}
 }

dotnet/src/dotnetframework/Providers/Cache/GxRedis/GxRedis.cs

@@ -21,12 +21,19 @@ public sealed class Redis : ICacheService2
 		IDatabase _redisDatabase;
 		ConfigurationOptions _redisConnectionOptions;
 		private const int REDIS_DEFAULT_PORT = 6379;
-
+		public int redisSessionTimeout;
 		public Redis(string connectionString)
 		{
 			_redisConnectionOptions = ConfigurationOptions.Parse(connectionString);
 			_redisConnectionOptions.AllowAdmin = true;
 		}
+
+		public Redis(string connectionString, int sessionTimeout)
+		{
+			_redisConnectionOptions = ConfigurationOptions.Parse(connectionString);
+			_redisConnectionOptions.AllowAdmin = true;
+			redisSessionTimeout = sessionTimeout;
+		}
 		public Redis()
 		{
 			GXService providerService = ServiceFactory.GetGXServices().Get(GXServices.CACHE_SERVICE);

dotnet/src/extensions/Azure/Handlers/HttpHandler/HttpTriggerHandler.cs

@@ -96,7 +96,10 @@ public void Remove(string key)
 
 		public void Set(string key, byte[] value)
 		{
-			_redis.Set(Id, key, value, AZURE_SESSION_TIMEOUT_IN_MINUTES); 
+			if (_redis.redisSessionTimeout != 0)
+				_redis.Set(Id, key, value, _redis.redisSessionTimeout);
+			else
+				_redis.Set(Id, key, value, AZURE_SESSION_TIMEOUT_IN_MINUTES);
 		}
 
 		public bool TryGetValue(string key, out byte[] value)

dotnet/src/extensions/Azure/Handlers/Program.cs

@@ -35,12 +35,9 @@ static async Task Main()
 				.ConfigureServices(services =>
 				{
 					ISessionService sessionService = GXSessionServiceFactory.GetProvider();
-					string connectionString = "";
 					if (sessionService is GxRedisSession)
 					{ 
-						connectionString = sessionService.ConnectionString;
-						services.AddSingleton<ICacheService2>(x => new Redis(connectionString));
-						//ConnectionMultiplexer.SetFeatureFlag("preventthreadtheft", true);
+						services.AddSingleton<ICacheService2>(x => new Redis(sessionService.ConnectionString, sessionService.SessionTimeout));
 					}
 					else
 						services.AddSingleton<ICacheService2>(x => new InProcessCache());