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

fix(p2p): errors on peers ignore

Browse Source
This commit is contained in:
Alexey Kasyanchuk 2018-02-21 16:22:40 +03:00
parent d560e5ec23
commit c91ade5903
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/background/spider.js
View File

@ -264,6 +264,7 @@ const tcpServer = net.createServer();
tcpServer.listen(config.spiderPort); tcpServer.listen(config.spiderPort);
tcpServer.on('connection', (socket) => { tcpServer.on('connection', (socket) => {
socket = new JsonSocket(socket); socket = new JsonSocket(socket);
socket.on('error', (err) => {})
socket.on('message', (message) => { socket.on('message', (message) => {
if(message.type && messageHandlers[message.type]) if(message.type && messageHandlers[message.type])
{ {
@ -1073,7 +1074,6 @@ const p2p = {
{ {
this.peers.push(address) this.peers.push(address)
const socket = new JsonSocket(new net.Socket()); //Decorate a standard net.Socket with JsonSocket const socket = new JsonSocket(new net.Socket()); //Decorate a standard net.Socket with JsonSocket
socket.connect(address.port, address.address);
socket.on('connect', () => { //Don't send until we're connected socket.on('connect', () => { //Don't send until we're connected
// add to peers // add to peers
send('peer', this.peers.length) send('peer', this.peers.length)
@ -1113,6 +1113,8 @@ const p2p = {
}) })
socket.on('error', (err) => {}) socket.on('error', (err) => {})
socket.connect(address.port, address.address);
}, },
emit(type, data, callback) emit(type, data, callback)
{ {