Merge branch 'master' of github.com:sintaxi/phoneroulette

lib/game/game.js

@@ -0,0 +1,81 @@
+module.exports = function(client){
+
+  var findOrCreate = function(inbound, cb){
+    client.sadd("players", inbound.phone, function(e, reply){
+      if(reply == 1){
+        cb(inbound, [{ phone: inbound.phone, body: "welcome to the game" }])
+      }else{
+        cb(inbound, [])
+      }
+    })
+  } 
+
+  var message = function(inb, cb){
+
+    client.get(inb.phone + ":partner", function(err, partner){
+      if(partner){
+        // DONE: send message to partner
+        cb(null, [{ phone: partner, body: inb.body }])
+      }else{
+
+        // no partner
+        client.lrange("queue", 0, -1, function(err, waiting){
+          if(waiting && waiting.indexOf(inb.phone) == -1){
+            // new player!
+            client.sadd("players", inb.phone, function(e, reply){
+              if(waiting.length > 0){
+                // join players together do not add to queue
+                client.lpop("queue", function(err, partner){
+                  // patch up players
+                  // send message
+                  client.multi()
+                  .set(inb.phone + ":partner", partner)
+                  .set(partner + ":partner", inb.phone)
+                  .exec(function(err, replies){
+                    // DONE: pairing has been done
+                    cb(null, [
+                      { phone: inb.phone, body: "you now have a partner" },
+                      { phone: partner, body: "you now have a partner" },
+                    ])
+                  })
+                })
+              }else{
+                client.rpush("queue", inb.phone, function(e, reply){
+                  // DONE: added to queue
+                  cb(inb, [{ phone: inb.phone, body: "welcome to the game" }])
+                })
+              }
+            })
+          }else{
+            // DONE: you are still in the queue
+            cb(inb, [{ phone: inb.phone, body: "you are still in the queue" }])
+          }
+
+        })
+
+      } //else
+
+    })// client.get()
+
+  };// message
+
+  return {
+
+    inbound: function(inb, cb){
+      message(inb, cb)
+    },
+
+    info: function(cb){
+      client.smembers("players", function(e, players){
+        client.lrange("queue", 0, -1, function(e, queue){
+          cb(null, { 
+            "queue": queue || [],
+            "players": players || []
+          })
+        })
+      })
+    }
+
+  }
+}
+