feat: implement bootstrap API #14

Author: richardschneider

src/CoreApi/BootstrapApi.cs

@@ -0,0 +1,67 @@
+using Newtonsoft.Json;
+using Newtonsoft.Json.Linq;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Net.Http;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+using Ipfs.CoreApi;
+using System.IO;
+
+namespace Ipfs.Api
+{
+
+    class BootstrapApi : IBootstrapApi
+    {
+        IpfsClient ipfs;
+
+        internal BootstrapApi(IpfsClient ipfs)
+        {
+            this.ipfs = ipfs;
+        }
+
+        public async Task<MultiAddress> AddAsync(MultiAddress address, CancellationToken cancel = default(CancellationToken))
+        {
+            var json = await ipfs.DoCommandAsync("bootstrap/add", cancel, address.ToString());
+            var addrs = (JArray)(JObject.Parse(json)["Peers"]);
+            var a = addrs.FirstOrDefault();
+            if (a == null)
+                return null;
+            return new MultiAddress((string)a);
+        }
+
+        public async Task<IEnumerable<MultiAddress>> AddDefaultsAsync(CancellationToken cancel = default(CancellationToken))
+        {
+            var json = await ipfs.DoCommandAsync("bootstrap/add/default", cancel);
+            var addrs = (JArray)(JObject.Parse(json)["Peers"]);
+            return addrs
+                .Select(a => new MultiAddress((string)a));
+        }
+
+        public async Task<IEnumerable<MultiAddress>> ListAsync(CancellationToken cancel = default(CancellationToken))
+        {
+            var json = await ipfs.DoCommandAsync("bootstrap/list", cancel);
+            var addrs = (JArray)(JObject.Parse(json)["Peers"]);
+            return addrs
+                .Select(a => new MultiAddress((string)a));
+        }
+
+        public Task RemoveAllAsync(CancellationToken cancel = default(CancellationToken))
+        {
+            return ipfs.DoCommandAsync("bootstrap/rm/all", cancel);
+        }
+
+        public async Task<MultiAddress> RemoveAsync(MultiAddress address, CancellationToken cancel = default(CancellationToken))
+        {
+            var json = await ipfs.DoCommandAsync("bootstrap/rm", cancel, address.ToString());
+            var addrs = (JArray)(JObject.Parse(json)["Peers"]);
+            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.3" />
+    <PackageReference Include="Ipfs.Core" Version="0.18.4" />
     <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'" />

src/IpfsClient.cs

@@ -61,6 +61,7 @@ public IpfsClient()
             UserAgent = string.Format("net-ipfs/{0}.{1}", version.Major, version.Minor);
             TrustedPeers = new TrustedPeerCollection(this);
 
+            Bootstrap = new BootstrapApi(this);
             Bitswap = new BitswapApi(this);
             Block = new BlockApi(this);
             Config = new ConfigApi(this);
@@ -115,6 +116,9 @@ public IpfsClient(string host)
         /// <inheritdoc />
         public IBitswapApi Bitswap { get; private set; }
 
+        /// <inheritdoc />
+        public IBootstrapApi Bootstrap { get; private set; }
+
         /// <inheritdoc />
         public IGenericApi Generic { get; private set; }
 

test/CoreApi/BootstrapTest.cs

@@ -0,0 +1,76 @@
+using Ipfs.Api;
+using Microsoft.VisualStudio.TestTools.UnitTesting;
+using System;
+using System.IO;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace Ipfs.Api
+{
+
+    [TestClass]
+    public class BootstapApiTest
+    {
+        IpfsClient ipfs = TestFixture.Ipfs;
+        MultiAddress somewhere = "/ip4/127.0.0.1/tcp/4009/ipfs/QmPv52ekjS75L4JmHpXVeuJ5uX2ecSfSZo88NSyxwA3rAQ";
+
+        [TestMethod]
+        public async Task Add_Remove()
+        {
+            var addr = await ipfs.Bootstrap.AddAsync(somewhere);
+            Assert.IsNotNull(addr);
+            Assert.AreEqual(somewhere, addr);
+            var addrs = await ipfs.Bootstrap.ListAsync();
+            Assert.IsTrue(addrs.Any(a => a == somewhere));
+
+            addr = await ipfs.Bootstrap.RemoveAsync(somewhere);
+            Assert.IsNotNull(addr);
+            Assert.AreEqual(somewhere, addr);
+            addrs = await ipfs.Bootstrap.ListAsync();
+            Assert.IsFalse(addrs.Any(a => a == somewhere));
+        }
+
+        [TestMethod]
+        public async Task List()
+        {
+            var addrs = await ipfs.Bootstrap.ListAsync();
+            Assert.IsNotNull(addrs);
+            Assert.AreNotEqual(0, addrs.Count());
+        }
+
+        [TestMethod]
+        public async Task Remove_All()
+        {
+            var original = await ipfs.Bootstrap.ListAsync();
+            await ipfs.Bootstrap.RemoveAllAsync();
+            var addrs = await ipfs.Bootstrap.ListAsync();
+            Assert.AreEqual(0, addrs.Count());
+            foreach (var addr in original)
+            {
+                await ipfs.Bootstrap.AddAsync(addr);
+            }
+        }
+
+        [TestMethod]
+        public async Task Add_Defaults()
+        {
+            var original = await ipfs.Bootstrap.ListAsync();
+            await ipfs.Bootstrap.RemoveAllAsync();
+            try
+            {
+                await ipfs.Bootstrap.AddDefaultsAsync();
+                var addrs = await ipfs.Bootstrap.ListAsync();
+                Assert.AreNotEqual(0, addrs.Count());
+            }
+            finally
+            {
+                await ipfs.Bootstrap.RemoveAllAsync();
+                foreach (var addr in original)
+                {
+                    await ipfs.Bootstrap.AddAsync(addr);
+                }
+            }
+        }
+    }
+}