QPID-4639: Add UI to add/delete virtual hosts into java broker web management console

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1455274 13f79535-47bb-0310-9956-ffa450edef68

9 files changed, 381 insertions, 8 deletions

diff --git a/java/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/servlet/rest/HelperServlet.java b/java/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/servlet/rest/HelperServlet.java
index fa82632dc1..3c6fb1c44d 100644
--- a/java/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/servlet/rest/HelperServlet.java
+++ b/java/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/servlet/rest/HelperServlet.java
@@ -32,6 +32,7 @@ import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
 
 import org.apache.qpid.server.management.plugin.servlet.rest.action.ListAuthenticationProviderAttributes;
+import org.apache.qpid.server.management.plugin.servlet.rest.action.ListMessageStoreTypes;
 import org.apache.qpid.server.model.Broker;
 import org.codehaus.jackson.map.ObjectMapper;
 import org.codehaus.jackson.map.SerializationConfig;
@@ -50,6 +51,8 @@ public class HelperServlet extends AbstractServlet
         _actions = new HashMap<String, Action>();
         Action listProviderAttributes = new ListAuthenticationProviderAttributes();
         _actions.put(listProviderAttributes.getName(), listProviderAttributes);
+        Action listMessageStoreTypes = new ListMessageStoreTypes();
+        _actions.put(listMessageStoreTypes.getName(), listMessageStoreTypes);
     }
 
     @Override
