Transfer

transfer.scala

def transfer(from: AccountID, to: AccountID, amount: PosAmount): F[TransferFailure \/ Unit] =
  coordinator
    .create(TransferID.random, Transfer(from, to, amount), from, to)
    .use(_.pollForFinalStatus())
    .flatMap {
      case Status.Committed => ().asRight[TransferFailure].pure
      case Status.Aborted(reason) =>
        reason match {
          case AbortReason.Timeout =>
            EitherT.leftT(TransferFailure.Timeout: TransferFailure).value
          case AbortReason.Branches(reasons)    => EitherT.leftT(reasons.head).value
          case AbortReason.Client(Some(reason)) => EitherT.leftT(reason).value
          case AbortReason.Client(None) =>  new Exception("Transaction aborted by client without justification").raiseError[F, TransferFailure \/ Unit]
        }
      case Status.Failed(errors) =>
        Logger[F].error(show"Transaction failed: $errors") *> new Exception("Transaction failed due to branch error").raiseError[F, TransferFailure \/ Unit]
    }