embarklabs
/
embark
mirror of https://github.com/embarklabs/embark.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

Fix failing test on blockchain

This commit is contained in:
Andre Medeiros 2018-07-11 11:38:58 -04:00 committed by Pascal Precht
parent b99c32eaad
commit 00410b7057
No known key found for this signature in database
GPG Key ID: 0EE28D8D6FD85D7D
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
lib/core/proxy.js
View File

@ -3,7 +3,7 @@ const http = require('http');
const constants = require('../constants.json'); const constants = require('../constants.json');
let commList = {}; let commList = {};
let transactions = {}; let transactions = {};
let receipts = {}; let receipts = {};
const parseRequest = function(reqBody){ const parseRequest = function(reqBody){
@ -42,7 +42,7 @@ const parseResponse = function(ipc, resBody){
commList[receipts[jsonO.id]].blockNumber = jsonO.result.blockNumber; commList[receipts[jsonO.id]].blockNumber = jsonO.result.blockNumber;
commList[receipts[jsonO.id]].gasUsed = jsonO.result.gasUsed; commList[receipts[jsonO.id]].gasUsed = jsonO.result.gasUsed;
commList[receipts[jsonO.id]].status = jsonO.result.status; commList[receipts[jsonO.id]].status = jsonO.result.status;
if(ipc.connected && !ipc.connecting){ if(ipc.connected && !ipc.connecting){
ipc.request('log', commList[receipts[jsonO.id]]); ipc.request('log', commList[receipts[jsonO.id]]);
} else { } else {
@ -109,16 +109,17 @@ exports.serve = function(ipc, host, port, ws){
parseResponse(ipc, data.toString().substr(data.indexOf("{"))); parseResponse(ipc, data.toString().substr(data.indexOf("{")));
}); });
}); });
proxy.on('proxyReqWs', (proxyReq, req, socket) => { proxy.on('proxyReqWs', (proxyReq, req, socket) => {
var parser = new WsParser(0, false); var parser = new WsParser(0, false);
socket.pipe(parser); socket.pipe(parser);
parser.on('frame', function (frame) { parser.on('frame', function (frame) {
parseRequest(frame.data); parseRequest(frame.data);
}); });
}); });
} }
server.listen(port); server.listen(port);
return server;
}; };