diff --git a/install/package.json b/install/package.json
index 280cb852a1..c4bc57109f 100644
--- a/install/package.json
+++ b/install/package.json
@@ -64,7 +64,7 @@
         "mousetrap": "^1.6.1",
         "mubsub": "^1.4.0",
         "nconf": "^0.9.1",
-        "nodebb-plugin-composer-default": "6.0.21",
+        "nodebb-plugin-composer-default": "6.0.22",
         "nodebb-plugin-dbsearch": "2.0.16",
         "nodebb-plugin-emoji": "^2.2.2",
         "nodebb-plugin-emoji-android": "2.0.0",
diff --git a/src/socket.io/posts.js b/src/socket.io/posts.js
index e0b7884ece..108a29d136 100644
--- a/src/socket.io/posts.js
+++ b/src/socket.io/posts.js
@@ -59,7 +59,7 @@ function postReply(socket, data, callback) {
 
 			next(null, postData);
 
-			websockets.in('uid_' + socket.uid).emit('event:new_post', result);
+			socket.emit('event:new_post', result);
 
 			user.updateOnlineUsers(socket.uid);
 
diff --git a/src/upgrades/1.4.6/delete_sessions.js b/src/upgrades/1.4.6/delete_sessions.js
index 29d11db48a..c899126bde 100644
--- a/src/upgrades/1.4.6/delete_sessions.js
+++ b/src/upgrades/1.4.6/delete_sessions.js
@@ -9,7 +9,13 @@ module.exports = {
 	name: 'Delete accidentally long-lived sessions',
 	timestamp: Date.UTC(2017, 3, 16),
 	method: function (callback) {
-		var configJSON = require('../../../config.json');
+		var configJSON;
+		try {
+			configJSON = require('../../../config.json') || { [process.env.database]: true };
+		} catch (err) {
+			configJSON = { [process.env.database]: true };
+		}
+
 		var isRedisSessionStore = configJSON.hasOwnProperty('redis');
 		var progress = this.progress;
 
diff --git a/src/upgrades/1.7.3/key_value_schema_change.js b/src/upgrades/1.7.3/key_value_schema_change.js
index 637d2c534d..a8abefb10a 100644
--- a/src/upgrades/1.7.3/key_value_schema_change.js
+++ b/src/upgrades/1.7.3/key_value_schema_change.js
@@ -8,7 +8,12 @@ module.exports = {
 	name: 'Change the schema of simple keys so they don\'t use value field (mongodb only)',
 	timestamp: Date.UTC(2017, 11, 18),
 	method: function (callback) {
-		var configJSON = require('../../../config.json');
+		var configJSON;
+		try {
+			configJSON = require('../../../config.json') || { [process.env.database]: true, database: process.env.database };
+		} catch (err) {
+			configJSON = { [process.env.database]: true, database: process.env.database };
+		}
 		var isMongo = configJSON.hasOwnProperty('mongo') && configJSON.database === 'mongo';
 		var progress = this.progress;
 		if (!isMongo) {
diff --git a/test/topics.js b/test/topics.js
index 559eaab973..e98a03a270 100644
--- a/test/topics.js
+++ b/test/topics.js
@@ -1080,14 +1080,12 @@ describe('Topic\'s', function () {
 		});
 
 		it('should mark topic notifications read', function (done) {
-			var socketPosts = require('../src/socket.io/posts');
-
 			async.waterfall([
 				function (next) {
 					socketTopics.follow({ uid: adminUid }, tid, next);
 				},
 				function (next) {
-					socketPosts.reply({ uid: uid }, { content: 'some content', tid: tid }, next);
+					topics.reply({ uid: uid, timestamp: Date.now(), content: 'some content', tid: tid }, next);
 				},
 				function (data, next) {
 					setTimeout(next, 2500);