broker-plugins/management-http/src/main/java/resources/js/qpid/management/Exchange.js

/*
 *
 * 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/parser",
        "dojo/query",
        "dojo/_base/connect",
        "dojo/_base/event",
        "dojo/json",
        "dojo/_base/lang",
        "dojo/promise/all",
        "dijit/registry",
        "qpid/common/properties",
        "qpid/common/updater",
        "qpid/common/util",
        "qpid/common/formatter",
        "qpid/common/UpdatableStore",
        "qpid/management/addBinding",
        "qpid/management/addExchange",
        "dojox/grid/EnhancedGrid",
        "dojox/html/entities",
        "dojo/text!showExchange.html",
        "qpid/common/StatisticsWidget",
        "dojo/domReady!"],
    function (xhr,
              parser,
              query,
              connect,
              event,
              json,
              lang,
              all,
              registry,
              properties,
              updater,
              util,
              formatter,
              UpdatableStore,
              addBinding,
              addExchange,
              EnhancedGrid,
              entities,
              template,
              StatisticsWidget)
    {

        function Exchange(kwArgs)
        {
            this.controller = kwArgs.controller;
            this.modelObj = kwArgs.tabData.modelObject;
            this.management = this.controller.management;
            this.name = this.modelObj.name;
        }

        Exchange.prototype.getExchangeName = function ()
        {
            return this.name;
        };

        Exchange.prototype.getVirtualHostName = function ()
        {
            return this.modelObj.parent.name;
        };

        Exchange.prototype.getVirtualHostNodeName = function ()
        {
            return this.modelObj.parent.parent.name;
        };

        Exchange.prototype.getTitle = function ()
        {
            return "Exchange: " + this.name;
        };

        Exchange.prototype.open = function (contentPane)
        {
            var that = this;
            this.contentPane = contentPane;

            contentPane.containerNode.innerHTML = template;
            parser.parse(contentPane.containerNode)
                .then(function (instances)
                {

                    that.exchangeUpdater = new ExchangeUpdater(that);
                    var addBindingButton = query(".addBindingButton", contentPane.containerNode)[0];
                    connect.connect(registry.byNode(addBindingButton), "onClick", function (evt)
                    {
                        event.stop(evt);
                        addBinding.show(that.management, that.modelObj);
                    });

                    var deleteBindingButton = query(".deleteBindingButton", contentPane.containerNode)[0];
                    connect.connect(registry.byNode(deleteBindingButton), "onClick", function (evt)
                    {
                        event.stop(evt);
                        that.deleteBindings();
                    });
                    var editExchangeButton = query(".editExchangeButton", contentPane.containerNode)[0];
                    connect.connect(registry.byNode(editExchangeButton), "onClick", function (evt)
                    {
                        event.stop(evt);
                        addExchange.show(that.management, that.modelObj, that.exchangeUpdater.exchangeData);
                    });

                    var isStandard = util.isReservedExchangeName(that.name);
                    var deleteExchangeButton = query(".deleteExchangeButton", contentPane.containerNode)[0];
                    var node = registry.byNode(deleteExchangeButton);
                    if (isStandard)
                    {
                        node.set('disabled', true);
                    }
                    else
                    {
                        connect.connect(node, "onClick", function (evt)
                        {
                            event.stop(evt);
                            that.deleteExchange();
                        });
                    }

                    that.exchangeUpdater.update(function ()
                    {
                        updater.add(that.exchangeUpdater)
                    });
                });
        };

        Exchange.prototype.close = function ()
        {
            updater.remove(this.exchangeUpdater);
        };

        Exchange.prototype.deleteBindings = function ()
        {
            var deletePromises = [];
            var deleteSelectedBindings = lang.hitch(this, function (data)
            {
                for (var i = 0; i < data.length; i++)
                {
                    var selectedItem = data[i];
                    var promise = this.management.update({
                            type: "exchange",
                            name: "unbind",
                            parent: this.modelObj
                        },
                        {
                            destination: selectedItem.destination,
                            bindingKey: selectedItem.bindingKey
                        });
                    promise.then(lang.hitch(this, function ()
                    {
                        this.exchangeUpdater.bindingsGrid.grid.selection.setSelected(selectedItem, false);
                    }));
                    deletePromises.push(promise);
                }
            });
            util.confirmAndDeleteGridSelection(
                this.exchangeUpdater.bindingsGrid.grid,
                "Are you sure you want to delete binding",
                deleteSelectedBindings);
            all(deletePromises)
                .then(lang.hitch(this, function ()
                {
                    this.exchangeUpdater.update();
                }));
        };

        function ExchangeUpdater(exchangeTab)
        {
            var that = this;
            this.tabObject = exchangeTab;
            this.management = exchangeTab.controller.management;
            this.modelObj = exchangeTab.modelObj;
            this.contentPane = exchangeTab.contentPane;
            var containerNode = exchangeTab.contentPane.containerNode;

            function findNode(name)
            {
                return query("." + name, containerNode)[0];
            }

            function storeNodes(names)
            {
                for (var i = 0; i < names.length; i++)
                {
                    that[names[i]] = findNode(names[i]);
                }
            }
            this.exchangeStatisticsNode = findNode("exchangeStatistics");

            storeNodes(["name",
                        "type",
                        "state",
                        "durable",
                        "lifetimePolicy",
                        "alternateBinding",
                        "unroutableMessageBehaviour"]);

            that.exchangeData = {};

            that.bindingsGrid = new UpdatableStore([], findNode("bindings"), [{
                name: "Destination",
                field: "destination",
                width: "40%"
            }, {
                name: "Binding Key",
                field: "bindingKey",
                width: "30%"
            }, {
                name: "Arguments",
                field: "arguments",
                width: "30%",
                formatter: function (args)
                {
                    return args ? json.stringify(args) : ""
                }
            }], null, {
                keepSelection: true,
                plugins: {
                    pagination: {
                        pageSizes: ["10", "25", "50", "100"],
                        description: true,
                        sizeSwitch: true,
                        pageStepper: true,
                        gotoButton: true,
                        maxPageStep: 4,
                        position: "bottom"
                    },
                    indirectSelection: true

                }
            }, EnhancedGrid);
        }

        ExchangeUpdater.prototype.updateHeader = function ()
        {
            this.name.innerHTML = entities.encode(String(this.exchangeData["name"]));
            this["type"].innerHTML = entities.encode(String(this.exchangeData["type"]));

            this.state.innerHTML = entities.encode(String(this.exchangeData["state"]));
            this.durable.innerHTML = entities.encode(String(this.exchangeData["durable"]));
            this.lifetimePolicy.innerHTML = entities.encode(String(this.exchangeData["lifetimePolicy"]));
            this.unroutableMessageBehaviour.innerHTML = entities.encode(String(this.exchangeData["unroutableMessageBehaviour"]));
            this.alternateBinding.innerHTML =
                this.exchangeData["alternateBinding"] && this.exchangeData["alternateBinding"]["destination"]
                    ? entities.encode(String(this.exchangeData["alternateBinding"]["destination"])) : "";
        };

        ExchangeUpdater.prototype.update = function (callback)
        {
            if (!this.contentPane.selected && !callback)
            {
                return;
            }

            var thisObj = this;

            this.management.load(this.modelObj, {excludeInheritedContext: true})
                .then(function (data)
                {
                    thisObj.exchangeData = data;

                    if (!thisObj.exchangeStatistics)
                    {
                        thisObj.exchangeStatistics = new StatisticsWidget({
                            category:  "Exchange",
                            type: thisObj.exchangeData.type,
                            management: thisObj.management,
                            defaultStatistics: ["messagesIn", "messagesDropped"]
                        });
                        thisObj.exchangeStatistics.placeAt(thisObj.exchangeStatisticsNode);
                        thisObj.exchangeStatistics.startup();
                    }

                    if (callback)
                    {
                        callback();
                    }

                    var bindings = thisObj.exchangeData.bindings || [];
                    for (var i = 0; i < bindings.length; i++)
                    {
                        bindings[i].name = bindings[i].bindingKey + "\" for \"" + bindings[i].destination;
                        bindings[i].id = bindings[i].destination + "/" + bindings[i].bindingKey;
                    }

                    thisObj.exchangeStatistics.update(thisObj.exchangeData.statistics);
                    thisObj.updateHeader();

                    // update bindings
                    thisObj.bindingsGrid.grid.beginUpdate();
                    try
                    {
                        thisObj.bindingsGrid.update(bindings);
                    }
                    finally
                    {
                        thisObj.bindingsGrid.grid.endUpdate()
                    }

                }, function (error)
                {
                    util.tabErrorHandler(error, {
                        updater: thisObj,
                        contentPane: thisObj.tabObject.contentPane,
                        tabContainer: thisObj.tabObject.controller.tabContainer,
                        name: thisObj.modelObj.name,
                        category: "Exchange"
                    });
                });
        };

        Exchange.prototype.deleteExchange = function ()
        {
            if (confirm("Are you sure you want to delete exchange '" + this.name + "'?"))
            {
                var that = this;
                this.management.remove(this.modelObj)
                    .then(function (data)
                    {
                        that.contentPane.onClose();
                        that.controller.tabContainer.removeChild(that.contentPane);
                        that.contentPane.destroyRecursive();
                    }, util.xhrErrorHandler);
            }
        };

        return Exchange;
    });