134 lines
4 KiB
JavaScript
134 lines
4 KiB
JavaScript
const _ = require('lodash/fp')
|
|
const jsonRpc = require('../../common/json-rpc')
|
|
|
|
const { utils } = require('lamassu-coins')
|
|
|
|
const blockchainUtils = require('../../../coin-utils')
|
|
const BN = require('../../../bn')
|
|
const E = require('../../../error')
|
|
|
|
const cryptoRec = utils.getCryptoCurrency('DASH')
|
|
const configPath = utils.configPath(cryptoRec, blockchainUtils.blockchainDir())
|
|
const unitScale = cryptoRec.unitScale
|
|
|
|
function rpcConfig () {
|
|
try {
|
|
const config = jsonRpc.parseConf(configPath)
|
|
return {
|
|
username: config.rpcuser,
|
|
password: config.rpcpassword,
|
|
port: config.rpcport || cryptoRec.defaultPort
|
|
}
|
|
} catch (err) {
|
|
throw new Error('wallet is currently not installed')
|
|
}
|
|
}
|
|
|
|
function fetch (method, params) {
|
|
return jsonRpc.fetch(rpcConfig(), method, params)
|
|
}
|
|
|
|
function checkCryptoCode (cryptoCode) {
|
|
if (cryptoCode !== 'DASH') return Promise.reject(new Error('Unsupported crypto: ' + cryptoCode))
|
|
return Promise.resolve()
|
|
}
|
|
|
|
function accountBalance (cryptoCode) {
|
|
return checkCryptoCode(cryptoCode)
|
|
.then(() => fetch('getwalletinfo'))
|
|
.then(({ balance }) => BN(balance).shift(unitScale).round())
|
|
}
|
|
|
|
function accountUnconfirmedBalance (cryptoCode) {
|
|
return checkCryptoCode(cryptoCode)
|
|
.then(() => fetch('getwalletinfo'))
|
|
.then(({ unconfirmed_balance: balance }) => BN(balance).shift(unitScale).round())
|
|
}
|
|
|
|
// We want a balance that includes all spends (0 conf) but only deposits that
|
|
// have at least 1 confirmation. getbalance does this for us automatically.
|
|
function balance (account, cryptoCode, settings, operatorId) {
|
|
return accountBalance(cryptoCode)
|
|
}
|
|
|
|
function sendCoins (account, tx, settings, operatorId) {
|
|
const { toAddress, cryptoAtoms, cryptoCode } = tx
|
|
const coins = cryptoAtoms.shift(-unitScale).toFixed(8)
|
|
|
|
return checkCryptoCode(cryptoCode)
|
|
.then(() => fetch('sendtoaddress', [toAddress, coins]))
|
|
.then((txId) => fetch('gettransaction', [txId]))
|
|
.then((res) => _.pick(['fee', 'txid'], res))
|
|
.then((pickedObj) => {
|
|
return {
|
|
fee: BN(pickedObj.fee).abs().shift(unitScale).round(),
|
|
txid: pickedObj.txid
|
|
}
|
|
})
|
|
.catch(err => {
|
|
if (err.code === -6) throw new E.InsufficientFundsError()
|
|
throw err
|
|
})
|
|
}
|
|
|
|
function newAddress (account, info, tx, settings, operatorId) {
|
|
return checkCryptoCode(info.cryptoCode)
|
|
.then(() => fetch('getnewaddress'))
|
|
}
|
|
|
|
function addressBalance (address, confs) {
|
|
return fetch('getreceivedbyaddress', [address, confs])
|
|
.then(r => BN(r).shift(unitScale).round())
|
|
}
|
|
|
|
function confirmedBalance (address, cryptoCode) {
|
|
return checkCryptoCode(cryptoCode)
|
|
.then(() => addressBalance(address, 1))
|
|
}
|
|
|
|
function pendingBalance (address, cryptoCode) {
|
|
return checkCryptoCode(cryptoCode)
|
|
.then(() => addressBalance(address, 0))
|
|
}
|
|
|
|
function getStatus (account, tx, requested, settings, operatorId) {
|
|
const { toAddress, cryptoCode } = tx
|
|
return checkCryptoCode(cryptoCode)
|
|
.then(() => confirmedBalance(toAddress, cryptoCode))
|
|
.then(confirmed => {
|
|
if (confirmed.gte(requested)) return { receivedCryptoAtoms: confirmed, status: 'confirmed' }
|
|
|
|
return pendingBalance(toAddress, cryptoCode)
|
|
.then(pending => {
|
|
if (pending.gte(requested)) return { receivedCryptoAtoms: pending, status: 'authorized' }
|
|
if (pending.gt(0)) return { receivedCryptoAtoms: pending, status: 'insufficientFunds' }
|
|
return { receivedCryptoAtoms: pending, status: 'notSeen' }
|
|
})
|
|
})
|
|
}
|
|
|
|
function newFunding (account, cryptoCode, settings, operatorId) {
|
|
return checkCryptoCode(cryptoCode)
|
|
.then(() => {
|
|
const promises = [
|
|
accountUnconfirmedBalance(cryptoCode),
|
|
accountBalance(cryptoCode),
|
|
newAddress(account, { cryptoCode })
|
|
]
|
|
|
|
return Promise.all(promises)
|
|
})
|
|
.then(([fundingPendingBalance, fundingConfirmedBalance, fundingAddress]) => ({
|
|
fundingPendingBalance,
|
|
fundingConfirmedBalance,
|
|
fundingAddress
|
|
}))
|
|
}
|
|
|
|
module.exports = {
|
|
balance,
|
|
sendCoins,
|
|
newAddress,
|
|
getStatus,
|
|
newFunding
|
|
}
|