Extensible trade execution processor

gistfile1.scala

trait ExtensibleTradeExecutionProcessor extends TradeExecutionProcessor {

  val requestedTradeRepository: RequestedTradeRepository
  val priceMutators: Set[(RequestedTrade, BigDecimal) => BigDecimal]

  def process(requestId: String, executionPrice: 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
      )
}

trait PriceMutators extends MarkupApplicator {

  val markingUpSymbol: String
  val symbolMarkup: BigDecimal

  val markupVolumeThreshold: Long
  val volumeMarkup: BigDecimal

  def symbolBasedPriceMutator(trade: RequestedTrade, executionPrice: BigDecimal): BigDecimal =
    (trade.symbol == markingUpSymbol)
      .option(addMarkup(trade.side, executionPrice, symbolMarkup))
      .getOrElse(executionPrice)

  def volumeThresholdPriceMutator(trade: RequestedTrade, executionPrice: BigDecimal): BigDecimal =
    (trade.volume <= markupVolumeThreshold)
      .option(addMarkup(trade.side, executionPrice, volumeMarkup))
      .getOrElse(executionPrice)
}