add comments and begin stripe integration

This commit is contained in:
Anthony 2021-06-12 21:16:34 +02:00
parent 8f9a58bfc8
commit 76e79886b2
No known key found for this signature in database
GPG key ID: C386D3C93D50E356

View file

@ -10,6 +10,7 @@ const Lbryio = {
CONNECTION_STRING: 'https://api.lbry.com/', CONNECTION_STRING: 'https://api.lbry.com/',
}; };
// 20 minute exchange rate timeout
const EXCHANGE_RATE_TIMEOUT = 20 * 60 * 1000; const EXCHANGE_RATE_TIMEOUT = 20 * 60 * 1000;
const INTERNAL_APIS_DOWN = 'internal_apis_down'; const INTERNAL_APIS_DOWN = 'internal_apis_down';
@ -18,16 +19,7 @@ Lbryio.setLocalApi = endpoint => {
Lbryio.CONNECTION_STRING = endpoint.replace(/\/*$/, '/'); // exactly one slash at the end; Lbryio.CONNECTION_STRING = endpoint.replace(/\/*$/, '/'); // exactly one slash at the end;
}; };
Lbryio.call = (resource, action, params = {}, method = 'get') => { function checkAndParse(response) {
if (!Lbryio.enabled) {
return Promise.reject(new Error(__('LBRY internal API is disabled')));
}
if (!(method === 'get' || method === 'post')) {
return Promise.reject(new Error(__('Invalid method')));
}
function checkAndParse(response) {
if (response.status >= 200 && response.status < 300) { if (response.status >= 200 && response.status < 300) {
return response.json(); return response.json();
} }
@ -47,14 +39,37 @@ Lbryio.call = (resource, action, params = {}, method = 'get') => {
error.response = response; // This is primarily a hack used in actions/user.js error.response = response; // This is primarily a hack used in actions/user.js
return Promise.reject(error); return Promise.reject(error);
}); });
} }
function makeRequest(url, options) { function makeRequest(url, options) {
return fetch(url, options).then(checkAndParse); return fetch(url, options).then(checkAndParse);
}
/**
* Call a Lbry API method
*
* @param {string} resource - resource value (me/lbc/customer/account/etc.)
* @param {string} action - the subresource (aka for customer: status/link)
* @param {object || string} params - used to build querystring for fetch (default {})
* @param {string} method - 'get' or 'post' (default - get)
* @returns {string} returns response.data returned by the API
*/
Lbryio.call = (resource, action, params = {}, method = 'get') => {
// reject promise if API disabled
if (!Lbryio.enabled) {
return Promise.reject(new Error(__('LBRY internal API is disabled')));
} }
// only allow get or post requests
if (!(method === 'get' || method === 'post')) {
return Promise.reject(new Error(__('Invalid method')));
}
// get auth token and build request to be called via fetch
return Lbryio.getAuthToken().then(token => { return Lbryio.getAuthToken().then(token => {
// add auth token to params
const fullParams = { auth_token: token, ...params }; const fullParams = { auth_token: token, ...params };
// stringify param values
Object.keys(fullParams).forEach(key => { Object.keys(fullParams).forEach(key => {
const value = fullParams[key]; const value = fullParams[key];
if (typeof value === 'object') { if (typeof value === 'object') {
@ -62,16 +77,21 @@ Lbryio.call = (resource, action, params = {}, method = 'get') => {
} }
}); });
// build querystring for fetch
const qs = querystring.stringify(fullParams); const qs = querystring.stringify(fullParams);
// build url for fetch
let url = `${Lbryio.CONNECTION_STRING}${resource}/${action}?${qs}`; let url = `${Lbryio.CONNECTION_STRING}${resource}/${action}?${qs}`;
// set method to GET (changed to POST if applicable later)
let options = { let options = {
method: 'GET', method: 'GET',
}; };
// build post request for fetch
if (method === 'post') { if (method === 'post') {
options = { options = {
method: 'POST', method: 'POST',
// send as a form encoded url with query string
headers: { headers: {
'Content-Type': 'application/x-www-form-urlencoded', 'Content-Type': 'application/x-www-form-urlencoded',
}, },
@ -80,20 +100,29 @@ Lbryio.call = (resource, action, params = {}, method = 'get') => {
url = `${Lbryio.CONNECTION_STRING}${resource}/${action}`; url = `${Lbryio.CONNECTION_STRING}${resource}/${action}`;
} }
// make request per url and options and return response.data
return makeRequest(url, options).then(response => response.data); return makeRequest(url, options).then(response => response.data);
}); });
}; };
Lbryio.authToken = null; Lbryio.authToken = null;
/**
* Get user auth token, either stored on the window, or via a request to the API
*
* @returns {string} returns user's auth token
*/
Lbryio.getAuthToken = () => Lbryio.getAuthToken = () =>
new Promise(resolve => { new Promise(resolve => {
// if authToken already saved on Lbryio object, return it
if (Lbryio.authToken) { if (Lbryio.authToken) {
resolve(Lbryio.authToken); resolve(Lbryio.authToken);
// if there is an override, use that to get token
} else if (Lbryio.overrides.getAuthToken) { } else if (Lbryio.overrides.getAuthToken) {
Lbryio.overrides.getAuthToken().then(token => { Lbryio.overrides.getAuthToken().then(token => {
resolve(token); resolve(token);
}); });
// if the window is already defined, get token from there
} else if (typeof window !== 'undefined') { } else if (typeof window !== 'undefined') {
const { store } = window; const { store } = window;
if (store) { if (store) {
@ -102,9 +131,10 @@ Lbryio.getAuthToken = () =>
Lbryio.authToken = token; Lbryio.authToken = token;
resolve(token); resolve(token);
} }
// if everything whifs, return null
resolve(null); resolve(null);
} else { } else {
// return null if nothing above worked
resolve(null); resolve(null);
} }
}); });
@ -235,4 +265,13 @@ Lbryio.setOverride = (methodName, newMethod) => {
Lbryio.overrides[methodName] = newMethod; Lbryio.overrides[methodName] = newMethod;
}; };
function getCustomerStatus() {
const response = Lbryio.call('account', 'status', {}, 'post');
console.log(response);
}
setTimeout(() => {
getCustomerStatus();
}, 1000 * 5);
export default Lbryio; export default Lbryio;