1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
|
const fs = require('fs');
var lastResponse;
var nodes = {};
module.exports = {
startNode: function startNode (nodeExec, dataDir, genesisPath, listeningPort, finished)
{
var utils = require('./utils.js');
var spawn = require('child_process').spawn
var options = [
'--private', 'privatechain',
'-d', dataDir,
'--config', genesisPath,
'--ipcpath', dataDir + '/geth.ipc',
'--ipc',
'--listen', listeningPort,
'--test'
]
utils.cLog('starting node')
utils.cLog(nodeExec + ' ' + options.join(' '))
var node = spawn(nodeExec, options)
node.stdout.on('data', (data) => {
utils.cLog(`stdout: ${data}`)
})
node.stderr.on('data', (data) => {
utils.cLog(`stderr: ${data}`)
})
node.on('close', (code) => {
utils.cLog(`child process exited with code ${code}`)
})
nodes[dataDir] = node;
utils.sleep(6000).then(() => {
utils.cLog("Node Started");
finished();
});
},
stopNode: function stopNode(dataDir, finished)
{
nodes[dataDir].kill();
var utils = require('./utils.js');
utils.sleep(1000).then(() => {
finished();
});
},
runScriptOnNode: function runScriptOnNode(dataDir, jsScript, args, finished)
{
var utils = require('./utils.js');
var ipcPath = dataDir + '/geth.ipc';
var Web3 = require('web3');
var web3admin = require('./web3Admin.js');
var net = require('net');
utils.cLog("Connecting to node at " + ipcPath);
var web3 = new Web3(new Web3.providers.IpcProvider(ipcPath, net));
web3admin.extend(web3);
global.web3 = web3;
var onScriptCallback = function (err, data)
{
utils.cLog(data);
lastResponse = data;
finished();
}
global.callback = onScriptCallback;
global.args = args;
var vm = require('vm');
utils.cLog("Executing " + jsScript + " ...");
fs.readFile(jsScript, 'utf8', function (err, data)
{
if (err)
{
utils.cLog(err);
finished();
}
else
{
var script = new vm.Script(data);
- script.runInThisContext();
}
});
},
getLastResponse: function getLastResponse()
{
return lastResponse;
}
}//exports
|
