Extensible trade execution processor

gistfile1.scala

object ExtensibleTradeExecutionProcessor extends TradeExecutionProcessor {

  def process(requestId: String,
              executionPrice: BigDecimal,
              requestedTradeRepository: RequestedTradeRepository,
              priceMutators: Set[(RequestedTrade, BigDecimal) => BigDecimal]): Option[ExecutedTrade] =
    for {
      requestedTrade <- requestedTradeRepository.findById(requestId)
      reportedPrice <- priceMutators.foldLeft(executionPrice)((price, mutator) => mutator(requestedTrade, price)).some
    } yield
      ExecutedTrade(
        requestId = requestedTrade.id,
        executedPrice = executionPrice,
        reportedPrice = reportedPrice
      )

}

//In App Config
val tradeExecutionProcessor(requestedTradeRepository: RequestedTradeRepository,
                          priceMutators: Set[(RequestedTrade, BigDecimal)
                          ):(String, BigDecimal) => Option[ExecutedTrade] =
  ExtensibleTradeExecutionProcessor.proces(_, _, requestedTradeRepository priceMutators)