Koa, mongoskin, monk, koa-ejs, koa-passport

server.js

var koa = require('koa');
var logger = require('koa-logger');
var path = require('path');

var Router = require('koa-router');

var bodyParser = require('koa-bodyparser');

var render = require('koa-ejs');


var session = require('koa-generic-session');

var passport = require('koa-passport');


var monk = require('monk'); //it's a wrapper for mongoskin :)
var wrap = require('co-monk'); //it's a wrapper for monk :)
var db = monk("mongodb://localhost:27017/todo");

//var db=monk(process.env.MONGOHQ_URL,{w:1});
//for heroku.com enviroment variable.

var busers = db.get('users');

//for passport-local, koa-passport with callbacks hell.
//Here I don't understand how to handle this all about with koa-passport.js
// co? or function *(){yield something??
//But an old good callback, so I feel better :)

var us = wrap(db.get('users'); //for a test in routing system with generators.

        passport.serializeUser(function(user, done) {
            done(null, user._id);
        });

        passport.deserializeUser(function(_id, done) {
            busers.findById(_id, function(err, user) {
                if (err) {
                    return done(err);
                }
                done(null, user);
            });
        });

        var LocalStrategy = require('passport-local').Strategy;

        passport.use(new LocalStrategy(

            function(username, password, done) {

                process.nextTick(function() {

                    busers.findOne({
                        'username': username
                    }, function(err, user) {
                        if (err) {
                            return done(err);
                        }
                        if (!user) {
                            return done(null, false, {
                                message: 'Unknown user ' + username
                            });
                        }
                        if (user.password != password) {
                            return done(null, false, {
                                message: 'Invalid password'
                            });
                        }
                        return done(null, user);

                    });
                });
            }));

        var app = koa()

        ; app.use(session()); app.use(logger()); app.keys = ['your-session-secret-for-Putin-and-Co'];

        app.use(bodyParser());

        app.use(passport.initialize());

        app.use(passport.session());

        app.use(Router(app));

        var locals = {
            version: '0.0.1'
        };

        render(app, {
            root: path.join(__dirname, 'views'),
            layout: 'template',
            viewExt: 'html',
            cache: false,
            debug: true,
            locals: locals,
            filters: 1
        });

        var public = new Router();



        public.get('/', function*() {


            var user = yield us.find({
                'username': 'Bob'
            });
            console.log(user);
            var body = this.req.user;
            yield this.render('login', {
                user: body
            });
        });

        public.post('/login',
            passport.authenticate('local', {

                successRedirect: '/app',
                failureRedirect: '/'
            })
        );



        public.get('/logout', function*(next) {

            this.logout();

            this.redirect('/');

        });

        app.use(public.middleware());

        function* authed(next) {
            if (this.req.isAuthenticated()) {
                yield next;
            } else {
                this.redirect('/');
            }
        }

        var secured = new Router();

        secured.get('/admin', authed, function*() {
            var body = this.req.user.username;
            console.log('this.req.user.username in admin: ' + body);
            yield this.render('app');
        });

        app.use(secured.middleware())

        ;


        app.listen(process.env.PORT || 3000);

        console.log(3000);

        //iojs server