Add follow stats (#52)

Author: ferhatelmas

src/stream-net-tests/IntegrationTests.cs

@@ -4,6 +4,7 @@
 using System.Collections.Generic;
 using System.IO;
 using System.Linq;
+using System.Text;
 using System.Threading.Tasks;
 
 namespace stream_net_tests
@@ -2503,5 +2504,25 @@ public async Task TestOG()
             Assert.IsNotEmpty(og.Images);
             Assert.IsNotEmpty(og.Images[0].Image);
         }
+
+        [Test]
+        public async Task TestFollowStats()
+        {
+            var f1 = _client.Feed("user", System.Guid.NewGuid().ToString());
+            var f2 = _client.Feed("user", System.Guid.NewGuid().ToString());
+            await f1.FollowFeed(f2);
+
+            var stats = await f1.FollowStats(null, new string[] { "timeline" });
+            Assert.AreEqual(stats.Followers.Count, 0);
+            Assert.AreEqual(stats.Followers.Feed, f1.FeedId);
+            Assert.AreEqual(stats.Following.Count, 0);
+            Assert.AreEqual(stats.Following.Feed, f1.FeedId);
+
+            stats = await f1.FollowStats(null, new string[] { "user" });
+            Assert.AreEqual(stats.Followers.Count, 0);
+            Assert.AreEqual(stats.Followers.Feed, f1.FeedId);
+            Assert.AreEqual(stats.Following.Count, 1);
+            Assert.AreEqual(stats.Following.Feed, f1.FeedId);
+        }
     }
 }

src/stream-net/FollowStats.cs

@@ -0,0 +1,26 @@
+using Newtonsoft.Json;
+
+namespace Stream
+{
+
+    public class FollowStat
+    {
+        [JsonProperty("count")]
+        public int Count { get; set; }
+
+        [JsonProperty("feed")]
+        public string Feed { get; set; }
+    }
+
+    public class FollowStats
+    {
+
+        [JsonProperty("followers")]
+        public FollowStat Followers { get; set; }
+
+        [JsonProperty("following")]
+        public FollowStat Following { get; set; }
+    }
+}
+
+

src/stream-net/IStreamFeed.cs

@@ -27,6 +27,7 @@ public interface IStreamFeed
         Task UnfollowFeed(string targetFeedSlug, string targetUserId, bool keepHistory = false);
         Task UpdateActivities(IEnumerable<Activity> activities);
         Task UpdateActivity(Activity activity);
+        Task<FollowStats> FollowStats(string[] followersSlugs = null, string[] followingSlugs = null);
         Task<UpdateToTargetsResponse> UpdateActivityToTargets(ForeignIDTime foreignIDTime,
             IEnumerable<string> adds = null,
             IEnumerable<string> newTargets = null,

src/stream-net/StreamClientToken.cs

@@ -1,4 +1,4 @@
-using Newtonsoft.Json;
+using Newtonsoft.Json;
 using System;
 using System.Collections.Generic;
 using System.Security.Cryptography;

src/stream-net/StreamFeed.cs

@@ -1,4 +1,4 @@
-using Newtonsoft.Json;
+using Newtonsoft.Json;
 using Newtonsoft.Json.Linq;
 using Stream.Rest;
 using System;
@@ -424,5 +424,32 @@ private void ValidateFeedFollow(IStreamFeed feed)
                 throw new ArgumentException("Cannot follow/unfollow myself");
         }
 
+        internal class FollowStatsResponse
+        {
+            public FollowStats Results { get; set; }
+        }
+
+        public async Task<FollowStats> FollowStats(string[] followersSlugs = null, string[] followingSlugs = null)
+        {
+            var request = this._client.BuildAppRequest("stats/follow/", HttpMethod.GET);
+            request.AddQueryParameter("followers", this.FeedId);
+            request.AddQueryParameter("following", this.FeedId);
+
+            if (followersSlugs != null)
+            {
+                request.AddQueryParameter("followers_slugs", string.Join(",", followersSlugs));
+            }
+            if (followingSlugs != null)
+            {
+                request.AddQueryParameter("following_slugs", string.Join(",", followingSlugs));
+            }
+
+            var response = await _client.MakeRequest(request);
+            if (response.StatusCode != System.Net.HttpStatusCode.OK)
+                throw StreamException.FromResponse(response);
+
+            return JsonConvert.DeserializeObject<FollowStatsResponse>(response.Content).Results;
+        }
+
     }
 }