private def zeroOrOneSnapshot()

in core/src/main/scala/org/apache/pekko/persistence/jdbc/snapshot/dao/DefaultSnapshotDao.scala [76:85]

• 9 lines of code
• 3 McCabe index (conditional complexity)

  private def zeroOrOneSnapshot(rows: Seq[SnapshotRow]): Option[(SnapshotMetadata, Any)] =
    rows.headOption.map(row => toSnapshotData(row).get) // throw is from a future map

  override def latestSnapshot(persistenceId: String): Future[Option[(SnapshotMetadata, Any)]] =
    db.run(queries.selectLatestByPersistenceId(persistenceId).result).flatMap { rows =>
      rows.headOption match {
        case Some(row) => Future.fromTry(toSnapshotData(row)).map(Option(_))
        case None      => Future.successful(None)
      }
    }