path: root/RPCTests/modules/ethconsole.js

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',
    '-a', '0x1122334455667788991011121314151617181920'
  ]
  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(14000).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