Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
} catch (err) {
await trx.rollback
throw err
}
})
} else {
await knex('transfer').insert(transferRecord)
try {
await knex('transferParticipant').insert(payerTransferParticipantRecord)
} catch (err) {
Logger.warn(`Payer transferParticipant insert error: ${err.message}`)
}
try {
await knex('transferParticipant').insert(payeeTransferParticipantRecord)
} catch (err) {
Logger.warn(`Payee transferParticipant insert error: ${err.message}`)
}
payerTransferParticipantRecord.name = payload.payerFsp
payeeTransferParticipantRecord.name = payload.payeeFsp
let transferExtensionsRecordList = []
if (payload.extensionList && payload.extensionList.extension) {
transferExtensionsRecordList = payload.extensionList.extension.map(ext => {
return {
transferId: payload.transferId,
key: ext.key,
value: ext.value
}
})
try {
await knex.batchInsert('transferExtension', transferExtensionsRecordList)
} catch (err) {
Logger.warn(`batchInsert transferExtension error: ${err.message}`)