diff --git a/java/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/servlet/rest/action/ListMessageStoreTypes.java b/java/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/servlet/rest/action/ListMessageStoreTypes.java
new file mode 100644
index 0000000000..4166736c01
--- /dev/null
+++ b/java/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/servlet/rest/action/ListMessageStoreTypes.java
@@ -0,0 +1,23 @@
+package org.apache.qpid.server.management.plugin.servlet.rest.action;
+
+import java.util.Map;
+
+import org.apache.qpid.server.management.plugin.servlet.rest.Action;
+import org.apache.qpid.server.model.Broker;
+
+public class ListMessageStoreTypes implements Action
+{
+
+    @Override
+    public String getName()
+    {
+        return ListMessageStoreTypes.class.getSimpleName();
+    }
+
+    @Override
+    public Object perform(Map<String, Object> request, Broker broker)
+    {
+        return broker.getAttribute(Broker.SUPPORTED_STORE_TYPES);
+    }
+
+}
diff --git a/java/broker-plugins/management-http/src/main/java/resources/addVirtualHost.html b/java/broker-plugins/management-http/src/main/java/resources/addVirtualHost.html
new file mode 100644
index 0000000000..d66e0e1b03
--- /dev/null
+++ b/java/broker-plugins/management-http/src/main/java/resources/addVirtualHost.html
@@ -0,0 +1,71 @@
+<!--
+ -
+ - Licensed to the Apache Software Foundation (ASF) under one
+ - or more contributor license agreements.  See the NOTICE file
+ - distributed with this work for additional information
+ - regarding copyright ownership.  The ASF licenses this file
+ - to you under the Apache License, Version 2.0 (the
+ - "License"); you may not use this file except in compliance
+ - with the License.  You may obtain a copy of the License at
+ -
+ -   http://www.apache.org/licenses/LICENSE-2.0
+ -
+ - Unless required by applicable law or agreed to in writing,
+ - software distributed under the License is distributed on an
+ - "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ - KIND, either express or implied.  See the License for the
+ - specific language governing permissions and limitations
+ - under the License.
+ -
+ -->
+<div class="dijitHidden">
+    <div data-dojo-type="dijit.Dialog" style="width:600px;" data-dojo-props="title:'Add Virtual Host'" id="addVirtualHost">
+        <form id="formAddVirtualHost" method="post" dojoType="dijit.form.Form">
+            <table class="tableContainer-table tableContainer-table-horiz">
+                <tr>
+                    <td class="tableContainer-labelCell" style="width: 300px;"><strong>Name*: </strong></td>
+                    <td class="tableContainer-valueCell">
+                        <input type="text" required="true" name="name" id="formAddVirtualHost.name"
+                            placeholder="Virtual Host Name" dojoType="dijit.form.ValidationTextBox"
+                            missingMessage="A name must be supplied" />
+                    </td>
+                </tr>
+            </table>
+            <br />
+            <div>Specify either a store type and location, or an XML configuration file location, but not both.</div>
+            <div style="height: 300px;" id="addVirtualHost.variants">
+                <div id="addVirtualHost.configPathDiv">
+                    <table class="tableContainer-table tableContainer-table-horiz">
+                        <tr>
+                            <td class="tableContainer-labelCell" style="width: 300px;"><strong>Path to virtual host configuration file*: </strong></td>
+                            <td class="tableContainer-valueCell">
+                                <input dojoType="dijit.form.ValidationTextBox" id="formAddVirtualHost.configPath"
+                                   name="configPath" placeholder="/path/to/virtualhost.xml" />
+                            </td>
+                        </tr>
+                    </table>
+                </div>
+                <div id="addVirtualHost.attributesDiv">
+                    <table class="tableContainer-table tableContainer-table-horiz">
+                        <tr>
+                            <td class="tableContainer-labelCell" style="width: 300px;"><strong>Store Type*:  </strong></td>
+                            <td class="tableContainer-valueCell" ><div id="addVirtualHost.selectStoreType"></div></td>
+                        </tr>
+                        <tr>
+                            <td class="tableContainer-labelCell" style="width: 300px;"><strong>Path to store location*:  </strong></td>
+                            <td class="tableContainer-valueCell">
+                                <input dojoType="dijit.form.ValidationTextBox" id="formAddVirtualHost.storePath"
+                                       name="storePath" placeholder="/path/to/message/store" />
+                            </td>
+                        </tr>
+                    </table>
+                </div>
+            </div>
+
+            <br/>
+            <!-- submit buttons -->
+            <input type="submit" value="Save" label="Save" dojoType="dijit.form.Button" />
+            <input type="hidden" id="formAddVirtualHost.id" name="id"/>
+        </form>
+    </div>
+</div>
diff --git a/java/broker-plugins/management-http/src/main/java/resources/js/qpid/management/Broker.js b/java/broker-plugins/management-http/src/main/java/resources/js/qpid/management/Broker.js
index 9b4e7aa3f9..84a0d8ca68 100644
--- a/java/broker-plugins/management-http/src/main/java/resources/js/qpid/management/Broker.js
+++ b/java/broker-plugins/management-http/src/main/java/resources/js/qpid/management/Broker.js
@@ -29,10 +29,13 @@ define(["dojo/_base/xhr",
         "dojox/grid/EnhancedGrid",
         "dijit/registry",
         "qpid/management/addAuthenticationProvider",
+        "qpid/management/addVirtualHost",
         "dojox/grid/enhanced/plugins/Pagination",
         "dojox/grid/enhanced/plugins/IndirectSelection",
+        "dijit/layout/AccordionContainer",
+        "dijit/layout/AccordionPane",
         "dojo/domReady!"],
-       function (xhr, parser, query, connect, properties, updater, util, UpdatableStore, EnhancedGrid, registry, addAuthenticationProvider) {
+       function (xhr, parser, query, connect, properties, updater, util, UpdatableStore, EnhancedGrid, registry, addAuthenticationProvider, addVirtualHost) {
 
            function Broker(name, parent, controller) {
                this.name = name;
@@ -78,6 +81,19 @@ define(["dojo/_base/xhr",
                                 }
                             );
 
+                            var addHostButton = query(".addVirtualHost", contentPane.containerNode)[0];
+                            connect.connect(registry.byNode(addHostButton), "onClick", function(evt){ addVirtualHost.show(); });
+
+                            var deleteHostButton = query(".deleteVirtualHost", contentPane.containerNode)[0];
+                            connect.connect(registry.byNode(deleteHostButton), "onClick",
+                                    function(evt){
+                                        util.deleteGridSelections(
+                                                that.brokerUpdater,
+                                                that.brokerUpdater.vhostsGrid.grid,
+                                                "rest/virtualhost",
+                                                "Deletion of virtual will delete the message store data.\n\n Are you sure you want to delete virtual host");
+                                }
+                            );
                         }});
            };
 
