Нодейс + Паспорт + MySQL

Question

Я пытаюсь понять, как использовать nodejs + Passport + MySQL. Кажется, что почти каждый учебник использует mongoDB, и я не хочу этого делать. Фактически, некоторые быстрые поиски этого типа приведут к веб-страницам, таким как ( http://nodejsrocks.blogspot.com/2012/04/nodejs-expressjs-mysql.html) и видео на YouTube, которое является парнем ( https://www.youtube.com/watch?v=jGBbMVJx3h0) ничего не делая, кроме входа в систему, и кто знает, что он на самом деле использует, но на странице было 3K + просмотров. Я надеюсь, что некоторые разработчики посмотрит на это и скажут, что, возможно, в MySQL есть что-то вроде всеобъемлющего, не MVC-типа. Моя причина в том, что я пытаюсь использовать только возможности iOS и Android, и мне не нужны большие затраты на строительные леса. Только сценарии на стороне БД и на сервере, обрабатывающие запросы и возвращающие объекты JSON на телефоны.

Так что, как говорится, может кто-то, кто имел реальный опыт в этом, пожалуйста, помогите мне (и остальной мир пытается делать подобные вещи без каких-либо подробных уроков, потому что мы не используем mongoDB и полнофункциональные леса),

Таблицы, которые я настроил для TwitterStrategy, - это пользователи (id (PK), имя пользователя, электронная почта, соль, пароль) и twitterusers(id (PK), имя, имя экрана, местоположение, описание, url, img, token, tokensecret).

Вот код, который я пытаюсь получить из одного файла main.js. Я знаю, что это не лучшие практики, и я планирую почистить это позже, но сейчас я хотел бы понять, чего мне не хватает, и заставить вещи работать. Было бы очень признательно, если кто-то может помочь, и я уверен, что другие тоже сочтут это очень полезным. Благодарю.

var http  = require('http'),
    mysql = require('mysql'),
    url   = require('url'),
    crypto = require('crypto'),
    express = require('express'),
    flash = require('connect-flash'),
    passport = require('passport'),
    TwitterStrategy = require('passport-twitter').Strategy;

var db = mysql.createConnection({
    host     : "****",
    user     : "****",
    password : "****",
    port     : '****',
    database : '****' 
});

// Connect the connection to DB and throw error if exists
db.connect(function(err) {
    if (err) { 
        console.error('Error connecting to db');
        console.error(err);
        return;
    }
    console.log('Database connected');
});

var TWITTER_CONSUMER_KEY = "****";
var TWITTER_CONSUMER_SECRET = "****";

passport.use(new TwitterStrategy({
    consumerKey: TWITTER_CONSUMER_KEY,
    consumerSecret: TWITTER_CONSUMER_SECRET,
    callbackURL: 'http://127.0.0.1:3000/auth/twitter/callback'},
    function(accessToken, refreshToken, profile, done) {
        //db.query(SELECT ........ FROM ...... WHERE ........, function (err, user){
            if (err) {
                console.log(err);
            }
            if (!err && user != null){
                done(null, result);
            } else {
                console.log(result);
            }
        })
        });
    }
));

passport.serializeUser(function(user, done) {
    console.log('serializeUser: ' + user.id);
    done(null, user.id);
});

passport.deserializeUser(function(id, done) {
    db.query('SELECT * FROM users WHERE id = ' + id, function(err, result) {
        if (err){
            console.log(err);
        } else {
        console.log(result);
        }
        if (!err) {
            done(null, result);
        } else {
            done(err, null);
        }
    });
});

var app = express();

app.set(function(){

    // app.set('views', __dirname + '/views'); // Definitely for some views which aren't being used here
    // app.set('view engine', 'jade'); // Using jade for views, not used
    // app.use(express.favicon()); // Not really sure this is important, should be web only
    app.use(express.logger('dev')); // Again, not really sure this is important
    app.use(express.bodyParser()); // Have no idea what this is used for
    app.use(express.methodOverride()); // Same no Fn clue
    app.use(express.cookieParser('what the F'));
    app.use(express.session());
    app.use(passport.initialize());
    app.use(passport.session());
    app.use(flash());
    // app.use(app.router); // Here again we are defining our routes in main, so shouldn't need this.
    // app.use(express.static(__dirname + '/public'));

});

var server = http.createServer(function(req, res) {
    console.log('url: ' + req.url); 

    var params = url.parse(req.url, true)
    var path = params.pathname;
    if (path == '/signup') {
        console.log("User signing up");
        onSignUp(params, res);
    } else if (path == '/signin') {
        console.log("User signing in");
        onSignIn(params, res);
    } else if (path == '/auth/twitter'){
        passport.authenticate('twitter'),
        function(req, res){
            console.log('Twitter User Created or Signed In');
        }
    }
});

//Keep server alive and listening to requests with DB connected also
server.listen(3000);

Я пропускаю другую таблицу аутентификации? Что нужно добавить в оператор MySQL, где точки, чтобы я мог найти пользователя, и какие параметры передаются из пользовательского запроса для запуска запроса, т.е. что это за идентификатор oauth, который я видел в учебники, которые передаются от того, что кажется пользователю в твиттер для авторизации? Кроме того, что я должен ожидать от этого обратного вызова из Twitter? В любом случае, я буду рад опубликовать все это где-нибудь, чтобы все могли посмотреть сразу. У меня есть решение, которое позволяет всем нам, использующим MySQL и ноду, не остаться в стороне и искать в Google, чтобы найти что-то, что кажется как будто он должен быть легко доступен, вместо копий одного и того же точного nodejs + mongoDB + express tutorial (со многими устаревшими, за исключением scotch io, который выглядит очень хорошо, если вы хотите использовать mongo... могу я добавить экземпляры в Amazon стоят около 279 долларов в месяц (по нижнему пределу), который плавает вокруг и перераспределяется практически всеми, у кого есть "учебник". Еще раз спасибо.

Answer 1

Попробуйте обернуть стратегию под process.nextTickнапример,

passport.use(new TwitterStrategy({
    consumerKey: TWITTER_CONSUMER_KEY,
    consumerSecret: TWITTER_CONSUMER_SECRET,
    callbackURL: 'http://127.0.0.1:3000/auth/twitter/callback'},
    function(accessToken, refreshToken, profile, done) {
        process.nextTick(function(){
        // this is where you put logic to check the profile sent from twitter already in your DB or not, 
        // its totally up to you whether you keep a separate auth table for it or not
        // NB: there will be some unique value in profile that can be used for next references
        db.query(SELECT ........ FROM ...... WHERE ........, function (err, user){
            if (err) {
                console.log(err);
            }
            if (!err && user != null){
                done(null, result);
            } else {
                console.log(result);
            }
        })
        });
       });
    }
));

Вы также должны иметь маршрут для принятия обратного вызова, например,

app.get('/auth/twitter/callback', function(req, res, next) {
   passport.authenticate('twitter', 
                           { }, 
                           function(err, user) {
                            // the result you send from the strategy function will be here
                            // do anything you like with the user send 
                           }

                         )(req, res, next);
});

Надеюсь, это прояснит ситуацию.