/
sms.js
69 lines (58 loc) · 1.76 KB
/
sms.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
RocketChat.API.v1.addRoute('livechat/sms-incoming/:service', {
post() {
const SMSService = RocketChat.SMS.getService(this.urlParams.service);
const sms = SMSService.parse(this.bodyParams);
let visitor = RocketChat.models.Users.findOneVisitorByPhone(sms.from);
const sendMessage = {
message: {
_id: Random.id()
},
roomInfo: {
sms: {
from: sms.to
}
}
};
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();
const 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.message.msg = sms.body;
sendMessage.guest = visitor;
try {
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;
} catch (e) {
return SMSService.error.call(this, e);
}
}
});