// account.js
let redis = require('redis'),
bluebird = require('bluebird');
bluebird.promisifyAll(redis.RedisClient.prototype);
bluebird.promisifyAll(redis.Multi.prototype);
let client = redis.createClient();
exports.findOrCreate = function findOrCreate(userID, provider){
client.getAsync('accounts:' + provider + ':' + userID).then((accountID) => {
if (accountID !== null) {
return client.hgetallAsync('account:' + accountID); // 1
}
})
};// passport.js
let passport = require('passport'),
account = require('./account'),
VKontakteStrategy = require('passport-vkontakte').Strategy;
//...
passport.use(new VKontakteStrategy(config,
verify = (accessToken, refreshToken, params, profile, done) => {
account.findOrCreate(profile.id, profile.provider) // 2
.then((accountInfo) => {
done(null, profile); // done(null, accountInfo);
})
.catch(done);
})
);
exports.findOrCreate = async function findOrCreate(userID, provider){
const accountID = await client.getAsync('accounts:' + provider + ':' + userID);
if (accountID !== null) {
return client.hgetallAsync('account:' + accountID); // 1
}else{
throw 'user not found';
}
};
(async () => {
const promise = findOrCreate(1); //Возвратит promise
const users = await findOrCreate(1); //Возвратит пользователей
const users = await promise; //Возвратит пользователей, аналог предыдущей строчки
})();
exports.findOrCreate = function findOrCreate(userID, provider){
return new Promise(function(resolve, reject) {
client.getAsync('accounts:' + provider + ':' + userID).then((accountID) => {
if (accountID !== null) {
client.hgetallAsync('account:' + accountID).then(resolve, reject);
} else {
reject();
}
}, reject);
});
};
Простой