Bugfix on aggregation worker when updating a user

telepat-io · Sep 14, 2016 · 0c1d7cb · 0c1d7cb
1 parent b35f11e
commit 0c1d7cb
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/lib/aggregation_worker.js b/lib/aggregation_worker.js
@@ -108,7 +108,7 @@ AggregationWorker.prototype.processMessage = function(message) {
 		},
 		function getAffectedChannels(callback) {
 			async.each(deltasToWrite, function(d, c) {
-				self.getAffectedChannels(d.object, d.application_id, function(err, channels) {
+				self.getAffectedChannels(d.object, d.application_id || message.application_id, function(err, channels) {
 					if (err)
 						return c(new Error('Failed to get affected channels: '+err.message));
 					d.subscriptions = channels.map(function(channel) {
@@ -258,6 +258,9 @@ AggregationWorker.prototype.getAffectedChannels = function(item, appId, callback
 AggregationWorker.prototype.validateAuthor = function(object, aclType, userId, callback) {
 	var appSchema = Models.Application.loadedAppModels[object.application_id].schema;
 
+	if (!appSchema[object.type])
+		return callback();
+
 	if ((appSchema[object.type][aclType] & 8) && userId) {
 		var authorFields = (appSchema[object.type].author_fields || []).concat('user_id');