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 {
      // 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.writeJson(`${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.writeJson(`${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.writeJson(_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;
  }
}