[BREAK] Decouple livechat visitors from regular users

.eslintignore

@@ -5,7 +5,7 @@ packages/meteor-timesync/
 packages/rocketchat-emoji-emojione/generateEmojiIndex.js
 packages/rocketchat-favico/favico.js
 packages/rocketchat-katex/client/katex/katex.min.js
-packages/rocketchat-livechat/app/node_modules
+packages/rocketchat-livechat/.app/node_modules
 packages/rocketchat-livechat/assets/rocketchat-livechat.min.js
 packages/rocketchat-livechat/assets/rocket-livechat.js
 packages/rocketchat-migrations/

.travis.yml

@@ -32,8 +32,8 @@ cache:
   - "$HOME/build/RocketChat/Rocket.Chat/node_modules"
   - "$HOME/build/RocketChat/Rocket.Chat/.meteor/local"
   - "$HOME/build/RocketChat/Rocket.Chat/packages/rocketchat-livechat/.npm"
-  - "$HOME/build/RocketChat/Rocket.Chat/packages/rocketchat-livechat/app/node_modules"
-  - "$HOME/build/RocketChat/Rocket.Chat/packages/rocketchat-livechat/app/.meteor/local"
+  - "$HOME/build/RocketChat/Rocket.Chat/packages/rocketchat-livechat/.app/node_modules"
+  - "$HOME/build/RocketChat/Rocket.Chat/packages/rocketchat-livechat/.app/.meteor/local"
 before_install:
 - if [ ! -e "$HOME/.meteor/meteor" ]; then curl https://install.meteor.com | sed s/--progress-bar/-sL/g | /bin/sh; fi
 # Start X Virtual Frame Buffer for headless testing with real browsers

packages/rocketchat-authorization/server/functions/canAccessRoom.js

@@ -17,9 +17,9 @@ RocketChat.authz.roomAccessValidators = [
 	}
 ];
 
-RocketChat.authz.canAccessRoom = function(room, user) {
+RocketChat.authz.canAccessRoom = function(room, user, extraData) {
 	return RocketChat.authz.roomAccessValidators.some((validator) => {
-		return validator.call(this, room, user);
+		return validator.call(this, room, user, extraData);
 	});
 };
 

packages/rocketchat-i18n/i18n/en.i18n.json

@@ -1082,6 +1082,8 @@
   "LDAP_Username_Field": "Username Field",
   "LDAP_Username_Field_Description": "Which field will be used as *username* for new users. Leave empty to use the username informed on login page.<br/>You can use template tags too, like `#{givenName}.#{sn}`.<br/>Default value is `sAMAccountName`.",
   "Execute_Synchronization_Now": "Execute Synchronization Now",
+  "Lead_capture_email_regex": "Lead capture email regex",
+  "Lead_capture_phone_regex": "Lead capture phone regex",
   "Least_Amount": "Least Amount",
   "Leave_Group_Warning": "Are you sure you want to leave the group \"%s\"?",
   "Leave_Livechat_Warning": "Are you sure you want to leave the livechat with \"%s\"?",
@@ -1624,6 +1626,7 @@
   "Send_invitation_email_info": "You can send multiple email invitations at once.",
   "Send_invitation_email_success": "You have successfully sent an invitation email to the following addresses:",
   "Send_request_on_chat_close": "Send Request on Chat Close",
+  "Send_request_on_lead_capture": "Send request on lead capture",
   "Send_request_on_offline_messages": "Send Request on Offline Messages",
   "Send_Test": "Send Test",
   "Send_welcome_email": "Send welcome email",
@@ -2122,4 +2125,4 @@
   "your_message_optional": "your message (optional)",
   "Your_password_is_wrong": "Your password is wrong!",
   "Your_push_was_sent_to_s_devices": "Your push was sent to %s devices"
-}
+}

packages/rocketchat-lib/package.js

