feat: #7743, webserver

src/flags.js

@@ -761,3 +761,5 @@ Flags.notify = function (flagObj, uid, callback) {
 		break;
 	}
 };
+
+require('./promisify')(Flags);

src/plugins/index.js

@@ -125,9 +125,9 @@ Plugins.reload = async function () {
 	});
 };
 
-Plugins.reloadRoutes = async function (router) {
+Plugins.reloadRoutes = async function (params) {
 	var controllers = require('../controllers');
-	await Plugins.fireHook('static:app.load', { app: app, router: router, middleware: middleware, controllers: controllers });
+	await Plugins.fireHook('static:app.load', { app: app, router: params.router, middleware: middleware, controllers: controllers });
 	winston.verbose('[plugins] All plugins reloaded and rerouted');
 };
 

src/routes/authentication.js

@@ -46,26 +46,21 @@ Auth.getLoginStrategies = function () {
 	return loginStrategies;
 };
 
-Auth.reloadRoutes = function (router, callback) {
+Auth.reloadRoutes = async function (params) {
 	loginStrategies.length = 0;
-
+	const router = params.router;
 	if (plugins.hasListeners('action:auth.overrideLogin')) {
 		winston.warn('[authentication] Login override detected, skipping local login strategy.');
 		plugins.fireHook('action:auth.overrideLogin');
 	} else {
 		passport.use(new passportLocal({ passReqToCallback: true }, controllers.authentication.localLogin));
 	}
-
-	async.waterfall([
-		function (next) {
-			plugins.fireHook('filter:auth.init', loginStrategies, function (err) {
-				if (err) {
+	try {
+		loginStrategies = await plugins.fireHook('filter:auth.init', loginStrategies);
+	} catch (err) {
 		winston.error('[authentication] ' + err.stack);
 	}
-				next(null, loginStrategies);
-			});
-		},
-		function (loginStrategies, next) {
+
 	loginStrategies = loginStrategies || [];
 	loginStrategies.forEach(function (strategy) {
 		if (strategy.url) {
@@ -134,10 +129,6 @@ Auth.reloadRoutes = function (router, callback) {
 	router.post('/register/abort', controllers.authentication.registerAbort);
 	router.post('/login', Auth.middleware.applyCSRF, Auth.middleware.applyBlacklist, controllers.authentication.login);
 	router.post('/logout', Auth.middleware.applyCSRF, controllers.authentication.logout);
-
-			next();
-		},
-	], callback);
 };
 
 passport.serializeUser(function (user, done) {

src/routes/index.js

@@ -3,7 +3,6 @@
 var nconf = require('nconf');
 var winston = require('winston');
 var path = require('path');
-var async = require('async');
 var express = require('express');
 
 var meta = require('../meta');
@@ -90,7 +89,7 @@ function groupRoutes(app, middleware, controllers) {
 	setupPageRoute(app, '/groups/:slug/members', middleware, middlewares, controllers.groups.members);
 }
 
-module.exports = function (app, middleware, callback) {
+module.exports = async function (app, middleware) {
 	const router = express.Router();
 	router.render = function () {
 		app.render.apply(app, arguments);
@@ -109,21 +108,15 @@ module.exports = function (app, middleware, callback) {
 	// homepage handled by `action:homepage.get:[route]`
 	setupPageRoute(router, '/', middleware, [], controllers.home.pluginHook);
 
-	async.series([
-		async.apply(plugins.reloadRoutes, router),
-		async.apply(authRoutes.reloadRoutes, router),
-		async.apply(addCoreRoutes, app, router, middleware),
-		async.apply(user.addInterstitials),
-		function (next) {
+	await plugins.reloadRoutes({ router: router });
+	await authRoutes.reloadRoutes({ router: router });
+	addCoreRoutes(app, router, middleware);
+	await user.addInterstitials();
+
 	winston.info('Routes added');
-			next();
-		},
-	], function (err) {
-		callback(err);
-	});
 };
 
-function addCoreRoutes(app, router, middleware, callback) {
+function addCoreRoutes(app, router, middleware) {
 	adminRoutes(router, middleware, controllers);
 	metaRoutes(router, middleware, controllers);
 	apiRoutes(router, middleware, controllers);
@@ -190,5 +183,4 @@ function addCoreRoutes(app, router, middleware, callback) {
 	app.use(controllers['404'].handle404);
 	app.use(controllers.errors.handleURIErrors);
 	app.use(controllers.errors.handleErrors);
-	setImmediate(callback);
 }

src/webserver.js

@@ -2,6 +2,7 @@
 'use strict';
 
 var fs = require('fs');
+const util = require('util');
 var path = require('path');
 var os = require('os');
 var nconf = require('nconf');
@@ -65,7 +66,7 @@ server.on('connection', function (conn) {
 	});
 });
 
-module.exports.destroy = function (callback) {
+exports.destroy = function (callback) {
 	server.close(callback);
 	for (var key in connections) {
 		if (connections.hasOwnProperty(key)) {
@@ -74,22 +75,12 @@ module.exports.destroy = function (callback) {
 	}
 };
 
-module.exports.listen = function (callback) {
-	callback = callback || function () { };
+exports.listen = async function () {
 	emailer.registerApp(app);
-
-	async.waterfall([
-		function (next) {
-			setupExpressApp(app, next);
-		},
-		function (next) {
+	setupExpressApp(app);
 	helpers.register();
-
 	logger.init(app);
-
-			initializeNodeBB(next);
-		},
-		function (next) {
+	await initializeNodeBB();
 	winston.info('NodeBB Ready');
 
 	require('./socket.io').server.emit('event:nodebb.ready', {
@@ -99,51 +90,30 @@ module.exports.listen = function (callback) {
 
 	plugins.fireHook('action:nodebb.ready');
 
-			listen(next);
-		},
-	], callback);
+	await util.promisify(listen)();
 };
 
-function initializeNodeBB(callback) {
-	var middleware = require('./middleware');
-
-	async.waterfall([
-		function (next) {
-			meta.themes.setupPaths(next);
-		},
-		function (next) {
-			plugins.init(app, middleware, next);
-		},
-		async.apply(plugins.fireHook, 'static:assets.prepare', {}),
-		function (next) {
-			plugins.fireHook('static:app.preload', {
+async function initializeNodeBB() {
+	const middleware = require('./middleware');
+	await meta.themes.setupPaths();
+	await plugins.init(app, middleware);
+	await plugins.fireHook('static:assets.prepare', {});
+	await plugins.fireHook('static:app.preload', {
 		app: app,
 		middleware: middleware,
-			}, next);
-		},
-		function (next) {
-			routes(app, middleware, next);
-		},
-		function (next) {
-			meta.sounds.addUploads(next);
-		},
-		function (next) {
-			meta.blacklist.load(next);
-		},
-		function (next) {
-			flags.init(next);
-		},
-	], function (err) {
-		callback(err);
 	});
+	await routes(app, middleware);
+	await meta.sounds.addUploads();
+	await meta.blacklist.load();
+	await flags.init();
 }
 
-function setupExpressApp(app, callback) {
-	var middleware = require('./middleware');
-	var pingController = require('./controllers/ping');
+function setupExpressApp(app) {
+	const middleware = require('./middleware');
+	const pingController = require('./controllers/ping');
 
-	var relativePath = nconf.get('relative_path');
-	var viewsDir = nconf.get('views_dir');
+	const relativePath = nconf.get('relative_path');
+	const viewsDir = nconf.get('views_dir');
 
 	app.engine('tpl', function (filepath, data, next) {
 		filepath = filepath.replace(/\.tpl$/, '.js');
@@ -210,8 +180,6 @@ function setupExpressApp(app, callback) {
 	var toobusy = require('toobusy-js');
 	toobusy.maxLag(meta.config.eventLoopLagThreshold);
 	toobusy.interval(meta.config.eventLoopInterval);
-
-	callback();
 }
 
 function setupFavicon(app) {
@@ -308,7 +276,7 @@ function listen(callback) {
 	}
 }
 
-module.exports.testSocket = function (socketPath, callback) {
+exports.testSocket = function (socketPath, callback) {
 	if (typeof socketPath !== 'string') {
 		return callback(new Error('invalid socket path : ' + socketPath));
 	}
@@ -337,3 +305,5 @@ module.exports.testSocket = function (socketPath, callback) {
 		async.apply(fs.unlink, socketPath),	// The socket was stale, kick it out of the way
 	], callback);
 };
+
+require('./promisify')(exports);