feat: swarm persistence

Author: richardschneider

src/CoreApi/SwarmApi.cs

@@ -105,6 +105,7 @@ TimeSpan ParseLatency(string latency)
 
         public async Task<MultiAddress> AddAddressFilterAsync(MultiAddress address, bool persist = false, CancellationToken cancel = default(CancellationToken))
         {
+            // go-ipfs always does persist, https://github.com/ipfs/go-ipfs/issues/4605
             var json = await ipfs.DoCommandAsync("swarm/filters/add", cancel, address.ToString());
             var addrs = (JArray)(JObject.Parse(json)["Strings"]);
             var a = addrs.FirstOrDefault();
@@ -115,15 +116,25 @@ TimeSpan ParseLatency(string latency)
 
         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;
+            JArray addrs;
+            if (persist)
+            {
+                addrs = await ipfs.Config.GetAsync("Swarm.AddrFilters", cancel) as JArray;
+            }
+            else
+            {
+                var json = await ipfs.DoCommandAsync("swarm/filters", cancel);
+                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))
         {
+            // go-ipfs always does persist, https://github.com/ipfs/go-ipfs/issues/4605
             var json = await ipfs.DoCommandAsync("swarm/filters/rm", cancel, address.ToString());
             var addrs = (JArray)(JObject.Parse(json)["Strings"]);
             var a = addrs.FirstOrDefault();

test/CoreApi/SwarmApiTest.cs

@@ -84,18 +84,22 @@ public async Task Connection()
         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);
+            var somewhere = new MultiAddress("/ip4/192.127.0.0/ipcidr/16");
+            var filter = await ipfs.Swarm.AddAddressFilterAsync(somewhere, true);
             Assert.IsNotNull(filter);
             Assert.AreEqual(somewhere, filter);
             var filters = await ipfs.Swarm.ListAddressFiltersAsync();
             Assert.IsTrue(filters.Any(a => a == somewhere));
+            filters = await ipfs.Swarm.ListAddressFiltersAsync(true);
+            Assert.IsTrue(filters.Any(a => a == somewhere));
 
-            filter = await ipfs.Swarm.RemoveAddressFilterAsync(somewhere);
+            filter = await ipfs.Swarm.RemoveAddressFilterAsync(somewhere, true);
             Assert.IsNotNull(filter);
             Assert.AreEqual(somewhere, filter);
             filters = await ipfs.Swarm.ListAddressFiltersAsync();
             Assert.IsFalse(filters.Any(a => a == somewhere));
+            filters = await ipfs.Swarm.ListAddressFiltersAsync(true);
+            Assert.IsFalse(filters.Any(a => a == somewhere));
         }
 
         [TestMethod]