in memory server to stub behaviors

Author: bleonard

server/.nvmrc

@@ -0,0 +1 @@
+iojs-v2.4.0

server/auth.js

@@ -0,0 +1,50 @@
+var User = require("./models").User;
+
+var renderAccount = function (user) {
+  var out = {
+    id: user.id,
+    token: user.token
+  };
+  return out;
+};
+
+exports.loginUser = function *() {
+  var params = this.request.body || {};
+  var username = (params.username || "").trim();
+  var password = (params.password || "").trim();
+
+  if(!username) this.throw("No username provided", 422);
+  if(!password) this.throw("No password provided", 422);
+  
+  var user = User.findByUsername(username);
+  if (user && user.authenticate(password)) {
+    this.status = 200;
+    this.body = renderAccount(user);
+  }
+  else {
+    this.status = 422;
+    this.body = {error: "Username and password not found"}
+  }
+};
+
+exports.getCurrentUser = function *() {
+  this.status = 200;
+  this.body = renderAccount(this.passport.user);
+};
+
+exports.createUser = function *() {
+  var params = this.request.body || {};
+  var username = (params.username || "").trim();
+  var password = (params.password || "").trim();
+
+  if(!username) this.throw("No username provided", 422);
+  if(!password) this.throw("No password provided", 422);
+  
+  var user = User.findByUsername(username);
+  if(user) this.throw("User already exists", 422);
+
+  user = User.create(params.username, params.password);
+
+  this.status = 201;
+  this.body = renderAccount(user);
+};

server/models.js

@@ -0,0 +1,46 @@
+// in memory database for testing
+
+var _users = {}
+var _usersCount = 0;
+var User = function(username) {
+  this.id = ++_usersCount;
+  this.username = username;
+  this.password = null;
+};
+
+User.findByUsername = function(username) {
+  for(var id in _users) {
+    if (_users[id].username === username) {
+      return _users[id];
+    }
+  }
+  return null;
+};
+
+User.findByToken = function(token) {
+  for(var id in _users) {
+    if (_users[id].token === token) {
+      return _users[id];
+    }
+  }
+  return null;
+};
+
+User.create = function(username, password) {
+  var user = new User(username);
+  user.password = password;
+  user.token = Math.random().toString(36).substr(2);
+  _users[user.id] = user;
+  return user;
+};
+
+User.prototype.authenticate = function(password) {
+  return this.password === password;
+};
+
+// Seed some people
+User.create('bleonard', 'sample');
+User.create('jrlai', 'sample');
+
+
+exports.User = User;

server/package.json

@@ -0,0 +1,18 @@
+{
+  "name": "server",
+  "version": "0.0.1",
+  "private": true,
+  "scripts": {
+    "start": "node --harmony server.js"
+  },
+  "dependencies": {
+    "koa": "^1.0.0",
+    "koa-bodyparser": "^2.0.1",
+    "koa-error": "^1.1.3",
+    "koa-passport": "^1.2.0",
+    "koa-router": "^5.1.2",
+    "passport": "^0.3.0",
+    "passport-http-bearer": "^1.0.1",
+    "password": "^0.1.1"
+  }
+}

server/secured.js

@@ -0,0 +1,31 @@
+var passport = require("koa-passport");
+var BearerStrategy = require('passport-http-bearer').Strategy;
+var User = require("./models").User;
+
+passport.use(new BearerStrategy({},
+  function(token, done) {
+    user = User.findByToken(token);
+    if (user) return done(null, user);
+    else return done(null, false);
+  }
+));
+
+var secured = function *(next) {
+    var _this = this;
+    yield passport.authenticate("bearer", { session: false },
+      function*(err, user, info) {
+        if (err) {
+          throw err;
+        }
+        else if (!user) {
+          _this.status = 401;
+          _this.body = {error: "Please log in"}
+        } 
+        else {
+          _this.passport.user = user;
+          yield next;
+        }
+    });
+};
+
+module.exports = secured;

server/server.js

@@ -0,0 +1,31 @@
+"use strict";
+
+const koa = require("koa");
+const errorHandler = require("koa-error");
+const bodyParser = require("koa-bodyparser");
+const Router = require("koa-router");
+
+const app = module.exports = koa();
+app.use(errorHandler());
+app.use(bodyParser());
+
+var router = new Router();
+
+router.use(function *(next) {
+  // everything json
+  this.type = "json";
+  this.headers['accept'] = "application/json";
+  yield next;
+});
+
+
+var secured = require('./secured')
+var auth    = require("./auth");
+ 
+router.post("/api/signup",  auth.createUser);
+router.post("/api/login",   auth.loginUser);
+router.get ("/api/account", secured, auth.getCurrentUser);
+app.use(router.routes());
+
+app.listen(3000);
+console.log("Server started, listening on port: 3000");