const _ = require('lodash/fp')
var db = require('../lib/db')
const settingsLoader = require('../lib/new-settings-loader')
const configManager = require('../lib/new-config-manager')

const curriedGetCashout = _.curry(configManager.getCashOut)

exports.up = function (next) {
  db.tx(async t => {
    const settingsPromise = settingsLoader.loadLatest()
    const machinesPromise = t.any('SELECT device_id FROM devices')
    const [{ config }, machines] = await Promise.all([settingsPromise, machinesPromise])
    const cryptoCodes = configManager.getCryptosFromWalletNamespace(config)
    const zeroConfLimits = _.map(_.flow(_.get('device_id'), curriedGetCashout(_, config), _.get('zeroConfLimit')), machines)
    const minArr = _.min(zeroConfLimits)
    const min = !_.isNil(minArr) && minArr < Infinity ? Number(minArr) : 0

    _.forEach(cryptoCode => {
      const walletConfig = configManager.getWalletSettings(cryptoCode, config)
      const zeroConfLimit = _.get('zeroConfLimit', walletConfig)
      const key = `wallets_${cryptoCode}_zeroConfLimit`
      if (_.isNil(zeroConfLimit)) {
        config[key] = min
      }
    }, cryptoCodes)

    const keysToErase = machines.map(machine =>
      config[`cashOut_${machine.device_id}_zeroConfLimit`] ? `cashOut_${machine.device_id}_zeroConfLimit` : null
    )

    _.forEach(key => {
      if (_.isNil(key)) return
      config[key] = null
    }, keysToErase)

    return settingsLoader.saveConfig(config)
  })
    .then(() => next())
    .catch(err => next(err))
}

exports.down = function (next) {
  next()
}