From f3fc683a6b775e8bfcfd9e62fe175922ed0e78e5 Mon Sep 17 00:00:00 2001
From: typpo <ian@typpo.us>
Date: Sat, 7 Apr 2012 05:00:44 -0400
Subject: [PATCH] it's all working

---
 app.js       | 79 +++++++++++++++++++++++++++++++++++++++-------------
 package.json |  1 +
 providers.js | 23 +++++++++++++++
 3 files changed, 83 insertions(+), 20 deletions(-)
 create mode 100644 providers.js

diff --git a/app.js b/app.js
index c38145f..082c89d 100644
--- a/app.js
+++ b/app.js
@@ -1,6 +1,7 @@
 var express = require('express')
   , app = express.createServer()
   , nodemailer = require('nodemailer')
+  , _ = require('underscore')
   /*
   , amazonses = require('amazon-ses')
   */
@@ -8,6 +9,7 @@ var express = require('express')
   , spawn = require('child_process').spawn
   , Stream = require('stream')
   , config = require('./config.js')
+  , providers = require('./providers.js').list
 
   /*
 var SendGrid = require('sendgrid').SendGrid;
@@ -41,24 +43,51 @@ app.get('/', function(req, res) {
 app.post('/text', function(req, res) {
   var keystr = req.connection.remoteAddress + '_' + dateStr();
 
-  redis.incr(keystr, function(err, num) {
+  var number = stripPhone(req.body.number);
+  if (number.length < 9 || number.length > 10) {
+    res.send({success:false,message:'Invalid phone number.'});
+    return;
+  }
+
+  redis.incr('phone:' + number, function(err, num) {
     if (err) {
-      res.send({success:false,message:'Could not validate IP quota.'});
+      res.send({success:false,message:'Could not validate phone# quota.'});
       return;
     }
 
-    if (num < 501) {
+    setTimeout(function() {
+      redis.decr('phone:' + number, function(err, num) {
+        if (err) {
+          console.log('*** WARNING failed to decr ' + number);
+        }
+      });
+    }, 1000*60*3);
+    if (num > 3) {
+      res.send({success:false,message:'Exceeded quota for this phone number.'});
+      return;
+    }
+
+    // now check against ip quota
+    redis.incr(keystr, function(err, num) {
+      if (err) {
+        res.send({success:false,message:'Could not validate IP quota.'});
+        return;
+      }
+      if (num > 500) {
+        res.send({success:false,message:'Exceeded quota for this IP address.'});
+        return;
+      }
+
       sendText(req.body.number, req.body.message, function(err) {
         if (err)
           res.send({success:false,message:'Communication with SMS gateway failed.'});
         else
           res.send({success:true});
       });
-    }
-    else {
-      res.send({success:false,message:'Exceeded quota.'});
-    }
+    });
+
   });
+
 });
 
 function dateStr() {
@@ -69,27 +98,37 @@ function dateStr() {
   return mm + '/' + dd + '/' + yyyy;
 }
 
-function validatePhone() {
+function stripPhone(phone) {
+  return phone.replace(/\D/g, '');
+}
 
+function validatePhone(phone) {
 
 }
 
 function sendText(phone, message, cb) {
-
-  var actual_phone = phone.replace(/\D/g, '');
-  console.log('txting phone', actual_phone);
+  console.log('txting phone', phone);
   console.log('msg', message);
 
-  //var child = process.createChildProcess('sendmail', ['-f"txt@textbelt.com"', '"9147727429@vtext.com"']);
-  var child = spawn('sendmail', ['-f', 'txt@textbelt.com', '9147727429@vtext.com']);
-  child.stdout.on('data', console.log);
-  child.stderr.on('data', console.log);
-  child.on('error', console.log);
-  child.on('exit', function(code, signal) {
-    cb(code !== 0);
+
+  var done = _.after(providers.length, function() {
+    cb(false);
   });
-  child.stdin.write('testiiii', 'binary');
-  child.stdin.end();
+
+
+  for (var i=0; i < providers.length; i++) {
+    var provider = providers[i];
+    var email = provider.replace('%s', phone);
+    var child = spawn('sendmail', ['-f', 'txt@textbelt.com', email]);
+    child.stdout.on('data', console.log);
+    child.stderr.on('data', console.log);
+    child.on('error', console.log);
+    child.on('exit', function(code, signal) {
+      done();
+    });
+    child.stdin.write(message + '\n.');
+    child.stdin.end();
+  }
 
 
   /*
diff --git a/package.json b/package.json
index 681cca4..92cdff8 100644
--- a/package.json
+++ b/package.json
@@ -7,6 +7,7 @@
       , "redis-url": "latest"
       , "amazon-ses": "latest"
       , "sendgrid": "latest"
+      , "underscore": "latest"
     }
   , "devDependencies": {
     }
diff --git a/providers.js b/providers.js
new file mode 100644
index 0000000..b2fc5c5
--- /dev/null
+++ b/providers.js
@@ -0,0 +1,23 @@
+
+module.exports = {
+
+  list: [
+    '%s@message.alltel.com',
+    '%s@paging.acswireless.com',
+    '%s@txt.att.net',
+    '%s@myboostmobile.com',
+    '%s@mobile.celloneusa.com',
+    '%s@sms.edgewireless.com',
+    '%s@messaging.sprintpcs.com',
+    '%s@tmomail.net',
+    '%s@mymetropcs.com',
+    '%s@messaging.nextel.com',
+    '%s@mobile.celloneusa.com',
+    '%s@qwestmp.com',
+    '%s@pcs.rogers.com',
+    '%s@msg.telus.com',
+    //'%s@email.uscc.net',
+    '%s@vtext.com',
+    '%s@vmobl.com',
+  ],
+};