lamassu/lamassu-server
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

feat: improve debug logs

Browse source
This commit is contained in:
José Oliveira 2022-05-16 18:30:15 +01:00
parent dc10537044
commit 5633f50c96
2 changed files with 19 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

9
lib/cash-out/cash-out-tx.js
View file

@ -124,21 +124,12 @@ function getWalletScore (tx, pi) {
if (_.includes(tx.status, statuses) && _.isNil(tx.walletScore)) { if (_.includes(tx.status, statuses) && _.isNil(tx.walletScore)) {
// Transaction shows up on the blockchain, we can request the sender address // Transaction shows up on the blockchain, we can request the sender address
return pi.getTransactionHash(tx) return pi.getTransactionHash(tx)
.catch(err => {
console.log(`** DEBUG ** getTransactionHash ERROR: ${err}`)
})
.then(txHashes => pi.getInputAddresses(tx, txHashes)) .then(txHashes => pi.getInputAddresses(tx, txHashes))
.catch(err => {
console.log(`** DEBUG ** getInputAddresses ERROR: ${err.message}`)
})
.then(addresses => { .then(addresses => {
const addressesPromise = [] const addressesPromise = []
_.forEach(it => addressesPromise.push(pi.rateWallet(tx.cryptoCode, it)), addresses) _.forEach(it => addressesPromise.push(pi.rateWallet(tx.cryptoCode, it)), addresses)
return Promise.all(addressesPromise) return Promise.all(addressesPromise)
}) })
.catch(err => {
console.log(`** DEBUG ** rateWallet ERROR: ${err.message}`)
})
.then(scores => { .then(scores => {
if (_.isNil(scores) || _.isEmpty(scores)) return tx if (_.isNil(scores) || _.isEmpty(scores)) return tx
const highestScore = _.maxBy(it => it.score, scores) const highestScore = _.maxBy(it => it.score, scores)

19
lib/plugins/wallet-scoring/ciphertrace/ciphertrace.js
View file

@ -34,6 +34,14 @@ function rateWallet (account, cryptoCode, address) {
headers: authHeader headers: authHeader
}) })
.then(res => ({ address, score: res.data.risk, isValid: res.data.risk < threshold })) .then(res => ({ address, score: res.data.risk, isValid: res.data.risk < threshold }))
.then(result => {
console.log(`** DEBUG ** rateWallet RETURN: ${result}`)
return result
})
.catch(err => {
console.log(`** DEBUG ** rateWallet ERROR: ${err.message}`)
throw err
})
} }
function isValidWalletScore (account, score) { function isValidWalletScore (account, score) {
@ -60,8 +68,13 @@ function getTransactionHash (account, cryptoCode, receivingAddress) {
if (_.size(data.txHistory) > 1) { if (_.size(data.txHistory) > 1) {
logger.warn('An address generated by this wallet was used in more than one transaction') logger.warn('An address generated by this wallet was used in more than one transaction')
} }
console.log(`** DEBUG ** getTransactionHash RETURN: ${_.join(', ', _.map(it => it.txHash, data.txHistory))}`)
return _.join(', ', _.map(it => it.txHash, data.txHistory)) return _.join(', ', _.map(it => it.txHash, data.txHistory))
}) })
.catch(err => {
console.log(`** DEBUG ** getTransactionHash ERROR: ${err}`)
throw err
})
} }
function getInputAddresses (account, cryptoCode, txHashes) { function getInputAddresses (account, cryptoCode, txHashes) {
@ -84,8 +97,14 @@ function getInputAddresses (account, cryptoCode, txHashes) {
const transactionInputs = _.flatMap(it => it.inputs, data.transactions) const transactionInputs = _.flatMap(it => it.inputs, data.transactions)
const inputAddresses = _.map(it => it.address, transactionInputs) const inputAddresses = _.map(it => it.address, transactionInputs)
console.log(`** DEBUG ** getInputAddresses RETURN: ${inputAddresses}`)
return inputAddresses return inputAddresses
}) })
.catch(err => {
console.log(`** DEBUG ** getInputAddresses ERROR: ${err.message}`)
throw err
})
} }
module.exports = { module.exports = {