У меня есть простая коллекция пользователей в моем MongoDB. Я пользователь монго-родного драйвера.

{
    "email": "[email protected]",
    "password": "123456",
    "_id": {
        "$oid": "50658c835b821298d3000001"
    }
}

Когда я использую auth через пару email: pass, я переписал по умолчанию функцию passport-local find findByUsername для этого:

function findByEmail(email, fn) {
    db.collection("users", function(err, collection) {
        collection.find({}, {}, function(err, users) {
            users.each(function(err, user) {
                if (user.email === email) {
                    return fn(null, user);
                }
            });
            return fn(null, null);
        });
    });
}

Просто получите всех пользователей из БД и проверьте - если user.email == предоставил адрес электронной почты, то верните объект пользователя.

Я использую параметр _id MongoDB в качестве идентификатора для пользователей, поэтому я изменяю эти две функции:

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

passport.deserializeUser(function(id, done) {
    findById(id, function(err, user) {
        done(err, user);
    });
});

И это мой код для локальной стратегии паспорта:

passport.use(new LocalStrategy( function(email, password, done) {
    process.nextTick(function() {
        console.log('initialize findByEmail() for "',email,'"');
        findByEmail(email, function(err, user) {
            if (err) {
                return done(err);
            }
            if (!user) {
                console.log('Unknown user ' + email)
                return done(null, false, {
                    message: 'Unknown user ' + email

                });
            }
            if (user.password != password) {
                console.log('Invalid password')
                return done(null, false, {
                    message: 'Invalid password'
                });
            }
            //сonsole.log('ALL VERIFIATION PASSED');
            return done(null, user);
        })
    });
}));

Я публикую данные со страницы входа в систему:

app.post('/login', passport.authenticate('local', {
    failureRedirect: '/',
    failureFlash: true
}), function(req, res) {
    res.redirect('/desk');
});

И я получаю

Error: Can't set headers after they are sent.

и после этого я получаю

TypeError: Cannot read property 'email' of null

Последняя ошибка действительно странная, так как findByEmail имеет строку console.log (user) (удалена из этого списка), в которой перечислены все данные пользователя.

Что я делаю неправильно?