diff --git a/Consul.Test/KVTest.cs b/Consul.Test/KVTest.cs index 5012278ef..9b78a2817 100644 --- a/Consul.Test/KVTest.cs +++ b/Consul.Test/KVTest.cs @@ -348,7 +348,7 @@ public async Task KV_Keys_DeleteRecurse() Assert.Equal(pairs.Response.Length, putTasks.Length); Assert.False(pairs.LastIndex == 0); - var deleteTree = await _client.KV.DeleteTree(prefix); + await _client.KV.DeleteTree(prefix); pairs = await _client.KV.Keys(prefix, ""); Assert.Null(pairs.Response); @@ -363,12 +363,12 @@ public async Task KV_AcquireRelease() Assert.False(string.IsNullOrEmpty(sessionRequest.Response)); var key = GenerateTestKeyName(); - var value = Encoding.UTF8.GetBytes("test"); + var value = "test"; var pair = new KVPair(key) { - Value = value, - Session = id + Value = Encoding.UTF8.GetBytes(value), + Session = id, }; var acquireRequest = await _client.KV.Acquire(pair); @@ -381,12 +381,14 @@ public async Task KV_AcquireRelease() Assert.Equal(getRequest.Response.LockIndex, (ulong)1); Assert.True(getRequest.LastIndex > 0); - acquireRequest = await _client.KV.Release(pair); - Assert.True(acquireRequest.Response); + var newValue = "test2"; + pair.Value = Encoding.UTF8.GetBytes(newValue); + var releaseRequest = await _client.KV.Release(pair); + Assert.True(releaseRequest.Response); getRequest = await _client.KV.Get(key); - Assert.NotNull(getRequest.Response); + Assert.Equal(newValue, Encoding.UTF8.GetString(getRequest.Response.Value)); Assert.Null(getRequest.Response.Session); Assert.Equal(getRequest.Response.LockIndex, (ulong)1); Assert.True(getRequest.LastIndex > 0); diff --git a/Consul/KV.cs b/Consul/KV.cs index 0bf982212..f372163fd 100644 --- a/Consul/KV.cs +++ b/Consul/KV.cs @@ -19,7 +19,6 @@ using System; using System.Collections.Generic; -using System.Net.Http; using System.Threading; using System.Threading.Tasks; using Newtonsoft.Json; @@ -509,7 +508,7 @@ public Task> Release(KVPair p, CancellationToken ct = default) public Task> Release(KVPair p, WriteOptions q, CancellationToken ct = default) { p.Validate(); - var req = _client.Put(string.Format("/v1/kv/{0}", p.Key.TrimStart('/')), null, q); + var req = _client.Put(string.Format("/v1/kv/{0}", p.Key.TrimStart('/')), p.Value, q); if (p.Flags > 0) { req.Params["flags"] = p.Flags.ToString(); @@ -620,9 +619,6 @@ public partial class ConsulClient : IConsulClient /// /// KV returns a handle to the KV endpoint /// - public IKVEndpoint KV - { - get { return _kv.Value; } - } + public IKVEndpoint KV => _kv.Value; } }