def highestDeletedSequenceNumber()

in core/src/main/scala/org/apache/pekko/persistence/cassandra/query/EventsByPersistenceIdStage.scala [85:104]

• 15 lines of code
• 7 McCabe index (conditional complexity)

    def highestDeletedSequenceNumber(persistenceId: String)(implicit ec: ExecutionContext): Future[Long] =
      executeStatement(selectDeletedToQuery.bind(persistenceId).setExecutionProfileName(profile)).map(r =>
        Option(r.one()).map(_.getLong("deleted_to")).getOrElse(0))

    private def executeStatement(statement: Statement[_]): Future[AsyncResultSet] =
      session.executeAsync(statement).asScala

  }

  private case object Continue
  private case object LookForMissingSeqNr

  private case class MissingSeqNr(deadline: Deadline, sawSeqNr: Long)

  private sealed trait QueryState
  private case object QueryIdle extends QueryState
  private final case class QueryInProgress(switchPartition: Boolean, fetchMore: Boolean, startTime: Long)
      extends QueryState
  private final case class QueryResult(resultSet: AsyncResultSet, empty: Boolean, switchPartition: Boolean)
      extends QueryState {