in src/main/java/org/openvasp/host/service/impl/VaspServiceImpl.java [323:345]
private void onTransferRequest(
@NonNull final TransferRequest message) {
val originator = message.getOriginator();
val originatorEntity = counterpartyService
.findByVaan(originator.getVaan())
.orElseGet(() -> counterpartyService.saveIncomingOriginator(originator));
val beneficiary = message.getBeneficiary();
val beneficiaryEntity = counterpartyService
.findByVaan(beneficiary.getVaan())
.orElseGet(() -> counterpartyService.saveIncomingBeneficiary(beneficiary));
transferService
.findBySessionId(message.getHeader().getSessionId())
.ifPresent(transferEntity -> {
transferEntity.setTrStatus(TransferStatus.TRANSFER_REQUESTED);
transferMapper.toEntity(message, transferEntity);
transferEntity.setOriginator(originatorEntity);
transferEntity.setBeneficiary(beneficiaryEntity);
transferService.save(transferEntity);
});
}