closes #2370

better error handling for #2363

upgrades now also call the suggestion route from nbbpm

upgrade button will show alert now if you try to upgrade past the suggested version, #2363

loader.js

@@ -161,14 +161,12 @@ Loader.addClusterEvents = function(callback) {
 			}
 		}
 
-		console.log('[cluster] Child Process (' + worker.process.pid + ') has exited (code: ' + code + ')');
+		console.log('[cluster] Child Process (' + worker.process.pid + ') has exited (code: ' + code + ', signal: ' + signal +')');
 		if (!worker.suicide) {
 			console.log('[cluster] Spinning up another process...');
 
 			var wasPrimary = parseInt(worker.id, 10) === Loader.primaryWorker;
-			cluster.fork({
+			forkWorker(wasPrimary);
-				handle_jobs: wasPrimary
-			});
 		}
 	});
 
@@ -177,29 +175,32 @@ Loader.addClusterEvents = function(callback) {
 	});
 
 	callback();
-}
+};
 
 Loader.start = function(callback) {
-	var output = logrotate({ file: __dirname + '/logs/output.log', size: '1m', keep: 3, compress: true }),
-		worker;
-
 	console.log('Clustering enabled: Spinning up ' + numProcs + ' process(es).\n');
 
-	for(var x=0;x<numProcs;x++) {
+	for(var x=0; x<numProcs; ++x) {
-		// Only the first worker sets up templates/sounds/jobs/etc
+		forkWorker(x === 0);
-		worker = cluster.fork({
+	}
-			cluster_setup: x === 0,
+
-			handle_jobs: x === 0
+	if (callback) {
-		});
+		callback();
+	}
+};
+
+function forkWorker(isPrimary) {
+	var worker = cluster.fork({
+			cluster_setup: isPrimary,
+			handle_jobs: isPrimary
+		}),
+		output = logrotate({ file: __dirname + '/logs/output.log', size: '1m', keep: 3, compress: true });
 
-		// Logging
 	if (silent) {
 		worker.process.stdout.pipe(output);
+		worker.process.stderr.pipe(output);
 	}
-	}
+}
-
-	if (callback) callback();
-};
 
 Loader.restart = function(callback) {
 	// Slate existing workers for termination -- welcome to death row.
@@ -219,7 +220,7 @@ Loader.notifyWorkers = function (msg) {
 	Object.keys(cluster.workers).forEach(function(id) {
 		cluster.workers[id].send(msg);
 	});
-}
+};
 
 
 nconf.argv().file({

nodebb

@@ -29,7 +29,7 @@ case "$1" in
 		echo "  \"./nodebb log\" to view server output";
 
 		# Start the loader daemon
-		"$node" loader -d "$@"
+		"$node" loader "$@"
 		;;
 
 	stop)

package.json

@@ -2,7 +2,7 @@
   "name": "nodebb",
   "license": "GPLv3 or later",
   "description": "NodeBB Forum",
-  "version": "0.5.3-dev",
+  "version": "0.5.4",
   "homepage": "http://www.nodebb.org",
   "repository": {
     "type": "git",

public/src/admin/extend/plugins.js

@@ -33,13 +33,75 @@ define('admin/extend/plugins', function() {
 				pluginsList.on('click', 'button[data-action="toggleInstall"]', function() {
 					pluginID = $(this).parents('li').attr('data-plugin-id');
 
+					Plugins.suggest(pluginID, function(err, payload) {
+						if (!err) {
+							Plugins.toggleInstall(pluginID, payload.version);
+						} else {
+							bootbox.confirm('<p>NodeBB could not reach the package manager, proceed with installation of latest version?</p><div class="alert alert-danger"><strong>Server returned (' + err.status + ')</strong>: ' + err.responseText + '</div>', function(confirm) {
+								if (confirm) {
+									Plugins.toggleInstall(pluginID, 'latest');
+								}
+							});
+						}
+					});
+				});
+
+				pluginsList.on('click', 'button[data-action="upgrade"]', function() {
 					var btn = $(this);
+					var parent = btn.parents('li');
+					pluginID = parent.attr('data-plugin-id');
+
+
+					Plugins.suggest(pluginID, function(err, payload) {
+						if (!err) {
+							require(['semver'], function(semver) {
+								if (payload.version === 'latest' || semver.gt(payload.version, parent.find('.currentVersion').text())) {
+									btn.attr('disabled', true).find('i').attr('class', 'fa fa-refresh fa-spin');
+									socket.emit('admin.plugins.upgrade', {
+										id: pluginID,
+										version: payload.version
+									}, function(err) {
+										if (err) {
+											return app.alertError(err.message);
+										}
+										parent.find('.fa-exclamation-triangle').remove();
+										parent.find('.currentVersion').text(payload.version);
+										btn.remove();
+									});
+								} else {
+									bootbox.alert('<p>Your version of NodeBB (v' + app.config.version + ') is only cleared to upgrade to v' + payload.version + ' of this plugin. Please update your NodeBB if you wish to install a newer version of this plugin.');
+								}
+							});
+						} else {
+							bootbox.alert('<p>NodeBB could not reach the package manager, an upgrade is not suggested at this time.</p>');
+						}
+					});
+				});
+
+
+				$('#plugin-search').on('input propertychange', function() {
+					var term = $(this).val();
+					$('.plugins li').each(function() {
+						var pluginId = $(this).attr('data-plugin-id');
+						$(this).toggleClass('hide', pluginId && pluginId.indexOf(term) === -1);
+					});
+				});
+
+			} else {
+				pluginsList.append('<li><p><i>No plugins found.</i></p></li>');
+			}
+		},
+		toggleInstall: function(pluginID, version, callback) {
+			var btn = $('li[data-plugin-id="' + pluginID + '"] button[data-action="toggleInstall"]');
 			var activateBtn = btn.siblings('[data-action="toggleActive"]');
 			btn.html(btn.html() + 'ing')
 				.attr('disabled', true)
 				.find('i').attr('class', 'fa fa-refresh fa-spin');
 
-					socket.emit('admin.plugins.toggleInstall', pluginID, function(err, status) {
+			socket.emit('admin.plugins.toggleInstall', {
+				id: pluginID,
+				version: version
+			}, function(err, status) {
 				if (err) {
 					return app.alertError(err.message);
 				}
@@ -62,38 +124,24 @@ define('admin/extend/plugins', function() {
 					type: 'info',
 					timeout: 5000
 				});
-					});
-				});
 
-				pluginsList.on('click', 'button[data-action="upgrade"]', function() {
+				if (typeof callback === 'function') {
-					var btn = $(this);
+					callback.apply(this, arguments);
-					var parent = btn.parents('li');
-					pluginID = parent.attr('data-plugin-id');
-
-					btn.attr('disabled', true).find('i').attr('class', 'fa fa-refresh fa-spin');
-
-					socket.emit('admin.plugins.upgrade', pluginID, function(err) {
-						if (err) {
-							return app.alertError(err.message);
 				}
-						parent.find('.fa-exclamation-triangle').remove();
-						parent.find('.currentVersion').text(parent.find('.latestVersion').text());
-						btn.remove();
 			});
-				});
+		},
-
+		suggest: function(pluginId, callback) {
-
+			var nbbVersion = app.config.version;
-				$('#plugin-search').on('input propertychange', function() {
+			$.ajax('https://packages.nodebb.org/api/v1/suggest', {
-					var term = $(this).val();
+				type: 'GET',
-					$('.plugins li').each(function() {
+				data: {
-						var pluginId = $(this).attr('data-plugin-id');
+					package: pluginId,
-						$(this).toggleClass('hide', pluginId && pluginId.indexOf(term) === -1);
+					version: nbbVersion
-					});
+				},
-				});
+				dataType: 'json'
-
+			}).done(function(payload) {
-			} else {
+				callback(undefined, payload);
-				pluginsList.append('<li><p><i>No plugins found.</i></p></li>');
+			}).fail(callback);
-			}
 		}
 	};
 

src/controllers/accounts.js

@@ -136,11 +136,18 @@ function getUserDataByUserSlug(userslug, callerUID, callback) {
 accountsController.getUserByUID = function(req, res, next) {
 	var uid = req.params.uid ? req.params.uid : 0;
 
-	user.getUserData(uid, function(err, userData) {
+	async.parallel({
+		settings: async.apply(user.getSettings, uid),
+		userData: async.apply(user.getUserData, uid)
+	}, function(err, results) {
 		if (err) {
 			return next(err);
 		}
-		res.json(userData);
+
+		results.userData.email = results.settings.showemail ? results.userData.email : undefined;
+		results.userData.fullname = results.settings.showfullname ? results.userData.fullname : undefined;
+
+		res.json(results.userData);
 	});
 };
 

src/groups.js

@@ -380,7 +380,7 @@ var async = require('async'),
 						db.rename('group:' + oldName, 'group:' + newName, next);
 					},
 					function(next) {
-						Groups.exists('group:' + oldName + ':members', function(err, exists) {
+						db.exists('group:' + oldName + ':members', function(err, exists) {
 							if (err) {
 								return next(err);
 							}

src/meta/configs.js

@@ -2,7 +2,8 @@
 'use strict';
 
 var winston = require('winston'),
-	db = require('../database');
+	db = require('../database'),
+	pkg = require('../../package.json');
 
 module.exports = function(Meta) {
 
@@ -25,7 +26,9 @@ module.exports = function(Meta) {
 
 	Meta.configs.list = function (callback) {
 		db.getObject('config', function (err, config) {
-			callback(err, config || {});
+			config = config || {};
+			config.version = pkg.version;
+			callback(err, config);
 		});
 	};
 

src/plugins.js

@@ -550,7 +550,7 @@ var fs = require('fs'),
 		});
 	};
 
-	Plugins.toggleInstall = function(id, callback) {
+	Plugins.toggleInstall = function(id, version, callback) {
 		Plugins.isInstalled(id, function(err, installed) {
 			if (err) {
 				return callback(err);
@@ -573,7 +573,7 @@ var fs = require('fs'),
 					npm.load({}, next);
 				},
 				function(res, next) {
-					npm.commands[installed ? 'uninstall' : 'install'](installed ? id : [id], next);
+					npm.commands[installed ? 'uninstall' : 'install'](installed ? id : [id + '@' + (version || 'latest')], next);
 				}
 			], function(err) {
 				callback(err, {
@@ -584,13 +584,13 @@ var fs = require('fs'),
 		});
 	};
 
-	Plugins.upgrade = function(id, callback) {
+	Plugins.upgrade = function(id, version, callback) {
 		async.waterfall([
 			function(next) {
 				npm.load({}, next);
 			},
 			function(res, next) {
-				npm.commands.install([id], next);
+				npm.commands.install([id + '@' + (version || 'latest')], next);
 			}
 		], callback);
 	};

src/socket.io/admin.js

@@ -94,12 +94,12 @@ SocketAdmin.plugins.toggleActive = function(socket, plugin_id, callback) {
 	plugins.toggleActive(plugin_id, callback);
 };
 
-SocketAdmin.plugins.toggleInstall = function(socket, plugin_id, callback) {
+SocketAdmin.plugins.toggleInstall = function(socket, data, callback) {
-	plugins.toggleInstall(plugin_id, callback);
+	plugins.toggleInstall(data.id, data.version, callback);
 };
 
-SocketAdmin.plugins.upgrade = function(socket, plugin_id, callback) {
+SocketAdmin.plugins.upgrade = function(socket, data, callback) {
-	plugins.upgrade(plugin_id, callback);
+	plugins.upgrade(data.id, data.version, callback);
 };
 
 SocketAdmin.widgets.set = function(socket, data, callback) {

src/user.js

@@ -104,7 +104,7 @@ var	async = require('async'),
 			}
 
 			if (user.password) {
-				user.password = null;
+				user.password = undefined;
 			}
 
 			if (!parseInt(user.uid, 10)) {

src/user/jobs.js

@@ -28,7 +28,7 @@ module.exports = function(User) {
 			return winston.log('[user/jobs] Did not send daily digests because subscription system is disabled.');
 		}
 
-		topics.getLatestTopics(0, 0, 10, 'day', function(err, topics) {
+		topics.getLatestTopics(0, 0, 10, 'day', function(err, data) {
 			if (err) {
 				return winston.error('[user/jobs] Could not send daily digests: ' + err.message);
 			}
@@ -49,7 +49,7 @@ module.exports = function(User) {
 						return next();
 					}
 
-					sendEmails(subscribed, topics, next);
+					sendEmails(subscribed, data.topics, next);
 				});
 			}, function(err) {
 				if (err) {

src/views/config.json

@@ -6,13 +6,13 @@
 		"^users/latest": "users",
 		"^users/sort-reputation": "users",
 		"^users/search": "users",
-		"^user.*edit": "account/edit",
+		"^user/.*/edit": "account/edit",
-		"^user.*following": "account/following",
+		"^user/.*/following": "account/following",
-		"^user.*followers": "account/followers",
+		"^user/.*/followers": "account/followers",
-		"^user.*settings": "account/settings",
+		"^user/.*/settings": "account/settings",
-		"^user.*favourites": "account/favourites",
+		"^user/.*/favourites": "account/favourites",
-		"^user.*posts": "account/posts",
+		"^user/.*/posts": "account/posts",
-		"^user.*topics": "account/topics",
+		"^user/.*/topics": "account/topics",
 		"^user/.*": "account/profile",
 		"^reset/.*": "reset_code",
 		"^tags/.*": "tag",