2017-09-18 19:14:06 +02:00
|
|
|
const db = require('../models');
|
2017-09-17 02:50:22 +02:00
|
|
|
const PassportLocalStrategy = require('passport-local').Strategy;
|
|
|
|
const lbryApi = require('../helpers/lbryApi.js');
|
2017-09-18 19:14:06 +02:00
|
|
|
const logger = require('winston');
|
2017-09-20 03:50:25 +02:00
|
|
|
const config = require('config');
|
2017-09-17 02:50:22 +02:00
|
|
|
|
|
|
|
module.exports = new PassportLocalStrategy(
|
|
|
|
{
|
2017-09-18 19:14:06 +02:00
|
|
|
usernameField : 'username', // sets the custom name of parameters in the POST body message
|
2017-09-17 02:50:22 +02:00
|
|
|
passwordField : 'password', // sets the custom name of parameters in the POST body message
|
|
|
|
session : false, // set to false because we will use token approach to auth
|
|
|
|
passReqToCallback: true, // we want to be able to read the post body message parameters in the callback
|
|
|
|
},
|
|
|
|
(req, username, password, done) => {
|
2017-09-20 03:50:25 +02:00
|
|
|
logger.debug('new channel signup request');
|
|
|
|
const address = config.get('WalletConfig.LbryClaimAddress');
|
2017-09-21 20:00:06 +02:00
|
|
|
let user;
|
|
|
|
// server-side validaton of inputs (username, password)
|
2017-09-20 19:14:00 +02:00
|
|
|
|
2017-09-17 02:50:22 +02:00
|
|
|
// create the channel and retrieve the metadata
|
2017-09-22 01:03:45 +02:00
|
|
|
return lbryApi.createChannel(username, address)
|
2017-09-21 21:05:04 +02:00
|
|
|
.then(tx => {
|
2017-09-21 20:00:06 +02:00
|
|
|
// create user record
|
|
|
|
const userData = {
|
|
|
|
channelName : username,
|
2017-09-21 21:05:04 +02:00
|
|
|
channelClaimId: tx.claim_id,
|
2017-09-21 20:00:06 +02:00
|
|
|
password : password,
|
|
|
|
};
|
|
|
|
logger.debug('userData >', userData);
|
2017-09-20 03:50:25 +02:00
|
|
|
// create certificate record
|
|
|
|
const certificateData = {
|
2017-09-21 21:05:04 +02:00
|
|
|
claimId: tx.claim_id,
|
2017-09-20 03:50:25 +02:00
|
|
|
name : username,
|
2017-09-22 01:03:45 +02:00
|
|
|
// address,
|
2017-09-20 03:50:25 +02:00
|
|
|
};
|
|
|
|
logger.debug('certificateData >', certificateData);
|
2017-09-21 20:00:06 +02:00
|
|
|
// save user and certificate to db
|
|
|
|
return Promise.all([db.User.create(userData), db.Certificate.create(certificateData)]);
|
2017-09-20 03:50:25 +02:00
|
|
|
})
|
2017-09-25 20:55:56 +02:00
|
|
|
.then(([newUser, newCertificate]) => {
|
|
|
|
user = newUser; // save outside scope of this function
|
2017-09-21 20:00:06 +02:00
|
|
|
logger.debug('user and certificate successfully created');
|
2017-09-25 20:55:56 +02:00
|
|
|
logger.debug('user result >', newUser.dataValues);
|
|
|
|
logger.debug('certificate result >', newCertificate.dataValues);
|
2017-09-21 20:00:06 +02:00
|
|
|
// associate the instances
|
2017-09-25 20:55:56 +02:00
|
|
|
return Promise.all([newCertificate.setUser(newUser), newUser.setCertificate(newCertificate)]);
|
2017-09-21 21:05:04 +02:00
|
|
|
}).then(() => {
|
2017-09-21 20:00:06 +02:00
|
|
|
logger.debug('user and certificate successfully associated');
|
2017-09-25 20:55:56 +02:00
|
|
|
logger.debug('user ===', user.dataValues);
|
2017-09-21 09:18:34 +02:00
|
|
|
return done(null, user);
|
2017-09-17 02:50:22 +02:00
|
|
|
})
|
|
|
|
.catch(error => {
|
2017-09-18 19:14:06 +02:00
|
|
|
logger.debug(error);
|
2017-09-17 02:50:22 +02:00
|
|
|
return done(error);
|
|
|
|
});
|
2017-09-18 19:14:06 +02:00
|
|
|
}
|
2017-09-17 02:50:22 +02:00
|
|
|
);
|