def extractCommand()

in auditlog/src/main/scala/com/gerritforge/analytics/auditlog/spark/sql/udf/SparkExtractors.scala [41:53]

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

  def extractCommand(what: String, accessPath: String, httpMethod: String = null): String =
    accessPath match {
      case "SSH_COMMAND"          => extractOrElse(GERRIT_SSH_COMMAND, what, what)
      case "GIT"                  => extractOrElse(GIT_COMMAND, what, what)
      case "REST_API" | "UNKNOWN" => Option(httpMethod).getOrElse(what)
      case "JSON_RPC"             => what
      case null if what == "AUTH" => FAILED_SSH_AUTH
      case unexpected =>
        logger.warn(
          s"Unexpected access path '$unexpected' encountered when extracting command from '$what'"
        )
        what
    }