test harness refactoring, improve functionality

readme.md

@@ -0,0 +1,10 @@
+HareDu
+======
+
+HareDu is a .NET based library that consumes the RabbitMQ REST API, which is itself used to manage and monitor a RabbitMQ server or cluster.
+
+Assumptions
+===========
+You have RabbitMQ running in some environment.
+You know the port URL and port to access the RabbitMQ REST API you want to interact with
+You know some valid credentials to communite with the RabbitMQ REST API (by default user id:guest, password: guest works)

src/HareDu.TestHarness/Program.cs

@@ -1,56 +1,192 @@
 using System;
 using System.Collections.Generic;
-using System.Linq;
-using System.Net;
 using System.Net.Http;
-using System.Net.Http.Headers;
-using System.Reflection;
-using System.Threading.Tasks;
+using HareDu.Model;
 
 namespace HareDu.TestHarness
 {
-    using Model;
-
-    class Program
+    internal class Program
     {
-        static void Main(string[] args)
+        private static void Main(string[] args)
+        {
+            Console.WriteLine("HareDu Test Harness");
+            string url;
+            string username;
+            string password;
+            string hostToDelete;
+            const int port = 55672;
+            const bool promptForParameters = true;
+            if (promptForParameters)
+            {
+                Console.Write("URL: ");
+                url = Console.ReadLine();
+
+                Console.Write("Username: ");
+                username = Console.ReadLine();
+
+                Console.Write("Password: ");
+                password = Console.ReadLine();
+
+                Console.Write("Host To Delete: ");
+                hostToDelete = Console.ReadLine();
+            }
+            else
+            {
+                url = "http://localhost";
+                username = "guest";
+                password = "guest";
+            }
+
+            var hareDuClientParameters = new HareDuClientParameters(url, port, username, password);
+
+            DumpInfoToConsole(hareDuClientParameters);
+
+            deleteVirtualHost(hareDuClientParameters, hostToDelete);
+        }
+
+        private static void DumpInfoToConsole(HareDuClientParameters hareDuClientParameters)
         {
-            Console.Write("URL: ");
-            string url = Console.ReadLine();
-            Console.Write("Username: ");
-            string username = Console.ReadLine();
-            Console.Write("Password: ");
-            string password = Console.ReadLine();
+            outputOverviewInfo(hareDuClientParameters);
+
+            outputWhoAmIInfo(hareDuClientParameters);
+
+            outputPermissionInfo(hareDuClientParameters);
 
-            url = "http://localhost";
-            var client = new HareDuClient(url, 55672, username, password);
+            outputVirtualHostInfo(hareDuClientParameters);
+
+            outputOpenChannelInfo(hareDuClientParameters);
+        }
+
+        private static void outputOverviewInfo(HareDuClientParameters hareDuClientParameters)
+        {
+            Console.WriteLine("************ Overview *************");
+            var client = CreateHareDuClient(hareDuClientParameters);
+            var myrequestTask = client.Overview();
+            var responseTask = myrequestTask.ContinueWith((requestTask) =>
+            {
+                HttpResponseMessage response = requestTask.Result;
+                response.EnsureSuccessStatusCode();
+
+                var r = response.GetResponse<Overview>();
+                Console.WriteLine(r.queue_totals.messages);
+            });
+            responseTask.Wait();
+        }
+
+        private static void outputWhoAmIInfo(HareDuClientParameters hareDuClientParameters)
+        {
+            Console.WriteLine("************ WhoAmI *************");
+            var client = CreateHareDuClient(hareDuClientParameters);
+            var myrequestTask = client.WhoAmI();
+            var responseTask = myrequestTask.ContinueWith((requestTask) =>
+                            {
+                                HttpResponseMessage response = requestTask.Result;
+                                response.EnsureSuccessStatusCode();
+
+                                var r = response.GetResponse<WhoAmI>();
+                                Console.WriteLine("Name:" + r.Name);
+                                Console.WriteLine("Tags:" + r.Tags);
+                                Console.WriteLine("AuthBackend:" + r.AuthBackend);
+                            });
+            responseTask.Wait();
+        }
+
+        private static void outputPermissionInfo(HareDuClientParameters hareDuClientParameters)
+        {
+            Console.WriteLine("************ API/PERMISSIONS *************");
+            var client = CreateHareDuClient(hareDuClientParameters);
+            var myrequestTask = client.Permissions();
+            var responseTask = myrequestTask.ContinueWith((requestTask) =>
+            {
+                HttpResponseMessage response = requestTask.Result;
+                response.EnsureSuccessStatusCode();
+
+                var r = response.GetResponse < IEnumerable<Permission>>();
+                foreach (var permission in r )
+                {
+                    Console.WriteLine("-------------------");
+                    Console.WriteLine("START");
+                    Console.WriteLine("User:" + permission.User);
+                    Console.WriteLine("Virtual Host:" + permission.VirtualHost);
+                    Console.WriteLine("Configure:" + permission.Configure);
+                    Console.WriteLine("Write:" + permission.Write);
+                    Console.WriteLine("Read:" + permission.Read);
+                    Console.WriteLine("END");
+
+                }
+            });
+            responseTask.Wait();
+        }
+
+        private static HareDuClient CreateHareDuClient(HareDuClientParameters hareDuClientParameters)
+        {
+            var client = new HareDuClient(hareDuClientParameters.Url, hareDuClientParameters.Port,
+                                          hareDuClientParameters.Username, hareDuClientParameters.Password);
+            return client;
+        }
+
+        private static void deleteVirtualHost(HareDuClientParameters hareDuClientParameters, string hostToDelete)
+        {
+            if (string.IsNullOrWhiteSpace(hostToDelete))
+            {
+                Console.WriteLine("No virtual host to delete specified - deleting skipped");
+                return;
+            }
+            var client = CreateHareDuClient(hareDuClientParameters);
+            var requestTask = client.DeleteVirtualHost(hostToDelete);
+            var responseTask = requestTask.ContinueWith(x =>
+                                                            {
+                                                                HttpResponseMessage response = x.Result;
+                                                                Console.WriteLine("response.IsSuccessStatusCode" +
+                                                                                  response.IsSuccessStatusCode);
+                                                            });
+            responseTask.Wait();
+        }
+
+        public static void outputVirtualHostInfo(HareDuClientParameters hareDuClientParameters)
+        {
+            Console.WriteLine("************ VIRTUAL HOSTS *************");
+            var client = CreateHareDuClient(hareDuClientParameters);
+            var requestTask = client.GetListOfVirtualHosts();
+            var responseTask = requestTask.ContinueWith(x =>
+                                                            {
+                                                                var response = x.Result;
+
+                                                                foreach (
+                                                                    var virtualHost in
+                                                                        response.GetResponse<IEnumerable<VirtualHost>>()
+                                                                    )
+                                                                {
+                                                                    Console.WriteLine("-------------------");
+                                                                    Console.WriteLine("START");
+                                                                    Console.WriteLine("Virtual Host Name:" +
+                                                                                      virtualHost.Name);
+                                                                    Console.WriteLine("Virtual Host tracingflag: " +
+                                                                                      virtualHost.Tracing);
+                                                                    Console.WriteLine("END");
+                                                                }
+                                                            });
+            responseTask.Wait();
+        }
+
+        public static void outputOpenChannelInfo(HareDuClientParameters hareDuClientParameters)
+        {
+            Console.WriteLine("************ Open Channels *************");
+            var client = CreateHareDuClient(hareDuClientParameters);
             var requestTask = client.GetListOfAllOpenChannels();
-                                 var responseTask = requestTask.ContinueWith(x =>
-                                                   {
-                                                       var response = x.Result;
-
-                                                       foreach (var channel in response.GetResponse<IEnumerable<Channel>>())
-                                                       {
-                                                           Console.WriteLine(channel.Name);
-                                                           Console.WriteLine(channel.Node);
-                                                       }
-                                                   });
+            var responseTask = requestTask.ContinueWith(x =>
+                                                            {
+                                                                var response = x.Result;
+
+                                                                foreach (
+                                                                    var channel in
+                                                                        response.GetResponse<IEnumerable<Channel>>())
+                                                                {
+                                                                    Console.WriteLine(channel.Name);
+                                                                    Console.WriteLine(channel.Node);
+                                                                }
+                                                            });
             responseTask.Wait();
-                                 //Task.Factory.StartNew(() => requestTask);
-                                 //Task.Factory.StartNew(() => responseTask);
-            //.Result.Content.ReadAsAsync<IEnumerable<Channel>>().Result;
-
-            //foreach (var channelInfo in channels)
-            //{
-            //    Console.WriteLine(channelInfo.MessageStats.Published);
-            //    Console.WriteLine(channelInfo.MessageStats.Acknowledged);
-            //    Console.WriteLine(channelInfo.MessageStats.Delivered);
-            //    Console.WriteLine(channelInfo.MessageStats.DeliveredOrGet);
-            //    Console.WriteLine(channelInfo.MessageStats.Unacknowledged);
-            //    Console.WriteLine(channelInfo.MessageStats.Unconfirmed);
-            //    Console.WriteLine(channelInfo.MessageStats.Uncommitted);
-            //    Console.WriteLine(channelInfo.MessageStats.AcknowledgesUncommitted);
-            //}
         }
     }
 }

