Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
while ((doc = await streamReader.readAsync()) !== null) {
let individualTransfer = doc.payload
individualTransfer.payerFsp = payload.payerFsp
individualTransfer.payeeFsp = payload.payeeFsp
individualTransfer.amount = individualTransfer.transferAmount
delete individualTransfer.transferAmount
individualTransfer.expiration = payload.expiration
const bulkTransferAssociationRecord = {
transferId: individualTransfer.transferId,
bulkTransferId: payload.bulkTransferId,
bulkProcessingStateId: Enum.BulkProcessingState.RECEIVED
}
await BulkTransferService.bulkTransferAssociationCreate(bulkTransferAssociationRecord)
let dataUri = encodePayload(JSON.stringify(individualTransfer), headers['content-type'])
let msg = Object.assign({}, prepareHandlerMessageProtocol)
msg.value.id = messageId
msg.value.from = payload.payerFsp
msg.value.to = payload.payeeFsp
msg.value.content.headers = headers
msg.value.content.payload = dataUri
msg.value.metadata.event.id = message.value.metadata.event.id
msg.value.metadata.event.createdAt = new Date()
params = { message: msg, kafkaTopic, consumer }
const producer = { functionality: TransferEventType.PREPARE, action: TransferEventAction.BULK_PREPARE }
await Util.proceed(params, { consumerCommit, histTimerEnd, producer })
}
} catch (err) { // TODO: handle individual transfers streaming error
Logger.info(Util.breadcrumb(location, `callbackErrorInternal2--${actionLetter}6`))
Logger.info(Util.breadcrumb(location, `notImplemented`))