Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
const fspiopError = ErrorHandler.Factory.createFSPIOPError(ErrorHandler.Enums.FSPIOPErrorCodes.CLIENT_ERROR)
await Kafka.proceed(Config.KAFKA_CONFIG, params, { consumerCommit, fspiopError: fspiopError.toApiErrorObject(Config.ERROR_HANDLING), eventDetail, fromSwitch })
throw fspiopError
}
// ============================================================================================
Util.breadcrumb(location, { path: 'validationPassed' })
Logger.info(Util.breadcrumb(location, `callbackMessage--${actionLetter}4`))
message.value.content.payload = TransferObjectTransform.toFulfil(transfer)
await Kafka.proceed(Config.KAFKA_CONFIG, params, { consumerCommit, eventDetail, fromSwitch })
histTimerEnd({ success: true, fspId: Config.INSTRUMENTATION_METRICS_LABELS.fspId })
return true
} catch (err) {
histTimerEnd({ success: false, fspId: Config.INSTRUMENTATION_METRICS_LABELS.fspId })
const fspiopError = ErrorHandler.Factory.reformatFSPIOPError(err)
Logger.error(`${Util.breadcrumb(location)}::${err.message}--G0`)
const state = new EventSdk.EventStateMetadata(EventSdk.EventStatusType.failed, fspiopError.apiErrorCode.code, fspiopError.apiErrorCode.message)
await span.error(fspiopError, state)
await span.finish(fspiopError.message, state)
return true
} finally {
if (!span.isFinished) {
await span.finish()
}
}
}