diff --git a/lib/cash-out/cash-out-low.js b/lib/cash-out/cash-out-low.js index 210270af..91130119 100644 --- a/lib/cash-out/cash-out-low.js +++ b/lib/cash-out/cash-out-low.js @@ -2,13 +2,14 @@ const _ = require('lodash/fp') const pgp = require('pg-promise')() const helper = require('./cash-out-helper') +const { anonymousCustomer } = require('../constants') const toDb = helper.toDb const toObj = helper.toObj const UPDATEABLE_FIELDS = ['txHash', 'txVersion', 'status', 'dispense', 'dispenseConfirmed', 'notified', 'redeem', 'phone', 'error', 'swept', 'publishedAt', 'confirmedAt', 'errorCode', - 'receivedCryptoAtoms', 'walletScore' ] + 'receivedCryptoAtoms', 'walletScore', 'customerId' ] module.exports = {upsert, update, insert} @@ -52,7 +53,15 @@ function diff (oldTx, newTx) { // We never null out an existing field if (oldTx && _.isNil(newTx[fieldKey])) return - updatedTx[fieldKey] = newTx[fieldKey] + switch (fieldKey) { + case 'customerId': + if (oldTx.customerId === anonymousCustomer.uuid) { + return updatedTx['customerId'] = newTx['customerId'] + } + return + default: + return updatedTx[fieldKey] = newTx[fieldKey] + } }) return updatedTx