Add new redisConnection filters

Author: mythz

build/build.bat

@@ -1,5 +1,7 @@
 SET MSBUILD="C:\Program Files (x86)\Microsoft Visual Studio\2017\Community\MSBuild\15.0\Bin\MSBuild.exe"
 
-%MSBUILD% build-core.proj /target:TeamCityBuild;NuGetPack /property:Configuration=Release;PatchVersion=41
-%MSBUILD% build.proj /target:TeamCityBuild;NuGetPack /property:Configuration=Release;PatchVersion=9
+REM %MSBUILD% build-core.proj /target:TeamCityBuild;NuGetPack /property:Configuration=Release;PatchVersion=41
+REM %MSBUILD% build.proj /target:TeamCityBuild;NuGetPack /property:Configuration=Release;PatchVersion=9
 REM %MSBUILD% build-sn.proj /target:NuGetPack /property:Configuration=Signed;PatchVersion=9
+
+msbuild /p:Configuration=Release ..\src\ServiceStack.Redis.sln

src/ServiceStack.Redis/TemplateRedisFilters.cs

@@ -23,16 +23,20 @@ public class RedisSearchResult
 
     public class TemplateRedisFilters : TemplateFilter
     {
-        public IRedisClientsManager RedisManager { get; set; }
-        public IAppSettings AppSettings { get; set; }
+        private IRedisClientsManager redisManager;
+        public IRedisClientsManager RedisManager
+        {
+            get => redisManager ?? (redisManager = Context.Container.Resolve<IRedisClientsManager>());
+            set => redisManager = value;
+        }
 
         T exec<T>(Func<IRedisClient, T> fn, TemplateScopeContext scope, object options)
         {
             try
             {
-                using (var db = RedisManager.GetClient())
+                using (var redis = RedisManager.GetClient())
                 {
-                    return fn(db);
+                    return fn(redis);
                 }
             }
             catch (Exception ex)
@@ -134,6 +138,54 @@ public List<RedisSearchResult> redisSearchKeys(TemplateScopeContext scope, strin
             return searchResults.Results;
         }
 
+        public string redisConnectionString(TemplateScopeContext scope) => exec(r => $"{r.Host}:{r.Port}?db={r.Db}", scope, null);
+
+        public string redisToConnectionString(TemplateScopeContext scope, object connectionInfo) => redisToConnectionString(scope, connectionInfo, null);
+        public string redisToConnectionString(TemplateScopeContext scope, object connectionInfo, object options)
+        {
+            var connectionString = connectionInfo as string;
+            if (connectionString != null)
+                return connectionString;
+
+            if (connectionInfo is IDictionary<string, object> d)
+            {
+                var host = (d.TryGetValue("host", out object h) ? h as string : null) ?? "localhost";
+                var port = d.TryGetValue("port", out object p) ? DynamicInt.Instance.ConvertFrom(p) : 6379;
+                var db = d.TryGetValue("db", out object oDb) ? DynamicInt.Instance.ConvertFrom(oDb) : 0;
+
+                connectionString = $"{host}:{port}?db={db}";
+
+                if (d.TryGetValue("password", out object password))
+                    connectionString += "&password=" + password.ToString().UrlEncode();
+            }
+
+            return connectionString;
+        }
+
+        public string redisChangeConnection(TemplateScopeContext scope, object newConnection) => redisChangeConnection(scope, newConnection, null);
+        public string redisChangeConnection(TemplateScopeContext scope, object newConnection, object options)
+        {
+            try
+            {
+                var connectionString = redisToConnectionString(scope, newConnection, options);
+                if (connectionString == null)
+                    throw new NotSupportedException(nameof(redisChangeConnection) + " expects a String or an ObjectDictionary but received: " + (newConnection?.GetType().Name ?? "null"));
+
+                using (var testConnection = new RedisClient(connectionString))
+                {
+                    testConnection.Ping();
+                }
+
+                ((IRedisFailover)RedisManager).FailoverTo(connectionString);
+
+                return connectionString;
+            }
+            catch (Exception ex)
+            {
+                throw new StopFilterExecutionException(scope, options ?? newConnection as IDictionary<string,object>, ex);
+            }
+        }
+
         public string redisSearchKeysAsJson(TemplateScopeContext scope, string query, object options)
         {
             if (string.IsNullOrEmpty(query))

tests/ServiceStack.Redis.Tests/RedisTemplateTests.cs

@@ -0,0 +1,46 @@
+using NUnit.Framework;
+using ServiceStack.Templates;
+
+namespace ServiceStack.Redis.Tests
+{
+    class RedisTemplateTests
+    {
+        [Test]
+        public void Does_build_connection_string()
+        {
+            var context = new TemplateContext
+            {
+                TemplateFilters = { new TemplateRedisFilters() }
+            };
+            context.Container.AddSingleton<IRedisClientsManager>(() => new RedisManagerPool());
+            context.Init();
+
+            Assert.That(context.EvaluateTemplate("{{ redisToConnectionString: host:7000?db=1 }}"),
+                Is.EqualTo("host:7000?db=1"));
+
+            Assert.That(context.EvaluateTemplate("{{ { host: 'host' } | redisToConnectionString }}"),
+                Is.EqualTo("host:6379?db=0"));
+
+            Assert.That(context.EvaluateTemplate("{{ { port: 7000 } | redisToConnectionString }}"),
+                Is.EqualTo("localhost:7000?db=0"));
+
+            Assert.That(context.EvaluateTemplate("{{ { db: 1 } | redisToConnectionString }}"),
+                Is.EqualTo("localhost:6379?db=1"));
+
+            Assert.That(context.EvaluateTemplate("{{ { host: 'host', port: 7000, db: 1 } | redisToConnectionString }}"),
+                Is.EqualTo("host:7000?db=1"));
+
+            Assert.That(context.EvaluateTemplate("{{ { host: 'host', port: 7000, db: 1, password:'secret' } | redisToConnectionString | raw }}"),
+                Is.EqualTo("host:7000?db=1&password=secret"));
+
+            Assert.That(context.EvaluateTemplate("{{ redisConnectionString }}"),
+                Is.EqualTo("localhost:6379?db=0"));
+
+            Assert.That(context.EvaluateTemplate("{{ { db: 1 } | redisChangeConnection }}"),
+                Is.EqualTo("localhost:6379?db=1"));
+
+            Assert.That(context.EvaluateTemplate("{{ redisConnectionString }}"),
+                Is.EqualTo("localhost:6379?db=1"));
+        }
+    }
+}