private def prepareCassandraDirectory()

in cassandra-launcher/src/main/scala/org/apache/pekko/persistence/cassandra/testkit/CassandraLauncher.scala [303:317]

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

  private def prepareCassandraDirectory(cassandraDirectory: File, clean: Boolean): Unit = {
    if (clean) {
      try {
        deleteRecursive(cassandraDirectory)
      } catch {
        // deleteRecursive may throw AssertionError
        case e: AssertionError =>
          throw new CleanFailedException(e.getMessage, e)
        case NonFatal(e) => throw new CleanFailedException(e.getMessage, e)
      }
    }

    if (!cassandraDirectory.exists)
      require(cassandraDirectory.mkdirs(), s"Couldn't create Cassandra directory [$cassandraDirectory]")
  }