123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211 |
- /**
- * 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.
- */
- var App = require('app');
- /**
- * initialize common cache container for mappers
- * App.cache contains shared data, used for syncronizing incoming server data among mappers
- */
- App.cache = {
- 'previousHostStatuses': {},
- 'previousComponentStatuses': {},
- 'previousComponentPassiveStates': {},
- 'services': [],
- 'currentConfigVersions': {}
- };
- App.cache.clear = function () {
- var clear = App.cache.clear;
- App.cache = {
- 'previousHostStatuses': {},
- 'previousComponentStatuses': {},
- 'previousComponentPassiveStates': {},
- 'services': [],
- 'currentConfigVersions': {}
- };
- App.cache.clear = clear;
- };
- App.ServerDataMapper = Em.Object.extend({
- jsonKey: false,
- map: function (json) {
- if (json) {
- var model = this.get('model');
- var jsonKey = this.get('jsonKey');
- if (jsonKey && json[jsonKey]) { // if data come as { hdfs: {...} }
- json = json[jsonKey];
- }
- $.each(json, function (field, value) {
- model.set(field, value);
- })
- }
- }
- });
- App.QuickDataMapper = App.ServerDataMapper.extend({
- config: {},
- model: null,
- map: function (json) {
- if (!this.get('model')) {
- return;
- }
- if (json.items) {
- var result = [];
- json.items.forEach(function (item) {
- result.push(this.parseIt(item, this.config));
- }, this);
- App.store.loadMany(this.get('model'), result);
- }
- },
- parseIt: function (data, config) {
- var result = {};
- for ( var i in config) {
- if (i.substr(0, 1) === '$') {
- i = i.substr(1, i.length);
- result[i] = config['$' + i];
- } else {
- var isSpecial = false;
- if (i.substr(-5) == '_type') {
- var prefix = i.substr(0, i.length - 5);
- isSpecial = config[prefix + '_key'] != null;
- } else if (i.substr(-4) == '_key') {
- var prefix = i.substr(0, i.length - 4);
- isSpecial = config[prefix + '_type'] != null;
- }
- if (!isSpecial && typeof config[i] == 'string') {
- result[i] = this.getJsonProperty(data, config[i]);
- } else if (typeof config[i] == 'object') {
- result[i] = [];
- var _data = this.getJsonProperty(data, config[i + '_key']);
- var _type = config[i + '_type'];
- var l = _data.length;
- for ( var index = 0; index < l; index++) {
- if (_type == 'array') {
- result[i].push(this.getJsonProperty(_data[index], config[i].item));
- } else {
- result[i].push(this.parseIt(_data[index], config[i]));
- }
- }
- // As for 'widgets', just show the original order
- if(_type == 'array' && i != 'widgets'){
- result[i] = result[i].sort();
- }
- }
- }
- }
- return result;
- },
- getJsonProperty: function (json, path) {
- var pathArr = path.split('.');
- var current = json;
- while (pathArr.length && current) {
- if (pathArr[0].substr(-1) == ']') {
- var index = parseInt(pathArr[0].substr(-2, 1));
- var attr = pathArr[0].substr(0, pathArr[0].length - 3);
- if (attr in current) {
- current = current[attr][index];
- }
- } else {
- current = current[pathArr[0]];
- }
- pathArr.splice(0, 1);
- }
- return current;
- },
- /**
- * properly delete record from model
- * @param item
- */
- deleteRecord: function (item) {
- item.deleteRecord();
- App.store.commit();
- item.get('stateManager').transitionTo('loading');
- },
- /**
- * check mutable fields whether they have been changed and if positive
- * return host object only with properties, that contains new value
- * @param current
- * @param previous
- * @param fields
- * @return {*}
- */
- getDiscrepancies: function (current, previous, fields) {
- var result = {};
- if (previous) {
- fields.forEach(function (field) {
- if (Array.isArray(current[field])) {
- if (JSON.stringify(current[field]) !== JSON.stringify(previous[field])) {
- result[field] = current[field];
- result.isLoadNeeded = true;
- }
- } else {
- if (current[field] != previous[field]) result[field] = current[field];
- }
- });
- return result;
- }
- return current;
- },
- /**
- * Binary search <code>searchElement</code> in the array (should be sorted!)
- * @param {number[]|string[]} array
- * @param {number|string} searchElement
- * @returns {number} position of the needed element or negative value, if value wasn't found
- * @method binaryIndexOf
- */
- binaryIndexOf: function (array, searchElement) {
- var minIndex = 0;
- var maxIndex = array.length - 1;
- var currentIndex;
- var currentElement;
- var resultIndex;
- if (array[0] > searchElement || array[array.length - 1] < searchElement) {
- return -1;
- }
- while (minIndex <= maxIndex) {
- resultIndex = currentIndex = (minIndex + maxIndex) / 2 | 0;
- currentElement = array[currentIndex];
- if (currentElement < searchElement) {
- minIndex = currentIndex + 1;
- }
- else
- if (currentElement > searchElement) {
- maxIndex = currentIndex - 1;
- }
- else {
- return currentIndex;
- }
- }
- return ~maxIndex;
- }
- });
|