feat(SwarmApi): address filters

Author: richardschneider

src/CoreApi/SwarmApi.cs

@@ -101,7 +101,36 @@ TimeSpan ParseLatency(string latency)
         public async Task DisconnectAsync(MultiAddress address, CancellationToken cancel = default(CancellationToken))
         {
             await ipfs.DoCommandAsync("swarm/disconnect", cancel, address.ToString());
-        }
+        }
+
+        public async Task<MultiAddress> AddAddressFilterAsync(MultiAddress address, bool persist = false, CancellationToken cancel = default(CancellationToken))
+        {
+            var json = await ipfs.DoCommandAsync("swarm/filters/add", cancel, address.ToString());
+            var addrs = (JArray)(JObject.Parse(json)["Strings"]);
+            var a = addrs.FirstOrDefault();
+            if (a == null)
+                return null;
+            return new MultiAddress((string)a);
+        }
+
+        public async Task<IEnumerable<MultiAddress>> ListAddressFiltersAsync(bool persist = false, CancellationToken cancel = default(CancellationToken))
+        {
+            var json = await ipfs.DoCommandAsync("swarm/filters", cancel);
+            var addrs = (JObject.Parse(json)["Strings"]) as JArray;
+            if (addrs == null)
+                return new MultiAddress[0];
+            return addrs.Select(a => new MultiAddress((string)a));
+        }
+
+        public async Task<MultiAddress> RemoveAddressFilterAsync(MultiAddress address, bool persist = false, CancellationToken cancel = default(CancellationToken))
+        {
+            var json = await ipfs.DoCommandAsync("swarm/filters/rm", cancel, address.ToString());
+            var addrs = (JArray)(JObject.Parse(json)["Strings"]);
+            var a = addrs.FirstOrDefault();
+            if (a == null)
+                return null;
+            return new MultiAddress((string)a);
+        }
     }
 
 }

src/IpfsApi.csproj

@@ -27,7 +27,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="Ipfs.Core" Version="0.18.4" />
+    <PackageReference Include="Ipfs.Core" Version="0.18.5" />
     <PackageReference Include="Newtonsoft.Json" Version="10.0.3" />
 	  <PackageReference Include="System.Net.Http" Version="4.3.3" Condition="'$(TargetFramework)' == 'netstandard14'" />
     <PackageReference Include="System.Net.Http" Version="4.3.3" Condition="'$(TargetFramework)' == 'net45'" />

test/CoreApi/SwarmApiTest.cs

@@ -79,5 +79,41 @@ public async Task Connection()
 
             Assert.Fail("Cannot connect to any peer");
         }
+
+        [TestMethod]
+        public async Task Filter_Add_Remove()
+        {
+            var ipfs = TestFixture.Ipfs;
+            var somewhere = new MultiAddress("/ip4/192.168.0.0/ipcidr/16");
+            var filter = await ipfs.Swarm.AddAddressFilterAsync(somewhere);
+            Assert.IsNotNull(filter);
+            Assert.AreEqual(somewhere, filter);
+            var filters = await ipfs.Swarm.ListAddressFiltersAsync();
+            Assert.IsTrue(filters.Any(a => a == somewhere));
+
+            filter = await ipfs.Swarm.RemoveAddressFilterAsync(somewhere);
+            Assert.IsNotNull(filter);
+            Assert.AreEqual(somewhere, filter);
+            filters = await ipfs.Swarm.ListAddressFiltersAsync();
+            Assert.IsFalse(filters.Any(a => a == somewhere));
+        }
+
+        [TestMethod]
+        public async Task Filter_List()
+        {
+            var ipfs = TestFixture.Ipfs;
+            var filters = await ipfs.Swarm.ListAddressFiltersAsync(persist: false);
+            Assert.IsNotNull(filters);
+        }
+
+        [TestMethod]
+        public async Task Filter_Remove_Unknown()
+        {
+            var ipfs = TestFixture.Ipfs;
+            var somewhere = new MultiAddress("/ip4/192.168.0.3/ipcidr/2");
+
+            var filter = await ipfs.Swarm.RemoveAddressFilterAsync(somewhere);
+            Assert.IsNull(filter);
+        }
     }
 }