40 lines
1.4 KiB
JavaScript
40 lines
1.4 KiB
JavaScript
import lbry from './lbry.js';
|
|
|
|
var lighthouse = {
|
|
_search_timeout: 5000,
|
|
_max_search_tries: 5,
|
|
|
|
servers: [
|
|
'http://lighthouse1.lbry.io:50005',
|
|
'http://lighthouse2.lbry.io:50005',
|
|
'http://lighthouse3.lbry.io:50005',
|
|
],
|
|
path: '/',
|
|
|
|
call: function(method, params, callback, errorCallback, connectFailedCallback, timeout) {
|
|
lbry.jsonrpc_call(this.server + this.path, method, params, callback, errorCallback, connectFailedCallback, timeout);
|
|
},
|
|
|
|
search: function(query, callback) {
|
|
let handleSearchFailed = function(tryNum=0) {
|
|
if (tryNum > lighthouse._max_search_tries) {
|
|
throw new Error(`Could not connect to Lighthouse server. Last server attempted: ${lighthouse.server}`);
|
|
} else {
|
|
// Randomly choose one of the other search servers to switch to
|
|
let otherServers = lighthouse.servers.slice();
|
|
otherServers.splice(otherServers.indexOf(lighthouse.server), 1);
|
|
lighthouse.server = otherServers[Math.round(Math.random() * (otherServers.length - 1))];
|
|
|
|
lighthouse.call('search', [query], callback, undefined, function() {
|
|
handleSearchFailed(tryNum + 1);
|
|
}, lighthouse._search_timeout);
|
|
}
|
|
}
|
|
|
|
lighthouse.call('search', [query], callback, undefined, function() { handleSearchFailed() }, lighthouse._search_timeout);
|
|
}
|
|
};
|
|
|
|
lighthouse.server = lighthouse.servers[Math.round(Math.random() * (lighthouse.servers.length - 1))];
|
|
|
|
export default lighthouse;
|