more stable p2p v2 connection to server

cron-as-worker-process
Moe 2022-06-23 16:36:13 -07:00
parent dee1cb27fa
commit 96c69c12c9
1 changed files with 6 additions and 0 deletions

View File

@ -162,6 +162,9 @@ function startConnection(p2pServerAddress,subscriptionId){
remotesocket.on('ready',() => {
remotesocket.write(initData.buffer)
})
remotesocket.on('error',(err) => {
s.debugLog('createRemoteSocket ERROR',err)
})
remotesocket.on('data', function(data) {
requestConnectionsData[requestId] = data.toString()
responseTunnel.send('data',data)
@ -285,6 +288,9 @@ function createResponseTunnel(originalRequestId){
rid: originalRequestId
})
}
responseTunnel.on('error', (err) => {
s.debugLog('responseTunnel ERROR',err)
})
responseTunnel.on('open', function(){
sendToResponseTunnel({
responseTunnel: originalRequestId,