Prepare transfer

prepare-transfer.scala

def prepare(transferID: TransferID, transfer: Transfer): F[Branch.Vote[TransferFailure]] = {
  if (accountID === transfer.origin)
    Logger[F].debug(show"Preparing outgoing transfer $transferID: $transfer for account $accountID") >>
      account.prepareOutgoingTransfer(transferID, transfer)
        .onErrorRetryWithBackoff(Logger[F].warn(_)(show"Error preparing outgoing transfer $transferID, retrying in a bit"))
        .onLeftRetryWithBackoff { case Account.PendingOutgoingTransfer =>
          Logger[F].warn(show"Account $accountID has a pending outgoing transfer, retrying in a bit")
        }(retryParameters.onPendingTransfer)
        .flatMap {
          case Left(Account.Unknown) => Branch.Vote.Abort(TransferFailure.AccountNotFound(accountID)).pure[F]
          case Left(InsufficientFunds(missing)) => Branch.Vote.Abort(TransferFailure.InsufficientFunds(missing)).pure[F]
          case Left(Account.PendingOutgoingTransfer) => Branch.Vote.Abort(TransferFailure.OtherPendingTransfer).pure[F]
          case Right(_) => Branch.Vote.Commit.pure[F]
        }
  else
    Logger[F].debug(show"Preparing incoming $transferID: $transfer for account $accountID") >>
      account.prepareIncomingTransfer(transferID, transfer)
        .onErrorRetryWithBackoff(Logger[F].warn(_)(show"Error preparing incoming transfer $transferID, retrying in a bit"))
        .map {
          case Left(Account.Unknown) => Branch.Vote.Abort(TransferFailure.AccountNotFound(accountID))
          case Right(_) => Branch.Vote.Commit
        }
}