61 lines
1.8 KiB
JavaScript
61 lines
1.8 KiB
JavaScript
import lbry from './lbry.js';
|
|
import jsonrpc from './jsonrpc.js';
|
|
|
|
const queryTimeout = 3000;
|
|
const maxQueryTries = 2;
|
|
const defaultServers = [
|
|
'http://lighthouse7.lbry.io:50005',
|
|
'http://lighthouse8.lbry.io:50005',
|
|
'http://lighthouse9.lbry.io:50005',
|
|
];
|
|
const path = '/';
|
|
|
|
let server = null;
|
|
let connectTryNum = 0;
|
|
|
|
function getServers() {
|
|
return lbry.getClientSetting('useCustomLighthouseServers')
|
|
? lbry.getClientSetting('customLighthouseServers')
|
|
: defaultServers;
|
|
}
|
|
|
|
function call(method, params, callback, errorCallback) {
|
|
if (connectTryNum >= maxQueryTries) {
|
|
errorCallback(new Error(__(`Could not connect to Lighthouse server. Last server attempted: %s`, server)));
|
|
return;
|
|
}
|
|
|
|
/**
|
|
* Set the Lighthouse server if it hasn't been set yet, if the current server is not in current
|
|
* set of servers (most likely because of a settings change), or we're re-trying after a failed
|
|
* query.
|
|
*/
|
|
if (!server || !getServers().includes(server) || connectTryNum > 0) {
|
|
// If there's a current server, filter it out so we get a new one
|
|
const newServerChoices = server ? getServers().filter((s) => s != server) : getServers();
|
|
server = newServerChoices[Math.round(Math.random() * (newServerChoices.length - 1))];
|
|
}
|
|
|
|
jsonrpc.call(server + path, method, params, (response) => {
|
|
connectTryNum = 0;
|
|
callback(response);
|
|
}, (error) => {
|
|
connectTryNum = 0;
|
|
errorCallback(error);
|
|
}, () => {
|
|
connectTryNum++;
|
|
call(method, params, callback, errorCallback);
|
|
}, queryTimeout);
|
|
}
|
|
|
|
const lighthouse = new Proxy({}, {
|
|
get: function(target, name) {
|
|
return function(...params) {
|
|
return new Promise((resolve, reject) => {
|
|
call(name, params, resolve, reject);
|
|
});
|
|
};
|
|
},
|
|
});
|
|
|
|
export default lighthouse;
|