@@ -105,6 +121,22 @@ define(["dojo/_base/xhr",
                              util.flattenStatistics( that.brokerData);
 
                              that.updateHeader();
+
+                             var gridProperties = {
+                                     height: 400,
+                                     plugins: {
+                                              pagination: {
+                                                  pageSizes: ["10", "25", "50", "100"],
+                                                  description: true,
+                                                  sizeSwitch: true,
+                                                  pageStepper: true,
+                                                  gotoButton: true,
+                                                  maxPageStep: 4,
+                                                  position: "bottom"
+                                              },
+                                              indirectSelection: true
+                                     }};
+
                              that.vhostsGrid =
                                 new UpdatableStore(that.brokerData.vhosts, query(".broker-virtualhosts")[0],
                                                 [ { name: "Virtual Host",    field: "name",      width: "120px"},
@@ -119,7 +151,7 @@ define(["dojo/_base/xhr",
                                                             var name = obj.dataStore.getValue(theItem,"name");
                                                             that.controller.show("virtualhost", name, brokerObj);
                                                         });
-                                                });
+                                                }, gridProperties, EnhancedGrid);
 
                              that.portsGrid =
                                 new UpdatableStore(that.brokerData.ports, query(".broker-ports")[0],
@@ -137,7 +169,7 @@ define(["dojo/_base/xhr",
                                                         });
                                                 });
 
