feat(BitswapApi): UnwantAsync

Author: richardschneider

README.md

@@ -16,6 +16,7 @@ More information, including the Class Reference, is on the [Project](https://ric
 - Targets .NET Framework 4.5, .NET Standard 1.4 and .NET Standard 2.0
 - [Asynchronous I/O](https://richardschneider.github.io/net-ipfs-api/articles/async.html) to an IPFS server
 - Supports [cancellation](https://richardschneider.github.io/net-ipfs-api/articles/cancellation.html) of all requests to the IPFS Server
+- Requests that all responses are compressed
 - Comprehensive [documentation](https://richardschneider.github.io/net-ipfs-api)
 - C# style access to the [ipfs core interface](https://richardschneider.github.io/net-ipfs-core/api/Ipfs.CoreApi.html)
   - [Bitswap API](https://richardschneider.github.io/net-ipfs-core/api/Ipfs.CoreApi.IBitswapApi.html)

src/CoreApi/BitswapApi.cs

@@ -40,7 +40,11 @@ internal BitswapApi(IpfsClient ipfs)
                     var obj = (JObject)k;
                     return Cid.Decode(obj["/"].ToString());
                 });
-
+        }
+
+        public async Task UnwantAsync(Cid id, CancellationToken cancel = default(CancellationToken))
+        {
+            await ipfs.DoCommandAsync("bitswap/unwant", cancel, id);
         }
     }
 

src/IpfsApi.csproj

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

test/CoreApi/BitswapApiTest.cs

@@ -32,5 +32,28 @@ public async Task Wants()
             Assert.Fail("wanted block is missing");
         }
 
+        [TestMethod]
+        [Ignore("doesn't work on go ipfs")]
+        public async Task Unwant()
+        {
+            var block = new DagNode(Encoding.UTF8.GetBytes("BitswapApiTest unknown block 2"));
+#pragma warning disable CS4014 // Because this call is not awaited, execution of the current method continues before the call is completed
+            Task.Run(() => ipfs.Bitswap.GetAsync(block.Id).Wait());
+
+            var endTime = DateTime.Now.AddSeconds(10);
+            while (true)
+            {
+                if (DateTime.Now > endTime)
+                    Assert.Fail("wanted block is missing");
+                await Task.Delay(100);
+                var w = await ipfs.Bitswap.WantsAsync();
+                if (w.Contains(block.Id))
+                    break;
+            }
+
+            await ipfs.Bitswap.UnwantAsync(block.Id);
+            var wants = await ipfs.Bitswap.WantsAsync();
+            CollectionAssert.DoesNotContain(wants.ToArray(), block.Id);
+        }
     }
 }