@@ -97,6 +97,7 @@ Package.onUse(function(api) {
 	api.addFiles('server/functions/deleteUser.js', 'server');
 	api.addFiles('server/functions/getFullUserData.js', 'server');
 	api.addFiles('server/functions/getRoomByNameOrIdWithOptionToJoin.js', 'server');
+	api.addFiles('server/functions/loadMessageHistory.js', 'server');
 	api.addFiles('server/functions/removeUserFromRoom.js', 'server');
 	api.addFiles('server/functions/saveUser.js', 'server');
 	api.addFiles('server/functions/saveCustomFields.js', 'server');

packages/rocketchat-lib/server/functions/Notifications.js

@@ -25,10 +25,7 @@ RocketChat.Notifications = new class {
 		this.streamUser.allowWrite('logged');
 		this.streamAll.allowRead('all');
 		this.streamLogged.allowRead('logged');
-		this.streamRoom.allowRead(function(eventName) {
-			if (this.userId == null) {
-				return false;
-			}
+		this.streamRoom.allowRead(function(eventName, extraData) {
 			const [roomId] = eventName.split('/');
 			const user = Meteor.users.findOne(this.userId, {
 				fields: {
@@ -40,9 +37,12 @@ RocketChat.Notifications = new class {
 				console.warn(`Invalid streamRoom eventName: "${ eventName }"`);
 				return false;
 			}
-			if (room.t === 'l' && room.v._id === user._id) {
+			if (room.t === 'l' && extraData && extraData.token && room.v.token === extraData.token) {
 				return true;
 			}
+			if (this.userId == null) {
+				return false;
+			}
 			return room.usernames.indexOf(user.username) > -1;
 		});
 		this.streamRoomUsers.allowRead('none');
@@ -117,12 +117,21 @@ RocketChat.Notifications = new class {
 	}
 };
 
-RocketChat.Notifications.streamRoom.allowWrite(function(eventName, username) {
-	const [, e] = eventName.split('/');
+RocketChat.Notifications.streamRoom.allowWrite(function(eventName, username, typing, extraData) {
+	const [roomId, e] = eventName.split('/');
 	if (e === 'webrtc') {
 		return true;
 	}
 	if (e === 'typing') {
+
+		// typing from livechat widget
+		if (extraData && extraData.token) {
+			const room = RocketChat.models.Rooms.findOneById(roomId);
+			if (room && room.t === 'l' && room.v.token === extraData.token) {
+				return true;
+			}
+		}
+
 		const user = Meteor.users.findOne(this.userId, {
 			fields: {
 				username: 1

packages/rocketchat-lib/server/functions/loadMessageHistory.js

@@ -0,0 +1,88 @@
+import _ from 'underscore';
+
+const hideMessagesOfType = [];
+
+RocketChat.settings.get(/Message_HideType_.+/, function(key, value) {
+	const type = key.replace('Message_HideType_', '');
+	const types = type === 'mute_unmute' ? ['user-muted', 'user-unmuted'] : [type];
+
+	return types.forEach((type) => {
+		const index = hideMessagesOfType.indexOf(type);
+
+		if (value === true && index === -1) {
+			return hideMessagesOfType.push(type);
+		}
+
+		if (index > -1) {
+			return hideMessagesOfType.splice(index, 1);
+		}
+	});
+});
+
+RocketChat.loadMessageHistory = function loadMessageHistory({ userId, rid, end, limit = 20, ls }) {
+	const options = {
+		sort: {
+			ts: -1
+		},
+		limit
+	};
+
+	if (!RocketChat.settings.get('Message_ShowEditedStatus')) {
+		options.fields = {
+			editedAt: 0
+		};
+	}
+
+	let records;
+	if (end != null) {
+		records = RocketChat.models.Messages.findVisibleByRoomIdBeforeTimestampNotContainingTypes(rid, end, hideMessagesOfType, options).fetch();
+	} else {
+		records = RocketChat.models.Messages.findVisibleByRoomIdNotContainingTypes(rid, hideMessagesOfType, options).fetch();
+	}
+
+	const UI_Use_Real_Name = RocketChat.settings.get('UI_Use_Real_Name') === true;
+
+	const messages = records.map((message) => {
+		message.starred = _.findWhere(message.starred, {
+			_id: userId
+		});
+		if (message.u && message.u._id && UI_Use_Real_Name) {
+			const user = RocketChat.models.Users.findOneById(message.u._id);
+			message.u.name = user && user.name;
+		}
+		if (message.mentions && message.mentions.length && UI_Use_Real_Name) {
+			message.mentions.forEach((mention) => {
+				const user = RocketChat.models.Users.findOneById(mention._id);
+				mention.name = user && user.name;
+			});
+		}
+		return message;
+	});
+
+	let unreadNotLoaded = 0;
+	let firstUnread;
+
+	if (ls != null) {
+		const firstMessage = messages[messages.length - 1];
+
+		if ((firstMessage != null ? firstMessage.ts : undefined) > ls) {
+			delete options.limit;
+
+			const unreadMessages = RocketChat.models.Messages.findVisibleByRoomIdBetweenTimestampsNotContainingTypes(rid, ls, firstMessage.ts, hideMessagesOfType, {
+				limit: 1,
+				sort: {
+					ts: 1
+				}
+			});
+
+			firstUnread = unreadMessages.fetch()[0];
+			unreadNotLoaded = unreadMessages.count();
+		}
+	}
+
+	return {
+		messages,
+		firstUnread,
+		unreadNotLoaded
+	};
+};

packages/rocketchat-lib/server/lib/sendNotificationsOnMessage.js

@@ -166,6 +166,11 @@ RocketChat.callbacks.add('afterSaveMessage', function(message, room, userId) {
 
 	const user = RocketChat.models.Users.findOneById(message.u._id);
 
+	// might be a livechat visitor
+	if (!user) {
+		return message;
+	}
+
 	/*
 	Increment unread couter if direct messages
 	 */

packages/rocketchat-livechat/app/.meteor/packages → packages/rocketchat-livechat/.app/.meteor/packages

@@ -38,3 +38,5 @@ standard-minifier-css@1.3.5
 standard-minifier-js@2.2.0
 shell-server@0.3.0
 dynamic-import@0.2.0
+
+konecty:user-presence

packages/rocketchat-livechat/app/.meteor/versions → packages/rocketchat-livechat/.app/.meteor/versions

@@ -40,6 +40,7 @@ jquery@1.11.10
 kadira:blaze-layout@2.3.0
 kadira:flow-router@2.12.1
 konecty:nrr@2.0.2
+konecty:user-presence@2.0.0
 less@2.7.11
 livedata@1.0.18
 localstorage@1.2.0
@@ -57,6 +58,7 @@ momentjs:moment@2.19.1
 mongo@1.3.0
 mongo-dev-server@1.1.0
 mongo-id@1.0.6
+nooitaf:colors@1.1.2_1
 npm-bcrypt@0.9.3
 npm-mongo@2.2.33
 observe-sequence@1.0.16
@@ -68,7 +70,7 @@ rate-limit@1.0.8
 reactive-dict@1.2.0
 reactive-var@1.0.11
 retry@1.0.9
-rocketchat:streamer@0.5.0
+rocketchat:streamer@0.6.0
 routepolicy@1.0.12
 service-configuration@1.0.11
 session@1.1.7

packages/rocketchat-livechat/app/client/lib/CustomFields.js → packages/rocketchat-livechat/.app/client/lib/CustomFields.js

@@ -1,3 +1,5 @@
+import visitor from '../../imports/client/visitor';
+
 this.CustomFields = (function() {
 	let queue = {};
 	let initiated = false;
@@ -13,7 +15,7 @@ this.CustomFields = (function() {
 
 	const init = function() {
 		Tracker.autorun(function() {
-			if (Meteor.userId()) {
+			if (visitor.getId()) {
 				initiated = true;
 				Object.keys(queue).forEach((key) => {
 					setCustomField.call(this, queue[key].token, key, queue[key].value, queue[key].overwrite);

packages/rocketchat-livechat/app/client/lib/LivechatVideoCall.js → packages/rocketchat-livechat/.app/client/lib/LivechatVideoCall.js

@@ -1,4 +1,5 @@
 /* globals LivechatVideoCall, cordova, JitsiMeetExternalAPI */
+import visitor from '../../imports/client/visitor';
 
 LivechatVideoCall = new (class LivechatVideoCall {
 	constructor() {

packages/rocketchat-livechat/app/client/lib/_livechat.js → packages/rocketchat-livechat/.app/client/lib/_livechat.js

@@ -1,3 +1,5 @@
+import visitor from '../../imports/client/visitor';
+
 this.Livechat = new (class Livechat {
 	constructor() {
 		this._online = new ReactiveVar(null);
@@ -30,17 +32,17 @@ this.Livechat = new (class Livechat {
 		this.stream = new Meteor.Streamer('livechat-room');
 
 		Tracker.autorun(() => {
-			if (this._room.get() && Meteor.userId()) {
+			if (this._room.get() && visitor.getId()) {
 				RoomHistoryManager.getMoreIfIsEmpty(this._room.get());
 				visitor.subscribeToRoom(this._room.get());
 				visitor.setRoom(this._room.get());
 
-				Meteor.call('livechat:getAgentData', this._room.get(), (error, result) => {
+				Meteor.call('livechat:getAgentData', { roomId: this._room.get(), token: visitor.getToken() }, (error, result) => {
 					if (!error) {
 						this._agent.set(result);
 					}
 				});
-				this.stream.on(this._room.get(), (eventData) => {
+				this.stream.on(this._room.get(), { token: visitor.getToken() }, (eventData) => {
 					if (!eventData || !eventData.type) {
 						return;
 					}