src/HareDu/HareDu.csproj

@@ -59,6 +59,7 @@
     <Compile Include="Contracts\CreateExchangeArgs.cs" />
     <Compile Include="Extensions\HttpExtensions.cs" />
     <Compile Include="HareDuBase.cs" />
+    <Compile Include="HareDuClientParameters.cs" />
     <Compile Include="Internal\CreateExchangeArgsImpl.cs" />
     <Compile Include="Model\Channel.cs" />
     <Compile Include="HareDuClient.cs" />
@@ -68,6 +69,10 @@
     <Compile Include="Model\ExchangeRoutingType.cs" />
     <Compile Include="Model\MessageStats.cs" />
     <Compile Include="Extensions\PrimitiveValueExtensions.cs" />
+    <Compile Include="Model\Overview.cs" />
+    <Compile Include="Model\Permission.cs" />
+    <Compile Include="Model\VirtualHost.cs" />
+    <Compile Include="Model\WhoAmI.cs" />
     <Compile Include="Model\Queue.cs" />
     <Compile Include="Model\UserPermissions.cs" />
     <Compile Include="Properties\AssemblyInfo.cs" />

src/HareDu/HareDuClient.cs

@@ -15,8 +15,41 @@ public HareDuClient(string hostUrl, int port, string username, string password)
         {
         }
 
