Add support for GeoAdd + GeoPos

Author: mythz

src/ServiceStack.Redis/Commands.cs

@@ -211,5 +211,13 @@ public static class Commands
         public readonly static byte[] Slaves = "slaves".ToUtf8Bytes();
         public readonly static byte[] Failover = "failover".ToUtf8Bytes();
         public readonly static byte[] GetMasterAddrByName = "get-master-addr-by-name".ToUtf8Bytes();
+
+        //Geo commands
+        public readonly static byte[] GeoAdd = "GEOADD".ToUtf8Bytes();
+        public readonly static byte[] GeoDist = "GEODIST".ToUtf8Bytes();
+        public readonly static byte[] GeoHash = "GEOHASH".ToUtf8Bytes();
+        public readonly static byte[] GeoPos = "GEOPOS".ToUtf8Bytes();
+        public readonly static byte[] GeoRadius = "GEORADIUS".ToUtf8Bytes();
+        public readonly static byte[] GeoRadiusByMember = "GEORADIUSBYMEMBER".ToUtf8Bytes();
     }
 }

src/ServiceStack.Redis/RedisNativeClient.cs

@@ -2201,6 +2201,67 @@ public RedisPipelineCommand CreatePipelineCommand()
 
         #endregion
 
+        #region GEO Operations
+
+        public long GeoAdd(string key, double longitude, double latitude, string member)
+        {
+            if (key == null)
+                throw new ArgumentNullException("key");
+            if (key == null)
+                throw new ArgumentNullException("member");
+
+            return SendExpectLong(Commands.GeoAdd, key.ToUtf8Bytes(), longitude.ToUtf8Bytes(), latitude.ToUtf8Bytes(), member.ToUtf8Bytes());
+        }
+
+        public long GeoAdd(string key, RedisGeo[] geoPoints)
+        {
+            throw new NotImplementedException();
+        }
+
+        public double GeoDist(string key, string fromMember, string toMember, string unit = null)
+        {
+            throw new NotImplementedException();
+        }
+
+        public byte[][] GeoHash(string key, params string[] members)
+        {
+            throw new NotImplementedException();
+        }
+
+        public List<RedisGeo> GeoPos(string key, params string[] members)
+        {
+            var cmdWithArgs = MergeCommandWithArgs(Commands.GeoPos, key.ToUtf8Bytes(), members.Map(x => x.ToUtf8Bytes()).ToArray());
+            var data = SendExpectComplexResponse(cmdWithArgs);
+            var to = new List<RedisGeo>();
+
+            for (var i = 0; i < members.Length; i++)
+            {
+                var entry = data.Children[i];
+                to.Add(new RedisGeo
+                {
+                    Longitude = double.Parse(entry.Children[0].Data.FromUtf8Bytes()),
+                    Latitude = double.Parse(entry.Children[1].Data.FromUtf8Bytes()),
+                    Member = members[i],
+                });
+            }
+
+            return to;
+        }
+
+        public List<RedisGeoResult> GeoRadius(string key, double longitude, double latitude, double radius,
+            string unit = null, bool withCoords = false, bool withHash = false, int count = 0, bool? asc = null)
+        {
+            throw new NotImplementedException();
+        }
+
+        public List<RedisGeoResult> GeoRadiusByMember(string key, double longitude, double latitude, double radius,
+            string unit = null, bool withCoords = false, bool withHash = false, int count = 0, bool? asc = null)
+        {
+            throw new NotImplementedException();
+        }
+
+        #endregion
+
         internal bool IsDisposed { get; set; }
 
         public bool IsManagedClient

tests/ServiceStack.Redis.Tests/RedisGeoTests.cs

@@ -0,0 +1,33 @@
+using NUnit.Framework;
+
+namespace ServiceStack.Redis.Tests
+{
+    [TestFixture]
+    public class RedisGeoTests
+    {
+        private RedisNativeClient redis;
+
+        public RedisGeoTests()
+        {
+            redis = new RedisNativeClient("10.0.0.121");
+        }
+
+        [TestFixtureTearDown]
+        public void TestFixtureTearDown()
+        {
+            redis.Dispose();
+        }
+
+        [Test]
+        public void Can_GeoAdd_and_GeoPos()
+        {
+            redis.GeoAdd("Sicily", 13.361389, 38.115556, "Palermo");
+            var results = redis.GeoPos("Sicily", "Palermo");
+
+            Assert.That(results.Count, Is.EqualTo(1));
+            Assert.That(results[0].Longitude, Is.EqualTo(13.361389).Within(.1));
+            Assert.That(results[0].Latitude, Is.EqualTo(38.115556).Within(.1));
+            Assert.That(results[0].Member, Is.EqualTo("Palermo"));
+        }
+    }
+}

tests/ServiceStack.Redis.Tests/ServiceStack.Redis.Tests.csproj

@@ -189,6 +189,7 @@
     <Compile Include="Examples\TestData.cs" />
     <Compile Include="Issues\RedisCharacterizationTests.cs" />
     <Compile Include="RedisBatchTests.cs" />
+    <Compile Include="RedisGeoTests.cs" />
     <Compile Include="RedisManagerPoolTests.cs" />
     <Compile Include="DiagnosticTests.cs" />
     <Compile Include="Examples\ServiceStack_Redis_UseCase.cs" />