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

fix: mempool flag and error handling

Browse source
This commit is contained in:
José Oliveira 2022-05-04 13:50:11 +01:00
parent 6dbb3bad34
commit 4d520f2c24
2 changed files with 12 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -6,7 +6,7 @@ const logger = require('../../../logger')
const NAME = 'CipherTrace'
const SUPPORTED_COINS = ['BTC', 'ETH', 'BCH', 'LTC', 'BNB', 'RSK']
function getClient(account) {
function getClient (account) {
if (_.isNil(account) || !account.enabled) return null
const [ctv1, username, secretKey] = account.authorizationValue.split(':')
@ -16,12 +16,12 @@ function getClient(account) {
const apiVersion = ctv1.slice(-2)
const authHeader = {
"Authorization": account.authorizationValue
'Authorization': account.authorizationValue
}
return { apiVersion, authHeader }
}
function rateWallet(account, cryptoCode, address) {
function rateWallet (account, cryptoCode, address) {
const client = getClient(account)
if (!_.includes(_.toUpper(cryptoCode), SUPPORTED_COINS) || _.isNil(client)) return Promise.resolve(null)
@ -34,7 +34,7 @@ function rateWallet(account, cryptoCode, address) {
.then(res => ({ address, score: res.data.risk, isValid: res.data.risk < threshold }))
}
function isValidWalletScore(account, score) {
function isValidWalletScore (account, score) {
const client = getClient(account)
if (_.isNil(client)) return Promise.resolve(true)
@ -42,13 +42,13 @@ function isValidWalletScore(account, score) {
return _.isNil(account) ? Promise.resolve(true) : Promise.resolve(score < threshold)
}
function getTransactionHash(account, cryptoCode, receivingAddress) {
function getTransactionHash (account, cryptoCode, receivingAddress) {
const client = getClient(account)
if (!_.includes(_.toUpper(cryptoCode), SUPPORTED_COINS) || _.isNil(client)) return Promise.resolve(null)
const { apiVersion, authHeader } = client
return axios.get(`https://rest.ciphertrace.com/api/${apiVersion}/${_.toLower(cryptoCode) !== 'btc' ? `${_.toLower(cryptoCode)}_` : ``}address/search?features=tx&address=${receivingAddress}`, {
return axios.get(`https://rest.ciphertrace.com/api/${apiVersion}/${_.toLower(cryptoCode) !== 'btc' ? `${_.toLower(cryptoCode)}_` : ``}address/search?features=tx&address=${receivingAddress}&mempool=true`, {
headers: authHeader
})
.then(res => {
@ -60,7 +60,7 @@ function getTransactionHash(account, cryptoCode, receivingAddress) {
})
}
function getInputAddresses(account, cryptoCode, txHashes) {
function getInputAddresses (account, cryptoCode, txHashes) {
const client = getClient(account)
if (!_.includes(_.toUpper(cryptoCode), SUPPORTED_COINS) || _.isNil(client)) return Promise.resolve(null)