496 lines
18 KiB
JavaScript
496 lines
18 KiB
JavaScript
const electron = require('electron'),
|
|
app = electron.app,
|
|
BrowserWindow = electron.BrowserWindow,
|
|
path = require('path'),
|
|
url = require('url'),
|
|
os = require('os'),
|
|
osPlatform = os.platform(),
|
|
fsnode = require('fs'),
|
|
fs = require('fs-extra'),
|
|
mkdirp = require('mkdirp'),
|
|
exec = require('child_process').exec,
|
|
spawn = require('child_process').spawn,
|
|
portscanner = require('portscanner'),
|
|
fixPath = require('fix-path'),
|
|
numCPUs = require('os').cpus().length;
|
|
//ipc = require('electron').ipcMain;
|
|
|
|
Promise = require('bluebird');
|
|
|
|
var ps = require('ps-node'),
|
|
shepherd = '',
|
|
assetChainPorts = require('./ports.js');
|
|
|
|
const killmm = require('./killmm');
|
|
|
|
// SETTING OS DIR TO RUN MARKETMAKER FROM
|
|
// SETTING APP ICON FOR LINUX AND WINDOWS
|
|
if (os.platform() === 'darwin') {
|
|
fixPath();
|
|
var BarterDEXBin = path.join(__dirname, '../assets/bin/osx/marketmaker'),
|
|
BarterDEXDir = `${process.env.HOME}/Library/Application Support/BarterDEX`;
|
|
}
|
|
|
|
if (os.platform() === 'linux') {
|
|
var BarterDEXBin = path.join(__dirname, '../assets/bin/linux64/marketmaker'),
|
|
BarterDEXDir = `${process.env.HOME}/.BarterDEX`;
|
|
}
|
|
|
|
if (os.platform() === 'win32') {
|
|
var BarterDEXBin = path.join(__dirname, '../assets/bin/win64/marketmaker.exe');
|
|
BarterDEXBin = path.normalize(BarterDEXBin);
|
|
BarterDEXDir = `${process.env.APPDATA}/BarterDEX`;
|
|
BarterDEXDir = path.normalize(BarterDEXDir);
|
|
BarterDEXIcon = path.join(__dirname, '/assets/icons/barterdex/barterdex.ico');
|
|
}
|
|
|
|
// DEFAULT COINS LIST FOR MARKETMAKER
|
|
defaultCoinsListFile = path.join(__dirname, '../assets/coins.json');
|
|
|
|
// DEFAULT BARTERDEX SETTINGS FILE
|
|
defaultBarterDEXSettingsFile = path.join(__dirname, '../assets/settings.json');
|
|
|
|
//Make empty zeroconf log files if not there
|
|
fs.ensureFile(`${BarterDEXDir}/ZeroConf_Deposit_logFile.log`)
|
|
.then(() => {
|
|
console.log('success!')
|
|
fs.readJson(`${BarterDEXDir}/ZeroConf_Deposit_logFile.log`, (err, zconf_deposit_log) => {
|
|
if (err) console.error(err)
|
|
var isitjson = typeof zconf_deposit_log == 'object';
|
|
if (isitjson == false){
|
|
fs.appendFile(`${BarterDEXDir}/ZeroConf_Deposit_logFile.log`, `[]`, function (err) {
|
|
if (err) throw err;
|
|
console.log('ZeroConf deposit log updated!');
|
|
});
|
|
}
|
|
})
|
|
})
|
|
.catch(err => {
|
|
console.error(err);
|
|
})
|
|
|
|
fs.ensureFile(`${BarterDEXDir}/ZeroConf_Claim_logFile.log`)
|
|
.then(() => {
|
|
console.log('success!')
|
|
fs.readJson(`${BarterDEXDir}/ZeroConf_Claim_logFile.log`, (err, zconf_claim_log) => {
|
|
if (err) console.error(err)
|
|
var isitjson = typeof zconf_claim_log == 'object';
|
|
if (isitjson == false){
|
|
fs.appendFile(`${BarterDEXDir}/ZeroConf_Claim_logFile.log`, `[]`, function (err) {
|
|
if (err) throw err;
|
|
console.log('ZeroConf claim log updated!');
|
|
});
|
|
}
|
|
})
|
|
})
|
|
.catch(err => {
|
|
console.error(err);
|
|
})
|
|
|
|
|
|
const _BarterDEXSettingsFile = `${BarterDEXDir}/settings.json`;
|
|
fs.pathExists(_BarterDEXSettingsFile, (err, exists) => {
|
|
if (exists === true) {
|
|
console.log('barterdex settings file exist');
|
|
} else if (exists === false) {
|
|
console.log('barterdex settings file doesn\'t exist');
|
|
fs.copy(defaultBarterDEXSettingsFile, _BarterDEXSettingsFile)
|
|
.then(() => {
|
|
console.log('barterdex settings file copied!')
|
|
})
|
|
.catch(err => {
|
|
console.error(err)
|
|
})
|
|
}
|
|
if (err) {
|
|
console.log(err) // => null
|
|
}
|
|
});
|
|
|
|
|
|
const {ipcMain} = require('electron');
|
|
/*ipcMain.on('shepherd-commandSync', (event, arg) => {
|
|
console.log(arg.command) // prints "ping"
|
|
event.returnValue = 'pong'
|
|
})*/
|
|
|
|
ipcMain.on('shepherd-command', (event, arg) => {
|
|
console.log(arg) // prints "ping"
|
|
switch (arg.command) {
|
|
case 'ping':
|
|
//event.sender.send('shepherd-reply', 'pong');
|
|
event.returnValue = 'pong'
|
|
break;
|
|
case 'login':
|
|
console.log(BarterDEXBin);
|
|
console.log(BarterDEXDir);
|
|
//event.sender.send('shepherd-reply', 'Logged In');
|
|
event.returnValue = 'Logged In';
|
|
//const _passphrase = 'scatter quote stumble confirm extra jacket lens abuse gesture soda rebel seed nature achieve hurt shoot farm middle venture fault mesh crew upset cotton';
|
|
StartMarketMaker({"passphrase":arg.passphrase});
|
|
break;
|
|
case 'logout':
|
|
killmm(true);
|
|
event.returnValue = 'Logged Out';
|
|
break;
|
|
case 'mmstatus':
|
|
portscanner.checkPortStatus(7783, '127.0.0.1', function(error, status) {
|
|
console.log(status)
|
|
//event.sender.send('shepherd-reply', status);
|
|
event.returnValue = status;
|
|
})
|
|
break;
|
|
case 'update_zeroconf_log':
|
|
//console.log(arg.data);
|
|
UpdateZeroConfLogs(arg.data);
|
|
event.returnValue = 'Zeroconf log updated';
|
|
break;
|
|
case 'read_zeroconf_log':
|
|
//console.log(arg.data);
|
|
if (arg.type == 'deposit') {
|
|
fs.readJson(`${BarterDEXDir}/ZeroConf_Deposit_logFile.log`)
|
|
.then(zconf_deposit_log_file => {
|
|
event.returnValue = zconf_deposit_log_file;
|
|
})
|
|
.catch(err => {
|
|
console.error(err)
|
|
})
|
|
}
|
|
if (arg.type == 'claim') {
|
|
fs.readJson(`${BarterDEXDir}/ZeroConf_Claim_logFile.log`)
|
|
.then(zconf_claim_log_file => {
|
|
event.returnValue = zconf_claim_log_file;
|
|
})
|
|
.catch(err => {
|
|
console.error(err)
|
|
})
|
|
}
|
|
break;
|
|
case 'remove_finished_swap_file':
|
|
//console.log(arg.data);
|
|
fs.remove(`${BarterDEXDir}/DB/SWAPS/${arg.requestid}-${arg.quoteid}.finished`)
|
|
.then(() => {
|
|
console.log('Removed: '+ `${BarterDEXDir}/DB/SWAPS/${arg.requestid}-${arg.quoteid}.finished`)
|
|
event.returnValue = 'removed';
|
|
})
|
|
.catch(err => {
|
|
console.error(err)
|
|
event.returnValue = 'error';
|
|
})
|
|
break;
|
|
case 'read_settings':
|
|
//console.log(arg.data);
|
|
fs.readJson(`${BarterDEXDir}/settings.json`)
|
|
.then(barterdex_settings_file_output => {
|
|
event.returnValue = barterdex_settings_file_output;
|
|
})
|
|
.catch(err => {
|
|
console.error(err)
|
|
})
|
|
break;
|
|
case 'update_settings':
|
|
//console.log(arg.data);
|
|
UpdateBarterDEXSettings(arg.data);
|
|
event.returnValue = 'BarterDEX settings updated';
|
|
break;
|
|
case 'reset_settings':
|
|
//console.log(arg.data);
|
|
fs.copy(defaultBarterDEXSettingsFile, _BarterDEXSettingsFile, { overwrite: true })
|
|
.then(() => {
|
|
console.log('barterdex settings file copied!')
|
|
})
|
|
.catch(err => {
|
|
console.error(err)
|
|
})
|
|
event.returnValue = 'reset_done';
|
|
break;
|
|
case 'app_info':
|
|
event.returnValue = app.getVersion();
|
|
break;
|
|
case 'get_lang_data':
|
|
console.log(arg.lang);
|
|
fs.readJson(path.join(__dirname, `../assets/languages/${arg.lang}.json`))
|
|
.then(barterdex_deflang_file_output => {
|
|
event.returnValue = barterdex_deflang_file_output;
|
|
})
|
|
.catch(err => {
|
|
console.error(err)
|
|
})
|
|
break;
|
|
case 'get_lang_file_list':
|
|
fs.readdir(path.join(__dirname, `../assets/languages/`),function(err,lang_files){
|
|
if(err) throw err;
|
|
console.log(lang_files);
|
|
event.returnValue = lang_files;
|
|
});
|
|
}
|
|
})
|
|
|
|
|
|
StartMarketMaker = function(data) {
|
|
//console.log(data.passphrase);
|
|
try {
|
|
fs.unlink(BarterDEXDir+'/coins.json');
|
|
// check if marketmaker instance is already running
|
|
portscanner.checkPortStatus(7783, '127.0.0.1', function(error, status) {
|
|
// Status is 'open' if currently in use or 'closed' if available
|
|
if (status === 'closed') {
|
|
const _coinsListFile = BarterDEXDir+'/coins.json'
|
|
|
|
fs.pathExists(_coinsListFile, (err, exists) => {
|
|
if (exists === true) {
|
|
console.log('file exist');
|
|
var coinslist_filedata = fs.readJsonSync(_coinsListFile, { throws: false });
|
|
data.coinslist = ProcessCoinsList(coinslist_filedata);
|
|
// data.coinslist is not used under Windows, if coins.json already exists
|
|
// it will be directly used by marketmaker
|
|
ExecMarketMaker(data);
|
|
} else if (exists === false) {
|
|
console.log('file doesn\'t exist');
|
|
fs.copy(defaultCoinsListFile, _coinsListFile)
|
|
.then(() => {
|
|
console.log('file copied!')
|
|
var coinslist_filedata = fs.readJsonSync(_coinsListFile, { throws: false });
|
|
data.coinslist = ProcessCoinsList(coinslist_filedata);
|
|
if (os.platform() === 'win32') {
|
|
// here we should write processed coin.json to it's location from where it will be use by marketmaker
|
|
/*
|
|
// ver.1
|
|
var json_to_write = JSON.stringify(data.coinslist);
|
|
//json_to_write = json_to_write.replace(/\\\\/g, "\\");
|
|
fs.writeFile(_coinsListFile, json_to_write, function(err) {
|
|
if(err) {
|
|
console.error(err);
|
|
}
|
|
});
|
|
*/
|
|
// ver.2
|
|
fs.writeJsonSync(_coinsListFile, data.coinslist);
|
|
}
|
|
ExecMarketMaker(data);
|
|
})
|
|
.catch(err => {
|
|
console.error(err)
|
|
})
|
|
}
|
|
if (err) {
|
|
console.log(err) // => null
|
|
}
|
|
})
|
|
} else {
|
|
console.log(`port 7783 marketmaker is already in use`);
|
|
}
|
|
});
|
|
} catch(e) {
|
|
console.log(`failed to start marketmaker err: ${e}`);
|
|
}
|
|
}
|
|
|
|
let mmid;
|
|
ExecMarketMaker = function(data) {
|
|
//console.log(data);
|
|
// start marketmaker via exec
|
|
/*if (os.platform() === 'win32') {
|
|
const _customParam = {
|
|
'gui':'uglygui',
|
|
'client':1,
|
|
'userhome':`${process.env.APPDATA}`,
|
|
'passphrase': data.passphrase,
|
|
'coins': data.coinslist
|
|
};
|
|
}
|
|
else {
|
|
const _customParam = {
|
|
'gui':'uglygui',
|
|
'client':1,
|
|
'userhome':`${process.env.HOME}`,
|
|
'passphrase': data.passphrase,
|
|
'coins': data.coinslist
|
|
};
|
|
}*/
|
|
|
|
const _customParam = {
|
|
'gui':'simplegui',
|
|
'client':1,
|
|
'profitmargin': 0.01,
|
|
'userhome':`${process.env.HOME}`,
|
|
'passphrase': data.passphrase,
|
|
'coins': data.coinslist
|
|
};
|
|
|
|
//console.log(JSON.stringify(_customParam))
|
|
//console.log(`exec ${BarterDEXBin} ${JSON.stringify(_customParam)}`);
|
|
|
|
let params = _customParam;
|
|
if (osPlatform !== 'win32') {
|
|
params = JSON.stringify(_customParam);
|
|
params = `'${params}'`;
|
|
} else {
|
|
BarterDEXBin = '"'+BarterDEXBin+'"';
|
|
params.userhome = process.env.APPDATA;
|
|
if (!!params.coins) { // if not undefined and true
|
|
delete params.coins; // for Windows we should use coins.json file, and don't pass coins in command line
|
|
}
|
|
//console.log('[Decker] BarterDEXBin = '+BarterDEXBin+', BarterDEXDir = '+BarterDEXDir);
|
|
params = JSON.stringify(_customParam);
|
|
params = params.replace(/"/g, '\\"');
|
|
params = '"' + params +'"';
|
|
|
|
}
|
|
|
|
//console.log(`[Decker] exec ${BarterDEXBin} ${params}`);
|
|
/*var out = fs.openSync(`${BarterDEXDir}/out.log`, 'a');
|
|
var err = fs.openSync(`${BarterDEXDir}/out.log`, 'a');
|
|
|
|
var cp = require('child_process');
|
|
console.log(params);
|
|
console.log(BarterDEXBin);
|
|
var child = cp.spawn(BarterDEXBin, [params], { detached: true, stdio: [ 'ignore', out, err ] });
|
|
child.unref();*/
|
|
|
|
var logStream = fs.createWriteStream(`${BarterDEXDir}/logFile.log`, {flags: 'a'});
|
|
|
|
console.log('mm start');
|
|
//console.log("[Decker] BarterDEXDir = '"+BarterDEXDir+"'");
|
|
|
|
console.log(`${BarterDEXBin} ${params}`)
|
|
mmid = exec(`${BarterDEXBin} ${params}`, {
|
|
cwd: BarterDEXDir,
|
|
maxBuffer: 1024 * 50000 // 50 mb
|
|
}, function(error, stdout, stderr) {
|
|
console.log(`stdout: ${stdout}`);
|
|
console.log(`stderr: ${stderr}`);
|
|
|
|
if (error !== null) {
|
|
console.log(`exec error: ${error}`);
|
|
|
|
/*if (error.toString().indexOf('using -reindex') > -1) {
|
|
cache.io.emit('service', {
|
|
'komodod': {
|
|
'error': 'run'
|
|
}
|
|
});
|
|
}*/
|
|
}
|
|
});
|
|
|
|
mmid.stdout.on('data', (data) => {
|
|
console.log(`child stdout:\n${data}`);
|
|
}).pipe(logStream);
|
|
|
|
mmid.stderr.on('data', (data) => {
|
|
console.error(`child stderr:\n${data}`);
|
|
}).pipe(logStream);
|
|
}
|
|
|
|
UpdateZeroConfLogs = function(zeroconf_log_data) {
|
|
//console.log(zeroconf_log_data);
|
|
if (zeroconf_log_data.type == 'deposit') {
|
|
fs.ensureFile(`${BarterDEXDir}/ZeroConf_Deposit_logFile.log`)
|
|
.then(() => {
|
|
console.log('success!')
|
|
fs.readJson(`${BarterDEXDir}/ZeroConf_Deposit_logFile.log`, (err, zconf_deposit_log) => {
|
|
if (err) console.error(err)
|
|
var isitjson = typeof zconf_deposit_log == 'object';
|
|
if (isitjson == false){
|
|
fs.appendFile(`${BarterDEXDir}/ZeroConf_Deposit_logFile.log`, `[`+zeroconf_log_data.logdata+`]`, function (err) {
|
|
if (err) throw err;
|
|
console.log('ZeroConf deposit log updated!');
|
|
});
|
|
} else {
|
|
console.log(zconf_deposit_log);
|
|
|
|
zconf_deposit_log.push(JSON.parse(zeroconf_log_data.logdata));
|
|
console.log('===============')
|
|
console.log(zconf_deposit_log);
|
|
fs.writeJsonSync(`${BarterDEXDir}/ZeroConf_Deposit_logFile.log`, zconf_deposit_log, function (err) {
|
|
if (err) throw err;
|
|
console.log('ZeroConf deposit log updated!');
|
|
});
|
|
}
|
|
})
|
|
})
|
|
.catch(err => {
|
|
console.error(err);
|
|
})
|
|
}
|
|
|
|
if (zeroconf_log_data.type == 'claim') {
|
|
fs.ensureFile(`${BarterDEXDir}/ZeroConf_Claim_logFile.log`)
|
|
.then(() => {
|
|
console.log('success!')
|
|
fs.readJson(`${BarterDEXDir}/ZeroConf_Claim_logFile.log`, (err, zconf_claim_log) => {
|
|
if (err) console.error(err)
|
|
var isitjson = typeof zconf_claim_log == 'object';
|
|
if (isitjson == false){
|
|
fs.appendFile(`${BarterDEXDir}/ZeroConf_Claim_logFile.log`, `[`+zeroconf_log_data.logdata+`]`, function (err) {
|
|
if (err) throw err;
|
|
console.log('ZeroConf claim log updated!');
|
|
});
|
|
} else {
|
|
//console.log(zconf_claim_log);
|
|
JSON.parse(zeroconf_log_data.logdata)
|
|
zconf_claim_log.push(JSON.parse(zeroconf_log_data.logdata));
|
|
//console.log('===============')
|
|
//console.log(zconf_claim_log);
|
|
fs.writeJsonSync(`${BarterDEXDir}/ZeroConf_Claim_logFile.log`, zconf_claim_log, function (err) {
|
|
if (err) throw err;
|
|
console.log('ZeroConf claim log updated!');
|
|
});
|
|
}
|
|
})
|
|
})
|
|
.catch(err => {
|
|
console.error(err);
|
|
})
|
|
}
|
|
}
|
|
|
|
|
|
|
|
UpdateBarterDEXSettings = function(settings_data) {
|
|
console.log(settings_data);
|
|
|
|
fs.ensureFile(_BarterDEXSettingsFile)
|
|
.then(() => {
|
|
fs.writeJsonSync(_BarterDEXSettingsFile, settings_data, function (err) {
|
|
if (err) throw err;
|
|
console.log('ZeroConf claim log updated!');
|
|
});
|
|
})
|
|
.catch(err => {
|
|
console.error(err);
|
|
})
|
|
}
|
|
|
|
|
|
|
|
function ProcessCoinsList(coins) {
|
|
if (os.platform() === 'darwin') {
|
|
fixPath();
|
|
coins = JSON.stringify(coins);
|
|
coins = coins.replace(/USERHOME/g, `${process.env.HOME}/Library/Application Support`);
|
|
coins = coins.replace(/\/\./g, '/');
|
|
coins = JSON.parse(coins);
|
|
return coins;
|
|
}
|
|
|
|
if (os.platform() === 'linux') {
|
|
coins = JSON.stringify(coins);
|
|
coins = coins.replace(/USERHOME/g, `${process.env.HOME}`);
|
|
coins = JSON.parse(coins);
|
|
return coins;
|
|
}
|
|
|
|
if (os.platform() === 'win32') {
|
|
coins = JSON.stringify(coins);
|
|
//console.log("\n\n[Decker #1] "+coins);
|
|
coins = coins.replace(/USERHOME/g, `${process.env.APPDATA}`);
|
|
coins = coins.replace(/\/\./g, '/');
|
|
coins = path.normalize(coins);
|
|
coins = coins.replace(/\\/g, "\\\\");
|
|
//console.log("\n\n[Decker #2] "+coins);
|
|
coins = JSON.parse(coins);
|
|
return coins;
|
|
}
|
|
} |