ncornwell

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