+        #region api/overview
+
+        public Task<HttpResponseMessage> Overview()
+        {
+            return Get("api/overview");
+        }
+
+        #endregion
+
+        #region api/whoami
+
+        public Task<HttpResponseMessage> WhoAmI()
+        {
+            return Get("api/whoami");
+        }
+
+        #endregion
+
+        #region Permissions
+
+        public Task<HttpResponseMessage> Permissions()
+        {
+            return Get("api/permissions");
+        }
+
+        #endregion
+
         #region Connectivity
 
+        //old
+        public Task<HttpResponseMessage> GetListOfAllOpenConnections()
+        {
+            return Get("api/connections");
+        }
+
         public Task<HttpResponseMessage> GetListOfAllOpenConnections(CancellationToken cancellationToken =
                                                                          default(CancellationToken))
         {
@@ -270,7 +303,7 @@ public virtual Task<HttpResponseMessage> DeleteQueue(string virtualHostName, str
             return cancellationToken == default(CancellationToken) ? Delete(url) : Delete(url, cancellationToken);
         }
 
-        #endregion
+#endregion
 
         #region Exchanges
 

src/HareDu/HareDuClientParameters.cs

@@ -0,0 +1,38 @@
+namespace HareDu
+{
+    public class HareDuClientParameters
+    {
+        private readonly string _url;
+        private readonly int _port;
+        private readonly string _username;
+        private readonly string _password;
+
+        public HareDuClientParameters(string url, int port, string username, string password)
+        {
+            _url = url;
+            _port = port;
+            _username = username;
+            _password = password;
+        }
+
+        public string Url
+        {
+            get { return _url; }
+        }
+
+        public int Port
+        {
+            get { return _port; }
+        }
+
+        public string Username
+        {
+            get { return _username; }
+        }
+
+        public string Password
+        {
+            get { return _password; }
+        }
+    }
+}