This repository has been archived by the owner on Jan 28, 2021. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 1
/
Copy pathserver.js
106 lines (85 loc) · 2.72 KB
/
server.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
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
var express = require('express');
var app = express();
var twilio = require('twilio');
var formidable = require('formidable');
var requestIp = require('request-ip');
var log = require('./logger')('events');
// init in-memory db for quotas
var db = {};
var db_timestamp = Date.now();
var db_lifetime = 24 * 60 * 60 * 1000; // 24 hours in ms
var quota = 5; // messages per day
// Set port from environment variable or default
var port = process.env.PORT || 3000;
// Set environment variables
var account_sid = process.env.TWILIO_ACCOUNT_SID;
var auth_token = process.env.TWILIO_AUTH_TOKEN;
var from_number = process.env.TWILIO_FROM_NUMBER;
// If env variables are not set, quit application with error exit code
if (!account_sid || !auth_token || !from_number) {
log.error("Missing environment variables")
process.exit(1);
}
app.use(requestIp.mw());
app.use(express.static('public'));
app.get('/', function(request, response) {
response.sendFile(__dirname + '/views/index.html');
});
app.post('/text', function(req, res, next) {
var form = new formidable.IncomingForm();
form.parse(req, function(err, fields, files) {
var message = fields.message;
var recipient = fields.recipient;
// Clear database if lifetime is exceeded
if (Date.now() - db_timestamp > db_lifetime) {
db_timestamp = Date.now();
db = {};
}
// Increase access counter by one
var ip = req.clientIp;
if (db[ip] == null) {
db[ip] = 1;
} else {
db[ip]++;
}
// Check if quota is exceeded
if (db[ip] > quota) {
log.info('Exceeded Quota.');
res.sendStatus(429);
return;
}
// Guard invalid requests
if (message == null || message.length < 10) {
log.info('Invalid request: No message provided.');
res.sendStatus(422);
return;
}
// Guard invalid recipient
if (recipient == null || recipient.length < 6) {
log.info('Invalid request: No recipient provided.');
res.sendStatus(422);
return;
}
// Data masking
var maskedMessage = message.substr(0, 10) + '...';
var maskedRecipient = recipient.substr(0, recipient.length - 5) + '*****';
// Prepare to send message
log.info('Sending message ' + maskedMessage + ' to ' + maskedRecipient + ' from ip ' + ip);
var client = new twilio(account_sid, auth_token);
var options = {
to: recipient,
from: from_number,
body: message
};
client.messages.create(options).then(function() {
res.sendStatus(200);
}).catch(function(err) {
log.error(err);
res.sendStatus(503);
});
});
});
// listen for requests :)
var listener = app.listen(port, function() {
log.info('Your app is listening on port ' + listener.address().port);
});