Merged Pull Request #484

2013-09-13 13:52:13 -07:00
parent 0f551acc76
commit 5d9cb85ccf
388 changed files with 39375 additions and 5533 deletions
@@ -0,0 +1,96 @@
+define([
+  'angular',
+  'underscore',
+  'config'
+],
+function (angular, _, config) {
+  'use strict';
+
+  var module = angular.module('kibana.services');
+
+  module.service('fields', function(dashboard, $rootScope, $http, alertSrv) {
+    // Save a reference to this
+    var self = this;
+
+    this.list = ['_type'];
+    this.mapping = {};
+
+    $rootScope.$watch(function(){return dashboard.indices;},function(n) {
+      if(!_.isUndefined(n) && n.length) {
+        // Only get the mapping for indices we don't know it for
+        var indices = _.difference(n,_.keys(self.mapping));
+        // Only get the mapping if there are indices
+        if(indices.length > 0) {
+          self.map(indices).then(function(result) {
+            self.mapping = _.extend(self.mapping,result);
+            self.list = mapFields(self.mapping);
+          });
+        // Otherwise just use the cached mapping
+        } else {
+          self.list = mapFields(_.pick(self.mapping,n));
+        }
+      }
+    });
+
+    var mapFields = function (m) {
+      var fields = [];
+      _.each(m, function(types) {
+        _.each(types, function(v) {
+          fields = _.union(fields,_.keys(v));
+        });
+      });
+      return fields;
+    };
+
+    this.map = function(indices) {
+      var request = $http({
+        url: config.elasticsearch + "/" + indices.join(',') + "/_mapping",
+        method: "GET"
+      }).error(function(data, status) {
+        if(status === 0) {
+          alertSrv.set('Error',"Could not contact Elasticsearch at "+config.elasticsearch+
+            ". Please ensure that Elasticsearch is reachable from your system." ,'error');
+        } else {
+          alertSrv.set('Error',"No index found at "+config.elasticsearch+"/" +
+            indices.join(',')+"/_mapping. Please create at least one index."  +
+            "If you're using a proxy ensure it is configured correctly.",'error');
+        }
+      });
+
+      return request.then(function(p) {
+        var mapping = {};
+        _.each(p.data, function(v,k) {
+          mapping[k] = {};
+          _.each(v, function (v,f) {
+            mapping[k][f] = flatten(v);
+          });
+        });
+        return mapping;
+      });
+    };
+
+    var flatten = function(obj,prefix) {
+      var propName = (prefix) ? prefix :  '',
+        dot = (prefix) ? '.':'',
+        ret = {};
+      for(var attr in obj){
+        // For now only support multi field on the top level
+        // and if if there is a default field set.
+        if(obj[attr]['type'] === 'multi_field') {
+          ret[attr] = obj[attr]['fields'][attr] || obj[attr];
+          continue;
+        }
+        if (attr === 'properties') {
+          _.extend(ret,flatten(obj[attr], propName));
+        } else if(typeof obj[attr] === 'object'){
+          _.extend(ret,flatten(obj[attr], propName + dot + attr));
+        } else {
+          ret[propName] = obj;
+        }
+      }
+      return ret;
+    };
+
+  });
+
+});