chore: small improvement to dependencies
This commit is contained in:
parent
a23ad99436
commit
008f3c9049
4 changed files with 8758 additions and 4966 deletions
|
|
@ -1,87 +0,0 @@
|
|||
const lnd = require('lnd-async')
|
||||
|
||||
const BN = require('../../../bn')
|
||||
const E = require('../../../error')
|
||||
const { utils: coinUtils } = require('@lamassu/coins')
|
||||
|
||||
const _ = require('lodash/fp')
|
||||
|
||||
const cryptoRec = coinUtils.getCryptoCurrency('BTC')
|
||||
const unitScale = cryptoRec.unitScale
|
||||
|
||||
const LND = process.env.LIGHTNING_NETWORK_DAEMON
|
||||
|
||||
module.exports = {
|
||||
balance,
|
||||
sendCoins,
|
||||
newAddress,
|
||||
getStatus,
|
||||
newFunding,
|
||||
cryptoNetwork
|
||||
}
|
||||
|
||||
function connect () {
|
||||
return lnd.connect(LND || {})
|
||||
}
|
||||
|
||||
function cryptoNetwork (account, cryptoCode, settings, operatorId) {
|
||||
return Promise.resolve('main')
|
||||
}
|
||||
|
||||
function checkCryptoCode (cryptoCode) {
|
||||
if (cryptoCode !== 'BTC') return Promise.reject(new Error('Unsupported crypto: ' + cryptoCode))
|
||||
return Promise.resolve()
|
||||
}
|
||||
|
||||
function balance (acount, cryptoCode, settings, operatorId) {
|
||||
return checkCryptoCode(cryptoCode)
|
||||
.then(connect)
|
||||
.then(c => c.channelBalance({}))
|
||||
.then(_.get('balance'))
|
||||
.then(BN)
|
||||
.then(r => r.shiftedBy(unitScale).decimalPlaces(0))
|
||||
}
|
||||
|
||||
function sendCoins (account, tx, settings, operatorId) {
|
||||
// const { toAddress, cryptoAtoms, cryptoCode } = tx
|
||||
// Not implemented yet
|
||||
return Promise.reject(new E.NotImplementedError())
|
||||
}
|
||||
|
||||
function newFunding (account, cryptoCode, settings, operatorId) {
|
||||
// Not implemented yet
|
||||
return Promise.reject(new E.NotImplementedError())
|
||||
}
|
||||
|
||||
function newAddress (account, info, tx, settings, operatorId) {
|
||||
return checkCryptoCode(info.cryptoCode)
|
||||
.then(connect)
|
||||
.then(c => {
|
||||
if (info.isLightning) {
|
||||
return c.addInvoice({memo: 'Lamassu cryptomat deposit', value: info.cryptoAtoms.toNumber()})
|
||||
.then(r => `${r.r_hash.toString('hex')}:${r.payment_request}`)
|
||||
}
|
||||
|
||||
return c.newAddress({type: 2})
|
||||
.then(_.get('address'))
|
||||
})
|
||||
}
|
||||
|
||||
function getStatus (account, tx, requested, settings, operatorId) {
|
||||
const { toAddress, cryptoCode } = tx
|
||||
return checkCryptoCode(cryptoCode)
|
||||
.then(() => {
|
||||
const parts = _.split(':', toAddress)
|
||||
const isLightning = _.size(parts) === 2
|
||||
const rHashStr = isLightning && _.head(parts)
|
||||
|
||||
return connect()
|
||||
.then(c => {
|
||||
return c.lookupInvoice({ r_hash_str: rHashStr })
|
||||
.then(r => {
|
||||
if (r.settled) return { status: 'confirmed' }
|
||||
return { status: 'notSeen' }
|
||||
})
|
||||
})
|
||||
})
|
||||
}
|
||||
Loading…
Add table
Add a link
Reference in a new issue