82 lines
2.5 KiB
JavaScript
82 lines
2.5 KiB
JavaScript
const _ = require('lodash/fp')
|
|
const uuid = require('uuid')
|
|
|
|
const logger = require('./logger')
|
|
const db = require('./db')
|
|
const ofac = require('./ofac/index')
|
|
|
|
function logSanctionsMatch (deviceId, customer, sanctionsId, alias) {
|
|
const sql = `insert into sanctions_logs
|
|
(id, device_id, sanctioned_id, sanctioned_alias_id, sanctioned_alias_full_name, customer_id)
|
|
values
|
|
($1, $2, $3, $4, $5, $6)`
|
|
|
|
return db.none(sql, [uuid.v4(), deviceId, sanctionsId, alias.id, alias.fullName, customer.id])
|
|
}
|
|
|
|
function logSanctionsMatches (deviceId, customer, results) {
|
|
const logAlias = resultId => alias => logSanctionsMatch(deviceId, customer, resultId, alias)
|
|
const logResult = result => _.map(logAlias(result.id), result.aliases)
|
|
|
|
return Promise.all(_.flatMap(logResult, results))
|
|
}
|
|
|
|
function matchOfac (deviceId, customer) {
|
|
return Promise.resolve()
|
|
.then(() => {
|
|
// Probably because we haven't asked for ID yet
|
|
if (!_.isPlainObject(customer.idCardData)) {
|
|
return true
|
|
}
|
|
|
|
const nameParts = {
|
|
firstName: customer.idCardData.firstName,
|
|
lastName: customer.idCardData.lastName
|
|
}
|
|
|
|
if (_.some(_.isNil, _.values(nameParts))) {
|
|
logger.error(new Error(`Insufficient idCardData while matching OFAC for: ${customer.id}`))
|
|
return true
|
|
}
|
|
|
|
const birthDate = customer.idCardData.dateOfBirth
|
|
|
|
if (_.isNil(birthDate)) {
|
|
logger.error(new Error(`No birth date while matching OFAC for: ${customer.id}`))
|
|
return true
|
|
}
|
|
|
|
const options = {
|
|
threshold: 0.85,
|
|
fullNameThreshold: 0.95,
|
|
debug: false
|
|
}
|
|
|
|
const results = ofac.match(nameParts, birthDate, options)
|
|
|
|
return logSanctionsMatches(deviceId, customer, results)
|
|
.then(() => !_.isEmpty(results))
|
|
})
|
|
}
|
|
|
|
// BACKWARDS_COMPATIBILITY 7.5
|
|
// machines before 7.5 need to test sanctionsActive here
|
|
function validateOfac (deviceId, sanctionsActive, customer) {
|
|
if (!sanctionsActive) return Promise.resolve(true)
|
|
if (customer.sanctionsOverride === 'blocked') return Promise.resolve(false)
|
|
if (customer.sanctionsOverride === 'verified') return Promise.resolve(true)
|
|
|
|
return matchOfac(deviceId, customer)
|
|
.then(didMatch => !didMatch)
|
|
}
|
|
|
|
function validationPatch (deviceId, sanctionsActive, customer) {
|
|
return validateOfac(deviceId, sanctionsActive, customer)
|
|
.then(sactions =>
|
|
_.isNil(customer.sanctions) || customer.sanctions !== sactions ?
|
|
{ sanctions } :
|
|
{}
|
|
)
|
|
}
|
|
|
|
module.exports = {validationPatch}
|