Product/119 refine vue web part

coscine/issues#119

src/Configuration/ConsulConfiguration.cs

@@ -31,7 +31,7 @@ namespace Coscine.Configuration
                 Value = value
             };
 
-            using (var client = new ConsulClient())
+            using (var client = new ConsulClient(Configuration))
             {
                 var putAttempt = await client.KV.Put(putPair);
 
@@ -39,9 +39,27 @@ namespace Coscine.Configuration
             }
         }
 
+
+        public bool PutAndWait(string key, byte[] value)
+        {
+            var putPair = new KVPair(key)
+            {
+                Value = value
+            };
+
+            using (var client = new ConsulClient(Configuration))
+            {
+                var putAttempt = client.KV.Put(putPair);
+
+                putAttempt.Wait();
+
+                return putAttempt.Result.Response;
+            }
+        }
+
         public async Task<byte[]> GetAsync(string key)
         {
-            using (var client = new ConsulClient())
+            using (var client = new ConsulClient(Configuration))
             {
                 var getPair = await client.KV.Get(key);
 
@@ -57,6 +75,26 @@ namespace Coscine.Configuration
             }
         }
 
+        public byte[] GetAndWait(string key)
+        {
+            using (var client = new ConsulClient(Configuration))
+            {
+                var getPair = client.KV.Get(key);
+
+                getPair.Wait();
+
+                if (getPair.Result.Response?.Value != null)
+                {
+                    return getPair.Result.Response.Value;
+                }
+                else
+                {
+                    return null;
+                }
+
+            }
+        }
+
         public async Task<string> GetStringAsync(string key)
         {
             var value = await GetAsync(key);
@@ -70,24 +108,57 @@ namespace Coscine.Configuration
             }
         }
 
+        public string GetStringAndWait(string key)
+        {
+            var value = GetAndWait(key);
+            if (value != null)
+            {
+                return Encoding.UTF8.GetString(value, 0, value.Length);
+            }
+            else
+            {
+                return null;
+            }
+        }
+
         public async Task<string[]> KeysAsync(string prefix)
         {
-            using (var client = new ConsulClient())
+            using (var client = new ConsulClient(Configuration))
             {
                 var keys = await client.KV.Keys(prefix);
                 return keys.Response;
             }
         }
 
+        public string[] KeysAndWait(string prefix)
+        {
+            using (var client = new ConsulClient(Configuration))
+            {
+                var keys = client.KV.Keys(prefix);
+                keys.Wait();
+                return keys.Result.Response;
+            }
+        }
+
         public async Task<bool> DeleteAsync(string key)
         {
-            using (var client = new ConsulClient())
+            using (var client = new ConsulClient(Configuration))
             {
                 var deleteRequest = await client.KV.Delete(key);
                 return deleteRequest.Response;
             }
         }
 
+        public bool DeleteAndWait(string key)
+        {
+            using (var client = new ConsulClient(Configuration))
+            {
+                var deleteRequest = client.KV.Delete(key);
+                deleteRequest.Wait();
+                return deleteRequest.Result.Response;
+            }
+        }
+
         public bool Put(string key, string value)
         {
             return PutAsync(key, value).GetAwaiter().GetResult();