var async = require('async'), utils = require('../public/src/utils.js'), fs = require('fs'), url = require('url'), path = require('path'), prompt = require('prompt'), winston = require('winston'), reds = require('reds'), nconf = require('nconf'), install = { questions: [{ name: 'base_url', description: 'URL of this installation', 'default': nconf.get('base_url') || 'http://localhost', pattern: /^http(?:s)?:\/\//, message: 'Base URL must begin with \'http://\' or \'https://\'', }, { name: 'port', description: 'Port number of your NodeBB', 'default': nconf.get('port') || 4567, pattern: /[0-9]{1,4}|[1-5][0-9]{4}|6[0-4][0-9]{3}|65[0-4][0-9]{2}|655[0-2][0-9]|6553[0-5]/, message: 'Please enter a value betweeen 1 and 65535' }, { name: 'use_port', description: 'Use a port number to access NodeBB?', 'default': (nconf.get('use_port') !== undefined ? (nconf.get('use_port') ? 'y' : 'n') : 'y'), pattern: /y[es]*|n[o]?/, message: 'Please enter \'yes\' or \'no\'', }, { name: 'secret', description: 'Please enter a NodeBB secret', 'default': nconf.get('secret') || utils.generateUUID() }, { name: 'bind_address', description: 'IP or Hostname to bind to', 'default': nconf.get('bind_address') || '0.0.0.0' }, { name: 'database', description: 'Which database to use', 'default': nconf.get('database') || 'redis' }], redisQuestions : [{ name: 'redis:host', description: 'Host IP or address of your Redis instance', 'default': nconf.get('redis:host') || '127.0.0.1' }, { name: 'redis:port', description: 'Host port of your Redis instance', 'default': nconf.get('redis:port') || 6379 }, { name: 'redis:password', description: 'Password of your Redis database' }, { name: "redis:database", description: "Which database to use (0..n)", 'default': nconf.get('redis:database') || 0 }], mongoQuestions : [{ name: 'mongo:host', description: 'Host IP or address of your MongoDB instance', 'default': nconf.get('mongo:host') || '127.0.0.1' }, { name: 'mongo:port', description: 'Host port of your MongoDB instance', 'default': nconf.get('mongo:port') || 27017 }, { name: 'mongo:user', description: 'MongoDB username' }, { name: 'mongo:password', description: 'Password of your MongoDB database' }, { name: "mongo:database", description: "Which database to use (0..n)", 'default': nconf.get('mongo:database') || 0 }], setup: function (callback) { async.series([ function(next) { // Check if the `--setup` flag contained values we can work with var setupVal; try { setupVal = JSON.parse(nconf.get('setup')); } catch (e) { setupVal = undefined; } if (setupVal && setupVal instanceof Object) { if (setupVal['admin:username'] && setupVal['admin:password'] && setupVal['admin:password:confirm'] && setupVal['admin:email']) { install.values = setupVal; next(); } else { winston.error('Required values are missing for automated setup:'); if (!setupVal['admin:username']) winston.error(' admin:username'); if (!setupVal['admin:password']) winston.error(' admin:password'); if (!setupVal['admin:password:confirm']) winston.error(' admin:password:confirm'); if (!setupVal['admin:email']) winston.error(' admin:email'); process.exit(); } } else { next(); } }, function (next) { var success = function (err, config) { if (!config) { return next(new Error('aborted')); } var dbQuestionsSuccess = function (err, databaseConfig) { if (!databaseConfig) { return next(new Error('aborted')); } // Translate redis properties into redis object if(config.database === 'redis') { config.redis = { host: databaseConfig['redis:host'], port: databaseConfig['redis:port'], password: databaseConfig['redis:password'], database: databaseConfig['redis:database'] }; } else if (config.database === 'mongo') { config.mongo = { host: databaseConfig['mongo:host'], port: databaseConfig['mongo:port'], password: databaseConfig['mongo:password'], database: databaseConfig['mongo:database'] }; } else { return next(new Error('unknown database : ' + config.database)); } config.bcrypt_rounds = 12; config.upload_path = '/public/uploads'; config.use_port = config.use_port.slice(0, 1) === 'y'; var urlObject = url.parse(config.base_url), relative_path = (urlObject.pathname && urlObject.pathname.length > 1) ? urlObject.pathname : '', host = urlObject.host, protocol = urlObject.protocol, server_conf = config, client_conf = { relative_path: relative_path }; server_conf.base_url = protocol + '//' + host; server_conf.relative_path = relative_path; install.save(server_conf, client_conf, function(err) { require('./database').init(next); }); }; if(config.database === 'redis') { if (config['redis:host'] && config['redis:port']) { dbQuestionsSuccess(null, config); } else { prompt.get(install.redisQuestions, dbQuestionsSuccess); } } else if(config.database === 'mongo') { if (config['mongo:host'] && config['mongo:port']) { dbQuestionsSuccess(null, config); } else { prompt.get(install.mongoQuestions, dbQuestionsSuccess); } } else { return next(new Error('unknown database : ' + config.database)); } }; // prompt prepends "prompt: " to questions, let's clear that. prompt.start(); prompt.message = ''; prompt.delimiter = ''; if (!install.values) { prompt.get(install.questions, success); } else { // Use provided values, fall back to defaults var config = {}, question, x, numQ, allQuestions = install.questions.concat(install.redisQuestions).concat(install.mongoQuestions); for(x=0,numQ=allQuestions.length;x 0) { winston.info('Administrator found, skipping Admin setup'); next(); } else { install.createAdmin(next); } }); } else { install.createAdmin(next); } }); }, function (next) { // Categories var Categories = require('./categories'); Categories.getAllCategories(0, function (err, data) { if (data.categories.length === 0) { winston.warn('No categories found, populating instance with default categories'); fs.readFile(path.join(__dirname, '../', 'install/data/categories.json'), function (err, default_categories) { default_categories = JSON.parse(default_categories); async.eachSeries(default_categories, function (category, next) { Categories.create(category, next); }, function (err) { if (!err) { next(); } else { winston.error('Could not set up categories'); } }); }); } else { winston.info('Categories OK. Found ' + data.categories.length + ' categories.'); next(); } }); }, function (next) { // Default plugins var Plugins = require('./plugins'); winston.info('Enabling default plugins'); var defaultEnabled = [ 'nodebb-plugin-markdown', 'nodebb-plugin-mentions' ]; async.each(defaultEnabled, function (pluginId, next) { Plugins.isActive(pluginId, function (err, active) { if (!active) { Plugins.toggleActive(pluginId, function () { next(); }); } else { next(); } }); }, next); }, function (next) { require('./upgrade').upgrade(next); } ], function (err) { if (err) { winston.warn('NodeBB Setup Aborted.'); process.exit(); } else { callback(); } }); }, createAdmin: function (callback) { var User = require('./user'), Groups = require('./groups'); winston.warn('No administrators have been detected, running initial user setup'); var questions = [{ name: 'username', description: 'Administrator username', required: true, type: 'string' }, { name: 'email', description: 'Administrator email address', pattern: /.+@.+/, required: true }], passwordQuestions = [{ name: 'password', description: 'Password', required: true, hidden: true, type: 'string' }, { name: 'password:confirm', description: 'Confirm Password', required: true, hidden: true, type: 'string' }], success = function(err, results) { if (!results) { return callback(new Error('aborted')); } // Check if the passwords match if (results['password:confirm'] !== results.password) { winston.warn("Passwords did not match, please try again"); // Re-prompt password questions. return retryPassword(results); } nconf.set('bcrypt_rounds', 12); User.create(results.username, results.password, results.email, function (err, uid) { if (err) { winston.warn(err.message + ' Please try again.'); return callback(new Error('invalid-values')); } Groups.getGidFromName('Administrators', function (err, gid) { if (gid) { Groups.join(gid, uid, callback); } else { Groups.create('Administrators', 'Forum Administrators', function (err, groupObj) { Groups.join(groupObj.gid, uid, callback); }); } }); }); }, retryPassword = function (originalResults) { // Ask only the password questions prompt.get(passwordQuestions, function (err, results) { if (!results) { return callback(new Error('aborted')); } // Update the original data with newly collected password originalResults.password = results.password; originalResults['password:confirm'] = results['password:confirm']; // Send back to success to handle success(err, originalResults); }); }; // Add the password questions questions = questions.concat(passwordQuestions); if (!install.values) { prompt.get(questions, success); } else { var results = { username: install.values['admin:username'], email: install.values['admin:email'], password: install.values['admin:password'], 'password:confirm': install.values['admin:password:confirm'] }; success(null, results); } }, save: function (server_conf, client_conf, callback) { // Server Config async.parallel([ function (next) { fs.writeFile(path.join(__dirname, '../', 'config.json'), JSON.stringify(server_conf, null, 4), function (err) { next(err); }); }, function (next) { fs.writeFile(path.join(__dirname, '../', 'public', 'config.json'), JSON.stringify(client_conf, null, 4), function (err) { next(err); }); } ], function (err) { winston.info('Configuration Saved OK'); nconf.file({ file: path.join(__dirname, '..', 'config.json') }); /*var RDB = require('./redis'); reds.createClient = function () { return reds.client || (reds.client = RDB); };*/ callback(err); }); } }; module.exports = install;