Refactor auth #112
3 changed files with 365 additions and 331 deletions
160
dist/bundle.es.js
vendored
160
dist/bundle.es.js
vendored
|
|
@ -219,7 +219,8 @@ const Lbryio = {
|
|||
CONNECTION_STRING: 'https://api.lbry.com/'
|
||||
};
|
||||
const EXCHANGE_RATE_TIMEOUT = 20 * 60 * 1000;
|
||||
const INTERNAL_APIS_DOWN = 'internal_apis_down'; // We can't use env's because they aren't passed into node_modules
|
||||
const INTERNAL_APIS_DOWN = 'internal_apis_down';
|
||||
Lbryio.fetchingUser = false; // We can't use env's because they aren't passed into node_modules
|
||||
|
||||
Lbryio.setLocalApi = endpoint => {
|
||||
Lbryio.CONNECTION_STRING = endpoint.replace(/\/*$/, '/'); // exactly one slash at the end;
|
||||
|
|
@ -262,11 +263,30 @@ Lbryio.call = (resource, action, params = {}, method = 'get') => {
|
|||
return fetch(url, options).then(checkAndParse);
|
||||
}
|
||||
|
||||
return Lbryio.getAuthToken().then(token => {
|
||||
const fullParams = {
|
||||
auth_token: token,
|
||||
...params
|
||||
return Lbryio.getTokens().then(tokens => {
|
||||
// TOKENS = { auth_token, access_token }
|
||||
const fullParams = { ...params
|
||||
};
|
||||
const headers = {
|
||||
'Content-Type': 'application/x-www-form-urlencoded'
|
||||
}; // TODO refactor this
|
||||
// Send both tokens to userMe
|
||||
// delete auth token after success
|
||||
|
||||
if (action === 'me') {
|
||||
// when we support transition from auth to access, bring this in
|
||||
// if (tokens && tokens.access_token) {
|
||||
// headers.Authorization = `Bearer ${tokens.access_token}`;
|
||||
// }
|
||||
if (tokens && tokens.auth_token) {
|
||||
fullParams.auth_token = tokens.auth_token;
|
||||
}
|
||||
} else if (tokens && tokens.access_token) {
|
||||
headers.Authorization = `Bearer ${tokens.access_token}`;
|
||||
} else {
|
||||
fullParams.auth_token = tokens.auth_token;
|
||||
}
|
||||
|
||||
Object.keys(fullParams).forEach(key => {
|
||||
const value = fullParams[key];
|
||||
|
||||
|
|
@ -295,113 +315,77 @@ Lbryio.call = (resource, action, params = {}, method = 'get') => {
|
|||
});
|
||||
};
|
||||
|
||||
Lbryio.authToken = null;
|
||||
|
||||
Lbryio.getAuthToken = () => new Promise(resolve => {
|
||||
if (Lbryio.authToken) {
|
||||
resolve(Lbryio.authToken);
|
||||
} else if (Lbryio.overrides.getAuthToken) {
|
||||
Lbryio.overrides.getAuthToken().then(token => {
|
||||
resolve(token);
|
||||
});
|
||||
} else if (typeof window !== 'undefined') {
|
||||
const {
|
||||
store
|
||||
} = window;
|
||||
});
|
||||
|
||||
if (store) {
|
||||
const state = store.getState();
|
||||
const token = state.auth ? state.auth.authToken : null;
|
||||
Lbryio.authToken = token;
|
||||
resolve(token);
|
||||
Lbryio.getTokens = () => new Promise(resolve => {
|
||||
Lbryio.overrides.getTokens().then(tokens => {
|
||||
resolve(tokens);
|
||||
});
|
||||
});
|
||||
|
||||
Lbryio.deleteAuthToken = () => new Promise(resolve => {
|
||||
Lbryio.overrides.deleteAuthToken().then(() => {
|
||||
resolve(true);
|
||||
});
|
||||
});
|
||||
|
||||
Lbryio.fetchCurrentUser = () => Lbryio.call('user', 'me').catch(e => ({
|
||||
error: {
|
||||
message: e.message
|
||||
}
|
||||
}));
|
||||
|
||||
resolve(null);
|
||||
Lbryio.fetchUser = async (domain, language) => {
|
||||
if (!Lbryio.fetchingUser) {
|
||||
let user;
|
||||
Lbryio.fetchingUser = true;
|
||||
const tokens = await Lbryio.getTokens(domain, language);
|
||||
|
||||
if (!tokens.auth_token && !tokens.access_token) {
|
||||
user = await Lbryio.fetchNewUser();
|
||||
} else {
|
||||
resolve(null);
|
||||
}
|
||||
});
|
||||
|
||||
Lbryio.getCurrentUser = () => Lbryio.call('user', 'me');
|
||||
|
||||
Lbryio.authenticate = (domain, language) => {
|
||||
if (!Lbryio.enabled) {
|
||||
const params = {
|
||||
id: 1,
|
||||
primary_email: 'disabled@lbry.io',
|
||||
has_verified_email: true,
|
||||
is_identity_verified: true,
|
||||
is_reward_approved: false,
|
||||
language: language || 'en'
|
||||
};
|
||||
return new Promise(resolve => {
|
||||
resolve(params);
|
||||
});
|
||||
user = await Lbryio.fetchCurrentUser();
|
||||
}
|
||||
|
||||
if (Lbryio.authenticationPromise === null) {
|
||||
Lbryio.authenticationPromise = new Promise((resolve, reject) => {
|
||||
Lbryio.getAuthToken().then(token => {
|
||||
if (!token || token.length > 60) {
|
||||
return false;
|
||||
} // check that token works
|
||||
|
||||
|
||||
return Lbryio.getCurrentUser().then(user => user).catch(error => {
|
||||
if (error === INTERNAL_APIS_DOWN) {
|
||||
throw new Error('Internal APIS down');
|
||||
if (tokens.access_token) {
|
||||
if (tokens.auth_token) {
|
||||
await Lbryio.deleteAuthToken();
|
||||
}
|
||||
}
|
||||
|
||||
return false;
|
||||
});
|
||||
}).then(user => {
|
||||
if (user) {
|
||||
return user;
|
||||
}
|
||||
};
|
||||
|
||||
return lbryRedux.Lbry.status().then(status => new Promise((res, rej) => {
|
||||
Lbryio.fetchNewUser = async (domain, language) => {
|
||||
try {
|
||||
const status = await lbryRedux.Lbry.status();
|
||||
const appId = domain && domain !== 'lbry.tv' ? (domain.replace(/[.]/gi, '') + status.installation_id).slice(0, 66) : status.installation_id;
|
||||
Lbryio.call('user', 'new', {
|
||||
const userResponse = await Lbryio.call('user', 'new', {
|
||||
auth_token: '',
|
||||
language: language || 'en',
|
||||
app_id: appId
|
||||
}, 'post').then(response => {
|
||||
if (!response.auth_token) {
|
||||
}, 'post');
|
||||
|
||||
if (!userResponse.auth_token) {
|
||||
throw new Error('auth_token was not set in the response');
|
||||
} else {
|
||||
await Lbryio.overrides.setAuthToken(userResponse.auth_token);
|
||||
}
|
||||
|
||||
const {
|
||||
store
|
||||
} = window;
|
||||
|
||||
if (Lbryio.overrides.setAuthToken) {
|
||||
Lbryio.overrides.setAuthToken(response.auth_token);
|
||||
return userResponse;
|
||||
} catch (e) {
|
||||
console.log('error', e.message);
|
||||
return {
|
||||
error: {
|
||||
message: e.message
|
||||
}
|
||||
|
||||
if (store) {
|
||||
store.dispatch({
|
||||
type: GENERATE_AUTH_TOKEN_SUCCESS,
|
||||
data: {
|
||||
authToken: response.auth_token
|
||||
};
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
Lbryio.authToken = response.auth_token;
|
||||
return res(response);
|
||||
}).catch(error => rej(error));
|
||||
})).then(newUser => {
|
||||
if (!newUser) {
|
||||
return Lbryio.getCurrentUser();
|
||||
}
|
||||
|
||||
return newUser;
|
||||
});
|
||||
}).then(resolve, reject);
|
||||
});
|
||||
}
|
||||
|
||||
return Lbryio.authenticationPromise;
|
||||
};
|
||||
|
||||
Lbryio.getStripeToken = () => Lbryio.CONNECTION_STRING.startsWith('http://localhost:') ? 'pk_test_NoL1JWL7i1ipfhVId5KfDZgo' : 'pk_live_e8M4dRNnCCbmpZzduEUZBgJO';
|
||||
|
|
|
|||
287
dist/bundle.js
vendored
287
dist/bundle.js
vendored
|
|
@ -499,11 +499,14 @@ var REFERRER_NOT_FOUND = 'A lbry.tv account could not be found for the referrer
|
|||
|
||||
"use strict";
|
||||
__webpack_require__.r(__webpack_exports__);
|
||||
/* harmony import */ var constants_action_types__WEBPACK_IMPORTED_MODULE_0__ = __webpack_require__(1);
|
||||
/* harmony import */ var lbry_redux__WEBPACK_IMPORTED_MODULE_1__ = __webpack_require__(5);
|
||||
/* harmony import */ var lbry_redux__WEBPACK_IMPORTED_MODULE_1___default = /*#__PURE__*/__webpack_require__.n(lbry_redux__WEBPACK_IMPORTED_MODULE_1__);
|
||||
/* harmony import */ var querystring__WEBPACK_IMPORTED_MODULE_2__ = __webpack_require__(6);
|
||||
/* harmony import */ var querystring__WEBPACK_IMPORTED_MODULE_2___default = /*#__PURE__*/__webpack_require__.n(querystring__WEBPACK_IMPORTED_MODULE_2__);
|
||||
/* harmony import */ var lbry_redux__WEBPACK_IMPORTED_MODULE_0__ = __webpack_require__(5);
|
||||
/* harmony import */ var lbry_redux__WEBPACK_IMPORTED_MODULE_0___default = /*#__PURE__*/__webpack_require__.n(lbry_redux__WEBPACK_IMPORTED_MODULE_0__);
|
||||
/* harmony import */ var querystring__WEBPACK_IMPORTED_MODULE_1__ = __webpack_require__(6);
|
||||
/* harmony import */ var querystring__WEBPACK_IMPORTED_MODULE_1___default = /*#__PURE__*/__webpack_require__.n(querystring__WEBPACK_IMPORTED_MODULE_1__);
|
||||
function asyncGeneratorStep(gen, resolve, reject, _next, _throw, key, arg) { try { var info = gen[key](arg); var value = info.value; } catch (error) { reject(error); return; } if (info.done) { resolve(value); } else { Promise.resolve(value).then(_next, _throw); } }
|
||||
|
||||
function _asyncToGenerator(fn) { return function () { var self = this, args = arguments; return new Promise(function (resolve, reject) { var gen = fn.apply(self, args); function _next(value) { asyncGeneratorStep(gen, resolve, reject, _next, _throw, "next", value); } function _throw(err) { asyncGeneratorStep(gen, resolve, reject, _next, _throw, "throw", err); } _next(undefined); }); }; }
|
||||
|
||||
function _typeof(obj) { if (typeof Symbol === "function" && typeof Symbol.iterator === "symbol") { _typeof = function _typeof(obj) { return typeof obj; }; } else { _typeof = function _typeof(obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; }; } return _typeof(obj); }
|
||||
|
||||
function _objectSpread(target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i] != null ? arguments[i] : {}; var ownKeys = Object.keys(source); if (typeof Object.getOwnPropertySymbols === 'function') { ownKeys = ownKeys.concat(Object.getOwnPropertySymbols(source).filter(function (sym) { return Object.getOwnPropertyDescriptor(source, sym).enumerable; })); } ownKeys.forEach(function (key) { _defineProperty(target, key, source[key]); }); } return target; }
|
||||
|
|
@ -512,7 +515,6 @@ function _defineProperty(obj, key, value) { if (key in obj) { Object.definePrope
|
|||
|
||||
|
||||
|
||||
|
||||
var Lbryio = {
|
||||
enabled: true,
|
||||
authenticationPromise: null,
|
||||
|
|
@ -521,7 +523,8 @@ var Lbryio = {
|
|||
CONNECTION_STRING: 'https://api.lbry.com/'
|
||||
};
|
||||
var EXCHANGE_RATE_TIMEOUT = 20 * 60 * 1000;
|
||||
var INTERNAL_APIS_DOWN = 'internal_apis_down'; // We can't use env's because they aren't passed into node_modules
|
||||
var INTERNAL_APIS_DOWN = 'internal_apis_down';
|
||||
Lbryio.fetchingUser = false; // We can't use env's because they aren't passed into node_modules
|
||||
|
||||
Lbryio.setLocalApi = function (endpoint) {
|
||||
Lbryio.CONNECTION_STRING = endpoint.replace(/\/*$/, '/'); // exactly one slash at the end;
|
||||
|
|
@ -567,10 +570,29 @@ Lbryio.call = function (resource, action) {
|
|||
return fetch(url, options).then(checkAndParse);
|
||||
}
|
||||
|
||||
return Lbryio.getAuthToken().then(function (token) {
|
||||
var fullParams = _objectSpread({
|
||||
auth_token: token
|
||||
}, params);
|
||||
return Lbryio.getTokens().then(function (tokens) {
|
||||
// TOKENS = { auth_token, access_token }
|
||||
var fullParams = _objectSpread({}, params);
|
||||
|
||||
var headers = {
|
||||
'Content-Type': 'application/x-www-form-urlencoded'
|
||||
}; // TODO refactor this
|
||||
// Send both tokens to userMe
|
||||
// delete auth token after success
|
||||
|
||||
if (action === 'me') {
|
||||
// when we support transition from auth to access, bring this in
|
||||
// if (tokens && tokens.access_token) {
|
||||
// headers.Authorization = `Bearer ${tokens.access_token}`;
|
||||
// }
|
||||
if (tokens && tokens.auth_token) {
|
||||
fullParams.auth_token = tokens.auth_token;
|
||||
}
|
||||
} else if (tokens && tokens.access_token) {
|
||||
headers.Authorization = "Bearer ".concat(tokens.access_token);
|
||||
} else {
|
||||
fullParams.auth_token = tokens.auth_token;
|
||||
}
|
||||
|
||||
Object.keys(fullParams).forEach(function (key) {
|
||||
var value = fullParams[key];
|
||||
|
|
@ -579,7 +601,7 @@ Lbryio.call = function (resource, action) {
|
|||
fullParams[key] = JSON.stringify(value);
|
||||
}
|
||||
});
|
||||
var qs = querystring__WEBPACK_IMPORTED_MODULE_2___default.a.stringify(fullParams);
|
||||
var qs = querystring__WEBPACK_IMPORTED_MODULE_1___default.a.stringify(fullParams);
|
||||
var url = "".concat(Lbryio.CONNECTION_STRING).concat(resource, "/").concat(action, "?").concat(qs);
|
||||
var options = {
|
||||
method: 'GET'
|
||||
|
|
@ -602,122 +624,177 @@ Lbryio.call = function (resource, action) {
|
|||
});
|
||||
};
|
||||
|
||||
Lbryio.authToken = null;
|
||||
|
||||
Lbryio.getAuthToken = function () {
|
||||
return new Promise(function (resolve) {
|
||||
if (Lbryio.authToken) {
|
||||
resolve(Lbryio.authToken);
|
||||
} else if (Lbryio.overrides.getAuthToken) {
|
||||
Lbryio.overrides.getAuthToken().then(function (token) {
|
||||
resolve(token);
|
||||
});
|
||||
} else if (typeof window !== 'undefined') {
|
||||
var _window = window,
|
||||
store = _window.store;
|
||||
|
||||
if (store) {
|
||||
var state = store.getState();
|
||||
var token = state.auth ? state.auth.authToken : null;
|
||||
Lbryio.authToken = token;
|
||||
resolve(token);
|
||||
}
|
||||
|
||||
resolve(null);
|
||||
} else {
|
||||
resolve(null);
|
||||
}
|
||||
});
|
||||
};
|
||||
|
||||
Lbryio.getCurrentUser = function () {
|
||||
return Lbryio.call('user', 'me');
|
||||
};
|
||||
|
||||
Lbryio.authenticate = function (domain, language) {
|
||||
if (!Lbryio.enabled) {
|
||||
var params = {
|
||||
id: 1,
|
||||
primary_email: 'disabled@lbry.io',
|
||||
has_verified_email: true,
|
||||
is_identity_verified: true,
|
||||
is_reward_approved: false,
|
||||
language: language || 'en'
|
||||
};
|
||||
Lbryio.getTokens = function () {
|
||||
return new Promise(function (resolve) {
|
||||
resolve(params);
|
||||
Lbryio.overrides.getTokens().then(function (tokens) {
|
||||
resolve(tokens);
|
||||
});
|
||||
}
|
||||
|
||||
if (Lbryio.authenticationPromise === null) {
|
||||
Lbryio.authenticationPromise = new Promise(function (resolve, reject) {
|
||||
Lbryio.getAuthToken().then(function (token) {
|
||||
if (!token || token.length > 60) {
|
||||
return false;
|
||||
} // check that token works
|
||||
|
||||
|
||||
return Lbryio.getCurrentUser().then(function (user) {
|
||||
return user;
|
||||
})["catch"](function (error) {
|
||||
if (error === INTERNAL_APIS_DOWN) {
|
||||
throw new Error('Internal APIS down');
|
||||
}
|
||||
|
||||
return false;
|
||||
});
|
||||
}).then(function (user) {
|
||||
if (user) {
|
||||
return user;
|
||||
};
|
||||
|
||||
Lbryio.deleteAuthToken = function () {
|
||||
return new Promise(function (resolve) {
|
||||
Lbryio.overrides.deleteAuthToken().then(function () {
|
||||
resolve(true);
|
||||
});
|
||||
});
|
||||
};
|
||||
|
||||
Lbryio.fetchCurrentUser = function () {
|
||||
return Lbryio.call('user', 'me')["catch"](function (e) {
|
||||
return {
|
||||
error: {
|
||||
message: e.message
|
||||
}
|
||||
};
|
||||
});
|
||||
};
|
||||
|
||||
Lbryio.fetchUser =
|
||||
/*#__PURE__*/
|
||||
function () {
|
||||
var _ref = _asyncToGenerator(
|
||||
/*#__PURE__*/
|
||||
regeneratorRuntime.mark(function _callee(domain, language) {
|
||||
var user, tokens;
|
||||
return regeneratorRuntime.wrap(function _callee$(_context) {
|
||||
while (1) {
|
||||
switch (_context.prev = _context.next) {
|
||||
case 0:
|
||||
if (Lbryio.fetchingUser) {
|
||||
_context.next = 19;
|
||||
break;
|
||||
}
|
||||
|
||||
return lbry_redux__WEBPACK_IMPORTED_MODULE_1__["Lbry"].status().then(function (status) {
|
||||
return new Promise(function (res, rej) {
|
||||
var appId = domain && domain !== 'lbry.tv' ? (domain.replace(/[.]/gi, '') + status.installation_id).slice(0, 66) : status.installation_id;
|
||||
Lbryio.call('user', 'new', {
|
||||
Lbryio.fetchingUser = true;
|
||||
_context.next = 4;
|
||||
return Lbryio.getTokens(domain, language);
|
||||
|
||||
case 4:
|
||||
tokens = _context.sent;
|
||||
|
||||
if (!(!tokens.auth_token && !tokens.access_token)) {
|
||||
_context.next = 11;
|
||||
break;
|
||||
}
|
||||
|
||||
_context.next = 8;
|
||||
return Lbryio.fetchNewUser();
|
||||
|
||||
case 8:
|
||||
user = _context.sent;
|
||||
_context.next = 14;
|
||||
break;
|
||||
|
||||
case 11:
|
||||
_context.next = 13;
|
||||
return Lbryio.fetchCurrentUser();
|
||||
|
||||
case 13:
|
||||
user = _context.sent;
|
||||
|
||||
case 14:
|
||||
if (!tokens.access_token) {
|
||||
_context.next = 18;
|
||||
break;
|
||||
}
|
||||
|
||||
if (!tokens.auth_token) {
|
||||
_context.next = 18;
|
||||
break;
|
||||
}
|
||||
|
||||
_context.next = 18;
|
||||
return Lbryio.deleteAuthToken();
|
||||
|
||||
case 18:
|
||||
return _context.abrupt("return", user);
|
||||
|
||||
case 19:
|
||||
case "end":
|
||||
return _context.stop();
|
||||
}
|
||||
}
|
||||
}, _callee);
|
||||
}));
|
||||
|
||||
return function (_x, _x2) {
|
||||
return _ref.apply(this, arguments);
|
||||
};
|
||||
}();
|
||||
|
||||
Lbryio.fetchNewUser =
|
||||
/*#__PURE__*/
|
||||
function () {
|
||||
var _ref2 = _asyncToGenerator(
|
||||
/*#__PURE__*/
|
||||
regeneratorRuntime.mark(function _callee2(domain, language) {
|
||||
var status, appId, userResponse;
|
||||
return regeneratorRuntime.wrap(function _callee2$(_context2) {
|
||||
while (1) {
|
||||
switch (_context2.prev = _context2.next) {
|
||||
case 0:
|
||||
_context2.prev = 0;
|
||||
_context2.next = 3;
|
||||
return lbry_redux__WEBPACK_IMPORTED_MODULE_0__["Lbry"].status();
|
||||
|
||||
case 3:
|
||||
status = _context2.sent;
|
||||
appId = domain && domain !== 'lbry.tv' ? (domain.replace(/[.]/gi, '') + status.installation_id).slice(0, 66) : status.installation_id;
|
||||
_context2.next = 7;
|
||||
return Lbryio.call('user', 'new', {
|
||||
auth_token: '',
|
||||
language: language || 'en',
|
||||
app_id: appId
|
||||
}, 'post').then(function (response) {
|
||||
if (!response.auth_token) {
|
||||
}, 'post');
|
||||
|
||||
case 7:
|
||||
userResponse = _context2.sent;
|
||||
|
||||
if (userResponse.auth_token) {
|
||||
_context2.next = 12;
|
||||
break;
|
||||
}
|
||||
|
||||
throw new Error('auth_token was not set in the response');
|
||||
}
|
||||
|
||||
var _window2 = window,
|
||||
store = _window2.store;
|
||||
case 12:
|
||||
_context2.next = 14;
|
||||
return Lbryio.overrides.setAuthToken(userResponse.auth_token);
|
||||
|
||||
if (Lbryio.overrides.setAuthToken) {
|
||||
Lbryio.overrides.setAuthToken(response.auth_token);
|
||||
}
|
||||
case 14:
|
||||
return _context2.abrupt("return", userResponse);
|
||||
|
||||
if (store) {
|
||||
store.dispatch({
|
||||
type: constants_action_types__WEBPACK_IMPORTED_MODULE_0__["GENERATE_AUTH_TOKEN_SUCCESS"],
|
||||
data: {
|
||||
authToken: response.auth_token
|
||||
case 17:
|
||||
_context2.prev = 17;
|
||||
_context2.t0 = _context2["catch"](0);
|
||||
console.log('error', _context2.t0.message);
|
||||
return _context2.abrupt("return", {
|
||||
error: {
|
||||
message: _context2.t0.message
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
Lbryio.authToken = response.auth_token;
|
||||
return res(response);
|
||||
})["catch"](function (error) {
|
||||
return rej(error);
|
||||
});
|
||||
});
|
||||
}).then(function (newUser) {
|
||||
if (!newUser) {
|
||||
return Lbryio.getCurrentUser();
|
||||
case 21:
|
||||
case "end":
|
||||
return _context2.stop();
|
||||
}
|
||||
|
||||
return newUser;
|
||||
});
|
||||
}).then(resolve, reject);
|
||||
});
|
||||
}
|
||||
}, _callee2, null, [[0, 17]]);
|
||||
}));
|
||||
|
||||
return Lbryio.authenticationPromise;
|
||||
return function (_x3, _x4) {
|
||||
return _ref2.apply(this, arguments);
|
||||
};
|
||||
}();
|
||||
|
||||
Lbryio.getStripeToken = function () {
|
||||
return Lbryio.CONNECTION_STRING.startsWith('http://localhost:') ? 'pk_test_NoL1JWL7i1ipfhVId5KfDZgo' : 'pk_live_e8M4dRNnCCbmpZzduEUZBgJO';
|
||||
|
|
@ -726,10 +803,10 @@ Lbryio.getStripeToken = function () {
|
|||
Lbryio.getExchangeRates = function () {
|
||||
if (!Lbryio.exchangeLastFetched || Date.now() - Lbryio.exchangeLastFetched > EXCHANGE_RATE_TIMEOUT) {
|
||||
Lbryio.exchangePromise = new Promise(function (resolve, reject) {
|
||||
Lbryio.call('lbc', 'exchange_rate', {}, 'get', true).then(function (_ref) {
|
||||
var LBC_USD = _ref.lbc_usd,
|
||||
LBC_BTC = _ref.lbc_btc,
|
||||
BTC_USD = _ref.btc_usd;
|
||||
Lbryio.call('lbc', 'exchange_rate', {}, 'get', true).then(function (_ref3) {
|
||||
var LBC_USD = _ref3.lbc_usd,
|
||||
LBC_BTC = _ref3.lbc_btc,
|
||||
BTC_USD = _ref3.btc_usd;
|
||||
var rates = {
|
||||
LBC_USD: LBC_USD,
|
||||
LBC_BTC: LBC_BTC,
|
||||
|
|
|
|||
161
src/lbryio.js
161
src/lbryio.js
|
|
@ -1,4 +1,3 @@
|
|||
import * as ACTIONS from 'constants/action_types';
|
||||
import { Lbry } from 'lbry-redux';
|
||||
import querystring from 'querystring';
|
||||
|
||||
|
|
@ -13,6 +12,7 @@ const Lbryio = {
|
|||
const EXCHANGE_RATE_TIMEOUT = 20 * 60 * 1000;
|
||||
const INTERNAL_APIS_DOWN = 'internal_apis_down';
|
||||
|
||||
Lbryio.fetchingUser = false;
|
||||
// We can't use env's because they aren't passed into node_modules
|
||||
Lbryio.setLocalApi = endpoint => {
|
||||
Lbryio.CONNECTION_STRING = endpoint.replace(/\/*$/, '/'); // exactly one slash at the end;
|
||||
|
|
@ -53,8 +53,30 @@ Lbryio.call = (resource, action, params = {}, method = 'get') => {
|
|||
return fetch(url, options).then(checkAndParse);
|
||||
}
|
||||
|
||||
return Lbryio.getAuthToken().then(token => {
|
||||
const fullParams = { auth_token: token, ...params };
|
||||
return Lbryio.getTokens().then(tokens => {
|
||||
// TOKENS = { auth_token, access_token }
|
||||
const fullParams = { ...params };
|
||||
const headers = {
|
||||
'Content-Type': 'application/x-www-form-urlencoded',
|
||||
};
|
||||
|
||||
// TODO refactor this
|
||||
// Send both tokens to userMe
|
||||
// delete auth token after success
|
||||
if (action === 'me') {
|
||||
// when we support transition from auth to access, bring this in
|
||||
// if (tokens && tokens.access_token) {
|
||||
// headers.Authorization = `Bearer ${tokens.access_token}`;
|
||||
// }
|
||||
if (tokens && tokens.auth_token) {
|
||||
fullParams.auth_token = tokens.auth_token;
|
||||
}
|
||||
} else if (tokens && tokens.access_token) {
|
||||
headers.Authorization = `Bearer ${tokens.access_token}`;
|
||||
} else {
|
||||
fullParams.auth_token = tokens.auth_token;
|
||||
}
|
||||
|
||||
Object.keys(fullParams).forEach(key => {
|
||||
const value = fullParams[key];
|
||||
if (typeof value === 'object') {
|
||||
|
|
@ -84,82 +106,57 @@ Lbryio.call = (resource, action, params = {}, method = 'get') => {
|
|||
});
|
||||
};
|
||||
|
||||
Lbryio.authToken = null;
|
||||
|
||||
Lbryio.getAuthToken = () =>
|
||||
new Promise(resolve => {
|
||||
if (Lbryio.authToken) {
|
||||
resolve(Lbryio.authToken);
|
||||
} else if (Lbryio.overrides.getAuthToken) {
|
||||
Lbryio.overrides.getAuthToken().then(token => {
|
||||
resolve(token);
|
||||
});
|
||||
} else if (typeof window !== 'undefined') {
|
||||
const { store } = window;
|
||||
if (store) {
|
||||
const state = store.getState();
|
||||
const token = state.auth ? state.auth.authToken : null;
|
||||
Lbryio.authToken = token;
|
||||
resolve(token);
|
||||
}
|
||||
});
|
||||
|
||||
resolve(null);
|
||||
Lbryio.getTokens = () =>
|
||||
new Promise(resolve => {
|
||||
Lbryio.overrides.getTokens().then(tokens => {
|
||||
resolve(tokens);
|
||||
});
|
||||
});
|
||||
|
||||
Lbryio.deleteAuthToken = () =>
|
||||
new Promise(resolve => {
|
||||
Lbryio.overrides.deleteAuthToken().then(() => {
|
||||
resolve(true);
|
||||
});
|
||||
});
|
||||
|
||||
Lbryio.fetchCurrentUser = () =>
|
||||
Lbryio.call('user', 'me').catch(e => ({ error: { message: e.message } }));
|
||||
|
||||
Lbryio.fetchUser = async (domain, language) => {
|
||||
if (!Lbryio.fetchingUser) {
|
||||
let user;
|
||||
Lbryio.fetchingUser = true;
|
||||
const tokens = await Lbryio.getTokens(domain, language);
|
||||
if (!tokens.auth_token && !tokens.access_token) {
|
||||
user = await Lbryio.fetchNewUser();
|
||||
} else {
|
||||
resolve(null);
|
||||
user = await Lbryio.fetchCurrentUser();
|
||||
}
|
||||
});
|
||||
|
||||
Lbryio.getCurrentUser = () => Lbryio.call('user', 'me');
|
||||
|
||||
Lbryio.authenticate = (domain, language) => {
|
||||
if (!Lbryio.enabled) {
|
||||
const params = {
|
||||
id: 1,
|
||||
primary_email: 'disabled@lbry.io',
|
||||
has_verified_email: true,
|
||||
is_identity_verified: true,
|
||||
is_reward_approved: false,
|
||||
language: language || 'en',
|
||||
};
|
||||
|
||||
return new Promise(resolve => {
|
||||
resolve(params);
|
||||
});
|
||||
if (tokens.access_token) {
|
||||
if (tokens.auth_token) {
|
||||
await Lbryio.deleteAuthToken();
|
||||
}
|
||||
|
||||
if (Lbryio.authenticationPromise === null) {
|
||||
Lbryio.authenticationPromise = new Promise((resolve, reject) => {
|
||||
Lbryio.getAuthToken()
|
||||
.then(token => {
|
||||
if (!token || token.length > 60) {
|
||||
return false;
|
||||
}
|
||||
|
||||
// check that token works
|
||||
return Lbryio.getCurrentUser()
|
||||
.then(user => user)
|
||||
.catch(error => {
|
||||
if (error === INTERNAL_APIS_DOWN) {
|
||||
throw new Error('Internal APIS down');
|
||||
}
|
||||
|
||||
return false;
|
||||
});
|
||||
})
|
||||
.then(user => {
|
||||
if (user) {
|
||||
return user;
|
||||
}
|
||||
};
|
||||
|
||||
return Lbry.status()
|
||||
.then(
|
||||
status =>
|
||||
new Promise((res, rej) => {
|
||||
Lbryio.fetchNewUser = async (domain, language) => {
|
||||
try {
|
||||
const status = await Lbry.status();
|
||||
const appId =
|
||||
domain && domain !== 'lbry.tv'
|
||||
? (domain.replace(/[.]/gi, '') + status.installation_id).slice(0, 66)
|
||||
: status.installation_id;
|
||||
Lbryio.call(
|
||||
const userResponse = await Lbryio.call(
|
||||
'user',
|
||||
'new',
|
||||
{
|
||||
|
|
@ -168,41 +165,17 @@ Lbryio.authenticate = (domain, language) => {
|
|||
app_id: appId,
|
||||
},
|
||||
'post'
|
||||
)
|
||||
.then(response => {
|
||||
if (!response.auth_token) {
|
||||
);
|
||||
if (!userResponse.auth_token) {
|
||||
throw new Error('auth_token was not set in the response');
|
||||
} else {
|
||||
await Lbryio.overrides.setAuthToken(userResponse.auth_token);
|
||||
}
|
||||
|
||||
const { store } = window;
|
||||
if (Lbryio.overrides.setAuthToken) {
|
||||
Lbryio.overrides.setAuthToken(response.auth_token);
|
||||
return userResponse;
|
||||
} catch (e) {
|
||||
console.log('error', e.message);
|
||||
return { error: { message: e.message } };
|
||||
}
|
||||
|
||||
if (store) {
|
||||
store.dispatch({
|
||||
type: ACTIONS.GENERATE_AUTH_TOKEN_SUCCESS,
|
||||
data: { authToken: response.auth_token },
|
||||
});
|
||||
}
|
||||
Lbryio.authToken = response.auth_token;
|
||||
return res(response);
|
||||
})
|
||||
.catch(error => rej(error));
|
||||
})
|
||||
)
|
||||
.then(newUser => {
|
||||
if (!newUser) {
|
||||
return Lbryio.getCurrentUser();
|
||||
}
|
||||
return newUser;
|
||||
});
|
||||
})
|
||||
.then(resolve, reject);
|
||||
});
|
||||
}
|
||||
|
||||
return Lbryio.authenticationPromise;
|
||||
};
|
||||
|
||||
Lbryio.getStripeToken = () =>
|
||||
|
|
|
|||
Loading…
Reference in a new issue