[NEW][Omnichannel/API] Endpoint livechat/room.visitor to change Omnichannel room's visitor

app/authorization/server/startup.js

@@ -24,6 +24,7 @@ Meteor.startup(function() {
 		{ _id: 'assign-roles',                       roles: ['admin'] },
 		{ _id: 'ban-user',                           roles: ['admin', 'owner', 'moderator'] },
 		{ _id: 'bulk-register-user',                 roles: ['admin'] },
+		{ _id: 'change-livechat-room-visitor',       roles: ['admin', 'livechat-manager', 'livechat-agent'] },
 		{ _id: 'create-c',                           roles: ['admin', 'user', 'bot', 'app'] },
 		{ _id: 'create-d',                           roles: ['admin', 'user', 'bot', 'app'] },
 		{ _id: 'create-p',                           roles: ['admin', 'user', 'bot', 'app'] },

app/livechat/server/api/v1/config.js

@@ -2,31 +2,42 @@ import { Match, check } from 'meteor/check';
 
 import { API } from '../../../../api/server';
 import { findGuest, settings, online, findOpenRoom, getExtraConfigInfo, findAgent } from '../lib/livechat';
+import { LivechatRooms } from '../../../../models';
+
 
 API.v1.addRoute('livechat/config', {
 	get() {
 		try {
 			check(this.queryParams, {
 				token: Match.Maybe(String),
 				department: Match.Maybe(String),
+				roomId: Match.Maybe(String),
 			});
 
 			const config = settings();
 			if (!config.enabled) {
 				return API.v1.success({ config: { enabled: false } });
 			}
 
-			const { token, department } = this.queryParams;
+			let { token } = this.queryParams;
+			const { department, roomId } = this.queryParams;
 			const status = online(department);
-			const guest = token && findGuest(token);
 
 			let room;
-			let agent;
+			room = roomId && Promise.await(LivechatRooms.findOneById(roomId));
+
+			if (room) {
+				token = room.v && room.v.token;
+			}
 
-			if (guest) {
+			const guest = token && findGuest(token);
+
+			if (guest && !room) {
 				room = findOpenRoom(token);
-				agent = room && room.servedBy && findAgent(room.servedBy._id);
 			}
+
+			const agent = room && room.servedBy && findAgent(room.servedBy._id);
+
 			const extra = Promise.await(getExtraConfigInfo(room));
 			const { config: extraConfig = {} } = extra || {};
 			Object.assign(config, { online: status, guest, room, agent }, { ...extraConfig });

app/livechat/server/api/v1/room.js

@@ -4,11 +4,14 @@ import { Random } from 'meteor/random';
 import { TAPi18n } from 'meteor/rocketchat:tap-i18n';
 
 import { settings as rcSettings } from '../../../../settings';
-import { Messages, LivechatRooms } from '../../../../models';
+import { Messages, LivechatRooms, Users } from '../../../../models';
 import { API } from '../../../../api/server';
 import { findGuest, findRoom, getRoom, settings, findAgent, onCheckRoomParams } from '../lib/livechat';
 import { Livechat } from '../../lib/Livechat';
 import { normalizeTransferredByData } from '../../lib/Helper';
+import { findVisitorInfo } from '../lib/visitors';
+import { hasPermissionAsync } from '../../../../authorization/server/functions/hasPermission';
+import { canAccessRoom } from '../../../../authorization/server/functions/canAccessRoom';
 
 API.v1.addRoute('livechat/room', {
 	get() {
@@ -179,3 +182,58 @@ API.v1.addRoute('livechat/room.forward', { authRequired: true }, {
 		API.v1.success(Meteor.runAsUser(this.userId, () => Meteor.call('livechat:transfer', this.bodyParams)));
 	},
 });
+
+API.v1.addRoute('livechat/room.visitor', { authRequired: true }, {
+	put() {
+		try {
+			check(this.bodyParams, {
+				rid: String,
+				oldVisitorId: String,
+				newVisitorId: String,
+			});
+
+			const user = Promise.await(Users.findOneById(this.userId));
+			if (!user) {
+				throw new Error('error-user-not-found');
+			}
+
+			if (!Promise.await(hasPermissionAsync(this.userId, 'change-livechat-room-visitor'))) {
+				throw new Error('error-not-authorized');
+			}
+
+			const { rid, newVisitorId, oldVisitorId } = this.bodyParams;
+
+			const { visitor } = Promise.await(findVisitorInfo({ userId: this.userId, visitorId: newVisitorId }));
+			if (!visitor) {
+				throw new Meteor.Error('invalid-new-visitor-id');
+			}
+			const { _id, username, token } = visitor;
+
+
+			const room = Promise.await(LivechatRooms.findOneById(rid));
+			if (!room) {
+				throw new Meteor.Error('invalid-room-id');
+			}
+
+			const { v: { _id: oldVisitorIdFromDb } } = room;
+			if (oldVisitorIdFromDb !== oldVisitorId) {
+				throw new Meteor.Error('invalid-old-visitor-id');
+			}
+
+			if (!canAccessRoom(room, user)) {
+				throw new Error('error-not-allowed');
+			}
+
+			Promise.await(Livechat.changeRoomVisitor(rid, { _id, username, token }));
+
+			return API.v1.success({
+				room: {
+					rid,
+					v: { _id, username, token },
+				},
+			});
+		} catch (e) {
+			return API.v1.failure(e);
+		}
+	},
+});

app/livechat/server/lib/Livechat.js

@@ -1119,6 +1119,18 @@ export const Livechat = {
 
 		return Promise.await(businessHourManager.allowAgentChangeServiceStatus(agentId));
 	},
+
+	notifyRoomVisitorChange(roomId, visitor) {
+		Livechat.stream.emit(roomId, {
+			type: 'visitorData',
+			visitor,
+		});
+	},
+
+	changeRoomVisitor(roomId, visitor) {
+		Promise.await(LivechatRooms.changeVisitorByRoomId(roomId, visitor));
+		Promise.await(Livechat.notifyRoomVisitorChange(roomId, visitor));
+	},
 };
 
 Livechat.stream = new Meteor.Streamer('livechat-room');

app/models/server/models/LivechatRooms.js

@@ -651,6 +651,22 @@ export class LivechatRooms extends Base {
 
 		return this.update(query, update);
 	}
+
+	changeVisitorByRoomId(roomId, { _id, username, token }) {
+		const query = {
+			_id: roomId,
+			t: 'l',
+		};
+		const update = {
+			$set: {
+				'v._id': _id,
+				'v.username': username,
+				'v.token': token,
+			},
+		};
+
+		return this.update(query, update);
+	}
 }
 
 export default new LivechatRooms(Rooms.model, true);