private def getStreamPosition()

in src/main/scala/com/gu/kinesis/ConsumerConfig.scala [127:139]

• 13 lines of code
• 4 McCabe index (conditional complexity)

  private def getStreamPosition(config: Config): Option[InitialPositionInStreamExtended] = {
    getStringOption(config, KeyInitialPosition)
      .map {
        case InitialPositionLatest =>
          InitialPositionInStreamExtended.newInitialPosition(InitialPositionInStream.LATEST)
        case InitialPositionTrimHorizon =>
          InitialPositionInStreamExtended.newInitialPosition(InitialPositionInStream.TRIM_HORIZON)
        case InitialPositionAtTimestamp =>
          InitialPositionInStreamExtended.newInitialPositionAtTimestamp(
            DateFormat.getInstance().parse(config.getString(KeyInitialPositionAtTimestampTime))
          )
      }
  }