http://git-wip-us.apache.org/repos/asf/qpid-dispatch/blob/dfd3cf7c/console/stand-alone/plugin/js/qdrSettings.js ---------------------------------------------------------------------- diff --git a/console/stand-alone/plugin/js/qdrSettings.js b/console/stand-alone/plugin/js/qdrSettings.js new file mode 100644 index 0000000..7f34758 --- /dev/null +++ b/console/stand-alone/plugin/js/qdrSettings.js @@ -0,0 +1,172 @@ +/* +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. +*/ +'use strict'; +/* global angular */ +/** + * @module QDR + */ +var QDR = (function(QDR) { + + /** + * @method SettingsController + * @param $scope + * @param QDRServer + * + * Controller that handles the QDR settings page + */ + + QDR.module.controller('QDR.SettingsController', ['$scope', 'QDRService', 'QDRChartService', '$timeout', function($scope, QDRService, QDRChartService, $timeout) { + + $scope.connecting = false; + $scope.connectionError = false; + $scope.connectionErrorText = undefined; + $scope.forms = {}; + + $scope.formEntity = angular.fromJson(localStorage[QDR.SETTINGS_KEY]) || { + address: '', + port: '', + username: '', + password: '', + autostart: false + }; + + $scope.$watch('formEntity', function(newValue, oldValue) { + if (newValue !== oldValue) { + localStorage[QDR.SETTINGS_KEY] = angular.toJson(newValue); + } + }, true); + + $scope.buttonText = function() { + if (QDRService.management.connection.is_connected()) { + return 'Disconnect'; + } else { + return 'Connect'; + } + }; + + // connect/disconnect button clicked + $scope.connect = function() { + if (QDRService.management.connection.is_connected()) { + $timeout( function () { + QDRService.disconnect(); + }); + return; + } + + if ($scope.settings.$valid) { + $scope.connectionError = false; + $scope.connecting = true; + // timeout so connecting animation can display + $timeout(function () { + doConnect(); + }); + } + }; + + var doConnect = function() { + QDR.log.info('doConnect called on connect page'); + if (!$scope.formEntity.address) + $scope.formEntity.address = 'localhost'; + if (!$scope.formEntity.port) + $scope.formEntity.port = 5673; + + var failed = function() { + $timeout(function() { + $scope.connecting = false; + $scope.connectionErrorText = 'Unable to connect to ' + $scope.formEntity.address + ':' + $scope.formEntity.port; + $scope.connectionError = true; + }); + }; + let options = {address: $scope.formEntity.address, port: $scope.formEntity.port, reconnect: true}; + QDRService.connect(options) + .then( function () { + // register a callback for when the node list is available (needed for loading saved charts) + QDRService.management.topology.addUpdatedAction('initChartService', function() { + QDRService.management.topology.delUpdatedAction('initChartService'); + QDRChartService.init(); // initialize charting service after we are connected + }); + // get the list of nodes + QDRService.management.topology.startUpdating(false); + // will have redirected to last known page or /overview + }, function (e) { + failed(e); + }); + }; + }]); + + + QDR.module.directive('posint', function() { + return { + require: 'ngModel', + + link: function(scope, elem, attr, ctrl) { + // input type number allows + and - but we don't want them so filter them out + elem.bind('keypress', function(event) { + let nkey = !event.charCode ? event.which : event.charCode; + let skey = String.fromCharCode(nkey); + let nono = '-+.,'; + if (nono.indexOf(skey) >= 0) { + event.preventDefault(); + return false; + } + // firefox doesn't filter out non-numeric input. it just sets the ctrl to invalid + if (/[!@#$%^&*()]/.test(skey) && event.shiftKey || // prevent shift numbers + !( // prevent all but the following + nkey <= 0 || // arrows + nkey == 8 || // delete|backspace + nkey == 13 || // enter + (nkey >= 37 && nkey <= 40) || // arrows + event.ctrlKey || event.altKey || // ctrl-v, etc. + /[0-9]/.test(skey)) // numbers + ) { + event.preventDefault(); + return false; + } + }); + // check the current value of input + var _isPortInvalid = function(value) { + let port = value + ''; + let isErrRange = false; + // empty string is valid + if (port.length !== 0) { + let n = ~~Number(port); + if (n < 1 || n > 65535) { + isErrRange = true; + } + } + ctrl.$setValidity('range', !isErrRange); + return isErrRange; + }; + + //For DOM -> model validation + ctrl.$parsers.unshift(function(value) { + return _isPortInvalid(value) ? undefined : value; + }); + + //For model -> DOM validation + ctrl.$formatters.unshift(function(value) { + _isPortInvalid(value); + return value; + }); + } + }; + }); + + return QDR; +}(QDR || {}));
http://git-wip-us.apache.org/repos/asf/qpid-dispatch/blob/dfd3cf7c/console/stand-alone/plugin/js/qdrTopAddressesController.js ---------------------------------------------------------------------- diff --git a/console/stand-alone/plugin/js/qdrTopAddressesController.js b/console/stand-alone/plugin/js/qdrTopAddressesController.js new file mode 100644 index 0000000..ece11ef --- /dev/null +++ b/console/stand-alone/plugin/js/qdrTopAddressesController.js @@ -0,0 +1,218 @@ +/* +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. +*/ +'use strict'; +/* global angular */ +/** + * @module QDR + */ +var QDR = (function(QDR) { + + QDR.module.controller('QDR.TopAddressesController', function ($scope, QDRService, $timeout) { + + $scope.addressesData = []; + $scope.topAddressesGrid = { + data: 'addressesData', + columnDefs: [ + { + field: 'address', + displayName: 'address' + }, + { + field: 'class', + displayName: 'class' + }, + /* + { + field: 'phase', + displayName: 'phase', + cellClass: 'grid-align-value' + }, + { + field: 'inproc', + displayName: 'in-proc' + }, + { + field: 'local', + displayName: 'local', + cellClass: 'grid-align-value' + }, + { + field: 'remote', + displayName: 'remote', + cellClass: 'grid-align-value' + }, + */ + { + field: 'in', + displayName: 'in', + cellClass: 'grid-align-value' + }, + { + field: 'out', + displayName: 'out', + cellClass: 'grid-align-value' + } + ], + enableColumnResize: true, + enableHorizontalScrollbar: 0, + enableVerticalScrollbar: 0, + multiSelect: false, + enableSelectAll: false, + enableSelectionBatchEvent: false, + enableRowHeaderSelection: false, + noUnselect: true + }; + + // get info for all addresses + var allAddressInfo = function (address, callback) { + let nodes = {}; + // gets called each node/entity response + var gotNode = function (nodeName, entity, response) { + if (!nodes[nodeName]) + nodes[nodeName] = {}; + nodes[nodeName][entity] = angular.copy(response); + }; + var addr_phase = function (addr) { + if (!addr) + return '-'; + if (addr[0] == 'M') + return addr[1]; + return ''; + }; + var prettyVal = function (val) { + return QDRService.utilities.pretty(val || '-'); + }; + let addressFields = []; + let addressObjs = {}; + let addNull = function (oldVal, newVal) { + if (oldVal != null && newVal != null) + return oldVal + newVal; + if (oldVal != null) + return oldVal; + return newVal; + }; + // send the requests for all connection and router info for all routers + QDRService.management.topology.fetchAllEntities({entity: 'router.address'}, function () { + for (let node in nodes) { + let response = nodes[node]['router.address']; + response.results.forEach( function (result) { + let address = QDRService.utilities.flatten(response.attributeNames, result); + let uid = address.identity; + let identity = QDRService.utilities.identity_clean(uid); + + let objname = QDRService.utilities.addr_text(identity)+QDRService.utilities.addr_class(identity); + if (!addressObjs[objname]) { + addressObjs[objname] = { + address: QDRService.utilities.addr_text(identity), + 'class': QDRService.utilities.addr_class(identity), + phase: addr_phase(identity), + inproc: address.inProcess, + local: address.subscriberCount, + remote: address.remoteCount, + 'in': address.deliveriesIngress, + out: address.deliveriesEgress, + thru: address.deliveriesTransit, + toproc: address.deliveriesToContainer, + fromproc:address.deliveriesFromContainer, + uid: uid + }; + } + else { + let sumObj = addressObjs[objname]; + sumObj.inproc = addNull(sumObj.inproc, address.inProcess); + sumObj.local = addNull(sumObj.local, address.subscriberCount); + sumObj.remote = addNull(sumObj.remote, address.remoteCount); + sumObj['in'] = addNull(sumObj['in'], address.deliveriesIngress); + sumObj.out = addNull(sumObj.out, address.deliveriesEgress); + sumObj.thru = addNull(sumObj.thru, address.deliveriesTransit); + sumObj.toproc = addNull(sumObj.toproc, address.deliveriesToContainer); + sumObj.fromproc = addNull(sumObj.fromproc, address.deliveriesFromContainer); + } + }); + } + for (let obj in addressObjs) { + addressObjs[obj].inproc = prettyVal(addressObjs[obj].inproc); + addressObjs[obj].local = prettyVal(addressObjs[obj].local); + addressObjs[obj].remote = prettyVal(addressObjs[obj].remote); + addressObjs[obj]['in'] = prettyVal(addressObjs[obj]['in']); + addressObjs[obj].rawout = addressObjs[obj].out; + addressObjs[obj].out = prettyVal(addressObjs[obj].out); + addressObjs[obj].thru = prettyVal(addressObjs[obj].thru); + addressObjs[obj].toproc = prettyVal(addressObjs[obj].toproc); + addressObjs[obj].fromproc = prettyVal(addressObjs[obj].fromproc); + addressFields.push(addressObjs[obj]); + } + if (addressFields.length === 0) + return; + // update the grid's data + addressFields.sort ( function (a,b) { + return a.address + a['class'] < b.address + b['class'] ? -1 : a.address + a['class'] > b.address + b['class'] ? 1 : 0;} + ); + // callapse all records with same addres+class + addressFields[0].title = addressFields[0].address; + for (let i=1; i<addressFields.length; ++i) { + // if this address is the same as the previous address, add a class to the display titles + if (addressFields[i].address === addressFields[i-1].address) { + addressFields[i-1].title = addressFields[i-1].address + ' (' + addressFields[i-1]['class'] + ')'; + addressFields[i].title = addressFields[i].address + ' (' + addressFields[i]['class'] + ')'; + } else + addressFields[i].title = addressFields[i].address; + } + addressFields = addressFields.filter( function (address) { + return address.rawout > 0 || address.rawin > 0; + }); + addressFields.sort ( function (a,b) { + return a.rawout < b.rawout ? -1 : a.rawout > b.rawout ? 1 : 0;} + ); + // take top 5 records + addressFields.splice(5); + + $scope.addressesData = addressFields; + callback(null); + }, gotNode); + }; + let timer; + var updateGrid = function () { + $timeout( function () { + allAddressInfo(null, function () {}); + expandGridToContent($scope.addressesData.length); + }); + }; + timer = setInterval(updateGrid, 5000); + updateGrid(); + + var expandGridToContent = function (rows) { + let height = (rows+1) * 30 + 40; // header is 40px + let gridDetails = $('#overview-controller .grid'); + gridDetails.css('height', height + 'px'); + }; + + $scope.anyAddresses = function () { + return $scope.addressesData.length > 0; + }; + + $scope.$on('$destroy', function() { + if (timer) + clearInterval(timer); + }); + + }); + return QDR; + +} (QDR || {})); --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
