Browse Source
Some code cleanup Added 2 buy/sell toastr msgs that will need lang settings Added grouping to swapstatus debug output Moved 1 HTML click function Updated with KomodoPlatform editsmaster
TheComputerGenie
7 years ago
committed by
Unknown
Unknown
9 changed files with 812 additions and 777 deletions
Binary file not shown.
@ -0,0 +1,35 @@ |
|||
$('.dexdashboard-btn').click(function (e) { |
|||
e.preventDefault(); |
|||
console.log('btn-exchangeclose clicked'); |
|||
console.log($(this).data()); |
|||
|
|||
$('.navbar-right').children().removeClass('active'); |
|||
$('.dexdashboard-btn').parent().addClass("active"); |
|||
|
|||
$('body').css('overflow', 'inherit'); |
|||
$('.dextradeshistory').hide(); |
|||
|
|||
$('.dexdebug').hide(); |
|||
$('.dexdebug-btn').show(); |
|||
$('.dexlogout-btn').show(); |
|||
$('.dexdebug-close-btn').hide(); |
|||
$('.dextradeshistory-btn').show(); |
|||
|
|||
//$('.screen-coindashboard').show()
|
|||
$('.screen-exchange').hide(); |
|||
$('.screen-inventory').hide(); |
|||
$('.screen-managecoins').hide(); |
|||
$('.screen-portfolio').show(); |
|||
CheckOrderBookFn(false); |
|||
check_swap_status(false); |
|||
check_bot_list(false); |
|||
check_my_prices(false); |
|||
bot_screen_coin_balance(false); |
|||
bot_screen_sellcoin_balance(false); |
|||
Refresh_active_StockChart(false); |
|||
//check_coin_balance_Interval = setInterval(check_coin_balance(),3000);
|
|||
//check_coin_balance();
|
|||
|
|||
CheckPortfolioFn(); |
|||
CheckPortfolio_Interval = setInterval(CheckPortfolioFn, 60000); |
|||
}); |
|||
@ -1,496 +1,351 @@ |
|||
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'); |
|||
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, |
|||
killmm = require('./killmm'), |
|||
_BarterDEXSettingsFile = `${BarterDEXDir}/settings.json`, |
|||
{ ipcMain } = require('electron'); |
|||
|
|||
var ps = require('ps-node'), |
|||
shepherd = '', |
|||
assetChainPorts = require('./ports.js'); |
|||
shepherd = '', |
|||
assetChainPorts = require('./ports.js'), |
|||
BarterDEXBin, |
|||
BarterDEXDir; |
|||
|
|||
const killmm = require('./killmm'); |
|||
Promise = require('bluebird'); |
|||
|
|||
// 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'); |
|||
switch (osPlatform) { |
|||
case "darwin": |
|||
fixPath(); |
|||
BarterDEXBin = path.join(__dirname, '../assets/bin/osx/marketmaker'); |
|||
BarterDEXDir = `${process.env.HOME}/Library/Application Support/BarterDEX`; |
|||
break; |
|||
case "linux": |
|||
BarterDEXBin = path.join(__dirname, '../assets/bin/linux64/marketmaker'); |
|||
BarterDEXDir = `${process.env.HOME}/.BarterDEX`; |
|||
break; |
|||
case "win32": |
|||
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'); |
|||
break; |
|||
} |
|||
|
|||
// 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); |
|||
.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) |
|||
.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){ |
|||
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); |
|||
}) |
|||
.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
|
|||
} |
|||
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.error(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; |
|||
}); |
|||
console.log('Shepard arg: ' + JSON.stringify(arg.command)) // prints arg
|
|||
switch (arg.command) { |
|||
case 'ping': |
|||
event.returnValue = 'pong' |
|||
break; |
|||
case 'login': |
|||
console.log(BarterDEXBin + '\n' + BarterDEXDir); |
|||
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.returnValue = status; |
|||
}) |
|||
break; |
|||
case 'update_zeroconf_log': |
|||
UpdateZeroConfLogs(arg.data); |
|||
event.returnValue = 'Zeroconf log updated'; |
|||
break; |
|||
case 'read_zeroconf_log': |
|||
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': |
|||
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': |
|||
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': |
|||
UpdateBarterDEXSettings(arg.data); |
|||
event.returnValue = 'BarterDEX settings updated'; |
|||
break; |
|||
case 'reset_settings': |
|||
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}`); |
|||
} |
|||
StartMarketMaker = function (data) { |
|||
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') { fs.writeJsonSync(_coinsListFile, data.coinslist); } // ver.2
|
|||
ExecMarketMaker(data); |
|||
}) |
|||
.catch(err => { console.error(err) }) |
|||
} |
|||
if (err) { console.error(err) } // => null
|
|||
}) |
|||
} else { console.error(`port 7783 marketmaker is already in use`); } |
|||
}); |
|||
} catch (e) { console.error(`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'}); |
|||
ExecMarketMaker = function (data) { |
|||
const _customParam = { |
|||
'gui': 'simplegui', |
|||
'client': 1, |
|||
'profitmargin': 0.01, |
|||
'userhome': `${process.env.HOME}`, |
|||
'passphrase': data.passphrase, |
|||
'coins': data.coinslist |
|||
}; |
|||
|
|||
let params = _customParam; |
|||
if (osPlatform !== 'win32') { |
|||
params = JSON.stringify(_customParam); |
|||
params = `'${params}'`; |
|||
} else { |
|||
BarterDEXBin = '"' + BarterDEXBin + '"'; |
|||
params.userhome = process.env.APPDATA; |
|||
// if not undefined and true for Windows we should use coins.json file, and don't pass coins in command line
|
|||
if (!!params.coins) { delete params.coins; } |
|||
params = JSON.stringify(_customParam); |
|||
params = params.replace(/"/g, '\\"'); |
|||
params = '"' + params + '"'; |
|||
|
|||
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); |
|||
var logStream = fs.createWriteStream(`${BarterDEXDir}/logFile.log`, { flags: 'a' }); |
|||
console.log('mm start\n' + `${BarterDEXBin} ${params}`) |
|||
mmid = exec(`${BarterDEXBin} ${params}`, { |
|||
cwd: BarterDEXDir, |
|||
maxBuffer: 1024 * 50000 // 50 mb
|
|||
}, function (error, stdout, stderr) { |
|||
console.log(`stdout: ${stdout}`); |
|||
console.error(`stderr: ${stderr}`); |
|||
if (error !== null) { console.error(`exec error: ${error}`); } |
|||
}); |
|||
|
|||
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);
|
|||
UpdateZeroConfLogs = function (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) |
|||
.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 (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); |
|||
console.log('===============\n' + 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); |
|||
}) |
|||
.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) |
|||
.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 (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); |
|||
}) |
|||
.catch(err => { console.error(err); }) |
|||
} |
|||
} |
|||
|
|||
|
|||
|
|||
UpdateBarterDEXSettings = function(settings_data) { |
|||
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); |
|||
}) |
|||
.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 (osPlatform === 'darwin') { fixPath(); }; |
|||
coins = JSON.stringify(coins); |
|||
switch (osPlatform) { |
|||
case "darwin": |
|||
coins = coins.replace(/USERHOME/g, `${process.env.HOME}/Library/Application Support`); |
|||
coins = coins.replace(/\/\./g, '/'); |
|||
break; |
|||
case "linux": |
|||
coins = coins.replace(/USERHOME/g, `${process.env.HOME}`); |
|||
break; |
|||
case "win32": |
|||
coins = coins.replace(/USERHOME/g, `${process.env.APPDATA}`); |
|||
coins = coins.replace(/\/\./g, '/'); |
|||
coins = path.normalize(coins); |
|||
coins = coins.replace(/\\/g, "\\\\"); |
|||
break; |
|||
} |
|||
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; |
|||
} |
|||
} |
|||
Loading…
Reference in new issue