[NEW] Apps engine Livechat

app/apps/server/bridges/bridges.js

@@ -13,6 +13,8 @@ import { AppRoomBridge } from './rooms';
 import { AppInternalBridge } from './internal';
 import { AppSettingBridge } from './settings';
 import { AppUserBridge } from './users';
+import { AppLivechatBridge } from './livechat';
+import { AppUploadBridge } from './uploads';
 
 export class RealAppBridges extends AppBridges {
 	constructor(orch) {
@@ -31,6 +33,8 @@ export class RealAppBridges extends AppBridges {
 		this._internalBridge = new AppInternalBridge(orch);
 		this._setsBridge = new AppSettingBridge(orch);
 		this._userBridge = new AppUserBridge(orch);
+		this._livechatBridge = new AppLivechatBridge(orch);
+		this._uploadBridge = new AppUploadBridge(orch);
 	}
 
 	getCommandBridge() {
@@ -84,4 +88,12 @@ export class RealAppBridges extends AppBridges {
 	getUserBridge() {
 		return this._userBridge;
 	}
+
+	getLivechatBridge() {
+		return this._livechatBridge;
+	}
+
+	getUploadBridge() {
+		return this._uploadBridge;
+	}
 }

app/apps/server/bridges/http.js

@@ -1,5 +1,31 @@
 import { HTTP } from 'meteor/http';
 
+/**
+ * Normalize the options object to a shape
+ * the HTTP.call method recognizes
+ *
+ * @param Object options Http options received from the engine
+ *
+ */
+function normalizeHttpOptions(options) {
+	const npmRequestOptions = {};
+
+	if (options.hasOwnProperty('strictSSL')) {
+		npmRequestOptions.strictSSL = options.strictSSL;
+		delete options.strictSSL;
+	}
+
+	if (options.hasOwnProperty('rejectUnauthorized')) {
+		npmRequestOptions.agentOptions = {
+			rejectUnauthorized: options.rejectUnauthorized,
+		};
+
+		delete options.rejectUnauthorized;
+	}
+
+	options.npmRequestOptions = npmRequestOptions;
+}
+
 export class AppHttpBridge {
 	constructor(orch) {
 		this.orch = orch;
@@ -10,6 +36,8 @@ export class AppHttpBridge {
 			info.request.content = JSON.stringify(info.request.data);
 		}
 
+		normalizeHttpOptions(info.request);
+
 		this.orch.debugLog(`The App ${ info.appId } is requesting from the outter webs:`, info);
 
 		try {

app/apps/server/bridges/livechat.js

@@ -0,0 +1,135 @@
+import { Random } from 'meteor/random';
+
+import { getRoom } from '../../../livechat/server/api/lib/livechat';
+import { Livechat } from '../../../livechat/server/lib/Livechat';
+import Rooms from '../../../models/server/models/Rooms';
+import LivechatVisitors from '../../../models/server/models/LivechatVisitors';
+import Users from '../../../models/server/models/Users';
+
+export class AppLivechatBridge {
+	constructor(orch) {
+		this.orch = orch;
+	}
+
+	async createMessage(message, appId) {
+		this.orch.debugLog(`The App ${ appId } is creating a new message.`);
+
+		if (!message.token) {
+			throw new Error('Invalid token for livechat message');
+		}
+
+		const data = {
+			guest: this.orch.getConverters().get('visitors').convertAppVisitor(message.visitor),
+			message: this.orch.getConverters().get('messages').convertAppMessage(message),
+		};
+
+		const msg = Livechat.sendMessage(data);
+
+		return msg._id;
+	}
+
+	async getMessageById(messageId, appId) {
+		this.orch.debugLog(`The App ${ appId } is getting the message: "${ messageId }"`);
+
+		return this.orch.getConverters().get('messages').convertById(messageId);
+	}
+
+	async updateMessage(message, appId) {
+		this.orch.debugLog(`The App ${ appId } is updating a message.`);
+
+		const data = {
+			guest: message.visitor,
+			message: this.orch.getConverters().get('messages').convertAppMessage(message),
+		};
+
+		Livechat.updateMessage(data);
+	}
+
+	async createRoom(visitor, agent, appId) {
+		this.orch.debugLog(`The App ${ appId } is creating a livechat room.`);
+
+		const agentUser = Users.findOneById(agent.id);
+		agentUser.agentId = agentUser._id;
+
+		return this.orch.getConverters().get('rooms').convertRoom(getRoom({
+			guest: this.orch.getConverters().get('visitors').convertAppVisitor(visitor),
+			agent: agentUser,
+			rid: Random.id(),
+		}).room);
+	}
+
+	async closeRoom(room, comment, appId) {
+		this.orch.debugLog(`The App ${ appId } is closing a livechat room.`);
+
+		return Livechat.closeRoom({
+			visitor: this.orch.getConverters().get('visitors').convertAppVisitor(room.visitor),
+			room: this.orch.getConverters().get('rooms').convertAppRoom(room),
+			comment,
+		});
+	}
+
+	async findRooms(visitor, departmentId, appId) {
+		this.orch.debugLog(`The App ${ appId } is looking for livechat visitors.`);
+
+		if (!visitor) {
+			return [];
+		}
+
+		let result;
+
+		if (departmentId) {
+			result = Rooms.findOpenByVisitorTokenAndDepartmentId(visitor.token, departmentId).fetch();
+		} else {
+			result = Rooms.findOpenByVisitorToken(visitor.token).fetch();
+		}
+
+		return result.map((room) => this.orch.getConverters().get('rooms').convertRoom(room));
+	}
+
+	async createVisitor(visitor, appId) {
+		this.orch.debugLog(`The App ${ appId } is creating a livechat visitor.`);
+
+		const registerData = {
+			department: visitor.department,
+			username: visitor.username,
+			name: visitor.name,
+			token: visitor.token,
+		};
+
+		if (visitor.visitorEmails && visitor.visitorEmails.length) {
+			registerData.email = visitor.visitorEmails[0].address;
+		}
+
+		if (visitor.phone && visitor.phone.length) {
+			registerData.phone = { number: visitor.phone[0].phoneNumber };
+		}
+
+		return Livechat.registerGuest(registerData);
+	}
+
+	async transferVisitor(visitor, transferData, appId) {
+		this.orch.debugLog(`The App ${ appId } is transfering a livechat.`);
+
+		if (!visitor) {
+			throw new Error('Invalid visitor, cannot transfer');
+		}
+
+		const {
+			targetAgent,
+			targetDepartment: departmentId,
+			currentRoom,
+		} = transferData;
+
+		return Livechat.transfer(
+			this.orch.getConverters().get('rooms').convertAppRoom(currentRoom),
+			this.orch.getConverters().get('visitors').convertAppVisitor(visitor),
+			{ userId: targetAgent.id, departmentId }
+		);
+	}
+
+	async findVisitors(query, appId) {
+		this.orch.debugLog(`The App ${ appId } is looking for livechat visitors.`);
+
+		return LivechatVisitors.find(query).fetch().map((visitor) => this.orch.getConverters().get('visitors').convertVisitor(visitor));
+	}
+}

app/apps/server/bridges/uploads.js

@@ -0,0 +1,27 @@
+import { FileUpload } from '../../../file-upload/server';
+
+export class AppUploadBridge {
+	constructor(orch) {
+		this.orch = orch;
+	}
+
+	async getById(id, appId) {
+		this.orch.debugLog(`The App ${ appId } is getting the upload: "${ id }"`);
+
+		return this.orch.getConverters().get('uploads').convertById(id);
+	}
+
+	getBuffer(upload, appId) {
+		this.orch.debugLog(`The App ${ appId } is getting the upload: "${ upload.id }"`);
+
+		return new Promise((resolve, reject) => {
+			FileUpload.getBuffer(upload, (error, result) => {
+				if (error) {
+					return reject(error);
+				}
+
+				resolve(result);
+			});
+		});
+	}
+}

app/apps/server/converters/departments.js

@@ -0,0 +1,52 @@
+import LivechatDepartment from '../../../models/server/models/LivechatDepartment';
+import { transformMappedData } from '../../lib/misc/transformMappedData';
+
+export class AppDepartmentsConverter {
+	constructor(orch) {
+		this.orch = orch;
+	}
+
+	convertById(id) {
+		const department = LivechatDepartment.findOneById(id);
+
+		return this.convertDepartment(department);
+	}
+
+	convertDepartment(department) {
+		if (!department) {
+			return undefined;
+		}
+
+		const map = {
+			id: '_id',
+			name: 'name',
+			email: 'email',
+			updatedAt: '_updatedAt',
+			enabled: 'enabled',
+			numberOfAgents: 'numAgents',
+			showOnOfflineForm: 'showOnOfflineForm',
+			showOnRegistration: 'showOnRegistration',
+		};
+
+		return transformMappedData(department, map);
+	}
+
+	convertAppDepartment(department) {
+		if (!department) {
+			return undefined;
+		}
+
+		const newDepartment = {
+			_id: department.id,
+			name: department.name,
+			email: department.email,
+			_updatedAt: department.updatedAt,
+			enabled: department.enabled,
+			numAgents: department.numberOfAgents,
+			showOnOfflineForm: department.showOnOfflineForm,
+			showOnRegistration: department.showOnRegistration,
+		};
+
+		return Object.assign(newDepartment, department._unmappedProperties_);
+	}
+}

app/apps/server/converters/messages.js

@@ -30,8 +30,10 @@ export class AppMessagesConverter {
 			emoji: 'emoji',
 			avatarUrl: 'avatar',
 			alias: 'alias',
+			file: 'file',
 			customFields: 'customFields',
 			groupable: 'groupable',
+			token: 'token',
 			room: (message) => {
 				const result = this.orch.getConverters().get('rooms').convertById(message.rid);
 				delete message.rid;