[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/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: roomVisitorId } = {} } = room;
+			if (roomVisitorId !== oldVisitorId) {
+				throw new Meteor.Error('invalid-room-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);