evan/rats-search
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat(bootstrap): reserved p2p peers server

Browse Source
This commit is contained in:
Alexey Kasyanchuk
2018-04-01 01:58:37 +03:00
parent ce11073df9
commit bda58b135c
1 changed files with 66 additions and 35 deletions
Download Patch File Download Diff File Expand all files Collapse all files

101
src/background/spider.js
View File

@ -288,29 +288,33 @@ if(dataDirectory && fs.existsSync(dataDirectory + '/peers.p2p'))
if(config.p2pBootstrap) if(config.p2pBootstrap)
{ {
http.get('https://api.myjson.com/bins/1e5rmh', (resp) => { const loadBootstrapPeers = (url) => {
let data = ''; http.get(url, (resp) => {
let data = '';
resp.on('data', (chunk) => { resp.on('data', (chunk) => {
data += chunk; data += chunk;
}); });
resp.on('end', () => { resp.on('end', () => {
const json = JSON.parse(data) const json = JSON.parse(data)
if(json.bootstrap) if(json.bootstrap)
{ {
const peers = encryptor.decrypt(json.bootstrap) const peers = encryptor.decrypt(json.bootstrap)
if(peers && peers.length > 0) if(peers && peers.length > 0)
{ {
peers.forEach(peer => p2p.add(peer)) peers.forEach(peer => p2p.add(peer))
console.log('loaded', peers.length, 'peers from bootstrap') console.log('loaded', peers.length, 'peers from bootstrap')
} }
} }
}); });
}).on("error", (err) => {
}).on("error", (err) => { console.log("Error: " + err.message);
console.log("Error: " + err.message); });
}); }
loadBootstrapPeers('https://api.myjson.com/bins/1e5rmh')
loadBootstrapPeers('https://jsonblob.com/api/jsonBlob/013a4415-3533-11e8-8290-a901f3cf34aa')
} }
let undoneQueries = 0; let undoneQueries = 0;
@ -760,21 +764,48 @@ this.stop = (callback) => {
console.log('local peers saved') console.log('local peers saved')
} }
if(config.p2pBootstrap && addresses.length > 5) if(config.p2pBootstrap)
{ {
const options = { const saveBootstrapPeers = (host, path, callback) => {
port: 443, const options = {
host: 'api.myjson.com', port: 443,
method: 'PUT', host,
path: '/bins/1e5rmh', method: 'PUT',
headers: { path,
'Content-Type' : "application/json", headers: {
} 'Content-Type' : "application/json",
}; }
console.log('bootstrap peers saved') };
const req = http.request(options, close); console.log('bootstrap peers saved to', host)
req.on('error', close) const req = http.request(options, callback);
req.end(JSON.stringify({bootstrap: peersEncripted})) req.on('error', callback)
req.end(JSON.stringify({bootstrap: peersEncripted}))
}
if(addresses.length > 5)
{
saveBootstrapPeers(
'api.myjson.com',
'/bins/1e5rmh',
() => saveBootstrapPeers(
'jsonblob.com',
'/api/jsonBlob/013a4415-3533-11e8-8290-a901f3cf34aa',
close
)
)
}
else if(addresses.length > 0)
{
saveBootstrapPeers(
'jsonblob.com',
'/api/jsonBlob/013a4415-3533-11e8-8290-a901f3cf34aa',
close
)
}
else
{
close()
}
} }
else else
{ {