[FEEDS-268] unfollowMany (#162)

* chore: unfollowMany

* chore: unfollowMany

* chore: unfollowMany

* chore: unfollowMany

* chore: fix old unrelated FlagActivity test

Author: itsmeadi

src/BatchOperations.cs

@@ -56,6 +56,28 @@ public async Task<ResponseBase> FollowManyAsync(IEnumerable<Follow> follows, int
             throw StreamException.FromResponse(response);
         }
 
+        public async Task<ResponseBase> UnfollowManyAsync(IEnumerable<UnfollowRelation> unfollows)
+        {
+            var request = _client.BuildAppRequest("unfollow_many/", HttpMethod.Post);
+            
+            // Create a new anonymous object array with the properties expected by the API
+            var unfollowRequests = unfollows.Select(f => new 
+            {
+                source = f.Source,
+                target = f.Target,
+                keep_history = f.KeepHistory
+            });
+            
+            request.SetJsonBody(StreamJsonConverter.SerializeObject(unfollowRequests));
+
+            var response = await _client.MakeRequestAsync(request);
+
+            if (response.StatusCode == HttpStatusCode.Created || response.StatusCode == HttpStatusCode.OK)
+                return StreamJsonConverter.DeserializeObject<ResponseBase>(response.Content);
+
+            throw StreamException.FromResponse(response);
+        }
+
         public async Task<GenericGetResponse<Activity>> GetActivitiesByIdAsync(IEnumerable<string> ids)
             => await GetActivitiesAsync(ids, null);
 

src/IBatchOperations.cs

@@ -21,6 +21,10 @@ public interface IBatchOperations
         /// <summary>Follow muiltiple feeds.</summary>
         /// <remarks>https://getstream.io/activity-feeds/docs/dotnet-csharp/add_many_activities/?language=csharp</remarks>
         Task<ResponseBase> FollowManyAsync(IEnumerable<Follow> follows, int activityCopyLimit = 100);
+        
+        /// <summary>Unfollow multiple feeds in a single request using UnfollowRelation objects.</summary>
+        /// <remarks>https://getstream.io/activity-feeds/docs/dotnet-csharp/add_many_activities/?language=csharp</remarks>
+        Task<ResponseBase> UnfollowManyAsync(IEnumerable<UnfollowRelation> unfollows);
 
         /// <summary>Get multiple activities by activity ids.</summary>
         /// <remarks>https://getstream.io/activity-feeds/docs/dotnet-csharp/add_many_activities/?language=csharp</remarks>

src/Models/UnfollowRelation.cs

@@ -0,0 +1,49 @@
+namespace Stream.Models
+{
+    /// <summary>
+    /// Represents a relationship to unfollow in batch operations
+    /// </summary>
+    public class UnfollowRelation
+    {
+        /// <summary>
+        /// Source feed id
+        /// </summary>
+        public string Source { get; set; }
+        
+        /// <summary>
+        /// Target feed id
+        /// </summary>
+        public string Target { get; set; }
+        
+        /// <summary>
+        /// Whether to keep activities from the unfollowed feed
+        /// </summary>
+        public bool KeepHistory { get; set; }
+
+        /// <summary>
+        /// Creates a new instance of the UnfollowRelation class
+        /// </summary>
+        /// <param name="source">Source feed id</param>
+        /// <param name="target">Target feed id</param>
+        /// <param name="keepHistory">Whether to keep activities from the unfollowed feed</param>
+        public UnfollowRelation(string source, string target, bool keepHistory = false)
+        {
+            Source = source;
+            Target = target;
+            KeepHistory = keepHistory;
+        }
+
+        /// <summary>
+        /// Creates a new instance of the UnfollowRelation class
+        /// </summary>
+        /// <param name="source">Source feed</param>
+        /// <param name="target">Target feed</param>
+        /// <param name="keepHistory">Whether to keep activities from the unfollowed feed</param>
+        public UnfollowRelation(IStreamFeed source, IStreamFeed target, bool keepHistory = false)
+        {
+            Source = source.FeedId;
+            Target = target.FeedId;
+            KeepHistory = keepHistory;
+        }
+    }
+} 

tests/BatchTests.cs

@@ -10,6 +10,28 @@ namespace StreamNetTests
     [TestFixture]
     public class BatchTests : TestBase
     {
+        [Test]
+        public void TestUnfollowManyArgumentValidation()
+        {
+            // Should work with empty array
+            Assert.DoesNotThrowAsync(async () =>
+            {
+                await Client.Batch.UnfollowManyAsync(new UnfollowRelation[] { });
+            });
+            
+            // Should work with valid unfollow relation objects
+            Assert.DoesNotThrowAsync(async () =>
+            {
+                await Client.Batch.UnfollowManyAsync(new[] { new UnfollowRelation("user:1", "user:2", false) });
+            });
+
+            // Should work with keepHistory true
+            Assert.DoesNotThrowAsync(async () =>
+            {
+                await Client.Batch.UnfollowManyAsync(new[] { new UnfollowRelation("user:1", "user:2", true) });
+            });
+        }
+
         [Test]
         public void TestGetEnrichedActivitiesArgumentValidation()
         {
@@ -305,5 +327,93 @@ public async Task TestBatchActivityForeignIdTime()
 
             Assert.AreEqual(1, result.Results.Count);
         }
+
+        [Test]
+        public async Task TestBatchUnfollowManyKeepHistoryFalse()
+        {
+            // First set up follows and add activities
+            await Client.Batch.FollowManyAsync(new[]
+            {
+                new Follow(UserFeed, FlatFeed),
+                new Follow(UserFeed2, FlatFeed),
+            });
+
+            var newActivity = new Activity("1", "test", "1");
+            var response = await this.FlatFeed.AddActivityAsync(newActivity);
+
+            // Verify follows are working
+            var activities1 = (await this.UserFeed.GetActivitiesAsync(0, 1)).Results;
+            var activities2 = (await this.UserFeed2.GetActivitiesAsync(0, 1)).Results;
+            
+            Assert.IsNotNull(activities1);
+            Assert.AreEqual(1, activities1.Count());
+            Assert.AreEqual(response.Id, activities1.First().Id);
+            
+            Assert.IsNotNull(activities2);
+            Assert.AreEqual(1, activities2.Count());
+            Assert.AreEqual(response.Id, activities2.First().Id);
+
+            // Use UnfollowMany with keepHistory=false
+            await Client.Batch.UnfollowManyAsync(new[]
+            {
+                new UnfollowRelation(UserFeed, FlatFeed, false),
+                new UnfollowRelation(UserFeed2, FlatFeed, false),
+            });
+
+            // Verify activities are removed
+            activities1 = (await this.UserFeed.GetActivitiesAsync(0, 1)).Results;
+            activities2 = (await this.UserFeed2.GetActivitiesAsync(0, 1)).Results;
+            
+            Assert.IsNotNull(activities1);
+            Assert.AreEqual(0, activities1.Count());
+            
+            Assert.IsNotNull(activities2);
+            Assert.AreEqual(0, activities2.Count());
+        }
+
+        [Test]
+        public async Task TestBatchUnfollowManyKeepHistoryTrue()
+        {
+            // First set up follows and add activities
+            await Client.Batch.FollowManyAsync(new[]
+            {
+                new Follow(UserFeed, FlatFeed),
+                new Follow(UserFeed2, FlatFeed),
+            });
+
+            var newActivity = new Activity("1", "test", "1");
+            var response = await this.FlatFeed.AddActivityAsync(newActivity);
+
+            // Verify follows are working
+            var activities1 = (await this.UserFeed.GetActivitiesAsync(0, 1)).Results;
+            var activities2 = (await this.UserFeed2.GetActivitiesAsync(0, 1)).Results;
+            
+            Assert.IsNotNull(activities1);
+            Assert.AreEqual(1, activities1.Count());
+            Assert.AreEqual(response.Id, activities1.First().Id);
+            
+            Assert.IsNotNull(activities2);
+            Assert.AreEqual(1, activities2.Count());
+            Assert.AreEqual(response.Id, activities2.First().Id);
+
+            // Use UnfollowMany with keepHistory=true
+            await Client.Batch.UnfollowManyAsync(new[]
+            {
+                new UnfollowRelation(UserFeed, FlatFeed, true),
+                new UnfollowRelation(UserFeed2, FlatFeed, true),
+            });
+
+            // Verify activities are retained
+            activities1 = (await this.UserFeed.GetActivitiesAsync(0, 1)).Results;
+            activities2 = (await this.UserFeed2.GetActivitiesAsync(0, 1)).Results;
+            
+            Assert.IsNotNull(activities1);
+            Assert.AreEqual(1, activities1.Count());
+            Assert.AreEqual(response.Id, activities1.First().Id);
+            
+            Assert.IsNotNull(activities2);
+            Assert.AreEqual(1, activities2.Count());
+            Assert.AreEqual(response.Id, activities2.First().Id);
+        }
     }
 }

tests/ModerationTests.cs

@@ -98,6 +98,13 @@ public async Task TestFlagActivity()
             newActivity.SetData<string>("stringint", "42");
             newActivity.SetData<string>("stringdouble", "42.2");
             newActivity.SetData<string>("stringcomplex", "{ \"test1\": 1, \"test2\": \"testing\" }");
+            
+            // Set moderation data with origin_feed
+            var moderationData = new Dictionary<string, object>
+            {
+                { "origin_feed", this.UserFeed.FeedId }
+            };
+            newActivity.SetData("moderation", moderationData);
 
             var response = await this.UserFeed.AddActivityAsync(newActivity);
             Assert.IsNotNull(response);