fix style issues in the server

This commit is contained in:
Spencer Alger 2015-04-03 16:05:24 -07:00
parent dd9ff1852f
commit 38a935fa10
10 changed files with 32 additions and 30 deletions

View file

@ -7,4 +7,7 @@ indent_size = 2
end_of_line = lf end_of_line = lf
charset = utf-8 charset = utf-8
trim_trailing_whitespace = true trim_trailing_whitespace = true
insert_final_newline = true insert_final_newline = true
[*.md]
insert_final_newline = false

View file

@ -34,7 +34,7 @@ module.exports = function (grunt) {
'Gruntfile.js', 'Gruntfile.js',
'<%= root %>/tasks/**/*.js', '<%= root %>/tasks/**/*.js',
'<%= src %>/kibana/*.js', '<%= src %>/kibana/*.js',
'<%= src %>/server/*.js', '<%= src %>/server/**/*.js',
'<%= src %>/kibana/{components,directives,factories,filters,plugins,registry,services,utils}/**/*.js', '<%= src %>/kibana/{components,directives,factories,filters,plugins,registry,services,utils}/**/*.js',
'<%= unitTestDir %>/**/*.js', '<%= unitTestDir %>/**/*.js',
'!<%= unitTestDir %>/specs/vislib/fixture/**/*' '!<%= unitTestDir %>/specs/vislib/fixture/**/*'

View file

@ -32,7 +32,6 @@ if (app.get('env') === 'development') {
// TODO: WE might want to move the middleware to each of the individual routes // TODO: WE might want to move the middleware to each of the individual routes
// so we don't have weird conflicts in the future. // so we don't have weird conflicts in the future.
app.use('/elasticsearch', proxy); app.use('/elasticsearch', proxy);
app.use('/enforcer', require('./lib/enforce'));
app.use(bodyParser.json()); app.use(bodyParser.json());
app.use(bodyParser.urlencoded({ extended: false })); app.use(bodyParser.urlencoded({ extended: false }));

View file

@ -52,6 +52,6 @@ verify_ssl: true
# Set the path to where you would like the process id file to be created. # Set the path to where you would like the process id file to be created.
# pid_file: /var/run/kibana.pid # pid_file: /var/run/kibana.pid
# If you would like to send the log output to a file you can set the path below. # If you would like to send the log output to a file you can set the path below.
# This will also turn off the STDOUT log output. # This will also turn off the STDOUT log output.
# log_file: ./kibana.log # log_file: ./kibana.log

View file

@ -25,12 +25,15 @@ var levelColor = function (code) {
if (code < 299) { if (code < 299) {
return ansicolors.green(code); return ansicolors.green(code);
} }
if (code < 399) { if (code < 399) {
return ansicolors.yellow(code) return ansicolors.yellow(code);
}; }
if (code < 499) { if (code < 499) {
return ansicolors.magenta(code) return ansicolors.magenta(code);
}; }
return ansicolors.red(code); return ansicolors.red(code);
}; };
@ -56,10 +59,13 @@ StdOutStream.prototype._write = function (entry, encoding, callback) {
} else if (entry.msg) { } else if (entry.msg) {
output += entry.msg; output += entry.msg;
} }
process.stdout.write(output + "\n");
process.stdout.write(output + '\n');
if (entry.err) { if (entry.err) {
process.stdout.write(ansicolors.brightRed(entry.err.stack) + "\n"); process.stdout.write(ansicolors.brightRed(entry.err.stack) + '\n');
} }
callback(); callback();
}; };

View file

@ -10,18 +10,21 @@ if (config.kibana.kibana_elasticsearch_username && config.kibana.kibana_elastics
uri.auth = util.format('%s:%s', config.kibana.kibana_elasticsearch_username, config.kibana.kibana_elasticsearch_password); uri.auth = util.format('%s:%s', config.kibana.kibana_elasticsearch_username, config.kibana.kibana_elasticsearch_password);
} }
var ssl = { rejectUnauthorized: config.kibana.verify_ssl } var ssl = { rejectUnauthorized: config.kibana.verify_ssl };
if (config.kibana.kibana_elasticsearch_client_crt && config.kibana.kibana_elasticsearch_client_key) { if (config.kibana.kibana_elasticsearch_client_crt && config.kibana.kibana_elasticsearch_client_key) {
ssl.cert = fs.readFileSync(config.kibana.kibana_elasticsearch_client_crt , 'utf8'); ssl.cert = fs.readFileSync(config.kibana.kibana_elasticsearch_client_crt, 'utf8');
ssl.key = fs.readFileSync(config.kibana.kibana_elasticsearch_client_key , 'utf8'); ssl.key = fs.readFileSync(config.kibana.kibana_elasticsearch_client_key, 'utf8');
} }
if (config.kibana.ca) { if (config.kibana.ca) {
ssl.ca = fs.readFileSync(config.kibana.ca , 'utf8'); ssl.ca = fs.readFileSync(config.kibana.ca, 'utf8');
} }
module.exports = new elasticsearch.Client({ module.exports = new elasticsearch.Client({
host: url.format(uri), host: url.format(uri),
ssl: ssl, ssl: ssl,
pingTimeout: config.kibana.ping_timeout,
log: function (config) { log: function (config) {
this.error = function (err) { this.error = function (err) {
logger.error({ err: err }); logger.error({ err: err });

File diff suppressed because one or more lines are too long

View file

@ -9,7 +9,7 @@ var config = require('../config');
var streams = []; var streams = [];
// Set the default stream based on the enviroment. If we are on development then // Set the default stream based on the enviroment. If we are on development then
// then we are going to create a pretty stream. Everytyhing else will get the // then we are going to create a pretty stream. Everytyhing else will get the
// JSON stream to stdout. // JSON stream to stdout.
var defaultStream; var defaultStream;
if (env === 'development') { if (env === 'development') {

View file

@ -6,7 +6,8 @@ var logger = require('./logger');
var config = require('../config'); var config = require('../config');
function waitForPong() { function waitForPong() {
return client.ping({ requestTimeout: 1500 }).catch(function (err) { return client.ping()
.catch(function (err) {
if (!(err instanceof NoConnections)) throw err; if (!(err instanceof NoConnections)) throw err;
logger.info('Unable to connect to elasticsearch at %s. Retrying in 2.5 seconds.', config.elasticsearch); logger.info('Unable to connect to elasticsearch at %s. Retrying in 2.5 seconds.', config.elasticsearch);

View file

@ -67,8 +67,7 @@ router.use(function (req, res, next) {
if (uri.auth) { if (uri.auth) {
var auth = new Buffer(uri.auth); var auth = new Buffer(uri.auth);
base64_auth = auth.toString('base64'); req.headers.authorization = 'Basic ' + auth.toString('base64');
req.headers.authorization = "Basic " + base64_auth;
} }
var options = { var options = {
@ -87,10 +86,10 @@ router.use(function (req, res, next) {
if (customCA) { if (customCA) {
options.agentOptions = { ca: [customCA] }; options.agentOptions = { ca: [customCA] };
} }
// Add client key and certificate for elasticsearch if needed. // Add client key and certificate for elasticsearch if needed.
if (clientCrt && clientKey) { if (clientCrt && clientKey) {
if (! options.agentOptions ) { if (!options.agentOptions) {
options.agentOptions = {}; options.agentOptions = {};
} }
options.agentOptions.cert = clientCrt; options.agentOptions.cert = clientCrt;