kibana/src/plugins/elasticsearch/index.js

module.exports = function (kibana) {
  var healthCheck = require('./lib/health_check');
  var exposeClient = require('./lib/expose_client');
  var createProxy = require('./lib/create_proxy');

  return new kibana.Plugin({
    require: ['kibana'],

    config: function (Joi) {
      return Joi.object({
        enabled: Joi.boolean().default(true),
        url: Joi.string().uri({ scheme: ['http', 'https'] }).default('http://localhost:9200'),
        preserveHost: Joi.boolean().default(true),
        username: Joi.string(),
        password: Joi.string(),
        shardTimeout: Joi.number().default(0),
        requestTimeout: Joi.number().default(30000),
        pingTimeout: Joi.number().default(30000),
        startupTimeout: Joi.number().default(5000),
        ssl: Joi.object({
          verify: Joi.boolean().default(true),
          ca: Joi.array().single().items(Joi.string()),
          cert: Joi.string(),
          key: Joi.string()
        }).default(),
        apiVersion: Joi.string().default('2.0'),
        engineVersion: Joi.string().valid('^2.1.0').default('^2.1.0')
      }).default();
    },

    init: function (server, options) {
      var config = server.config();

      // Expose the client to the server
      exposeClient(server);
      createProxy(server, 'GET', '/{paths*}');
      createProxy(server, 'POST', '/_mget');
      createProxy(server, 'POST', '/{index}/_search');
      createProxy(server, 'POST', '/{index}/_field_stats');
      createProxy(server, 'POST', '/_msearch');

      function noBulkCheck(request, reply) {
        if (/\/_bulk/.test(request.path)) {
          return reply({
            error: 'You can not send _bulk requests to this interface.'
          }).code(400).takeover();
        }
        return reply.continue();
      }

      createProxy(
        server,
        ['PUT', 'POST', 'DELETE'],
        '/' + config.get('kibana.index') + '/{paths*}',
        {
          pre: [ noBulkCheck ]
        }
      );

      // Set up the health check service and start it.
      healthCheck(this, server).start();
    }
  });

};