Rocket.Chat/packages/rocketchat-livechat/server/api.js

/* globals Restivus */
const Api = new Restivus({
	apiPath: 'livechat-api/',
	useDefaultAuth: true,
	prettyJson: true
});

Api.addRoute('sms-incoming/:service', {
	post() {
		const SMSService = RocketChat.SMS.getService(this.urlParams.service);

		const sms = SMSService.parse(this.bodyParams);

		var visitor = RocketChat.models.Users.findOneVisitorByPhone(sms.from);

		let sendMessage = {
			message: {
				_id: Random.id()
			}
		};

		if (visitor) {
			const rooms = RocketChat.models.Rooms.findOpenByVisitorToken(visitor.profile.token).fetch();

			if (rooms && rooms.length > 0) {
				sendMessage.message.rid = rooms[0]._id;
			} else {
				sendMessage.message.rid = Random.id();
			}
			sendMessage.message.token = visitor.profile.token;
		} else {
			sendMessage.message.rid = Random.id();
			sendMessage.message.token = Random.id();

			let userId = RocketChat.Livechat.registerGuest({
				username: sms.from.replace(/[^0-9]/g, ''),
				token: sendMessage.message.token,
				phone: {
					number: sms.from
				}
			});

			visitor = RocketChat.models.Users.findOneById(userId);

			sendMessage.roomInfo = {
				sms: {
					from: sms.to
				}
			};
		}

		sendMessage.message.msg = sms.body;

		sendMessage.guest = visitor;

		const message = SMSService.response.call(this, RocketChat.Livechat.sendMessage(sendMessage));

		Meteor.defer(() => {
			if (sms.extra) {
				if (sms.extra.fromCountry) {
					Meteor.call('livechat:setCustomField', sendMessage.message.token, 'country', sms.extra.fromCountry);
				}
				if (sms.extra.fromState) {
					Meteor.call('livechat:setCustomField', sendMessage.message.token, 'state', sms.extra.fromState);
				}
				if (sms.extra.fromCity) {
					Meteor.call('livechat:setCustomField', sendMessage.message.token, 'city', sms.extra.fromCity);
				}
			}
		});

		return message;
	}
});