lbry-desktop/ui/js/lighthouse.js

60 lines
1.7 KiB
JavaScript
Raw Normal View History

2016-11-22 21:19:08 +01:00
import lbry from './lbry.js';
import jsonrpc from './jsonrpc.js';
2016-11-22 21:19:08 +01:00
2017-04-13 21:37:41 +02:00
const queryTimeout = 3000;
const maxQueryTries = 2;
const defaultServers = [
2017-04-17 18:37:25 +02:00
'http://lighthouse7.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) {
2017-04-13 21:37:41 +02:00
if (connectTryNum >= maxQueryTries) {
2017-04-13 20:52:26 +02:00
errorCallback(new Error(`Could not connect to Lighthouse server. Last server attempted: ${server}`));
2017-04-13 21:37:41 +02:00
return;
}
2016-12-09 10:57:13 +01:00
/**
* 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);
2017-04-13 20:52:26 +02:00
}, queryTimeout);
}
const lighthouse = new Proxy({}, {
get: function(target, name) {
return function(...params) {
return new Promise((resolve, reject) => {
call(name, params, resolve, reject);
});
};
},
});
2016-11-22 21:19:08 +01:00
export default lighthouse;