만드는 것까지가 아니라
운영되는 상태까지 만듭니다.

@Component
@RequiredArgsConstructor
public class TransferExecutionHandler {

    private final TransferPersistHelper transferPersistHelper;
    private final DataTransferOutboxHelper dataTransferOutboxHelper;
    private final TransferDataMapper transferDataMapper;


    @Transactional
    public Transfer sendData(Transfer transfer, SourceContentData sourceContentData) {

        List<TransferRequestEvent> transferRequestEvents = transferPersistHelper.persistTransferLog(transfer,sourceContentData);

        for (TransferRequestEvent transferRequestEvent : transferRequestEvents) {

            DataTransferEventPayload dataTransferEventPayload =
                    transferDataMapper.transferRequestEventToDataTransferEventPayload(transferRequestEvent);

            dataTransferOutboxHelper.saveDataTransferOutboxMessage(dataTransferEventPayload,
                    UUID.randomUUID());

        }

        updateTransferSendResult(transfer);

        return transfer;
    }


    public void updateTransferSendResult(Transfer transfer) {
        transferPersistHelper.updateTransferSendResult(transfer);
    }

}