-                             var gridProperties = {
+                             gridProperties = {
                                      keepSelection: true,
                                      plugins: {
                                                indirectSelection: true
diff --git a/java/broker-plugins/management-http/src/main/java/resources/js/qpid/management/VirtualHost.js b/java/broker-plugins/management-http/src/main/java/resources/js/qpid/management/VirtualHost.js
index 2efc46476d..ceab5640d3 100644
--- a/java/broker-plugins/management-http/src/main/java/resources/js/qpid/management/VirtualHost.js
+++ b/java/broker-plugins/management-http/src/main/java/resources/js/qpid/management/VirtualHost.js
@@ -134,7 +134,10 @@ define(["dojo/_base/xhr",
                            "bytesInRateUnits",
                            "msgOutRate",
                            "bytesOutRate",
-                           "bytesOutRateUnits"]);
+                           "bytesOutRateUnits",
+                           "storeType",
+                           "storePath",
+                           "configPath"]);
 
                this.query = "rest/virtualhost/"+ encodeURIComponent(vhost.name);
 
@@ -143,6 +146,11 @@ define(["dojo/_base/xhr",
                xhr.get({url: this.query, sync: properties.useSyncGet, handleAs: "json"}).then(function(data) {
                    that.vhostData = data[0];
 
+                   if (!that.vhostData.hasOwnProperty("configPath"))
+                   {
+                       var node = findNode("configPathDiv");
+                       node.style.display = "none";
+                   }
                        // flatten statistics into attributes
                        util.flattenStatistics( that.vhostData );
 
@@ -233,8 +241,9 @@ define(["dojo/_base/xhr",
                this.state.innerHTML = this.vhostData[ "state" ];
                this.durable.innerHTML = this.vhostData[ "durable" ];
                this.lifetimePolicy.innerHTML = this.vhostData[ "lifetimePolicy" ];
-
-
+               this.storeType.innerHTML = this.vhostData[ "storeType" ];
+               this.storePath.innerHTML = this.vhostData[ "storePath" ];
+               this.configPath.innerHTML = this.vhostData[ "configPath" ];
            };
 
            Updater.prototype.update = function()
diff --git a/java/broker-plugins/management-http/src/main/java/resources/js/qpid/management/addVirtualHost.js b/java/broker-plugins/management-http/src/main/java/resources/js/qpid/management/addVirtualHost.js
new file mode 100644
index 0000000000..9c04c3014f
--- /dev/null
+++ b/java/broker-plugins/management-http/src/main/java/resources/js/qpid/management/addVirtualHost.js
@@ -0,0 +1,211 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+define(["dojo/_base/xhr",
+        "dojo/dom",
+        "dojo/dom-construct",
+        "dojo/_base/window",
+        "dijit/registry",
+        "dojo/parser",
+        "dojo/_base/array",
+        "dojo/_base/event",
+        'dojo/_base/json',
+        "dojo/store/Memory",
+        "dijit/form/FilteringSelect",
+        "dojo/_base/connect",
+        "dojo/dom-style",
+        "dijit/form/NumberSpinner", // required by the form
+        /* dojox/ validate resources */
+        "dojox/validate/us", "dojox/validate/web",
+        /* basic dijit classes */
+        "dijit/Dialog",
+        "dijit/form/CheckBox", "dijit/form/Textarea",
+        "dijit/form/FilteringSelect", "dijit/form/TextBox",
+        "dijit/form/ValidationTextBox", "dijit/form/DateTextBox",
+        "dijit/form/TimeTextBox", "dijit/form/Button",
+        "dijit/form/RadioButton", "dijit/form/Form",
+        "dijit/form/DateTextBox",
+        /* basic dojox classes */
+        "dojox/form/BusyButton", "dojox/form/CheckedMultiSelect",
+        "dojox/layout/TableContainer",
+        "dijit/layout/AccordionContainer",
+        "dijit/layout/AccordionPane",
+        "dojo/domReady!"],
+    function (xhr, dom, construct, win, registry, parser, array, event, json, Memory, FilteringSelect, connect, domStyle) {
+
+        var addVirtualHost = {};
+
+        var node = construct.create("div", null, win.body(), "last");
+
+        var convertToVirtualHost = function convertToVirtualHost(formValues)
+        {
+            var newVirtualHost = {};
+            var id = dojo.byId("formAddVirtualHost.id").value;
+            if (id)
+            {
+                newVirtualHost.id = id;
+            }
+            for(var propName in formValues)
+            {
+                if(formValues.hasOwnProperty(propName))
+                {
+                    if(formValues[ propName ] !== "") {
+                        newVirtualHost[ propName ] = formValues[propName];
+                    }
+
+                }
+            }
+
+            return newVirtualHost;
+        }
+
+        if (!dijit.registry["addVirtualHost"])
+        {
+            var that = this;
+            xhr.get({url: "addVirtualHost.html",
+                 sync: true,
+                 load:  function(data) {
+                            var theForm;
+                            node.innerHTML = data;
+                            addVirtualHost.dialogNode = dom.byId("addVirtualHost");
+                            parser.instantiate([addVirtualHost.dialogNode]);
+
+                            var configPathPane =  new dijit.layout.AccordionPane({
+                                title: "Configuration File"
+                            }, "addVirtualHost.configPathDiv");
+
+                            var attributesPane =  new dijit.layout.AccordionPane({
+                                title: "Store Attributes",
+                                selected: true
+                            }, "addVirtualHost.attributesDiv");
+
+                            var aContainer = new dijit.layout.AccordionContainer({
+                                style: "height: 150px"
+                            },
+                            "addVirtualHost.variants");
+
+                            aContainer.addChild(attributesPane);
+                            aContainer.addChild(configPathPane);
+                            aContainer.startup();
+
+                            theForm = registry.byId("formAddVirtualHost");
+                            theForm.on("submit", function(e) {
+
+                                event.stop(e);
+                                if(theForm.validate()){
+
+                                    var formValues = theForm.getValues();
+                                    if (formValues.configPath == "" && formValues.storeType == "")
+                                    {
+                                        alert("Please specify either configuration or store type for the virtual host");
+                                        return false;
+                                    }
+                                    if (formValues.configPath != "" && formValues.storeType != "")
+                                    {
+                                        alert("Either configuration or store type with path have to be specified!");
+                                        return false;
+                                    }
+                                    var newVirtualHost = convertToVirtualHost(formValues);
+                                    var that = this;
+
+                                    xhr.put({url: "rest/virtualhost/" + encodeURIComponent(newVirtualHost.name),
+                                             sync: true, handleAs: "json",
+                                             headers: { "Content-Type": "application/json"},
+                                             putData: json.toJson(newVirtualHost),
+                                             load: function(x) {that.success = true; },
+                                             error: function(error) {that.success = false; that.failureReason = error;}});
+
+                                    if(this.success === true)
+                                    {
+                                        registry.byId("addVirtualHost").hide();
+                                    }
+                                    else
+                                    {
+                                        alert("Error:" + this.failureReason);
+                                    }
+                                    return false;
+                                }else{
+                                    alert('Form contains invalid data.  Please correct first');
+                                    return false;
+                                }
+                            });
+                        }});
+        }
+
+        addVirtualHost.show = function(virtualHostName) {
+            var that = this;
+            registry.byId("formAddVirtualHost").reset();
+            dojo.byId("formAddVirtualHost.id").value="";
+            if (!that.hasOwnProperty("storeTypeChooser"))
+            {
+                xhr.get({
+                    sync: true,
+                    url: "rest/helper?action=ListMessageStoreTypes",
+                    handleAs: "json"
+                }).then(
+                   function(data) {
+                       var storeTypes =  data;
+                       var storeTypesData = [];
+                       for (var i =0 ; i < storeTypes.length; i++)
+                       {
+                           storeTypesData[i]= {id: storeTypes[i], name: storeTypes[i]};
+                       }
+                       var storeTypesStore = new Memory({ data: storeTypesData });
+                       var storeTypesDiv = dom.byId("addVirtualHost.selectStoreType");
+                       var input = construct.create("input", {id: "addStoreType", required: false}, storeTypesDiv);
+                       that.storeTypeChooser = new FilteringSelect({ id: "addVirtualHost.storeType",
+                                                                 name: "storeType",
+                                                                 store: storeTypesStore,
+                                                                 searchAttr: "name", required: false}, input);
+               });
+            }
+            if (virtualHostName)
+            {
+                xhr.get({
+                    url: "rest/virtualhost/" + encodeURIComponent(virtualHostName),
+                    handleAs: "json"
+                }).then(
+                   function(data) {
+                       var host = data[0];
+                       var nameField = dijit.byId("formAddVirtualHost.name");
+                       nameField.set("value", host.name);
+                       dojo.byId("formAddVirtualHost.id").value=host.id;
+                       var configPath = host.configPath;
+                       if (configPath)
+                       {
+                           var configPathField = dijit.byId("formAddVirtualHost.configPath");
+                           configPathField.set("value", host.configPath);
+                       }
+                       else
+                       {
+                           that.storeTypeChooser.set("value", host.storeType.toLowerCase());
+                           var storePathField = dijit.byId("formAddVirtualHost.storePath");
+                           storePathField.set("value", host.storePath);
+                       }
+                       registry.byId("addVirtualHost").show();
+               });
+            }
+            else
+            {
+                registry.byId("addVirtualHost").show();
+            }
+        }
+        return addVirtualHost;
+    });
\ No newline at end of file
diff --git a/java/broker-plugins/management-http/src/main/java/resources/showBroker.html b/java/broker-plugins/management-http/src/main/java/resources/showBroker.html
index f656124a2a..527d38c333 100644
--- a/java/broker-plugins/management-http/src/main/java/resources/showBroker.html
+++ b/java/broker-plugins/management-http/src/main/java/resources/showBroker.html
@@ -30,6 +30,8 @@
     <br/>
     <div data-dojo-type="dijit.TitlePane" data-dojo-props="title: 'Virtual Hosts'">
         <div class="broker-virtualhosts"></div>
+        <button data-dojo-type="dijit.form.Button" class="addVirtualHost">Add Virtual Host</button>
+        <button data-dojo-type="dijit.form.Button" class="deleteVirtualHost">Delete Virtual Host</button>
     </div>
     <br/>
     <div data-dojo-type="dijit.TitlePane" data-dojo-props="title: 'Ports'">
diff --git a/java/broker-plugins/management-http/src/main/java/resources/showVirtualHost.html b/java/broker-plugins/management-http/src/main/java/resources/showVirtualHost.html
index 73c912e0d4..14833e0d2e 100644
--- a/java/broker-plugins/management-http/src/main/java/resources/showVirtualHost.html
+++ b/java/broker-plugins/management-http/src/main/java/resources/showVirtualHost.html
@@ -39,6 +39,13 @@
     <span class="bytesOutRate" style="position:absolute; right: 3.3em"></span>
     <span class="bytesOutRateUnits" style="position:absolute; right: 0em; width: 3em"></span>
     <br/>
+    <span style="">Store Type:</span><span style="position:absolute; left:6em" class="storeType"></span>
+    <span style="position:absolute; left:26em">Store Path:</span>
+    <span class="storePath" style="position:absolute; right: 1em"></span>
+    <div class="configPathDiv">
+        <span style="">ConfigPath:</span><span style="position:absolute; left:6em" class="configPath"></span>
+    </div>
+
     <br/>
     <div data-dojo-type="dijit.TitlePane" data-dojo-props="title: 'Exchanges'">
         <div class="exchanges"></div>
diff --git a/java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/JMXManagement.java b/java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/JMXManagement.java
index d725dc4dc3..3342aea4fb 100644
--- a/java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/JMXManagement.java
+++ b/java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/JMXManagement.java
@@ -297,12 +297,27 @@ public class JMXManagement extends AbstractPluginAdapter implements Configuratio
                     }
                     catch(JMException e)
                     {
-                        LOGGER.error("Error creating mbean", e);
+                        LOGGER.error("Error unregistering user management mbean: " + child.getName(), e);
+                        //TODO - report error on removing child MBean
+                    }
+                }
+            }
+            else if (child instanceof VirtualHost)
+            {
+                AMQManagedObject mbean = _children.remove(child);
+                if(mbean != null)
+                {
+                    try
+                    {
+                        mbean.unregister();
+                    }
+                    catch(JMException e)
+                    {
+                        LOGGER.error("Error unregistering virtual host mbean :" + child.getName(), e);
                         //TODO - report error on removing child MBean
                     }
                 }
             }
-
         }
     }