Merge pull request RocketChat#623 from WideChat/throw_livechat_messag…

…e_on_kill_switch_on

Throw livechat message on kill switch on

app/lib/server/functions/sendMessage.js

@@ -219,34 +219,36 @@ export const sendMessage = function(user, message, room, upsert = false) {
 	}
 
 	message = callbacks.run('beforeSaveMessage', message, room);
-	if (message) {
-		if (message._id && upsert) {
-			const { _id } = message;
-			delete message._id;
-			Messages.upsert({
-				_id,
-				'u._id': message.u._id,
-			}, message);
-			message._id = _id;
-		} else {
-			const messageAlreadyExists = message._id && Messages.findOneById(message._id, { fields: { _id: 1 } });
-			if (messageAlreadyExists) {
-				return;
+	if (!settings.get('Livechat_kill_switch') || room.lastMessage.msg !== settings.get('Livechat_kill_switch_message')) {
+		if (message) {
+			if (message._id && upsert) {
+				const { _id } = message;
+				delete message._id;
+				Messages.upsert({
+					_id,
+					'u._id': message.u._id,
+				}, message);
+				message._id = _id;
+			} else {
+				const messageAlreadyExists = message._id && Messages.findOneById(message._id, { fields: { _id: 1 } });
+				if (messageAlreadyExists) {
+					return;
+				}
+				message._id = Messages.insert(message);
 			}
-			message._id = Messages.insert(message);
-		}
 
-		if (Apps && Apps.isLoaded()) {
-			// This returns a promise, but it won't mutate anything about the message
-			// so, we don't really care if it is successful or fails
-			Apps.getBridges().getListenerBridge().messageEvent('IPostMessageSent', message);
-		}
+			if (Apps && Apps.isLoaded()) {
+				// This returns a promise, but it won't mutate anything about the message
+				// so, we don't really care if it is successful or fails
+				Apps.getBridges().getListenerBridge().messageEvent('IPostMessageSent', message);
+			}
 
-		/*
-		Defer other updates as their return is not interesting to the user
-		*/
-		// Execute all callbacks
-		callbacks.runAsync('afterSaveMessage', message, room, user._id);
-		return message;
+			/*
+			Defer other updates as their return is not interesting to the user
+			*/
+			// Execute all callbacks
+			callbacks.runAsync('afterSaveMessage', message, room, user._id);
+			return message;
+		}
 	}
 };

app/livechat/server/hooks/leadCapture.js

@@ -1,8 +1,6 @@
-import { Meteor } from 'meteor/meteor';
-
 import { callbacks } from '../../../callbacks';
-import { settings } from '../../../settings';
 import { LivechatVisitors } from '../../../models';
+import { settings } from '../../../settings';
 
 function validateMessage(message, room) {
 	// skips this callback if the message was edited
@@ -48,8 +46,13 @@ callbacks.add('afterSaveMessage', function(message, room) {
 	return message;
 }, callbacks.priority.LOW, 'leadCapture');
 
-callbacks.add('beforeSaveMessage', function() {
+callbacks.add('beforeSaveMessage', function(message, room) {
 	if (settings.get('Livechat_kill_switch')) {
-		throw new Meteor.Error(settings.get('Livechat_kill_switch_message'));
+		if (room && room.lastMessage.msg !== settings.get('Livechat_kill_switch_message')) {
+			message.msg = settings.get('Livechat_kill_switch_message');
+			message.avatar = '';
+			message.u._id = room.servedBy._id;
+			message.u.username = room.servedBy.username;
+		}
 	}
 }, callbacks.priority.LOW, 'leadCapture');